aboutsummaryrefslogtreecommitdiffstats
path: root/fs/ceph/osd_client.h
diff options
context:
space:
mode:
authorYehuda Sadeh <yehuda@hq.newdream.net>2010-01-13 20:03:23 -0500
committerSage Weil <sage@newdream.net>2010-01-25 15:58:08 -0500
commit0d59ab81c3d3adf466c3fd37d7fb6d46b05d1fd4 (patch)
tree1cdf338188bc323379ced8d5e1bdec31f500768c /fs/ceph/osd_client.h
parent0547a9b30a5ac8680325752b61d3ffa9d4971b6e (diff)
ceph: keep reserved replies on the request structure
This includes treating all the data preallocation and revokation at the same place, not having to have a special case for the reserved pages. Signed-off-by: Yehuda Sadeh <yehuda@hq.newdream.net>
Diffstat (limited to 'fs/ceph/osd_client.h')
-rw-r--r--fs/ceph/osd_client.h8
1 files changed, 5 insertions, 3 deletions
diff --git a/fs/ceph/osd_client.h b/fs/ceph/osd_client.h
index 4162c6810a8f..8d533d9406ff 100644
--- a/fs/ceph/osd_client.h
+++ b/fs/ceph/osd_client.h
@@ -44,7 +44,7 @@ struct ceph_osd_request {
44 struct ceph_osd *r_osd; 44 struct ceph_osd *r_osd;
45 struct ceph_pg r_pgid; 45 struct ceph_pg r_pgid;
46 46
47 struct ceph_connection *r_con_filling_pages; 47 struct ceph_connection *r_con_filling_msg;
48 48
49 struct ceph_msg *r_request, *r_reply; 49 struct ceph_msg *r_request, *r_reply;
50 int r_result; 50 int r_result;
@@ -75,6 +75,9 @@ struct ceph_osd_request {
75 struct page **r_pages; /* pages for data payload */ 75 struct page **r_pages; /* pages for data payload */
76 int r_pages_from_pool; 76 int r_pages_from_pool;
77 int r_own_pages; /* if true, i own page list */ 77 int r_own_pages; /* if true, i own page list */
78
79 struct ceph_msg *replies[2];
80 int cur_reply;
78}; 81};
79 82
80struct ceph_osd_client { 83struct ceph_osd_client {
@@ -98,8 +101,7 @@ struct ceph_osd_client {
98 101
99 mempool_t *req_mempool; 102 mempool_t *req_mempool;
100 103
101 struct ceph_msgpool msgpool_op; 104 struct ceph_msgpool msgpool_op;
102 struct ceph_msgpool msgpool_op_reply;
103}; 105};
104 106
105extern int ceph_osdc_init(struct ceph_osd_client *osdc, 107extern int ceph_osdc_init(struct ceph_osd_client *osdc,