1 /* $NetBSD: emdtv_dtv.c,v 1.17 2022/03/29 09:08:44 riastradh Exp $ */
2 
3 /*-
4  * Copyright (c) 2008, 2011 Jared D. McNeill <jmcneill@invisible.ca>
5  * All rights reserved.
6  *
7  * Redistribution and use in source and binary forms, with or without
8  * modification, are permitted provided that the following conditions
9  * are met:
10  * 1. Redistributions of source code must retain the above copyright
11  *    notice, this list of conditions and the following disclaimer.
12  * 2. Redistributions in binary form must reproduce the above copyright
13  *    notice, this list of conditions and the following disclaimer in the
14  *    documentation and/or other materials provided with the distribution.
15  *
16  * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
17  * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
18  * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
19  * PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
20  * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
21  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
22  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
23  * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
24  * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
25  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
26  * POSSIBILITY OF SUCH DAMAGE.
27  */
28 
29 #include <sys/cdefs.h>
30 __KERNEL_RCSID(0, "$NetBSD: emdtv_dtv.c,v 1.17 2022/03/29 09:08:44 riastradh Exp $");
31 
32 #include <sys/param.h>
33 #include <sys/systm.h>
34 #include <sys/device.h>
35 #include <sys/lwp.h>
36 #include <sys/conf.h>
37 
38 #include <dev/usb/usb.h>
39 #include <dev/usb/usbdi.h>
40 #include <dev/usb/usbdi_util.h>
41 #include <dev/usb/usbdivar.h>
42 #include <dev/usb/usbdevs.h>
43 
44 #include <dev/i2c/i2cvar.h>
45 
46 #include <dev/usb/emdtvvar.h>
47 #include <dev/usb/emdtvreg.h>
48 
49 static void                   emdtv_dtv_get_devinfo(void *,
50                                   struct dvb_frontend_info *);
51 static int                    emdtv_dtv_open(void *, int);
52 static void                   emdtv_dtv_close(void *);
53 static int                    emdtv_dtv_set_tuner(void *,
54                                   const struct dvb_frontend_parameters *);
55 static fe_status_t  emdtv_dtv_get_status(void *);
56 static uint16_t               emdtv_dtv_get_signal_strength(void *);
57 static uint16_t               emdtv_dtv_get_snr(void *);
58 static int                    emdtv_dtv_start_transfer(void *,
59                                   void (*)(void *, const struct dtv_payload *),
60                                   void *);
61 static int                    emdtv_dtv_stop_transfer(void *);
62 
63 static int                    emdtv_dtv_tuner_reset(void *);
64 
65 static void                   emdtv_dtv_isoc_startall(struct emdtv_softc *);
66 static int                    emdtv_dtv_isoc_start(struct emdtv_softc *,
67                                   struct emdtv_isoc_xfer *);
68 static void                   emdtv_dtv_isoc(struct usbd_xfer *, void *,
69                                   usbd_status);
70 
71 static const struct dtv_hw_if emdtv_dtv_if = {
72           .get_devinfo = emdtv_dtv_get_devinfo,
73           .open = emdtv_dtv_open,
74           .close = emdtv_dtv_close,
75           .set_tuner = emdtv_dtv_set_tuner,
76           .get_status = emdtv_dtv_get_status,
77           .get_signal_strength = emdtv_dtv_get_signal_strength,
78           .get_snr = emdtv_dtv_get_snr,
79           .start_transfer = emdtv_dtv_start_transfer,
80           .stop_transfer = emdtv_dtv_stop_transfer,
81 };
82 
83 void
emdtv_dtv_attach(struct emdtv_softc * sc)84 emdtv_dtv_attach(struct emdtv_softc *sc)
85 {
86           usb_endpoint_descriptor_t *ed;
87           usbd_status status;
88           int i;
89 
90           for (i = 0; i < EMDTV_NXFERS; i++) {
91                     sc->sc_ix[i].ix_altix = (i & 1) ?
92                         &sc->sc_ix[i - 1] : &sc->sc_ix[i + 1];
93                     sc->sc_ix[i].ix_sc = sc;
94           }
95 
96           ed = usbd_interface2endpoint_descriptor(sc->sc_iface, 3);
97           if (ed == NULL) {
98                     aprint_error_dev(sc->sc_dev, "couldn't find endpoint 3\n");
99                     return;
100           }
101           sc->sc_isoc_maxpacketsize = UGETW(ed->wMaxPacketSize);
102           sc->sc_isoc_buflen = sc->sc_isoc_maxpacketsize * EMDTV_NFRAMES;
103 
104           aprint_debug_dev(sc->sc_dev, "calling usbd_open_pipe, ep 0x%02x\n",
105               ed->bEndpointAddress);
106           status = usbd_open_pipe(sc->sc_iface,
107               ed->bEndpointAddress, USBD_EXCLUSIVE_USE|USBD_MPSAFE,
108               &sc->sc_isoc_pipe);
109           if (status != USBD_NORMAL_COMPLETION) {
110                     aprint_error_dev(sc->sc_dev, "couldn't open isoc pipe\n");
111                     usbd_set_interface(sc->sc_iface, 0);
112                     return;
113           }
114 
115           emdtv_write_1(sc, UR_GET_STATUS, 0x48, 0x00);
116           emdtv_write_1(sc, UR_GET_STATUS, 0x12, 0x77);
117           usbd_delay_ms(sc->sc_udev, 6);
118 
119           emdtv_gpio_ctl(sc, EMDTV_GPIO_ANALOG_ON, false);
120           emdtv_gpio_ctl(sc, EMDTV_GPIO_TS1_ON, true);
121           emdtv_gpio_ctl(sc, EMDTV_GPIO_TUNER1_ON, true);
122           emdtv_gpio_ctl(sc, EMDTV_GPIO_DEMOD1_RESET, true);
123           usbd_delay_ms(sc->sc_udev, 100);
124 
125           emdtv_dtv_rescan(sc, NULL, NULL);
126 }
127 
128 static void
emdtv_dtv_free_xfers(struct emdtv_softc * sc)129 emdtv_dtv_free_xfers(struct emdtv_softc *sc)
130 {
131 
132           for (size_t i = 0; i < EMDTV_NXFERS; i++)
133                     if (sc->sc_ix[i].ix_xfer) {
134                               usbd_destroy_xfer(sc->sc_ix[i].ix_xfer);
135                               sc->sc_ix[i].ix_xfer = NULL;
136                               sc->sc_ix[i].ix_buf = NULL;
137                     }
138 
139           return;
140 }
141 
142 void
emdtv_dtv_detach(struct emdtv_softc * sc,int flags)143 emdtv_dtv_detach(struct emdtv_softc *sc, int flags)
144 {
145 
146           sc->sc_streaming = false;
147 
148           if (sc->sc_xc3028)
149                     xc3028_close(sc->sc_xc3028);
150           if (sc->sc_lg3303)
151                     lg3303_close(sc->sc_lg3303);
152 
153           if (sc->sc_isoc_pipe) {
154                     usbd_abort_pipe(sc->sc_isoc_pipe);
155                     emdtv_dtv_free_xfers(sc);
156                     usbd_close_pipe(sc->sc_isoc_pipe);
157                     sc->sc_isoc_pipe = NULL;
158           }
159 }
160 
161 void
emdtv_dtv_rescan(struct emdtv_softc * sc,const char * ifattr,const int * locs)162 emdtv_dtv_rescan(struct emdtv_softc *sc, const char *ifattr, const int *locs)
163 {
164           struct dtv_attach_args daa;
165 
166           daa.hw = &emdtv_dtv_if;
167           daa.priv = sc;
168 
169           if (ifattr_match(ifattr, "dtvbus") && sc->sc_dtvdev == NULL)
170                     sc->sc_dtvdev = config_found(sc->sc_dev, &daa, dtv_print,
171                         CFARGS(.iattr = "dtvbus"));
172 }
173 
174 static void
emdtv_dtv_get_devinfo(void * priv,struct dvb_frontend_info * info)175 emdtv_dtv_get_devinfo(void *priv, struct dvb_frontend_info *info)
176 {
177           struct emdtv_softc *sc = priv;
178 
179           memset(info, 0, sizeof(*info));
180           strlcpy(info->name, sc->sc_board->eb_name, sizeof(info->name));
181           info->type = FE_ATSC;
182           info->frequency_min = 54000000;
183           info->frequency_max = 858000000;
184           info->frequency_stepsize = 62500;
185           info->caps = FE_CAN_8VSB;
186 }
187 
188 static int
emdtv_dtv_open(void * priv,int flags)189 emdtv_dtv_open(void *priv, int flags)
190 {
191           struct emdtv_softc *sc = priv;
192 
193           if (sc->sc_dying)
194                     return ENXIO;
195 
196           aprint_debug_dev(sc->sc_dev, "allocating isoc xfers (pktsz %d)\n",
197               sc->sc_isoc_maxpacketsize);
198 
199           for (size_t i = 0; i < EMDTV_NXFERS; i++) {
200                     int error = usbd_create_xfer(sc->sc_isoc_pipe,
201                         sc->sc_isoc_buflen, USBD_SHORT_XFER_OK, EMDTV_NFRAMES,
202                         &sc->sc_ix[i].ix_xfer);
203                     if (error)
204                               return error;
205                     sc->sc_ix[i].ix_buf = usbd_get_buffer(sc->sc_ix[i].ix_xfer);
206                     aprint_debug_dev(sc->sc_dev, "  ix[%zu] xfer %p buf %p\n",
207                         i, sc->sc_ix[i].ix_xfer, sc->sc_ix[i].ix_buf);
208           }
209 
210           switch (sc->sc_board->eb_tuner) {
211           case EMDTV_TUNER_XC3028:
212                     if (sc->sc_xc3028 == NULL) {
213                               sc->sc_xc3028 = xc3028_open(sc->sc_dev,
214                                   &sc->sc_i2c, 0x61 << 1, emdtv_dtv_tuner_reset, sc,
215                                   XC3028);
216                     }
217                     if (sc->sc_xc3028 == NULL) {
218                               aprint_error_dev(sc->sc_dev, "couldn't open xc3028\n");
219                               return ENXIO;
220                     }
221                     break;
222           case EMDTV_TUNER_XC3028L:
223                     if (sc->sc_xc3028 == NULL) {
224                               sc->sc_xc3028 = xc3028_open(sc->sc_dev,
225                                   &sc->sc_i2c, 0x61 << 1, emdtv_dtv_tuner_reset, sc,
226                                   XC3028L);
227                     }
228                     if (sc->sc_xc3028 == NULL) {
229                               aprint_error_dev(sc->sc_dev, "couldn't open xc3028l\n");
230                               return ENXIO;
231                     }
232                     break;
233           default:
234                     aprint_error_dev(sc->sc_dev, "unsupported tuner (%d)\n",
235                         sc->sc_board->eb_tuner);
236                     return EIO;
237           }
238 
239           switch (sc->sc_board->eb_demod) {
240           case EMDTV_DEMOD_LG3303:
241                     if (sc->sc_lg3303 == NULL) {
242                               sc->sc_lg3303 = lg3303_open(sc->sc_dev,
243                                   &sc->sc_i2c, 0x1c, 0);
244                     }
245                     if (sc->sc_lg3303 == NULL) {
246                               aprint_error_dev(sc->sc_dev, "couldn't open lg3303\n");
247                               return ENXIO;
248                     }
249                     break;
250           default:
251                     aprint_error_dev(sc->sc_dev, "unsupported demod (%d)\n",
252                         sc->sc_board->eb_demod);
253                     return EIO;
254           }
255 
256           return 0;
257 }
258 
259 static void
emdtv_dtv_close(void * priv)260 emdtv_dtv_close(void *priv)
261 {
262           struct emdtv_softc *sc = priv;
263 
264           emdtv_dtv_free_xfers(sc);
265 }
266 
267 static int
emdtv_dtv_set_tuner(void * priv,const struct dvb_frontend_parameters * params)268 emdtv_dtv_set_tuner(void *priv, const struct dvb_frontend_parameters *params)
269 {
270           struct emdtv_softc *sc = priv;
271           int error;
272 
273           /* Setup demod */
274           error = ENXIO;
275           if (sc->sc_lg3303)
276                     error = lg3303_set_modulation(sc->sc_lg3303,
277                         params->u.vsb.modulation);
278           if (error)
279                     return error;
280 
281           /* Setup tuner */
282           error = ENXIO;
283           if (sc->sc_xc3028)
284                     error = xc3028_tune_dtv(sc->sc_xc3028, params);
285 
286           return error;
287 }
288 
289 static fe_status_t
emdtv_dtv_get_status(void * priv)290 emdtv_dtv_get_status(void *priv)
291 {
292           struct emdtv_softc *sc = priv;
293 
294           if (sc->sc_lg3303)
295                     return lg3303_get_dtv_status(sc->sc_lg3303);
296 
297           return 0;
298 }
299 
300 uint16_t
emdtv_dtv_get_signal_strength(void * priv)301 emdtv_dtv_get_signal_strength(void *priv)
302 {
303           struct emdtv_softc *sc = priv;
304 
305           if (sc->sc_lg3303)
306                     return lg3303_get_signal_strength(sc->sc_lg3303);
307 
308           return 0;
309 }
310 
311 uint16_t
emdtv_dtv_get_snr(void * priv)312 emdtv_dtv_get_snr(void *priv)
313 {
314           struct emdtv_softc *sc = priv;
315 
316           if (sc->sc_lg3303)
317                     return lg3303_get_snr(sc->sc_lg3303);
318 
319           return 0;
320 }
321 
322 static int
emdtv_dtv_start_transfer(void * priv,void (* cb)(void *,const struct dtv_payload *),void * arg)323 emdtv_dtv_start_transfer(void *priv,
324     void (*cb)(void *, const struct dtv_payload *), void *arg)
325 {
326           struct emdtv_softc *sc = priv;
327           int s;
328 
329           s = splusb();
330 
331           sc->sc_streaming = true;
332           sc->sc_dtvsubmitcb = cb;
333           sc->sc_dtvsubmitarg = arg;
334 
335           aprint_debug_dev(sc->sc_dev, "starting isoc transactions\n");
336 
337           emdtv_dtv_isoc_startall(sc);
338           splx(s);
339 
340           return 0;
341 }
342 
343 static int
emdtv_dtv_stop_transfer(void * priv)344 emdtv_dtv_stop_transfer(void *priv)
345 {
346           struct emdtv_softc *sc = priv;
347 
348           aprint_debug_dev(sc->sc_dev, "stopping stream\n");
349 
350           sc->sc_streaming = false;
351 
352           KERNEL_LOCK(1, curlwp);
353           if (sc->sc_isoc_pipe != NULL)
354                     usbd_abort_pipe(sc->sc_isoc_pipe);
355           KERNEL_UNLOCK_ONE(curlwp);
356 
357           sc->sc_dtvsubmitcb = NULL;
358           sc->sc_dtvsubmitarg = NULL;
359 
360           return 0;
361 }
362 
363 static void
emdtv_dtv_isoc_startall(struct emdtv_softc * sc)364 emdtv_dtv_isoc_startall(struct emdtv_softc *sc)
365 {
366           int i;
367 
368           if (sc->sc_streaming == false || sc->sc_dying == true)
369                     return;
370 
371           for (i = 0; i < EMDTV_NXFERS; i += 2)
372                     emdtv_dtv_isoc_start(sc, &sc->sc_ix[i]);
373 }
374 
375 static int
emdtv_dtv_isoc_start(struct emdtv_softc * sc,struct emdtv_isoc_xfer * ix)376 emdtv_dtv_isoc_start(struct emdtv_softc *sc, struct emdtv_isoc_xfer *ix)
377 {
378           int i;
379 
380           if (sc->sc_isoc_pipe == NULL)
381                     return EIO;
382 
383           for (i = 0; i < EMDTV_NFRAMES; i++)
384                     ix->ix_frlengths[i] = sc->sc_isoc_maxpacketsize;
385 
386           usbd_setup_isoc_xfer(ix->ix_xfer,
387                                    ix,
388                                    ix->ix_frlengths,
389                                    EMDTV_NFRAMES,
390                                    USBD_SHORT_XFER_OK,
391                                    emdtv_dtv_isoc);
392 
393           KERNEL_LOCK(1, curlwp);
394           usbd_transfer(ix->ix_xfer);
395           KERNEL_UNLOCK_ONE(curlwp);
396 
397           return 0;
398 }
399 
400 static void
emdtv_dtv_isoc(struct usbd_xfer * xfer,void * priv,usbd_status err)401 emdtv_dtv_isoc(struct usbd_xfer *xfer, void * priv,
402     usbd_status err)
403 {
404           struct emdtv_isoc_xfer *ix = priv;
405           struct emdtv_softc *sc = ix->ix_sc;
406           struct dtv_payload payload;
407           struct usbd_pipe *isoc = sc->sc_isoc_pipe;
408           uint32_t len;
409           uint8_t *buf;
410           int i;
411 
412           KASSERT(xfer == ix->ix_xfer);
413 
414           if (sc->sc_dying || sc->sc_dtvsubmitcb == NULL)
415                     return;
416 
417           if (err) {
418                     if (err == USBD_STALLED) {
419                               usbd_clear_endpoint_stall_async(isoc);
420                               goto resched;
421                     }
422                     return;
423           }
424 
425           usbd_get_xfer_status(xfer, NULL, NULL, &len, NULL);
426 
427           if (len == 0)
428                     goto resched;
429 
430           buf = usbd_get_buffer(xfer);
431           if (buf == NULL)
432                     goto resched;
433 
434           for (i = 0; i < EMDTV_NFRAMES; i++, buf += sc->sc_isoc_maxpacketsize) {
435                     if (ix->ix_frlengths[i] == 0)
436                               continue;
437                     payload.data = buf;
438                     payload.size = ix->ix_frlengths[i];
439                     sc->sc_dtvsubmitcb(sc->sc_dtvsubmitarg, &payload);
440           }
441 
442 resched:
443           emdtv_dtv_isoc_start(sc, ix->ix_altix);
444 }
445 
446 static int
emdtv_dtv_tuner_reset(void * opaque)447 emdtv_dtv_tuner_reset(void *opaque)
448 {
449           struct emdtv_softc *sc = opaque;
450           emdtv_gpio_ctl(sc, EMDTV_GPIO_TUNER1_RESET, true);
451           return 0;
452 }
453