| .. | .. |
|---|
| 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 |
|---|