Linux Audio

Check our new training course

Loading...
v6.8
  1// SPDX-License-Identifier: GPL-2.0-only
  2/*
  3 * phonet.c -- USB CDC Phonet host driver
  4 *
  5 * Copyright (C) 2008-2009 Nokia Corporation. All rights reserved.
  6 *
  7 * Author: RĂ©mi Denis-Courmont
 
 
 
 
 
 
 
 
 
 
 
 
 
 
  8 */
  9
 10#include <linux/kernel.h>
 11#include <linux/mm.h>
 12#include <linux/module.h>
 13#include <linux/gfp.h>
 14#include <linux/usb.h>
 15#include <linux/usb/cdc.h>
 16#include <linux/netdevice.h>
 17#include <linux/if_arp.h>
 18#include <linux/if_phonet.h>
 19#include <linux/phonet.h>
 20
 21#define PN_MEDIA_USB	0x1B
 22
 23static const unsigned rxq_size = 17;
 24
 25struct usbpn_dev {
 26	struct net_device	*dev;
 27
 28	struct usb_interface	*intf, *data_intf;
 29	struct usb_device	*usb;
 30	unsigned int		tx_pipe, rx_pipe;
 31	u8 active_setting;
 32	u8 disconnected;
 33
 34	unsigned		tx_queue;
 35	spinlock_t		tx_lock;
 36
 37	spinlock_t		rx_lock;
 38	struct sk_buff		*rx_skb;
 39	struct urb		*urbs[];
 40};
 41
 42static void tx_complete(struct urb *req);
 43static void rx_complete(struct urb *req);
 44
 45/*
 46 * Network device callbacks
 47 */
 48static netdev_tx_t usbpn_xmit(struct sk_buff *skb, struct net_device *dev)
 49{
 50	struct usbpn_dev *pnd = netdev_priv(dev);
 51	struct urb *req = NULL;
 52	unsigned long flags;
 53	int err;
 54
 55	if (skb->protocol != htons(ETH_P_PHONET))
 56		goto drop;
 57
 58	req = usb_alloc_urb(0, GFP_ATOMIC);
 59	if (!req)
 60		goto drop;
 61	usb_fill_bulk_urb(req, pnd->usb, pnd->tx_pipe, skb->data, skb->len,
 62				tx_complete, skb);
 63	req->transfer_flags = URB_ZERO_PACKET;
 64	err = usb_submit_urb(req, GFP_ATOMIC);
 65	if (err) {
 66		usb_free_urb(req);
 67		goto drop;
 68	}
 69
 70	spin_lock_irqsave(&pnd->tx_lock, flags);
 71	pnd->tx_queue++;
 72	if (pnd->tx_queue >= dev->tx_queue_len)
 73		netif_stop_queue(dev);
 74	spin_unlock_irqrestore(&pnd->tx_lock, flags);
 75	return NETDEV_TX_OK;
 76
 77drop:
 78	dev_kfree_skb(skb);
 79	dev->stats.tx_dropped++;
 80	return NETDEV_TX_OK;
 81}
 82
 83static void tx_complete(struct urb *req)
 84{
 85	struct sk_buff *skb = req->context;
 86	struct net_device *dev = skb->dev;
 87	struct usbpn_dev *pnd = netdev_priv(dev);
 88	int status = req->status;
 89	unsigned long flags;
 90
 91	switch (status) {
 92	case 0:
 93		dev->stats.tx_bytes += skb->len;
 94		break;
 95
 96	case -ENOENT:
 97	case -ECONNRESET:
 98	case -ESHUTDOWN:
 99		dev->stats.tx_aborted_errors++;
100		fallthrough;
101	default:
102		dev->stats.tx_errors++;
103		dev_dbg(&dev->dev, "TX error (%d)\n", status);
104	}
105	dev->stats.tx_packets++;
106
107	spin_lock_irqsave(&pnd->tx_lock, flags);
108	pnd->tx_queue--;
109	netif_wake_queue(dev);
110	spin_unlock_irqrestore(&pnd->tx_lock, flags);
111
112	dev_kfree_skb_any(skb);
113	usb_free_urb(req);
114}
115
116static int rx_submit(struct usbpn_dev *pnd, struct urb *req, gfp_t gfp_flags)
117{
118	struct net_device *dev = pnd->dev;
119	struct page *page;
120	int err;
121
122	page = __dev_alloc_page(gfp_flags | __GFP_NOMEMALLOC);
123	if (!page)
124		return -ENOMEM;
125
126	usb_fill_bulk_urb(req, pnd->usb, pnd->rx_pipe, page_address(page),
127				PAGE_SIZE, rx_complete, dev);
128	req->transfer_flags = 0;
129	err = usb_submit_urb(req, gfp_flags);
130	if (unlikely(err)) {
131		dev_dbg(&dev->dev, "RX submit error (%d)\n", err);
132		put_page(page);
133	}
134	return err;
135}
136
137static void rx_complete(struct urb *req)
138{
139	struct net_device *dev = req->context;
140	struct usbpn_dev *pnd = netdev_priv(dev);
141	struct page *page = virt_to_page(req->transfer_buffer);
142	struct sk_buff *skb;
143	unsigned long flags;
144	int status = req->status;
145
146	switch (status) {
147	case 0:
148		spin_lock_irqsave(&pnd->rx_lock, flags);
149		skb = pnd->rx_skb;
150		if (!skb) {
151			skb = pnd->rx_skb = netdev_alloc_skb(dev, 12);
152			if (likely(skb)) {
153				/* Can't use pskb_pull() on page in IRQ */
154				skb_put_data(skb, page_address(page), 1);
155				skb_add_rx_frag(skb, skb_shinfo(skb)->nr_frags,
156						page, 1, req->actual_length,
157						PAGE_SIZE);
158				page = NULL;
159			}
160		} else {
161			skb_add_rx_frag(skb, skb_shinfo(skb)->nr_frags,
162					page, 0, req->actual_length,
163					PAGE_SIZE);
164			page = NULL;
165		}
166		if (req->actual_length < PAGE_SIZE)
167			pnd->rx_skb = NULL; /* Last fragment */
168		else
169			skb = NULL;
170		spin_unlock_irqrestore(&pnd->rx_lock, flags);
171		if (skb) {
172			skb->protocol = htons(ETH_P_PHONET);
173			skb_reset_mac_header(skb);
174			__skb_pull(skb, 1);
175			skb->dev = dev;
176			dev->stats.rx_packets++;
177			dev->stats.rx_bytes += skb->len;
178
179			netif_rx(skb);
180		}
181		goto resubmit;
182
183	case -ENOENT:
184	case -ECONNRESET:
185	case -ESHUTDOWN:
186		req = NULL;
187		break;
188
189	case -EOVERFLOW:
190		dev->stats.rx_over_errors++;
191		dev_dbg(&dev->dev, "RX overflow\n");
192		break;
193
194	case -EILSEQ:
195		dev->stats.rx_crc_errors++;
196		break;
197	}
198
199	dev->stats.rx_errors++;
200resubmit:
201	if (page)
202		put_page(page);
203	if (req)
204		rx_submit(pnd, req, GFP_ATOMIC);
205}
206
207static int usbpn_close(struct net_device *dev);
208
209static int usbpn_open(struct net_device *dev)
210{
211	struct usbpn_dev *pnd = netdev_priv(dev);
212	int err;
213	unsigned i;
214	unsigned num = pnd->data_intf->cur_altsetting->desc.bInterfaceNumber;
215
216	err = usb_set_interface(pnd->usb, num, pnd->active_setting);
217	if (err)
218		return err;
219
220	for (i = 0; i < rxq_size; i++) {
221		struct urb *req = usb_alloc_urb(0, GFP_KERNEL);
222
223		if (!req || rx_submit(pnd, req, GFP_KERNEL)) {
224			usb_free_urb(req);
225			usbpn_close(dev);
226			return -ENOMEM;
227		}
228		pnd->urbs[i] = req;
229	}
230
231	netif_wake_queue(dev);
232	return 0;
233}
234
235static int usbpn_close(struct net_device *dev)
236{
237	struct usbpn_dev *pnd = netdev_priv(dev);
238	unsigned i;
239	unsigned num = pnd->data_intf->cur_altsetting->desc.bInterfaceNumber;
240
241	netif_stop_queue(dev);
242
243	for (i = 0; i < rxq_size; i++) {
244		struct urb *req = pnd->urbs[i];
245
246		if (!req)
247			continue;
248		usb_kill_urb(req);
249		usb_free_urb(req);
250		pnd->urbs[i] = NULL;
251	}
252
253	return usb_set_interface(pnd->usb, num, !pnd->active_setting);
254}
255
256static int usbpn_siocdevprivate(struct net_device *dev, struct ifreq *ifr,
257				void __user *data, int cmd)
258{
259	struct if_phonet_req *req = (struct if_phonet_req *)ifr;
260
261	switch (cmd) {
262	case SIOCPNGAUTOCONF:
263		req->ifr_phonet_autoconf.device = PN_DEV_PC;
264		return 0;
265	}
266	return -ENOIOCTLCMD;
267}
268
 
 
 
 
 
 
 
 
 
269static const struct net_device_ops usbpn_ops = {
270	.ndo_open	= usbpn_open,
271	.ndo_stop	= usbpn_close,
272	.ndo_start_xmit = usbpn_xmit,
273	.ndo_siocdevprivate = usbpn_siocdevprivate,
 
274};
275
276static void usbpn_setup(struct net_device *dev)
277{
278	const u8 addr = PN_MEDIA_USB;
279
280	dev->features		= 0;
281	dev->netdev_ops		= &usbpn_ops;
282	dev->header_ops		= &phonet_header_ops;
283	dev->type		= ARPHRD_PHONET;
284	dev->flags		= IFF_POINTOPOINT | IFF_NOARP;
285	dev->mtu		= PHONET_MAX_MTU;
286	dev->min_mtu		= PHONET_MIN_MTU;
287	dev->max_mtu		= PHONET_MAX_MTU;
288	dev->hard_header_len	= 1;
 
289	dev->addr_len		= 1;
290	dev_addr_set(dev, &addr);
291	dev->tx_queue_len	= 3;
292
293	dev->needs_free_netdev	= true;
294}
295
296/*
297 * USB driver callbacks
298 */
299static const struct usb_device_id usbpn_ids[] = {
300	{
301		.match_flags = USB_DEVICE_ID_MATCH_VENDOR
302			| USB_DEVICE_ID_MATCH_INT_CLASS
303			| USB_DEVICE_ID_MATCH_INT_SUBCLASS,
304		.idVendor = 0x0421, /* Nokia */
305		.bInterfaceClass = USB_CLASS_COMM,
306		.bInterfaceSubClass = 0xFE,
307	},
308	{ },
309};
310
311MODULE_DEVICE_TABLE(usb, usbpn_ids);
312
313static struct usb_driver usbpn_driver;
314
315static int usbpn_probe(struct usb_interface *intf, const struct usb_device_id *id)
316{
317	static const char ifname[] = "usbpn%d";
318	const struct usb_cdc_union_desc *union_header = NULL;
319	const struct usb_host_interface *data_desc;
320	struct usb_interface *data_intf;
321	struct usb_device *usbdev = interface_to_usbdev(intf);
322	struct net_device *dev;
323	struct usbpn_dev *pnd;
324	u8 *data;
325	int phonet = 0;
326	int len, err;
327	struct usb_cdc_parsed_header hdr;
328
329	data = intf->altsetting->extra;
330	len = intf->altsetting->extralen;
331	cdc_parse_cdc_header(&hdr, intf, data, len);
332	union_header = hdr.usb_cdc_union_desc;
333	phonet = hdr.phonet_magic_present;
334
335	if (!union_header || !phonet)
336		return -EINVAL;
337
338	data_intf = usb_ifnum_to_if(usbdev, union_header->bSlaveInterface0);
339	if (data_intf == NULL)
340		return -ENODEV;
341	/* Data interface has one inactive and one active setting */
342	if (data_intf->num_altsetting != 2)
343		return -EINVAL;
344	if (data_intf->altsetting[0].desc.bNumEndpoints == 0 &&
345	    data_intf->altsetting[1].desc.bNumEndpoints == 2)
346		data_desc = data_intf->altsetting + 1;
347	else
348	if (data_intf->altsetting[0].desc.bNumEndpoints == 2 &&
349	    data_intf->altsetting[1].desc.bNumEndpoints == 0)
350		data_desc = data_intf->altsetting;
351	else
352		return -EINVAL;
353
354	dev = alloc_netdev(struct_size(pnd, urbs, rxq_size), ifname,
355			   NET_NAME_UNKNOWN, usbpn_setup);
356	if (!dev)
357		return -ENOMEM;
358
359	pnd = netdev_priv(dev);
360	SET_NETDEV_DEV(dev, &intf->dev);
361
362	pnd->dev = dev;
363	pnd->usb = usbdev;
364	pnd->intf = intf;
365	pnd->data_intf = data_intf;
366	spin_lock_init(&pnd->tx_lock);
367	spin_lock_init(&pnd->rx_lock);
368	/* Endpoints */
369	if (usb_pipein(data_desc->endpoint[0].desc.bEndpointAddress)) {
370		pnd->rx_pipe = usb_rcvbulkpipe(usbdev,
371			data_desc->endpoint[0].desc.bEndpointAddress);
372		pnd->tx_pipe = usb_sndbulkpipe(usbdev,
373			data_desc->endpoint[1].desc.bEndpointAddress);
374	} else {
375		pnd->rx_pipe = usb_rcvbulkpipe(usbdev,
376			data_desc->endpoint[1].desc.bEndpointAddress);
377		pnd->tx_pipe = usb_sndbulkpipe(usbdev,
378			data_desc->endpoint[0].desc.bEndpointAddress);
379	}
380	pnd->active_setting = data_desc - data_intf->altsetting;
381
382	err = usb_driver_claim_interface(&usbpn_driver, data_intf, pnd);
383	if (err)
384		goto out;
385
386	/* Force inactive mode until the network device is brought UP */
387	usb_set_interface(usbdev, union_header->bSlaveInterface0,
388				!pnd->active_setting);
389	usb_set_intfdata(intf, pnd);
390
391	err = register_netdev(dev);
392	if (err) {
393		/* Set disconnected flag so that disconnect() returns early. */
394		pnd->disconnected = 1;
395		usb_driver_release_interface(&usbpn_driver, data_intf);
396		goto out;
397	}
398
399	dev_dbg(&dev->dev, "USB CDC Phonet device found\n");
400	return 0;
401
402out:
403	usb_set_intfdata(intf, NULL);
404	free_netdev(dev);
405	return err;
406}
407
408static void usbpn_disconnect(struct usb_interface *intf)
409{
410	struct usbpn_dev *pnd = usb_get_intfdata(intf);
411
412	if (pnd->disconnected)
413		return;
414
415	pnd->disconnected = 1;
416	usb_driver_release_interface(&usbpn_driver,
417			(pnd->intf == intf) ? pnd->data_intf : pnd->intf);
418	unregister_netdev(pnd->dev);
419}
420
421static struct usb_driver usbpn_driver = {
422	.name =		"cdc_phonet",
423	.probe =	usbpn_probe,
424	.disconnect =	usbpn_disconnect,
425	.id_table =	usbpn_ids,
426	.disable_hub_initiated_lpm = 1,
427};
428
429module_usb_driver(usbpn_driver);
430
431MODULE_AUTHOR("Remi Denis-Courmont");
432MODULE_DESCRIPTION("USB CDC Phonet host interface");
433MODULE_LICENSE("GPL");
v4.6
 
  1/*
  2 * phonet.c -- USB CDC Phonet host driver
  3 *
  4 * Copyright (C) 2008-2009 Nokia Corporation. All rights reserved.
  5 *
  6 * Author: RĂ©mi Denis-Courmont
  7 *
  8 * This program is free software; you can redistribute it and/or
  9 * modify it under the terms of the GNU General Public License
 10 * version 2 as published by the Free Software Foundation.
 11 *
 12 * This program is distributed in the hope that it will be useful, but
 13 * WITHOUT ANY WARRANTY; without even the implied warranty of
 14 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 15 * General Public License for more details.
 16 *
 17 * You should have received a copy of the GNU General Public License
 18 * along with this program; if not, write to the Free Software
 19 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
 20 * 02110-1301 USA
 21 */
 22
 23#include <linux/kernel.h>
 24#include <linux/mm.h>
 25#include <linux/module.h>
 26#include <linux/gfp.h>
 27#include <linux/usb.h>
 28#include <linux/usb/cdc.h>
 29#include <linux/netdevice.h>
 30#include <linux/if_arp.h>
 31#include <linux/if_phonet.h>
 32#include <linux/phonet.h>
 33
 34#define PN_MEDIA_USB	0x1B
 35
 36static const unsigned rxq_size = 17;
 37
 38struct usbpn_dev {
 39	struct net_device	*dev;
 40
 41	struct usb_interface	*intf, *data_intf;
 42	struct usb_device	*usb;
 43	unsigned int		tx_pipe, rx_pipe;
 44	u8 active_setting;
 45	u8 disconnected;
 46
 47	unsigned		tx_queue;
 48	spinlock_t		tx_lock;
 49
 50	spinlock_t		rx_lock;
 51	struct sk_buff		*rx_skb;
 52	struct urb		*urbs[0];
 53};
 54
 55static void tx_complete(struct urb *req);
 56static void rx_complete(struct urb *req);
 57
 58/*
 59 * Network device callbacks
 60 */
 61static netdev_tx_t usbpn_xmit(struct sk_buff *skb, struct net_device *dev)
 62{
 63	struct usbpn_dev *pnd = netdev_priv(dev);
 64	struct urb *req = NULL;
 65	unsigned long flags;
 66	int err;
 67
 68	if (skb->protocol != htons(ETH_P_PHONET))
 69		goto drop;
 70
 71	req = usb_alloc_urb(0, GFP_ATOMIC);
 72	if (!req)
 73		goto drop;
 74	usb_fill_bulk_urb(req, pnd->usb, pnd->tx_pipe, skb->data, skb->len,
 75				tx_complete, skb);
 76	req->transfer_flags = URB_ZERO_PACKET;
 77	err = usb_submit_urb(req, GFP_ATOMIC);
 78	if (err) {
 79		usb_free_urb(req);
 80		goto drop;
 81	}
 82
 83	spin_lock_irqsave(&pnd->tx_lock, flags);
 84	pnd->tx_queue++;
 85	if (pnd->tx_queue >= dev->tx_queue_len)
 86		netif_stop_queue(dev);
 87	spin_unlock_irqrestore(&pnd->tx_lock, flags);
 88	return NETDEV_TX_OK;
 89
 90drop:
 91	dev_kfree_skb(skb);
 92	dev->stats.tx_dropped++;
 93	return NETDEV_TX_OK;
 94}
 95
 96static void tx_complete(struct urb *req)
 97{
 98	struct sk_buff *skb = req->context;
 99	struct net_device *dev = skb->dev;
100	struct usbpn_dev *pnd = netdev_priv(dev);
101	int status = req->status;
 
102
103	switch (status) {
104	case 0:
105		dev->stats.tx_bytes += skb->len;
106		break;
107
108	case -ENOENT:
109	case -ECONNRESET:
110	case -ESHUTDOWN:
111		dev->stats.tx_aborted_errors++;
 
112	default:
113		dev->stats.tx_errors++;
114		dev_dbg(&dev->dev, "TX error (%d)\n", status);
115	}
116	dev->stats.tx_packets++;
117
118	spin_lock(&pnd->tx_lock);
119	pnd->tx_queue--;
120	netif_wake_queue(dev);
121	spin_unlock(&pnd->tx_lock);
122
123	dev_kfree_skb_any(skb);
124	usb_free_urb(req);
125}
126
127static int rx_submit(struct usbpn_dev *pnd, struct urb *req, gfp_t gfp_flags)
128{
129	struct net_device *dev = pnd->dev;
130	struct page *page;
131	int err;
132
133	page = __dev_alloc_page(gfp_flags | __GFP_NOMEMALLOC);
134	if (!page)
135		return -ENOMEM;
136
137	usb_fill_bulk_urb(req, pnd->usb, pnd->rx_pipe, page_address(page),
138				PAGE_SIZE, rx_complete, dev);
139	req->transfer_flags = 0;
140	err = usb_submit_urb(req, gfp_flags);
141	if (unlikely(err)) {
142		dev_dbg(&dev->dev, "RX submit error (%d)\n", err);
143		put_page(page);
144	}
145	return err;
146}
147
148static void rx_complete(struct urb *req)
149{
150	struct net_device *dev = req->context;
151	struct usbpn_dev *pnd = netdev_priv(dev);
152	struct page *page = virt_to_page(req->transfer_buffer);
153	struct sk_buff *skb;
154	unsigned long flags;
155	int status = req->status;
156
157	switch (status) {
158	case 0:
159		spin_lock_irqsave(&pnd->rx_lock, flags);
160		skb = pnd->rx_skb;
161		if (!skb) {
162			skb = pnd->rx_skb = netdev_alloc_skb(dev, 12);
163			if (likely(skb)) {
164				/* Can't use pskb_pull() on page in IRQ */
165				memcpy(skb_put(skb, 1), page_address(page), 1);
166				skb_add_rx_frag(skb, skb_shinfo(skb)->nr_frags,
167						page, 1, req->actual_length,
168						PAGE_SIZE);
169				page = NULL;
170			}
171		} else {
172			skb_add_rx_frag(skb, skb_shinfo(skb)->nr_frags,
173					page, 0, req->actual_length,
174					PAGE_SIZE);
175			page = NULL;
176		}
177		if (req->actual_length < PAGE_SIZE)
178			pnd->rx_skb = NULL; /* Last fragment */
179		else
180			skb = NULL;
181		spin_unlock_irqrestore(&pnd->rx_lock, flags);
182		if (skb) {
183			skb->protocol = htons(ETH_P_PHONET);
184			skb_reset_mac_header(skb);
185			__skb_pull(skb, 1);
186			skb->dev = dev;
187			dev->stats.rx_packets++;
188			dev->stats.rx_bytes += skb->len;
189
190			netif_rx(skb);
191		}
192		goto resubmit;
193
194	case -ENOENT:
195	case -ECONNRESET:
196	case -ESHUTDOWN:
197		req = NULL;
198		break;
199
200	case -EOVERFLOW:
201		dev->stats.rx_over_errors++;
202		dev_dbg(&dev->dev, "RX overflow\n");
203		break;
204
205	case -EILSEQ:
206		dev->stats.rx_crc_errors++;
207		break;
208	}
209
210	dev->stats.rx_errors++;
211resubmit:
212	if (page)
213		put_page(page);
214	if (req)
215		rx_submit(pnd, req, GFP_ATOMIC);
216}
217
218static int usbpn_close(struct net_device *dev);
219
220static int usbpn_open(struct net_device *dev)
221{
222	struct usbpn_dev *pnd = netdev_priv(dev);
223	int err;
224	unsigned i;
225	unsigned num = pnd->data_intf->cur_altsetting->desc.bInterfaceNumber;
226
227	err = usb_set_interface(pnd->usb, num, pnd->active_setting);
228	if (err)
229		return err;
230
231	for (i = 0; i < rxq_size; i++) {
232		struct urb *req = usb_alloc_urb(0, GFP_KERNEL);
233
234		if (!req || rx_submit(pnd, req, GFP_KERNEL)) {
235			usb_free_urb(req);
236			usbpn_close(dev);
237			return -ENOMEM;
238		}
239		pnd->urbs[i] = req;
240	}
241
242	netif_wake_queue(dev);
243	return 0;
244}
245
246static int usbpn_close(struct net_device *dev)
247{
248	struct usbpn_dev *pnd = netdev_priv(dev);
249	unsigned i;
250	unsigned num = pnd->data_intf->cur_altsetting->desc.bInterfaceNumber;
251
252	netif_stop_queue(dev);
253
254	for (i = 0; i < rxq_size; i++) {
255		struct urb *req = pnd->urbs[i];
256
257		if (!req)
258			continue;
259		usb_kill_urb(req);
260		usb_free_urb(req);
261		pnd->urbs[i] = NULL;
262	}
263
264	return usb_set_interface(pnd->usb, num, !pnd->active_setting);
265}
266
267static int usbpn_ioctl(struct net_device *dev, struct ifreq *ifr, int cmd)
 
268{
269	struct if_phonet_req *req = (struct if_phonet_req *)ifr;
270
271	switch (cmd) {
272	case SIOCPNGAUTOCONF:
273		req->ifr_phonet_autoconf.device = PN_DEV_PC;
274		return 0;
275	}
276	return -ENOIOCTLCMD;
277}
278
279static int usbpn_set_mtu(struct net_device *dev, int new_mtu)
280{
281	if ((new_mtu < PHONET_MIN_MTU) || (new_mtu > PHONET_MAX_MTU))
282		return -EINVAL;
283
284	dev->mtu = new_mtu;
285	return 0;
286}
287
288static const struct net_device_ops usbpn_ops = {
289	.ndo_open	= usbpn_open,
290	.ndo_stop	= usbpn_close,
291	.ndo_start_xmit = usbpn_xmit,
292	.ndo_do_ioctl	= usbpn_ioctl,
293	.ndo_change_mtu = usbpn_set_mtu,
294};
295
296static void usbpn_setup(struct net_device *dev)
297{
 
 
298	dev->features		= 0;
299	dev->netdev_ops		= &usbpn_ops,
300	dev->header_ops		= &phonet_header_ops;
301	dev->type		= ARPHRD_PHONET;
302	dev->flags		= IFF_POINTOPOINT | IFF_NOARP;
303	dev->mtu		= PHONET_MAX_MTU;
 
 
304	dev->hard_header_len	= 1;
305	dev->dev_addr[0]	= PN_MEDIA_USB;
306	dev->addr_len		= 1;
 
307	dev->tx_queue_len	= 3;
308
309	dev->destructor		= free_netdev;
310}
311
312/*
313 * USB driver callbacks
314 */
315static struct usb_device_id usbpn_ids[] = {
316	{
317		.match_flags = USB_DEVICE_ID_MATCH_VENDOR
318			| USB_DEVICE_ID_MATCH_INT_CLASS
319			| USB_DEVICE_ID_MATCH_INT_SUBCLASS,
320		.idVendor = 0x0421, /* Nokia */
321		.bInterfaceClass = USB_CLASS_COMM,
322		.bInterfaceSubClass = 0xFE,
323	},
324	{ },
325};
326
327MODULE_DEVICE_TABLE(usb, usbpn_ids);
328
329static struct usb_driver usbpn_driver;
330
331static int usbpn_probe(struct usb_interface *intf, const struct usb_device_id *id)
332{
333	static const char ifname[] = "usbpn%d";
334	const struct usb_cdc_union_desc *union_header = NULL;
335	const struct usb_host_interface *data_desc;
336	struct usb_interface *data_intf;
337	struct usb_device *usbdev = interface_to_usbdev(intf);
338	struct net_device *dev;
339	struct usbpn_dev *pnd;
340	u8 *data;
341	int phonet = 0;
342	int len, err;
343	struct usb_cdc_parsed_header hdr;
344
345	data = intf->altsetting->extra;
346	len = intf->altsetting->extralen;
347	cdc_parse_cdc_header(&hdr, intf, data, len);
348	union_header = hdr.usb_cdc_union_desc;
349	phonet = hdr.phonet_magic_present;
350
351	if (!union_header || !phonet)
352		return -EINVAL;
353
354	data_intf = usb_ifnum_to_if(usbdev, union_header->bSlaveInterface0);
355	if (data_intf == NULL)
356		return -ENODEV;
357	/* Data interface has one inactive and one active setting */
358	if (data_intf->num_altsetting != 2)
359		return -EINVAL;
360	if (data_intf->altsetting[0].desc.bNumEndpoints == 0 &&
361	    data_intf->altsetting[1].desc.bNumEndpoints == 2)
362		data_desc = data_intf->altsetting + 1;
363	else
364	if (data_intf->altsetting[0].desc.bNumEndpoints == 2 &&
365	    data_intf->altsetting[1].desc.bNumEndpoints == 0)
366		data_desc = data_intf->altsetting;
367	else
368		return -EINVAL;
369
370	dev = alloc_netdev(sizeof(*pnd) + sizeof(pnd->urbs[0]) * rxq_size,
371			   ifname, NET_NAME_UNKNOWN, usbpn_setup);
372	if (!dev)
373		return -ENOMEM;
374
375	pnd = netdev_priv(dev);
376	SET_NETDEV_DEV(dev, &intf->dev);
377
378	pnd->dev = dev;
379	pnd->usb = usbdev;
380	pnd->intf = intf;
381	pnd->data_intf = data_intf;
382	spin_lock_init(&pnd->tx_lock);
383	spin_lock_init(&pnd->rx_lock);
384	/* Endpoints */
385	if (usb_pipein(data_desc->endpoint[0].desc.bEndpointAddress)) {
386		pnd->rx_pipe = usb_rcvbulkpipe(usbdev,
387			data_desc->endpoint[0].desc.bEndpointAddress);
388		pnd->tx_pipe = usb_sndbulkpipe(usbdev,
389			data_desc->endpoint[1].desc.bEndpointAddress);
390	} else {
391		pnd->rx_pipe = usb_rcvbulkpipe(usbdev,
392			data_desc->endpoint[1].desc.bEndpointAddress);
393		pnd->tx_pipe = usb_sndbulkpipe(usbdev,
394			data_desc->endpoint[0].desc.bEndpointAddress);
395	}
396	pnd->active_setting = data_desc - data_intf->altsetting;
397
398	err = usb_driver_claim_interface(&usbpn_driver, data_intf, pnd);
399	if (err)
400		goto out;
401
402	/* Force inactive mode until the network device is brought UP */
403	usb_set_interface(usbdev, union_header->bSlaveInterface0,
404				!pnd->active_setting);
405	usb_set_intfdata(intf, pnd);
406
407	err = register_netdev(dev);
408	if (err) {
 
 
409		usb_driver_release_interface(&usbpn_driver, data_intf);
410		goto out;
411	}
412
413	dev_dbg(&dev->dev, "USB CDC Phonet device found\n");
414	return 0;
415
416out:
417	usb_set_intfdata(intf, NULL);
418	free_netdev(dev);
419	return err;
420}
421
422static void usbpn_disconnect(struct usb_interface *intf)
423{
424	struct usbpn_dev *pnd = usb_get_intfdata(intf);
425
426	if (pnd->disconnected)
427		return;
428
429	pnd->disconnected = 1;
430	usb_driver_release_interface(&usbpn_driver,
431			(pnd->intf == intf) ? pnd->data_intf : pnd->intf);
432	unregister_netdev(pnd->dev);
433}
434
435static struct usb_driver usbpn_driver = {
436	.name =		"cdc_phonet",
437	.probe =	usbpn_probe,
438	.disconnect =	usbpn_disconnect,
439	.id_table =	usbpn_ids,
440	.disable_hub_initiated_lpm = 1,
441};
442
443module_usb_driver(usbpn_driver);
444
445MODULE_AUTHOR("Remi Denis-Courmont");
446MODULE_DESCRIPTION("USB CDC Phonet host interface");
447MODULE_LICENSE("GPL");