openkylin
/
linux
mirror of https://gitee.com/openkylin/linux.git
9
0
Fork 0
Code Issues Projects Releases Wiki Activity

rocker: pre-allocate wait structures during cmd ring init 

This avoids need to alloc/free wait structure for every command call.

Signed-off-by: Jiri Pirko <jiri@mellanox.com>
Signed-off-by: David S. Miller <davem@davemloft.net>
This commit is contained in:
Jiri Pirko 2016-02-16 15:14:47 +01:00 committed by David S. Miller
parent c1fe922e15
commit ca0a5f2a39
1 changed files with 66 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

87
drivers/net/ethernet/rocker/rocker_main.c
View File

@ -338,23 +338,19 @@ static void rocker_wait_init(struct rocker_wait *wait)
rocker_wait_reset(wait);
}
static struct rocker_wait *rocker_wait_create(struct rocker_port *rocker_port,
struct switchdev_trans *trans,
int flags)
static struct rocker_wait *rocker_wait_create(void)
{
struct rocker_wait *wait;
wait = rocker_kzalloc(trans, flags, sizeof(*wait));
wait = kzalloc(sizeof(*wait), GFP_KERNEL);
if (!wait)
return NULL;
rocker_wait_init(wait);
return wait;
}
static void rocker_wait_destroy(struct switchdev_trans *trans,
struct rocker_wait *wait)
static void rocker_wait_destroy(struct rocker_wait *wait)
{
rocker_kfree(trans, wait);
kfree(wait);
}
static bool rocker_wait_event_timeout(struct rocker_wait *wait,
@ -831,6 +827,53 @@ static void rocker_dma_ring_bufs_free(const struct rocker *rocker,
}
}
static int rocker_dma_cmd_ring_wait_alloc(struct rocker_desc_info *desc_info)
{
struct rocker_wait *wait;
wait = rocker_wait_create();
if (!wait)
return -ENOMEM;
rocker_desc_cookie_ptr_set(desc_info, wait);
return 0;
}
static void
rocker_dma_cmd_ring_wait_free(const struct rocker_desc_info *desc_info)
{
struct rocker_wait *wait = rocker_desc_cookie_ptr_get(desc_info);
rocker_wait_destroy(wait);
}
static int rocker_dma_cmd_ring_waits_alloc(const struct rocker *rocker)
{
const struct rocker_dma_ring_info *cmd_ring = &rocker->cmd_ring;
int i;
int err;
for (i = 0; i < cmd_ring->size; i++) {
err = rocker_dma_cmd_ring_wait_alloc(&cmd_ring->desc_info[i]);
if (err)
goto rollback;
}
return 0;
rollback:
for (i--; i >= 0; i--)
rocker_dma_cmd_ring_wait_free(&cmd_ring->desc_info[i]);
return err;
}
static void rocker_dma_cmd_ring_waits_free(const struct rocker *rocker)
{
const struct rocker_dma_ring_info *cmd_ring = &rocker->cmd_ring;
int i;
for (i = 0; i < cmd_ring->size; i++)
rocker_dma_cmd_ring_wait_free(&cmd_ring->desc_info[i]);
}
static int rocker_dma_rings_init(struct rocker *rocker)
{
const struct pci_dev *pdev = rocker->pdev;
@ -853,6 +896,12 @@ static int rocker_dma_rings_init(struct rocker *rocker)
goto err_dma_cmd_ring_bufs_alloc;
}
err = rocker_dma_cmd_ring_waits_alloc(rocker);
if (err) {
dev_err(&pdev->dev, "failed to alloc command dma ring waits\n");
goto err_dma_cmd_ring_waits_alloc;
}
err = rocker_dma_ring_create(rocker, ROCKER_DMA_EVENT,
ROCKER_DMA_EVENT_DEFAULT_SIZE,
&rocker->event_ring);
@ -875,6 +924,8 @@ static int rocker_dma_rings_init(struct rocker *rocker)
err_dma_event_ring_create:
rocker_dma_ring_bufs_free(rocker, &rocker->cmd_ring,
PCI_DMA_BIDIRECTIONAL);
err_dma_cmd_ring_waits_alloc:
rocker_dma_cmd_ring_waits_free(rocker);
err_dma_cmd_ring_bufs_alloc:
rocker_dma_ring_destroy(rocker, &rocker->cmd_ring);
return err;
@ -885,6 +936,7 @@ static void rocker_dma_rings_fini(struct rocker *rocker)
rocker_dma_ring_bufs_free(rocker, &rocker->event_ring,
PCI_DMA_BIDIRECTIONAL);
rocker_dma_ring_destroy(rocker, &rocker->event_ring);
rocker_dma_cmd_ring_waits_free(rocker);
rocker_dma_ring_bufs_free(rocker, &rocker->cmd_ring,
PCI_DMA_BIDIRECTIONAL);
rocker_dma_ring_destroy(rocker, &rocker->cmd_ring);
@ -1106,7 +1158,6 @@ static irqreturn_t rocker_cmd_irq_handler(int irq, void *dev_id)
wait = rocker_desc_cookie_ptr_get(desc_info);
if (wait->nowait) {
rocker_desc_gen_clear(desc_info);
rocker_wait_destroy(NULL, wait);
} else {
rocker_wait_wake_up(wait);
}
@ -1298,28 +1349,24 @@ static int rocker_cmd_exec(struct rocker_port *rocker_port,
unsigned long lock_flags;
int err;
wait = rocker_wait_create(rocker_port, trans, flags);
if (!wait)
return -ENOMEM;
wait->nowait = nowait;
spin_lock_irqsave(&rocker->cmd_ring_lock, lock_flags);
desc_info = rocker_desc_head_get(&rocker->cmd_ring);
if (!desc_info) {
spin_unlock_irqrestore(&rocker->cmd_ring_lock, lock_flags);
err = -EAGAIN;
goto out;
return -EAGAIN;
}
wait = rocker_desc_cookie_ptr_get(desc_info);
rocker_wait_init(wait);
wait->nowait = nowait;
err = prepare(rocker_port, desc_info, prepare_priv);
if (err) {
spin_unlock_irqrestore(&rocker->cmd_ring_lock, lock_flags);
goto out;
return err;
}
rocker_desc_cookie_ptr_set(desc_info, wait);
if (!switchdev_trans_ph_prepare(trans))
rocker_desc_head_set(rocker, &rocker->cmd_ring, desc_info);
@ -1340,8 +1387,6 @@ static int rocker_cmd_exec(struct rocker_port *rocker_port,
err = process(rocker_port, desc_info, process_priv);
rocker_desc_gen_clear(desc_info);
out:
rocker_wait_destroy(trans, wait);
return err;
}