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
|
// Copyright (c) Arni Mar Jonsson.
// See LICENSE for details.
#ifndef __LEVELDB__MODULE__H__
#define __LEVELDB__MODULE__H__
extern "C" {
#include <Python.h>
#include "structmember.h"
#include <stdio.h>
#include <limits.h>
}
#include <leveldb/db.h>
#include <leveldb/write_batch.h>
#include <leveldb/comparator.h>
#include <leveldb/cache.h>
#include <vector>
extern const char leveldb_repair_db_doc[];
extern const char leveldb_destroy_db_doc[];
extern "C" PyObject* leveldb_repair_db(PyObject* o, PyObject* args);
extern "C" PyObject* leveldb_destroy_db(PyObject* o, PyObject* args);
typedef struct {
PyObject_HEAD
// object is open if all of these are non-null,
// once an object has been closed, it can not be re-opened
leveldb::DB* _db;
leveldb::Options* _options;
leveldb::Cache* _cache;
// number of open snapshots, associated with LevelDB object
int n_snapshots;
// number of open iterators, associated with LevelDB object
int n_iterators;
} PyLevelDB;
typedef struct {
PyObject_HEAD
// the associated LevelDB object
PyLevelDB* db;
// the snapshot
const leveldb::Snapshot* snapshot;
} PyLevelDBSnapshot;
typedef struct {
PyObject_HEAD
// the associated LevelDB object or snapshot
PyObject* ref;
// the associated db object
PyLevelDB* db;
// the iterator
leveldb::Iterator* iterator;
// upper/lower limit, inclusive, if any
std::string* bound;
// iterator direction
int is_reverse;
// if 1: return (k, v) 2-tuples, otherwise just k
int include_value;
} PyLevelDBIter;
typedef struct {
bool is_put;
std::string key;
std::string value;
} PyWriteBatchEntry;
typedef struct {
PyObject_HEAD
std::vector<PyWriteBatchEntry>* ops;
} PyWriteBatch;
// custom types
extern PyTypeObject PyLevelDB_Type;
extern PyTypeObject PyLevelDBSnapshot_Type;
extern PyTypeObject PyWriteBatch_Type;
#define PyLevelDB_Check(op) PyObject_TypeCheck(op, &PyLevelDB_Type)
#define PyLevelDBSnapshotCheck(op) PyObject_TypeCheck(op, &PyLevelDBSnapshot_Type)
#define PyWriteBatch_Check(op) PyObject_TypeCheck(op, &PyWriteBatch_Type)
extern PyObject* leveldb_exception;
#endif
|
