4 * Copyright (C) 2005 Mike Isely <isely@pobox.com>
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
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.
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
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>
32 static void pvr2_context_destroy(struct pvr2_context
*mp
)
34 if (mp
->hdw
) pvr2_hdw_destroy(mp
->hdw
);
35 pvr2_trace(PVR2_TRACE_STRUCT
,"Destroying pvr_main id=%p",mp
);
36 flush_workqueue(mp
->workqueue
);
37 destroy_workqueue(mp
->workqueue
);
42 static void pvr2_context_trigger_poll(struct pvr2_context
*mp
)
44 queue_work(mp
->workqueue
,&mp
->workpoll
);
48 static void pvr2_context_poll(struct pvr2_context
*mp
)
50 pvr2_context_enter(mp
); do {
51 pvr2_hdw_poll(mp
->hdw
);
52 } while (0); pvr2_context_exit(mp
);
56 static void pvr2_context_setup(struct pvr2_context
*mp
)
58 pvr2_context_enter(mp
); do {
59 if (!pvr2_hdw_dev_ok(mp
->hdw
)) break;
60 pvr2_hdw_setup(mp
->hdw
);
61 pvr2_hdw_setup_poll_trigger(
63 (void (*)(void *))pvr2_context_trigger_poll
,
65 if (!pvr2_hdw_dev_ok(mp
->hdw
)) break;
66 if (!pvr2_hdw_init_ok(mp
->hdw
)) break;
67 mp
->video_stream
.stream
= pvr2_hdw_get_video_stream(mp
->hdw
);
71 } while (0); pvr2_context_exit(mp
);
75 struct pvr2_context
*pvr2_context_create(
76 struct usb_interface
*intf
,
77 const struct usb_device_id
*devid
,
78 void (*setup_func
)(struct pvr2_context
*))
80 struct pvr2_context
*mp
= NULL
;
81 mp
= kmalloc(sizeof(*mp
),GFP_KERNEL
);
83 memset(mp
,0,sizeof(*mp
));
84 pvr2_trace(PVR2_TRACE_STRUCT
,"Creating pvr_main id=%p",mp
);
85 mp
->setup_func
= setup_func
;
86 mutex_init(&mp
->mutex
);
87 mp
->hdw
= pvr2_hdw_create(intf
,devid
);
89 pvr2_context_destroy(mp
);
94 mp
->workqueue
= create_singlethread_workqueue("pvrusb2");
95 INIT_WORK(&mp
->workinit
,(void (*)(void*))pvr2_context_setup
,mp
);
96 INIT_WORK(&mp
->workpoll
,(void (*)(void*))pvr2_context_poll
,mp
);
97 queue_work(mp
->workqueue
,&mp
->workinit
);
103 void pvr2_context_enter(struct pvr2_context
*mp
)
105 mutex_lock(&mp
->mutex
);
106 pvr2_trace(PVR2_TRACE_CREG
,"pvr2_context_enter(id=%p)",mp
);
110 void pvr2_context_exit(struct pvr2_context
*mp
)
112 int destroy_flag
= 0;
113 if (!(mp
->mc_first
|| !mp
->disconnect_flag
)) {
116 pvr2_trace(PVR2_TRACE_CREG
,"pvr2_context_exit(id=%p) outside",mp
);
117 mutex_unlock(&mp
->mutex
);
118 if (destroy_flag
) pvr2_context_destroy(mp
);
122 static void pvr2_context_run_checks(struct pvr2_context
*mp
)
124 struct pvr2_channel
*ch1
,*ch2
;
125 for (ch1
= mp
->mc_first
; ch1
; ch1
= ch2
) {
127 if (ch1
->check_func
) {
128 ch1
->check_func(ch1
);
134 void pvr2_context_disconnect(struct pvr2_context
*mp
)
136 pvr2_context_enter(mp
); do {
137 pvr2_hdw_disconnect(mp
->hdw
);
138 mp
->disconnect_flag
= !0;
139 pvr2_context_run_checks(mp
);
140 } while (0); pvr2_context_exit(mp
);
144 void pvr2_channel_init(struct pvr2_channel
*cp
,struct pvr2_context
*mp
)
149 cp
->mc_prev
= mp
->mc_last
;
151 mp
->mc_last
->mc_next
= cp
;
159 static void pvr2_channel_disclaim_stream(struct pvr2_channel
*cp
)
161 if (!cp
->stream
) return;
162 pvr2_stream_kill(cp
->stream
->stream
);
163 cp
->stream
->user
= NULL
;
168 void pvr2_channel_done(struct pvr2_channel
*cp
)
170 struct pvr2_context
*mp
= cp
->mc_head
;
171 pvr2_channel_disclaim_stream(cp
);
173 cp
->mc_next
->mc_prev
= cp
->mc_prev
;
175 mp
->mc_last
= cp
->mc_prev
;
178 cp
->mc_prev
->mc_next
= cp
->mc_next
;
180 mp
->mc_first
= cp
->mc_next
;
186 int pvr2_channel_claim_stream(struct pvr2_channel
*cp
,
187 struct pvr2_context_stream
*sp
)
190 pvr2_context_enter(cp
->mc_head
); do {
191 if (sp
== cp
->stream
) break;
196 pvr2_channel_disclaim_stream(cp
);
200 } while (0); pvr2_context_exit(cp
->mc_head
);
205 // This is the marker for the real beginning of a legitimate mpeg2 stream.
206 static char stream_sync_key
[] = {
207 0x00, 0x00, 0x01, 0xba,
210 struct pvr2_ioread
*pvr2_channel_create_mpeg_stream(
211 struct pvr2_context_stream
*sp
)
213 struct pvr2_ioread
*cp
;
214 cp
= pvr2_ioread_create();
215 if (!cp
) return NULL
;
216 pvr2_ioread_setup(cp
,sp
->stream
);
217 pvr2_ioread_set_sync_key(cp
,stream_sync_key
,sizeof(stream_sync_key
));
223 Stuff for Emacs to see, in order to encourage consistent editing style:
224 *** Local Variables: ***
226 *** fill-column: 75 ***
228 *** c-basic-offset: 8 ***