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
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
|
/*
Unix SMB/CIFS implementation.
Swig interface to tdb.
Copyright (C) 2004-2006 Tim Potter <tpot@samba.org>
Copyright (C) 2007 Jelmer Vernooij <jelmer@samba.org>
** NOTE! The following LGPL license applies to the tdb
** library. This does NOT imply that all of Samba is released
** under the LGPL
This library is free software; you can redistribute it and/or
modify it under the terms of the GNU Lesser General Public
License as published by the Free Software Foundation; either
version 3 of the License, or (at your option) any later version.
This library is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
Lesser General Public License for more details.
You should have received a copy of the GNU Lesser General Public
License along with this library; if not, see <http://www.gnu.org/licenses/>.
*/
%module tdb
%{
/* This symbol is used in both includes.h and Python.h which causes an
annoying compiler warning. */
#ifdef HAVE_FSTAT
#undef HAVE_FSTAT
#endif
/* Include tdb headers */
#include <stdint.h>
#include <signal.h>
#include <tdb.h>
#include <fcntl.h>
typedef TDB_CONTEXT tdb;
%}
/* The tdb functions will crash if a NULL tdb context is passed */
%import exception.i
%import stdint.i
%typemap(check,noblock=1) TDB_CONTEXT* {
if ($1 == NULL)
SWIG_exception(SWIG_ValueError,
"tdb context must be non-NULL");
}
/* In and out typemaps for the TDB_DATA structure. This is converted to
and from the Python string type which can contain arbitrary binary
data.. */
%typemap(in,noblock=1) TDB_DATA {
if (!PyString_Check($input)) {
PyErr_SetString(PyExc_TypeError, "string arg expected");
return NULL;
}
$1.dsize = PyString_Size($input);
$1.dptr = (uint8_t *)PyString_AsString($input);
}
%typemap(out,noblock=1) TDB_DATA {
if ($1.dptr == NULL && $1.dsize == 0) {
$result = Py_None;
} else {
$result = PyString_FromStringAndSize((const char *)$1.dptr, $1.dsize);
free($1.dptr);
}
}
/* Treat a mode_t as an unsigned integer */
typedef int mode_t;
/* flags to tdb_store() */
%constant int REPLACE = TDB_REPLACE;
%constant int INSERT = TDB_INSERT;
%constant int MODIFY = TDB_MODIFY;
/* flags for tdb_open() */
%constant int DEFAULT = TDB_DEFAULT;
%constant int CLEAR_IF_FIRST = TDB_CLEAR_IF_FIRST;
%constant int INTERNAL = TDB_INTERNAL;
%constant int NOLOCK = TDB_NOLOCK;
%constant int NOMMAP = TDB_NOMMAP;
%constant int CONVERT = TDB_CONVERT;
%constant int BIGENDIAN = TDB_BIGENDIAN;
enum TDB_ERROR {
TDB_SUCCESS=0,
TDB_ERR_CORRUPT,
TDB_ERR_IO,
TDB_ERR_LOCK,
TDB_ERR_OOM,
TDB_ERR_EXISTS,
TDB_ERR_NOLOCK,
TDB_ERR_LOCK_TIMEOUT,
TDB_ERR_NOEXIST,
TDB_ERR_EINVAL,
TDB_ERR_RDONLY
};
%rename(Tdb) tdb;
%rename(lock_all) tdb_context::lockall;
%rename(unlock_all) tdb_context::unlockall;
%rename(read_lock_all) tdb_context::lockall_read;
%rename(read_unlock_all) tdb_context::unlockall_read;
%typemap(default,noblock=1) int tdb_flags {
$1 = TDB_DEFAULT;
}
%typemap(default,noblock=1) int open_flags {
$1 = O_RDWR;
}
%typemap(default,noblock=1) int hash_size {
$1 = 0;
}
%typemap(default,noblock=1) mode_t mode {
$1 = 0600;
}
%typemap(default,noblock=1) int flag {
$1 = TDB_REPLACE;
}
typedef struct tdb_context {
%extend {
tdb(const char *name, int hash_size,
int tdb_flags,
int open_flags, mode_t mode)
{
tdb *ret = tdb_open(name, hash_size, tdb_flags, open_flags, mode);
/* Throw an IOError exception from errno if tdb_open() returns
NULL */
if (ret == NULL) {
PyErr_SetFromErrno(PyExc_IOError);
SWIG_fail;
}
fail:
return ret;
}
enum TDB_ERROR error();
~tdb() { tdb_close($self); }
int close();
int append(TDB_DATA key, TDB_DATA new_dbuf);
const char *errorstr();
TDB_DATA fetch(TDB_DATA key);
int delete(TDB_DATA key);
int store(TDB_DATA key, TDB_DATA dbuf, int flag);
int exists(TDB_DATA key);
TDB_DATA firstkey();
TDB_DATA nextkey(TDB_DATA key);
int lockall();
int unlockall();
int lockall_read();
int unlockall_read();
int reopen();
int transaction_start();
int transaction_commit();
int transaction_cancel();
int transaction_recover();
int hash_size();
size_t map_size();
int get_flags();
void set_max_dead(int max_dead);
const char *name();
}
%pythoncode {
def __str__(self):
return self.name()
# Random access to keys, values
def __getitem__(self, key):
result = self.fetch(key)
if result is None:
raise KeyError, '%s: %s' % (key, self.errorstr())
return result
def __setitem__(self, key, item):
if self.store(key, item) == -1:
raise IOError, self.errorstr()
def __delitem__(self, key):
if not self.exists(key):
raise KeyError, '%s: %s' % (key, self.errorstr())
self.delete(key)
def __contains__(self, key):
return self.exists(key) != 0
def has_key(self, key):
return self.exists(key) != 0
# Tdb iterator
class TdbIterator:
def __init__(self, tdb):
self.tdb = tdb
self.key = None
def __iter__(self):
return self
def next(self):
if self.key is None:
self.key = self.tdb.firstkey()
if self.key is None:
raise StopIteration
return self.key
else:
self.key = self.tdb.nextkey(self.key)
if self.key is None:
raise StopIteration
return self.key
def __iter__(self):
return self.TdbIterator(self)
# Implement other dict functions using TdbIterator
def keys(self):
return [k for k in iter(self)]
def values(self):
return [self[k] for k in iter(self)]
def items(self):
return [(k, self[k]) for k in iter(self)]
def __len__(self):
return len(self.keys())
def clear(self):
for k in iter(self):
del(self[k])
# TODO: iterkeys, itervalues, iteritems
# TODO: any other missing methods for container types
}
} tdb;
|