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
|
#include "store-port.h"
#include "store.h"
#include <stdlib.h>
#include <sys/mman.h>
static void free_memory(void *data, size_t size) { (void)size; free(data); }
static void unmap_memory(void *data, size_t size) { if (size) munmap(data, size); }
static bool allocate(void *context, size_t size, PureResource *out) {
(void)context;
void *data = malloc(size);
if (!data) return false;
*out = (PureResource){.body = {data, size}, .allocation = data,
.allocation_size = size, .release = free_memory};
return true;
}
static PureResult read_value(void *context, const void *definition, const char *key,
size_t available, PureResource *out, int64_t *revision) {
const PureProgram *program = definition;
if (!program) return PURE_INVALID;
PureStoredView view = {0};
PureRegion region = program->read;
PureResult result = pure_store_select(context, key, region.offset, region.length,
region.to_end, program->read_required, available, &view);
if (result == PURE_OK) {
*out = (PureResource){.body = view.body, .allocation = view.mapping,
.allocation_size = view.mapped_size, .release = view.mapped_size ? unmap_memory : NULL};
*revision = view.revision;
}
return result;
}
static PureResult write_value(void *context, const void *definition, const char *key,
int64_t expected, PureSpan input, PureSpan *reply,
int64_t *revision) {
const PureProgram *program = definition;
if (!program) return PURE_INVALID;
PureSpan value;
if (!pure_program_input(program, input, &value, reply)) return PURE_LIMIT;
if (!program->splice) return pure_store_put(context, key, expected, value, revision);
size_t offset, remove;
if (!pure_program_splice(program, input, &offset, &remove)) return PURE_LIMIT;
return pure_store_splice(context, key, expected, offset, remove, value,
program->splice_limit, revision);
}
PureHost pure_store_host(const char *path) {
return (PureHost){.context = (void *)path, .allocate = allocate,
.read = read_value, .write = write_value};
}
|
