From e0db724f513abad5f726af1ff97728181133f6d4 Mon Sep 17 00:00:00 2001 From: sageweil Date: Fri, 30 Nov 2007 17:33:38 +0000 Subject: [PATCH] queue send work if new messages are queued git-svn-id: https://ceph.svn.sf.net/svnroot/ceph@2160 29311d96-e01e-0410-9327-a35deaab8ce9 --- trunk/ceph/kernel/messenger.c | 3 +++ 1 file changed, 3 insertions(+) diff --git a/trunk/ceph/kernel/messenger.c b/trunk/ceph/kernel/messenger.c index 35af66e8540bc..64ecfdd3edcd9 100644 --- a/trunk/ceph/kernel/messenger.c +++ b/trunk/ceph/kernel/messenger.c @@ -935,6 +935,9 @@ int ceph_msg_send(struct ceph_messenger *msgr, struct ceph_msg *msg) ceph_msg_get(msg); list_add_tail(&msg->list_head, &con->out_queue); + if (test_and_set_bit(WRITE_PENDING, &con->state) == 0) + queue_work(send_wq, &con->swork); + out: spin_unlock(&con->lock); put_connection(con); -- 2.39.5