diff options
| author | Linus Torvalds <torvalds@linux-foundation.org> | 2010-10-21 15:38:28 -0400 |
|---|---|---|
| committer | Linus Torvalds <torvalds@linux-foundation.org> | 2010-10-21 15:38:28 -0400 |
| commit | 2017bd19454ea7cdae19922d15b6930f6c8088a2 (patch) | |
| tree | 53974657ab3a2c98f2da7b3fcb050ff5b697f876 /include/linux | |
| parent | 9f1ad09493451c19d00c004da479acf699eeedd6 (diff) | |
| parent | efa4c1206eaff047c474af2136748a58eb8cc33b (diff) | |
Merge branch 'for-linus' of git://git.kernel.org/pub/scm/linux/kernel/git/sage/ceph-client
* 'for-linus' of git://git.kernel.org/pub/scm/linux/kernel/git/sage/ceph-client: (22 commits)
ceph: do not carry i_lock for readdir from dcache
fs/ceph/xattr.c: Use kmemdup
rbd: passing wrong variable to bvec_kunmap_irq()
rbd: null vs ERR_PTR
ceph: fix num_pages_free accounting in pagelist
ceph: add CEPH_MDS_OP_SETDIRLAYOUT and associated ioctl.
ceph: don't crash when passed bad mount options
ceph: fix debugfs warnings
block: rbd: removing unnecessary test
block: rbd: fixed may leaks
ceph: switch from BKL to lock_flocks()
ceph: preallocate flock state without locks held
ceph: add pagelist_reserve, pagelist_truncate, pagelist_set_cursor
ceph: use mapping->nrpages to determine if mapping is empty
ceph: only invalidate on check_caps if we actually have pages
ceph: do not hide .snap in root directory
rbd: introduce rados block device (rbd), based on libceph
ceph: factor out libceph from Ceph file system
ceph-rbd: osdc support for osd call and rollback operations
ceph: messenger and osdc changes for rbd
...
Diffstat (limited to 'include/linux')
| -rw-r--r-- | include/linux/ceph/auth.h | 92 | ||||
| -rw-r--r-- | include/linux/ceph/buffer.h | 39 | ||||
| -rw-r--r-- | include/linux/ceph/ceph_debug.h | 38 | ||||
| -rw-r--r-- | include/linux/ceph/ceph_frag.h | 109 | ||||
| -rw-r--r-- | include/linux/ceph/ceph_fs.h | 729 | ||||
| -rw-r--r-- | include/linux/ceph/ceph_hash.h | 13 | ||||
| -rw-r--r-- | include/linux/ceph/debugfs.h | 33 | ||||
| -rw-r--r-- | include/linux/ceph/decode.h | 201 | ||||
| -rw-r--r-- | include/linux/ceph/libceph.h | 249 | ||||
| -rw-r--r-- | include/linux/ceph/mdsmap.h | 62 | ||||
| -rw-r--r-- | include/linux/ceph/messenger.h | 261 | ||||
| -rw-r--r-- | include/linux/ceph/mon_client.h | 122 | ||||
| -rw-r--r-- | include/linux/ceph/msgpool.h | 25 | ||||
| -rw-r--r-- | include/linux/ceph/msgr.h | 175 | ||||
| -rw-r--r-- | include/linux/ceph/osd_client.h | 234 | ||||
| -rw-r--r-- | include/linux/ceph/osdmap.h | 130 | ||||
| -rw-r--r-- | include/linux/ceph/pagelist.h | 75 | ||||
| -rw-r--r-- | include/linux/ceph/rados.h | 405 | ||||
| -rw-r--r-- | include/linux/ceph/types.h | 29 | ||||
| -rw-r--r-- | include/linux/crush/crush.h | 180 | ||||
| -rw-r--r-- | include/linux/crush/hash.h | 17 | ||||
| -rw-r--r-- | include/linux/crush/mapper.h | 20 |
22 files changed, 3238 insertions, 0 deletions
diff --git a/include/linux/ceph/auth.h b/include/linux/ceph/auth.h new file mode 100644 index 000000000000..7fff521d7eb5 --- /dev/null +++ b/include/linux/ceph/auth.h | |||
| @@ -0,0 +1,92 @@ | |||
| 1 | #ifndef _FS_CEPH_AUTH_H | ||
| 2 | #define _FS_CEPH_AUTH_H | ||
| 3 | |||
| 4 | #include <linux/ceph/types.h> | ||
| 5 | #include <linux/ceph/buffer.h> | ||
| 6 | |||
| 7 | /* | ||
| 8 | * Abstract interface for communicating with the authenticate module. | ||
| 9 | * There is some handshake that takes place between us and the monitor | ||
| 10 | * to acquire the necessary keys. These are used to generate an | ||
| 11 | * 'authorizer' that we use when connecting to a service (mds, osd). | ||
| 12 | */ | ||
| 13 | |||
| 14 | struct ceph_auth_client; | ||
| 15 | struct ceph_authorizer; | ||
| 16 | |||
| 17 | struct ceph_auth_client_ops { | ||
| 18 | const char *name; | ||
| 19 | |||
| 20 | /* | ||
| 21 | * true if we are authenticated and can connect to | ||
| 22 | * services. | ||
| 23 | */ | ||
| 24 | int (*is_authenticated)(struct ceph_auth_client *ac); | ||
| 25 | |||
| 26 | /* | ||
| 27 | * true if we should (re)authenticate, e.g., when our tickets | ||
| 28 | * are getting old and crusty. | ||
| 29 | */ | ||
| 30 | int (*should_authenticate)(struct ceph_auth_client *ac); | ||
| 31 | |||
| 32 | /* | ||
| 33 | * build requests and process replies during monitor | ||
| 34 | * handshake. if handle_reply returns -EAGAIN, we build | ||
| 35 | * another request. | ||
| 36 | */ | ||
| 37 | int (*build_request)(struct ceph_auth_client *ac, void *buf, void *end); | ||
| 38 | int (*handle_reply)(struct ceph_auth_client *ac, int result, | ||
| 39 | void *buf, void *end); | ||
| 40 | |||
| 41 | /* | ||
| 42 | * Create authorizer for connecting to a service, and verify | ||
| 43 | * the response to authenticate the service. | ||
| 44 | */ | ||
| 45 | int (*create_authorizer)(struct ceph_auth_client *ac, int peer_type, | ||
| 46 | struct ceph_authorizer **a, | ||
| 47 | void **buf, size_t *len, | ||
| 48 | void **reply_buf, size_t *reply_len); | ||
| 49 | int (*verify_authorizer_reply)(struct ceph_auth_client *ac, | ||
| 50 | struct ceph_authorizer *a, size_t len); | ||
| 51 | void (*destroy_authorizer)(struct ceph_auth_client *ac, | ||
| 52 | struct ceph_authorizer *a); | ||
| 53 | void (*invalidate_authorizer)(struct ceph_auth_client *ac, | ||
| 54 | int peer_type); | ||
| 55 | |||
| 56 | /* reset when we (re)connect to a monitor */ | ||
| 57 | void (*reset)(struct ceph_auth_client *ac); | ||
| 58 | |||
| 59 | void (*destroy)(struct ceph_auth_client *ac); | ||
| 60 | }; | ||
| 61 | |||
| 62 | struct ceph_auth_client { | ||
| 63 | u32 protocol; /* CEPH_AUTH_* */ | ||
| 64 | void *private; /* for use by protocol implementation */ | ||
| 65 | const struct ceph_auth_client_ops *ops; /* null iff protocol==0 */ | ||
| 66 | |||
| 67 | bool negotiating; /* true if negotiating protocol */ | ||
| 68 | const char *name; /* entity name */ | ||
| 69 | u64 global_id; /* our unique id in system */ | ||
| 70 | const char *secret; /* our secret key */ | ||
| 71 | unsigned want_keys; /* which services we want */ | ||
| 72 | }; | ||
| 73 | |||
| 74 | extern struct ceph_auth_client *ceph_auth_init(const char *name, | ||
| 75 | const char *secret); | ||
| 76 | extern void ceph_auth_destroy(struct ceph_auth_client *ac); | ||
| 77 | |||
| 78 | extern void ceph_auth_reset(struct ceph_auth_client *ac); | ||
| 79 | |||
| 80 | extern int ceph_auth_build_hello(struct ceph_auth_client *ac, | ||
| 81 | void *buf, size_t len); | ||
| 82 | extern int ceph_handle_auth_reply(struct ceph_auth_client *ac, | ||
| 83 | void *buf, size_t len, | ||
| 84 | void *reply_buf, size_t reply_len); | ||
| 85 | extern int ceph_entity_name_encode(const char *name, void **p, void *end); | ||
| 86 | |||
| 87 | extern int ceph_build_auth(struct ceph_auth_client *ac, | ||
| 88 | void *msg_buf, size_t msg_len); | ||
| 89 | |||
| 90 | extern int ceph_auth_is_authenticated(struct ceph_auth_client *ac); | ||
| 91 | |||
| 92 | #endif | ||
diff --git a/include/linux/ceph/buffer.h b/include/linux/ceph/buffer.h new file mode 100644 index 000000000000..58d19014068f --- /dev/null +++ b/include/linux/ceph/buffer.h | |||
| @@ -0,0 +1,39 @@ | |||
| 1 | #ifndef __FS_CEPH_BUFFER_H | ||
| 2 | #define __FS_CEPH_BUFFER_H | ||
| 3 | |||
| 4 | #include <linux/kref.h> | ||
| 5 | #include <linux/mm.h> | ||
| 6 | #include <linux/vmalloc.h> | ||
| 7 | #include <linux/types.h> | ||
| 8 | #include <linux/uio.h> | ||
| 9 | |||
| 10 | /* | ||
| 11 | * a simple reference counted buffer. | ||
| 12 | * | ||
| 13 | * use kmalloc for small sizes (<= one page), vmalloc for larger | ||
| 14 | * sizes. | ||
| 15 | */ | ||
| 16 | struct ceph_buffer { | ||
| 17 | struct kref kref; | ||
| 18 | struct kvec vec; | ||
| 19 | size_t alloc_len; | ||
| 20 | bool is_vmalloc; | ||
| 21 | }; | ||
| 22 | |||
| 23 | extern struct ceph_buffer *ceph_buffer_new(size_t len, gfp_t gfp); | ||
| 24 | extern void ceph_buffer_release(struct kref *kref); | ||
| 25 | |||
| 26 | static inline struct ceph_buffer *ceph_buffer_get(struct ceph_buffer *b) | ||
| 27 | { | ||
| 28 | kref_get(&b->kref); | ||
| 29 | return b; | ||
| 30 | } | ||
| 31 | |||
| 32 | static inline void ceph_buffer_put(struct ceph_buffer *b) | ||
| 33 | { | ||
| 34 | kref_put(&b->kref, ceph_buffer_release); | ||
| 35 | } | ||
| 36 | |||
| 37 | extern int ceph_decode_buffer(struct ceph_buffer **b, void **p, void *end); | ||
| 38 | |||
| 39 | #endif | ||
diff --git a/include/linux/ceph/ceph_debug.h b/include/linux/ceph/ceph_debug.h new file mode 100644 index 000000000000..aa2e19182d99 --- /dev/null +++ b/include/linux/ceph/ceph_debug.h | |||
| @@ -0,0 +1,38 @@ | |||
| 1 | #ifndef _FS_CEPH_DEBUG_H | ||
| 2 | #define _FS_CEPH_DEBUG_H | ||
| 3 | |||
| 4 | #define pr_fmt(fmt) KBUILD_MODNAME ": " fmt | ||
| 5 | |||
| 6 | #ifdef CONFIG_CEPH_LIB_PRETTYDEBUG | ||
| 7 | |||
| 8 | /* | ||
| 9 | * wrap pr_debug to include a filename:lineno prefix on each line. | ||
| 10 | * this incurs some overhead (kernel size and execution time) due to | ||
| 11 | * the extra function call at each call site. | ||
| 12 | */ | ||
| 13 | |||
| 14 | # if defined(DEBUG) || defined(CONFIG_DYNAMIC_DEBUG) | ||
| 15 | extern const char *ceph_file_part(const char *s, int len); | ||
| 16 | # define dout(fmt, ...) \ | ||
| 17 | pr_debug("%.*s %12.12s:%-4d : " fmt, \ | ||
| 18 | 8 - (int)sizeof(KBUILD_MODNAME), " ", \ | ||
| 19 | ceph_file_part(__FILE__, sizeof(__FILE__)), \ | ||
| 20 | __LINE__, ##__VA_ARGS__) | ||
| 21 | # else | ||
| 22 | <|||
