##// END OF EJS Templates
revlog: don't say "not found" on internal error...
Martin von Zweigbergk -
r37878:a9d9802d default
parent child Browse files
Show More
@@ -1,2101 +1,2099 b''
1 /*
1 /*
2 parsers.c - efficient content parsing
2 parsers.c - efficient content parsing
3
3
4 Copyright 2008 Matt Mackall <mpm@selenic.com> and others
4 Copyright 2008 Matt Mackall <mpm@selenic.com> and others
5
5
6 This software may be used and distributed according to the terms of
6 This software may be used and distributed according to the terms of
7 the GNU General Public License, incorporated herein by reference.
7 the GNU General Public License, incorporated herein by reference.
8 */
8 */
9
9
10 #include <Python.h>
10 #include <Python.h>
11 #include <assert.h>
11 #include <assert.h>
12 #include <ctype.h>
12 #include <ctype.h>
13 #include <stddef.h>
13 #include <stddef.h>
14 #include <string.h>
14 #include <string.h>
15
15
16 #include "bitmanipulation.h"
16 #include "bitmanipulation.h"
17 #include "charencode.h"
17 #include "charencode.h"
18 #include "util.h"
18 #include "util.h"
19
19
20 #ifdef IS_PY3K
20 #ifdef IS_PY3K
21 /* The mapping of Python types is meant to be temporary to get Python
21 /* The mapping of Python types is meant to be temporary to get Python
22 * 3 to compile. We should remove this once Python 3 support is fully
22 * 3 to compile. We should remove this once Python 3 support is fully
23 * supported and proper types are used in the extensions themselves. */
23 * supported and proper types are used in the extensions themselves. */
24 #define PyInt_Check PyLong_Check
24 #define PyInt_Check PyLong_Check
25 #define PyInt_FromLong PyLong_FromLong
25 #define PyInt_FromLong PyLong_FromLong
26 #define PyInt_FromSsize_t PyLong_FromSsize_t
26 #define PyInt_FromSsize_t PyLong_FromSsize_t
27 #define PyInt_AS_LONG PyLong_AS_LONG
27 #define PyInt_AS_LONG PyLong_AS_LONG
28 #define PyInt_AsLong PyLong_AsLong
28 #define PyInt_AsLong PyLong_AsLong
29 #endif
29 #endif
30
30
31 /*
31 /*
32 * A base-16 trie for fast node->rev mapping.
32 * A base-16 trie for fast node->rev mapping.
33 *
33 *
34 * Positive value is index of the next node in the trie
34 * Positive value is index of the next node in the trie
35 * Negative value is a leaf: -(rev + 1)
35 * Negative value is a leaf: -(rev + 1)
36 * Zero is empty
36 * Zero is empty
37 */
37 */
38 typedef struct {
38 typedef struct {
39 int children[16];
39 int children[16];
40 } nodetree;
40 } nodetree;
41
41
42 /*
42 /*
43 * This class has two behaviors.
43 * This class has two behaviors.
44 *
44 *
45 * When used in a list-like way (with integer keys), we decode an
45 * When used in a list-like way (with integer keys), we decode an
46 * entry in a RevlogNG index file on demand. Our last entry is a
46 * entry in a RevlogNG index file on demand. Our last entry is a
47 * sentinel, always a nullid. We have limited support for
47 * sentinel, always a nullid. We have limited support for
48 * integer-keyed insert and delete, only at elements right before the
48 * integer-keyed insert and delete, only at elements right before the
49 * sentinel.
49 * sentinel.
50 *
50 *
51 * With string keys, we lazily perform a reverse mapping from node to
51 * With string keys, we lazily perform a reverse mapping from node to
52 * rev, using a base-16 trie.
52 * rev, using a base-16 trie.
53 */
53 */
54 typedef struct {
54 typedef struct {
55 PyObject_HEAD
55 PyObject_HEAD
56 /* Type-specific fields go here. */
56 /* Type-specific fields go here. */
57 PyObject *data; /* raw bytes of index */
57 PyObject *data; /* raw bytes of index */
58 Py_buffer buf; /* buffer of data */
58 Py_buffer buf; /* buffer of data */
59 PyObject **cache; /* cached tuples */
59 PyObject **cache; /* cached tuples */
60 const char **offsets; /* populated on demand */
60 const char **offsets; /* populated on demand */
61 Py_ssize_t raw_length; /* original number of elements */
61 Py_ssize_t raw_length; /* original number of elements */
62 Py_ssize_t length; /* current number of elements */
62 Py_ssize_t length; /* current number of elements */
63 PyObject *added; /* populated on demand */
63 PyObject *added; /* populated on demand */
64 PyObject *headrevs; /* cache, invalidated on changes */
64 PyObject *headrevs; /* cache, invalidated on changes */
65 PyObject *filteredrevs;/* filtered revs set */
65 PyObject *filteredrevs;/* filtered revs set */
66 nodetree *nt; /* base-16 trie */
66 nodetree *nt; /* base-16 trie */
67 unsigned ntlength; /* # nodes in use */
67 unsigned ntlength; /* # nodes in use */
68 unsigned ntcapacity; /* # nodes allocated */
68 unsigned ntcapacity; /* # nodes allocated */
69 int ntdepth; /* maximum depth of tree */
69 int ntdepth; /* maximum depth of tree */
70 int ntsplits; /* # splits performed */
70 int ntsplits; /* # splits performed */
71 int ntrev; /* last rev scanned */
71 int ntrev; /* last rev scanned */
72 int ntlookups; /* # lookups */
72 int ntlookups; /* # lookups */
73 int ntmisses; /* # lookups that miss the cache */
73 int ntmisses; /* # lookups that miss the cache */
74 int inlined;
74 int inlined;
75 } indexObject;
75 } indexObject;
76
76
77 static Py_ssize_t index_length(const indexObject *self)
77 static Py_ssize_t index_length(const indexObject *self)
78 {
78 {
79 if (self->added == NULL)
79 if (self->added == NULL)
80 return self->length;
80 return self->length;
81 return self->length + PyList_GET_SIZE(self->added);
81 return self->length + PyList_GET_SIZE(self->added);
82 }
82 }
83
83
84 static PyObject *nullentry;
84 static PyObject *nullentry;
85 static const char nullid[20];
85 static const char nullid[20];
86
86
87 static Py_ssize_t inline_scan(indexObject *self, const char **offsets);
87 static Py_ssize_t inline_scan(indexObject *self, const char **offsets);
88
88
89 #if LONG_MAX == 0x7fffffffL
89 #if LONG_MAX == 0x7fffffffL
90 static const char *const tuple_format = PY23("Kiiiiiis#", "Kiiiiiiy#");
90 static const char *const tuple_format = PY23("Kiiiiiis#", "Kiiiiiiy#");
91 #else
91 #else
92 static const char *const tuple_format = PY23("kiiiiiis#", "kiiiiiiy#");
92 static const char *const tuple_format = PY23("kiiiiiis#", "kiiiiiiy#");
93 #endif
93 #endif
94
94
95 /* A RevlogNG v1 index entry is 64 bytes long. */
95 /* A RevlogNG v1 index entry is 64 bytes long. */
96 static const long v1_hdrsize = 64;
96 static const long v1_hdrsize = 64;
97
97
98 /*
98 /*
99 * Return a pointer to the beginning of a RevlogNG record.
99 * Return a pointer to the beginning of a RevlogNG record.
100 */
100 */
101 static const char *index_deref(indexObject *self, Py_ssize_t pos)
101 static const char *index_deref(indexObject *self, Py_ssize_t pos)
102 {
102 {
103 if (self->inlined && pos > 0) {
103 if (self->inlined && pos > 0) {
104 if (self->offsets == NULL) {
104 if (self->offsets == NULL) {
105 self->offsets = PyMem_Malloc(self->raw_length *
105 self->offsets = PyMem_Malloc(self->raw_length *
106 sizeof(*self->offsets));
106 sizeof(*self->offsets));
107 if (self->offsets == NULL)
107 if (self->offsets == NULL)
108 return (const char *)PyErr_NoMemory();
108 return (const char *)PyErr_NoMemory();
109 inline_scan(self, self->offsets);
109 inline_scan(self, self->offsets);
110 }
110 }
111 return self->offsets[pos];
111 return self->offsets[pos];
112 }
112 }
113
113
114 return (const char *)(self->buf.buf) + pos * v1_hdrsize;
114 return (const char *)(self->buf.buf) + pos * v1_hdrsize;
115 }
115 }
116
116
117 static inline int index_get_parents(indexObject *self, Py_ssize_t rev,
117 static inline int index_get_parents(indexObject *self, Py_ssize_t rev,
118 int *ps, int maxrev)
118 int *ps, int maxrev)
119 {
119 {
120 if (rev >= self->length - 1) {
120 if (rev >= self->length - 1) {
121 PyObject *tuple = PyList_GET_ITEM(self->added,
121 PyObject *tuple = PyList_GET_ITEM(self->added,
122 rev - self->length + 1);
122 rev - self->length + 1);
123 ps[0] = (int)PyInt_AS_LONG(PyTuple_GET_ITEM(tuple, 5));
123 ps[0] = (int)PyInt_AS_LONG(PyTuple_GET_ITEM(tuple, 5));
124 ps[1] = (int)PyInt_AS_LONG(PyTuple_GET_ITEM(tuple, 6));
124 ps[1] = (int)PyInt_AS_LONG(PyTuple_GET_ITEM(tuple, 6));
125 } else {
125 } else {
126 const char *data = index_deref(self, rev);
126 const char *data = index_deref(self, rev);
127 ps[0] = getbe32(data + 24);
127 ps[0] = getbe32(data + 24);
128 ps[1] = getbe32(data + 28);
128 ps[1] = getbe32(data + 28);
129 }
129 }
130 /* If index file is corrupted, ps[] may point to invalid revisions. So
130 /* If index file is corrupted, ps[] may point to invalid revisions. So
131 * there is a risk of buffer overflow to trust them unconditionally. */
131 * there is a risk of buffer overflow to trust them unconditionally. */
132 if (ps[0] > maxrev || ps[1] > maxrev) {
132 if (ps[0] > maxrev || ps[1] > maxrev) {
133 PyErr_SetString(PyExc_ValueError, "parent out of range");
133 PyErr_SetString(PyExc_ValueError, "parent out of range");
134 return -1;
134 return -1;
135 }
135 }
136 return 0;
136 return 0;
137 }
137 }
138
138
139
139
140 /*
140 /*
141 * RevlogNG format (all in big endian, data may be inlined):
141 * RevlogNG format (all in big endian, data may be inlined):
142 * 6 bytes: offset
142 * 6 bytes: offset
143 * 2 bytes: flags
143 * 2 bytes: flags
144 * 4 bytes: compressed length
144 * 4 bytes: compressed length
145 * 4 bytes: uncompressed length
145 * 4 bytes: uncompressed length
146 * 4 bytes: base revision
146 * 4 bytes: base revision
147 * 4 bytes: link revision
147 * 4 bytes: link revision
148 * 4 bytes: parent 1 revision
148 * 4 bytes: parent 1 revision
149 * 4 bytes: parent 2 revision
149 * 4 bytes: parent 2 revision
150 * 32 bytes: nodeid (only 20 bytes used)
150 * 32 bytes: nodeid (only 20 bytes used)
151 */
151 */
152 static PyObject *index_get(indexObject *self, Py_ssize_t pos)
152 static PyObject *index_get(indexObject *self, Py_ssize_t pos)
153 {
153 {
154 uint64_t offset_flags;
154 uint64_t offset_flags;
155 int comp_len, uncomp_len, base_rev, link_rev, parent_1, parent_2;
155 int comp_len, uncomp_len, base_rev, link_rev, parent_1, parent_2;
156 const char *c_node_id;
156 const char *c_node_id;
157 const char *data;
157 const char *data;
158 Py_ssize_t length = index_length(self);
158 Py_ssize_t length = index_length(self);
159 PyObject *entry;
159 PyObject *entry;
160
160
161 if (pos < 0)
161 if (pos < 0)
162 pos += length;
162 pos += length;
163
163
164 if (pos < 0 || pos >= length) {
164 if (pos < 0 || pos >= length) {
165 PyErr_SetString(PyExc_IndexError, "revlog index out of range");
165 PyErr_SetString(PyExc_IndexError, "revlog index out of range");
166 return NULL;
166 return NULL;
167 }
167 }
168
168
169 if (pos == length - 1) {
169 if (pos == length - 1) {
170 Py_INCREF(nullentry);
170 Py_INCREF(nullentry);
171 return nullentry;
171 return nullentry;
172 }
172 }
173
173
174 if (pos >= self->length - 1) {
174 if (pos >= self->length - 1) {
175 PyObject *obj;
175 PyObject *obj;
176 obj = PyList_GET_ITEM(self->added, pos - self->length + 1);
176 obj = PyList_GET_ITEM(self->added, pos - self->length + 1);
177 Py_INCREF(obj);
177 Py_INCREF(obj);
178 return obj;
178 return obj;
179 }
179 }
180
180
181 if (self->cache) {
181 if (self->cache) {
182 if (self->cache[pos]) {
182 if (self->cache[pos]) {
183 Py_INCREF(self->cache[pos]);
183 Py_INCREF(self->cache[pos]);
184 return self->cache[pos];
184 return self->cache[pos];
185 }
185 }
186 } else {
186 } else {
187 self->cache = calloc(self->raw_length, sizeof(PyObject *));
187 self->cache = calloc(self->raw_length, sizeof(PyObject *));
188 if (self->cache == NULL)
188 if (self->cache == NULL)
189 return PyErr_NoMemory();
189 return PyErr_NoMemory();
190 }
190 }
191
191
192 data = index_deref(self, pos);
192 data = index_deref(self, pos);
193 if (data == NULL)
193 if (data == NULL)
194 return NULL;
194 return NULL;
195
195
196 offset_flags = getbe32(data + 4);
196 offset_flags = getbe32(data + 4);
197 if (pos == 0) /* mask out version number for the first entry */
197 if (pos == 0) /* mask out version number for the first entry */
198 offset_flags &= 0xFFFF;
198 offset_flags &= 0xFFFF;
199 else {
199 else {
200 uint32_t offset_high = getbe32(data);
200 uint32_t offset_high = getbe32(data);
201 offset_flags |= ((uint64_t)offset_high) << 32;
201 offset_flags |= ((uint64_t)offset_high) << 32;
202 }
202 }
203
203
204 comp_len = getbe32(data + 8);
204 comp_len = getbe32(data + 8);
205 uncomp_len = getbe32(data + 12);
205 uncomp_len = getbe32(data + 12);
206 base_rev = getbe32(data + 16);
206 base_rev = getbe32(data + 16);
207 link_rev = getbe32(data + 20);
207 link_rev = getbe32(data + 20);
208 parent_1 = getbe32(data + 24);
208 parent_1 = getbe32(data + 24);
209 parent_2 = getbe32(data + 28);
209 parent_2 = getbe32(data + 28);
210 c_node_id = data + 32;
210 c_node_id = data + 32;
211
211
212 entry = Py_BuildValue(tuple_format, offset_flags, comp_len,
212 entry = Py_BuildValue(tuple_format, offset_flags, comp_len,
213 uncomp_len, base_rev, link_rev,
213 uncomp_len, base_rev, link_rev,
214 parent_1, parent_2, c_node_id, 20);
214 parent_1, parent_2, c_node_id, 20);
215
215
216 if (entry) {
216 if (entry) {
217 PyObject_GC_UnTrack(entry);
217 PyObject_GC_UnTrack(entry);
218 Py_INCREF(entry);
218 Py_INCREF(entry);
219 }
219 }
220
220
221 self->cache[pos] = entry;
221 self->cache[pos] = entry;
222
222
223 return entry;
223 return entry;
224 }
224 }
225
225
226 /*
226 /*
227 * Return the 20-byte SHA of the node corresponding to the given rev.
227 * Return the 20-byte SHA of the node corresponding to the given rev.
228 */
228 */
229 static const char *index_node(indexObject *self, Py_ssize_t pos)
229 static const char *index_node(indexObject *self, Py_ssize_t pos)
230 {
230 {
231 Py_ssize_t length = index_length(self);
231 Py_ssize_t length = index_length(self);
232 const char *data;
232 const char *data;
233
233
234 if (pos == length - 1 || pos == INT_MAX)
234 if (pos == length - 1 || pos == INT_MAX)
235 return nullid;
235 return nullid;
236
236
237 if (pos >= length)
237 if (pos >= length)
238 return NULL;
238 return NULL;
239
239
240 if (pos >= self->length - 1) {
240 if (pos >= self->length - 1) {
241 PyObject *tuple, *str;
241 PyObject *tuple, *str;
242 tuple = PyList_GET_ITEM(self->added, pos - self->length + 1);
242 tuple = PyList_GET_ITEM(self->added, pos - self->length + 1);
243 str = PyTuple_GetItem(tuple, 7);
243 str = PyTuple_GetItem(tuple, 7);
244 return str ? PyBytes_AS_STRING(str) : NULL;
244 return str ? PyBytes_AS_STRING(str) : NULL;
245 }
245 }
246
246
247 data = index_deref(self, pos);
247 data = index_deref(self, pos);
248 return data ? data + 32 : NULL;
248 return data ? data + 32 : NULL;
249 }
249 }
250
250
251 /*
251 /*
252 * Return the 20-byte SHA of the node corresponding to the given rev. The
252 * Return the 20-byte SHA of the node corresponding to the given rev. The
253 * rev is assumed to be existing. If not, an exception is set.
253 * rev is assumed to be existing. If not, an exception is set.
254 */
254 */
255 static const char *index_node_existing(indexObject *self, Py_ssize_t pos)
255 static const char *index_node_existing(indexObject *self, Py_ssize_t pos)
256 {
256 {
257 const char *node = index_node(self, pos);
257 const char *node = index_node(self, pos);
258 if (node == NULL) {
258 if (node == NULL) {
259 PyErr_Format(PyExc_IndexError, "could not access rev %d",
259 PyErr_Format(PyExc_IndexError, "could not access rev %d",
260 (int)pos);
260 (int)pos);
261 }
261 }
262 return node;
262 return node;
263 }
263 }
264
264
265 static int nt_insert(indexObject *self, const char *node, int rev);
265 static int nt_insert(indexObject *self, const char *node, int rev);
266
266
267 static int node_check(PyObject *obj, char **node, Py_ssize_t *nodelen)
267 static int node_check(PyObject *obj, char **node, Py_ssize_t *nodelen)
268 {
268 {
269 if (PyBytes_AsStringAndSize(obj, node, nodelen) == -1)
269 if (PyBytes_AsStringAndSize(obj, node, nodelen) == -1)
270 return -1;
270 return -1;
271 if (*nodelen == 20)
271 if (*nodelen == 20)
272 return 0;
272 return 0;
273 PyErr_SetString(PyExc_ValueError, "20-byte hash required");
273 PyErr_SetString(PyExc_ValueError, "20-byte hash required");
274 return -1;
274 return -1;
275 }
275 }
276
276
277 static PyObject *index_insert(indexObject *self, PyObject *args)
277 static PyObject *index_insert(indexObject *self, PyObject *args)
278 {
278 {
279 PyObject *obj;
279 PyObject *obj;
280 char *node;
280 char *node;
281 int index;
281 int index;
282 Py_ssize_t len, nodelen;
282 Py_ssize_t len, nodelen;
283
283
284 if (!PyArg_ParseTuple(args, "iO", &index, &obj))
284 if (!PyArg_ParseTuple(args, "iO", &index, &obj))
285 return NULL;
285 return NULL;
286
286
287 if (!PyTuple_Check(obj) || PyTuple_GET_SIZE(obj) != 8) {
287 if (!PyTuple_Check(obj) || PyTuple_GET_SIZE(obj) != 8) {
288 PyErr_SetString(PyExc_TypeError, "8-tuple required");
288 PyErr_SetString(PyExc_TypeError, "8-tuple required");
289 return NULL;
289 return NULL;
290 }
290 }
291
291
292 if (node_check(PyTuple_GET_ITEM(obj, 7), &node, &nodelen) == -1)
292 if (node_check(PyTuple_GET_ITEM(obj, 7), &node, &nodelen) == -1)
293 return NULL;
293 return NULL;
294
294
295 len = index_length(self);
295 len = index_length(self);
296
296
297 if (index < 0)
297 if (index < 0)
298 index += len;
298 index += len;
299
299
300 if (index != len - 1) {
300 if (index != len - 1) {
301 PyErr_SetString(PyExc_IndexError,
301 PyErr_SetString(PyExc_IndexError,
302 "insert only supported at index -1");
302 "insert only supported at index -1");
303 return NULL;
303 return NULL;
304 }
304 }
305
305
306 if (self->added == NULL) {
306 if (self->added == NULL) {
307 self->added = PyList_New(0);
307 self->added = PyList_New(0);
308 if (self->added == NULL)
308 if (self->added == NULL)
309 return NULL;
309 return NULL;
310 }
310 }
311
311
312 if (PyList_Append(self->added, obj) == -1)
312 if (PyList_Append(self->added, obj) == -1)
313 return NULL;
313 return NULL;
314
314
315 if (self->nt)
315 if (self->nt)
316 nt_insert(self, node, index);
316 nt_insert(self, node, index);
317
317
318 Py_CLEAR(self->headrevs);
318 Py_CLEAR(self->headrevs);
319 Py_RETURN_NONE;
319 Py_RETURN_NONE;
320 }
320 }
321
321
322 static void _index_clearcaches(indexObject *self)
322 static void _index_clearcaches(indexObject *self)
323 {
323 {
324 if (self->cache) {
324 if (self->cache) {
325 Py_ssize_t i;
325 Py_ssize_t i;
326
326
327 for (i = 0; i < self->raw_length; i++)
327 for (i = 0; i < self->raw_length; i++)
328 Py_CLEAR(self->cache[i]);
328 Py_CLEAR(self->cache[i]);
329 free(self->cache);
329 free(self->cache);
330 self->cache = NULL;
330 self->cache = NULL;
331 }
331 }
332 if (self->offsets) {
332 if (self->offsets) {
333 PyMem_Free(self->offsets);
333 PyMem_Free(self->offsets);
334 self->offsets = NULL;
334 self->offsets = NULL;
335 }
335 }
336 if (self->nt) {
336 if (self->nt) {
337 free(self->nt);
337 free(self->nt);
338 self->nt = NULL;
338 self->nt = NULL;
339 }
339 }
340 Py_CLEAR(self->headrevs);
340 Py_CLEAR(self->headrevs);
341 }
341 }
342
342
343 static PyObject *index_clearcaches(indexObject *self)
343 static PyObject *index_clearcaches(indexObject *self)
344 {
344 {
345 _index_clearcaches(self);
345 _index_clearcaches(self);
346 self->ntlength = self->ntcapacity = 0;
346 self->ntlength = self->ntcapacity = 0;
347 self->ntdepth = self->ntsplits = 0;
347 self->ntdepth = self->ntsplits = 0;
348 self->ntrev = -1;
348 self->ntrev = -1;
349 self->ntlookups = self->ntmisses = 0;
349 self->ntlookups = self->ntmisses = 0;
350 Py_RETURN_NONE;
350 Py_RETURN_NONE;
351 }
351 }
352
352
353 static PyObject *index_stats(indexObject *self)
353 static PyObject *index_stats(indexObject *self)
354 {
354 {
355 PyObject *obj = PyDict_New();
355 PyObject *obj = PyDict_New();
356 PyObject *t = NULL;
356 PyObject *t = NULL;
357
357
358 if (obj == NULL)
358 if (obj == NULL)
359 return NULL;
359 return NULL;
360
360
361 #define istat(__n, __d) \
361 #define istat(__n, __d) \
362 do { \
362 do { \
363 t = PyInt_FromSsize_t(self->__n); \
363 t = PyInt_FromSsize_t(self->__n); \
364 if (!t) \
364 if (!t) \
365 goto bail; \
365 goto bail; \
366 if (PyDict_SetItemString(obj, __d, t) == -1) \
366 if (PyDict_SetItemString(obj, __d, t) == -1) \
367 goto bail; \
367 goto bail; \
368 Py_DECREF(t); \
368 Py_DECREF(t); \
369 } while (0)
369 } while (0)
370
370
371 if (self->added) {
371 if (self->added) {
372 Py_ssize_t len = PyList_GET_SIZE(self->added);
372 Py_ssize_t len = PyList_GET_SIZE(self->added);
373 t = PyInt_FromSsize_t(len);
373 t = PyInt_FromSsize_t(len);
374 if (!t)
374 if (!t)
375 goto bail;
375 goto bail;
376 if (PyDict_SetItemString(obj, "index entries added", t) == -1)
376 if (PyDict_SetItemString(obj, "index entries added", t) == -1)
377 goto bail;
377 goto bail;
378 Py_DECREF(t);
378 Py_DECREF(t);
379 }
379 }
380
380
381 if (self->raw_length != self->length - 1)
381 if (self->raw_length != self->length - 1)
382 istat(raw_length, "revs on disk");
382 istat(raw_length, "revs on disk");
383 istat(length, "revs in memory");
383 istat(length, "revs in memory");
384 istat(ntcapacity, "node trie capacity");
384 istat(ntcapacity, "node trie capacity");
385 istat(ntdepth, "node trie depth");
385 istat(ntdepth, "node trie depth");
386 istat(ntlength, "node trie count");
386 istat(ntlength, "node trie count");
387 istat(ntlookups, "node trie lookups");
387 istat(ntlookups, "node trie lookups");
388 istat(ntmisses, "node trie misses");
388 istat(ntmisses, "node trie misses");
389 istat(ntrev, "node trie last rev scanned");
389 istat(ntrev, "node trie last rev scanned");
390 istat(ntsplits, "node trie splits");
390 istat(ntsplits, "node trie splits");
391
391
392 #undef istat
392 #undef istat
393
393
394 return obj;
394 return obj;
395
395
396 bail:
396 bail:
397 Py_XDECREF(obj);
397 Py_XDECREF(obj);
398 Py_XDECREF(t);
398 Py_XDECREF(t);
399 return NULL;
399 return NULL;
400 }
400 }
401
401
402 /*
402 /*
403 * When we cache a list, we want to be sure the caller can't mutate
403 * When we cache a list, we want to be sure the caller can't mutate
404 * the cached copy.
404 * the cached copy.
405 */
405 */
406 static PyObject *list_copy(PyObject *list)
406 static PyObject *list_copy(PyObject *list)
407 {
407 {
408 Py_ssize_t len = PyList_GET_SIZE(list);
408 Py_ssize_t len = PyList_GET_SIZE(list);
409 PyObject *newlist = PyList_New(len);
409 PyObject *newlist = PyList_New(len);
410 Py_ssize_t i;
410 Py_ssize_t i;
411
411
412 if (newlist == NULL)
412 if (newlist == NULL)
413 return NULL;
413 return NULL;
414
414
415 for (i = 0; i < len; i++) {
415 for (i = 0; i < len; i++) {
416 PyObject *obj = PyList_GET_ITEM(list, i);
416 PyObject *obj = PyList_GET_ITEM(list, i);
417 Py_INCREF(obj);
417 Py_INCREF(obj);
418 PyList_SET_ITEM(newlist, i, obj);
418 PyList_SET_ITEM(newlist, i, obj);
419 }
419 }
420
420
421 return newlist;
421 return newlist;
422 }
422 }
423
423
424 static int check_filter(PyObject *filter, Py_ssize_t arg)
424 static int check_filter(PyObject *filter, Py_ssize_t arg)
425 {
425 {
426 if (filter) {
426 if (filter) {
427 PyObject *arglist, *result;
427 PyObject *arglist, *result;
428 int isfiltered;
428 int isfiltered;
429
429
430 arglist = Py_BuildValue("(n)", arg);
430 arglist = Py_BuildValue("(n)", arg);
431 if (!arglist) {
431 if (!arglist) {
432 return -1;
432 return -1;
433 }
433 }
434
434
435 result = PyEval_CallObject(filter, arglist);
435 result = PyEval_CallObject(filter, arglist);
436 Py_DECREF(arglist);
436 Py_DECREF(arglist);
437 if (!result) {
437 if (!result) {
438 return -1;
438 return -1;
439 }
439 }
440
440
441 /* PyObject_IsTrue returns 1 if true, 0 if false, -1 if error,
441 /* PyObject_IsTrue returns 1 if true, 0 if false, -1 if error,
442 * same as this function, so we can just return it directly.*/
442 * same as this function, so we can just return it directly.*/
443 isfiltered = PyObject_IsTrue(result);
443 isfiltered = PyObject_IsTrue(result);
444 Py_DECREF(result);
444 Py_DECREF(result);
445 return isfiltered;
445 return isfiltered;
446 } else {
446 } else {
447 return 0;
447 return 0;
448 }
448 }
449 }
449 }
450
450
451 static Py_ssize_t add_roots_get_min(indexObject *self, PyObject *list,
451 static Py_ssize_t add_roots_get_min(indexObject *self, PyObject *list,
452 Py_ssize_t marker, char *phases)
452 Py_ssize_t marker, char *phases)
453 {
453 {
454 PyObject *iter = NULL;
454 PyObject *iter = NULL;
455 PyObject *iter_item = NULL;
455 PyObject *iter_item = NULL;
456 Py_ssize_t min_idx = index_length(self) + 1;
456 Py_ssize_t min_idx = index_length(self) + 1;
457 long iter_item_long;
457 long iter_item_long;
458
458
459 if (PyList_GET_SIZE(list) != 0) {
459 if (PyList_GET_SIZE(list) != 0) {
460 iter = PyObject_GetIter(list);
460 iter = PyObject_GetIter(list);
461 if (iter == NULL)
461 if (iter == NULL)
462 return -2;
462 return -2;
463 while ((iter_item = PyIter_Next(iter))) {
463 while ((iter_item = PyIter_Next(iter))) {
464 iter_item_long = PyInt_AS_LONG(iter_item);
464 iter_item_long = PyInt_AS_LONG(iter_item);
465 Py_DECREF(iter_item);
465 Py_DECREF(iter_item);
466 if (iter_item_long < min_idx)
466 if (iter_item_long < min_idx)
467 min_idx = iter_item_long;
467 min_idx = iter_item_long;
468 phases[iter_item_long] = marker;
468 phases[iter_item_long] = marker;
469 }
469 }
470 Py_DECREF(iter);
470 Py_DECREF(iter);
471 }
471 }
472
472
473 return min_idx;
473 return min_idx;
474 }
474 }
475
475
476 static inline void set_phase_from_parents(char *phases, int parent_1,
476 static inline void set_phase_from_parents(char *phases, int parent_1,
477 int parent_2, Py_ssize_t i)
477 int parent_2, Py_ssize_t i)
478 {
478 {
479 if (parent_1 >= 0 && phases[parent_1] > phases[i])
479 if (parent_1 >= 0 && phases[parent_1] > phases[i])
480 phases[i] = phases[parent_1];
480 phases[i] = phases[parent_1];
481 if (parent_2 >= 0 && phases[parent_2] > phases[i])
481 if (parent_2 >= 0 && phases[parent_2] > phases[i])
482 phases[i] = phases[parent_2];
482 phases[i] = phases[parent_2];
483 }
483 }
484
484
485 static PyObject *reachableroots2(indexObject *self, PyObject *args)
485 static PyObject *reachableroots2(indexObject *self, PyObject *args)
486 {
486 {
487
487
488 /* Input */
488 /* Input */
489 long minroot;
489 long minroot;
490 PyObject *includepatharg = NULL;
490 PyObject *includepatharg = NULL;
491 int includepath = 0;
491 int includepath = 0;
492 /* heads and roots are lists */
492 /* heads and roots are lists */
493 PyObject *heads = NULL;
493 PyObject *heads = NULL;
494 PyObject *roots = NULL;
494 PyObject *roots = NULL;
495 PyObject *reachable = NULL;
495 PyObject *reachable = NULL;
496
496
497 PyObject *val;
497 PyObject *val;
498 Py_ssize_t len = index_length(self) - 1;
498 Py_ssize_t len = index_length(self) - 1;
499 long revnum;
499 long revnum;
500 Py_ssize_t k;
500 Py_ssize_t k;
501 Py_ssize_t i;
501 Py_ssize_t i;
502 Py_ssize_t l;
502 Py_ssize_t l;
503 int r;
503 int r;
504 int parents[2];
504 int parents[2];
505
505
506 /* Internal data structure:
506 /* Internal data structure:
507 * tovisit: array of length len+1 (all revs + nullrev), filled upto lentovisit
507 * tovisit: array of length len+1 (all revs + nullrev), filled upto lentovisit
508 * revstates: array of length len+1 (all revs + nullrev) */
508 * revstates: array of length len+1 (all revs + nullrev) */
509 int *tovisit = NULL;
509 int *tovisit = NULL;
510 long lentovisit = 0;
510 long lentovisit = 0;
511 enum { RS_SEEN = 1, RS_ROOT = 2, RS_REACHABLE = 4 };
511 enum { RS_SEEN = 1, RS_ROOT = 2, RS_REACHABLE = 4 };
512 char *revstates = NULL;
512 char *revstates = NULL;
513
513
514 /* Get arguments */
514 /* Get arguments */
515 if (!PyArg_ParseTuple(args, "lO!O!O!", &minroot, &PyList_Type, &heads,
515 if (!PyArg_ParseTuple(args, "lO!O!O!", &minroot, &PyList_Type, &heads,
516 &PyList_Type, &roots,
516 &PyList_Type, &roots,
517 &PyBool_Type, &includepatharg))
517 &PyBool_Type, &includepatharg))
518 goto bail;
518 goto bail;
519
519
520 if (includepatharg == Py_True)
520 if (includepatharg == Py_True)
521 includepath = 1;
521 includepath = 1;
522
522
523 /* Initialize return set */
523 /* Initialize return set */
524 reachable = PyList_New(0);
524 reachable = PyList_New(0);
525 if (reachable == NULL)
525 if (reachable == NULL)
526 goto bail;
526 goto bail;
527
527
528 /* Initialize internal datastructures */
528 /* Initialize internal datastructures */
529 tovisit = (int *)malloc((len + 1) * sizeof(int));
529 tovisit = (int *)malloc((len + 1) * sizeof(int));
530 if (tovisit == NULL) {
530 if (tovisit == NULL) {
531 PyErr_NoMemory();
531 PyErr_NoMemory();
532 goto bail;
532 goto bail;
533 }
533 }
534
534
535 revstates = (char *)calloc(len + 1, 1);
535 revstates = (char *)calloc(len + 1, 1);
536 if (revstates == NULL) {
536 if (revstates == NULL) {
537 PyErr_NoMemory();
537 PyErr_NoMemory();
538 goto bail;
538 goto bail;
539 }
539 }
540
540
541 l = PyList_GET_SIZE(roots);
541 l = PyList_GET_SIZE(roots);
542 for (i = 0; i < l; i++) {
542 for (i = 0; i < l; i++) {
543 revnum = PyInt_AsLong(PyList_GET_ITEM(roots, i));
543 revnum = PyInt_AsLong(PyList_GET_ITEM(roots, i));
544 if (revnum == -1 && PyErr_Occurred())
544 if (revnum == -1 && PyErr_Occurred())
545 goto bail;
545 goto bail;
546 /* If root is out of range, e.g. wdir(), it must be unreachable
546 /* If root is out of range, e.g. wdir(), it must be unreachable
547 * from heads. So we can just ignore it. */
547 * from heads. So we can just ignore it. */
548 if (revnum + 1 < 0 || revnum + 1 >= len + 1)
548 if (revnum + 1 < 0 || revnum + 1 >= len + 1)
549 continue;
549 continue;
550 revstates[revnum + 1] |= RS_ROOT;
550 revstates[revnum + 1] |= RS_ROOT;
551 }
551 }
552
552
553 /* Populate tovisit with all the heads */
553 /* Populate tovisit with all the heads */
554 l = PyList_GET_SIZE(heads);
554 l = PyList_GET_SIZE(heads);
555 for (i = 0; i < l; i++) {
555 for (i = 0; i < l; i++) {
556 revnum = PyInt_AsLong(PyList_GET_ITEM(heads, i));
556 revnum = PyInt_AsLong(PyList_GET_ITEM(heads, i));
557 if (revnum == -1 && PyErr_Occurred())
557 if (revnum == -1 && PyErr_Occurred())
558 goto bail;
558 goto bail;
559 if (revnum + 1 < 0 || revnum + 1 >= len + 1) {
559 if (revnum + 1 < 0 || revnum + 1 >= len + 1) {
560 PyErr_SetString(PyExc_IndexError, "head out of range");
560 PyErr_SetString(PyExc_IndexError, "head out of range");
561 goto bail;
561 goto bail;
562 }
562 }
563 if (!(revstates[revnum + 1] & RS_SEEN)) {
563 if (!(revstates[revnum + 1] & RS_SEEN)) {
564 tovisit[lentovisit++] = (int)revnum;
564 tovisit[lentovisit++] = (int)revnum;
565 revstates[revnum + 1] |= RS_SEEN;
565 revstates[revnum + 1] |= RS_SEEN;
566 }
566 }
567 }
567 }
568
568
569 /* Visit the tovisit list and find the reachable roots */
569 /* Visit the tovisit list and find the reachable roots */
570 k = 0;
570 k = 0;
571 while (k < lentovisit) {
571 while (k < lentovisit) {
572 /* Add the node to reachable if it is a root*/
572 /* Add the node to reachable if it is a root*/
573 revnum = tovisit[k++];
573 revnum = tovisit[k++];
574 if (revstates[revnum + 1] & RS_ROOT) {
574 if (revstates[revnum + 1] & RS_ROOT) {
575 revstates[revnum + 1] |= RS_REACHABLE;
575 revstates[revnum + 1] |= RS_REACHABLE;
576 val = PyInt_FromLong(revnum);
576 val = PyInt_FromLong(revnum);
577 if (val == NULL)
577 if (val == NULL)
578 goto bail;
578 goto bail;
579 r = PyList_Append(reachable, val);
579 r = PyList_Append(reachable, val);
580 Py_DECREF(val);
580 Py_DECREF(val);
581 if (r < 0)
581 if (r < 0)
582 goto bail;
582 goto bail;
583 if (includepath == 0)
583 if (includepath == 0)
584 continue;
584 continue;
585 }
585 }
586
586
587 /* Add its parents to the list of nodes to visit */
587 /* Add its parents to the list of nodes to visit */
588 if (revnum == -1)
588 if (revnum == -1)
589 continue;
589 continue;
590 r = index_get_parents(self, revnum, parents, (int)len - 1);
590 r = index_get_parents(self, revnum, parents, (int)len - 1);
591 if (r < 0)
591 if (r < 0)
592 goto bail;
592 goto bail;
593 for (i = 0; i < 2; i++) {
593 for (i = 0; i < 2; i++) {
594 if (!(revstates[parents[i] + 1] & RS_SEEN)
594 if (!(revstates[parents[i] + 1] & RS_SEEN)
595 && parents[i] >= minroot) {
595 && parents[i] >= minroot) {
596 tovisit[lentovisit++] = parents[i];
596 tovisit[lentovisit++] = parents[i];
597 revstates[parents[i] + 1] |= RS_SEEN;
597 revstates[parents[i] + 1] |= RS_SEEN;
598 }
598 }
599 }
599 }
600 }
600 }
601
601
602 /* Find all the nodes in between the roots we found and the heads
602 /* Find all the nodes in between the roots we found and the heads
603 * and add them to the reachable set */
603 * and add them to the reachable set */
604 if (includepath == 1) {
604 if (includepath == 1) {
605 long minidx = minroot;
605 long minidx = minroot;
606 if (minidx < 0)
606 if (minidx < 0)
607 minidx = 0;
607 minidx = 0;
608 for (i = minidx; i < len; i++) {
608 for (i = minidx; i < len; i++) {
609 if (!(revstates[i + 1] & RS_SEEN))
609 if (!(revstates[i + 1] & RS_SEEN))
610 continue;
610 continue;
611 r = index_get_parents(self, i, parents, (int)len - 1);
611 r = index_get_parents(self, i, parents, (int)len - 1);
612 /* Corrupted index file, error is set from
612 /* Corrupted index file, error is set from
613 * index_get_parents */
613 * index_get_parents */
614 if (r < 0)
614 if (r < 0)
615 goto bail;
615 goto bail;
616 if (((revstates[parents[0] + 1] |
616 if (((revstates[parents[0] + 1] |
617 revstates[parents[1] + 1]) & RS_REACHABLE)
617 revstates[parents[1] + 1]) & RS_REACHABLE)
618 && !(revstates[i + 1] & RS_REACHABLE)) {
618 && !(revstates[i + 1] & RS_REACHABLE)) {
619 revstates[i + 1] |= RS_REACHABLE;
619 revstates[i + 1] |= RS_REACHABLE;
620 val = PyInt_FromLong(i);
620 val = PyInt_FromLong(i);
621 if (val == NULL)
621 if (val == NULL)
622 goto bail;
622 goto bail;
623 r = PyList_Append(reachable, val);
623 r = PyList_Append(reachable, val);
624 Py_DECREF(val);
624 Py_DECREF(val);
625 if (r < 0)
625 if (r < 0)
626 goto bail;
626 goto bail;
627 }
627 }
628 }
628 }
629 }
629 }
630
630
631 free(revstates);
631 free(revstates);
632 free(tovisit);
632 free(tovisit);
633 return reachable;
633 return reachable;
634 bail:
634 bail:
635 Py_XDECREF(reachable);
635 Py_XDECREF(reachable);
636 free(revstates);
636 free(revstates);
637 free(tovisit);
637 free(tovisit);
638 return NULL;
638 return NULL;
639 }
639 }
640
640
641 static PyObject *compute_phases_map_sets(indexObject *self, PyObject *args)
641 static PyObject *compute_phases_map_sets(indexObject *self, PyObject *args)
642 {
642 {
643 PyObject *roots = Py_None;
643 PyObject *roots = Py_None;
644 PyObject *ret = NULL;
644 PyObject *ret = NULL;
645 PyObject *phasessize = NULL;
645 PyObject *phasessize = NULL;
646 PyObject *phaseroots = NULL;
646 PyObject *phaseroots = NULL;
647 PyObject *phaseset = NULL;
647 PyObject *phaseset = NULL;
648 PyObject *phasessetlist = NULL;
648 PyObject *phasessetlist = NULL;
649 PyObject *rev = NULL;
649 PyObject *rev = NULL;
650 Py_ssize_t len = index_length(self) - 1;
650 Py_ssize_t len = index_length(self) - 1;
651 Py_ssize_t numphase = 0;
651 Py_ssize_t numphase = 0;
652 Py_ssize_t minrevallphases = 0;
652 Py_ssize_t minrevallphases = 0;
653 Py_ssize_t minrevphase = 0;
653 Py_ssize_t minrevphase = 0;
654 Py_ssize_t i = 0;
654 Py_ssize_t i = 0;
655 char *phases = NULL;
655 char *phases = NULL;
656 long phase;
656 long phase;
657
657
658 if (!PyArg_ParseTuple(args, "O", &roots))
658 if (!PyArg_ParseTuple(args, "O", &roots))
659 goto done;
659 goto done;
660 if (roots == NULL || !PyList_Check(roots)) {
660 if (roots == NULL || !PyList_Check(roots)) {
661 PyErr_SetString(PyExc_TypeError, "roots must be a list");
661 PyErr_SetString(PyExc_TypeError, "roots must be a list");
662 goto done;
662 goto done;
663 }
663 }
664
664
665 phases = calloc(len, 1); /* phase per rev: {0: public, 1: draft, 2: secret} */
665 phases = calloc(len, 1); /* phase per rev: {0: public, 1: draft, 2: secret} */
666 if (phases == NULL) {
666 if (phases == NULL) {
667 PyErr_NoMemory();
667 PyErr_NoMemory();
668 goto done;
668 goto done;
669 }
669 }
670 /* Put the phase information of all the roots in phases */
670 /* Put the phase information of all the roots in phases */
671 numphase = PyList_GET_SIZE(roots)+1;
671 numphase = PyList_GET_SIZE(roots)+1;
672 minrevallphases = len + 1;
672 minrevallphases = len + 1;
673 phasessetlist = PyList_New(numphase);
673 phasessetlist = PyList_New(numphase);
674 if (phasessetlist == NULL)
674 if (phasessetlist == NULL)
675 goto done;
675 goto done;
676
676
677 PyList_SET_ITEM(phasessetlist, 0, Py_None);
677 PyList_SET_ITEM(phasessetlist, 0, Py_None);
678 Py_INCREF(Py_None);
678 Py_INCREF(Py_None);
679
679
680 for (i = 0; i < numphase-1; i++) {
680 for (i = 0; i < numphase-1; i++) {
681 phaseroots = PyList_GET_ITEM(roots, i);
681 phaseroots = PyList_GET_ITEM(roots, i);
682 phaseset = PySet_New(NULL);
682 phaseset = PySet_New(NULL);
683 if (phaseset == NULL)
683 if (phaseset == NULL)
684 goto release;
684 goto release;
685 PyList_SET_ITEM(phasessetlist, i+1, phaseset);
685 PyList_SET_ITEM(phasessetlist, i+1, phaseset);
686 if (!PyList_Check(phaseroots)) {
686 if (!PyList_Check(phaseroots)) {
687 PyErr_SetString(PyExc_TypeError,
687 PyErr_SetString(PyExc_TypeError,
688 "roots item must be a list");
688 "roots item must be a list");
689 goto release;
689 goto release;
690 }
690 }
691 minrevphase = add_roots_get_min(self, phaseroots, i+1, phases);
691 minrevphase = add_roots_get_min(self, phaseroots, i+1, phases);
692 if (minrevphase == -2) /* Error from add_roots_get_min */
692 if (minrevphase == -2) /* Error from add_roots_get_min */
693 goto release;
693 goto release;
694 minrevallphases = MIN(minrevallphases, minrevphase);
694 minrevallphases = MIN(minrevallphases, minrevphase);
695 }
695 }
696 /* Propagate the phase information from the roots to the revs */
696 /* Propagate the phase information from the roots to the revs */
697 if (minrevallphases != -1) {
697 if (minrevallphases != -1) {
698 int parents[2];
698 int parents[2];
699 for (i = minrevallphases; i < len; i++) {
699 for (i = minrevallphases; i < len; i++) {
700 if (index_get_parents(self, i, parents,
700 if (index_get_parents(self, i, parents,
701 (int)len - 1) < 0)
701 (int)len - 1) < 0)
702 goto release;
702 goto release;
703 set_phase_from_parents(phases, parents[0], parents[1], i);
703 set_phase_from_parents(phases, parents[0], parents[1], i);
704 }
704 }
705 }
705 }
706 /* Transform phase list to a python list */
706 /* Transform phase list to a python list */
707 phasessize = PyInt_FromLong(len);
707 phasessize = PyInt_FromLong(len);
708 if (phasessize == NULL)
708 if (phasessize == NULL)
709 goto release;
709 goto release;
710 for (i = 0; i < len; i++) {
710 for (i = 0; i < len; i++) {
711 phase = phases[i];
711 phase = phases[i];
712 /* We only store the sets of phase for non public phase, the public phase
712 /* We only store the sets of phase for non public phase, the public phase
713 * is computed as a difference */
713 * is computed as a difference */
714 if (phase != 0) {
714 if (phase != 0) {
715 phaseset = PyList_GET_ITEM(phasessetlist, phase);
715 phaseset = PyList_GET_ITEM(phasessetlist, phase);
716 rev = PyInt_FromLong(i);
716 rev = PyInt_FromLong(i);
717 if (rev == NULL)
717 if (rev == NULL)
718 goto release;
718 goto release;
719 PySet_Add(phaseset, rev);
719 PySet_Add(phaseset, rev);
720 Py_XDECREF(rev);
720 Py_XDECREF(rev);
721 }
721 }
722 }
722 }
723 ret = PyTuple_Pack(2, phasessize, phasessetlist);
723 ret = PyTuple_Pack(2, phasessize, phasessetlist);
724
724
725 release:
725 release:
726 Py_XDECREF(phasessize);
726 Py_XDECREF(phasessize);
727 Py_XDECREF(phasessetlist);
727 Py_XDECREF(phasessetlist);
728 done:
728 done:
729 free(phases);
729 free(phases);
730 return ret;
730 return ret;
731 }
731 }
732
732
733 static PyObject *index_headrevs(indexObject *self, PyObject *args)
733 static PyObject *index_headrevs(indexObject *self, PyObject *args)
734 {
734 {
735 Py_ssize_t i, j, len;
735 Py_ssize_t i, j, len;
736 char *nothead = NULL;
736 char *nothead = NULL;
737 PyObject *heads = NULL;
737 PyObject *heads = NULL;
738 PyObject *filter = NULL;
738 PyObject *filter = NULL;
739 PyObject *filteredrevs = Py_None;
739 PyObject *filteredrevs = Py_None;
740
740
741 if (!PyArg_ParseTuple(args, "|O", &filteredrevs)) {
741 if (!PyArg_ParseTuple(args, "|O", &filteredrevs)) {
742 return NULL;
742 return NULL;
743 }
743 }
744
744
745 if (self->headrevs && filteredrevs == self->filteredrevs)
745 if (self->headrevs && filteredrevs == self->filteredrevs)
746 return list_copy(self->headrevs);
746 return list_copy(self->headrevs);
747
747
748 Py_DECREF(self->filteredrevs);
748 Py_DECREF(self->filteredrevs);
749 self->filteredrevs = filteredrevs;
749 self->filteredrevs = filteredrevs;
750 Py_INCREF(filteredrevs);
750 Py_INCREF(filteredrevs);
751
751
752 if (filteredrevs != Py_None) {
752 if (filteredrevs != Py_None) {
753 filter = PyObject_GetAttrString(filteredrevs, "__contains__");
753 filter = PyObject_GetAttrString(filteredrevs, "__contains__");
754 if (!filter) {
754 if (!filter) {
755 PyErr_SetString(PyExc_TypeError,
755 PyErr_SetString(PyExc_TypeError,
756 "filteredrevs has no attribute __contains__");
756 "filteredrevs has no attribute __contains__");
757 goto bail;
757 goto bail;
758 }
758 }
759 }
759 }
760
760
761 len = index_length(self) - 1;
761 len = index_length(self) - 1;
762 heads = PyList_New(0);
762 heads = PyList_New(0);
763 if (heads == NULL)
763 if (heads == NULL)
764 goto bail;
764 goto bail;
765 if (len == 0) {
765 if (len == 0) {
766 PyObject *nullid = PyInt_FromLong(-1);
766 PyObject *nullid = PyInt_FromLong(-1);
767 if (nullid == NULL || PyList_Append(heads, nullid) == -1) {
767 if (nullid == NULL || PyList_Append(heads, nullid) == -1) {
768 Py_XDECREF(nullid);
768 Py_XDECREF(nullid);
769 goto bail;
769 goto bail;
770 }
770 }
771 goto done;
771 goto done;
772 }
772 }
773
773
774 nothead = calloc(len, 1);
774 nothead = calloc(len, 1);
775 if (nothead == NULL) {
775 if (nothead == NULL) {
776 PyErr_NoMemory();
776 PyErr_NoMemory();
777 goto bail;
777 goto bail;
778 }
778 }
779
779
780 for (i = len - 1; i >= 0; i--) {
780 for (i = len - 1; i >= 0; i--) {
781 int isfiltered;
781 int isfiltered;
782 int parents[2];
782 int parents[2];
783
783
784 /* If nothead[i] == 1, it means we've seen an unfiltered child of this
784 /* If nothead[i] == 1, it means we've seen an unfiltered child of this
785 * node already, and therefore this node is not filtered. So we can skip
785 * node already, and therefore this node is not filtered. So we can skip
786 * the expensive check_filter step.
786 * the expensive check_filter step.
787 */
787 */
788 if (nothead[i] != 1) {
788 if (nothead[i] != 1) {
789 isfiltered = check_filter(filter, i);
789 isfiltered = check_filter(filter, i);
790 if (isfiltered == -1) {
790 if (isfiltered == -1) {
791 PyErr_SetString(PyExc_TypeError,
791 PyErr_SetString(PyExc_TypeError,
792 "unable to check filter");
792 "unable to check filter");
793 goto bail;
793 goto bail;
794 }
794 }
795
795
796 if (isfiltered) {
796 if (isfiltered) {
797 nothead[i] = 1;
797 nothead[i] = 1;
798 continue;
798 continue;
799 }
799 }
800 }
800 }
801
801
802 if (index_get_parents(self, i, parents, (int)len - 1) < 0)
802 if (index_get_parents(self, i, parents, (int)len - 1) < 0)
803 goto bail;
803 goto bail;
804 for (j = 0; j < 2; j++) {
804 for (j = 0; j < 2; j++) {
805 if (parents[j] >= 0)
805 if (parents[j] >= 0)
806 nothead[parents[j]] = 1;
806 nothead[parents[j]] = 1;
807 }
807 }
808 }
808 }
809
809
810 for (i = 0; i < len; i++) {
810 for (i = 0; i < len; i++) {
811 PyObject *head;
811 PyObject *head;
812
812
813 if (nothead[i])
813 if (nothead[i])
814 continue;
814 continue;
815 head = PyInt_FromSsize_t(i);
815 head = PyInt_FromSsize_t(i);
816 if (head == NULL || PyList_Append(heads, head) == -1) {
816 if (head == NULL || PyList_Append(heads, head) == -1) {
817 Py_XDECREF(head);
817 Py_XDECREF(head);
818 goto bail;
818 goto bail;
819 }
819 }
820 }
820 }
821
821
822 done:
822 done:
823 self->headrevs = heads;
823 self->headrevs = heads;
824 Py_XDECREF(filter);
824 Py_XDECREF(filter);
825 free(nothead);
825 free(nothead);
826 return list_copy(self->headrevs);
826 return list_copy(self->headrevs);
827 bail:
827 bail:
828 Py_XDECREF(filter);
828 Py_XDECREF(filter);
829 Py_XDECREF(heads);
829 Py_XDECREF(heads);
830 free(nothead);
830 free(nothead);
831 return NULL;
831 return NULL;
832 }
832 }
833
833
834 /**
834 /**
835 * Obtain the base revision index entry.
835 * Obtain the base revision index entry.
836 *
836 *
837 * Callers must ensure that rev >= 0 or illegal memory access may occur.
837 * Callers must ensure that rev >= 0 or illegal memory access may occur.
838 */
838 */
839 static inline int index_baserev(indexObject *self, int rev)
839 static inline int index_baserev(indexObject *self, int rev)
840 {
840 {
841 const char *data;
841 const char *data;
842
842
843 if (rev >= self->length - 1) {
843 if (rev >= self->length - 1) {
844 PyObject *tuple = PyList_GET_ITEM(self->added,
844 PyObject *tuple = PyList_GET_ITEM(self->added,
845 rev - self->length + 1);
845 rev - self->length + 1);
846 return (int)PyInt_AS_LONG(PyTuple_GET_ITEM(tuple, 3));
846 return (int)PyInt_AS_LONG(PyTuple_GET_ITEM(tuple, 3));
847 }
847 }
848 else {
848 else {
849 data = index_deref(self, rev);
849 data = index_deref(self, rev);
850 if (data == NULL) {
850 if (data == NULL) {
851 return -2;
851 return -2;
852 }
852 }
853
853
854 return getbe32(data + 16);
854 return getbe32(data + 16);
855 }
855 }
856 }
856 }
857
857
858 static PyObject *index_deltachain(indexObject *self, PyObject *args)
858 static PyObject *index_deltachain(indexObject *self, PyObject *args)
859 {
859 {
860 int rev, generaldelta;
860 int rev, generaldelta;
861 PyObject *stoparg;
861 PyObject *stoparg;
862 int stoprev, iterrev, baserev = -1;
862 int stoprev, iterrev, baserev = -1;
863 int stopped;
863 int stopped;
864 PyObject *chain = NULL, *result = NULL;
864 PyObject *chain = NULL, *result = NULL;
865 const Py_ssize_t length = index_length(self);
865 const Py_ssize_t length = index_length(self);
866
866
867 if (!PyArg_ParseTuple(args, "iOi", &rev, &stoparg, &generaldelta)) {
867 if (!PyArg_ParseTuple(args, "iOi", &rev, &stoparg, &generaldelta)) {
868 return NULL;
868 return NULL;
869 }
869 }
870
870
871 if (PyInt_Check(stoparg)) {
871 if (PyInt_Check(stoparg)) {
872 stoprev = (int)PyInt_AsLong(stoparg);
872 stoprev = (int)PyInt_AsLong(stoparg);
873 if (stoprev == -1 && PyErr_Occurred()) {
873 if (stoprev == -1 && PyErr_Occurred()) {
874 return NULL;
874 return NULL;
875 }
875 }
876 }
876 }
877 else if (stoparg == Py_None) {
877 else if (stoparg == Py_None) {
878 stoprev = -2;
878 stoprev = -2;
879 }
879 }
880 else {
880 else {
881 PyErr_SetString(PyExc_ValueError,
881 PyErr_SetString(PyExc_ValueError,
882 "stoprev must be integer or None");
882 "stoprev must be integer or None");
883 return NULL;
883 return NULL;
884 }
884 }
885
885
886 if (rev < 0 || rev >= length - 1) {
886 if (rev < 0 || rev >= length - 1) {
887 PyErr_SetString(PyExc_ValueError, "revlog index out of range");
887 PyErr_SetString(PyExc_ValueError, "revlog index out of range");
888 return NULL;
888 return NULL;
889 }
889 }
890
890
891 chain = PyList_New(0);
891 chain = PyList_New(0);
892 if (chain == NULL) {
892 if (chain == NULL) {
893 return NULL;
893 return NULL;
894 }
894 }
895
895
896 baserev = index_baserev(self, rev);
896 baserev = index_baserev(self, rev);
897
897
898 /* This should never happen. */
898 /* This should never happen. */
899 if (baserev <= -2) {
899 if (baserev <= -2) {
900 /* Error should be set by index_deref() */
900 /* Error should be set by index_deref() */
901 assert(PyErr_Occurred());
901 assert(PyErr_Occurred());
902 goto bail;
902 goto bail;
903 }
903 }
904
904
905 iterrev = rev;
905 iterrev = rev;
906
906
907 while (iterrev != baserev && iterrev != stoprev) {
907 while (iterrev != baserev && iterrev != stoprev) {
908 PyObject *value = PyInt_FromLong(iterrev);
908 PyObject *value = PyInt_FromLong(iterrev);
909 if (value == NULL) {
909 if (value == NULL) {
910 goto bail;
910 goto bail;
911 }
911 }
912 if (PyList_Append(chain, value)) {
912 if (PyList_Append(chain, value)) {
913 Py_DECREF(value);
913 Py_DECREF(value);
914 goto bail;
914 goto bail;
915 }
915 }
916 Py_DECREF(value);
916 Py_DECREF(value);
917
917
918 if (generaldelta) {
918 if (generaldelta) {
919 iterrev = baserev;
919 iterrev = baserev;
920 }
920 }
921 else {
921 else {
922 iterrev--;
922 iterrev--;
923 }
923 }
924
924
925 if (iterrev < 0) {
925 if (iterrev < 0) {
926 break;
926 break;
927 }
927 }
928
928
929 if (iterrev >= length - 1) {
929 if (iterrev >= length - 1) {
930 PyErr_SetString(PyExc_IndexError, "revision outside index");
930 PyErr_SetString(PyExc_IndexError, "revision outside index");
931 return NULL;
931 return NULL;
932 }
932 }
933
933
934 baserev = index_baserev(self, iterrev);
934 baserev = index_baserev(self, iterrev);
935
935
936 /* This should never happen. */
936 /* This should never happen. */
937 if (baserev <= -2) {
937 if (baserev <= -2) {
938 /* Error should be set by index_deref() */
938 /* Error should be set by index_deref() */
939 assert(PyErr_Occurred());
939 assert(PyErr_Occurred());
940 goto bail;
940 goto bail;
941 }
941 }
942 }
942 }
943
943
944 if (iterrev == stoprev) {
944 if (iterrev == stoprev) {
945 stopped = 1;
945 stopped = 1;
946 }
946 }
947 else {
947 else {
948 PyObject *value = PyInt_FromLong(iterrev);
948 PyObject *value = PyInt_FromLong(iterrev);
949 if (value == NULL) {
949 if (value == NULL) {
950 goto bail;
950 goto bail;
951 }
951 }
952 if (PyList_Append(chain, value)) {
952 if (PyList_Append(chain, value)) {
953 Py_DECREF(value);
953 Py_DECREF(value);
954 goto bail;
954 goto bail;
955 }
955 }
956 Py_DECREF(value);
956 Py_DECREF(value);
957
957
958 stopped = 0;
958 stopped = 0;
959 }
959 }
960
960
961 if (PyList_Reverse(chain)) {
961 if (PyList_Reverse(chain)) {
962 goto bail;
962 goto bail;
963 }
963 }
964
964
965 result = Py_BuildValue("OO", chain, stopped ? Py_True : Py_False);
965 result = Py_BuildValue("OO", chain, stopped ? Py_True : Py_False);
966 Py_DECREF(chain);
966 Py_DECREF(chain);
967 return result;
967 return result;
968
968
969 bail:
969 bail:
970 Py_DECREF(chain);
970 Py_DECREF(chain);
971 return NULL;
971 return NULL;
972 }
972 }
973
973
974 static inline int nt_level(const char *node, Py_ssize_t level)
974 static inline int nt_level(const char *node, Py_ssize_t level)
975 {
975 {
976 int v = node[level>>1];
976 int v = node[level>>1];
977 if (!(level & 1))
977 if (!(level & 1))
978 v >>= 4;
978 v >>= 4;
979 return v & 0xf;
979 return v & 0xf;
980 }
980 }
981
981
982 /*
982 /*
983 * Return values:
983 * Return values:
984 *
984 *
985 * -4: match is ambiguous (multiple candidates)
985 * -4: match is ambiguous (multiple candidates)
986 * -2: not found
986 * -2: not found
987 * rest: valid rev
987 * rest: valid rev
988 */
988 */
989 static int nt_find(indexObject *self, const char *node, Py_ssize_t nodelen,
989 static int nt_find(indexObject *self, const char *node, Py_ssize_t nodelen,
990 int hex)
990 int hex)
991 {
991 {
992 int (*getnybble)(const char *, Py_ssize_t) = hex ? hexdigit : nt_level;
992 int (*getnybble)(const char *, Py_ssize_t) = hex ? hexdigit : nt_level;
993 int level, maxlevel, off;
993 int level, maxlevel, off;
994
994
995 if (nodelen == 20 && node[0] == '\0' && memcmp(node, nullid, 20) == 0)
995 if (nodelen == 20 && node[0] == '\0' && memcmp(node, nullid, 20) == 0)
996 return -1;
996 return -1;
997
997
998 if (self->nt == NULL)
998 if (self->nt == NULL)
999 return -2;
999 return -2;
1000
1000
1001 if (hex)
1001 if (hex)
1002 maxlevel = nodelen > 40 ? 40 : (int)nodelen;
1002 maxlevel = nodelen > 40 ? 40 : (int)nodelen;
1003 else
1003 else
1004 maxlevel = nodelen > 20 ? 40 : ((int)nodelen * 2);
1004 maxlevel = nodelen > 20 ? 40 : ((int)nodelen * 2);
1005
1005
1006 for (level = off = 0; level < maxlevel; level++) {
1006 for (level = off = 0; level < maxlevel; level++) {
1007 int k = getnybble(node, level);
1007 int k = getnybble(node, level);
1008 nodetree *n = &self->nt[off];
1008 nodetree *n = &self->nt[off];
1009 int v = n->children[k];
1009 int v = n->children[k];
1010
1010
1011 if (v < 0) {
1011 if (v < 0) {
1012 const char *n;
1012 const char *n;
1013 Py_ssize_t i;
1013 Py_ssize_t i;
1014
1014
1015 v = -(v + 1);
1015 v = -(v + 1);
1016 n = index_node(self, v);
1016 n = index_node(self, v);
1017 if (n == NULL)
1017 if (n == NULL)
1018 return -2;
1018 return -2;
1019 for (i = level; i < maxlevel; i++)
1019 for (i = level; i < maxlevel; i++)
1020 if (getnybble(node, i) != nt_level(n, i))
1020 if (getnybble(node, i) != nt_level(n, i))
1021 return -2;
1021 return -2;
1022 return v;
1022 return v;
1023 }
1023 }
1024 if (v == 0)
1024 if (v == 0)
1025 return -2;
1025 return -2;
1026 off = v;
1026 off = v;
1027 }
1027 }
1028 /* multiple matches against an ambiguous prefix */
1028 /* multiple matches against an ambiguous prefix */
1029 return -4;
1029 return -4;
1030 }
1030 }
1031
1031
1032 static int nt_new(indexObject *self)
1032 static int nt_new(indexObject *self)
1033 {
1033 {
1034 if (self->ntlength == self->ntcapacity) {
1034 if (self->ntlength == self->ntcapacity) {
1035 if (self->ntcapacity >= INT_MAX / (sizeof(nodetree) * 2)) {
1035 if (self->ntcapacity >= INT_MAX / (sizeof(nodetree) * 2)) {
1036 PyErr_SetString(PyExc_MemoryError,
1036 PyErr_SetString(PyExc_MemoryError,
1037 "overflow in nt_new");
1037 "overflow in nt_new");
1038 return -1;
1038 return -1;
1039 }
1039 }
1040 self->ntcapacity *= 2;
1040 self->ntcapacity *= 2;
1041 self->nt = realloc(self->nt,
1041 self->nt = realloc(self->nt,
1042 self->ntcapacity * sizeof(nodetree));
1042 self->ntcapacity * sizeof(nodetree));
1043 if (self->nt == NULL) {
1043 if (self->nt == NULL) {
1044 PyErr_SetString(PyExc_MemoryError, "out of memory");
1044 PyErr_SetString(PyExc_MemoryError, "out of memory");
1045 return -1;
1045 return -1;
1046 }
1046 }
1047 memset(&self->nt[self->ntlength], 0,
1047 memset(&self->nt[self->ntlength], 0,
1048 sizeof(nodetree) * (self->ntcapacity - self->ntlength));
1048 sizeof(nodetree) * (self->ntcapacity - self->ntlength));
1049 }
1049 }
1050 return self->ntlength++;
1050 return self->ntlength++;
1051 }
1051 }
1052
1052
1053 static int nt_insert(indexObject *self, const char *node, int rev)
1053 static int nt_insert(indexObject *self, const char *node, int rev)
1054 {
1054 {
1055 int level = 0;
1055 int level = 0;
1056 int off = 0;
1056 int off = 0;
1057
1057
1058 while (level < 40) {
1058 while (level < 40) {
1059 int k = nt_level(node, level);
1059 int k = nt_level(node, level);
1060 nodetree *n;
1060 nodetree *n;
1061 int v;
1061 int v;
1062
1062
1063 n = &self->nt[off];
1063 n = &self->nt[off];
1064 v = n->children[k];
1064 v = n->children[k];
1065
1065
1066 if (v == 0) {
1066 if (v == 0) {
1067 n->children[k] = -rev - 1;
1067 n->children[k] = -rev - 1;
1068 return 0;
1068 return 0;
1069 }
1069 }
1070 if (v < 0) {
1070 if (v < 0) {
1071 const char *oldnode = index_node(self, -(v + 1));
1071 const char *oldnode = index_node(self, -(v + 1));
1072 int noff;
1072 int noff;
1073
1073
1074 if (!oldnode || !memcmp(oldnode, node, 20)) {
1074 if (!oldnode || !memcmp(oldnode, node, 20)) {
1075 n->children[k] = -rev - 1;
1075 n->children[k] = -rev - 1;
1076 return 0;
1076 return 0;
1077 }
1077 }
1078 noff = nt_new(self);
1078 noff = nt_new(self);
1079 if (noff == -1)
1079 if (noff == -1)
1080 return -1;
1080 return -1;
1081 /* self->nt may have been changed by realloc */
1081 /* self->nt may have been changed by realloc */
1082 self->nt[off].children[k] = noff;
1082 self->nt[off].children[k] = noff;
1083 off = noff;
1083 off = noff;
1084 n = &self->nt[off];
1084 n = &self->nt[off];
1085 n->children[nt_level(oldnode, ++level)] = v;
1085 n->children[nt_level(oldnode, ++level)] = v;
1086 if (level > self->ntdepth)
1086 if (level > self->ntdepth)
1087 self->ntdepth = level;
1087 self->ntdepth = level;
1088 self->ntsplits += 1;
1088 self->ntsplits += 1;
1089 } else {
1089 } else {
1090 level += 1;
1090 level += 1;
1091 off = v;
1091 off = v;
1092 }
1092 }
1093 }
1093 }
1094
1094
1095 return -1;
1095 return -1;
1096 }
1096 }
1097
1097
1098 static int nt_init(indexObject *self)
1098 static int nt_init(indexObject *self)
1099 {
1099 {
1100 if (self->nt == NULL) {
1100 if (self->nt == NULL) {
1101 if ((size_t)self->raw_length > INT_MAX / sizeof(nodetree)) {
1101 if ((size_t)self->raw_length > INT_MAX / sizeof(nodetree)) {
1102 PyErr_SetString(PyExc_ValueError, "overflow in nt_init");
1102 PyErr_SetString(PyExc_ValueError, "overflow in nt_init");
1103 return -1;
1103 return -1;
1104 }
1104 }
1105 self->ntcapacity = self->raw_length < 4
1105 self->ntcapacity = self->raw_length < 4
1106 ? 4 : (int)self->raw_length / 2;
1106 ? 4 : (int)self->raw_length / 2;
1107
1107
1108 self->nt = calloc(self->ntcapacity, sizeof(nodetree));
1108 self->nt = calloc(self->ntcapacity, sizeof(nodetree));
1109 if (self->nt == NULL) {
1109 if (self->nt == NULL) {
1110 PyErr_NoMemory();
1110 PyErr_NoMemory();
1111 return -1;
1111 return -1;
1112 }
1112 }
1113 self->ntlength = 1;
1113 self->ntlength = 1;
1114 self->ntrev = (int)index_length(self) - 1;
1114 self->ntrev = (int)index_length(self) - 1;
1115 self->ntlookups = 1;
1115 self->ntlookups = 1;
1116 self->ntmisses = 0;
1116 self->ntmisses = 0;
1117 if (nt_insert(self, nullid, INT_MAX) == -1)
1117 if (nt_insert(self, nullid, INT_MAX) == -1)
1118 return -1;
1118 return -1;
1119 }
1119 }
1120 return 0;
1120 return 0;
1121 }
1121 }
1122
1122
1123 /*
1123 /*
1124 * Return values:
1124 * Return values:
1125 *
1125 *
1126 * -3: error (exception set)
1126 * -3: error (exception set)
1127 * -2: not found (no exception set)
1127 * -2: not found (no exception set)
1128 * rest: valid rev
1128 * rest: valid rev
1129 */
1129 */
1130 static int index_find_node(indexObject *self,
1130 static int index_find_node(indexObject *self,
1131 const char *node, Py_ssize_t nodelen)
1131 const char *node, Py_ssize_t nodelen)
1132 {
1132 {
1133 int rev;
1133 int rev;
1134
1134
1135 self->ntlookups++;
1135 self->ntlookups++;
1136 rev = nt_find(self, node, nodelen, 0);
1136 rev = nt_find(self, node, nodelen, 0);
1137 if (rev >= -1)
1137 if (rev >= -1)
1138 return rev;
1138 return rev;
1139
1139
1140 if (nt_init(self) == -1)
1140 if (nt_init(self) == -1)
1141 return -3;
1141 return -3;
1142
1142
1143 /*
1143 /*
1144 * For the first handful of lookups, we scan the entire index,
1144 * For the first handful of lookups, we scan the entire index,
1145 * and cache only the matching nodes. This optimizes for cases
1145 * and cache only the matching nodes. This optimizes for cases
1146 * like "hg tip", where only a few nodes are accessed.
1146 * like "hg tip", where only a few nodes are accessed.
1147 *
1147 *
1148 * After that, we cache every node we visit, using a single
1148 * After that, we cache every node we visit, using a single
1149 * scan amortized over multiple lookups. This gives the best
1149 * scan amortized over multiple lookups. This gives the best
1150 * bulk performance, e.g. for "hg log".
1150 * bulk performance, e.g. for "hg log".
1151 */
1151 */
1152 if (self->ntmisses++ < 4) {
1152 if (self->ntmisses++ < 4) {
1153 for (rev = self->ntrev - 1; rev >= 0; rev--) {
1153 for (rev = self->ntrev - 1; rev >= 0; rev--) {
1154 const char *n = index_node(self, rev);
1154 const char *n = index_node_existing(self, rev);
1155 if (n == NULL)
1155 if (n == NULL)
1156 return -2;
1156 return -3;
1157 if (memcmp(node, n, nodelen > 20 ? 20 : nodelen) == 0) {
1157 if (memcmp(node, n, nodelen > 20 ? 20 : nodelen) == 0) {
1158 if (nt_insert(self, n, rev) == -1)
1158 if (nt_insert(self, n, rev) == -1)
1159 return -3;
1159 return -3;
1160 break;
1160 break;
1161 }
1161 }
1162 }
1162 }
1163 } else {
1163 } else {
1164 for (rev = self->ntrev - 1; rev >= 0; rev--) {
1164 for (rev = self->ntrev - 1; rev >= 0; rev--) {
1165 const char *n = index_node(self, rev);
1165 const char *n = index_node_existing(self, rev);
1166 if (n == NULL) {
1166 if (n == NULL)
1167 self->ntrev = rev + 1;
1167 return -3;
1168 return -2;
1169 }
1170 if (nt_insert(self, n, rev) == -1) {
1168 if (nt_insert(self, n, rev) == -1) {
1171 self->ntrev = rev + 1;
1169 self->ntrev = rev + 1;
1172 return -3;
1170 return -3;
1173 }
1171 }
1174 if (memcmp(node, n, nodelen > 20 ? 20 : nodelen) == 0) {
1172 if (memcmp(node, n, nodelen > 20 ? 20 : nodelen) == 0) {
1175 break;
1173 break;
1176 }
1174 }
1177 }
1175 }
1178 self->ntrev = rev;
1176 self->ntrev = rev;
1179 }
1177 }
1180
1178
1181 if (rev >= 0)
1179 if (rev >= 0)
1182 return rev;
1180 return rev;
1183 return -2;
1181 return -2;
1184 }
1182 }
1185
1183
1186 static void raise_revlog_error(void)
1184 static void raise_revlog_error(void)
1187 {
1185 {
1188 PyObject *mod = NULL, *dict = NULL, *errclass = NULL;
1186 PyObject *mod = NULL, *dict = NULL, *errclass = NULL;
1189
1187
1190 mod = PyImport_ImportModule("mercurial.error");
1188 mod = PyImport_ImportModule("mercurial.error");
1191 if (mod == NULL) {
1189 if (mod == NULL) {
1192 goto cleanup;
1190 goto cleanup;
1193 }
1191 }
1194
1192
1195 dict = PyModule_GetDict(mod);
1193 dict = PyModule_GetDict(mod);
1196 if (dict == NULL) {
1194 if (dict == NULL) {
1197 goto cleanup;
1195 goto cleanup;
1198 }
1196 }
1199 Py_INCREF(dict);
1197 Py_INCREF(dict);
1200
1198
1201 errclass = PyDict_GetItemString(dict, "RevlogError");
1199 errclass = PyDict_GetItemString(dict, "RevlogError");
1202 if (errclass == NULL) {
1200 if (errclass == NULL) {
1203 PyErr_SetString(PyExc_SystemError,
1201 PyErr_SetString(PyExc_SystemError,
1204 "could not find RevlogError");
1202 "could not find RevlogError");
1205 goto cleanup;
1203 goto cleanup;
1206 }
1204 }
1207
1205
1208 /* value of exception is ignored by callers */
1206 /* value of exception is ignored by callers */
1209 PyErr_SetString(errclass, "RevlogError");
1207 PyErr_SetString(errclass, "RevlogError");
1210
1208
1211 cleanup:
1209 cleanup:
1212 Py_XDECREF(dict);
1210 Py_XDECREF(dict);
1213 Py_XDECREF(mod);
1211 Py_XDECREF(mod);
1214 }
1212 }
1215
1213
1216 static PyObject *index_getitem(indexObject *self, PyObject *value)
1214 static PyObject *index_getitem(indexObject *self, PyObject *value)
1217 {
1215 {
1218 char *node;
1216 char *node;
1219 Py_ssize_t nodelen;
1217 Py_ssize_t nodelen;
1220 int rev;
1218 int rev;
1221
1219
1222 if (PyInt_Check(value))
1220 if (PyInt_Check(value))
1223 return index_get(self, PyInt_AS_LONG(value));
1221 return index_get(self, PyInt_AS_LONG(value));
1224
1222
1225 if (node_check(value, &node, &nodelen) == -1)
1223 if (node_check(value, &node, &nodelen) == -1)
1226 return NULL;
1224 return NULL;
1227 rev = index_find_node(self, node, nodelen);
1225 rev = index_find_node(self, node, nodelen);
1228 if (rev >= -1)
1226 if (rev >= -1)
1229 return PyInt_FromLong(rev);
1227 return PyInt_FromLong(rev);
1230 if (rev == -2)
1228 if (rev == -2)
1231 raise_revlog_error();
1229 raise_revlog_error();
1232 return NULL;
1230 return NULL;
1233 }
1231 }
1234
1232
1235 static int nt_partialmatch(indexObject *self, const char *node,
1233 static int nt_partialmatch(indexObject *self, const char *node,
1236 Py_ssize_t nodelen)
1234 Py_ssize_t nodelen)
1237 {
1235 {
1238 int rev;
1236 int rev;
1239
1237
1240 if (nt_init(self) == -1)
1238 if (nt_init(self) == -1)
1241 return -3;
1239 return -3;
1242
1240
1243 if (self->ntrev > 0) {
1241 if (self->ntrev > 0) {
1244 /* ensure that the radix tree is fully populated */
1242 /* ensure that the radix tree is fully populated */
1245 for (rev = self->ntrev - 1; rev >= 0; rev--) {
1243 for (rev = self->ntrev - 1; rev >= 0; rev--) {
1246 const char *n = index_node(self, rev);
1244 const char *n = index_node_existing(self, rev);
1247 if (n == NULL)
1245 if (n == NULL)
1248 return -2;
1246 return -3;
1249 if (nt_insert(self, n, rev) == -1)
1247 if (nt_insert(self, n, rev) == -1)
1250 return -3;
1248 return -3;
1251 }
1249 }
1252 self->ntrev = rev;
1250 self->ntrev = rev;
1253 }
1251 }
1254
1252
1255 return nt_find(self, node, nodelen, 1);
1253 return nt_find(self, node, nodelen, 1);
1256 }
1254 }
1257
1255
1258 static PyObject *index_partialmatch(indexObject *self, PyObject *args)
1256 static PyObject *index_partialmatch(indexObject *self, PyObject *args)
1259 {
1257 {
1260 const char *fullnode;
1258 const char *fullnode;
1261 int nodelen;
1259 int nodelen;
1262 char *node;
1260 char *node;
1263 int rev, i;
1261 int rev, i;
1264
1262
1265 if (!PyArg_ParseTuple(args, PY23("s#", "y#"), &node, &nodelen))
1263 if (!PyArg_ParseTuple(args, PY23("s#", "y#"), &node, &nodelen))
1266 return NULL;
1264 return NULL;
1267
1265
1268 if (nodelen < 1) {
1266 if (nodelen < 1) {
1269 PyErr_SetString(PyExc_ValueError, "key too short");
1267 PyErr_SetString(PyExc_ValueError, "key too short");
1270 return NULL;
1268 return NULL;
1271 }
1269 }
1272
1270
1273 if (nodelen > 40) {
1271 if (nodelen > 40) {
1274 PyErr_SetString(PyExc_ValueError, "key too long");
1272 PyErr_SetString(PyExc_ValueError, "key too long");
1275 return NULL;
1273 return NULL;
1276 }
1274 }
1277
1275
1278 for (i = 0; i < nodelen; i++)
1276 for (i = 0; i < nodelen; i++)
1279 hexdigit(node, i);
1277 hexdigit(node, i);
1280 if (PyErr_Occurred()) {
1278 if (PyErr_Occurred()) {
1281 /* input contains non-hex characters */
1279 /* input contains non-hex characters */
1282 PyErr_Clear();
1280 PyErr_Clear();
1283 Py_RETURN_NONE;
1281 Py_RETURN_NONE;
1284 }
1282 }
1285
1283
1286 rev = nt_partialmatch(self, node, nodelen);
1284 rev = nt_partialmatch(self, node, nodelen);
1287
1285
1288 switch (rev) {
1286 switch (rev) {
1289 case -4:
1287 case -4:
1290 raise_revlog_error();
1288 raise_revlog_error();
1291 case -3:
1289 case -3:
1292 return NULL;
1290 return NULL;
1293 case -2:
1291 case -2:
1294 Py_RETURN_NONE;
1292 Py_RETURN_NONE;
1295 case -1:
1293 case -1:
1296 return PyBytes_FromStringAndSize(nullid, 20);
1294 return PyBytes_FromStringAndSize(nullid, 20);
1297 }
1295 }
1298
1296
1299 fullnode = index_node_existing(self, rev);
1297 fullnode = index_node_existing(self, rev);
1300 if (fullnode == NULL) {
1298 if (fullnode == NULL) {
1301 return NULL;
1299 return NULL;
1302 }
1300 }
1303 return PyBytes_FromStringAndSize(fullnode, 20);
1301 return PyBytes_FromStringAndSize(fullnode, 20);
1304 }
1302 }
1305
1303
1306 static PyObject *index_m_get(indexObject *self, PyObject *args)
1304 static PyObject *index_m_get(indexObject *self, PyObject *args)
1307 {
1305 {
1308 Py_ssize_t nodelen;
1306 Py_ssize_t nodelen;
1309 PyObject *val;
1307 PyObject *val;
1310 char *node;
1308 char *node;
1311 int rev;
1309 int rev;
1312
1310
1313 if (!PyArg_ParseTuple(args, "O", &val))
1311 if (!PyArg_ParseTuple(args, "O", &val))
1314 return NULL;
1312 return NULL;
1315 if (node_check(val, &node, &nodelen) == -1)
1313 if (node_check(val, &node, &nodelen) == -1)
1316 return NULL;
1314 return NULL;
1317 rev = index_find_node(self, node, nodelen);
1315 rev = index_find_node(self, node, nodelen);
1318 if (rev == -3)
1316 if (rev == -3)
1319 return NULL;
1317 return NULL;
1320 if (rev == -2)
1318 if (rev == -2)
1321 Py_RETURN_NONE;
1319 Py_RETURN_NONE;
1322 return PyInt_FromLong(rev);
1320 return PyInt_FromLong(rev);
1323 }
1321 }
1324
1322
1325 static int index_contains(indexObject *self, PyObject *value)
1323 static int index_contains(indexObject *self, PyObject *value)
1326 {
1324 {
1327 char *node;
1325 char *node;
1328 Py_ssize_t nodelen;
1326 Py_ssize_t nodelen;
1329
1327
1330 if (PyInt_Check(value)) {
1328 if (PyInt_Check(value)) {
1331 long rev = PyInt_AS_LONG(value);
1329 long rev = PyInt_AS_LONG(value);
1332 return rev >= -1 && rev < index_length(self);
1330 return rev >= -1 && rev < index_length(self);
1333 }
1331 }
1334
1332
1335 if (node_check(value, &node, &nodelen) == -1)
1333 if (node_check(value, &node, &nodelen) == -1)
1336 return -1;
1334 return -1;
1337
1335
1338 switch (index_find_node(self, node, nodelen)) {
1336 switch (index_find_node(self, node, nodelen)) {
1339 case -3:
1337 case -3:
1340 return -1;
1338 return -1;
1341 case -2:
1339 case -2:
1342 return 0;
1340 return 0;
1343 default:
1341 default:
1344 return 1;
1342 return 1;
1345 }
1343 }
1346 }
1344 }
1347
1345
1348 typedef uint64_t bitmask;
1346 typedef uint64_t bitmask;
1349
1347
1350 /*
1348 /*
1351 * Given a disjoint set of revs, return all candidates for the
1349 * Given a disjoint set of revs, return all candidates for the
1352 * greatest common ancestor. In revset notation, this is the set
1350 * greatest common ancestor. In revset notation, this is the set
1353 * "heads(::a and ::b and ...)"
1351 * "heads(::a and ::b and ...)"
1354 */
1352 */
1355 static PyObject *find_gca_candidates(indexObject *self, const int *revs,
1353 static PyObject *find_gca_candidates(indexObject *self, const int *revs,
1356 int revcount)
1354 int revcount)
1357 {
1355 {
1358 const bitmask allseen = (1ull << revcount) - 1;
1356 const bitmask allseen = (1ull << revcount) - 1;
1359 const bitmask poison = 1ull << revcount;
1357 const bitmask poison = 1ull << revcount;
1360 PyObject *gca = PyList_New(0);
1358 PyObject *gca = PyList_New(0);
1361 int i, v, interesting;
1359 int i, v, interesting;
1362 int maxrev = -1;
1360 int maxrev = -1;
1363 bitmask sp;
1361 bitmask sp;
1364 bitmask *seen;
1362 bitmask *seen;
1365
1363
1366 if (gca == NULL)
1364 if (gca == NULL)
1367 return PyErr_NoMemory();
1365 return PyErr_NoMemory();
1368
1366
1369 for (i = 0; i < revcount; i++) {
1367 for (i = 0; i < revcount; i++) {
1370 if (revs[i] > maxrev)
1368 if (revs[i] > maxrev)
1371 maxrev = revs[i];
1369 maxrev = revs[i];
1372 }
1370 }
1373
1371
1374 seen = calloc(sizeof(*seen), maxrev + 1);
1372 seen = calloc(sizeof(*seen), maxrev + 1);
1375 if (seen == NULL) {
1373 if (seen == NULL) {
1376 Py_DECREF(gca);
1374 Py_DECREF(gca);
1377 return PyErr_NoMemory();
1375 return PyErr_NoMemory();
1378 }
1376 }
1379
1377
1380 for (i = 0; i < revcount; i++)
1378 for (i = 0; i < revcount; i++)
1381 seen[revs[i]] = 1ull << i;
1379 seen[revs[i]] = 1ull << i;
1382
1380
1383 interesting = revcount;
1381 interesting = revcount;
1384
1382
1385 for (v = maxrev; v >= 0 && interesting; v--) {
1383 for (v = maxrev; v >= 0 && interesting; v--) {
1386 bitmask sv = seen[v];
1384 bitmask sv = seen[v];
1387 int parents[2];
1385 int parents[2];
1388
1386
1389 if (!sv)
1387 if (!sv)
1390 continue;
1388 continue;
1391
1389
1392 if (sv < poison) {
1390 if (sv < poison) {
1393 interesting -= 1;
1391 interesting -= 1;
1394 if (sv == allseen) {
1392 if (sv == allseen) {
1395 PyObject *obj = PyInt_FromLong(v);
1393 PyObject *obj = PyInt_FromLong(v);
1396 if (obj == NULL)
1394 if (obj == NULL)
1397 goto bail;
1395 goto bail;
1398 if (PyList_Append(gca, obj) == -1) {
1396 if (PyList_Append(gca, obj) == -1) {
1399 Py_DECREF(obj);
1397 Py_DECREF(obj);
1400 goto bail;
1398 goto bail;
1401 }
1399 }
1402 sv |= poison;
1400 sv |= poison;
1403 for (i = 0; i < revcount; i++) {
1401 for (i = 0; i < revcount; i++) {
1404 if (revs[i] == v)
1402 if (revs[i] == v)
1405 goto done;
1403 goto done;
1406 }
1404 }
1407 }
1405 }
1408 }
1406 }
1409 if (index_get_parents(self, v, parents, maxrev) < 0)
1407 if (index_get_parents(self, v, parents, maxrev) < 0)
1410 goto bail;
1408 goto bail;
1411
1409
1412 for (i = 0; i < 2; i++) {
1410 for (i = 0; i < 2; i++) {
1413 int p = parents[i];
1411 int p = parents[i];
1414 if (p == -1)
1412 if (p == -1)
1415 continue;
1413 continue;
1416 sp = seen[p];
1414 sp = seen[p];
1417 if (sv < poison) {
1415 if (sv < poison) {
1418 if (sp == 0) {
1416 if (sp == 0) {
1419 seen[p] = sv;
1417 seen[p] = sv;
1420 interesting++;
1418 interesting++;
1421 }
1419 }
1422 else if (sp != sv)
1420 else if (sp != sv)
1423 seen[p] |= sv;
1421 seen[p] |= sv;
1424 } else {
1422 } else {
1425 if (sp && sp < poison)
1423 if (sp && sp < poison)
1426 interesting--;
1424 interesting--;
1427 seen[p] = sv;
1425 seen[p] = sv;
1428 }
1426 }
1429 }
1427 }
1430 }
1428 }
1431
1429
1432 done:
1430 done:
1433 free(seen);
1431 free(seen);
1434 return gca;
1432 return gca;
1435 bail:
1433 bail:
1436 free(seen);
1434 free(seen);
1437 Py_XDECREF(gca);
1435 Py_XDECREF(gca);
1438 return NULL;
1436 return NULL;
1439 }
1437 }
1440
1438
1441 /*
1439 /*
1442 * Given a disjoint set of revs, return the subset with the longest
1440 * Given a disjoint set of revs, return the subset with the longest
1443 * path to the root.
1441 * path to the root.
1444 */
1442 */
1445 static PyObject *find_deepest(indexObject *self, PyObject *revs)
1443 static PyObject *find_deepest(indexObject *self, PyObject *revs)
1446 {
1444 {
1447 const Py_ssize_t revcount = PyList_GET_SIZE(revs);
1445 const Py_ssize_t revcount = PyList_GET_SIZE(revs);
1448 static const Py_ssize_t capacity = 24;
1446 static const Py_ssize_t capacity = 24;
1449 int *depth, *interesting = NULL;
1447 int *depth, *interesting = NULL;
1450 int i, j, v, ninteresting;
1448 int i, j, v, ninteresting;
1451 PyObject *dict = NULL, *keys = NULL;
1449 PyObject *dict = NULL, *keys = NULL;
1452 long *seen = NULL;
1450 long *seen = NULL;
1453 int maxrev = -1;
1451 int maxrev = -1;
1454 long final;
1452 long final;
1455
1453
1456 if (revcount > capacity) {
1454 if (revcount > capacity) {
1457 PyErr_Format(PyExc_OverflowError,
1455 PyErr_Format(PyExc_OverflowError,
1458 "bitset size (%ld) > capacity (%ld)",
1456 "bitset size (%ld) > capacity (%ld)",
1459 (long)revcount, (long)capacity);
1457 (long)revcount, (long)capacity);
1460 return NULL;
1458 return NULL;
1461 }
1459 }
1462
1460
1463 for (i = 0; i < revcount; i++) {
1461 for (i = 0; i < revcount; i++) {
1464 int n = (int)PyInt_AsLong(PyList_GET_ITEM(revs, i));
1462 int n = (int)PyInt_AsLong(PyList_GET_ITEM(revs, i));
1465 if (n > maxrev)
1463 if (n > maxrev)
1466 maxrev = n;
1464 maxrev = n;
1467 }
1465 }
1468
1466
1469 depth = calloc(sizeof(*depth), maxrev + 1);
1467 depth = calloc(sizeof(*depth), maxrev + 1);
1470 if (depth == NULL)
1468 if (depth == NULL)
1471 return PyErr_NoMemory();
1469 return PyErr_NoMemory();
1472
1470
1473 seen = calloc(sizeof(*seen), maxrev + 1);
1471 seen = calloc(sizeof(*seen), maxrev + 1);
1474 if (seen == NULL) {
1472 if (seen == NULL) {
1475 PyErr_NoMemory();
1473 PyErr_NoMemory();
1476 goto bail;
1474 goto bail;
1477 }
1475 }
1478
1476
1479 interesting = calloc(sizeof(*interesting), 1 << revcount);
1477 interesting = calloc(sizeof(*interesting), 1 << revcount);
1480 if (interesting == NULL) {
1478 if (interesting == NULL) {
1481 PyErr_NoMemory();
1479 PyErr_NoMemory();
1482 goto bail;
1480 goto bail;
1483 }
1481 }
1484
1482
1485 if (PyList_Sort(revs) == -1)
1483 if (PyList_Sort(revs) == -1)
1486 goto bail;
1484 goto bail;
1487
1485
1488 for (i = 0; i < revcount; i++) {
1486 for (i = 0; i < revcount; i++) {
1489 int n = (int)PyInt_AsLong(PyList_GET_ITEM(revs, i));
1487 int n = (int)PyInt_AsLong(PyList_GET_ITEM(revs, i));
1490 long b = 1l << i;
1488 long b = 1l << i;
1491 depth[n] = 1;
1489 depth[n] = 1;
1492 seen[n] = b;
1490 seen[n] = b;
1493 interesting[b] = 1;
1491 interesting[b] = 1;
1494 }
1492 }
1495
1493
1496 /* invariant: ninteresting is the number of non-zero entries in
1494 /* invariant: ninteresting is the number of non-zero entries in
1497 * interesting. */
1495 * interesting. */
1498 ninteresting = (int)revcount;
1496 ninteresting = (int)revcount;
1499
1497
1500 for (v = maxrev; v >= 0 && ninteresting > 1; v--) {
1498 for (v = maxrev; v >= 0 && ninteresting > 1; v--) {
1501 int dv = depth[v];
1499 int dv = depth[v];
1502 int parents[2];
1500 int parents[2];
1503 long sv;
1501 long sv;
1504
1502
1505 if (dv == 0)
1503 if (dv == 0)
1506 continue;
1504 continue;
1507
1505
1508 sv = seen[v];
1506 sv = seen[v];
1509 if (index_get_parents(self, v, parents, maxrev) < 0)
1507 if (index_get_parents(self, v, parents, maxrev) < 0)
1510 goto bail;
1508 goto bail;
1511
1509
1512 for (i = 0; i < 2; i++) {
1510 for (i = 0; i < 2; i++) {
1513 int p = parents[i];
1511 int p = parents[i];
1514 long sp;
1512 long sp;
1515 int dp;
1513 int dp;
1516
1514
1517 if (p == -1)
1515 if (p == -1)
1518 continue;
1516 continue;
1519
1517
1520 dp = depth[p];
1518 dp = depth[p];
1521 sp = seen[p];
1519 sp = seen[p];
1522 if (dp <= dv) {
1520 if (dp <= dv) {
1523 depth[p] = dv + 1;
1521 depth[p] = dv + 1;
1524 if (sp != sv) {
1522 if (sp != sv) {
1525 interesting[sv] += 1;
1523 interesting[sv] += 1;
1526 seen[p] = sv;
1524 seen[p] = sv;
1527 if (sp) {
1525 if (sp) {
1528 interesting[sp] -= 1;
1526 interesting[sp] -= 1;
1529 if (interesting[sp] == 0)
1527 if (interesting[sp] == 0)
1530 ninteresting -= 1;
1528 ninteresting -= 1;
1531 }
1529 }
1532 }
1530 }
1533 }
1531 }
1534 else if (dv == dp - 1) {
1532 else if (dv == dp - 1) {
1535 long nsp = sp | sv;
1533 long nsp = sp | sv;
1536 if (nsp == sp)
1534 if (nsp == sp)
1537 continue;
1535 continue;
1538 seen[p] = nsp;
1536 seen[p] = nsp;
1539 interesting[sp] -= 1;
1537 interesting[sp] -= 1;
1540 if (interesting[sp] == 0)
1538 if (interesting[sp] == 0)
1541 ninteresting -= 1;
1539 ninteresting -= 1;
1542 if (interesting[nsp] == 0)
1540 if (interesting[nsp] == 0)
1543 ninteresting += 1;
1541 ninteresting += 1;
1544 interesting[nsp] += 1;
1542 interesting[nsp] += 1;
1545 }
1543 }
1546 }
1544 }
1547 interesting[sv] -= 1;
1545 interesting[sv] -= 1;
1548 if (interesting[sv] == 0)
1546 if (interesting[sv] == 0)
1549 ninteresting -= 1;
1547 ninteresting -= 1;
1550 }
1548 }
1551
1549
1552 final = 0;
1550 final = 0;
1553 j = ninteresting;
1551 j = ninteresting;
1554 for (i = 0; i < (int)(2 << revcount) && j > 0; i++) {
1552 for (i = 0; i < (int)(2 << revcount) && j > 0; i++) {
1555 if (interesting[i] == 0)
1553 if (interesting[i] == 0)
1556 continue;
1554 continue;
1557 final |= i;
1555 final |= i;
1558 j -= 1;
1556 j -= 1;
1559 }
1557 }
1560 if (final == 0) {
1558 if (final == 0) {
1561 keys = PyList_New(0);
1559 keys = PyList_New(0);
1562 goto bail;
1560 goto bail;
1563 }
1561 }
1564
1562
1565 dict = PyDict_New();
1563 dict = PyDict_New();
1566 if (dict == NULL)
1564 if (dict == NULL)
1567 goto bail;
1565 goto bail;
1568
1566
1569 for (i = 0; i < revcount; i++) {
1567 for (i = 0; i < revcount; i++) {
1570 PyObject *key;
1568 PyObject *key;
1571
1569
1572 if ((final & (1 << i)) == 0)
1570 if ((final & (1 << i)) == 0)
1573 continue;
1571 continue;
1574
1572
1575 key = PyList_GET_ITEM(revs, i);
1573 key = PyList_GET_ITEM(revs, i);
1576 Py_INCREF(key);
1574 Py_INCREF(key);
1577 Py_INCREF(Py_None);
1575 Py_INCREF(Py_None);
1578 if (PyDict_SetItem(dict, key, Py_None) == -1) {
1576 if (PyDict_SetItem(dict, key, Py_None) == -1) {
1579 Py_DECREF(key);
1577 Py_DECREF(key);
1580 Py_DECREF(Py_None);
1578 Py_DECREF(Py_None);
1581 goto bail;
1579 goto bail;
1582 }
1580 }
1583 }
1581 }
1584
1582
1585 keys = PyDict_Keys(dict);
1583 keys = PyDict_Keys(dict);
1586
1584
1587 bail:
1585 bail:
1588 free(depth);
1586 free(depth);
1589 free(seen);
1587 free(seen);
1590 free(interesting);
1588 free(interesting);
1591 Py_XDECREF(dict);
1589 Py_XDECREF(dict);
1592
1590
1593 return keys;
1591 return keys;
1594 }
1592 }
1595
1593
1596 /*
1594 /*
1597 * Given a (possibly overlapping) set of revs, return all the
1595 * Given a (possibly overlapping) set of revs, return all the
1598 * common ancestors heads: heads(::args[0] and ::a[1] and ...)
1596 * common ancestors heads: heads(::args[0] and ::a[1] and ...)
1599 */
1597 */
1600 static PyObject *index_commonancestorsheads(indexObject *self, PyObject *args)
1598 static PyObject *index_commonancestorsheads(indexObject *self, PyObject *args)
1601 {
1599 {
1602 PyObject *ret = NULL;
1600 PyObject *ret = NULL;
1603 Py_ssize_t argcount, i, len;
1601 Py_ssize_t argcount, i, len;
1604 bitmask repeat = 0;
1602 bitmask repeat = 0;
1605 int revcount = 0;
1603 int revcount = 0;
1606 int *revs;
1604 int *revs;
1607
1605
1608 argcount = PySequence_Length(args);
1606 argcount = PySequence_Length(args);
1609 revs = PyMem_Malloc(argcount * sizeof(*revs));
1607 revs = PyMem_Malloc(argcount * sizeof(*revs));
1610 if (argcount > 0 && revs == NULL)
1608 if (argcount > 0 && revs == NULL)
1611 return PyErr_NoMemory();
1609 return PyErr_NoMemory();
1612 len = index_length(self) - 1;
1610 len = index_length(self) - 1;
1613
1611
1614 for (i = 0; i < argcount; i++) {
1612 for (i = 0; i < argcount; i++) {
1615 static const int capacity = 24;
1613 static const int capacity = 24;
1616 PyObject *obj = PySequence_GetItem(args, i);
1614 PyObject *obj = PySequence_GetItem(args, i);
1617 bitmask x;
1615 bitmask x;
1618 long val;
1616 long val;
1619
1617
1620 if (!PyInt_Check(obj)) {
1618 if (!PyInt_Check(obj)) {
1621 PyErr_SetString(PyExc_TypeError,
1619 PyErr_SetString(PyExc_TypeError,
1622 "arguments must all be ints");
1620 "arguments must all be ints");
1623 Py_DECREF(obj);
1621 Py_DECREF(obj);
1624 goto bail;
1622 goto bail;
1625 }
1623 }
1626 val = PyInt_AsLong(obj);
1624 val = PyInt_AsLong(obj);
1627 Py_DECREF(obj);
1625 Py_DECREF(obj);
1628 if (val == -1) {
1626 if (val == -1) {
1629 ret = PyList_New(0);
1627 ret = PyList_New(0);
1630 goto done;
1628 goto done;
1631 }
1629 }
1632 if (val < 0 || val >= len) {
1630 if (val < 0 || val >= len) {
1633 PyErr_SetString(PyExc_IndexError,
1631 PyErr_SetString(PyExc_IndexError,
1634 "index out of range");
1632 "index out of range");
1635 goto bail;
1633 goto bail;
1636 }
1634 }
1637 /* this cheesy bloom filter lets us avoid some more
1635 /* this cheesy bloom filter lets us avoid some more
1638 * expensive duplicate checks in the common set-is-disjoint
1636 * expensive duplicate checks in the common set-is-disjoint
1639 * case */
1637 * case */
1640 x = 1ull << (val & 0x3f);
1638 x = 1ull << (val & 0x3f);
1641 if (repeat & x) {
1639 if (repeat & x) {
1642 int k;
1640 int k;
1643 for (k = 0; k < revcount; k++) {
1641 for (k = 0; k < revcount; k++) {
1644 if (val == revs[k])
1642 if (val == revs[k])
1645 goto duplicate;
1643 goto duplicate;
1646 }
1644 }
1647 }
1645 }
1648 else repeat |= x;
1646 else repeat |= x;
1649 if (revcount >= capacity) {
1647 if (revcount >= capacity) {
1650 PyErr_Format(PyExc_OverflowError,
1648 PyErr_Format(PyExc_OverflowError,
1651 "bitset size (%d) > capacity (%d)",
1649 "bitset size (%d) > capacity (%d)",
1652 revcount, capacity);
1650 revcount, capacity);
1653 goto bail;
1651 goto bail;
1654 }
1652 }
1655 revs[revcount++] = (int)val;
1653 revs[revcount++] = (int)val;
1656 duplicate:;
1654 duplicate:;
1657 }
1655 }
1658
1656
1659 if (revcount == 0) {
1657 if (revcount == 0) {
1660 ret = PyList_New(0);
1658 ret = PyList_New(0);
1661 goto done;
1659 goto done;
1662 }
1660 }
1663 if (revcount == 1) {
1661 if (revcount == 1) {
1664 PyObject *obj;
1662 PyObject *obj;
1665 ret = PyList_New(1);
1663 ret = PyList_New(1);
1666 if (ret == NULL)
1664 if (ret == NULL)
1667 goto bail;
1665 goto bail;
1668 obj = PyInt_FromLong(revs[0]);
1666 obj = PyInt_FromLong(revs[0]);
1669 if (obj == NULL)
1667 if (obj == NULL)
1670 goto bail;
1668 goto bail;
1671 PyList_SET_ITEM(ret, 0, obj);
1669 PyList_SET_ITEM(ret, 0, obj);
1672 goto done;
1670 goto done;
1673 }
1671 }
1674
1672
1675 ret = find_gca_candidates(self, revs, revcount);
1673 ret = find_gca_candidates(self, revs, revcount);
1676 if (ret == NULL)
1674 if (ret == NULL)
1677 goto bail;
1675 goto bail;
1678
1676
1679 done:
1677 done:
1680 PyMem_Free(revs);
1678 PyMem_Free(revs);
1681 return ret;
1679 return ret;
1682
1680
1683 bail:
1681 bail:
1684 PyMem_Free(revs);
1682 PyMem_Free(revs);
1685 Py_XDECREF(ret);
1683 Py_XDECREF(ret);
1686 return NULL;
1684 return NULL;
1687 }
1685 }
1688
1686
1689 /*
1687 /*
1690 * Given a (possibly overlapping) set of revs, return the greatest
1688 * Given a (possibly overlapping) set of revs, return the greatest
1691 * common ancestors: those with the longest path to the root.
1689 * common ancestors: those with the longest path to the root.
1692 */
1690 */
1693 static PyObject *index_ancestors(indexObject *self, PyObject *args)
1691 static PyObject *index_ancestors(indexObject *self, PyObject *args)
1694 {
1692 {
1695 PyObject *ret;
1693 PyObject *ret;
1696 PyObject *gca = index_commonancestorsheads(self, args);
1694 PyObject *gca = index_commonancestorsheads(self, args);
1697 if (gca == NULL)
1695 if (gca == NULL)
1698 return NULL;
1696 return NULL;
1699
1697
1700 if (PyList_GET_SIZE(gca) <= 1) {
1698 if (PyList_GET_SIZE(gca) <= 1) {
1701 return gca;
1699 return gca;
1702 }
1700 }
1703
1701
1704 ret = find_deepest(self, gca);
1702 ret = find_deepest(self, gca);
1705 Py_DECREF(gca);
1703 Py_DECREF(gca);
1706 return ret;
1704 return ret;
1707 }
1705 }
1708
1706
1709 /*
1707 /*
1710 * Invalidate any trie entries introduced by added revs.
1708 * Invalidate any trie entries introduced by added revs.
1711 */
1709 */
1712 static void nt_invalidate_added(indexObject *self, Py_ssize_t start)
1710 static void nt_invalidate_added(indexObject *self, Py_ssize_t start)
1713 {
1711 {
1714 Py_ssize_t i, len = PyList_GET_SIZE(self->added);
1712 Py_ssize_t i, len = PyList_GET_SIZE(self->added);
1715
1713
1716 for (i = start; i < len; i++) {
1714 for (i = start; i < len; i++) {
1717 PyObject *tuple = PyList_GET_ITEM(self->added, i);
1715 PyObject *tuple = PyList_GET_ITEM(self->added, i);
1718 PyObject *node = PyTuple_GET_ITEM(tuple, 7);
1716 PyObject *node = PyTuple_GET_ITEM(tuple, 7);
1719
1717
1720 nt_insert(self, PyBytes_AS_STRING(node), -1);
1718 nt_insert(self, PyBytes_AS_STRING(node), -1);
1721 }
1719 }
1722
1720
1723 if (start == 0)
1721 if (start == 0)
1724 Py_CLEAR(self->added);
1722 Py_CLEAR(self->added);
1725 }
1723 }
1726
1724
1727 /*
1725 /*
1728 * Delete a numeric range of revs, which must be at the end of the
1726 * Delete a numeric range of revs, which must be at the end of the
1729 * range, but exclude the sentinel nullid entry.
1727 * range, but exclude the sentinel nullid entry.
1730 */
1728 */
1731 static int index_slice_del(indexObject *self, PyObject *item)
1729 static int index_slice_del(indexObject *self, PyObject *item)
1732 {
1730 {
1733 Py_ssize_t start, stop, step, slicelength;
1731 Py_ssize_t start, stop, step, slicelength;
1734 Py_ssize_t length = index_length(self);
1732 Py_ssize_t length = index_length(self);
1735 int ret = 0;
1733 int ret = 0;
1736
1734
1737 /* Argument changed from PySliceObject* to PyObject* in Python 3. */
1735 /* Argument changed from PySliceObject* to PyObject* in Python 3. */
1738 #ifdef IS_PY3K
1736 #ifdef IS_PY3K
1739 if (PySlice_GetIndicesEx(item, length,
1737 if (PySlice_GetIndicesEx(item, length,
1740 #else
1738 #else
1741 if (PySlice_GetIndicesEx((PySliceObject*)item, length,
1739 if (PySlice_GetIndicesEx((PySliceObject*)item, length,
1742 #endif
1740 #endif
1743 &start, &stop, &step, &slicelength) < 0)
1741 &start, &stop, &step, &slicelength) < 0)
1744 return -1;
1742 return -1;
1745
1743
1746 if (slicelength <= 0)
1744 if (slicelength <= 0)
1747 return 0;
1745 return 0;
1748
1746
1749 if ((step < 0 && start < stop) || (step > 0 && start > stop))
1747 if ((step < 0 && start < stop) || (step > 0 && start > stop))
1750 stop = start;
1748 stop = start;
1751
1749
1752 if (step < 0) {
1750 if (step < 0) {
1753 stop = start + 1;
1751 stop = start + 1;
1754 start = stop + step*(slicelength - 1) - 1;
1752 start = stop + step*(slicelength - 1) - 1;
1755 step = -step;
1753 step = -step;
1756 }
1754 }
1757
1755
1758 if (step != 1) {
1756 if (step != 1) {
1759 PyErr_SetString(PyExc_ValueError,
1757 PyErr_SetString(PyExc_ValueError,
1760 "revlog index delete requires step size of 1");
1758 "revlog index delete requires step size of 1");
1761 return -1;
1759 return -1;
1762 }
1760 }
1763
1761
1764 if (stop != length - 1) {
1762 if (stop != length - 1) {
1765 PyErr_SetString(PyExc_IndexError,
1763 PyErr_SetString(PyExc_IndexError,
1766 "revlog index deletion indices are invalid");
1764 "revlog index deletion indices are invalid");
1767 return -1;
1765 return -1;
1768 }
1766 }
1769
1767
1770 if (start < self->length - 1) {
1768 if (start < self->length - 1) {
1771 if (self->nt) {
1769 if (self->nt) {
1772 Py_ssize_t i;
1770 Py_ssize_t i;
1773
1771
1774 for (i = start + 1; i < self->length - 1; i++) {
1772 for (i = start + 1; i < self->length - 1; i++) {
1775 const char *node = index_node(self, i);
1773 const char *node = index_node(self, i);
1776
1774
1777 if (node)
1775 if (node)
1778 nt_insert(self, node, -1);
1776 nt_insert(self, node, -1);
1779 }
1777 }
1780 if (self->added)
1778 if (self->added)
1781 nt_invalidate_added(self, 0);
1779 nt_invalidate_added(self, 0);
1782 if (self->ntrev > start)
1780 if (self->ntrev > start)
1783 self->ntrev = (int)start;
1781 self->ntrev = (int)start;
1784 }
1782 }
1785 self->length = start + 1;
1783 self->length = start + 1;
1786 if (start < self->raw_length) {
1784 if (start < self->raw_length) {
1787 if (self->cache) {
1785 if (self->cache) {
1788 Py_ssize_t i;
1786 Py_ssize_t i;
1789 for (i = start; i < self->raw_length; i++)
1787 for (i = start; i < self->raw_length; i++)
1790 Py_CLEAR(self->cache[i]);
1788 Py_CLEAR(self->cache[i]);
1791 }
1789 }
1792 self->raw_length = start;
1790 self->raw_length = start;
1793 }
1791 }
1794 goto done;
1792 goto done;
1795 }
1793 }
1796
1794
1797 if (self->nt) {
1795 if (self->nt) {
1798 nt_invalidate_added(self, start - self->length + 1);
1796 nt_invalidate_added(self, start - self->length + 1);
1799 if (self->ntrev > start)
1797 if (self->ntrev > start)
1800 self->ntrev = (int)start;
1798 self->ntrev = (int)start;
1801 }
1799 }
1802 if (self->added)
1800 if (self->added)
1803 ret = PyList_SetSlice(self->added, start - self->length + 1,
1801 ret = PyList_SetSlice(self->added, start - self->length + 1,
1804 PyList_GET_SIZE(self->added), NULL);
1802 PyList_GET_SIZE(self->added), NULL);
1805 done:
1803 done:
1806 Py_CLEAR(self->headrevs);
1804 Py_CLEAR(self->headrevs);
1807 return ret;
1805 return ret;
1808 }
1806 }
1809
1807
1810 /*
1808 /*
1811 * Supported ops:
1809 * Supported ops:
1812 *
1810 *
1813 * slice deletion
1811 * slice deletion
1814 * string assignment (extend node->rev mapping)
1812 * string assignment (extend node->rev mapping)
1815 * string deletion (shrink node->rev mapping)
1813 * string deletion (shrink node->rev mapping)
1816 */
1814 */
1817 static int index_assign_subscript(indexObject *self, PyObject *item,
1815 static int index_assign_subscript(indexObject *self, PyObject *item,
1818 PyObject *value)
1816 PyObject *value)
1819 {
1817 {
1820 char *node;
1818 char *node;
1821 Py_ssize_t nodelen;
1819 Py_ssize_t nodelen;
1822 long rev;
1820 long rev;
1823
1821
1824 if (PySlice_Check(item) && value == NULL)
1822 if (PySlice_Check(item) && value == NULL)
1825 return index_slice_del(self, item);
1823 return index_slice_del(self, item);
1826
1824
1827 if (node_check(item, &node, &nodelen) == -1)
1825 if (node_check(item, &node, &nodelen) == -1)
1828 return -1;
1826 return -1;
1829
1827
1830 if (value == NULL)
1828 if (value == NULL)
1831 return self->nt ? nt_insert(self, node, -1) : 0;
1829 return self->nt ? nt_insert(self, node, -1) : 0;
1832 rev = PyInt_AsLong(value);
1830 rev = PyInt_AsLong(value);
1833 if (rev > INT_MAX || rev < 0) {
1831 if (rev > INT_MAX || rev < 0) {
1834 if (!PyErr_Occurred())
1832 if (!PyErr_Occurred())
1835 PyErr_SetString(PyExc_ValueError, "rev out of range");
1833 PyErr_SetString(PyExc_ValueError, "rev out of range");
1836 return -1;
1834 return -1;
1837 }
1835 }
1838
1836
1839 if (nt_init(self) == -1)
1837 if (nt_init(self) == -1)
1840 return -1;
1838 return -1;
1841 return nt_insert(self, node, (int)rev);
1839 return nt_insert(self, node, (int)rev);
1842 }
1840 }
1843
1841
1844 /*
1842 /*
1845 * Find all RevlogNG entries in an index that has inline data. Update
1843 * Find all RevlogNG entries in an index that has inline data. Update
1846 * the optional "offsets" table with those entries.
1844 * the optional "offsets" table with those entries.
1847 */
1845 */
1848 static Py_ssize_t inline_scan(indexObject *self, const char **offsets)
1846 static Py_ssize_t inline_scan(indexObject *self, const char **offsets)
1849 {
1847 {
1850 const char *data = (const char *)self->buf.buf;
1848 const char *data = (const char *)self->buf.buf;
1851 Py_ssize_t pos = 0;
1849 Py_ssize_t pos = 0;
1852 Py_ssize_t end = self->buf.len;
1850 Py_ssize_t end = self->buf.len;
1853 long incr = v1_hdrsize;
1851 long incr = v1_hdrsize;
1854 Py_ssize_t len = 0;
1852 Py_ssize_t len = 0;
1855
1853
1856 while (pos + v1_hdrsize <= end && pos >= 0) {
1854 while (pos + v1_hdrsize <= end && pos >= 0) {
1857 uint32_t comp_len;
1855 uint32_t comp_len;
1858 /* 3rd element of header is length of compressed inline data */
1856 /* 3rd element of header is length of compressed inline data */
1859 comp_len = getbe32(data + pos + 8);
1857 comp_len = getbe32(data + pos + 8);
1860 incr = v1_hdrsize + comp_len;
1858 incr = v1_hdrsize + comp_len;
1861 if (offsets)
1859 if (offsets)
1862 offsets[len] = data + pos;
1860 offsets[len] = data + pos;
1863 len++;
1861 len++;
1864 pos += incr;
1862 pos += incr;
1865 }
1863 }
1866
1864
1867 if (pos != end) {
1865 if (pos != end) {
1868 if (!PyErr_Occurred())
1866 if (!PyErr_Occurred())
1869 PyErr_SetString(PyExc_ValueError, "corrupt index file");
1867 PyErr_SetString(PyExc_ValueError, "corrupt index file");
1870 return -1;
1868 return -1;
1871 }
1869 }
1872
1870
1873 return len;
1871 return len;
1874 }
1872 }
1875
1873
1876 static int index_init(indexObject *self, PyObject *args)
1874 static int index_init(indexObject *self, PyObject *args)
1877 {
1875 {
1878 PyObject *data_obj, *inlined_obj;
1876 PyObject *data_obj, *inlined_obj;
1879 Py_ssize_t size;
1877 Py_ssize_t size;
1880
1878
1881 /* Initialize before argument-checking to avoid index_dealloc() crash. */
1879 /* Initialize before argument-checking to avoid index_dealloc() crash. */
1882 self->raw_length = 0;
1880 self->raw_length = 0;
1883 self->added = NULL;
1881 self->added = NULL;
1884 self->cache = NULL;
1882 self->cache = NULL;
1885 self->data = NULL;
1883 self->data = NULL;
1886 memset(&self->buf, 0, sizeof(self->buf));
1884 memset(&self->buf, 0, sizeof(self->buf));
1887 self->headrevs = NULL;
1885 self->headrevs = NULL;
1888 self->filteredrevs = Py_None;
1886 self->filteredrevs = Py_None;
1889 Py_INCREF(Py_None);
1887 Py_INCREF(Py_None);
1890 self->nt = NULL;
1888 self->nt = NULL;
1891 self->offsets = NULL;
1889 self->offsets = NULL;
1892
1890
1893 if (!PyArg_ParseTuple(args, "OO", &data_obj, &inlined_obj))
1891 if (!PyArg_ParseTuple(args, "OO", &data_obj, &inlined_obj))
1894 return -1;
1892 return -1;
1895 if (!PyObject_CheckBuffer(data_obj)) {
1893 if (!PyObject_CheckBuffer(data_obj)) {
1896 PyErr_SetString(PyExc_TypeError,
1894 PyErr_SetString(PyExc_TypeError,
1897 "data does not support buffer interface");
1895 "data does not support buffer interface");
1898 return -1;
1896 return -1;
1899 }
1897 }
1900
1898
1901 if (PyObject_GetBuffer(data_obj, &self->buf, PyBUF_SIMPLE) == -1)
1899 if (PyObject_GetBuffer(data_obj, &self->buf, PyBUF_SIMPLE) == -1)
1902 return -1;
1900 return -1;
1903 size = self->buf.len;
1901 size = self->buf.len;
1904
1902
1905 self->inlined = inlined_obj && PyObject_IsTrue(inlined_obj);
1903 self->inlined = inlined_obj && PyObject_IsTrue(inlined_obj);
1906 self->data = data_obj;
1904 self->data = data_obj;
1907
1905
1908 self->ntlength = self->ntcapacity = 0;
1906 self->ntlength = self->ntcapacity = 0;
1909 self->ntdepth = self->ntsplits = 0;
1907 self->ntdepth = self->ntsplits = 0;
1910 self->ntlookups = self->ntmisses = 0;
1908 self->ntlookups = self->ntmisses = 0;
1911 self->ntrev = -1;
1909 self->ntrev = -1;
1912 Py_INCREF(self->data);
1910 Py_INCREF(self->data);
1913
1911
1914 if (self->inlined) {
1912 if (self->inlined) {
1915 Py_ssize_t len = inline_scan(self, NULL);
1913 Py_ssize_t len = inline_scan(self, NULL);
1916 if (len == -1)
1914 if (len == -1)
1917 goto bail;
1915 goto bail;
1918 self->raw_length = len;
1916 self->raw_length = len;
1919 self->length = len + 1;
1917 self->length = len + 1;
1920 } else {
1918 } else {
1921 if (size % v1_hdrsize) {
1919 if (size % v1_hdrsize) {
1922 PyErr_SetString(PyExc_ValueError, "corrupt index file");
1920 PyErr_SetString(PyExc_ValueError, "corrupt index file");
1923 goto bail;
1921 goto bail;
1924 }
1922 }
1925 self->raw_length = size / v1_hdrsize;
1923 self->raw_length = size / v1_hdrsize;
1926 self->length = self->raw_length + 1;
1924 self->length = self->raw_length + 1;
1927 }
1925 }
1928
1926
1929 return 0;
1927 return 0;
1930 bail:
1928 bail:
1931 return -1;
1929 return -1;
1932 }
1930 }
1933
1931
1934 static PyObject *index_nodemap(indexObject *self)
1932 static PyObject *index_nodemap(indexObject *self)
1935 {
1933 {
1936 Py_INCREF(self);
1934 Py_INCREF(self);
1937 return (PyObject *)self;
1935 return (PyObject *)self;
1938 }
1936 }
1939
1937
1940 static void index_dealloc(indexObject *self)
1938 static void index_dealloc(indexObject *self)
1941 {
1939 {
1942 _index_clearcaches(self);
1940 _index_clearcaches(self);
1943 Py_XDECREF(self->filteredrevs);
1941 Py_XDECREF(self->filteredrevs);
1944 if (self->buf.buf) {
1942 if (self->buf.buf) {
1945 PyBuffer_Release(&self->buf);
1943 PyBuffer_Release(&self->buf);
1946 memset(&self->buf, 0, sizeof(self->buf));
1944 memset(&self->buf, 0, sizeof(self->buf));
1947 }
1945 }
1948 Py_XDECREF(self->data);
1946 Py_XDECREF(self->data);
1949 Py_XDECREF(self->added);
1947 Py_XDECREF(self->added);
1950 PyObject_Del(self);
1948 PyObject_Del(self);
1951 }
1949 }
1952
1950
1953 static PySequenceMethods index_sequence_methods = {
1951 static PySequenceMethods index_sequence_methods = {
1954 (lenfunc)index_length, /* sq_length */
1952 (lenfunc)index_length, /* sq_length */
1955 0, /* sq_concat */
1953 0, /* sq_concat */
1956 0, /* sq_repeat */
1954 0, /* sq_repeat */
1957 (ssizeargfunc)index_get, /* sq_item */
1955 (ssizeargfunc)index_get, /* sq_item */
1958 0, /* sq_slice */
1956 0, /* sq_slice */
1959 0, /* sq_ass_item */
1957 0, /* sq_ass_item */
1960 0, /* sq_ass_slice */
1958 0, /* sq_ass_slice */
1961 (objobjproc)index_contains, /* sq_contains */
1959 (objobjproc)index_contains, /* sq_contains */
1962 };
1960 };
1963
1961
1964 static PyMappingMethods index_mapping_methods = {
1962 static PyMappingMethods index_mapping_methods = {
1965 (lenfunc)index_length, /* mp_length */
1963 (lenfunc)index_length, /* mp_length */
1966 (binaryfunc)index_getitem, /* mp_subscript */
1964 (binaryfunc)index_getitem, /* mp_subscript */
1967 (objobjargproc)index_assign_subscript, /* mp_ass_subscript */
1965 (objobjargproc)index_assign_subscript, /* mp_ass_subscript */
1968 };
1966 };
1969
1967
1970 static PyMethodDef index_methods[] = {
1968 static PyMethodDef index_methods[] = {
1971 {"ancestors", (PyCFunction)index_ancestors, METH_VARARGS,
1969 {"ancestors", (PyCFunction)index_ancestors, METH_VARARGS,
1972 "return the gca set of the given revs"},
1970 "return the gca set of the given revs"},
1973 {"commonancestorsheads", (PyCFunction)index_commonancestorsheads,
1971 {"commonancestorsheads", (PyCFunction)index_commonancestorsheads,
1974 METH_VARARGS,
1972 METH_VARARGS,
1975 "return the heads of the common ancestors of the given revs"},
1973 "return the heads of the common ancestors of the given revs"},
1976 {"clearcaches", (PyCFunction)index_clearcaches, METH_NOARGS,
1974 {"clearcaches", (PyCFunction)index_clearcaches, METH_NOARGS,
1977 "clear the index caches"},
1975 "clear the index caches"},
1978 {"get", (PyCFunction)index_m_get, METH_VARARGS,
1976 {"get", (PyCFunction)index_m_get, METH_VARARGS,
1979 "get an index entry"},
1977 "get an index entry"},
1980 {"computephasesmapsets", (PyCFunction)compute_phases_map_sets,
1978 {"computephasesmapsets", (PyCFunction)compute_phases_map_sets,
1981 METH_VARARGS, "compute phases"},
1979 METH_VARARGS, "compute phases"},
1982 {"reachableroots2", (PyCFunction)reachableroots2, METH_VARARGS,
1980 {"reachableroots2", (PyCFunction)reachableroots2, METH_VARARGS,
1983 "reachableroots"},
1981 "reachableroots"},
1984 {"headrevs", (PyCFunction)index_headrevs, METH_VARARGS,
1982 {"headrevs", (PyCFunction)index_headrevs, METH_VARARGS,
1985 "get head revisions"}, /* Can do filtering since 3.2 */
1983 "get head revisions"}, /* Can do filtering since 3.2 */
1986 {"headrevsfiltered", (PyCFunction)index_headrevs, METH_VARARGS,
1984 {"headrevsfiltered", (PyCFunction)index_headrevs, METH_VARARGS,
1987 "get filtered head revisions"}, /* Can always do filtering */
1985 "get filtered head revisions"}, /* Can always do filtering */
1988 {"deltachain", (PyCFunction)index_deltachain, METH_VARARGS,
1986 {"deltachain", (PyCFunction)index_deltachain, METH_VARARGS,
1989 "determine revisions with deltas to reconstruct fulltext"},
1987 "determine revisions with deltas to reconstruct fulltext"},
1990 {"insert", (PyCFunction)index_insert, METH_VARARGS,
1988 {"insert", (PyCFunction)index_insert, METH_VARARGS,
1991 "insert an index entry"},
1989 "insert an index entry"},
1992 {"partialmatch", (PyCFunction)index_partialmatch, METH_VARARGS,
1990 {"partialmatch", (PyCFunction)index_partialmatch, METH_VARARGS,
1993 "match a potentially ambiguous node ID"},
1991 "match a potentially ambiguous node ID"},
1994 {"stats", (PyCFunction)index_stats, METH_NOARGS,
1992 {"stats", (PyCFunction)index_stats, METH_NOARGS,
1995 "stats for the index"},
1993 "stats for the index"},
1996 {NULL} /* Sentinel */
1994 {NULL} /* Sentinel */
1997 };
1995 };
1998
1996
1999 static PyGetSetDef index_getset[] = {
1997 static PyGetSetDef index_getset[] = {
2000 {"nodemap", (getter)index_nodemap, NULL, "nodemap", NULL},
1998 {"nodemap", (getter)index_nodemap, NULL, "nodemap", NULL},
2001 {NULL} /* Sentinel */
1999 {NULL} /* Sentinel */
2002 };
2000 };
2003
2001
2004 static PyTypeObject indexType = {
2002 static PyTypeObject indexType = {
2005 PyVarObject_HEAD_INIT(NULL, 0) /* header */
2003 PyVarObject_HEAD_INIT(NULL, 0) /* header */
2006 "parsers.index", /* tp_name */
2004 "parsers.index", /* tp_name */
2007 sizeof(indexObject), /* tp_basicsize */
2005 sizeof(indexObject), /* tp_basicsize */
2008 0, /* tp_itemsize */
2006 0, /* tp_itemsize */
2009 (destructor)index_dealloc, /* tp_dealloc */
2007 (destructor)index_dealloc, /* tp_dealloc */
2010 0, /* tp_print */
2008 0, /* tp_print */
2011 0, /* tp_getattr */
2009 0, /* tp_getattr */
2012 0, /* tp_setattr */
2010 0, /* tp_setattr */
2013 0, /* tp_compare */
2011 0, /* tp_compare */
2014 0, /* tp_repr */
2012 0, /* tp_repr */
2015 0, /* tp_as_number */
2013 0, /* tp_as_number */
2016 &index_sequence_methods, /* tp_as_sequence */
2014 &index_sequence_methods, /* tp_as_sequence */
2017 &index_mapping_methods, /* tp_as_mapping */
2015 &index_mapping_methods, /* tp_as_mapping */
2018 0, /* tp_hash */
2016 0, /* tp_hash */
2019 0, /* tp_call */
2017 0, /* tp_call */
2020 0, /* tp_str */
2018 0, /* tp_str */
2021 0, /* tp_getattro */
2019 0, /* tp_getattro */
2022 0, /* tp_setattro */
2020 0, /* tp_setattro */
2023 0, /* tp_as_buffer */
2021 0, /* tp_as_buffer */
2024 Py_TPFLAGS_DEFAULT, /* tp_flags */
2022 Py_TPFLAGS_DEFAULT, /* tp_flags */
2025 "revlog index", /* tp_doc */
2023 "revlog index", /* tp_doc */
2026 0, /* tp_traverse */
2024 0, /* tp_traverse */
2027 0, /* tp_clear */
2025 0, /* tp_clear */
2028 0, /* tp_richcompare */
2026 0, /* tp_richcompare */
2029 0, /* tp_weaklistoffset */
2027 0, /* tp_weaklistoffset */
2030 0, /* tp_iter */
2028 0, /* tp_iter */
2031 0, /* tp_iternext */
2029 0, /* tp_iternext */
2032 index_methods, /* tp_methods */
2030 index_methods, /* tp_methods */
2033 0, /* tp_members */
2031 0, /* tp_members */
2034 index_getset, /* tp_getset */
2032 index_getset, /* tp_getset */
2035 0, /* tp_base */
2033 0, /* tp_base */
2036 0, /* tp_dict */
2034 0, /* tp_dict */
2037 0, /* tp_descr_get */
2035 0, /* tp_descr_get */
2038 0, /* tp_descr_set */
2036 0, /* tp_descr_set */
2039 0, /* tp_dictoffset */
2037 0, /* tp_dictoffset */
2040 (initproc)index_init, /* tp_init */
2038 (initproc)index_init, /* tp_init */
2041 0, /* tp_alloc */
2039 0, /* tp_alloc */
2042 };
2040 };
2043
2041
2044 /*
2042 /*
2045 * returns a tuple of the form (index, index, cache) with elements as
2043 * returns a tuple of the form (index, index, cache) with elements as
2046 * follows:
2044 * follows:
2047 *
2045 *
2048 * index: an index object that lazily parses RevlogNG records
2046 * index: an index object that lazily parses RevlogNG records
2049 * cache: if data is inlined, a tuple (0, index_file_content), else None
2047 * cache: if data is inlined, a tuple (0, index_file_content), else None
2050 * index_file_content could be a string, or a buffer
2048 * index_file_content could be a string, or a buffer
2051 *
2049 *
2052 * added complications are for backwards compatibility
2050 * added complications are for backwards compatibility
2053 */
2051 */
2054 PyObject *parse_index2(PyObject *self, PyObject *args)
2052 PyObject *parse_index2(PyObject *self, PyObject *args)
2055 {
2053 {
2056 PyObject *tuple = NULL, *cache = NULL;
2054 PyObject *tuple = NULL, *cache = NULL;
2057 indexObject *idx;
2055 indexObject *idx;
2058 int ret;
2056 int ret;
2059
2057
2060 idx = PyObject_New(indexObject, &indexType);
2058 idx = PyObject_New(indexObject, &indexType);
2061 if (idx == NULL)
2059 if (idx == NULL)
2062 goto bail;
2060 goto bail;
2063
2061
2064 ret = index_init(idx, args);
2062 ret = index_init(idx, args);
2065 if (ret == -1)
2063 if (ret == -1)
2066 goto bail;
2064 goto bail;
2067
2065
2068 if (idx->inlined) {
2066 if (idx->inlined) {
2069 cache = Py_BuildValue("iO", 0, idx->data);
2067 cache = Py_BuildValue("iO", 0, idx->data);
2070 if (cache == NULL)
2068 if (cache == NULL)
2071 goto bail;
2069 goto bail;
2072 } else {
2070 } else {
2073 cache = Py_None;
2071 cache = Py_None;
2074 Py_INCREF(cache);
2072 Py_INCREF(cache);
2075 }
2073 }
2076
2074
2077 tuple = Py_BuildValue("NN", idx, cache);
2075 tuple = Py_BuildValue("NN", idx, cache);
2078 if (!tuple)
2076 if (!tuple)
2079 goto bail;
2077 goto bail;
2080 return tuple;
2078 return tuple;
2081
2079
2082 bail:
2080 bail:
2083 Py_XDECREF(idx);
2081 Py_XDECREF(idx);
2084 Py_XDECREF(cache);
2082 Py_XDECREF(cache);
2085 Py_XDECREF(tuple);
2083 Py_XDECREF(tuple);
2086 return NULL;
2084 return NULL;
2087 }
2085 }
2088
2086
2089 void revlog_module_init(PyObject *mod)
2087 void revlog_module_init(PyObject *mod)
2090 {
2088 {
2091 indexType.tp_new = PyType_GenericNew;
2089 indexType.tp_new = PyType_GenericNew;
2092 if (PyType_Ready(&indexType) < 0)
2090 if (PyType_Ready(&indexType) < 0)
2093 return;
2091 return;
2094 Py_INCREF(&indexType);
2092 Py_INCREF(&indexType);
2095 PyModule_AddObject(mod, "index", (PyObject *)&indexType);
2093 PyModule_AddObject(mod, "index", (PyObject *)&indexType);
2096
2094
2097 nullentry = Py_BuildValue(PY23("iiiiiiis#", "iiiiiiiy#"), 0, 0, 0,
2095 nullentry = Py_BuildValue(PY23("iiiiiiis#", "iiiiiiiy#"), 0, 0, 0,
2098 -1, -1, -1, -1, nullid, 20);
2096 -1, -1, -1, -1, nullid, 20);
2099 if (nullentry)
2097 if (nullentry)
2100 PyObject_GC_UnTrack(nullentry);
2098 PyObject_GC_UnTrack(nullentry);
2101 }
2099 }
General Comments 0
You need to be logged in to leave comments. Login now