1 /*
2 * $Id$
3 *
4 * Copyright (C) 2005 Mike Isely <isely@pobox.com>
5 *
6 * This program is free software; you can redistribute it and/or modify
7 * it under the terms of the GNU General Public License as published by
8 * the Free Software Foundation; either version 2 of the License
9 *
10 * This program is distributed in the hope that it will be useful,
11 * but WITHOUT ANY WARRANTY; without even the implied warranty of
12 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
13 * GNU General Public License for more details.
14 *
15 * You should have received a copy of the GNU General Public License
16 * along with this program; if not, write to the Free Software
17 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
18 *
19 */
20
21 #include "pvrusb2-context.h"
22 #include "pvrusb2-io.h"
23 #include "pvrusb2-ioread.h"
24 #include "pvrusb2-hdw.h"
25 #include "pvrusb2-debug.h"
26 #include <linux/errno.h>
27 #include <linux/string.h>
28 #include <linux/slab.h>
29 #include <asm/semaphore.h>
30
31
32 static void pvr2_context_destroy(struct pvr2_context *mp)
33 {
34 pvr2_trace(PVR2_TRACE_STRUCT,"Destroying pvr_main id=%p",mp);
35 if (mp->hdw) pvr2_hdw_destroy(mp->hdw);
36 kfree(mp);
37 }
38
39
40 static void pvr2_context_state_check(struct pvr2_context *mp)
41 {
42 if (mp->init_flag) return;
43
44 switch (pvr2_hdw_get_state(mp->hdw)) {
45 case PVR2_STATE_WARM: break;
46 case PVR2_STATE_ERROR: break;
47 case PVR2_STATE_READY: break;
48 case PVR2_STATE_RUN: break;
49 default: return;
50 }
51
52 pvr2_context_enter(mp); do {
53 mp->init_flag = !0;
54 mp->video_stream.stream = pvr2_hdw_get_video_stream(mp->hdw);
55 if (mp->setup_func) {
56 mp->setup_func(mp);
57 }
58 } while (0); pvr2_context_exit(mp);
59 }
60
61
62 struct pvr2_context *pvr2_context_create(
63 struct usb_interface *intf,
64 const struct usb_device_id *devid,
65 void (*setup_func)(struct pvr2_context *))
66 {
67 struct pvr2_context *mp = NULL;
68 mp = kzalloc(sizeof(*mp),GFP_KERNEL);
69 if (!mp) goto done;
70 pvr2_trace(PVR2_TRACE_STRUCT,"Creating pvr_main id=%p",mp);
71 mp->setup_func = setup_func;
72 mutex_init(&mp->mutex);
73 mp->hdw = pvr2_hdw_create(intf,devid);
74 if (!mp->hdw) {
75 pvr2_context_destroy(mp);
76 mp = NULL;
77 goto done;
78 }
79 pvr2_hdw_set_state_callback(mp->hdw,
80 (void (*)(void *))pvr2_context_state_check,
81 mp);
82 pvr2_context_state_check(mp);
83 done:
84 return mp;
85 }
86
87
88 void pvr2_context_enter(struct pvr2_context *mp)
89 {
90 mutex_lock(&mp->mutex);
91 pvr2_trace(PVR2_TRACE_CREG,"pvr2_context_enter(id=%p)",mp);
92 }
93
94
95 void pvr2_context_exit(struct pvr2_context *mp)
96 {
97 int destroy_flag = 0;
98 if (!(mp->mc_first || !mp->disconnect_flag)) {
99 destroy_flag = !0;
100 }
101 pvr2_trace(PVR2_TRACE_CREG,"pvr2_context_exit(id=%p) outside",mp);
102 mutex_unlock(&mp->mutex);
103 if (destroy_flag) pvr2_context_destroy(mp);
104 }
105
106
107 static void pvr2_context_run_checks(struct pvr2_context *mp)
108 {
109 struct pvr2_channel *ch1,*ch2;
110 for (ch1 = mp->mc_first; ch1; ch1 = ch2) {
111 ch2 = ch1->mc_next;
112 if (ch1->check_func) {
113 ch1->check_func(ch1);
114 }
115 }
116 }
117
118
119 void pvr2_context_disconnect(struct pvr2_context *mp)
120 {
121 pvr2_context_enter(mp); do {
122 pvr2_hdw_disconnect(mp->hdw);
123 mp->disconnect_flag = !0;
124 pvr2_context_run_checks(mp);
125 } while (0); pvr2_context_exit(mp);
126 }
127
128
129 void pvr2_channel_init(struct pvr2_channel *cp,struct pvr2_context *mp)
130 {
131 cp->hdw = mp->hdw;
132 cp->mc_head = mp;
133 cp->mc_next = NULL;
134 cp->mc_prev = mp->mc_last;
135 if (mp->mc_last) {
136 mp->mc_last->mc_next = cp;
137 } else {
138 mp->mc_first = cp;
139 }
140 mp->mc_last = cp;
141 }
142
143
144 static void pvr2_channel_disclaim_stream(struct pvr2_channel *cp)
145 {
146 if (!cp->stream) return;
147 pvr2_stream_kill(cp->stream->stream);
148 cp->stream->user = NULL;
149 cp->stream = NULL;
150 }
151
152
153 void pvr2_channel_done(struct pvr2_channel *cp)
154 {
155 struct pvr2_context *mp = cp->mc_head;
156 pvr2_channel_disclaim_stream(cp);
157 if (cp->mc_next) {
158 cp->mc_next->mc_prev = cp->mc_prev;
159 } else {
160 mp->mc_last = cp->mc_prev;
161 }
162 if (cp->mc_prev) {
163 cp->mc_prev->mc_next = cp->mc_next;
164 } else {
165 mp->mc_first = cp->mc_next;
166 }
167 cp->hdw = NULL;
168 }
169
170
171 int pvr2_channel_claim_stream(struct pvr2_channel *cp,
172 struct pvr2_context_stream *sp)
173 {
174 int code = 0;
175 pvr2_context_enter(cp->mc_head); do {
176 if (sp == cp->stream) break;
177 if (sp->user) {
178 code = -EBUSY;
179 break;
180 }
181 pvr2_channel_disclaim_stream(cp);
182 if (!sp) break;
183 sp->user = cp;
184 cp->stream = sp;
185 } while (0); pvr2_context_exit(cp->mc_head);
186 return code;
187 }
188
189
190 // This is the marker for the real beginning of a legitimate mpeg2 stream.
191 static char stream_sync_key[] = {
192 0x00, 0x00, 0x01, 0xba,
193 };
194
195 struct pvr2_ioread *pvr2_channel_create_mpeg_stream(
196 struct pvr2_context_stream *sp)
197 {
198 struct pvr2_ioread *cp;
199 cp = pvr2_ioread_create();
200 if (!cp) return NULL;
201 pvr2_ioread_setup(cp,sp->stream);
202 pvr2_ioread_set_sync_key(cp,stream_sync_key,sizeof(stream_sync_key));
203 return cp;
204 }
205
206
207 /*
208 Stuff for Emacs to see, in order to encourage consistent editing style:
209 *** Local Variables: ***
210 *** mode: c ***
211 *** fill-column: 75 ***
212 *** tab-width: 8 ***
213 *** c-basic-offset: 8 ***
214 *** End: ***
215 */
216
|
This page was automatically generated by the
LXR engine.
|