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
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
|
/* Copyright (C) 2001-2005 by Hans Reiser, licensing governed by
reiser4progs/COPYING.
oid40_repair.c -- reiser4 oid allocator plugin. */
#ifndef ENABLE_MINIMAL
#include "oid40.h"
#include "oid40_repair.h"
static uint32_t oid40_get_state(reiser4_oid_ent_t *entity) {
aal_assert("umka-2088", entity != NULL);
return PLUG_ENT(entity)->state;
}
/* Returnes next oid to be used */
static uint64_t oid40_get_next_oid(reiser4_oid_ent_t *entity) {
aal_assert("umka-1109", entity != NULL);
return PLUG_ENT(entity)->next;
}
/* Returns number of used oids */
static uint64_t oid40_get_used_oid(reiser4_oid_ent_t *entity) {
aal_assert("umka-530", entity != NULL);
return PLUG_ENT(entity)->used;
}
static void oid40_set_state(reiser4_oid_ent_t *entity,
uint32_t state)
{
aal_assert("umka-2089", entity != NULL);
PLUG_ENT(entity)->state = state;
}
/* Updates next oid to be used */
static void oid40_set_next_oid(reiser4_oid_ent_t *entity, uint64_t next) {
aal_assert("vpf-1588", entity != NULL);
PLUG_ENT(entity)->next = next;
PLUG_ENT(entity)->state = (1 << ENTITY_DIRTY);
}
/* Updates number of used oids */
static void oid40_set_used_oid(reiser4_oid_ent_t *entity, uint64_t used) {
aal_assert("umka-530", entity != NULL);
PLUG_ENT(entity)->used = used;
PLUG_ENT(entity)->state = (1 << ENTITY_DIRTY);
}
/* Open oid allocator on passed format instance. */
static reiser4_oid_ent_t *oid40_open(reiser4_format_ent_t *format) {
oid40_t *oid;
aal_assert("umka-2664", format != NULL);
if (!(oid = aal_calloc(sizeof(*oid), 0)))
return NULL;
oid->state = 0;
oid->format = format;
oid->plug = &oid40_plug;
/* Getting oid pluign work area from format plugin. */
entcall(format, oid_area, &oid->start, &oid->len);
oid->next = oid40_get_next(oid->start);
oid->used = oid40_get_used(oid->start);
return (reiser4_oid_ent_t *)oid;
}
static void oid40_close(reiser4_oid_ent_t *entity) {
aal_assert("umka-510", entity != NULL);
aal_free(entity);
}
/* Initializes oid allocator instance and returns it to caller. */
static reiser4_oid_ent_t *oid40_create(reiser4_format_ent_t *format) {
oid40_t *oid;
if (!(oid = aal_calloc(sizeof(*oid), 0)))
return NULL;
oid->state = (1 << ENTITY_DIRTY);
/* Setting up next by OID40_RESERVED. It is needed because all oid less
then OID40_RESERVED will be used for reiser4 insetrnal purposes. */
oid->used = 0;
oid->format = format;
oid->plug = &oid40_plug;
oid->next = OID40_RESERVED;
/* Getting oid pluign work area from format plugin. */
entcall(format, oid_area, &oid->start, &oid->len);
oid40_set_next(oid->start, oid->next);
oid40_set_used(oid->start, oid->used);
return (reiser4_oid_ent_t *)oid;
}
/* Updating next and used values in oid allocator dedicated area */
static errno_t oid40_sync(reiser4_oid_ent_t *entity) {
reiser4_format_ent_t *format;
uint32_t state;
aal_assert("umka-1016", entity != NULL);
oid40_set_next(PLUG_ENT(entity)->start,
PLUG_ENT(entity)->next);
oid40_set_used(PLUG_ENT(entity)->start,
PLUG_ENT(entity)->used);
/* Mark the format dirty. */
format = PLUG_ENT(entity)->format;
state = entcall(format, get_state);
entcall(format, set_state, state | (1 << ENTITY_DIRTY));
return 0;
}
/* Returns free oid and marks it as used */
static oid_t oid40_allocate(reiser4_oid_ent_t *entity) {
aal_assert("umka-513", entity != NULL);
PLUG_ENT(entity)->next++;
PLUG_ENT(entity)->used++;
PLUG_ENT(entity)->state |= (1 << ENTITY_DIRTY);
return PLUG_ENT(entity)->next - 1;
}
/* Releases passed oid */
static void oid40_release(reiser4_oid_ent_t *entity,
oid_t oid)
{
aal_assert("umka-528", entity != NULL);
PLUG_ENT(entity)->used--;
PLUG_ENT(entity)->state |= (1 << ENTITY_DIRTY);
}
/* Returns number of free oids */
static oid_t oid40_free(reiser4_oid_ent_t *entity) {
aal_assert("umka-961", entity != NULL);
return MAX_UINT64 - PLUG_ENT(entity)->next;
}
/* Checks oid allocator for validness */
static errno_t oid40_valid(reiser4_oid_ent_t *entity) {
aal_assert("umka-966", entity != NULL);
/* Next oid should not be less than the root locality */
if (PLUG_ENT(entity)->next < OID40_ROOT_LOCALITY)
return -EINVAL;
return 0;
}
/* Returns root locality */
static oid_t oid40_root_locality() {
return OID40_ROOT_LOCALITY;
}
/* Returns root oid */
static oid_t oid40_root_objectid() {
return OID40_ROOT_OBJECTID;
}
reiser4_oid_plug_t oid40_plug = {
.p = {
.id = {OID_REISER40_ID, 0, OID_PLUG_TYPE},
.label = "oid40",
.desc = "Inode number allocator plugin.",
},
.open = oid40_open,
.close = oid40_close,
.create = oid40_create,
.valid = oid40_valid,
.allocate = oid40_allocate,
.release = oid40_release,
.sync = oid40_sync,
.print = oid40_print,
.free = oid40_free,
.layout = NULL,
.set_state = oid40_set_state,
.set_next = oid40_set_next_oid,
.set_used = oid40_set_used_oid,
.get_state = oid40_get_state,
.get_next = oid40_get_next_oid,
.get_used = oid40_get_used_oid,
.root_locality = oid40_root_locality,
.root_objectid = oid40_root_objectid,
.lost_objectid = oid40_lost_objectid,
.slink_locality = oid40_slink_locality
};
#endif
|
