[sheepdog] [PATCH v8 08/19] sheep: get_request() for deferred response
Hitoshi Mitake
mitake.hitoshi at gmail.com
Thu May 15 17:22:35 CEST 2014
With the new function, response message to clients can be deferred
safely without blocking the main thread.
Cc: MORITA Kazutaka <morita.kazutaka at lab.ntt.co.jp>
Cc: Valerio Pachera <sirio81 at gmail.com>
Cc: Alessandro Bolgia <alessandro at extensys.it>
Signed-off-by: Hitoshi Mitake <mitake.hitoshi at lab.ntt.co.jp>
---
sheep/request.c | 5 +++++
sheep/sheep_priv.h | 1 +
2 files changed, 6 insertions(+)
diff --git a/sheep/request.c b/sheep/request.c
index 4aa928e..6972f10 100644
--- a/sheep/request.c
+++ b/sheep/request.c
@@ -709,6 +709,11 @@ main_fn void put_request(struct request *req)
}
}
+main_fn void get_request(struct request *req)
+{
+ refcount_inc(&req->refcnt);
+}
+
static void rx_work(struct work *work)
{
struct client_info *ci = container_of(work, struct client_info,
diff --git a/sheep/sheep_priv.h b/sheep/sheep_priv.h
index 1b95901..9c08b0c 100644
--- a/sheep/sheep_priv.h
+++ b/sheep/sheep_priv.h
@@ -398,6 +398,7 @@ int objlist_cache_insert(uint64_t oid);
void objlist_cache_remove(uint64_t oid);
void put_request(struct request *req);
+void get_request(struct request *req);
int sheep_bnode_writer(uint64_t oid, void *mem, unsigned int len,
uint64_t offset, uint32_t flags, int copies,
--
1.9.1
More information about the sheepdog
mailing list