Commit eff0dee5 authored by Daniel Walker's avatar Daniel Walker Committed by David S. Miller

atm: ambassador: vcc_sf semaphore to mutex

Signed-off-by: default avatarDaniel Walker <dwalker@mvista.com>
Signed-off-by: default avatarDavid S. Miller <davem@davemloft.net>
parent 220fc3fc
...@@ -33,6 +33,7 @@ ...@@ -33,6 +33,7 @@
#include <linux/interrupt.h> #include <linux/interrupt.h>
#include <linux/poison.h> #include <linux/poison.h>
#include <linux/bitrev.h> #include <linux/bitrev.h>
#include <linux/mutex.h>
#include <asm/atomic.h> #include <asm/atomic.h>
#include <asm/io.h> #include <asm/io.h>
...@@ -1177,7 +1178,7 @@ static int amb_open (struct atm_vcc * atm_vcc) ...@@ -1177,7 +1178,7 @@ static int amb_open (struct atm_vcc * atm_vcc)
vcc->tx_frame_bits = tx_frame_bits; vcc->tx_frame_bits = tx_frame_bits;
down (&dev->vcc_sf); mutex_lock(&dev->vcc_sf);
if (dev->rxer[vci]) { if (dev->rxer[vci]) {
// RXer on the channel already, just modify rate... // RXer on the channel already, just modify rate...
cmd.request = cpu_to_be32 (SRB_MODIFY_VC_RATE); cmd.request = cpu_to_be32 (SRB_MODIFY_VC_RATE);
...@@ -1203,7 +1204,7 @@ static int amb_open (struct atm_vcc * atm_vcc) ...@@ -1203,7 +1204,7 @@ static int amb_open (struct atm_vcc * atm_vcc)
schedule(); schedule();
} }
dev->txer[vci].tx_present = 1; dev->txer[vci].tx_present = 1;
up (&dev->vcc_sf); mutex_unlock(&dev->vcc_sf);
} }
if (rxtp->traffic_class != ATM_NONE) { if (rxtp->traffic_class != ATM_NONE) {
...@@ -1211,7 +1212,7 @@ static int amb_open (struct atm_vcc * atm_vcc) ...@@ -1211,7 +1212,7 @@ static int amb_open (struct atm_vcc * atm_vcc)
vcc->rx_info.pool = pool; vcc->rx_info.pool = pool;
down (&dev->vcc_sf); mutex_lock(&dev->vcc_sf);
/* grow RX buffer pool */ /* grow RX buffer pool */
if (!dev->rxq[pool].buffers_wanted) if (!dev->rxq[pool].buffers_wanted)
dev->rxq[pool].buffers_wanted = rx_lats; dev->rxq[pool].buffers_wanted = rx_lats;
...@@ -1237,7 +1238,7 @@ static int amb_open (struct atm_vcc * atm_vcc) ...@@ -1237,7 +1238,7 @@ static int amb_open (struct atm_vcc * atm_vcc)
schedule(); schedule();
// this link allows RX frames through // this link allows RX frames through
dev->rxer[vci] = atm_vcc; dev->rxer[vci] = atm_vcc;
up (&dev->vcc_sf); mutex_unlock(&dev->vcc_sf);
} }
// indicate readiness // indicate readiness
...@@ -1262,7 +1263,7 @@ static void amb_close (struct atm_vcc * atm_vcc) { ...@@ -1262,7 +1263,7 @@ static void amb_close (struct atm_vcc * atm_vcc) {
if (atm_vcc->qos.txtp.traffic_class != ATM_NONE) { if (atm_vcc->qos.txtp.traffic_class != ATM_NONE) {
command cmd; command cmd;
down (&dev->vcc_sf); mutex_lock(&dev->vcc_sf);
if (dev->rxer[vci]) { if (dev->rxer[vci]) {
// RXer still on the channel, just modify rate... XXX not really needed // RXer still on the channel, just modify rate... XXX not really needed
cmd.request = cpu_to_be32 (SRB_MODIFY_VC_RATE); cmd.request = cpu_to_be32 (SRB_MODIFY_VC_RATE);
...@@ -1277,7 +1278,7 @@ static void amb_close (struct atm_vcc * atm_vcc) { ...@@ -1277,7 +1278,7 @@ static void amb_close (struct atm_vcc * atm_vcc) {
dev->txer[vci].tx_present = 0; dev->txer[vci].tx_present = 0;
while (command_do (dev, &cmd)) while (command_do (dev, &cmd))
schedule(); schedule();
up (&dev->vcc_sf); mutex_unlock(&dev->vcc_sf);
} }
// disable RXing // disable RXing
...@@ -1287,7 +1288,7 @@ static void amb_close (struct atm_vcc * atm_vcc) { ...@@ -1287,7 +1288,7 @@ static void amb_close (struct atm_vcc * atm_vcc) {
// this is (the?) one reason why we need the amb_vcc struct // this is (the?) one reason why we need the amb_vcc struct
unsigned char pool = vcc->rx_info.pool; unsigned char pool = vcc->rx_info.pool;
down (&dev->vcc_sf); mutex_lock(&dev->vcc_sf);
if (dev->txer[vci].tx_present) { if (dev->txer[vci].tx_present) {
// TXer still on the channel, just go to pool zero XXX not really needed // TXer still on the channel, just go to pool zero XXX not really needed
cmd.request = cpu_to_be32 (SRB_MODIFY_VC_FLAGS); cmd.request = cpu_to_be32 (SRB_MODIFY_VC_FLAGS);
...@@ -1314,7 +1315,7 @@ static void amb_close (struct atm_vcc * atm_vcc) { ...@@ -1314,7 +1315,7 @@ static void amb_close (struct atm_vcc * atm_vcc) {
dev->rxq[pool].buffers_wanted = 0; dev->rxq[pool].buffers_wanted = 0;
drain_rx_pool (dev, pool); drain_rx_pool (dev, pool);
} }
up (&dev->vcc_sf); mutex_unlock(&dev->vcc_sf);
} }
// free our structure // free our structure
...@@ -2188,7 +2189,7 @@ static void setup_dev(amb_dev *dev, struct pci_dev *pci_dev) ...@@ -2188,7 +2189,7 @@ static void setup_dev(amb_dev *dev, struct pci_dev *pci_dev)
// semaphore for txer/rxer modifications - we cannot use a // semaphore for txer/rxer modifications - we cannot use a
// spinlock as the critical region needs to switch processes // spinlock as the critical region needs to switch processes
init_MUTEX (&dev->vcc_sf); mutex_init(&dev->vcc_sf);
// queue manipulation spinlocks; we want atomic reads and // queue manipulation spinlocks; we want atomic reads and
// writes to the queue descriptors (handles IRQ and SMP) // writes to the queue descriptors (handles IRQ and SMP)
// consider replacing "int pending" -> "atomic_t available" // consider replacing "int pending" -> "atomic_t available"
......
...@@ -638,7 +638,7 @@ struct amb_dev { ...@@ -638,7 +638,7 @@ struct amb_dev {
amb_txq txq; amb_txq txq;
amb_rxq rxq[NUM_RX_POOLS]; amb_rxq rxq[NUM_RX_POOLS];
struct semaphore vcc_sf; struct mutex vcc_sf;
amb_tx_info txer[NUM_VCS]; amb_tx_info txer[NUM_VCS];
struct atm_vcc * rxer[NUM_VCS]; struct atm_vcc * rxer[NUM_VCS];
unsigned int tx_avail; unsigned int tx_avail;
......
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