Linux Audio

Check our new training course

Linux debugging, profiling, tracing and performance analysis training

Apr 14-17, 2025
Register
Loading...
Note: File does not exist in v6.8.
  1// SPDX-License-Identifier: GPL-2.0-only
  2/*
  3 *  Copyright (C) 2002 Intersil Americas Inc.
  4 *  Copyright 2004 Jens Maurer <Jens.Maurer@gmx.net>
  5 */
  6
  7#include <linux/netdevice.h>
  8#include <linux/module.h>
  9#include <linux/pci.h>
 10#include <linux/sched.h>
 11#include <linux/slab.h>
 12
 13#include <asm/io.h>
 14#include <linux/if_arp.h>
 15
 16#include "prismcompat.h"
 17#include "isl_38xx.h"
 18#include "islpci_mgt.h"
 19#include "isl_oid.h"		/* additional types and defs for isl38xx fw */
 20#include "isl_ioctl.h"
 21
 22#include <net/iw_handler.h>
 23
 24/******************************************************************************
 25        Global variable definition section
 26******************************************************************************/
 27int pc_debug = VERBOSE;
 28module_param(pc_debug, int, 0);
 29
 30/******************************************************************************
 31    Driver general functions
 32******************************************************************************/
 33#if VERBOSE > SHOW_ERROR_MESSAGES
 34void
 35display_buffer(char *buffer, int length)
 36{
 37	if ((pc_debug & SHOW_BUFFER_CONTENTS) == 0)
 38		return;
 39
 40	while (length > 0) {
 41		printk("[%02x]", *buffer & 255);
 42		length--;
 43		buffer++;
 44	}
 45
 46	printk("\n");
 47}
 48#endif
 49
 50/*****************************************************************************
 51    Queue handling for management frames
 52******************************************************************************/
 53
 54/*
 55 * Helper function to create a PIMFOR management frame header.
 56 */
 57static void
 58pimfor_encode_header(int operation, u32 oid, u32 length, pimfor_header_t *h)
 59{
 60	h->version = PIMFOR_VERSION;
 61	h->operation = operation;
 62	h->device_id = PIMFOR_DEV_ID_MHLI_MIB;
 63	h->flags = 0;
 64	h->oid = cpu_to_be32(oid);
 65	h->length = cpu_to_be32(length);
 66}
 67
 68/*
 69 * Helper function to analyze a PIMFOR management frame header.
 70 */
 71static pimfor_header_t *
 72pimfor_decode_header(void *data, int len)
 73{
 74	pimfor_header_t *h = data;
 75
 76	while ((void *) h < data + len) {
 77		if (h->flags & PIMFOR_FLAG_LITTLE_ENDIAN) {
 78			le32_to_cpus(&h->oid);
 79			le32_to_cpus(&h->length);
 80		} else {
 81			be32_to_cpus(&h->oid);
 82			be32_to_cpus(&h->length);
 83		}
 84		if (h->oid != OID_INL_TUNNEL)
 85			return h;
 86		h++;
 87	}
 88	return NULL;
 89}
 90
 91/*
 92 * Fill the receive queue for management frames with fresh buffers.
 93 */
 94int
 95islpci_mgmt_rx_fill(struct net_device *ndev)
 96{
 97	islpci_private *priv = netdev_priv(ndev);
 98	isl38xx_control_block *cb =	/* volatile not needed */
 99	    (isl38xx_control_block *) priv->control_block;
100	u32 curr = le32_to_cpu(cb->driver_curr_frag[ISL38XX_CB_RX_MGMTQ]);
101
102#if VERBOSE > SHOW_ERROR_MESSAGES
103	DEBUG(SHOW_FUNCTION_CALLS, "islpci_mgmt_rx_fill\n");
104#endif
105
106	while (curr - priv->index_mgmt_rx < ISL38XX_CB_MGMT_QSIZE) {
107		u32 index = curr % ISL38XX_CB_MGMT_QSIZE;
108		struct islpci_membuf *buf = &priv->mgmt_rx[index];
109		isl38xx_fragment *frag = &cb->rx_data_mgmt[index];
110
111		if (buf->mem == NULL) {
112			buf->mem = kmalloc(MGMT_FRAME_SIZE, GFP_ATOMIC);
113			if (!buf->mem)
114				return -ENOMEM;
115			buf->size = MGMT_FRAME_SIZE;
116		}
117		if (buf->pci_addr == 0) {
118			buf->pci_addr = pci_map_single(priv->pdev, buf->mem,
119						       MGMT_FRAME_SIZE,
120						       PCI_DMA_FROMDEVICE);
121			if (pci_dma_mapping_error(priv->pdev, buf->pci_addr)) {
122				printk(KERN_WARNING
123				       "Failed to make memory DMA'able.\n");
124				return -ENOMEM;
125			}
126		}
127
128		/* be safe: always reset control block information */
129		frag->size = cpu_to_le16(MGMT_FRAME_SIZE);
130		frag->flags = 0;
131		frag->address = cpu_to_le32(buf->pci_addr);
132		curr++;
133
134		/* The fragment address in the control block must have
135		 * been written before announcing the frame buffer to
136		 * device */
137		wmb();
138		cb->driver_curr_frag[ISL38XX_CB_RX_MGMTQ] = cpu_to_le32(curr);
139	}
140	return 0;
141}
142
143/*
144 * Create and transmit a management frame using "operation" and "oid",
145 * with arguments data/length.
146 * We either return an error and free the frame, or we return 0 and
147 * islpci_mgt_cleanup_transmit() frees the frame in the tx-done
148 * interrupt.
149 */
150static int
151islpci_mgt_transmit(struct net_device *ndev, int operation, unsigned long oid,
152		    void *data, int length)
153{
154	islpci_private *priv = netdev_priv(ndev);
155	isl38xx_control_block *cb =
156	    (isl38xx_control_block *) priv->control_block;
157	void *p;
158	int err = -EINVAL;
159	unsigned long flags;
160	isl38xx_fragment *frag;
161	struct islpci_membuf buf;
162	u32 curr_frag;
163	int index;
164	int frag_len = length + PIMFOR_HEADER_SIZE;
165
166#if VERBOSE > SHOW_ERROR_MESSAGES
167	DEBUG(SHOW_FUNCTION_CALLS, "islpci_mgt_transmit\n");
168#endif
169
170	if (frag_len > MGMT_FRAME_SIZE) {
171		printk(KERN_DEBUG "%s: mgmt frame too large %d\n",
172		       ndev->name, frag_len);
173		goto error;
174	}
175
176	err = -ENOMEM;
177	p = buf.mem = kmalloc(frag_len, GFP_KERNEL);
178	if (!buf.mem)
179		goto error;
180
181	buf.size = frag_len;
182
183	/* create the header directly in the fragment data area */
184	pimfor_encode_header(operation, oid, length, (pimfor_header_t *) p);
185	p += PIMFOR_HEADER_SIZE;
186
187	if (data)
188		memcpy(p, data, length);
189	else
190		memset(p, 0, length);
191
192#if VERBOSE > SHOW_ERROR_MESSAGES
193	{
194		pimfor_header_t *h = buf.mem;
195		DEBUG(SHOW_PIMFOR_FRAMES,
196		      "PIMFOR: op %i, oid 0x%08lx, device %i, flags 0x%x length 0x%x\n",
197		      h->operation, oid, h->device_id, h->flags, length);
198
199		/* display the buffer contents for debugging */
200		display_buffer((char *) h, sizeof (pimfor_header_t));
201		display_buffer(p, length);
202	}
203#endif
204
205	err = -ENOMEM;
206	buf.pci_addr = pci_map_single(priv->pdev, buf.mem, frag_len,
207				      PCI_DMA_TODEVICE);
208	if (pci_dma_mapping_error(priv->pdev, buf.pci_addr)) {
209		printk(KERN_WARNING "%s: cannot map PCI memory for mgmt\n",
210		       ndev->name);
211		goto error_free;
212	}
213
214	/* Protect the control block modifications against interrupts. */
215	spin_lock_irqsave(&priv->slock, flags);
216	curr_frag = le32_to_cpu(cb->driver_curr_frag[ISL38XX_CB_TX_MGMTQ]);
217	if (curr_frag - priv->index_mgmt_tx >= ISL38XX_CB_MGMT_QSIZE) {
218		printk(KERN_WARNING "%s: mgmt tx queue is still full\n",
219		       ndev->name);
220		goto error_unlock;
221	}
222
223	/* commit the frame to the tx device queue */
224	index = curr_frag % ISL38XX_CB_MGMT_QSIZE;
225	priv->mgmt_tx[index] = buf;
226	frag = &cb->tx_data_mgmt[index];
227	frag->size = cpu_to_le16(frag_len);
228	frag->flags = 0;	/* for any other than the last fragment, set to 1 */
229	frag->address = cpu_to_le32(buf.pci_addr);
230
231	/* The fragment address in the control block must have
232	 * been written before announcing the frame buffer to
233	 * device */
234	wmb();
235	cb->driver_curr_frag[ISL38XX_CB_TX_MGMTQ] = cpu_to_le32(curr_frag + 1);
236	spin_unlock_irqrestore(&priv->slock, flags);
237
238	/* trigger the device */
239	islpci_trigger(priv);
240	return 0;
241
242      error_unlock:
243	spin_unlock_irqrestore(&priv->slock, flags);
244      error_free:
245	kfree(buf.mem);
246      error:
247	return err;
248}
249
250/*
251 * Receive a management frame from the device.
252 * This can be an arbitrary number of traps, and at most one response
253 * frame for a previous request sent via islpci_mgt_transmit().
254 */
255int
256islpci_mgt_receive(struct net_device *ndev)
257{
258	islpci_private *priv = netdev_priv(ndev);
259	isl38xx_control_block *cb =
260	    (isl38xx_control_block *) priv->control_block;
261	u32 curr_frag;
262
263#if VERBOSE > SHOW_ERROR_MESSAGES
264	DEBUG(SHOW_FUNCTION_CALLS, "islpci_mgt_receive\n");
265#endif
266
267	/* Only once per interrupt, determine fragment range to
268	 * process.  This avoids an endless loop (i.e. lockup) if
269	 * frames come in faster than we can process them. */
270	curr_frag = le32_to_cpu(cb->device_curr_frag[ISL38XX_CB_RX_MGMTQ]);
271	barrier();
272
273	for (; priv->index_mgmt_rx < curr_frag; priv->index_mgmt_rx++) {
274		pimfor_header_t *header;
275		u32 index = priv->index_mgmt_rx % ISL38XX_CB_MGMT_QSIZE;
276		struct islpci_membuf *buf = &priv->mgmt_rx[index];
277		u16 frag_len;
278		int size;
279		struct islpci_mgmtframe *frame;
280
281		/* I have no idea (and no documentation) if flags != 0
282		 * is possible.  Drop the frame, reuse the buffer. */
283		if (le16_to_cpu(cb->rx_data_mgmt[index].flags) != 0) {
284			printk(KERN_WARNING "%s: unknown flags 0x%04x\n",
285			       ndev->name,
286			       le16_to_cpu(cb->rx_data_mgmt[index].flags));
287			continue;
288		}
289
290		/* The device only returns the size of the header(s) here. */
291		frag_len = le16_to_cpu(cb->rx_data_mgmt[index].size);
292
293		/*
294		 * We appear to have no way to tell the device the
295		 * size of a receive buffer.  Thus, if this check
296		 * triggers, we likely have kernel heap corruption. */
297		if (frag_len > MGMT_FRAME_SIZE) {
298			printk(KERN_WARNING
299				"%s: Bogus packet size of %d (%#x).\n",
300				ndev->name, frag_len, frag_len);
301			frag_len = MGMT_FRAME_SIZE;
302		}
303
304		/* Ensure the results of device DMA are visible to the CPU. */
305		pci_dma_sync_single_for_cpu(priv->pdev, buf->pci_addr,
306					    buf->size, PCI_DMA_FROMDEVICE);
307
308		/* Perform endianess conversion for PIMFOR header in-place. */
309		header = pimfor_decode_header(buf->mem, frag_len);
310		if (!header) {
311			printk(KERN_WARNING "%s: no PIMFOR header found\n",
312			       ndev->name);
313			continue;
314		}
315
316		/* The device ID from the PIMFOR packet received from
317		 * the MVC is always 0.  We forward a sensible device_id.
318		 * Not that anyone upstream would care... */
319		header->device_id = priv->ndev->ifindex;
320
321#if VERBOSE > SHOW_ERROR_MESSAGES
322		DEBUG(SHOW_PIMFOR_FRAMES,
323		      "PIMFOR: op %i, oid 0x%08x, device %i, flags 0x%x length 0x%x\n",
324		      header->operation, header->oid, header->device_id,
325		      header->flags, header->length);
326
327		/* display the buffer contents for debugging */
328		display_buffer((char *) header, PIMFOR_HEADER_SIZE);
329		display_buffer((char *) header + PIMFOR_HEADER_SIZE,
330			       header->length);
331#endif
332
333		/* nobody sends these */
334		if (header->flags & PIMFOR_FLAG_APPLIC_ORIGIN) {
335			printk(KERN_DEBUG
336			       "%s: errant PIMFOR application frame\n",
337			       ndev->name);
338			continue;
339		}
340
341		/* Determine frame size, skipping OID_INL_TUNNEL headers. */
342		size = PIMFOR_HEADER_SIZE + header->length;
343		frame = kmalloc(sizeof(struct islpci_mgmtframe) + size,
344				GFP_ATOMIC);
345		if (!frame)
346			continue;
347
348		frame->ndev = ndev;
349		memcpy(&frame->buf, header, size);
350		frame->header = (pimfor_header_t *) frame->buf;
351		frame->data = frame->buf + PIMFOR_HEADER_SIZE;
352
353#if VERBOSE > SHOW_ERROR_MESSAGES
354		DEBUG(SHOW_PIMFOR_FRAMES,
355		      "frame: header: %p, data: %p, size: %d\n",
356		      frame->header, frame->data, size);
357#endif
358
359		if (header->operation == PIMFOR_OP_TRAP) {
360#if VERBOSE > SHOW_ERROR_MESSAGES
361			printk(KERN_DEBUG
362			       "TRAP: oid 0x%x, device %i, flags 0x%x length %i\n",
363			       header->oid, header->device_id, header->flags,
364			       header->length);
365#endif
366
367			/* Create work to handle trap out of interrupt
368			 * context. */
369			INIT_WORK(&frame->ws, prism54_process_trap);
370			schedule_work(&frame->ws);
371
372		} else {
373			/* Signal the one waiting process that a response
374			 * has been received. */
375			if ((frame = xchg(&priv->mgmt_received, frame)) != NULL) {
376				printk(KERN_WARNING
377				       "%s: mgmt response not collected\n",
378				       ndev->name);
379				kfree(frame);
380			}
381#if VERBOSE > SHOW_ERROR_MESSAGES
382			DEBUG(SHOW_TRACING, "Wake up Mgmt Queue\n");
383#endif
384			wake_up(&priv->mgmt_wqueue);
385		}
386
387	}
388
389	return 0;
390}
391
392/*
393 * Cleanup the transmit queue by freeing all frames handled by the device.
394 */
395void
396islpci_mgt_cleanup_transmit(struct net_device *ndev)
397{
398	islpci_private *priv = netdev_priv(ndev);
399	isl38xx_control_block *cb =	/* volatile not needed */
400	    (isl38xx_control_block *) priv->control_block;
401	u32 curr_frag;
402
403#if VERBOSE > SHOW_ERROR_MESSAGES
404	DEBUG(SHOW_FUNCTION_CALLS, "islpci_mgt_cleanup_transmit\n");
405#endif
406
407	/* Only once per cleanup, determine fragment range to
408	 * process.  This avoids an endless loop (i.e. lockup) if
409	 * the device became confused, incrementing device_curr_frag
410	 * rapidly. */
411	curr_frag = le32_to_cpu(cb->device_curr_frag[ISL38XX_CB_TX_MGMTQ]);
412	barrier();
413
414	for (; priv->index_mgmt_tx < curr_frag; priv->index_mgmt_tx++) {
415		int index = priv->index_mgmt_tx % ISL38XX_CB_MGMT_QSIZE;
416		struct islpci_membuf *buf = &priv->mgmt_tx[index];
417		pci_unmap_single(priv->pdev, buf->pci_addr, buf->size,
418				 PCI_DMA_TODEVICE);
419		buf->pci_addr = 0;
420		kfree(buf->mem);
421		buf->mem = NULL;
422		buf->size = 0;
423	}
424}
425
426/*
427 * Perform one request-response transaction to the device.
428 */
429int
430islpci_mgt_transaction(struct net_device *ndev,
431		       int operation, unsigned long oid,
432		       void *senddata, int sendlen,
433		       struct islpci_mgmtframe **recvframe)
434{
435	islpci_private *priv = netdev_priv(ndev);
436	const long wait_cycle_jiffies = msecs_to_jiffies(ISL38XX_WAIT_CYCLE * 10);
437	long timeout_left = ISL38XX_MAX_WAIT_CYCLES * wait_cycle_jiffies;
438	int err;
439	DEFINE_WAIT(wait);
440
441	*recvframe = NULL;
442
443	if (mutex_lock_interruptible(&priv->mgmt_lock))
444		return -ERESTARTSYS;
445
446	prepare_to_wait(&priv->mgmt_wqueue, &wait, TASK_UNINTERRUPTIBLE);
447	err = islpci_mgt_transmit(ndev, operation, oid, senddata, sendlen);
448	if (err)
449		goto out;
450
451	err = -ETIMEDOUT;
452	while (timeout_left > 0) {
453		int timeleft;
454		struct islpci_mgmtframe *frame;
455
456		timeleft = schedule_timeout_uninterruptible(wait_cycle_jiffies);
457		frame = xchg(&priv->mgmt_received, NULL);
458		if (frame) {
459			if (frame->header->oid == oid) {
460				*recvframe = frame;
461				err = 0;
462				goto out;
463			} else {
464				printk(KERN_DEBUG
465				       "%s: expecting oid 0x%x, received 0x%x.\n",
466				       ndev->name, (unsigned int) oid,
467				       frame->header->oid);
468				kfree(frame);
469				frame = NULL;
470			}
471		}
472		if (timeleft == 0) {
473			printk(KERN_DEBUG
474				"%s: timeout waiting for mgmt response %lu, "
475				"triggering device\n",
476				ndev->name, timeout_left);
477			islpci_trigger(priv);
478		}
479		timeout_left += timeleft - wait_cycle_jiffies;
480	}
481	printk(KERN_WARNING "%s: timeout waiting for mgmt response\n",
482	       ndev->name);
483
484	/* TODO: we should reset the device here */
485 out:
486	finish_wait(&priv->mgmt_wqueue, &wait);
487	mutex_unlock(&priv->mgmt_lock);
488	return err;
489}
490