Sage Weil | 5cd068c | 2010-07-07 08:38:17 -0700 | [diff] [blame] | 1 | #ifndef CEPH_RADOS_H |
| 2 | #define CEPH_RADOS_H |
Sage Weil | 0dee3c2 | 2009-10-06 11:31:06 -0700 | [diff] [blame] | 3 | |
| 4 | /* |
| 5 | * Data types for the Ceph distributed object storage layer RADOS |
| 6 | * (Reliable Autonomic Distributed Object Store). |
| 7 | */ |
| 8 | |
David Howells | a1ce392 | 2012-10-02 18:01:25 +0100 | [diff] [blame] | 9 | #include <linux/ceph/msgr.h> |
Sage Weil | 0dee3c2 | 2009-10-06 11:31:06 -0700 | [diff] [blame] | 10 | |
| 11 | /* |
Sage Weil | 02f90c6 | 2010-02-04 16:18:10 -0800 | [diff] [blame] | 12 | * osdmap encoding versions |
| 13 | */ |
Sage Weil | 2844a76 | 2010-04-09 15:46:42 -0700 | [diff] [blame] | 14 | #define CEPH_OSDMAP_INC_VERSION 5 |
Yehuda Sadeh | 483fac7 | 2011-01-20 16:36:06 -0800 | [diff] [blame] | 15 | #define CEPH_OSDMAP_INC_VERSION_EXT 6 |
Sage Weil | 2844a76 | 2010-04-09 15:46:42 -0700 | [diff] [blame] | 16 | #define CEPH_OSDMAP_VERSION 5 |
Yehuda Sadeh | 483fac7 | 2011-01-20 16:36:06 -0800 | [diff] [blame] | 17 | #define CEPH_OSDMAP_VERSION_EXT 6 |
Sage Weil | 02f90c6 | 2010-02-04 16:18:10 -0800 | [diff] [blame] | 18 | |
| 19 | /* |
Sage Weil | 0dee3c2 | 2009-10-06 11:31:06 -0700 | [diff] [blame] | 20 | * fs id |
| 21 | */ |
| 22 | struct ceph_fsid { |
| 23 | unsigned char fsid[16]; |
| 24 | }; |
| 25 | |
| 26 | static inline int ceph_fsid_compare(const struct ceph_fsid *a, |
| 27 | const struct ceph_fsid *b) |
| 28 | { |
| 29 | return memcmp(a, b, sizeof(*a)); |
| 30 | } |
| 31 | |
| 32 | /* |
| 33 | * ino, object, etc. |
| 34 | */ |
| 35 | typedef __le64 ceph_snapid_t; |
| 36 | #define CEPH_SNAPDIR ((__u64)(-1)) /* reserved for hidden .snap dir */ |
| 37 | #define CEPH_NOSNAP ((__u64)(-2)) /* "head", "live" revision */ |
| 38 | #define CEPH_MAXSNAP ((__u64)(-3)) /* largest valid snapid */ |
| 39 | |
| 40 | struct ceph_timespec { |
| 41 | __le32 tv_sec; |
| 42 | __le32 tv_nsec; |
| 43 | } __attribute__ ((packed)); |
| 44 | |
| 45 | |
| 46 | /* |
| 47 | * object layout - how objects are mapped into PGs |
| 48 | */ |
| 49 | #define CEPH_OBJECT_LAYOUT_HASH 1 |
| 50 | #define CEPH_OBJECT_LAYOUT_LINEAR 2 |
| 51 | #define CEPH_OBJECT_LAYOUT_HASHINO 3 |
| 52 | |
| 53 | /* |
| 54 | * pg layout -- how PGs are mapped onto (sets of) OSDs |
| 55 | */ |
| 56 | #define CEPH_PG_LAYOUT_CRUSH 0 |
| 57 | #define CEPH_PG_LAYOUT_HASH 1 |
| 58 | #define CEPH_PG_LAYOUT_LINEAR 2 |
| 59 | #define CEPH_PG_LAYOUT_HYBRID 3 |
| 60 | |
Sage Weil | d85b705 | 2010-05-10 10:24:48 -0700 | [diff] [blame] | 61 | #define CEPH_PG_MAX_SIZE 16 /* max # osds in a single pg */ |
Sage Weil | 0dee3c2 | 2009-10-06 11:31:06 -0700 | [diff] [blame] | 62 | |
| 63 | /* |
| 64 | * placement group. |
| 65 | * we encode this into one __le64. |
| 66 | */ |
Sage Weil | 5104212 | 2009-11-04 11:39:12 -0800 | [diff] [blame] | 67 | struct ceph_pg { |
| 68 | __le16 preferred; /* preferred primary osd */ |
| 69 | __le16 ps; /* placement seed */ |
| 70 | __le32 pool; /* object pool */ |
Sage Weil | 0dee3c2 | 2009-10-06 11:31:06 -0700 | [diff] [blame] | 71 | } __attribute__ ((packed)); |
| 72 | |
| 73 | /* |
| 74 | * pg_pool is a set of pgs storing a pool of objects |
| 75 | * |
| 76 | * pg_num -- base number of pseudorandomly placed pgs |
| 77 | * |
| 78 | * pgp_num -- effective number when calculating pg placement. this |
| 79 | * is used for pg_num increases. new pgs result in data being "split" |
| 80 | * into new pgs. for this to proceed smoothly, new pgs are intiially |
| 81 | * colocated with their parents; that is, pgp_num doesn't increase |
| 82 | * until the new pgs have successfully split. only _then_ are the new |
| 83 | * pgs placed independently. |
| 84 | * |
| 85 | * lpg_num -- localized pg count (per device). replicas are randomly |
| 86 | * selected. |
| 87 | * |
| 88 | * lpgp_num -- as above. |
| 89 | */ |
Alex Elder | 86b00e0 | 2012-10-25 23:34:42 -0500 | [diff] [blame] | 90 | #define CEPH_NOPOOL ((__u64) (-1)) /* pool id not defined */ |
| 91 | |
Sage Weil | 0dee3c2 | 2009-10-06 11:31:06 -0700 | [diff] [blame] | 92 | #define CEPH_PG_TYPE_REP 1 |
| 93 | #define CEPH_PG_TYPE_RAID4 2 |
Sage Weil | 02f90c6 | 2010-02-04 16:18:10 -0800 | [diff] [blame] | 94 | #define CEPH_PG_POOL_VERSION 2 |
Sage Weil | 0dee3c2 | 2009-10-06 11:31:06 -0700 | [diff] [blame] | 95 | struct ceph_pg_pool { |
| 96 | __u8 type; /* CEPH_PG_TYPE_* */ |
| 97 | __u8 size; /* number of osds in each pg */ |
| 98 | __u8 crush_ruleset; /* crush placement rule */ |
Sage Weil | 1654dd0 | 2009-11-06 21:55:25 -0800 | [diff] [blame] | 99 | __u8 object_hash; /* hash mapping object name to ps */ |
Sage Weil | 0dee3c2 | 2009-10-06 11:31:06 -0700 | [diff] [blame] | 100 | __le32 pg_num, pgp_num; /* number of pg's */ |
| 101 | __le32 lpg_num, lpgp_num; /* number of localized pg's */ |
| 102 | __le32 last_change; /* most recent epoch changed */ |
| 103 | __le64 snap_seq; /* seq for per-pool snapshot */ |
| 104 | __le32 snap_epoch; /* epoch of last snap */ |
| 105 | __le32 num_snaps; |
Sage Weil | ca9d93a | 2010-05-12 14:48:20 -0700 | [diff] [blame] | 106 | __le32 num_removed_snap_intervals; /* if non-empty, NO per-pool snaps */ |
| 107 | __le64 auid; /* who owns the pg */ |
Sage Weil | 0dee3c2 | 2009-10-06 11:31:06 -0700 | [diff] [blame] | 108 | } __attribute__ ((packed)); |
| 109 | |
| 110 | /* |
| 111 | * stable_mod func is used to control number of placement groups. |
| 112 | * similar to straight-up modulo, but produces a stable mapping as b |
| 113 | * increases over time. b is the number of bins, and bmask is the |
| 114 | * containing power of 2 minus 1. |
| 115 | * |
| 116 | * b <= bmask and bmask=(2**n)-1 |
| 117 | * e.g., b=12 -> bmask=15, b=123 -> bmask=127 |
| 118 | */ |
| 119 | static inline int ceph_stable_mod(int x, int b, int bmask) |
| 120 | { |
| 121 | if ((x & bmask) < b) |
| 122 | return x & bmask; |
| 123 | else |
| 124 | return x & (bmask >> 1); |
| 125 | } |
| 126 | |
| 127 | /* |
| 128 | * object layout - how a given object should be stored. |
| 129 | */ |
| 130 | struct ceph_object_layout { |
Sage Weil | 5104212 | 2009-11-04 11:39:12 -0800 | [diff] [blame] | 131 | struct ceph_pg ol_pgid; /* raw pg, with _full_ ps precision. */ |
Sage Weil | 0dee3c2 | 2009-10-06 11:31:06 -0700 | [diff] [blame] | 132 | __le32 ol_stripe_unit; /* for per-object parity, if any */ |
| 133 | } __attribute__ ((packed)); |
| 134 | |
| 135 | /* |
| 136 | * compound epoch+version, used by storage layer to serialize mutations |
| 137 | */ |
| 138 | struct ceph_eversion { |
| 139 | __le32 epoch; |
| 140 | __le64 version; |
| 141 | } __attribute__ ((packed)); |
| 142 | |
| 143 | /* |
| 144 | * osd map bits |
| 145 | */ |
| 146 | |
| 147 | /* status bits */ |
Alex Elder | 0315a77 | 2013-02-15 11:42:30 -0600 | [diff] [blame^] | 148 | #define CEPH_OSD_EXISTS (1<<0) |
| 149 | #define CEPH_OSD_UP (1<<1) |
| 150 | #define CEPH_OSD_AUTOOUT (1<<2) /* osd was automatically marked out */ |
| 151 | #define CEPH_OSD_NEW (1<<3) /* osd is new, never marked in */ |
Sage Weil | 0dee3c2 | 2009-10-06 11:31:06 -0700 | [diff] [blame] | 152 | |
| 153 | /* osd weights. fixed point value: 0x10000 == 1.0 ("in"), 0 == "out" */ |
| 154 | #define CEPH_OSD_IN 0x10000 |
| 155 | #define CEPH_OSD_OUT 0 |
| 156 | |
| 157 | |
| 158 | /* |
| 159 | * osd map flag bits |
| 160 | */ |
| 161 | #define CEPH_OSDMAP_NEARFULL (1<<0) /* sync writes (near ENOSPC) */ |
| 162 | #define CEPH_OSDMAP_FULL (1<<1) /* no data writes (ENOSPC) */ |
| 163 | #define CEPH_OSDMAP_PAUSERD (1<<2) /* pause all reads */ |
| 164 | #define CEPH_OSDMAP_PAUSEWR (1<<3) /* pause all writes */ |
| 165 | #define CEPH_OSDMAP_PAUSEREC (1<<4) /* pause recovery */ |
Alex Elder | 0315a77 | 2013-02-15 11:42:30 -0600 | [diff] [blame^] | 166 | #define CEPH_OSDMAP_NOUP (1<<5) /* block osd boot */ |
| 167 | #define CEPH_OSDMAP_NODOWN (1<<6) /* block osd mark-down/failure */ |
| 168 | #define CEPH_OSDMAP_NOOUT (1<<7) /* block osd auto mark-out */ |
| 169 | #define CEPH_OSDMAP_NOIN (1<<8) /* block osd auto mark-in */ |
| 170 | #define CEPH_OSDMAP_NOBACKFILL (1<<9) /* block osd backfill */ |
| 171 | #define CEPH_OSDMAP_NORECOVER (1<<10) /* block osd recovery and backfill */ |
| 172 | |
| 173 | /* |
| 174 | * The error code to return when an OSD can't handle a write |
| 175 | * because it is too large. |
| 176 | */ |
| 177 | #define OSD_WRITETOOBIG EMSGSIZE |
Sage Weil | 0dee3c2 | 2009-10-06 11:31:06 -0700 | [diff] [blame] | 178 | |
| 179 | /* |
| 180 | * osd ops |
Alex Elder | 0315a77 | 2013-02-15 11:42:30 -0600 | [diff] [blame^] | 181 | * |
| 182 | * WARNING: do not use these op codes directly. Use the helpers |
| 183 | * defined below instead. In certain cases, op code behavior was |
| 184 | * redefined, resulting in special-cases in the helpers. |
Sage Weil | 0dee3c2 | 2009-10-06 11:31:06 -0700 | [diff] [blame] | 185 | */ |
| 186 | #define CEPH_OSD_OP_MODE 0xf000 |
| 187 | #define CEPH_OSD_OP_MODE_RD 0x1000 |
| 188 | #define CEPH_OSD_OP_MODE_WR 0x2000 |
| 189 | #define CEPH_OSD_OP_MODE_RMW 0x3000 |
| 190 | #define CEPH_OSD_OP_MODE_SUB 0x4000 |
Sage Weil | 0dee3c2 | 2009-10-06 11:31:06 -0700 | [diff] [blame] | 191 | |
| 192 | #define CEPH_OSD_OP_TYPE 0x0f00 |
| 193 | #define CEPH_OSD_OP_TYPE_LOCK 0x0100 |
| 194 | #define CEPH_OSD_OP_TYPE_DATA 0x0200 |
| 195 | #define CEPH_OSD_OP_TYPE_ATTR 0x0300 |
| 196 | #define CEPH_OSD_OP_TYPE_EXEC 0x0400 |
| 197 | #define CEPH_OSD_OP_TYPE_PG 0x0500 |
Alex Elder | 0315a77 | 2013-02-15 11:42:30 -0600 | [diff] [blame^] | 198 | #define CEPH_OSD_OP_TYPE_MULTI 0x0600 /* multiobject */ |
Sage Weil | 0dee3c2 | 2009-10-06 11:31:06 -0700 | [diff] [blame] | 199 | |
| 200 | enum { |
| 201 | /** data **/ |
| 202 | /* read */ |
| 203 | CEPH_OSD_OP_READ = CEPH_OSD_OP_MODE_RD | CEPH_OSD_OP_TYPE_DATA | 1, |
| 204 | CEPH_OSD_OP_STAT = CEPH_OSD_OP_MODE_RD | CEPH_OSD_OP_TYPE_DATA | 2, |
Yehuda Sadeh | 483fac7 | 2011-01-20 16:36:06 -0800 | [diff] [blame] | 205 | CEPH_OSD_OP_MAPEXT = CEPH_OSD_OP_MODE_RD | CEPH_OSD_OP_TYPE_DATA | 3, |
Sage Weil | 0dee3c2 | 2009-10-06 11:31:06 -0700 | [diff] [blame] | 206 | |
| 207 | /* fancy read */ |
Yehuda Sadeh | 483fac7 | 2011-01-20 16:36:06 -0800 | [diff] [blame] | 208 | CEPH_OSD_OP_MASKTRUNC = CEPH_OSD_OP_MODE_RD | CEPH_OSD_OP_TYPE_DATA | 4, |
| 209 | CEPH_OSD_OP_SPARSE_READ = CEPH_OSD_OP_MODE_RD | CEPH_OSD_OP_TYPE_DATA | 5, |
| 210 | |
| 211 | CEPH_OSD_OP_NOTIFY = CEPH_OSD_OP_MODE_RD | CEPH_OSD_OP_TYPE_DATA | 6, |
| 212 | CEPH_OSD_OP_NOTIFY_ACK = CEPH_OSD_OP_MODE_RD | CEPH_OSD_OP_TYPE_DATA | 7, |
| 213 | |
| 214 | /* versioning */ |
| 215 | CEPH_OSD_OP_ASSERT_VER = CEPH_OSD_OP_MODE_RD | CEPH_OSD_OP_TYPE_DATA | 8, |
Sage Weil | 0dee3c2 | 2009-10-06 11:31:06 -0700 | [diff] [blame] | 216 | |
| 217 | /* write */ |
| 218 | CEPH_OSD_OP_WRITE = CEPH_OSD_OP_MODE_WR | CEPH_OSD_OP_TYPE_DATA | 1, |
| 219 | CEPH_OSD_OP_WRITEFULL = CEPH_OSD_OP_MODE_WR | CEPH_OSD_OP_TYPE_DATA | 2, |
| 220 | CEPH_OSD_OP_TRUNCATE = CEPH_OSD_OP_MODE_WR | CEPH_OSD_OP_TYPE_DATA | 3, |
| 221 | CEPH_OSD_OP_ZERO = CEPH_OSD_OP_MODE_WR | CEPH_OSD_OP_TYPE_DATA | 4, |
| 222 | CEPH_OSD_OP_DELETE = CEPH_OSD_OP_MODE_WR | CEPH_OSD_OP_TYPE_DATA | 5, |
| 223 | |
| 224 | /* fancy write */ |
| 225 | CEPH_OSD_OP_APPEND = CEPH_OSD_OP_MODE_WR | CEPH_OSD_OP_TYPE_DATA | 6, |
| 226 | CEPH_OSD_OP_STARTSYNC = CEPH_OSD_OP_MODE_WR | CEPH_OSD_OP_TYPE_DATA | 7, |
| 227 | CEPH_OSD_OP_SETTRUNC = CEPH_OSD_OP_MODE_WR | CEPH_OSD_OP_TYPE_DATA | 8, |
| 228 | CEPH_OSD_OP_TRIMTRUNC = CEPH_OSD_OP_MODE_WR | CEPH_OSD_OP_TYPE_DATA | 9, |
| 229 | |
| 230 | CEPH_OSD_OP_TMAPUP = CEPH_OSD_OP_MODE_RMW | CEPH_OSD_OP_TYPE_DATA | 10, |
| 231 | CEPH_OSD_OP_TMAPPUT = CEPH_OSD_OP_MODE_WR | CEPH_OSD_OP_TYPE_DATA | 11, |
| 232 | CEPH_OSD_OP_TMAPGET = CEPH_OSD_OP_MODE_RD | CEPH_OSD_OP_TYPE_DATA | 12, |
| 233 | |
| 234 | CEPH_OSD_OP_CREATE = CEPH_OSD_OP_MODE_WR | CEPH_OSD_OP_TYPE_DATA | 13, |
Sage Weil | f0b18d9 | 2010-07-07 08:39:03 -0700 | [diff] [blame] | 235 | CEPH_OSD_OP_ROLLBACK= CEPH_OSD_OP_MODE_WR | CEPH_OSD_OP_TYPE_DATA | 14, |
Sage Weil | 0dee3c2 | 2009-10-06 11:31:06 -0700 | [diff] [blame] | 236 | |
Yehuda Sadeh | 483fac7 | 2011-01-20 16:36:06 -0800 | [diff] [blame] | 237 | CEPH_OSD_OP_WATCH = CEPH_OSD_OP_MODE_WR | CEPH_OSD_OP_TYPE_DATA | 15, |
| 238 | |
Alex Elder | 0315a77 | 2013-02-15 11:42:30 -0600 | [diff] [blame^] | 239 | /* omap */ |
| 240 | CEPH_OSD_OP_OMAPGETKEYS = CEPH_OSD_OP_MODE_RD | CEPH_OSD_OP_TYPE_DATA | 17, |
| 241 | CEPH_OSD_OP_OMAPGETVALS = CEPH_OSD_OP_MODE_RD | CEPH_OSD_OP_TYPE_DATA | 18, |
| 242 | CEPH_OSD_OP_OMAPGETHEADER = CEPH_OSD_OP_MODE_RD | CEPH_OSD_OP_TYPE_DATA | 19, |
| 243 | CEPH_OSD_OP_OMAPGETVALSBYKEYS = |
| 244 | CEPH_OSD_OP_MODE_RD | CEPH_OSD_OP_TYPE_DATA | 20, |
| 245 | CEPH_OSD_OP_OMAPSETVALS = CEPH_OSD_OP_MODE_WR | CEPH_OSD_OP_TYPE_DATA | 21, |
| 246 | CEPH_OSD_OP_OMAPSETHEADER = CEPH_OSD_OP_MODE_WR | CEPH_OSD_OP_TYPE_DATA | 22, |
| 247 | CEPH_OSD_OP_OMAPCLEAR = CEPH_OSD_OP_MODE_WR | CEPH_OSD_OP_TYPE_DATA | 23, |
| 248 | CEPH_OSD_OP_OMAPRMKEYS = CEPH_OSD_OP_MODE_WR | CEPH_OSD_OP_TYPE_DATA | 24, |
| 249 | CEPH_OSD_OP_OMAP_CMP = CEPH_OSD_OP_MODE_RD | CEPH_OSD_OP_TYPE_DATA | 25, |
| 250 | |
| 251 | /** multi **/ |
| 252 | CEPH_OSD_OP_CLONERANGE = CEPH_OSD_OP_MODE_WR | CEPH_OSD_OP_TYPE_MULTI | 1, |
| 253 | CEPH_OSD_OP_ASSERT_SRC_VERSION = CEPH_OSD_OP_MODE_RD | CEPH_OSD_OP_TYPE_MULTI | 2, |
| 254 | CEPH_OSD_OP_SRC_CMPXATTR = CEPH_OSD_OP_MODE_RD | CEPH_OSD_OP_TYPE_MULTI | 3, |
| 255 | |
Sage Weil | 0dee3c2 | 2009-10-06 11:31:06 -0700 | [diff] [blame] | 256 | /** attrs **/ |
| 257 | /* read */ |
| 258 | CEPH_OSD_OP_GETXATTR = CEPH_OSD_OP_MODE_RD | CEPH_OSD_OP_TYPE_ATTR | 1, |
| 259 | CEPH_OSD_OP_GETXATTRS = CEPH_OSD_OP_MODE_RD | CEPH_OSD_OP_TYPE_ATTR | 2, |
Sage Weil | ca9d93a | 2010-05-12 14:48:20 -0700 | [diff] [blame] | 260 | CEPH_OSD_OP_CMPXATTR = CEPH_OSD_OP_MODE_RD | CEPH_OSD_OP_TYPE_ATTR | 3, |
Sage Weil | 0dee3c2 | 2009-10-06 11:31:06 -0700 | [diff] [blame] | 261 | |
| 262 | /* write */ |
| 263 | CEPH_OSD_OP_SETXATTR = CEPH_OSD_OP_MODE_WR | CEPH_OSD_OP_TYPE_ATTR | 1, |
| 264 | CEPH_OSD_OP_SETXATTRS = CEPH_OSD_OP_MODE_WR | CEPH_OSD_OP_TYPE_ATTR | 2, |
| 265 | CEPH_OSD_OP_RESETXATTRS = CEPH_OSD_OP_MODE_WR|CEPH_OSD_OP_TYPE_ATTR | 3, |
| 266 | CEPH_OSD_OP_RMXATTR = CEPH_OSD_OP_MODE_WR | CEPH_OSD_OP_TYPE_ATTR | 4, |
| 267 | |
| 268 | /** subop **/ |
Yehuda Sadeh | 483fac7 | 2011-01-20 16:36:06 -0800 | [diff] [blame] | 269 | CEPH_OSD_OP_PULL = CEPH_OSD_OP_MODE_SUB | 1, |
| 270 | CEPH_OSD_OP_PUSH = CEPH_OSD_OP_MODE_SUB | 2, |
| 271 | CEPH_OSD_OP_BALANCEREADS = CEPH_OSD_OP_MODE_SUB | 3, |
| 272 | CEPH_OSD_OP_UNBALANCEREADS = CEPH_OSD_OP_MODE_SUB | 4, |
| 273 | CEPH_OSD_OP_SCRUB = CEPH_OSD_OP_MODE_SUB | 5, |
| 274 | CEPH_OSD_OP_SCRUB_RESERVE = CEPH_OSD_OP_MODE_SUB | 6, |
| 275 | CEPH_OSD_OP_SCRUB_UNRESERVE = CEPH_OSD_OP_MODE_SUB | 7, |
| 276 | CEPH_OSD_OP_SCRUB_STOP = CEPH_OSD_OP_MODE_SUB | 8, |
Alex Elder | 0315a77 | 2013-02-15 11:42:30 -0600 | [diff] [blame^] | 277 | CEPH_OSD_OP_SCRUB_MAP = CEPH_OSD_OP_MODE_SUB | 9, |
Sage Weil | 0dee3c2 | 2009-10-06 11:31:06 -0700 | [diff] [blame] | 278 | |
| 279 | /** lock **/ |
| 280 | CEPH_OSD_OP_WRLOCK = CEPH_OSD_OP_MODE_WR | CEPH_OSD_OP_TYPE_LOCK | 1, |
| 281 | CEPH_OSD_OP_WRUNLOCK = CEPH_OSD_OP_MODE_WR | CEPH_OSD_OP_TYPE_LOCK | 2, |
| 282 | CEPH_OSD_OP_RDLOCK = CEPH_OSD_OP_MODE_WR | CEPH_OSD_OP_TYPE_LOCK | 3, |
| 283 | CEPH_OSD_OP_RDUNLOCK = CEPH_OSD_OP_MODE_WR | CEPH_OSD_OP_TYPE_LOCK | 4, |
| 284 | CEPH_OSD_OP_UPLOCK = CEPH_OSD_OP_MODE_WR | CEPH_OSD_OP_TYPE_LOCK | 5, |
| 285 | CEPH_OSD_OP_DNLOCK = CEPH_OSD_OP_MODE_WR | CEPH_OSD_OP_TYPE_LOCK | 6, |
| 286 | |
| 287 | /** exec **/ |
Alex Elder | 0315a77 | 2013-02-15 11:42:30 -0600 | [diff] [blame^] | 288 | /* note: the RD bit here is wrong; see special-case below in helper */ |
Sage Weil | 0dee3c2 | 2009-10-06 11:31:06 -0700 | [diff] [blame] | 289 | CEPH_OSD_OP_CALL = CEPH_OSD_OP_MODE_RD | CEPH_OSD_OP_TYPE_EXEC | 1, |
| 290 | |
| 291 | /** pg **/ |
| 292 | CEPH_OSD_OP_PGLS = CEPH_OSD_OP_MODE_RD | CEPH_OSD_OP_TYPE_PG | 1, |
Alex Elder | 0315a77 | 2013-02-15 11:42:30 -0600 | [diff] [blame^] | 293 | CEPH_OSD_OP_PGLS_FILTER = CEPH_OSD_OP_MODE_RD | CEPH_OSD_OP_TYPE_PG | 2, |
Sage Weil | 0dee3c2 | 2009-10-06 11:31:06 -0700 | [diff] [blame] | 294 | }; |
| 295 | |
| 296 | static inline int ceph_osd_op_type_lock(int op) |
| 297 | { |
| 298 | return (op & CEPH_OSD_OP_TYPE) == CEPH_OSD_OP_TYPE_LOCK; |
| 299 | } |
| 300 | static inline int ceph_osd_op_type_data(int op) |
| 301 | { |
| 302 | return (op & CEPH_OSD_OP_TYPE) == CEPH_OSD_OP_TYPE_DATA; |
| 303 | } |
| 304 | static inline int ceph_osd_op_type_attr(int op) |
| 305 | { |
| 306 | return (op & CEPH_OSD_OP_TYPE) == CEPH_OSD_OP_TYPE_ATTR; |
| 307 | } |
| 308 | static inline int ceph_osd_op_type_exec(int op) |
| 309 | { |
| 310 | return (op & CEPH_OSD_OP_TYPE) == CEPH_OSD_OP_TYPE_EXEC; |
| 311 | } |
| 312 | static inline int ceph_osd_op_type_pg(int op) |
| 313 | { |
| 314 | return (op & CEPH_OSD_OP_TYPE) == CEPH_OSD_OP_TYPE_PG; |
| 315 | } |
Alex Elder | 0315a77 | 2013-02-15 11:42:30 -0600 | [diff] [blame^] | 316 | static inline int ceph_osd_op_type_multi(int op) |
| 317 | { |
| 318 | return (op & CEPH_OSD_OP_TYPE) == CEPH_OSD_OP_TYPE_MULTI; |
| 319 | } |
Sage Weil | 0dee3c2 | 2009-10-06 11:31:06 -0700 | [diff] [blame] | 320 | |
| 321 | static inline int ceph_osd_op_mode_subop(int op) |
| 322 | { |
| 323 | return (op & CEPH_OSD_OP_MODE) == CEPH_OSD_OP_MODE_SUB; |
| 324 | } |
| 325 | static inline int ceph_osd_op_mode_read(int op) |
| 326 | { |
Alex Elder | 0315a77 | 2013-02-15 11:42:30 -0600 | [diff] [blame^] | 327 | return (op & CEPH_OSD_OP_MODE_RD) && |
| 328 | op != CEPH_OSD_OP_CALL; |
Sage Weil | 0dee3c2 | 2009-10-06 11:31:06 -0700 | [diff] [blame] | 329 | } |
| 330 | static inline int ceph_osd_op_mode_modify(int op) |
| 331 | { |
Alex Elder | 0315a77 | 2013-02-15 11:42:30 -0600 | [diff] [blame^] | 332 | return op & CEPH_OSD_OP_MODE_WR; |
Sage Weil | 0dee3c2 | 2009-10-06 11:31:06 -0700 | [diff] [blame] | 333 | } |
| 334 | |
Sage Weil | f0b18d9 | 2010-07-07 08:39:03 -0700 | [diff] [blame] | 335 | /* |
| 336 | * note that the following tmap stuff is also defined in the ceph librados.h |
| 337 | * any modification here needs to be updated there |
| 338 | */ |
Sage Weil | 0dee3c2 | 2009-10-06 11:31:06 -0700 | [diff] [blame] | 339 | #define CEPH_OSD_TMAP_HDR 'h' |
| 340 | #define CEPH_OSD_TMAP_SET 's' |
Alex Elder | 0315a77 | 2013-02-15 11:42:30 -0600 | [diff] [blame^] | 341 | #define CEPH_OSD_TMAP_CREATE 'c' /* create key */ |
Sage Weil | 0dee3c2 | 2009-10-06 11:31:06 -0700 | [diff] [blame] | 342 | #define CEPH_OSD_TMAP_RM 'r' |
Alex Elder | 0315a77 | 2013-02-15 11:42:30 -0600 | [diff] [blame^] | 343 | #define CEPH_OSD_TMAP_RMSLOPPY 'R' |
Sage Weil | 0dee3c2 | 2009-10-06 11:31:06 -0700 | [diff] [blame] | 344 | |
| 345 | extern const char *ceph_osd_op_name(int op); |
| 346 | |
Sage Weil | 0dee3c2 | 2009-10-06 11:31:06 -0700 | [diff] [blame] | 347 | /* |
| 348 | * osd op flags |
| 349 | * |
| 350 | * An op may be READ, WRITE, or READ|WRITE. |
| 351 | */ |
| 352 | enum { |
Alex Elder | 0315a77 | 2013-02-15 11:42:30 -0600 | [diff] [blame^] | 353 | CEPH_OSD_FLAG_ACK = 0x0001, /* want (or is) "ack" ack */ |
| 354 | CEPH_OSD_FLAG_ONNVRAM = 0x0002, /* want (or is) "onnvram" ack */ |
| 355 | CEPH_OSD_FLAG_ONDISK = 0x0004, /* want (or is) "ondisk" ack */ |
| 356 | CEPH_OSD_FLAG_RETRY = 0x0008, /* resend attempt */ |
| 357 | CEPH_OSD_FLAG_READ = 0x0010, /* op may read */ |
| 358 | CEPH_OSD_FLAG_WRITE = 0x0020, /* op may write */ |
| 359 | CEPH_OSD_FLAG_ORDERSNAP = 0x0040, /* EOLDSNAP if snapc is out of order */ |
| 360 | CEPH_OSD_FLAG_PEERSTAT_OLD = 0x0080, /* DEPRECATED msg includes osd_peer_stat */ |
| 361 | CEPH_OSD_FLAG_BALANCE_READS = 0x0100, |
| 362 | CEPH_OSD_FLAG_PARALLELEXEC = 0x0200, /* execute op in parallel */ |
| 363 | CEPH_OSD_FLAG_PGOP = 0x0400, /* pg op, no object */ |
| 364 | CEPH_OSD_FLAG_EXEC = 0x0800, /* op may exec */ |
| 365 | CEPH_OSD_FLAG_EXEC_PUBLIC = 0x1000, /* DEPRECATED op may exec (public) */ |
| 366 | CEPH_OSD_FLAG_LOCALIZE_READS = 0x2000, /* read from nearby replica, if any */ |
| 367 | CEPH_OSD_FLAG_RWORDERED = 0x4000, /* order wrt concurrent reads */ |
Sage Weil | 0dee3c2 | 2009-10-06 11:31:06 -0700 | [diff] [blame] | 368 | }; |
| 369 | |
| 370 | enum { |
| 371 | CEPH_OSD_OP_FLAG_EXCL = 1, /* EXCL object create */ |
Alex Elder | 0315a77 | 2013-02-15 11:42:30 -0600 | [diff] [blame^] | 372 | CEPH_OSD_OP_FLAG_FAILOK = 2, /* continue despite failure */ |
Sage Weil | 0dee3c2 | 2009-10-06 11:31:06 -0700 | [diff] [blame] | 373 | }; |
| 374 | |
| 375 | #define EOLDSNAPC ERESTART /* ORDERSNAP flag set; writer has old snapc*/ |
| 376 | #define EBLACKLISTED ESHUTDOWN /* blacklisted */ |
| 377 | |
Sage Weil | ca9d93a | 2010-05-12 14:48:20 -0700 | [diff] [blame] | 378 | /* xattr comparison */ |
| 379 | enum { |
| 380 | CEPH_OSD_CMPXATTR_OP_NOP = 0, |
| 381 | CEPH_OSD_CMPXATTR_OP_EQ = 1, |
| 382 | CEPH_OSD_CMPXATTR_OP_NE = 2, |
| 383 | CEPH_OSD_CMPXATTR_OP_GT = 3, |
| 384 | CEPH_OSD_CMPXATTR_OP_GTE = 4, |
| 385 | CEPH_OSD_CMPXATTR_OP_LT = 5, |
| 386 | CEPH_OSD_CMPXATTR_OP_LTE = 6 |
| 387 | }; |
| 388 | |
| 389 | enum { |
| 390 | CEPH_OSD_CMPXATTR_MODE_STRING = 1, |
| 391 | CEPH_OSD_CMPXATTR_MODE_U64 = 2 |
| 392 | }; |
| 393 | |
Yehuda Sadeh | 483fac7 | 2011-01-20 16:36:06 -0800 | [diff] [blame] | 394 | #define RADOS_NOTIFY_VER 1 |
| 395 | |
Sage Weil | 0dee3c2 | 2009-10-06 11:31:06 -0700 | [diff] [blame] | 396 | /* |
| 397 | * an individual object operation. each may be accompanied by some data |
| 398 | * payload |
| 399 | */ |
| 400 | struct ceph_osd_op { |
| 401 | __le16 op; /* CEPH_OSD_OP_* */ |
| 402 | __le32 flags; /* CEPH_OSD_FLAG_* */ |
| 403 | union { |
| 404 | struct { |
| 405 | __le64 offset, length; |
Yehuda Sadeh | 0c94899 | 2010-02-01 16:10:45 -0800 | [diff] [blame] | 406 | __le64 truncate_size; |
| 407 | __le32 truncate_seq; |
Sage Weil | 0dee3c2 | 2009-10-06 11:31:06 -0700 | [diff] [blame] | 408 | } __attribute__ ((packed)) extent; |
| 409 | struct { |
| 410 | __le32 name_len; |
| 411 | __le32 value_len; |
Sage Weil | ca9d93a | 2010-05-12 14:48:20 -0700 | [diff] [blame] | 412 | __u8 cmp_op; /* CEPH_OSD_CMPXATTR_OP_* */ |
| 413 | __u8 cmp_mode; /* CEPH_OSD_CMPXATTR_MODE_* */ |
Sage Weil | 0dee3c2 | 2009-10-06 11:31:06 -0700 | [diff] [blame] | 414 | } __attribute__ ((packed)) xattr; |
| 415 | struct { |
Sage Weil | 0dee3c2 | 2009-10-06 11:31:06 -0700 | [diff] [blame] | 416 | __u8 class_len; |
| 417 | __u8 method_len; |
| 418 | __u8 argc; |
| 419 | __le32 indata_len; |
| 420 | } __attribute__ ((packed)) cls; |
| 421 | struct { |
| 422 | __le64 cookie, count; |
| 423 | } __attribute__ ((packed)) pgls; |
Sage Weil | f0b18d9 | 2010-07-07 08:39:03 -0700 | [diff] [blame] | 424 | struct { |
| 425 | __le64 snapid; |
| 426 | } __attribute__ ((packed)) snap; |
Yehuda Sadeh | 483fac7 | 2011-01-20 16:36:06 -0800 | [diff] [blame] | 427 | struct { |
| 428 | __le64 cookie; |
| 429 | __le64 ver; |
| 430 | __u8 flag; /* 0 = unwatch, 1 = watch */ |
| 431 | } __attribute__ ((packed)) watch; |
Alex Elder | 0315a77 | 2013-02-15 11:42:30 -0600 | [diff] [blame^] | 432 | struct { |
| 433 | __le64 offset, length; |
| 434 | __le64 src_offset; |
| 435 | } __attribute__ ((packed)) clonerange; |
| 436 | }; |
Sage Weil | 0dee3c2 | 2009-10-06 11:31:06 -0700 | [diff] [blame] | 437 | __le32 payload_len; |
| 438 | } __attribute__ ((packed)); |
| 439 | |
| 440 | /* |
| 441 | * osd request message header. each request may include multiple |
| 442 | * ceph_osd_op object operations. |
| 443 | */ |
| 444 | struct ceph_osd_request_head { |
Sage Weil | 0dee3c2 | 2009-10-06 11:31:06 -0700 | [diff] [blame] | 445 | __le32 client_inc; /* client incarnation */ |
| 446 | struct ceph_object_layout layout; /* pgid */ |
| 447 | __le32 osdmap_epoch; /* client's osdmap epoch */ |
| 448 | |
| 449 | __le32 flags; |
| 450 | |
| 451 | struct ceph_timespec mtime; /* for mutations only */ |
| 452 | struct ceph_eversion reassert_version; /* if we are replaying op */ |
| 453 | |
| 454 | __le32 object_len; /* length of object name */ |
| 455 | |
| 456 | __le64 snapid; /* snapid to read */ |
| 457 | __le64 snap_seq; /* writer's snap context */ |
| 458 | __le32 num_snaps; |
| 459 | |
| 460 | __le16 num_ops; |
| 461 | struct ceph_osd_op ops[]; /* followed by ops[], obj, ticket, snaps */ |
| 462 | } __attribute__ ((packed)); |
| 463 | |
| 464 | struct ceph_osd_reply_head { |
Sage Weil | 0dee3c2 | 2009-10-06 11:31:06 -0700 | [diff] [blame] | 465 | __le32 client_inc; /* client incarnation */ |
| 466 | __le32 flags; |
| 467 | struct ceph_object_layout layout; |
| 468 | __le32 osdmap_epoch; |
| 469 | struct ceph_eversion reassert_version; /* for replaying uncommitted */ |
| 470 | |
| 471 | __le32 result; /* result code */ |
| 472 | |
| 473 | __le32 object_len; /* length of object name */ |
| 474 | __le32 num_ops; |
| 475 | struct ceph_osd_op ops[0]; /* ops[], object */ |
| 476 | } __attribute__ ((packed)); |
| 477 | |
| 478 | |
Sage Weil | 0dee3c2 | 2009-10-06 11:31:06 -0700 | [diff] [blame] | 479 | #endif |