Merge tag 'for-linus-20160324' of git://git.infradead.org/linux-mtd
[deliverable/linux.git] / drivers / media / usb / dvb-usb / dvb-usb-dvb.c
CommitLineData
776338e1
JS
1/* dvb-usb-dvb.c is part of the DVB USB library.
2 *
99e44da7 3 * Copyright (C) 2004-6 Patrick Boettcher (patrick.boettcher@posteo.de)
776338e1
JS
4 * see dvb-usb-init.c for copyright information.
5 *
6 * This file contains functions for initializing and handling the
7 * linux-dvb API.
8 */
9#include "dvb-usb-common.h"
41b44e35 10#include <media/media-device.h>
776338e1 11
4d43e13f 12/* does the complete input transfer handling */
776338e1
JS
13static int dvb_usb_ctrl_feed(struct dvb_demux_feed *dvbdmxfeed, int onoff)
14{
4d43e13f 15 struct dvb_usb_adapter *adap = dvbdmxfeed->demux->priv;
c8b7ced3 16 int newfeedcount, ret;
776338e1 17
4d43e13f 18 if (adap == NULL)
776338e1
JS
19 return -ENODEV;
20
2d04c13a
MK
21 if ((adap->active_fe < 0) ||
22 (adap->active_fe >= adap->num_frontends_initialized)) {
77eed219
MK
23 return -EINVAL;
24 }
25
4d43e13f 26 newfeedcount = adap->feedcount + (onoff ? 1 : -1);
776338e1 27
4d43e13f 28 /* stop feed before setting a new pid if there will be no pid anymore */
776338e1
JS
29 if (newfeedcount == 0) {
30 deb_ts("stop feeding\n");
77eed219 31 usb_urb_kill(&adap->fe_adap[adap->active_fe].stream);
776338e1 32
77eed219
MK
33 if (adap->props.fe[adap->active_fe].streaming_ctrl != NULL) {
34 ret = adap->props.fe[adap->active_fe].streaming_ctrl(adap, 0);
dca6b74b
MP
35 if (ret < 0) {
36 err("error while stopping stream.");
c8b7ced3 37 return ret;
dca6b74b 38 }
c8b7ced3 39 }
776338e1
JS
40 }
41
4d43e13f 42 adap->feedcount = newfeedcount;
776338e1
JS
43
44 /* activate the pid on the device specific pid_filter */
2b7a7c30
MK
45 deb_ts("setting pid (%s): %5d %04x at index %d '%s'\n",
46 adap->fe_adap[adap->active_fe].pid_filtering ?
47 "yes" : "no", dvbdmxfeed->pid, dvbdmxfeed->pid,
48 dvbdmxfeed->index, onoff ? "on" : "off");
77eed219
MK
49 if (adap->props.fe[adap->active_fe].caps & DVB_USB_ADAP_HAS_PID_FILTER &&
50 adap->fe_adap[adap->active_fe].pid_filtering &&
51 adap->props.fe[adap->active_fe].pid_filter != NULL)
52 adap->props.fe[adap->active_fe].pid_filter(adap, dvbdmxfeed->index, dvbdmxfeed->pid, onoff);
776338e1
JS
53
54 /* start the feed if this was the first feed and there is still a feed
55 * for reception.
56 */
4d43e13f 57 if (adap->feedcount == onoff && adap->feedcount > 0) {
8126fdbc 58 deb_ts("submitting all URBs\n");
77eed219 59 usb_urb_submit(&adap->fe_adap[adap->active_fe].stream);
776338e1
JS
60
61 deb_ts("controlling pid parser\n");
77eed219
MK
62 if (adap->props.fe[adap->active_fe].caps & DVB_USB_ADAP_HAS_PID_FILTER &&
63 adap->props.fe[adap->active_fe].caps &
c8b7ced3 64 DVB_USB_ADAP_PID_FILTER_CAN_BE_TURNED_OFF &&
77eed219
MK
65 adap->props.fe[adap->active_fe].pid_filter_ctrl != NULL) {
66 ret = adap->props.fe[adap->active_fe].pid_filter_ctrl(adap,
67 adap->fe_adap[adap->active_fe].pid_filtering);
c8b7ced3 68 if (ret < 0) {
776338e1 69 err("could not handle pid_parser");
c8b7ced3
MP
70 return ret;
71 }
72 }
776338e1 73 deb_ts("start feeding\n");
77eed219
MK
74 if (adap->props.fe[adap->active_fe].streaming_ctrl != NULL) {
75 ret = adap->props.fe[adap->active_fe].streaming_ctrl(adap, 1);
c8b7ced3 76 if (ret < 0) {
776338e1 77 err("error while enabling fifo.");
c8b7ced3 78 return ret;
776338e1 79 }
c8b7ced3 80 }
776338e1 81
776338e1
JS
82 }
83 return 0;
84}
85
86static int dvb_usb_start_feed(struct dvb_demux_feed *dvbdmxfeed)
87{
e68c2fe6
LB
88 deb_ts("start pid: 0x%04x, feedtype: %d\n", dvbdmxfeed->pid,
89 dvbdmxfeed->type);
90 return dvb_usb_ctrl_feed(dvbdmxfeed, 1);
776338e1
JS
91}
92
93static int dvb_usb_stop_feed(struct dvb_demux_feed *dvbdmxfeed)
94{
95 deb_ts("stop pid: 0x%04x, feedtype: %d\n", dvbdmxfeed->pid, dvbdmxfeed->type);
e68c2fe6 96 return dvb_usb_ctrl_feed(dvbdmxfeed, 0);
776338e1
JS
97}
98
9f806795 99static int dvb_usb_media_device_init(struct dvb_usb_adapter *adap)
496ccf92
RLLC
100{
101#ifdef CONFIG_MEDIA_CONTROLLER_DVB
496ccf92 102 struct media_device *mdev;
a3dfc6d9 103 struct dvb_usb_device *d = adap->dev;
496ccf92 104 struct usb_device *udev = d->udev;
496ccf92 105
6cf5dad1
MCC
106 mdev = kzalloc(sizeof(*mdev), GFP_KERNEL);
107 if (!mdev)
108 return -ENOMEM;
109
110 media_device_usb_init(mdev, udev, d->desc->name);
9832e155 111
89a2c1d6 112 dvb_register_media_controller(&adap->dvb_adap, mdev);
496ccf92
RLLC
113
114 dev_info(&d->udev->dev, "media controller created\n");
496ccf92 115#endif
9f806795 116 return 0;
496ccf92
RLLC
117}
118
9f806795 119static int dvb_usb_media_device_register(struct dvb_usb_adapter *adap)
9832e155
JMC
120{
121#ifdef CONFIG_MEDIA_CONTROLLER_DVB
9f806795
MCC
122 return media_device_register(adap->dvb_adap.mdev);
123#else
124 return 0;
9832e155
JMC
125#endif
126}
127
a3dfc6d9 128static void dvb_usb_media_device_unregister(struct dvb_usb_adapter *adap)
496ccf92
RLLC
129{
130#ifdef CONFIG_MEDIA_CONTROLLER_DVB
a3dfc6d9 131 if (!adap->dvb_adap.mdev)
496ccf92
RLLC
132 return;
133
a3dfc6d9 134 media_device_unregister(adap->dvb_adap.mdev);
9832e155 135 media_device_cleanup(adap->dvb_adap.mdev);
a3dfc6d9
MCC
136 kfree(adap->dvb_adap.mdev);
137 adap->dvb_adap.mdev = NULL;
496ccf92
RLLC
138#endif
139}
140
78e92006 141int dvb_usb_adapter_dvb_init(struct dvb_usb_adapter *adap, short *adapter_nums)
776338e1 142{
77eed219 143 int i;
78e92006
JG
144 int ret = dvb_register_adapter(&adap->dvb_adap, adap->dev->desc->name,
145 adap->dev->owner, &adap->dev->udev->dev,
146 adapter_nums);
776338e1 147
78e92006 148 if (ret < 0) {
776338e1
JS
149 deb_info("dvb_register_adapter failed: error %d", ret);
150 goto err;
151 }
4d43e13f
PB
152 adap->dvb_adap.priv = adap;
153
9f806795
MCC
154 ret = dvb_usb_media_device_init(adap);
155 if (ret < 0) {
156 deb_info("dvb_usb_media_device_init failed: error %d", ret);
157 goto err_mc;
158 }
496ccf92 159
4d43e13f 160 if (adap->dev->props.read_mac_address) {
e68c2fe6
LB
161 if (adap->dev->props.read_mac_address(adap->dev, adap->dvb_adap.proposed_mac) == 0)
162 info("MAC address: %pM", adap->dvb_adap.proposed_mac);
776338e1
JS
163 else
164 err("MAC address reading failed.");
165 }
166
167
4d43e13f
PB
168 adap->demux.dmx.capabilities = DMX_TS_FILTERING | DMX_SECTION_FILTERING;
169 adap->demux.priv = adap;
776338e1 170
77eed219
MK
171 adap->demux.filternum = 0;
172 for (i = 0; i < adap->props.num_frontends; i++) {
173 if (adap->demux.filternum < adap->fe_adap[i].max_feed_count)
174 adap->demux.filternum = adap->fe_adap[i].max_feed_count;
175 }
176 adap->demux.feednum = adap->demux.filternum;
4d43e13f
PB
177 adap->demux.start_feed = dvb_usb_start_feed;
178 adap->demux.stop_feed = dvb_usb_stop_feed;
179 adap->demux.write_to_decoder = NULL;
180 if ((ret = dvb_dmx_init(&adap->demux)) < 0) {
e68c2fe6 181 err("dvb_dmx_init failed: error %d", ret);
776338e1
JS
182 goto err_dmx;
183 }
184
4d43e13f
PB
185 adap->dmxdev.filternum = adap->demux.filternum;
186 adap->dmxdev.demux = &adap->demux.dmx;
187 adap->dmxdev.capabilities = 0;
188 if ((ret = dvb_dmxdev_init(&adap->dmxdev, &adap->dvb_adap)) < 0) {
e68c2fe6 189 err("dvb_dmxdev_init failed: error %d", ret);
776338e1
JS
190 goto err_dmx_dev;
191 }
192
60826f02
JN
193 if ((ret = dvb_net_init(&adap->dvb_adap, &adap->dvb_net,
194 &adap->demux.dmx)) < 0) {
e68c2fe6 195 err("dvb_net_init failed: error %d", ret);
60826f02
JN
196 goto err_net_init;
197 }
776338e1 198
4d43e13f 199 adap->state |= DVB_USB_ADAP_STATE_DVB;
8397703e
TP
200 return 0;
201
60826f02
JN
202err_net_init:
203 dvb_dmxdev_release(&adap->dmxdev);
776338e1 204err_dmx_dev:
4d43e13f 205 dvb_dmx_release(&adap->demux);
776338e1 206err_dmx:
a3dfc6d9 207 dvb_usb_media_device_unregister(adap);
9f806795 208err_mc:
4d43e13f 209 dvb_unregister_adapter(&adap->dvb_adap);
776338e1
JS
210err:
211 return ret;
776338e1
JS
212}
213
4d43e13f 214int dvb_usb_adapter_dvb_exit(struct dvb_usb_adapter *adap)
776338e1 215{
4d43e13f 216 if (adap->state & DVB_USB_ADAP_STATE_DVB) {
776338e1 217 deb_info("unregistering DVB part\n");
4d43e13f
PB
218 dvb_net_release(&adap->dvb_net);
219 adap->demux.dmx.close(&adap->demux.dmx);
220 dvb_dmxdev_release(&adap->dmxdev);
221 dvb_dmx_release(&adap->demux);
a3dfc6d9 222 dvb_usb_media_device_unregister(adap);
4d43e13f
PB
223 dvb_unregister_adapter(&adap->dvb_adap);
224 adap->state &= ~DVB_USB_ADAP_STATE_DVB;
776338e1
JS
225 }
226 return 0;
227}
228
77eed219
MK
229static int dvb_usb_set_active_fe(struct dvb_frontend *fe, int onoff)
230{
231 struct dvb_usb_adapter *adap = fe->dvb->priv;
232
233 int ret = (adap->props.frontend_ctrl) ?
234 adap->props.frontend_ctrl(fe, onoff) : 0;
235
236 if (ret < 0) {
237 err("frontend_ctrl request failed");
238 return ret;
239 }
240 if (onoff)
241 adap->active_fe = fe->id;
242
243 return 0;
244}
245
776338e1
JS
246static int dvb_usb_fe_wakeup(struct dvb_frontend *fe)
247{
4d43e13f 248 struct dvb_usb_adapter *adap = fe->dvb->priv;
776338e1 249
4d43e13f 250 dvb_usb_device_power_ctrl(adap->dev, 1);
776338e1 251
77eed219 252 dvb_usb_set_active_fe(fe, 1);
9bd9e3bd 253
77eed219
MK
254 if (adap->fe_adap[fe->id].fe_init)
255 adap->fe_adap[fe->id].fe_init(fe);
776338e1
JS
256
257 return 0;
258}
259
260static int dvb_usb_fe_sleep(struct dvb_frontend *fe)
261{
4d43e13f 262 struct dvb_usb_adapter *adap = fe->dvb->priv;
776338e1 263
77eed219
MK
264 if (adap->fe_adap[fe->id].fe_sleep)
265 adap->fe_adap[fe->id].fe_sleep(fe);
9bd9e3bd 266
77eed219 267 dvb_usb_set_active_fe(fe, 0);
776338e1 268
4d43e13f 269 return dvb_usb_device_power_ctrl(adap->dev, 0);
776338e1
JS
270}
271
4d43e13f 272int dvb_usb_adapter_frontend_init(struct dvb_usb_adapter *adap)
776338e1 273{
77eed219 274 int ret, i;
9bd9e3bd 275
77eed219
MK
276 /* register all given adapter frontends */
277 for (i = 0; i < adap->props.num_frontends; i++) {
9bd9e3bd 278
77eed219
MK
279 if (adap->props.fe[i].frontend_attach == NULL) {
280 err("strange: '%s' #%d,%d "
281 "doesn't want to attach a frontend.",
282 adap->dev->desc->name, adap->id, i);
9bd9e3bd 283
77eed219
MK
284 return 0;
285 }
776338e1 286
77eed219
MK
287 ret = adap->props.fe[i].frontend_attach(adap);
288 if (ret || adap->fe_adap[i].fe == NULL) {
9bd9e3bd
AP
289 /* only print error when there is no FE at all */
290 if (i == 0)
291 err("no frontend was attached by '%s'",
292 adap->dev->desc->name);
293
294 return 0;
295 }
776338e1 296
77eed219 297 adap->fe_adap[i].fe->id = i;
9bd9e3bd
AP
298
299 /* re-assign sleep and wakeup functions */
77eed219
MK
300 adap->fe_adap[i].fe_init = adap->fe_adap[i].fe->ops.init;
301 adap->fe_adap[i].fe->ops.init = dvb_usb_fe_wakeup;
302 adap->fe_adap[i].fe_sleep = adap->fe_adap[i].fe->ops.sleep;
303 adap->fe_adap[i].fe->ops.sleep = dvb_usb_fe_sleep;
9bd9e3bd 304
77eed219 305 if (dvb_register_frontend(&adap->dvb_adap, adap->fe_adap[i].fe)) {
9bd9e3bd 306 err("Frontend %d registration failed.", i);
77eed219
MK
307 dvb_frontend_detach(adap->fe_adap[i].fe);
308 adap->fe_adap[i].fe = NULL;
9bd9e3bd
AP
309 /* In error case, do not try register more FEs,
310 * still leaving already registered FEs alive. */
311 if (i == 0)
312 return -ENODEV;
313 else
314 return 0;
776338e1 315 }
5a19f312
PB
316
317 /* only attach the tuner if the demod is there */
77eed219
MK
318 if (adap->props.fe[i].tuner_attach != NULL)
319 adap->props.fe[i].tuner_attach(adap);
320
321 adap->num_frontends_initialized++;
9bd9e3bd 322 }
0d3ab841
MCC
323 if (ret)
324 return ret;
776338e1 325
0230d60e 326 ret = dvb_create_media_graph(&adap->dvb_adap, true);
9f806795
MCC
327 if (ret)
328 return ret;
496ccf92 329
9f806795 330 ret = dvb_usb_media_device_register(adap);
9832e155 331
0d3ab841 332 return ret;
776338e1
JS
333}
334
4d43e13f 335int dvb_usb_adapter_frontend_exit(struct dvb_usb_adapter *adap)
776338e1 336{
77eed219 337 int i = adap->num_frontends_initialized - 1;
9bd9e3bd
AP
338
339 /* unregister all given adapter frontends */
9bd9e3bd 340 for (; i >= 0; i--) {
77eed219
MK
341 if (adap->fe_adap[i].fe != NULL) {
342 dvb_unregister_frontend(adap->fe_adap[i].fe);
343 dvb_frontend_detach(adap->fe_adap[i].fe);
9bd9e3bd 344 }
4e66c97c 345 }
77eed219 346 adap->num_frontends_initialized = 0;
9bd9e3bd 347
776338e1
JS
348 return 0;
349}
This page took 0.9115 seconds and 5 git commands to generate.