Skip to content

Commit

Permalink
net: qrtr: Remove receive worker
Browse files Browse the repository at this point in the history
Rather than enqueuing messages and scheduling a worker to deliver them
to the individual sockets we can now, thanks to the previous work, move
this directly into the endpoint callback.

This saves us a context switch per incoming message and removes the
possibility of an opportunistic suspend to happen between the message is
coming from the endpoint until it ends up in the socket's receive
buffer.

Signed-off-by: Bjorn Andersson <[email protected]>
Signed-off-by: David S. Miller <[email protected]>
  • Loading branch information
andersson authored and davem330 committed Jan 15, 2020
1 parent f16a4b2 commit e04df98
Showing 1 changed file with 17 additions and 40 deletions.
57 changes: 17 additions & 40 deletions net/qrtr/qrtr.c
Original file line number Diff line number Diff line change
Expand Up @@ -119,7 +119,6 @@ static DEFINE_MUTEX(qrtr_port_lock);
* @qrtr_tx_flow: tree of qrtr_tx_flow, keyed by node << 32 | port
* @qrtr_tx_lock: lock for qrtr_tx_flow inserts
* @rx_queue: receive queue
* @work: scheduled work struct for recv work
* @item: list item for broadcast list
*/
struct qrtr_node {
Expand All @@ -132,7 +131,6 @@ struct qrtr_node {
struct mutex qrtr_tx_lock; /* for qrtr_tx_flow */

struct sk_buff_head rx_queue;
struct work_struct work;
struct list_head item;
};

Expand All @@ -157,6 +155,8 @@ static int qrtr_local_enqueue(struct qrtr_node *node, struct sk_buff *skb,
static int qrtr_bcast_enqueue(struct qrtr_node *node, struct sk_buff *skb,
int type, struct sockaddr_qrtr *from,
struct sockaddr_qrtr *to);
static struct qrtr_sock *qrtr_port_lookup(int port);
static void qrtr_port_put(struct qrtr_sock *ipc);

/* Release node resources and free the node.
*
Expand All @@ -178,7 +178,6 @@ static void __qrtr_node_release(struct kref *kref)
list_del(&node->item);
mutex_unlock(&qrtr_node_lock);

cancel_work_sync(&node->work);
skb_queue_purge(&node->rx_queue);

/* Free tx flow counters */
Expand Down Expand Up @@ -422,6 +421,7 @@ int qrtr_endpoint_post(struct qrtr_endpoint *ep, const void *data, size_t len)
struct qrtr_node *node = ep->node;
const struct qrtr_hdr_v1 *v1;
const struct qrtr_hdr_v2 *v2;
struct qrtr_sock *ipc;
struct sk_buff *skb;
struct qrtr_cb *cb;
unsigned int size;
Expand Down Expand Up @@ -486,8 +486,20 @@ int qrtr_endpoint_post(struct qrtr_endpoint *ep, const void *data, size_t len)

skb_put_data(skb, data + hdrlen, size);

skb_queue_tail(&node->rx_queue, skb);
schedule_work(&node->work);
qrtr_node_assign(node, cb->src_node);

if (cb->type == QRTR_TYPE_RESUME_TX) {
qrtr_tx_resume(node, skb);
} else {
ipc = qrtr_port_lookup(cb->dst_port);
if (!ipc)
goto err;

if (sock_queue_rcv_skb(&ipc->sk, skb))
goto err;

qrtr_port_put(ipc);
}

return 0;

Expand Down Expand Up @@ -522,40 +534,6 @@ static struct sk_buff *qrtr_alloc_ctrl_packet(struct qrtr_ctrl_pkt **pkt)
return skb;
}

static struct qrtr_sock *qrtr_port_lookup(int port);
static void qrtr_port_put(struct qrtr_sock *ipc);

/* Handle and route a received packet.
*
* This will auto-reply with resume-tx packet as necessary.
*/
static void qrtr_node_rx_work(struct work_struct *work)
{
struct qrtr_node *node = container_of(work, struct qrtr_node, work);
struct sk_buff *skb;

while ((skb = skb_dequeue(&node->rx_queue)) != NULL) {
struct qrtr_sock *ipc;
struct qrtr_cb *cb = (struct qrtr_cb *)skb->cb;

qrtr_node_assign(node, cb->src_node);

if (cb->type == QRTR_TYPE_RESUME_TX) {
qrtr_tx_resume(node, skb);
} else {
ipc = qrtr_port_lookup(cb->dst_port);
if (!ipc) {
kfree_skb(skb);
} else {
if (sock_queue_rcv_skb(&ipc->sk, skb))
kfree_skb(skb);

qrtr_port_put(ipc);
}
}
}
}

/**
* qrtr_endpoint_register() - register a new endpoint
* @ep: endpoint to register
Expand All @@ -575,7 +553,6 @@ int qrtr_endpoint_register(struct qrtr_endpoint *ep, unsigned int nid)
if (!node)
return -ENOMEM;

INIT_WORK(&node->work, qrtr_node_rx_work);
kref_init(&node->ref);
mutex_init(&node->ep_lock);
skb_queue_head_init(&node->rx_queue);
Expand Down

0 comments on commit e04df98

Please sign in to comment.