[linux-2.6-block.git] / fs / ceph / osd_client.h

#ifndef _FS_CEPH_OSD_CLIENT_H
#define _FS_CEPH_OSD_CLIENT_H

#include <linux/completion.h>
#include <linux/mempool.h>
#include <linux/rbtree.h>

#include "types.h"
#include "osdmap.h"
#include "messenger.h"

struct ceph_msg;
struct ceph_snap_context;
struct ceph_osd_request;
struct ceph_osd_client;

/*
 * completion callback for async writepages
 */
typedef void (*ceph_osdc_callback_t)(struct ceph_osd_request *,
				     struct ceph_msg *);

/* a given osd we're communicating with */
struct ceph_osd {
	atomic_t o_ref;
	struct ceph_osd_client *o_osdc;
	int o_osd;
	int o_incarnation;
	struct rb_node o_node;
	struct ceph_connection o_con;
	struct list_head o_requests;
};

/* an in-flight request */
struct ceph_osd_request {
	u64             r_tid;              /* unique for this client */
	struct rb_node  r_node;
	struct list_head r_osd_item;
	struct ceph_osd *r_osd;

	struct ceph_msg  *r_request, *r_reply;
	int               r_result;
	int               r_flags;     /* any additional flags for the osd */
	u32               r_sent;      /* >0 if r_request is sending/sent */
	int r_prepared_pages, r_got_reply;

	struct ceph_osd_client *r_osdc;
	atomic_t          r_ref;
	bool              r_mempool;
	struct completion r_completion, r_safe_completion;
	ceph_osdc_callback_t r_callback, r_safe_callback;
	struct ceph_eversion r_reassert_version;
	struct list_head  r_unsafe_item;

	struct inode *r_inode;         	      /* for use by callbacks */
	struct writeback_control *r_wbc;      /* ditto */

	char              r_oid[40];          /* object name */
	int               r_oid_len;
	unsigned long     r_timeout_stamp;
	bool              r_resend;           /* msg send failed, needs retry */

	struct ceph_file_layout r_file_layout;
	struct ceph_snap_context *r_snapc;    /* snap context for writes */
	unsigned          r_num_pages;        /* size of page array (follows) */
	struct page     **r_pages;            /* pages for data payload */
	int               r_pages_from_pool;
	int               r_own_pages;        /* if true, i own page list */
};

struct ceph_osd_client {
	struct ceph_client     *client;

	struct ceph_osdmap     *osdmap;       /* current map */
	struct rw_semaphore    map_sem;
	struct completion      map_waiters;
	u64                    last_requested_map;

	struct mutex           request_mutex;
	struct rb_root         osds;          /* osds */
	u64                    timeout_tid;   /* tid of timeout triggering rq */
	u64                    last_tid;      /* tid of last request */
	struct rb_root         requests;      /* pending requests */
	int                    num_requests;
	struct delayed_work    timeout_work;
	struct dentry 	       *debugfs_file;

	mempool_t              *req_mempool;

	struct ceph_msgpool   msgpool_op;
	struct ceph_msgpool   msgpool_op_reply;
};

extern int ceph_osdc_init(struct ceph_osd_client *osdc,
			  struct ceph_client *client);
extern void ceph_osdc_stop(struct ceph_osd_client *osdc);

extern void ceph_osdc_handle_reply(struct ceph_osd_client *osdc,
				   struct ceph_msg *msg);
extern void ceph_osdc_handle_map(struct ceph_osd_client *osdc,
				 struct ceph_msg *msg);

extern struct ceph_osd_request *ceph_osdc_new_request(struct ceph_osd_client *,
				      struct ceph_file_layout *layout,
				      struct ceph_vino vino,
				      u64 offset, u64 *len, int op, int flags,
				      struct ceph_snap_context *snapc,
				      int do_sync, u32 truncate_seq,
				      u64 truncate_size,
				      struct timespec *mtime,
				      bool use_mempool, int num_reply);

static inline void ceph_osdc_get_request(struct ceph_osd_request *req)
{
	atomic_inc(&req->r_ref);
}
extern void ceph_osdc_put_request(struct ceph_osd_request *req);

extern int ceph_osdc_start_request(struct ceph_osd_client *osdc,
				   struct ceph_osd_request *req,
				   bool nofail);
extern int ceph_osdc_wait_request(struct ceph_osd_client *osdc,
				  struct ceph_osd_request *req);
extern void ceph_osdc_sync(struct ceph_osd_client *osdc);

extern int ceph_osdc_readpages(struct ceph_osd_client *osdc,
			       struct ceph_vino vino,
			       struct ceph_file_layout *layout,
			       u64 off, u64 *plen,
			       u32 truncate_seq, u64 truncate_size,
			       struct page **pages, int nr_pages);

extern int ceph_osdc_writepages(struct ceph_osd_client *osdc,
				struct ceph_vino vino,
				struct ceph_file_layout *layout,
				struct ceph_snap_context *sc,
				u64 off, u64 len,
				u32 truncate_seq, u64 truncate_size,
				struct timespec *mtime,
				struct page **pages, int nr_pages,
				int flags, int do_sync, bool nofail);

#endif
Commit	Line	Data
f24e9980 SW	1	#ifndef _FS_CEPH_OSD_CLIENT_H
	2	#define _FS_CEPH_OSD_CLIENT_H
	3
	4	#include <linux/completion.h>
	5	#include <linux/mempool.h>
	6	#include <linux/rbtree.h>
	7
	8	#include "types.h"
	9	#include "osdmap.h"
	10	#include "messenger.h"
	11
	12	struct ceph_msg;
	13	struct ceph_snap_context;
	14	struct ceph_osd_request;
	15	struct ceph_osd_client;
	16
	17	/*
	18	* completion callback for async writepages
	19	*/
	20	typedef void (ceph_osdc_callback_t)(struct ceph_osd_request ,
	21	struct ceph_msg *);
	22
	23	/* a given osd we're communicating with */
	24	struct ceph_osd {
	25	atomic_t o_ref;
	26	struct ceph_osd_client *o_osdc;
	27	int o_osd;
	28	int o_incarnation;
	29	struct rb_node o_node;
	30	struct ceph_connection o_con;
	31	struct list_head o_requests;
	32	};
	33
	34	/* an in-flight request */
	35	struct ceph_osd_request {
	36	u64 r_tid; /* unique for this client */
	37	struct rb_node r_node;
	38	struct list_head r_osd_item;
	39	struct ceph_osd *r_osd;
	40
	41	struct ceph_msg r_request, r_reply;
	42	int r_result;
	43	int r_flags; /* any additional flags for the osd */
	44	u32 r_sent; /* >0 if r_request is sending/sent */
	45	int r_prepared_pages, r_got_reply;
	46
	47	struct ceph_osd_client *r_osdc;
	48	atomic_t r_ref;
	49	bool r_mempool;
	50	struct completion r_completion, r_safe_completion;
	51	ceph_osdc_callback_t r_callback, r_safe_callback;
	52	struct ceph_eversion r_reassert_version;
	53	struct list_head r_unsafe_item;
	54
	55	struct inode r_inode; / for use by callbacks */
	56	struct writeback_control r_wbc; / ditto */
	57
	58	char r_oid[40]; /* object name */
	59	int r_oid_len;
	60	unsigned long r_timeout_stamp;
	61	bool r_resend; /* msg send failed, needs retry */
	62
	63	struct ceph_file_layout r_file_layout;
	64	struct ceph_snap_context r_snapc; / snap context for writes */
65	unsigned r_num_pages; /* size of page array (follows) */
66	struct page *r_pages; / pages for data payload */
67	int r_pages_from_pool;
68	int r_own_pages; /* if true, i own page list */
69	};
70
71	struct ceph_osd_client {
72	struct ceph_client *client;
73
74	struct ceph_osdmap osdmap; / current map */
75	struct rw_semaphore map_sem;
76	struct completion map_waiters;
77	u64 last_requested_map;
78
79	struct mutex request_mutex;
80	struct rb_root osds; /* osds */
81	u64 timeout_tid; /* tid of timeout triggering rq */
82	u64 last_tid; /* tid of last request */
83	struct rb_root requests; /* pending requests */
84	int num_requests;
85	struct delayed_work timeout_work;
86	struct dentry *debugfs_file;
87
88	mempool_t *req_mempool;
89
90	struct ceph_msgpool msgpool_op;
91	struct ceph_msgpool msgpool_op_reply;
92	};
93
94	extern int ceph_osdc_init(struct ceph_osd_client *osdc,
95	struct ceph_client *client);
96	extern void ceph_osdc_stop(struct ceph_osd_client *osdc);
97
98	extern void ceph_osdc_handle_reply(struct ceph_osd_client *osdc,
99	struct ceph_msg *msg);
100	extern void ceph_osdc_handle_map(struct ceph_osd_client *osdc,
101	struct ceph_msg *msg);
102
103	extern struct ceph_osd_request ceph_osdc_new_request(struct ceph_osd_client ,
104	struct ceph_file_layout *layout,
105	struct ceph_vino vino,
106	u64 offset, u64 *len, int op, int flags,
107	struct ceph_snap_context *snapc,
108	int do_sync, u32 truncate_seq,
109	u64 truncate_size,
110	struct timespec *mtime,
111	bool use_mempool, int num_reply);
112
113	static inline void ceph_osdc_get_request(struct ceph_osd_request *req)
114	{
115	atomic_inc(&req->r_ref);
116	}
117	extern void ceph_osdc_put_request(struct ceph_osd_request *req);
118
119	extern int ceph_osdc_start_request(struct ceph_osd_client *osdc,
120	struct ceph_osd_request *req,
121	bool nofail);
122	extern int ceph_osdc_wait_request(struct ceph_osd_client *osdc,
123	struct ceph_osd_request *req);
124	extern void ceph_osdc_sync(struct ceph_osd_client *osdc);
125
126	extern int ceph_osdc_readpages(struct ceph_osd_client *osdc,
127	struct ceph_vino vino,
128	struct ceph_file_layout *layout,
129	u64 off, u64 *plen,
130	u32 truncate_seq, u64 truncate_size,
131	struct page **pages, int nr_pages);
132
133	extern int ceph_osdc_writepages(struct ceph_osd_client *osdc,
134	struct ceph_vino vino,
135	struct ceph_file_layout *layout,
136	struct ceph_snap_context *sc,
137	u64 off, u64 len,
138	u32 truncate_seq, u64 truncate_size,
139	struct timespec *mtime,
140	struct page **pages, int nr_pages,
141	int flags, int do_sync, bool nofail);
142
143	#endif
144