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
|
/* SPDX-License-Identifier: LGPL-2.1-only */
/* Copyright (C) 2020 Gediminas Jakutis */
#ifndef ALGOS_DEFS_H_INCLUDED
#define ALGOS_DEFS_H_INCLUDED
#include <stddef.h>
#include <stdint.h>
#include <sys/types.h>
#include <rin/diagnostic.h>
#define try_s(a,l) do {\
if(a) {\
goto l;\
}} while (0);
#define try(a,l,e,m,...) do {\
if(a) {\
ret = e;\
rin_err(m __VA_OPT__(,) __VA_ARGS__);\
goto l;\
}} while (0);
#if entry_field_size == 16
# ifdef entry_field_signed
typedef int16_t field;
# else
typedef uint16_t field;
# endif
#elif entry_field_size == 32
# ifdef entry_field_signed
typedef int32_t field;
# else
typedef uint32_t field;
# endif
#else
# ifdef entry_field_signed
typedef int64_t field;
# else
typedef uint64_t field;
# endif
#endif
#define get(in) (in->settings->access == cached ? in->get_next_element_cache(in) : in->get_next_element_direct(in))
#define put(in, data) (in->settings->access == cached ? in->place_next_element_cache(in, data) : in->place_next_element_direct(in, data))
#define stream_blank .fd = -1, .settings = &settings, .get_next_element_direct = stub_getnext, \
.get_next_element_cache = stub_getnext, .place_next_element_direct = stub_put, \
.place_next_element_cache = stub_put, .split = stub_split, .flush = stub_flush
union nextoff {
struct entry_l *next;
ptrdiff_t offset;
int64_t spacer; /* make sure it is 8-byte-alligned on 32 bit pointer systems */
};
union cachewrap {
char *cache;
struct entry *cache_a;
struct entry_l *cache_l;
};
/* for array implementation */
struct entry {
field val;
};
/* for linked list implementation */
struct entry_l {
struct entry;
union nextoff;
};
enum opmode {
mode_normal,
mode_fetch,
mode_generate
};
enum accessmode {
cached,
direct
};
enum dataformat {
array,
list
};
enum streamtype {
stream_invalid = -1,
stream_in,
stream_out,
stream_outlite,
stream_randread
};
struct stream {
struct stream *parent;
size_t n;
int fd;
enum streamtype type;
char *name;
size_t stride;
size_t index;
struct entry_l *pnode; /* "previous" node */
struct entry_l *cnode; /* "current" node */
union cachewrap;
struct settings *settings;
struct entry_l *(*get_next_element_direct)(struct stream * const);
struct entry_l *(*get_next_element_cache)(struct stream * const);
int (*place_next_element_direct)(struct stream * const, struct entry_l const * const);
int (*place_next_element_cache)(struct stream * const, struct entry_l const * const);
int (*split)(struct stream * const, struct stream * const, struct stream * const);
int (*flush)(struct stream * const);
};
struct settings {
size_t ss;
size_t to;
size_t stride;
char *filein;
char *fileout;
enum opmode opmode;
enum dataformat format;
enum accessmode access;
};
#endif /* ALGOS_DEFS_H_INCLUDED */
|
