summaryrefslogtreecommitdiff
path: root/fs/ceph/decode.h
blob: fc2769df062d715c056a2da97f4421175ea40db7 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
#ifndef __CEPH_DECODE_H
#define __CEPH_DECODE_H

#include <asm/unaligned.h>

/*
 * in all cases,
 *   void **p     pointer to position pointer
 *   void *end    pointer to end of buffer (last byte + 1)
 */

/*
 * bounds check input.
 */
#define ceph_decode_need(p, end, n, bad)		\
	do {						\
		if (unlikely(*(p) + (n) > (end))) 	\
			goto bad;			\
	} while (0)

#define ceph_decode_64(p, v)					\
	do {							\
		v = get_unaligned_le64(*(p));			\
		*(p) += sizeof(u64);				\
	} while (0)
#define ceph_decode_32(p, v)					\
	do {							\
		v = get_unaligned_le32(*(p));			\
		*(p) += sizeof(u32);				\
	} while (0)
#define ceph_decode_16(p, v)					\
	do {							\
		v = get_unaligned_le16(*(p));			\
		*(p) += sizeof(u16);				\
	} while (0)
#define ceph_decode_8(p, v)				\
	do {						\
		v = *(u8 *)*(p);			\
		(*p)++;					\
	} while (0)

#define ceph_decode_copy(p, pv, n)			\
	do {						\
		memcpy(pv, *(p), n);			\
		*(p) += n;				\
	} while (0)

/* bounds check too */
#define ceph_decode_64_safe(p, end, v, bad)			\
	do {							\
		ceph_decode_need(p, end, sizeof(u64), bad);	\
		ceph_decode_64(p, v);				\
	} while (0)
#define ceph_decode_32_safe(p, end, v, bad)			\
	do {							\
		ceph_decode_need(p, end, sizeof(u32), bad);	\
		ceph_decode_32(p, v);				\
	} while (0)
#define ceph_decode_16_safe(p, end, v, bad)			\
	do {							\
		ceph_decode_need(p, end, sizeof(u16), bad);	\
		ceph_decode_16(p, v);				\
	} while (0)

#define ceph_decode_copy_safe(p, end, pv, n, bad)		\
	do {							\
		ceph_decode_need(p, end, n, bad);		\
		ceph_decode_copy(p, pv, n);			\
	} while (0)

/*
 * struct ceph_timespec <-> struct timespec
 */
#define ceph_decode_timespec(ts, tv)					\
	do {								\
		(ts)->tv_sec = le32_to_cpu((tv)->tv_sec);		\
		(ts)->tv_nsec = le32_to_cpu((tv)->tv_nsec);		\
	} while (0)
#define ceph_encode_timespec(tv, ts)				\
	do {							\
		(tv)->tv_sec = cpu_to_le32((ts)->tv_sec);	\
		(tv)->tv_nsec = cpu_to_le32((ts)->tv_nsec);	\
	} while (0)


/*
 * encoders
 */
#define ceph_encode_64(p, v)						\
	do {								\
		put_unaligned_le64(v, (__le64 *)*(p));			\
		*(p) += sizeof(u64);					\
	} while (0)
#define ceph_encode_32(p, v)					\
	do {							\
		put_unaligned_le32(v, (__le32 *)*(p));		\
		*(p) += sizeof(u32);				\
	} while (0)
#define ceph_encode_16(p, v)					\
	do {							\
		put_unaligned_le16(v), (__le16 *)*(p));		\
	*(p) += sizeof(u16);					\
	} while (0)
#define ceph_encode_8(p, v)			  \
	do {					  \
		*(u8 *)*(p) = v;		  \
		(*(p))++;			  \
	} while (0)

/*
 * filepath, string encoders
 */
static inline void ceph_encode_filepath(void **p, void *end,
					u64 ino, const char *path)
{
	u32 len = path ? strlen(path) : 0;
	BUG_ON(*p + sizeof(ino) + sizeof(len) + len > end);
	ceph_encode_64(p, ino);
	ceph_encode_32(p, len);
	if (len)
		memcpy(*p, path, len);
	*p += len;
}

static inline void ceph_encode_string(void **p, void *end,
				      const char *s, u32 len)
{
	BUG_ON(*p + sizeof(len) + len > end);
	ceph_encode_32(p, len);
	if (len)
		memcpy(*p, s, len);
	*p += len;
}


#endif