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
|
%%
%% %CopyrightBegin%
%%
%% Copyright Ericsson AB 2001-2016. All Rights Reserved.
%%
%% Licensed under the Apache License, Version 2.0 (the "License");
%% you may not use this file except in compliance with the License.
%% You may obtain a copy of the License at
%%
%% http://www.apache.org/licenses/LICENSE-2.0
%%
%% Unless required by applicable law or agreed to in writing, software
%% distributed under the License is distributed on an "AS IS" BASIS,
%% WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
%% See the License for the specific language governing permissions and
%% limitations under the License.
%%
%% %CopyrightEnd%
%%
-define(DEFAULT_MIN_NO_SLOTS, 256).
-define(DEFAULT_MAX_NO_SLOTS, 32*1024*1024).
-define(DEFAULT_AUTOSAVE, 3). % minutes
-define(DEFAULT_CACHE, {3000, 14000}). % cache_parms()
%% Type.
-define(SET, 1).
-define(BAG, 2).
-define(DUPLICATE_BAG, 3).
-define(MAGIC, 16#0abcdef). % dets cookie, won't ever change.
%% Status values.
-define(FREE, 16#3abcdef).
-define(ACTIVE, 16#12345678).
-define(FILE_FORMAT_VERSION_POS, 16).
-define(CHUNK_SIZE, 8192).
-define(SERVER_NAME, dets).
-define(POW(X), (1 bsl (X))).
%% REM2(A,B) = A rem B, if B is a power of 2.
-define(REM2(A, B), ((A) band ((B)-1))).
-define(DETS_CALL(Pid, Req), {'$dets_call', Pid, Req}).
-type access() :: 'read' | 'read_write'.
-type auto_save() :: 'infinity' | non_neg_integer().
-type hash_bif() :: 'phash' | 'phash2'.
-type keypos() :: pos_integer().
-type no_colls() :: [{LogSize :: non_neg_integer(),
NoCollections :: non_neg_integer()}].
-type no_slots() :: 'default' | non_neg_integer().
-type tab_name() :: term().
-type type() :: 'bag' | 'duplicate_bag' | 'set'.
-type update_mode() :: 'dirty'
| 'new_dirty'
| 'saved'
| {'error', Reason :: term()}.
%% Record holding the file header and more.
-record(head, {
m :: non_neg_integer(), % size
m2 :: non_neg_integer(), % m * 2
next :: non_neg_integer(), % next position for growth
% (segm mgmt only)
fptr :: file:fd(), % the file descriptor
no_objects :: non_neg_integer() , % number of objects in table,
no_keys :: non_neg_integer(), % number of keys
maxobjsize :: 'undefined' | non_neg_integer(), % 2-log of
% the size of the biggest object collection
n, % split indicator
type :: type(),
keypos :: keypos(), % default is 1 as for ets
freelists :: 'undefined'
| tuple(), % tuple of free lists of buddies
% if fixed =/= false, then a pair of freelists
freelists_p :: 'undefined'
| non_neg_integer(), % cached FreelistsPointer
no_collections :: 'undefined'
| no_colls(), % number of object collections
% per size (version 9(b))
auto_save :: auto_save(),
update_mode :: update_mode(),
fixed = false :: 'false'
| {{integer(), integer()}, % time of first fix,
[{pid(), % and number of fixes per process
non_neg_integer()}]},
hash_bif :: hash_bif(), % hash bif used for this file
has_md5 :: boolean(), % whether the header has
% an MD5 sum (version 9(c))
min_no_slots :: no_slots(), % minimum number of slots
max_no_slots :: no_slots(), % maximum number of slots
cache :: 'undefined' | cache(), % Write cache.
filename :: file:name(), % name of the file being used
access = read_write :: access(),
ram_file = false :: boolean(),
name :: tab_name(), % the name of the table
parent :: 'undefined' | pid(), % The supervisor of Dets processes.
server :: 'undefined' | pid(), % The creator of Dets processes.
bump :: non_neg_integer(),
base :: non_neg_integer()
}).
%% Info extracted from the file header.
-record(fileheader, {
freelist :: non_neg_integer(),
fl_base :: non_neg_integer(),
cookie :: non_neg_integer(),
closed_properly :: non_neg_integer(),
type :: 'badtype' | type(),
version :: non_neg_integer(),
m :: non_neg_integer(),
next :: non_neg_integer(),
keypos :: keypos(),
no_objects :: non_neg_integer(),
no_keys :: non_neg_integer(),
min_no_slots :: non_neg_integer(),
max_no_slots :: non_neg_integer(),
no_colls :: 'undefined' | no_colls(),
hash_method :: non_neg_integer(),
read_md5 :: binary(),
has_md5 :: boolean(),
md5 :: binary(),
trailer :: non_neg_integer(),
eof :: non_neg_integer(),
n
}).
-type delay() :: non_neg_integer().
-type threshold() :: non_neg_integer().
-type cache_parms() ::
{Delay :: delay(), % max time items are kept in RAM only,
% in milliseconds
Size :: threshold()}. % threshold size of cache, in bytes
%% Write Cache.
-record(cache, {
cache :: % write cache, last item first
[{Key :: term(),
{Seq :: non_neg_integer(), Item :: term()}}],
csize :: non_neg_integer(), % current size of the cached items
inserts :: % upper limit on number of inserted keys
non_neg_integer(),
wrtime :: 'undefined' | integer(), % last write or update time
tsize :: threshold(), % threshold size of cache
delay :: delay() % max time items are kept in RAM only
}).
-type cache() :: #cache{}.
|
