xen-blkfront: don't add indirect pages to list when !feature_persistent
[linux-2.6-block.git] / net / ceph / buffer.c
CommitLineData
c30dbb9c 1
3d14c5d2 2#include <linux/ceph/ceph_debug.h>
5a0e3ad6 3
3d14c5d2 4#include <linux/module.h>
5a0e3ad6
TH
5#include <linux/slab.h>
6
3d14c5d2
YS
7#include <linux/ceph/buffer.h>
8#include <linux/ceph/decode.h>
4965fc38 9#include <linux/ceph/libceph.h> /* for ceph_kvmalloc */
c30dbb9c 10
b6c1d5b8 11struct ceph_buffer *ceph_buffer_new(size_t len, gfp_t gfp)
c30dbb9c
SW
12{
13 struct ceph_buffer *b;
14
15 b = kmalloc(sizeof(*b), gfp);
16 if (!b)
17 return NULL;
b6c1d5b8 18
eeb0bed5
ID
19 b->vec.iov_base = ceph_kvmalloc(len, gfp);
20 if (!b->vec.iov_base) {
21 kfree(b);
22 return NULL;
b6c1d5b8
SW
23 }
24
dd26d857 25 kref_init(&b->kref);
b6c1d5b8
SW
26 b->alloc_len = len;
27 b->vec.iov_len = len;
28 dout("buffer_new %p\n", b);
c30dbb9c
SW
29 return b;
30}
3d14c5d2 31EXPORT_SYMBOL(ceph_buffer_new);
c30dbb9c 32
dd26d857
SW
33void ceph_buffer_release(struct kref *kref)
34{
35 struct ceph_buffer *b = container_of(kref, struct ceph_buffer, kref);
b6c1d5b8
SW
36
37 dout("buffer_release %p\n", b);
4965fc38 38 kvfree(b->vec.iov_base);
dd26d857
SW
39 kfree(b);
40}
3d14c5d2 41EXPORT_SYMBOL(ceph_buffer_release);
dd26d857 42
c7e337d6
SW
43int ceph_decode_buffer(struct ceph_buffer **b, void **p, void *end)
44{
45 size_t len;
46
47 ceph_decode_need(p, end, sizeof(u32), bad);
48 len = ceph_decode_32(p);
49 dout("decode_buffer len %d\n", (int)len);
50 ceph_decode_need(p, end, len, bad);
51 *b = ceph_buffer_new(len, GFP_NOFS);
52 if (!*b)
53 return -ENOMEM;
54 ceph_decode_copy(p, (*b)->vec.iov_base, len);
55 return 0;
56bad:
57 return -EINVAL;
58}