.. | .. |
---|
13 | 13 | mempool_t *pool; |
---|
14 | 14 | int type; /* preallocated message type */ |
---|
15 | 15 | int front_len; /* preallocated payload size */ |
---|
| 16 | + int max_data_items; |
---|
16 | 17 | }; |
---|
17 | 18 | |
---|
18 | | -extern int ceph_msgpool_init(struct ceph_msgpool *pool, int type, |
---|
19 | | - int front_len, int size, bool blocking, |
---|
20 | | - const char *name); |
---|
| 19 | +int ceph_msgpool_init(struct ceph_msgpool *pool, int type, |
---|
| 20 | + int front_len, int max_data_items, int size, |
---|
| 21 | + const char *name); |
---|
21 | 22 | extern void ceph_msgpool_destroy(struct ceph_msgpool *pool); |
---|
22 | | -extern struct ceph_msg *ceph_msgpool_get(struct ceph_msgpool *, |
---|
23 | | - int front_len); |
---|
| 23 | +struct ceph_msg *ceph_msgpool_get(struct ceph_msgpool *pool, int front_len, |
---|
| 24 | + int max_data_items); |
---|
24 | 25 | extern void ceph_msgpool_put(struct ceph_msgpool *, struct ceph_msg *); |
---|
25 | 26 | |
---|
26 | 27 | #endif |
---|