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
|
/* Research 046: what a store did to its files, as the shim (shim.c) saw it and the follower (follower.c) does it again.
* An op is a u8 kind, its path (u16le length, bytes; relative to the store's directory, "" the directory itself), then:
* OP_CREATE u32le the open's flags among O_CREAT, O_EXCL, O_TRUNC; u32le mode
* OP_WRITE u64le offset, u32le length, the bytes
* OP_TRUNCATE u64le length
* OP_ALLOCATE u64le offset, u64le length (posix_fallocate)
* OP_RENAME the second path (u16le length, bytes)
* OP_UNLINK u32le flags (AT_REMOVEDIR)
* OP_MKDIR u32le mode
* OP_SYNC (an fsync or fdatasync of that path: where a cut ends)
* A cut is the ops since the last, ending in one OP_SYNC. On the link a record is u8 1 when it ends its cut (else 0),
* u64le the cut's number, then whole ops. */
#ifndef OPS_H
#define OPS_H
#include <stdint.h>
#include <string.h>
enum { OP_CREATE = 1, OP_WRITE, OP_TRUNCATE, OP_ALLOCATE, OP_RENAME, OP_UNLINK, OP_MKDIR, OP_SYNC, OP_KINDS };
static const char *const op_names[OP_KINDS] = {"", "create", "write", "truncate", "allocate", "rename", "unlink", "mkdir", "sync"};
static inline void put16(unsigned char *p, uint16_t v) { p[0] = (unsigned char)v, p[1] = (unsigned char)(v >> 8); }
static inline void put32(unsigned char *p, uint32_t v) { for (int i = 0; i < 4; ++i) p[i] = (unsigned char)(v >> (8 * i)); }
static inline void put64(unsigned char *p, uint64_t v) { for (int i = 0; i < 8; ++i) p[i] = (unsigned char)(v >> (8 * i)); }
static inline uint16_t get16(const unsigned char *p) { return (uint16_t)(p[0] | p[1] << 8); }
static inline uint32_t get32(const unsigned char *p) { uint32_t v = 0; for (int i = 3; i >= 0; --i) v = v << 8 | p[i]; return v; }
static inline uint64_t get64(const unsigned char *p) { uint64_t v = 0; for (int i = 7; i >= 0; --i) v = v << 8 | p[i]; return v; }
/* An op's size from its start (at most size bytes there), or 0 when it is not whole. */
static inline size_t op_size(const unsigned char *p, size_t size) {
if (size < 3) return 0;
size_t at = 3 + get16(p + 1);
if (at > size) return 0;
switch (p[0]) {
case OP_CREATE: at += 8; break;
case OP_WRITE: if (at + 12 > size) return 0; at += 12 + get32(p + at + 8); break;
case OP_TRUNCATE: at += 8; break;
case OP_ALLOCATE: at += 16; break;
case OP_RENAME: if (at + 2 > size) return 0; at += 2 + get16(p + at); break;
case OP_UNLINK: case OP_MKDIR: at += 4; break;
case OP_SYNC: break;
default: return 0;
}
return at <= size ? at : 0;
}
#endif
|
