Commit 1f6ccccc authored by Jussi Kivilinna's avatar Jussi Kivilinna Committed by John W. Linville

zd1211rw: reset rx urbs after idle period of 30 seconds

RX appears to freeze while idle. Resetting rx-urbs appears to be enough to fix
this. Do reset 30 seconds after last rx.
Signed-off-by: default avatarJussi Kivilinna <jussi.kivilinna@mbnet.fi>
Signed-off-by: default avatarJohn W. Linville <linville@tuxdriver.com>
parent 3985a465
...@@ -638,6 +638,8 @@ static void rx_urb_complete(struct urb *urb) ...@@ -638,6 +638,8 @@ static void rx_urb_complete(struct urb *urb)
usb = urb->context; usb = urb->context;
rx = &usb->rx; rx = &usb->rx;
zd_usb_reset_rx_idle_timer(usb);
if (length%rx->usb_packet_size > rx->usb_packet_size-4) { if (length%rx->usb_packet_size > rx->usb_packet_size-4) {
/* If there is an old first fragment, we don't care. */ /* If there is an old first fragment, we don't care. */
dev_dbg_f(urb_dev(urb), "*** first fragment ***\n"); dev_dbg_f(urb_dev(urb), "*** first fragment ***\n");
...@@ -702,7 +704,7 @@ static void free_rx_urb(struct urb *urb) ...@@ -702,7 +704,7 @@ static void free_rx_urb(struct urb *urb)
usb_free_urb(urb); usb_free_urb(urb);
} }
int zd_usb_enable_rx(struct zd_usb *usb) static int __zd_usb_enable_rx(struct zd_usb *usb)
{ {
int i, r; int i, r;
struct zd_usb_rx *rx = &usb->rx; struct zd_usb_rx *rx = &usb->rx;
...@@ -754,7 +756,21 @@ int zd_usb_enable_rx(struct zd_usb *usb) ...@@ -754,7 +756,21 @@ int zd_usb_enable_rx(struct zd_usb *usb)
return r; return r;
} }
void zd_usb_disable_rx(struct zd_usb *usb) int zd_usb_enable_rx(struct zd_usb *usb)
{
int r;
struct zd_usb_rx *rx = &usb->rx;
mutex_lock(&rx->setup_mutex);
r = __zd_usb_enable_rx(usb);
mutex_unlock(&rx->setup_mutex);
zd_usb_reset_rx_idle_timer(usb);
return r;
}
static void __zd_usb_disable_rx(struct zd_usb *usb)
{ {
int i; int i;
unsigned long flags; unsigned long flags;
...@@ -781,6 +797,40 @@ void zd_usb_disable_rx(struct zd_usb *usb) ...@@ -781,6 +797,40 @@ void zd_usb_disable_rx(struct zd_usb *usb)
spin_unlock_irqrestore(&rx->lock, flags); spin_unlock_irqrestore(&rx->lock, flags);
} }
void zd_usb_disable_rx(struct zd_usb *usb)
{
struct zd_usb_rx *rx = &usb->rx;
mutex_lock(&rx->setup_mutex);
__zd_usb_disable_rx(usb);
mutex_unlock(&rx->setup_mutex);
cancel_delayed_work_sync(&rx->idle_work);
}
static void zd_usb_reset_rx(struct zd_usb *usb)
{
bool do_reset;
struct zd_usb_rx *rx = &usb->rx;
unsigned long flags;
mutex_lock(&rx->setup_mutex);
spin_lock_irqsave(&rx->lock, flags);
do_reset = rx->urbs != NULL;
spin_unlock_irqrestore(&rx->lock, flags);
if (do_reset) {
__zd_usb_disable_rx(usb);
__zd_usb_enable_rx(usb);
}
mutex_unlock(&rx->setup_mutex);
if (do_reset)
zd_usb_reset_rx_idle_timer(usb);
}
/** /**
* zd_usb_disable_tx - disable transmission * zd_usb_disable_tx - disable transmission
* @usb: the zd1211rw-private USB structure * @usb: the zd1211rw-private USB structure
...@@ -1033,6 +1083,29 @@ void zd_tx_watchdog_disable(struct zd_usb *usb) ...@@ -1033,6 +1083,29 @@ void zd_tx_watchdog_disable(struct zd_usb *usb)
} }
} }
static void zd_rx_idle_timer_handler(struct work_struct *work)
{
struct zd_usb *usb =
container_of(work, struct zd_usb, rx.idle_work.work);
struct zd_mac *mac = zd_usb_to_mac(usb);
if (!test_bit(ZD_DEVICE_RUNNING, &mac->flags))
return;
dev_dbg_f(zd_usb_dev(usb), "\n");
/* 30 seconds since last rx, reset rx */
zd_usb_reset_rx(usb);
}
void zd_usb_reset_rx_idle_timer(struct zd_usb *usb)
{
struct zd_usb_rx *rx = &usb->rx;
cancel_delayed_work(&rx->idle_work);
queue_delayed_work(zd_workqueue, &rx->idle_work, ZD_RX_IDLE_INTERVAL);
}
static inline void init_usb_interrupt(struct zd_usb *usb) static inline void init_usb_interrupt(struct zd_usb *usb)
{ {
struct zd_usb_interrupt *intr = &usb->intr; struct zd_usb_interrupt *intr = &usb->intr;
...@@ -1047,12 +1120,14 @@ static inline void init_usb_rx(struct zd_usb *usb) ...@@ -1047,12 +1120,14 @@ static inline void init_usb_rx(struct zd_usb *usb)
{ {
struct zd_usb_rx *rx = &usb->rx; struct zd_usb_rx *rx = &usb->rx;
spin_lock_init(&rx->lock); spin_lock_init(&rx->lock);
mutex_init(&rx->setup_mutex);
if (interface_to_usbdev(usb->intf)->speed == USB_SPEED_HIGH) { if (interface_to_usbdev(usb->intf)->speed == USB_SPEED_HIGH) {
rx->usb_packet_size = 512; rx->usb_packet_size = 512;
} else { } else {
rx->usb_packet_size = 64; rx->usb_packet_size = 64;
} }
ZD_ASSERT(rx->fragment_length == 0); ZD_ASSERT(rx->fragment_length == 0);
INIT_DELAYED_WORK(&rx->idle_work, zd_rx_idle_timer_handler);
} }
static inline void init_usb_tx(struct zd_usb *usb) static inline void init_usb_tx(struct zd_usb *usb)
......
...@@ -34,6 +34,7 @@ ...@@ -34,6 +34,7 @@
#define ZD_TX_TIMEOUT (HZ * 5) #define ZD_TX_TIMEOUT (HZ * 5)
#define ZD_TX_WATCHDOG_INTERVAL round_jiffies_relative(HZ) #define ZD_TX_WATCHDOG_INTERVAL round_jiffies_relative(HZ)
#define ZD_RX_IDLE_INTERVAL round_jiffies_relative(30 * HZ)
enum devicetype { enum devicetype {
DEVICE_ZD1211 = 0, DEVICE_ZD1211 = 0,
...@@ -180,7 +181,9 @@ static inline struct usb_int_regs *get_read_regs(struct zd_usb_interrupt *intr) ...@@ -180,7 +181,9 @@ static inline struct usb_int_regs *get_read_regs(struct zd_usb_interrupt *intr)
struct zd_usb_rx { struct zd_usb_rx {
spinlock_t lock; spinlock_t lock;
u8 fragment[2*USB_MAX_RX_SIZE]; struct mutex setup_mutex;
struct delayed_work idle_work;
u8 fragment[2 * USB_MAX_RX_SIZE];
unsigned int fragment_length; unsigned int fragment_length;
unsigned int usb_packet_size; unsigned int usb_packet_size;
struct urb **urbs; struct urb **urbs;
...@@ -251,6 +254,8 @@ void zd_usb_disable_int(struct zd_usb *usb); ...@@ -251,6 +254,8 @@ void zd_usb_disable_int(struct zd_usb *usb);
int zd_usb_enable_rx(struct zd_usb *usb); int zd_usb_enable_rx(struct zd_usb *usb);
void zd_usb_disable_rx(struct zd_usb *usb); void zd_usb_disable_rx(struct zd_usb *usb);
void zd_usb_reset_rx_idle_timer(struct zd_usb *usb);
void zd_usb_enable_tx(struct zd_usb *usb); void zd_usb_enable_tx(struct zd_usb *usb);
void zd_usb_disable_tx(struct zd_usb *usb); void zd_usb_disable_tx(struct zd_usb *usb);
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment