diff options
Diffstat (limited to 'fs/ceph/msgpool.h')
| -rw-r--r-- | fs/ceph/msgpool.h | 12 |
1 files changed, 5 insertions, 7 deletions
diff --git a/fs/ceph/msgpool.h b/fs/ceph/msgpool.h index bc834bfcd720..a362605f9368 100644 --- a/fs/ceph/msgpool.h +++ b/fs/ceph/msgpool.h | |||
| @@ -1,6 +1,7 @@ | |||
| 1 | #ifndef _FS_CEPH_MSGPOOL | 1 | #ifndef _FS_CEPH_MSGPOOL |
| 2 | #define _FS_CEPH_MSGPOOL | 2 | #define _FS_CEPH_MSGPOOL |
| 3 | 3 | ||
| 4 | #include <linux/mempool.h> | ||
| 4 | #include "messenger.h" | 5 | #include "messenger.h" |
| 5 | 6 | ||
| 6 | /* | 7 | /* |
| @@ -8,18 +9,15 @@ | |||
| 8 | * avoid unexpected OOM conditions. | 9 | * avoid unexpected OOM conditions. |
| 9 | */ | 10 | */ |
| 10 | struct ceph_msgpool { | 11 | struct ceph_msgpool { |
| 11 | spinlock_t lock; | 12 | const char *name; |
| 13 | mempool_t *pool; | ||
| 12 | int front_len; /* preallocated payload size */ | 14 | int front_len; /* preallocated payload size */ |
| 13 | struct list_head msgs; /* msgs in the pool; each has 1 ref */ | ||
| 14 | int num, min; /* cur, min # msgs in the pool */ | ||
| 15 | bool blocking; | ||
| 16 | wait_queue_head_t wait; | ||
| 17 | }; | 15 | }; |
| 18 | 16 | ||
| 19 | extern int ceph_msgpool_init(struct ceph_msgpool *pool, | 17 | extern int ceph_msgpool_init(struct ceph_msgpool *pool, |
| 20 | int front_len, int size, bool blocking); | 18 | int front_len, int size, bool blocking, |
| 19 | const char *name); | ||
| 21 | extern void ceph_msgpool_destroy(struct ceph_msgpool *pool); | 20 | extern void ceph_msgpool_destroy(struct ceph_msgpool *pool); |
| 22 | extern int ceph_msgpool_resv(struct ceph_msgpool *, int delta); | ||
| 23 | extern struct ceph_msg *ceph_msgpool_get(struct ceph_msgpool *, | 21 | extern struct ceph_msg *ceph_msgpool_get(struct ceph_msgpool *, |
| 24 | int front_len); | 22 | int front_len); |
| 25 | extern void ceph_msgpool_put(struct ceph_msgpool *, struct ceph_msg *); | 23 | extern void ceph_msgpool_put(struct ceph_msgpool *, struct ceph_msg *); |
