Commit 072a14ec authored by Long Li's avatar Long Li Committed by Steve French

cifs: smbd: Merge code to track pending packets

As an optimization, SMBD tries to track two types of packets: packets with
payload and without payload. There is no obvious benefit or performance gain
to separately track two types of packets.

Just treat them as pending packets and merge the tracking code.
Signed-off-by: default avatarLong Li <longli@microsoft.com>
Signed-off-by: default avatarSteve French <stfrench@microsoft.com>
parent e79b0332
...@@ -323,10 +323,8 @@ static int cifs_debug_data_proc_show(struct seq_file *m, void *v) ...@@ -323,10 +323,8 @@ static int cifs_debug_data_proc_show(struct seq_file *m, void *v)
atomic_read(&server->smbd_conn->send_credits), atomic_read(&server->smbd_conn->send_credits),
atomic_read(&server->smbd_conn->receive_credits), atomic_read(&server->smbd_conn->receive_credits),
server->smbd_conn->receive_credit_target); server->smbd_conn->receive_credit_target);
seq_printf(m, "\nPending send_pending: %x " seq_printf(m, "\nPending send_pending: %x ",
"send_payload_pending: %x", atomic_read(&server->smbd_conn->send_pending));
atomic_read(&server->smbd_conn->send_pending),
atomic_read(&server->smbd_conn->send_payload_pending));
seq_printf(m, "\nReceive buffers count_receive_queue: %x " seq_printf(m, "\nReceive buffers count_receive_queue: %x "
"count_empty_packet_queue: %x", "count_empty_packet_queue: %x",
server->smbd_conn->count_receive_queue, server->smbd_conn->count_receive_queue,
......
...@@ -284,13 +284,9 @@ static void send_done(struct ib_cq *cq, struct ib_wc *wc) ...@@ -284,13 +284,9 @@ static void send_done(struct ib_cq *cq, struct ib_wc *wc)
request->sge[i].length, request->sge[i].length,
DMA_TO_DEVICE); DMA_TO_DEVICE);
if (request->has_payload) {
if (atomic_dec_and_test(&request->info->send_payload_pending))
wake_up(&request->info->wait_send_payload_pending);
} else {
if (atomic_dec_and_test(&request->info->send_pending)) if (atomic_dec_and_test(&request->info->send_pending))
wake_up(&request->info->wait_send_pending); wake_up(&request->info->wait_send_pending);
}
mempool_free(request, request->info->request_mempool); mempool_free(request, request->info->request_mempool);
} }
...@@ -749,7 +745,6 @@ static int smbd_post_send_negotiate_req(struct smbd_connection *info) ...@@ -749,7 +745,6 @@ static int smbd_post_send_negotiate_req(struct smbd_connection *info)
request->sge[0].addr, request->sge[0].addr,
request->sge[0].length, request->sge[0].lkey); request->sge[0].length, request->sge[0].lkey);
request->has_payload = false;
atomic_inc(&info->send_pending); atomic_inc(&info->send_pending);
rc = ib_post_send(info->id->qp, &send_wr, NULL); rc = ib_post_send(info->id->qp, &send_wr, NULL);
if (!rc) if (!rc)
...@@ -919,7 +914,7 @@ static void smbd_destroy_header(struct smbd_connection *info, ...@@ -919,7 +914,7 @@ static void smbd_destroy_header(struct smbd_connection *info,
/* Post the send request */ /* Post the send request */
static int smbd_post_send(struct smbd_connection *info, static int smbd_post_send(struct smbd_connection *info,
struct smbd_request *request, bool has_payload) struct smbd_request *request)
{ {
struct ib_send_wr send_wr; struct ib_send_wr send_wr;
int rc, i; int rc, i;
...@@ -944,24 +939,13 @@ static int smbd_post_send(struct smbd_connection *info, ...@@ -944,24 +939,13 @@ static int smbd_post_send(struct smbd_connection *info,
send_wr.opcode = IB_WR_SEND; send_wr.opcode = IB_WR_SEND;
send_wr.send_flags = IB_SEND_SIGNALED; send_wr.send_flags = IB_SEND_SIGNALED;
if (has_payload) {
request->has_payload = true;
atomic_inc(&info->send_payload_pending);
} else {
request->has_payload = false;
atomic_inc(&info->send_pending); atomic_inc(&info->send_pending);
}
rc = ib_post_send(info->id->qp, &send_wr, NULL); rc = ib_post_send(info->id->qp, &send_wr, NULL);
if (rc) { if (rc) {
log_rdma_send(ERR, "ib_post_send failed rc=%d\n", rc); log_rdma_send(ERR, "ib_post_send failed rc=%d\n", rc);
if (has_payload) {
if (atomic_dec_and_test(&info->send_payload_pending))
wake_up(&info->wait_send_payload_pending);
} else {
if (atomic_dec_and_test(&info->send_pending)) if (atomic_dec_and_test(&info->send_pending))
wake_up(&info->wait_send_pending); wake_up(&info->wait_send_pending);
}
smbd_disconnect_rdma_connection(info); smbd_disconnect_rdma_connection(info);
rc = -EAGAIN; rc = -EAGAIN;
} else } else
...@@ -1001,7 +985,7 @@ static int smbd_post_send_sgl(struct smbd_connection *info, ...@@ -1001,7 +985,7 @@ static int smbd_post_send_sgl(struct smbd_connection *info,
request->num_sge++; request->num_sge++;
} }
rc = smbd_post_send(info, request, data_length); rc = smbd_post_send(info, request);
if (!rc) if (!rc)
return 0; return 0;
...@@ -1413,8 +1397,6 @@ void smbd_destroy(struct TCP_Server_Info *server) ...@@ -1413,8 +1397,6 @@ void smbd_destroy(struct TCP_Server_Info *server)
log_rdma_event(INFO, "wait for all send posted to IB to finish\n"); log_rdma_event(INFO, "wait for all send posted to IB to finish\n");
wait_event(info->wait_send_pending, wait_event(info->wait_send_pending,
atomic_read(&info->send_pending) == 0); atomic_read(&info->send_pending) == 0);
wait_event(info->wait_send_payload_pending,
atomic_read(&info->send_payload_pending) == 0);
/* It's not posssible for upper layer to get to reassembly */ /* It's not posssible for upper layer to get to reassembly */
log_rdma_event(INFO, "drain the reassembly queue\n"); log_rdma_event(INFO, "drain the reassembly queue\n");
...@@ -1751,8 +1733,6 @@ static struct smbd_connection *_smbd_get_connection( ...@@ -1751,8 +1733,6 @@ static struct smbd_connection *_smbd_get_connection(
init_waitqueue_head(&info->wait_send_pending); init_waitqueue_head(&info->wait_send_pending);
atomic_set(&info->send_pending, 0); atomic_set(&info->send_pending, 0);
init_waitqueue_head(&info->wait_send_payload_pending);
atomic_set(&info->send_payload_pending, 0);
INIT_WORK(&info->disconnect_work, smbd_disconnect_rdma_work); INIT_WORK(&info->disconnect_work, smbd_disconnect_rdma_work);
INIT_WORK(&info->post_send_credits_work, smbd_post_send_credits); INIT_WORK(&info->post_send_credits_work, smbd_post_send_credits);
...@@ -2226,8 +2206,8 @@ int smbd_send(struct TCP_Server_Info *server, ...@@ -2226,8 +2206,8 @@ int smbd_send(struct TCP_Server_Info *server,
* that means all the I/Os have been out and we are good to return * that means all the I/Os have been out and we are good to return
*/ */
wait_event(info->wait_send_payload_pending, wait_event(info->wait_send_pending,
atomic_read(&info->send_payload_pending) == 0); atomic_read(&info->send_pending) == 0);
return rc; return rc;
} }
......
...@@ -114,8 +114,6 @@ struct smbd_connection { ...@@ -114,8 +114,6 @@ struct smbd_connection {
/* Activity accoutning */ /* Activity accoutning */
atomic_t send_pending; atomic_t send_pending;
wait_queue_head_t wait_send_pending; wait_queue_head_t wait_send_pending;
atomic_t send_payload_pending;
wait_queue_head_t wait_send_payload_pending;
/* Receive queue */ /* Receive queue */
struct list_head receive_queue; struct list_head receive_queue;
...@@ -234,9 +232,6 @@ struct smbd_request { ...@@ -234,9 +232,6 @@ struct smbd_request {
struct smbd_connection *info; struct smbd_connection *info;
struct ib_cqe cqe; struct ib_cqe cqe;
/* true if this request carries upper layer payload */
bool has_payload;
/* the SGE entries for this packet */ /* the SGE entries for this packet */
struct ib_sge sge[SMBDIRECT_MAX_SGE]; struct ib_sge sge[SMBDIRECT_MAX_SGE];
int num_sge; int num_sge;
......
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