##// END OF EJS Templates
parsers: factor out most of asciilower into an internal function...
Siddharth Agarwal -
r24574:e97a00bf default
parent child Browse files
Show More
@@ -1,2516 +1,2524 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 <ctype.h>
11 #include <ctype.h>
12 #include <stddef.h>
12 #include <stddef.h>
13 #include <string.h>
13 #include <string.h>
14
14
15 #include "util.h"
15 #include "util.h"
16
16
17 static char *versionerrortext = "Python minor version mismatch";
17 static char *versionerrortext = "Python minor version mismatch";
18
18
19 static int8_t hextable[256] = {
19 static int8_t hextable[256] = {
20 -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1,
20 -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1,
21 -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1,
21 -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1,
22 -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1,
22 -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1,
23 0, 1, 2, 3, 4, 5, 6, 7, 8, 9, -1, -1, -1, -1, -1, -1, /* 0-9 */
23 0, 1, 2, 3, 4, 5, 6, 7, 8, 9, -1, -1, -1, -1, -1, -1, /* 0-9 */
24 -1, 10, 11, 12, 13, 14, 15, -1, -1, -1, -1, -1, -1, -1, -1, -1, /* A-F */
24 -1, 10, 11, 12, 13, 14, 15, -1, -1, -1, -1, -1, -1, -1, -1, -1, /* A-F */
25 -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1,
25 -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1,
26 -1, 10, 11, 12, 13, 14, 15, -1, -1, -1, -1, -1, -1, -1, -1, -1, /* a-f */
26 -1, 10, 11, 12, 13, 14, 15, -1, -1, -1, -1, -1, -1, -1, -1, -1, /* a-f */
27 -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1,
27 -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1,
28 -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1,
28 -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1,
29 -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1,
29 -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1,
30 -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1,
30 -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1,
31 -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1,
31 -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1,
32 -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1,
32 -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1,
33 -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1,
33 -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1,
34 -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1,
34 -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1,
35 -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1
35 -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1
36 };
36 };
37
37
38 static char lowertable[128] = {
38 static char lowertable[128] = {
39 '\x00', '\x01', '\x02', '\x03', '\x04', '\x05', '\x06', '\x07',
39 '\x00', '\x01', '\x02', '\x03', '\x04', '\x05', '\x06', '\x07',
40 '\x08', '\x09', '\x0a', '\x0b', '\x0c', '\x0d', '\x0e', '\x0f',
40 '\x08', '\x09', '\x0a', '\x0b', '\x0c', '\x0d', '\x0e', '\x0f',
41 '\x10', '\x11', '\x12', '\x13', '\x14', '\x15', '\x16', '\x17',
41 '\x10', '\x11', '\x12', '\x13', '\x14', '\x15', '\x16', '\x17',
42 '\x18', '\x19', '\x1a', '\x1b', '\x1c', '\x1d', '\x1e', '\x1f',
42 '\x18', '\x19', '\x1a', '\x1b', '\x1c', '\x1d', '\x1e', '\x1f',
43 '\x20', '\x21', '\x22', '\x23', '\x24', '\x25', '\x26', '\x27',
43 '\x20', '\x21', '\x22', '\x23', '\x24', '\x25', '\x26', '\x27',
44 '\x28', '\x29', '\x2a', '\x2b', '\x2c', '\x2d', '\x2e', '\x2f',
44 '\x28', '\x29', '\x2a', '\x2b', '\x2c', '\x2d', '\x2e', '\x2f',
45 '\x30', '\x31', '\x32', '\x33', '\x34', '\x35', '\x36', '\x37',
45 '\x30', '\x31', '\x32', '\x33', '\x34', '\x35', '\x36', '\x37',
46 '\x38', '\x39', '\x3a', '\x3b', '\x3c', '\x3d', '\x3e', '\x3f',
46 '\x38', '\x39', '\x3a', '\x3b', '\x3c', '\x3d', '\x3e', '\x3f',
47 '\x40',
47 '\x40',
48 '\x61', '\x62', '\x63', '\x64', '\x65', '\x66', '\x67', /* A-G */
48 '\x61', '\x62', '\x63', '\x64', '\x65', '\x66', '\x67', /* A-G */
49 '\x68', '\x69', '\x6a', '\x6b', '\x6c', '\x6d', '\x6e', '\x6f', /* H-O */
49 '\x68', '\x69', '\x6a', '\x6b', '\x6c', '\x6d', '\x6e', '\x6f', /* H-O */
50 '\x70', '\x71', '\x72', '\x73', '\x74', '\x75', '\x76', '\x77', /* P-W */
50 '\x70', '\x71', '\x72', '\x73', '\x74', '\x75', '\x76', '\x77', /* P-W */
51 '\x78', '\x79', '\x7a', /* X-Z */
51 '\x78', '\x79', '\x7a', /* X-Z */
52 '\x5b', '\x5c', '\x5d', '\x5e', '\x5f',
52 '\x5b', '\x5c', '\x5d', '\x5e', '\x5f',
53 '\x60', '\x61', '\x62', '\x63', '\x64', '\x65', '\x66', '\x67',
53 '\x60', '\x61', '\x62', '\x63', '\x64', '\x65', '\x66', '\x67',
54 '\x68', '\x69', '\x6a', '\x6b', '\x6c', '\x6d', '\x6e', '\x6f',
54 '\x68', '\x69', '\x6a', '\x6b', '\x6c', '\x6d', '\x6e', '\x6f',
55 '\x70', '\x71', '\x72', '\x73', '\x74', '\x75', '\x76', '\x77',
55 '\x70', '\x71', '\x72', '\x73', '\x74', '\x75', '\x76', '\x77',
56 '\x78', '\x79', '\x7a', '\x7b', '\x7c', '\x7d', '\x7e', '\x7f'
56 '\x78', '\x79', '\x7a', '\x7b', '\x7c', '\x7d', '\x7e', '\x7f'
57 };
57 };
58
58
59 static inline int hexdigit(const char *p, Py_ssize_t off)
59 static inline int hexdigit(const char *p, Py_ssize_t off)
60 {
60 {
61 int8_t val = hextable[(unsigned char)p[off]];
61 int8_t val = hextable[(unsigned char)p[off]];
62
62
63 if (val >= 0) {
63 if (val >= 0) {
64 return val;
64 return val;
65 }
65 }
66
66
67 PyErr_SetString(PyExc_ValueError, "input contains non-hex character");
67 PyErr_SetString(PyExc_ValueError, "input contains non-hex character");
68 return 0;
68 return 0;
69 }
69 }
70
70
71 /*
71 /*
72 * Turn a hex-encoded string into binary.
72 * Turn a hex-encoded string into binary.
73 */
73 */
74 PyObject *unhexlify(const char *str, int len)
74 PyObject *unhexlify(const char *str, int len)
75 {
75 {
76 PyObject *ret;
76 PyObject *ret;
77 char *d;
77 char *d;
78 int i;
78 int i;
79
79
80 ret = PyBytes_FromStringAndSize(NULL, len / 2);
80 ret = PyBytes_FromStringAndSize(NULL, len / 2);
81
81
82 if (!ret)
82 if (!ret)
83 return NULL;
83 return NULL;
84
84
85 d = PyBytes_AsString(ret);
85 d = PyBytes_AsString(ret);
86
86
87 for (i = 0; i < len;) {
87 for (i = 0; i < len;) {
88 int hi = hexdigit(str, i++);
88 int hi = hexdigit(str, i++);
89 int lo = hexdigit(str, i++);
89 int lo = hexdigit(str, i++);
90 *d++ = (hi << 4) | lo;
90 *d++ = (hi << 4) | lo;
91 }
91 }
92
92
93 return ret;
93 return ret;
94 }
94 }
95
95
96 static PyObject *asciilower(PyObject *self, PyObject *args)
96 static inline PyObject *_asciilower(PyObject *str_obj)
97 {
97 {
98 char *str, *newstr;
98 char *str, *newstr;
99 int i, len;
99 Py_ssize_t i, len;
100 PyObject *newobj = NULL;
100 PyObject *newobj = NULL;
101
101
102 if (!PyArg_ParseTuple(args, "s#", &str, &len))
102 str = PyBytes_AS_STRING(str_obj);
103 goto quit;
103 len = PyBytes_GET_SIZE(str_obj);
104
104
105 newobj = PyBytes_FromStringAndSize(NULL, len);
105 newobj = PyBytes_FromStringAndSize(NULL, len);
106 if (!newobj)
106 if (!newobj)
107 goto quit;
107 goto quit;
108
108
109 newstr = PyBytes_AS_STRING(newobj);
109 newstr = PyBytes_AS_STRING(newobj);
110
110
111 for (i = 0; i < len; i++) {
111 for (i = 0; i < len; i++) {
112 char c = str[i];
112 char c = str[i];
113 if (c & 0x80) {
113 if (c & 0x80) {
114 PyObject *err = PyUnicodeDecodeError_Create(
114 PyObject *err = PyUnicodeDecodeError_Create(
115 "ascii", str, len, i, (i + 1),
115 "ascii", str, len, i, (i + 1),
116 "unexpected code byte");
116 "unexpected code byte");
117 PyErr_SetObject(PyExc_UnicodeDecodeError, err);
117 PyErr_SetObject(PyExc_UnicodeDecodeError, err);
118 Py_XDECREF(err);
118 Py_XDECREF(err);
119 goto quit;
119 goto quit;
120 }
120 }
121 newstr[i] = lowertable[(unsigned char)c];
121 newstr[i] = lowertable[(unsigned char)c];
122 }
122 }
123
123
124 return newobj;
124 return newobj;
125 quit:
125 quit:
126 Py_XDECREF(newobj);
126 Py_XDECREF(newobj);
127 return NULL;
127 return NULL;
128 }
128 }
129
129
130 static PyObject *asciilower(PyObject *self, PyObject *args)
131 {
132 PyObject *str_obj;
133 if (!PyArg_ParseTuple(args, "O!:asciilower", &PyBytes_Type, &str_obj))
134 return NULL;
135 return _asciilower(str_obj);
136 }
137
130 /*
138 /*
131 * This code assumes that a manifest is stitched together with newline
139 * This code assumes that a manifest is stitched together with newline
132 * ('\n') characters.
140 * ('\n') characters.
133 */
141 */
134 static PyObject *parse_manifest(PyObject *self, PyObject *args)
142 static PyObject *parse_manifest(PyObject *self, PyObject *args)
135 {
143 {
136 PyObject *mfdict, *fdict;
144 PyObject *mfdict, *fdict;
137 char *str, *start, *end;
145 char *str, *start, *end;
138 int len;
146 int len;
139
147
140 if (!PyArg_ParseTuple(args, "O!O!s#:parse_manifest",
148 if (!PyArg_ParseTuple(args, "O!O!s#:parse_manifest",
141 &PyDict_Type, &mfdict,
149 &PyDict_Type, &mfdict,
142 &PyDict_Type, &fdict,
150 &PyDict_Type, &fdict,
143 &str, &len))
151 &str, &len))
144 goto quit;
152 goto quit;
145
153
146 start = str;
154 start = str;
147 end = str + len;
155 end = str + len;
148 while (start < end) {
156 while (start < end) {
149 PyObject *file = NULL, *node = NULL;
157 PyObject *file = NULL, *node = NULL;
150 PyObject *flags = NULL;
158 PyObject *flags = NULL;
151 char *zero = NULL, *newline = NULL;
159 char *zero = NULL, *newline = NULL;
152 ptrdiff_t nlen;
160 ptrdiff_t nlen;
153
161
154 zero = memchr(start, '\0', end - start);
162 zero = memchr(start, '\0', end - start);
155 if (!zero) {
163 if (!zero) {
156 PyErr_SetString(PyExc_ValueError,
164 PyErr_SetString(PyExc_ValueError,
157 "manifest entry has no separator");
165 "manifest entry has no separator");
158 goto quit;
166 goto quit;
159 }
167 }
160
168
161 newline = memchr(zero + 1, '\n', end - (zero + 1));
169 newline = memchr(zero + 1, '\n', end - (zero + 1));
162 if (!newline) {
170 if (!newline) {
163 PyErr_SetString(PyExc_ValueError,
171 PyErr_SetString(PyExc_ValueError,
164 "manifest contains trailing garbage");
172 "manifest contains trailing garbage");
165 goto quit;
173 goto quit;
166 }
174 }
167
175
168 file = PyBytes_FromStringAndSize(start, zero - start);
176 file = PyBytes_FromStringAndSize(start, zero - start);
169
177
170 if (!file)
178 if (!file)
171 goto bail;
179 goto bail;
172
180
173 nlen = newline - zero - 1;
181 nlen = newline - zero - 1;
174
182
175 node = unhexlify(zero + 1, nlen > 40 ? 40 : (int)nlen);
183 node = unhexlify(zero + 1, nlen > 40 ? 40 : (int)nlen);
176 if (!node)
184 if (!node)
177 goto bail;
185 goto bail;
178
186
179 if (nlen > 40) {
187 if (nlen > 40) {
180 flags = PyBytes_FromStringAndSize(zero + 41,
188 flags = PyBytes_FromStringAndSize(zero + 41,
181 nlen - 40);
189 nlen - 40);
182 if (!flags)
190 if (!flags)
183 goto bail;
191 goto bail;
184
192
185 if (PyDict_SetItem(fdict, file, flags) == -1)
193 if (PyDict_SetItem(fdict, file, flags) == -1)
186 goto bail;
194 goto bail;
187 }
195 }
188
196
189 if (PyDict_SetItem(mfdict, file, node) == -1)
197 if (PyDict_SetItem(mfdict, file, node) == -1)
190 goto bail;
198 goto bail;
191
199
192 start = newline + 1;
200 start = newline + 1;
193
201
194 Py_XDECREF(flags);
202 Py_XDECREF(flags);
195 Py_XDECREF(node);
203 Py_XDECREF(node);
196 Py_XDECREF(file);
204 Py_XDECREF(file);
197 continue;
205 continue;
198 bail:
206 bail:
199 Py_XDECREF(flags);
207 Py_XDECREF(flags);
200 Py_XDECREF(node);
208 Py_XDECREF(node);
201 Py_XDECREF(file);
209 Py_XDECREF(file);
202 goto quit;
210 goto quit;
203 }
211 }
204
212
205 Py_INCREF(Py_None);
213 Py_INCREF(Py_None);
206 return Py_None;
214 return Py_None;
207 quit:
215 quit:
208 return NULL;
216 return NULL;
209 }
217 }
210
218
211 static inline dirstateTupleObject *make_dirstate_tuple(char state, int mode,
219 static inline dirstateTupleObject *make_dirstate_tuple(char state, int mode,
212 int size, int mtime)
220 int size, int mtime)
213 {
221 {
214 dirstateTupleObject *t = PyObject_New(dirstateTupleObject,
222 dirstateTupleObject *t = PyObject_New(dirstateTupleObject,
215 &dirstateTupleType);
223 &dirstateTupleType);
216 if (!t)
224 if (!t)
217 return NULL;
225 return NULL;
218 t->state = state;
226 t->state = state;
219 t->mode = mode;
227 t->mode = mode;
220 t->size = size;
228 t->size = size;
221 t->mtime = mtime;
229 t->mtime = mtime;
222 return t;
230 return t;
223 }
231 }
224
232
225 static PyObject *dirstate_tuple_new(PyTypeObject *subtype, PyObject *args,
233 static PyObject *dirstate_tuple_new(PyTypeObject *subtype, PyObject *args,
226 PyObject *kwds)
234 PyObject *kwds)
227 {
235 {
228 /* We do all the initialization here and not a tp_init function because
236 /* We do all the initialization here and not a tp_init function because
229 * dirstate_tuple is immutable. */
237 * dirstate_tuple is immutable. */
230 dirstateTupleObject *t;
238 dirstateTupleObject *t;
231 char state;
239 char state;
232 int size, mode, mtime;
240 int size, mode, mtime;
233 if (!PyArg_ParseTuple(args, "ciii", &state, &mode, &size, &mtime))
241 if (!PyArg_ParseTuple(args, "ciii", &state, &mode, &size, &mtime))
234 return NULL;
242 return NULL;
235
243
236 t = (dirstateTupleObject *)subtype->tp_alloc(subtype, 1);
244 t = (dirstateTupleObject *)subtype->tp_alloc(subtype, 1);
237 if (!t)
245 if (!t)
238 return NULL;
246 return NULL;
239 t->state = state;
247 t->state = state;
240 t->mode = mode;
248 t->mode = mode;
241 t->size = size;
249 t->size = size;
242 t->mtime = mtime;
250 t->mtime = mtime;
243
251
244 return (PyObject *)t;
252 return (PyObject *)t;
245 }
253 }
246
254
247 static void dirstate_tuple_dealloc(PyObject *o)
255 static void dirstate_tuple_dealloc(PyObject *o)
248 {
256 {
249 PyObject_Del(o);
257 PyObject_Del(o);
250 }
258 }
251
259
252 static Py_ssize_t dirstate_tuple_length(PyObject *o)
260 static Py_ssize_t dirstate_tuple_length(PyObject *o)
253 {
261 {
254 return 4;
262 return 4;
255 }
263 }
256
264
257 static PyObject *dirstate_tuple_item(PyObject *o, Py_ssize_t i)
265 static PyObject *dirstate_tuple_item(PyObject *o, Py_ssize_t i)
258 {
266 {
259 dirstateTupleObject *t = (dirstateTupleObject *)o;
267 dirstateTupleObject *t = (dirstateTupleObject *)o;
260 switch (i) {
268 switch (i) {
261 case 0:
269 case 0:
262 return PyBytes_FromStringAndSize(&t->state, 1);
270 return PyBytes_FromStringAndSize(&t->state, 1);
263 case 1:
271 case 1:
264 return PyInt_FromLong(t->mode);
272 return PyInt_FromLong(t->mode);
265 case 2:
273 case 2:
266 return PyInt_FromLong(t->size);
274 return PyInt_FromLong(t->size);
267 case 3:
275 case 3:
268 return PyInt_FromLong(t->mtime);
276 return PyInt_FromLong(t->mtime);
269 default:
277 default:
270 PyErr_SetString(PyExc_IndexError, "index out of range");
278 PyErr_SetString(PyExc_IndexError, "index out of range");
271 return NULL;
279 return NULL;
272 }
280 }
273 }
281 }
274
282
275 static PySequenceMethods dirstate_tuple_sq = {
283 static PySequenceMethods dirstate_tuple_sq = {
276 dirstate_tuple_length, /* sq_length */
284 dirstate_tuple_length, /* sq_length */
277 0, /* sq_concat */
285 0, /* sq_concat */
278 0, /* sq_repeat */
286 0, /* sq_repeat */
279 dirstate_tuple_item, /* sq_item */
287 dirstate_tuple_item, /* sq_item */
280 0, /* sq_ass_item */
288 0, /* sq_ass_item */
281 0, /* sq_contains */
289 0, /* sq_contains */
282 0, /* sq_inplace_concat */
290 0, /* sq_inplace_concat */
283 0 /* sq_inplace_repeat */
291 0 /* sq_inplace_repeat */
284 };
292 };
285
293
286 PyTypeObject dirstateTupleType = {
294 PyTypeObject dirstateTupleType = {
287 PyVarObject_HEAD_INIT(NULL, 0)
295 PyVarObject_HEAD_INIT(NULL, 0)
288 "dirstate_tuple", /* tp_name */
296 "dirstate_tuple", /* tp_name */
289 sizeof(dirstateTupleObject),/* tp_basicsize */
297 sizeof(dirstateTupleObject),/* tp_basicsize */
290 0, /* tp_itemsize */
298 0, /* tp_itemsize */
291 (destructor)dirstate_tuple_dealloc, /* tp_dealloc */
299 (destructor)dirstate_tuple_dealloc, /* tp_dealloc */
292 0, /* tp_print */
300 0, /* tp_print */
293 0, /* tp_getattr */
301 0, /* tp_getattr */
294 0, /* tp_setattr */
302 0, /* tp_setattr */
295 0, /* tp_compare */
303 0, /* tp_compare */
296 0, /* tp_repr */
304 0, /* tp_repr */
297 0, /* tp_as_number */
305 0, /* tp_as_number */
298 &dirstate_tuple_sq, /* tp_as_sequence */
306 &dirstate_tuple_sq, /* tp_as_sequence */
299 0, /* tp_as_mapping */
307 0, /* tp_as_mapping */
300 0, /* tp_hash */
308 0, /* tp_hash */
301 0, /* tp_call */
309 0, /* tp_call */
302 0, /* tp_str */
310 0, /* tp_str */
303 0, /* tp_getattro */
311 0, /* tp_getattro */
304 0, /* tp_setattro */
312 0, /* tp_setattro */
305 0, /* tp_as_buffer */
313 0, /* tp_as_buffer */
306 Py_TPFLAGS_DEFAULT, /* tp_flags */
314 Py_TPFLAGS_DEFAULT, /* tp_flags */
307 "dirstate tuple", /* tp_doc */
315 "dirstate tuple", /* tp_doc */
308 0, /* tp_traverse */
316 0, /* tp_traverse */
309 0, /* tp_clear */
317 0, /* tp_clear */
310 0, /* tp_richcompare */
318 0, /* tp_richcompare */
311 0, /* tp_weaklistoffset */
319 0, /* tp_weaklistoffset */
312 0, /* tp_iter */
320 0, /* tp_iter */
313 0, /* tp_iternext */
321 0, /* tp_iternext */
314 0, /* tp_methods */
322 0, /* tp_methods */
315 0, /* tp_members */
323 0, /* tp_members */
316 0, /* tp_getset */
324 0, /* tp_getset */
317 0, /* tp_base */
325 0, /* tp_base */
318 0, /* tp_dict */
326 0, /* tp_dict */
319 0, /* tp_descr_get */
327 0, /* tp_descr_get */
320 0, /* tp_descr_set */
328 0, /* tp_descr_set */
321 0, /* tp_dictoffset */
329 0, /* tp_dictoffset */
322 0, /* tp_init */
330 0, /* tp_init */
323 0, /* tp_alloc */
331 0, /* tp_alloc */
324 dirstate_tuple_new, /* tp_new */
332 dirstate_tuple_new, /* tp_new */
325 };
333 };
326
334
327 static PyObject *parse_dirstate(PyObject *self, PyObject *args)
335 static PyObject *parse_dirstate(PyObject *self, PyObject *args)
328 {
336 {
329 PyObject *dmap, *cmap, *parents = NULL, *ret = NULL;
337 PyObject *dmap, *cmap, *parents = NULL, *ret = NULL;
330 PyObject *fname = NULL, *cname = NULL, *entry = NULL;
338 PyObject *fname = NULL, *cname = NULL, *entry = NULL;
331 char state, *cur, *str, *cpos;
339 char state, *cur, *str, *cpos;
332 int mode, size, mtime;
340 int mode, size, mtime;
333 unsigned int flen, len, pos = 40;
341 unsigned int flen, len, pos = 40;
334 int readlen;
342 int readlen;
335
343
336 if (!PyArg_ParseTuple(args, "O!O!s#:parse_dirstate",
344 if (!PyArg_ParseTuple(args, "O!O!s#:parse_dirstate",
337 &PyDict_Type, &dmap,
345 &PyDict_Type, &dmap,
338 &PyDict_Type, &cmap,
346 &PyDict_Type, &cmap,
339 &str, &readlen))
347 &str, &readlen))
340 goto quit;
348 goto quit;
341
349
342 if (readlen < 0)
350 if (readlen < 0)
343 goto quit;
351 goto quit;
344
352
345 len = readlen;
353 len = readlen;
346
354
347 /* read parents */
355 /* read parents */
348 if (len < 40)
356 if (len < 40)
349 goto quit;
357 goto quit;
350
358
351 parents = Py_BuildValue("s#s#", str, 20, str + 20, 20);
359 parents = Py_BuildValue("s#s#", str, 20, str + 20, 20);
352 if (!parents)
360 if (!parents)
353 goto quit;
361 goto quit;
354
362
355 /* read filenames */
363 /* read filenames */
356 while (pos >= 40 && pos < len) {
364 while (pos >= 40 && pos < len) {
357 cur = str + pos;
365 cur = str + pos;
358 /* unpack header */
366 /* unpack header */
359 state = *cur;
367 state = *cur;
360 mode = getbe32(cur + 1);
368 mode = getbe32(cur + 1);
361 size = getbe32(cur + 5);
369 size = getbe32(cur + 5);
362 mtime = getbe32(cur + 9);
370 mtime = getbe32(cur + 9);
363 flen = getbe32(cur + 13);
371 flen = getbe32(cur + 13);
364 pos += 17;
372 pos += 17;
365 cur += 17;
373 cur += 17;
366 if (flen > len - pos) {
374 if (flen > len - pos) {
367 PyErr_SetString(PyExc_ValueError, "overflow in dirstate");
375 PyErr_SetString(PyExc_ValueError, "overflow in dirstate");
368 goto quit;
376 goto quit;
369 }
377 }
370
378
371 entry = (PyObject *)make_dirstate_tuple(state, mode, size,
379 entry = (PyObject *)make_dirstate_tuple(state, mode, size,
372 mtime);
380 mtime);
373 cpos = memchr(cur, 0, flen);
381 cpos = memchr(cur, 0, flen);
374 if (cpos) {
382 if (cpos) {
375 fname = PyBytes_FromStringAndSize(cur, cpos - cur);
383 fname = PyBytes_FromStringAndSize(cur, cpos - cur);
376 cname = PyBytes_FromStringAndSize(cpos + 1,
384 cname = PyBytes_FromStringAndSize(cpos + 1,
377 flen - (cpos - cur) - 1);
385 flen - (cpos - cur) - 1);
378 if (!fname || !cname ||
386 if (!fname || !cname ||
379 PyDict_SetItem(cmap, fname, cname) == -1 ||
387 PyDict_SetItem(cmap, fname, cname) == -1 ||
380 PyDict_SetItem(dmap, fname, entry) == -1)
388 PyDict_SetItem(dmap, fname, entry) == -1)
381 goto quit;
389 goto quit;
382 Py_DECREF(cname);
390 Py_DECREF(cname);
383 } else {
391 } else {
384 fname = PyBytes_FromStringAndSize(cur, flen);
392 fname = PyBytes_FromStringAndSize(cur, flen);
385 if (!fname ||
393 if (!fname ||
386 PyDict_SetItem(dmap, fname, entry) == -1)
394 PyDict_SetItem(dmap, fname, entry) == -1)
387 goto quit;
395 goto quit;
388 }
396 }
389 Py_DECREF(fname);
397 Py_DECREF(fname);
390 Py_DECREF(entry);
398 Py_DECREF(entry);
391 fname = cname = entry = NULL;
399 fname = cname = entry = NULL;
392 pos += flen;
400 pos += flen;
393 }
401 }
394
402
395 ret = parents;
403 ret = parents;
396 Py_INCREF(ret);
404 Py_INCREF(ret);
397 quit:
405 quit:
398 Py_XDECREF(fname);
406 Py_XDECREF(fname);
399 Py_XDECREF(cname);
407 Py_XDECREF(cname);
400 Py_XDECREF(entry);
408 Py_XDECREF(entry);
401 Py_XDECREF(parents);
409 Py_XDECREF(parents);
402 return ret;
410 return ret;
403 }
411 }
404
412
405 /*
413 /*
406 * Efficiently pack a dirstate object into its on-disk format.
414 * Efficiently pack a dirstate object into its on-disk format.
407 */
415 */
408 static PyObject *pack_dirstate(PyObject *self, PyObject *args)
416 static PyObject *pack_dirstate(PyObject *self, PyObject *args)
409 {
417 {
410 PyObject *packobj = NULL;
418 PyObject *packobj = NULL;
411 PyObject *map, *copymap, *pl, *mtime_unset = NULL;
419 PyObject *map, *copymap, *pl, *mtime_unset = NULL;
412 Py_ssize_t nbytes, pos, l;
420 Py_ssize_t nbytes, pos, l;
413 PyObject *k, *v = NULL, *pn;
421 PyObject *k, *v = NULL, *pn;
414 char *p, *s;
422 char *p, *s;
415 double now;
423 double now;
416
424
417 if (!PyArg_ParseTuple(args, "O!O!Od:pack_dirstate",
425 if (!PyArg_ParseTuple(args, "O!O!Od:pack_dirstate",
418 &PyDict_Type, &map, &PyDict_Type, &copymap,
426 &PyDict_Type, &map, &PyDict_Type, &copymap,
419 &pl, &now))
427 &pl, &now))
420 return NULL;
428 return NULL;
421
429
422 if (!PySequence_Check(pl) || PySequence_Size(pl) != 2) {
430 if (!PySequence_Check(pl) || PySequence_Size(pl) != 2) {
423 PyErr_SetString(PyExc_TypeError, "expected 2-element sequence");
431 PyErr_SetString(PyExc_TypeError, "expected 2-element sequence");
424 return NULL;
432 return NULL;
425 }
433 }
426
434
427 /* Figure out how much we need to allocate. */
435 /* Figure out how much we need to allocate. */
428 for (nbytes = 40, pos = 0; PyDict_Next(map, &pos, &k, &v);) {
436 for (nbytes = 40, pos = 0; PyDict_Next(map, &pos, &k, &v);) {
429 PyObject *c;
437 PyObject *c;
430 if (!PyString_Check(k)) {
438 if (!PyString_Check(k)) {
431 PyErr_SetString(PyExc_TypeError, "expected string key");
439 PyErr_SetString(PyExc_TypeError, "expected string key");
432 goto bail;
440 goto bail;
433 }
441 }
434 nbytes += PyString_GET_SIZE(k) + 17;
442 nbytes += PyString_GET_SIZE(k) + 17;
435 c = PyDict_GetItem(copymap, k);
443 c = PyDict_GetItem(copymap, k);
436 if (c) {
444 if (c) {
437 if (!PyString_Check(c)) {
445 if (!PyString_Check(c)) {
438 PyErr_SetString(PyExc_TypeError,
446 PyErr_SetString(PyExc_TypeError,
439 "expected string key");
447 "expected string key");
440 goto bail;
448 goto bail;
441 }
449 }
442 nbytes += PyString_GET_SIZE(c) + 1;
450 nbytes += PyString_GET_SIZE(c) + 1;
443 }
451 }
444 }
452 }
445
453
446 packobj = PyString_FromStringAndSize(NULL, nbytes);
454 packobj = PyString_FromStringAndSize(NULL, nbytes);
447 if (packobj == NULL)
455 if (packobj == NULL)
448 goto bail;
456 goto bail;
449
457
450 p = PyString_AS_STRING(packobj);
458 p = PyString_AS_STRING(packobj);
451
459
452 pn = PySequence_ITEM(pl, 0);
460 pn = PySequence_ITEM(pl, 0);
453 if (PyString_AsStringAndSize(pn, &s, &l) == -1 || l != 20) {
461 if (PyString_AsStringAndSize(pn, &s, &l) == -1 || l != 20) {
454 PyErr_SetString(PyExc_TypeError, "expected a 20-byte hash");
462 PyErr_SetString(PyExc_TypeError, "expected a 20-byte hash");
455 goto bail;
463 goto bail;
456 }
464 }
457 memcpy(p, s, l);
465 memcpy(p, s, l);
458 p += 20;
466 p += 20;
459 pn = PySequence_ITEM(pl, 1);
467 pn = PySequence_ITEM(pl, 1);
460 if (PyString_AsStringAndSize(pn, &s, &l) == -1 || l != 20) {
468 if (PyString_AsStringAndSize(pn, &s, &l) == -1 || l != 20) {
461 PyErr_SetString(PyExc_TypeError, "expected a 20-byte hash");
469 PyErr_SetString(PyExc_TypeError, "expected a 20-byte hash");
462 goto bail;
470 goto bail;
463 }
471 }
464 memcpy(p, s, l);
472 memcpy(p, s, l);
465 p += 20;
473 p += 20;
466
474
467 for (pos = 0; PyDict_Next(map, &pos, &k, &v); ) {
475 for (pos = 0; PyDict_Next(map, &pos, &k, &v); ) {
468 dirstateTupleObject *tuple;
476 dirstateTupleObject *tuple;
469 char state;
477 char state;
470 uint32_t mode, size, mtime;
478 uint32_t mode, size, mtime;
471 Py_ssize_t len, l;
479 Py_ssize_t len, l;
472 PyObject *o;
480 PyObject *o;
473 char *t;
481 char *t;
474
482
475 if (!dirstate_tuple_check(v)) {
483 if (!dirstate_tuple_check(v)) {
476 PyErr_SetString(PyExc_TypeError,
484 PyErr_SetString(PyExc_TypeError,
477 "expected a dirstate tuple");
485 "expected a dirstate tuple");
478 goto bail;
486 goto bail;
479 }
487 }
480 tuple = (dirstateTupleObject *)v;
488 tuple = (dirstateTupleObject *)v;
481
489
482 state = tuple->state;
490 state = tuple->state;
483 mode = tuple->mode;
491 mode = tuple->mode;
484 size = tuple->size;
492 size = tuple->size;
485 mtime = tuple->mtime;
493 mtime = tuple->mtime;
486 if (state == 'n' && mtime == (uint32_t)now) {
494 if (state == 'n' && mtime == (uint32_t)now) {
487 /* See pure/parsers.py:pack_dirstate for why we do
495 /* See pure/parsers.py:pack_dirstate for why we do
488 * this. */
496 * this. */
489 mtime = -1;
497 mtime = -1;
490 mtime_unset = (PyObject *)make_dirstate_tuple(
498 mtime_unset = (PyObject *)make_dirstate_tuple(
491 state, mode, size, mtime);
499 state, mode, size, mtime);
492 if (!mtime_unset)
500 if (!mtime_unset)
493 goto bail;
501 goto bail;
494 if (PyDict_SetItem(map, k, mtime_unset) == -1)
502 if (PyDict_SetItem(map, k, mtime_unset) == -1)
495 goto bail;
503 goto bail;
496 Py_DECREF(mtime_unset);
504 Py_DECREF(mtime_unset);
497 mtime_unset = NULL;
505 mtime_unset = NULL;
498 }
506 }
499 *p++ = state;
507 *p++ = state;
500 putbe32(mode, p);
508 putbe32(mode, p);
501 putbe32(size, p + 4);
509 putbe32(size, p + 4);
502 putbe32(mtime, p + 8);
510 putbe32(mtime, p + 8);
503 t = p + 12;
511 t = p + 12;
504 p += 16;
512 p += 16;
505 len = PyString_GET_SIZE(k);
513 len = PyString_GET_SIZE(k);
506 memcpy(p, PyString_AS_STRING(k), len);
514 memcpy(p, PyString_AS_STRING(k), len);
507 p += len;
515 p += len;
508 o = PyDict_GetItem(copymap, k);
516 o = PyDict_GetItem(copymap, k);
509 if (o) {
517 if (o) {
510 *p++ = '\0';
518 *p++ = '\0';
511 l = PyString_GET_SIZE(o);
519 l = PyString_GET_SIZE(o);
512 memcpy(p, PyString_AS_STRING(o), l);
520 memcpy(p, PyString_AS_STRING(o), l);
513 p += l;
521 p += l;
514 len += l + 1;
522 len += l + 1;
515 }
523 }
516 putbe32((uint32_t)len, t);
524 putbe32((uint32_t)len, t);
517 }
525 }
518
526
519 pos = p - PyString_AS_STRING(packobj);
527 pos = p - PyString_AS_STRING(packobj);
520 if (pos != nbytes) {
528 if (pos != nbytes) {
521 PyErr_Format(PyExc_SystemError, "bad dirstate size: %ld != %ld",
529 PyErr_Format(PyExc_SystemError, "bad dirstate size: %ld != %ld",
522 (long)pos, (long)nbytes);
530 (long)pos, (long)nbytes);
523 goto bail;
531 goto bail;
524 }
532 }
525
533
526 return packobj;
534 return packobj;
527 bail:
535 bail:
528 Py_XDECREF(mtime_unset);
536 Py_XDECREF(mtime_unset);
529 Py_XDECREF(packobj);
537 Py_XDECREF(packobj);
530 Py_XDECREF(v);
538 Py_XDECREF(v);
531 return NULL;
539 return NULL;
532 }
540 }
533
541
534 /*
542 /*
535 * A base-16 trie for fast node->rev mapping.
543 * A base-16 trie for fast node->rev mapping.
536 *
544 *
537 * Positive value is index of the next node in the trie
545 * Positive value is index of the next node in the trie
538 * Negative value is a leaf: -(rev + 1)
546 * Negative value is a leaf: -(rev + 1)
539 * Zero is empty
547 * Zero is empty
540 */
548 */
541 typedef struct {
549 typedef struct {
542 int children[16];
550 int children[16];
543 } nodetree;
551 } nodetree;
544
552
545 /*
553 /*
546 * This class has two behaviours.
554 * This class has two behaviours.
547 *
555 *
548 * When used in a list-like way (with integer keys), we decode an
556 * When used in a list-like way (with integer keys), we decode an
549 * entry in a RevlogNG index file on demand. Our last entry is a
557 * entry in a RevlogNG index file on demand. Our last entry is a
550 * sentinel, always a nullid. We have limited support for
558 * sentinel, always a nullid. We have limited support for
551 * integer-keyed insert and delete, only at elements right before the
559 * integer-keyed insert and delete, only at elements right before the
552 * sentinel.
560 * sentinel.
553 *
561 *
554 * With string keys, we lazily perform a reverse mapping from node to
562 * With string keys, we lazily perform a reverse mapping from node to
555 * rev, using a base-16 trie.
563 * rev, using a base-16 trie.
556 */
564 */
557 typedef struct {
565 typedef struct {
558 PyObject_HEAD
566 PyObject_HEAD
559 /* Type-specific fields go here. */
567 /* Type-specific fields go here. */
560 PyObject *data; /* raw bytes of index */
568 PyObject *data; /* raw bytes of index */
561 PyObject **cache; /* cached tuples */
569 PyObject **cache; /* cached tuples */
562 const char **offsets; /* populated on demand */
570 const char **offsets; /* populated on demand */
563 Py_ssize_t raw_length; /* original number of elements */
571 Py_ssize_t raw_length; /* original number of elements */
564 Py_ssize_t length; /* current number of elements */
572 Py_ssize_t length; /* current number of elements */
565 PyObject *added; /* populated on demand */
573 PyObject *added; /* populated on demand */
566 PyObject *headrevs; /* cache, invalidated on changes */
574 PyObject *headrevs; /* cache, invalidated on changes */
567 PyObject *filteredrevs;/* filtered revs set */
575 PyObject *filteredrevs;/* filtered revs set */
568 nodetree *nt; /* base-16 trie */
576 nodetree *nt; /* base-16 trie */
569 int ntlength; /* # nodes in use */
577 int ntlength; /* # nodes in use */
570 int ntcapacity; /* # nodes allocated */
578 int ntcapacity; /* # nodes allocated */
571 int ntdepth; /* maximum depth of tree */
579 int ntdepth; /* maximum depth of tree */
572 int ntsplits; /* # splits performed */
580 int ntsplits; /* # splits performed */
573 int ntrev; /* last rev scanned */
581 int ntrev; /* last rev scanned */
574 int ntlookups; /* # lookups */
582 int ntlookups; /* # lookups */
575 int ntmisses; /* # lookups that miss the cache */
583 int ntmisses; /* # lookups that miss the cache */
576 int inlined;
584 int inlined;
577 } indexObject;
585 } indexObject;
578
586
579 static Py_ssize_t index_length(const indexObject *self)
587 static Py_ssize_t index_length(const indexObject *self)
580 {
588 {
581 if (self->added == NULL)
589 if (self->added == NULL)
582 return self->length;
590 return self->length;
583 return self->length + PyList_GET_SIZE(self->added);
591 return self->length + PyList_GET_SIZE(self->added);
584 }
592 }
585
593
586 static PyObject *nullentry;
594 static PyObject *nullentry;
587 static const char nullid[20];
595 static const char nullid[20];
588
596
589 static Py_ssize_t inline_scan(indexObject *self, const char **offsets);
597 static Py_ssize_t inline_scan(indexObject *self, const char **offsets);
590
598
591 #if LONG_MAX == 0x7fffffffL
599 #if LONG_MAX == 0x7fffffffL
592 static char *tuple_format = "Kiiiiiis#";
600 static char *tuple_format = "Kiiiiiis#";
593 #else
601 #else
594 static char *tuple_format = "kiiiiiis#";
602 static char *tuple_format = "kiiiiiis#";
595 #endif
603 #endif
596
604
597 /* A RevlogNG v1 index entry is 64 bytes long. */
605 /* A RevlogNG v1 index entry is 64 bytes long. */
598 static const long v1_hdrsize = 64;
606 static const long v1_hdrsize = 64;
599
607
600 /*
608 /*
601 * Return a pointer to the beginning of a RevlogNG record.
609 * Return a pointer to the beginning of a RevlogNG record.
602 */
610 */
603 static const char *index_deref(indexObject *self, Py_ssize_t pos)
611 static const char *index_deref(indexObject *self, Py_ssize_t pos)
604 {
612 {
605 if (self->inlined && pos > 0) {
613 if (self->inlined && pos > 0) {
606 if (self->offsets == NULL) {
614 if (self->offsets == NULL) {
607 self->offsets = malloc(self->raw_length *
615 self->offsets = malloc(self->raw_length *
608 sizeof(*self->offsets));
616 sizeof(*self->offsets));
609 if (self->offsets == NULL)
617 if (self->offsets == NULL)
610 return (const char *)PyErr_NoMemory();
618 return (const char *)PyErr_NoMemory();
611 inline_scan(self, self->offsets);
619 inline_scan(self, self->offsets);
612 }
620 }
613 return self->offsets[pos];
621 return self->offsets[pos];
614 }
622 }
615
623
616 return PyString_AS_STRING(self->data) + pos * v1_hdrsize;
624 return PyString_AS_STRING(self->data) + pos * v1_hdrsize;
617 }
625 }
618
626
619 /*
627 /*
620 * RevlogNG format (all in big endian, data may be inlined):
628 * RevlogNG format (all in big endian, data may be inlined):
621 * 6 bytes: offset
629 * 6 bytes: offset
622 * 2 bytes: flags
630 * 2 bytes: flags
623 * 4 bytes: compressed length
631 * 4 bytes: compressed length
624 * 4 bytes: uncompressed length
632 * 4 bytes: uncompressed length
625 * 4 bytes: base revision
633 * 4 bytes: base revision
626 * 4 bytes: link revision
634 * 4 bytes: link revision
627 * 4 bytes: parent 1 revision
635 * 4 bytes: parent 1 revision
628 * 4 bytes: parent 2 revision
636 * 4 bytes: parent 2 revision
629 * 32 bytes: nodeid (only 20 bytes used)
637 * 32 bytes: nodeid (only 20 bytes used)
630 */
638 */
631 static PyObject *index_get(indexObject *self, Py_ssize_t pos)
639 static PyObject *index_get(indexObject *self, Py_ssize_t pos)
632 {
640 {
633 uint64_t offset_flags;
641 uint64_t offset_flags;
634 int comp_len, uncomp_len, base_rev, link_rev, parent_1, parent_2;
642 int comp_len, uncomp_len, base_rev, link_rev, parent_1, parent_2;
635 const char *c_node_id;
643 const char *c_node_id;
636 const char *data;
644 const char *data;
637 Py_ssize_t length = index_length(self);
645 Py_ssize_t length = index_length(self);
638 PyObject *entry;
646 PyObject *entry;
639
647
640 if (pos < 0)
648 if (pos < 0)
641 pos += length;
649 pos += length;
642
650
643 if (pos < 0 || pos >= length) {
651 if (pos < 0 || pos >= length) {
644 PyErr_SetString(PyExc_IndexError, "revlog index out of range");
652 PyErr_SetString(PyExc_IndexError, "revlog index out of range");
645 return NULL;
653 return NULL;
646 }
654 }
647
655
648 if (pos == length - 1) {
656 if (pos == length - 1) {
649 Py_INCREF(nullentry);
657 Py_INCREF(nullentry);
650 return nullentry;
658 return nullentry;
651 }
659 }
652
660
653 if (pos >= self->length - 1) {
661 if (pos >= self->length - 1) {
654 PyObject *obj;
662 PyObject *obj;
655 obj = PyList_GET_ITEM(self->added, pos - self->length + 1);
663 obj = PyList_GET_ITEM(self->added, pos - self->length + 1);
656 Py_INCREF(obj);
664 Py_INCREF(obj);
657 return obj;
665 return obj;
658 }
666 }
659
667
660 if (self->cache) {
668 if (self->cache) {
661 if (self->cache[pos]) {
669 if (self->cache[pos]) {
662 Py_INCREF(self->cache[pos]);
670 Py_INCREF(self->cache[pos]);
663 return self->cache[pos];
671 return self->cache[pos];
664 }
672 }
665 } else {
673 } else {
666 self->cache = calloc(self->raw_length, sizeof(PyObject *));
674 self->cache = calloc(self->raw_length, sizeof(PyObject *));
667 if (self->cache == NULL)
675 if (self->cache == NULL)
668 return PyErr_NoMemory();
676 return PyErr_NoMemory();
669 }
677 }
670
678
671 data = index_deref(self, pos);
679 data = index_deref(self, pos);
672 if (data == NULL)
680 if (data == NULL)
673 return NULL;
681 return NULL;
674
682
675 offset_flags = getbe32(data + 4);
683 offset_flags = getbe32(data + 4);
676 if (pos == 0) /* mask out version number for the first entry */
684 if (pos == 0) /* mask out version number for the first entry */
677 offset_flags &= 0xFFFF;
685 offset_flags &= 0xFFFF;
678 else {
686 else {
679 uint32_t offset_high = getbe32(data);
687 uint32_t offset_high = getbe32(data);
680 offset_flags |= ((uint64_t)offset_high) << 32;
688 offset_flags |= ((uint64_t)offset_high) << 32;
681 }
689 }
682
690
683 comp_len = getbe32(data + 8);
691 comp_len = getbe32(data + 8);
684 uncomp_len = getbe32(data + 12);
692 uncomp_len = getbe32(data + 12);
685 base_rev = getbe32(data + 16);
693 base_rev = getbe32(data + 16);
686 link_rev = getbe32(data + 20);
694 link_rev = getbe32(data + 20);
687 parent_1 = getbe32(data + 24);
695 parent_1 = getbe32(data + 24);
688 parent_2 = getbe32(data + 28);
696 parent_2 = getbe32(data + 28);
689 c_node_id = data + 32;
697 c_node_id = data + 32;
690
698
691 entry = Py_BuildValue(tuple_format, offset_flags, comp_len,
699 entry = Py_BuildValue(tuple_format, offset_flags, comp_len,
692 uncomp_len, base_rev, link_rev,
700 uncomp_len, base_rev, link_rev,
693 parent_1, parent_2, c_node_id, 20);
701 parent_1, parent_2, c_node_id, 20);
694
702
695 if (entry) {
703 if (entry) {
696 PyObject_GC_UnTrack(entry);
704 PyObject_GC_UnTrack(entry);
697 Py_INCREF(entry);
705 Py_INCREF(entry);
698 }
706 }
699
707
700 self->cache[pos] = entry;
708 self->cache[pos] = entry;
701
709
702 return entry;
710 return entry;
703 }
711 }
704
712
705 /*
713 /*
706 * Return the 20-byte SHA of the node corresponding to the given rev.
714 * Return the 20-byte SHA of the node corresponding to the given rev.
707 */
715 */
708 static const char *index_node(indexObject *self, Py_ssize_t pos)
716 static const char *index_node(indexObject *self, Py_ssize_t pos)
709 {
717 {
710 Py_ssize_t length = index_length(self);
718 Py_ssize_t length = index_length(self);
711 const char *data;
719 const char *data;
712
720
713 if (pos == length - 1 || pos == INT_MAX)
721 if (pos == length - 1 || pos == INT_MAX)
714 return nullid;
722 return nullid;
715
723
716 if (pos >= length)
724 if (pos >= length)
717 return NULL;
725 return NULL;
718
726
719 if (pos >= self->length - 1) {
727 if (pos >= self->length - 1) {
720 PyObject *tuple, *str;
728 PyObject *tuple, *str;
721 tuple = PyList_GET_ITEM(self->added, pos - self->length + 1);
729 tuple = PyList_GET_ITEM(self->added, pos - self->length + 1);
722 str = PyTuple_GetItem(tuple, 7);
730 str = PyTuple_GetItem(tuple, 7);
723 return str ? PyString_AS_STRING(str) : NULL;
731 return str ? PyString_AS_STRING(str) : NULL;
724 }
732 }
725
733
726 data = index_deref(self, pos);
734 data = index_deref(self, pos);
727 return data ? data + 32 : NULL;
735 return data ? data + 32 : NULL;
728 }
736 }
729
737
730 static int nt_insert(indexObject *self, const char *node, int rev);
738 static int nt_insert(indexObject *self, const char *node, int rev);
731
739
732 static int node_check(PyObject *obj, char **node, Py_ssize_t *nodelen)
740 static int node_check(PyObject *obj, char **node, Py_ssize_t *nodelen)
733 {
741 {
734 if (PyString_AsStringAndSize(obj, node, nodelen) == -1)
742 if (PyString_AsStringAndSize(obj, node, nodelen) == -1)
735 return -1;
743 return -1;
736 if (*nodelen == 20)
744 if (*nodelen == 20)
737 return 0;
745 return 0;
738 PyErr_SetString(PyExc_ValueError, "20-byte hash required");
746 PyErr_SetString(PyExc_ValueError, "20-byte hash required");
739 return -1;
747 return -1;
740 }
748 }
741
749
742 static PyObject *index_insert(indexObject *self, PyObject *args)
750 static PyObject *index_insert(indexObject *self, PyObject *args)
743 {
751 {
744 PyObject *obj;
752 PyObject *obj;
745 char *node;
753 char *node;
746 int index;
754 int index;
747 Py_ssize_t len, nodelen;
755 Py_ssize_t len, nodelen;
748
756
749 if (!PyArg_ParseTuple(args, "iO", &index, &obj))
757 if (!PyArg_ParseTuple(args, "iO", &index, &obj))
750 return NULL;
758 return NULL;
751
759
752 if (!PyTuple_Check(obj) || PyTuple_GET_SIZE(obj) != 8) {
760 if (!PyTuple_Check(obj) || PyTuple_GET_SIZE(obj) != 8) {
753 PyErr_SetString(PyExc_TypeError, "8-tuple required");
761 PyErr_SetString(PyExc_TypeError, "8-tuple required");
754 return NULL;
762 return NULL;
755 }
763 }
756
764
757 if (node_check(PyTuple_GET_ITEM(obj, 7), &node, &nodelen) == -1)
765 if (node_check(PyTuple_GET_ITEM(obj, 7), &node, &nodelen) == -1)
758 return NULL;
766 return NULL;
759
767
760 len = index_length(self);
768 len = index_length(self);
761
769
762 if (index < 0)
770 if (index < 0)
763 index += len;
771 index += len;
764
772
765 if (index != len - 1) {
773 if (index != len - 1) {
766 PyErr_SetString(PyExc_IndexError,
774 PyErr_SetString(PyExc_IndexError,
767 "insert only supported at index -1");
775 "insert only supported at index -1");
768 return NULL;
776 return NULL;
769 }
777 }
770
778
771 if (self->added == NULL) {
779 if (self->added == NULL) {
772 self->added = PyList_New(0);
780 self->added = PyList_New(0);
773 if (self->added == NULL)
781 if (self->added == NULL)
774 return NULL;
782 return NULL;
775 }
783 }
776
784
777 if (PyList_Append(self->added, obj) == -1)
785 if (PyList_Append(self->added, obj) == -1)
778 return NULL;
786 return NULL;
779
787
780 if (self->nt)
788 if (self->nt)
781 nt_insert(self, node, index);
789 nt_insert(self, node, index);
782
790
783 Py_CLEAR(self->headrevs);
791 Py_CLEAR(self->headrevs);
784 Py_RETURN_NONE;
792 Py_RETURN_NONE;
785 }
793 }
786
794
787 static void _index_clearcaches(indexObject *self)
795 static void _index_clearcaches(indexObject *self)
788 {
796 {
789 if (self->cache) {
797 if (self->cache) {
790 Py_ssize_t i;
798 Py_ssize_t i;
791
799
792 for (i = 0; i < self->raw_length; i++)
800 for (i = 0; i < self->raw_length; i++)
793 Py_CLEAR(self->cache[i]);
801 Py_CLEAR(self->cache[i]);
794 free(self->cache);
802 free(self->cache);
795 self->cache = NULL;
803 self->cache = NULL;
796 }
804 }
797 if (self->offsets) {
805 if (self->offsets) {
798 free(self->offsets);
806 free(self->offsets);
799 self->offsets = NULL;
807 self->offsets = NULL;
800 }
808 }
801 if (self->nt) {
809 if (self->nt) {
802 free(self->nt);
810 free(self->nt);
803 self->nt = NULL;
811 self->nt = NULL;
804 }
812 }
805 Py_CLEAR(self->headrevs);
813 Py_CLEAR(self->headrevs);
806 }
814 }
807
815
808 static PyObject *index_clearcaches(indexObject *self)
816 static PyObject *index_clearcaches(indexObject *self)
809 {
817 {
810 _index_clearcaches(self);
818 _index_clearcaches(self);
811 self->ntlength = self->ntcapacity = 0;
819 self->ntlength = self->ntcapacity = 0;
812 self->ntdepth = self->ntsplits = 0;
820 self->ntdepth = self->ntsplits = 0;
813 self->ntrev = -1;
821 self->ntrev = -1;
814 self->ntlookups = self->ntmisses = 0;
822 self->ntlookups = self->ntmisses = 0;
815 Py_RETURN_NONE;
823 Py_RETURN_NONE;
816 }
824 }
817
825
818 static PyObject *index_stats(indexObject *self)
826 static PyObject *index_stats(indexObject *self)
819 {
827 {
820 PyObject *obj = PyDict_New();
828 PyObject *obj = PyDict_New();
821 PyObject *t = NULL;
829 PyObject *t = NULL;
822
830
823 if (obj == NULL)
831 if (obj == NULL)
824 return NULL;
832 return NULL;
825
833
826 #define istat(__n, __d) \
834 #define istat(__n, __d) \
827 t = PyInt_FromSsize_t(self->__n); \
835 t = PyInt_FromSsize_t(self->__n); \
828 if (!t) \
836 if (!t) \
829 goto bail; \
837 goto bail; \
830 if (PyDict_SetItemString(obj, __d, t) == -1) \
838 if (PyDict_SetItemString(obj, __d, t) == -1) \
831 goto bail; \
839 goto bail; \
832 Py_DECREF(t);
840 Py_DECREF(t);
833
841
834 if (self->added) {
842 if (self->added) {
835 Py_ssize_t len = PyList_GET_SIZE(self->added);
843 Py_ssize_t len = PyList_GET_SIZE(self->added);
836 t = PyInt_FromSsize_t(len);
844 t = PyInt_FromSsize_t(len);
837 if (!t)
845 if (!t)
838 goto bail;
846 goto bail;
839 if (PyDict_SetItemString(obj, "index entries added", t) == -1)
847 if (PyDict_SetItemString(obj, "index entries added", t) == -1)
840 goto bail;
848 goto bail;
841 Py_DECREF(t);
849 Py_DECREF(t);
842 }
850 }
843
851
844 if (self->raw_length != self->length - 1)
852 if (self->raw_length != self->length - 1)
845 istat(raw_length, "revs on disk");
853 istat(raw_length, "revs on disk");
846 istat(length, "revs in memory");
854 istat(length, "revs in memory");
847 istat(ntcapacity, "node trie capacity");
855 istat(ntcapacity, "node trie capacity");
848 istat(ntdepth, "node trie depth");
856 istat(ntdepth, "node trie depth");
849 istat(ntlength, "node trie count");
857 istat(ntlength, "node trie count");
850 istat(ntlookups, "node trie lookups");
858 istat(ntlookups, "node trie lookups");
851 istat(ntmisses, "node trie misses");
859 istat(ntmisses, "node trie misses");
852 istat(ntrev, "node trie last rev scanned");
860 istat(ntrev, "node trie last rev scanned");
853 istat(ntsplits, "node trie splits");
861 istat(ntsplits, "node trie splits");
854
862
855 #undef istat
863 #undef istat
856
864
857 return obj;
865 return obj;
858
866
859 bail:
867 bail:
860 Py_XDECREF(obj);
868 Py_XDECREF(obj);
861 Py_XDECREF(t);
869 Py_XDECREF(t);
862 return NULL;
870 return NULL;
863 }
871 }
864
872
865 /*
873 /*
866 * When we cache a list, we want to be sure the caller can't mutate
874 * When we cache a list, we want to be sure the caller can't mutate
867 * the cached copy.
875 * the cached copy.
868 */
876 */
869 static PyObject *list_copy(PyObject *list)
877 static PyObject *list_copy(PyObject *list)
870 {
878 {
871 Py_ssize_t len = PyList_GET_SIZE(list);
879 Py_ssize_t len = PyList_GET_SIZE(list);
872 PyObject *newlist = PyList_New(len);
880 PyObject *newlist = PyList_New(len);
873 Py_ssize_t i;
881 Py_ssize_t i;
874
882
875 if (newlist == NULL)
883 if (newlist == NULL)
876 return NULL;
884 return NULL;
877
885
878 for (i = 0; i < len; i++) {
886 for (i = 0; i < len; i++) {
879 PyObject *obj = PyList_GET_ITEM(list, i);
887 PyObject *obj = PyList_GET_ITEM(list, i);
880 Py_INCREF(obj);
888 Py_INCREF(obj);
881 PyList_SET_ITEM(newlist, i, obj);
889 PyList_SET_ITEM(newlist, i, obj);
882 }
890 }
883
891
884 return newlist;
892 return newlist;
885 }
893 }
886
894
887 /* arg should be Py_ssize_t but Python 2.4 do not support the n format */
895 /* arg should be Py_ssize_t but Python 2.4 do not support the n format */
888 static int check_filter(PyObject *filter, unsigned long arg) {
896 static int check_filter(PyObject *filter, unsigned long arg) {
889 if (filter) {
897 if (filter) {
890 PyObject *arglist, *result;
898 PyObject *arglist, *result;
891 int isfiltered;
899 int isfiltered;
892
900
893 arglist = Py_BuildValue("(k)", arg);
901 arglist = Py_BuildValue("(k)", arg);
894 if (!arglist) {
902 if (!arglist) {
895 return -1;
903 return -1;
896 }
904 }
897
905
898 result = PyEval_CallObject(filter, arglist);
906 result = PyEval_CallObject(filter, arglist);
899 Py_DECREF(arglist);
907 Py_DECREF(arglist);
900 if (!result) {
908 if (!result) {
901 return -1;
909 return -1;
902 }
910 }
903
911
904 /* PyObject_IsTrue returns 1 if true, 0 if false, -1 if error,
912 /* PyObject_IsTrue returns 1 if true, 0 if false, -1 if error,
905 * same as this function, so we can just return it directly.*/
913 * same as this function, so we can just return it directly.*/
906 isfiltered = PyObject_IsTrue(result);
914 isfiltered = PyObject_IsTrue(result);
907 Py_DECREF(result);
915 Py_DECREF(result);
908 return isfiltered;
916 return isfiltered;
909 } else {
917 } else {
910 return 0;
918 return 0;
911 }
919 }
912 }
920 }
913
921
914 static Py_ssize_t add_roots_get_min(indexObject *self, PyObject *list,
922 static Py_ssize_t add_roots_get_min(indexObject *self, PyObject *list,
915 Py_ssize_t marker, char *phases)
923 Py_ssize_t marker, char *phases)
916 {
924 {
917 PyObject *iter = NULL;
925 PyObject *iter = NULL;
918 PyObject *iter_item = NULL;
926 PyObject *iter_item = NULL;
919 Py_ssize_t min_idx = index_length(self) + 1;
927 Py_ssize_t min_idx = index_length(self) + 1;
920 long iter_item_long;
928 long iter_item_long;
921
929
922 if (PyList_GET_SIZE(list) != 0) {
930 if (PyList_GET_SIZE(list) != 0) {
923 iter = PyObject_GetIter(list);
931 iter = PyObject_GetIter(list);
924 if (iter == NULL)
932 if (iter == NULL)
925 return -2;
933 return -2;
926 while ((iter_item = PyIter_Next(iter)))
934 while ((iter_item = PyIter_Next(iter)))
927 {
935 {
928 iter_item_long = PyInt_AS_LONG(iter_item);
936 iter_item_long = PyInt_AS_LONG(iter_item);
929 Py_DECREF(iter_item);
937 Py_DECREF(iter_item);
930 if (iter_item_long < min_idx)
938 if (iter_item_long < min_idx)
931 min_idx = iter_item_long;
939 min_idx = iter_item_long;
932 phases[iter_item_long] = marker;
940 phases[iter_item_long] = marker;
933 }
941 }
934 Py_DECREF(iter);
942 Py_DECREF(iter);
935 }
943 }
936
944
937 return min_idx;
945 return min_idx;
938 }
946 }
939
947
940 static inline void set_phase_from_parents(char *phases, int parent_1,
948 static inline void set_phase_from_parents(char *phases, int parent_1,
941 int parent_2, Py_ssize_t i)
949 int parent_2, Py_ssize_t i)
942 {
950 {
943 if (parent_1 >= 0 && phases[parent_1] > phases[i])
951 if (parent_1 >= 0 && phases[parent_1] > phases[i])
944 phases[i] = phases[parent_1];
952 phases[i] = phases[parent_1];
945 if (parent_2 >= 0 && phases[parent_2] > phases[i])
953 if (parent_2 >= 0 && phases[parent_2] > phases[i])
946 phases[i] = phases[parent_2];
954 phases[i] = phases[parent_2];
947 }
955 }
948
956
949 static PyObject *compute_phases(indexObject *self, PyObject *args)
957 static PyObject *compute_phases(indexObject *self, PyObject *args)
950 {
958 {
951 PyObject *roots = Py_None;
959 PyObject *roots = Py_None;
952 PyObject *phaseslist = NULL;
960 PyObject *phaseslist = NULL;
953 PyObject *phaseroots = NULL;
961 PyObject *phaseroots = NULL;
954 PyObject *rev = NULL;
962 PyObject *rev = NULL;
955 PyObject *p1 = NULL;
963 PyObject *p1 = NULL;
956 PyObject *p2 = NULL;
964 PyObject *p2 = NULL;
957 Py_ssize_t addlen = self->added ? PyList_GET_SIZE(self->added) : 0;
965 Py_ssize_t addlen = self->added ? PyList_GET_SIZE(self->added) : 0;
958 Py_ssize_t len = index_length(self) - 1;
966 Py_ssize_t len = index_length(self) - 1;
959 Py_ssize_t numphase = 0;
967 Py_ssize_t numphase = 0;
960 Py_ssize_t minrevallphases = 0;
968 Py_ssize_t minrevallphases = 0;
961 Py_ssize_t minrevphase = 0;
969 Py_ssize_t minrevphase = 0;
962 Py_ssize_t i = 0;
970 Py_ssize_t i = 0;
963 int parent_1, parent_2;
971 int parent_1, parent_2;
964 char *phases = NULL;
972 char *phases = NULL;
965 const char *data;
973 const char *data;
966
974
967 if (!PyArg_ParseTuple(args, "O", &roots))
975 if (!PyArg_ParseTuple(args, "O", &roots))
968 goto release_none;
976 goto release_none;
969 if (roots == NULL || !PyList_Check(roots))
977 if (roots == NULL || !PyList_Check(roots))
970 goto release_none;
978 goto release_none;
971
979
972 phases = calloc(len, 1); /* phase per rev: {0: public, 1: draft, 2: secret} */
980 phases = calloc(len, 1); /* phase per rev: {0: public, 1: draft, 2: secret} */
973 if (phases == NULL)
981 if (phases == NULL)
974 goto release_none;
982 goto release_none;
975 /* Put the phase information of all the roots in phases */
983 /* Put the phase information of all the roots in phases */
976 numphase = PyList_GET_SIZE(roots)+1;
984 numphase = PyList_GET_SIZE(roots)+1;
977 minrevallphases = len + 1;
985 minrevallphases = len + 1;
978 for (i = 0; i < numphase-1; i++) {
986 for (i = 0; i < numphase-1; i++) {
979 phaseroots = PyList_GET_ITEM(roots, i);
987 phaseroots = PyList_GET_ITEM(roots, i);
980 if (!PyList_Check(phaseroots))
988 if (!PyList_Check(phaseroots))
981 goto release_phases;
989 goto release_phases;
982 minrevphase = add_roots_get_min(self, phaseroots, i+1, phases);
990 minrevphase = add_roots_get_min(self, phaseroots, i+1, phases);
983 if (minrevphase == -2) /* Error from add_roots_get_min */
991 if (minrevphase == -2) /* Error from add_roots_get_min */
984 goto release_phases;
992 goto release_phases;
985 minrevallphases = MIN(minrevallphases, minrevphase);
993 minrevallphases = MIN(minrevallphases, minrevphase);
986 }
994 }
987 /* Propagate the phase information from the roots to the revs */
995 /* Propagate the phase information from the roots to the revs */
988 if (minrevallphases != -1) {
996 if (minrevallphases != -1) {
989 for (i = minrevallphases; i < self->raw_length; i++) {
997 for (i = minrevallphases; i < self->raw_length; i++) {
990 data = index_deref(self, i);
998 data = index_deref(self, i);
991 set_phase_from_parents(phases, getbe32(data+24), getbe32(data+28), i);
999 set_phase_from_parents(phases, getbe32(data+24), getbe32(data+28), i);
992 }
1000 }
993 for (i = 0; i < addlen; i++) {
1001 for (i = 0; i < addlen; i++) {
994 rev = PyList_GET_ITEM(self->added, i);
1002 rev = PyList_GET_ITEM(self->added, i);
995 p1 = PyTuple_GET_ITEM(rev, 5);
1003 p1 = PyTuple_GET_ITEM(rev, 5);
996 p2 = PyTuple_GET_ITEM(rev, 6);
1004 p2 = PyTuple_GET_ITEM(rev, 6);
997 if (!PyInt_Check(p1) || !PyInt_Check(p2)) {
1005 if (!PyInt_Check(p1) || !PyInt_Check(p2)) {
998 PyErr_SetString(PyExc_TypeError, "revlog parents are invalid");
1006 PyErr_SetString(PyExc_TypeError, "revlog parents are invalid");
999 goto release_phases;
1007 goto release_phases;
1000 }
1008 }
1001 parent_1 = (int)PyInt_AS_LONG(p1);
1009 parent_1 = (int)PyInt_AS_LONG(p1);
1002 parent_2 = (int)PyInt_AS_LONG(p2);
1010 parent_2 = (int)PyInt_AS_LONG(p2);
1003 set_phase_from_parents(phases, parent_1, parent_2, i+self->raw_length);
1011 set_phase_from_parents(phases, parent_1, parent_2, i+self->raw_length);
1004 }
1012 }
1005 }
1013 }
1006 /* Transform phase list to a python list */
1014 /* Transform phase list to a python list */
1007 phaseslist = PyList_New(len);
1015 phaseslist = PyList_New(len);
1008 if (phaseslist == NULL)
1016 if (phaseslist == NULL)
1009 goto release_phases;
1017 goto release_phases;
1010 for (i = 0; i < len; i++)
1018 for (i = 0; i < len; i++)
1011 PyList_SET_ITEM(phaseslist, i, PyInt_FromLong(phases[i]));
1019 PyList_SET_ITEM(phaseslist, i, PyInt_FromLong(phases[i]));
1012
1020
1013 release_phases:
1021 release_phases:
1014 free(phases);
1022 free(phases);
1015 release_none:
1023 release_none:
1016 return phaseslist;
1024 return phaseslist;
1017 }
1025 }
1018
1026
1019 static PyObject *index_headrevs(indexObject *self, PyObject *args)
1027 static PyObject *index_headrevs(indexObject *self, PyObject *args)
1020 {
1028 {
1021 Py_ssize_t i, len, addlen;
1029 Py_ssize_t i, len, addlen;
1022 char *nothead = NULL;
1030 char *nothead = NULL;
1023 PyObject *heads = NULL;
1031 PyObject *heads = NULL;
1024 PyObject *filter = NULL;
1032 PyObject *filter = NULL;
1025 PyObject *filteredrevs = Py_None;
1033 PyObject *filteredrevs = Py_None;
1026
1034
1027 if (!PyArg_ParseTuple(args, "|O", &filteredrevs)) {
1035 if (!PyArg_ParseTuple(args, "|O", &filteredrevs)) {
1028 return NULL;
1036 return NULL;
1029 }
1037 }
1030
1038
1031 if (self->headrevs && filteredrevs == self->filteredrevs)
1039 if (self->headrevs && filteredrevs == self->filteredrevs)
1032 return list_copy(self->headrevs);
1040 return list_copy(self->headrevs);
1033
1041
1034 Py_DECREF(self->filteredrevs);
1042 Py_DECREF(self->filteredrevs);
1035 self->filteredrevs = filteredrevs;
1043 self->filteredrevs = filteredrevs;
1036 Py_INCREF(filteredrevs);
1044 Py_INCREF(filteredrevs);
1037
1045
1038 if (filteredrevs != Py_None) {
1046 if (filteredrevs != Py_None) {
1039 filter = PyObject_GetAttrString(filteredrevs, "__contains__");
1047 filter = PyObject_GetAttrString(filteredrevs, "__contains__");
1040 if (!filter) {
1048 if (!filter) {
1041 PyErr_SetString(PyExc_TypeError,
1049 PyErr_SetString(PyExc_TypeError,
1042 "filteredrevs has no attribute __contains__");
1050 "filteredrevs has no attribute __contains__");
1043 goto bail;
1051 goto bail;
1044 }
1052 }
1045 }
1053 }
1046
1054
1047 len = index_length(self) - 1;
1055 len = index_length(self) - 1;
1048 heads = PyList_New(0);
1056 heads = PyList_New(0);
1049 if (heads == NULL)
1057 if (heads == NULL)
1050 goto bail;
1058 goto bail;
1051 if (len == 0) {
1059 if (len == 0) {
1052 PyObject *nullid = PyInt_FromLong(-1);
1060 PyObject *nullid = PyInt_FromLong(-1);
1053 if (nullid == NULL || PyList_Append(heads, nullid) == -1) {
1061 if (nullid == NULL || PyList_Append(heads, nullid) == -1) {
1054 Py_XDECREF(nullid);
1062 Py_XDECREF(nullid);
1055 goto bail;
1063 goto bail;
1056 }
1064 }
1057 goto done;
1065 goto done;
1058 }
1066 }
1059
1067
1060 nothead = calloc(len, 1);
1068 nothead = calloc(len, 1);
1061 if (nothead == NULL)
1069 if (nothead == NULL)
1062 goto bail;
1070 goto bail;
1063
1071
1064 for (i = 0; i < self->raw_length; i++) {
1072 for (i = 0; i < self->raw_length; i++) {
1065 const char *data;
1073 const char *data;
1066 int parent_1, parent_2, isfiltered;
1074 int parent_1, parent_2, isfiltered;
1067
1075
1068 isfiltered = check_filter(filter, i);
1076 isfiltered = check_filter(filter, i);
1069 if (isfiltered == -1) {
1077 if (isfiltered == -1) {
1070 PyErr_SetString(PyExc_TypeError,
1078 PyErr_SetString(PyExc_TypeError,
1071 "unable to check filter");
1079 "unable to check filter");
1072 goto bail;
1080 goto bail;
1073 }
1081 }
1074
1082
1075 if (isfiltered) {
1083 if (isfiltered) {
1076 nothead[i] = 1;
1084 nothead[i] = 1;
1077 continue;
1085 continue;
1078 }
1086 }
1079
1087
1080 data = index_deref(self, i);
1088 data = index_deref(self, i);
1081 parent_1 = getbe32(data + 24);
1089 parent_1 = getbe32(data + 24);
1082 parent_2 = getbe32(data + 28);
1090 parent_2 = getbe32(data + 28);
1083
1091
1084 if (parent_1 >= 0)
1092 if (parent_1 >= 0)
1085 nothead[parent_1] = 1;
1093 nothead[parent_1] = 1;
1086 if (parent_2 >= 0)
1094 if (parent_2 >= 0)
1087 nothead[parent_2] = 1;
1095 nothead[parent_2] = 1;
1088 }
1096 }
1089
1097
1090 addlen = self->added ? PyList_GET_SIZE(self->added) : 0;
1098 addlen = self->added ? PyList_GET_SIZE(self->added) : 0;
1091
1099
1092 for (i = 0; i < addlen; i++) {
1100 for (i = 0; i < addlen; i++) {
1093 PyObject *rev = PyList_GET_ITEM(self->added, i);
1101 PyObject *rev = PyList_GET_ITEM(self->added, i);
1094 PyObject *p1 = PyTuple_GET_ITEM(rev, 5);
1102 PyObject *p1 = PyTuple_GET_ITEM(rev, 5);
1095 PyObject *p2 = PyTuple_GET_ITEM(rev, 6);
1103 PyObject *p2 = PyTuple_GET_ITEM(rev, 6);
1096 long parent_1, parent_2;
1104 long parent_1, parent_2;
1097 int isfiltered;
1105 int isfiltered;
1098
1106
1099 if (!PyInt_Check(p1) || !PyInt_Check(p2)) {
1107 if (!PyInt_Check(p1) || !PyInt_Check(p2)) {
1100 PyErr_SetString(PyExc_TypeError,
1108 PyErr_SetString(PyExc_TypeError,
1101 "revlog parents are invalid");
1109 "revlog parents are invalid");
1102 goto bail;
1110 goto bail;
1103 }
1111 }
1104
1112
1105 isfiltered = check_filter(filter, i);
1113 isfiltered = check_filter(filter, i);
1106 if (isfiltered == -1) {
1114 if (isfiltered == -1) {
1107 PyErr_SetString(PyExc_TypeError,
1115 PyErr_SetString(PyExc_TypeError,
1108 "unable to check filter");
1116 "unable to check filter");
1109 goto bail;
1117 goto bail;
1110 }
1118 }
1111
1119
1112 if (isfiltered) {
1120 if (isfiltered) {
1113 nothead[i] = 1;
1121 nothead[i] = 1;
1114 continue;
1122 continue;
1115 }
1123 }
1116
1124
1117 parent_1 = PyInt_AS_LONG(p1);
1125 parent_1 = PyInt_AS_LONG(p1);
1118 parent_2 = PyInt_AS_LONG(p2);
1126 parent_2 = PyInt_AS_LONG(p2);
1119 if (parent_1 >= 0)
1127 if (parent_1 >= 0)
1120 nothead[parent_1] = 1;
1128 nothead[parent_1] = 1;
1121 if (parent_2 >= 0)
1129 if (parent_2 >= 0)
1122 nothead[parent_2] = 1;
1130 nothead[parent_2] = 1;
1123 }
1131 }
1124
1132
1125 for (i = 0; i < len; i++) {
1133 for (i = 0; i < len; i++) {
1126 PyObject *head;
1134 PyObject *head;
1127
1135
1128 if (nothead[i])
1136 if (nothead[i])
1129 continue;
1137 continue;
1130 head = PyInt_FromSsize_t(i);
1138 head = PyInt_FromSsize_t(i);
1131 if (head == NULL || PyList_Append(heads, head) == -1) {
1139 if (head == NULL || PyList_Append(heads, head) == -1) {
1132 Py_XDECREF(head);
1140 Py_XDECREF(head);
1133 goto bail;
1141 goto bail;
1134 }
1142 }
1135 }
1143 }
1136
1144
1137 done:
1145 done:
1138 self->headrevs = heads;
1146 self->headrevs = heads;
1139 Py_XDECREF(filter);
1147 Py_XDECREF(filter);
1140 free(nothead);
1148 free(nothead);
1141 return list_copy(self->headrevs);
1149 return list_copy(self->headrevs);
1142 bail:
1150 bail:
1143 Py_XDECREF(filter);
1151 Py_XDECREF(filter);
1144 Py_XDECREF(heads);
1152 Py_XDECREF(heads);
1145 free(nothead);
1153 free(nothead);
1146 return NULL;
1154 return NULL;
1147 }
1155 }
1148
1156
1149 static inline int nt_level(const char *node, Py_ssize_t level)
1157 static inline int nt_level(const char *node, Py_ssize_t level)
1150 {
1158 {
1151 int v = node[level>>1];
1159 int v = node[level>>1];
1152 if (!(level & 1))
1160 if (!(level & 1))
1153 v >>= 4;
1161 v >>= 4;
1154 return v & 0xf;
1162 return v & 0xf;
1155 }
1163 }
1156
1164
1157 /*
1165 /*
1158 * Return values:
1166 * Return values:
1159 *
1167 *
1160 * -4: match is ambiguous (multiple candidates)
1168 * -4: match is ambiguous (multiple candidates)
1161 * -2: not found
1169 * -2: not found
1162 * rest: valid rev
1170 * rest: valid rev
1163 */
1171 */
1164 static int nt_find(indexObject *self, const char *node, Py_ssize_t nodelen,
1172 static int nt_find(indexObject *self, const char *node, Py_ssize_t nodelen,
1165 int hex)
1173 int hex)
1166 {
1174 {
1167 int (*getnybble)(const char *, Py_ssize_t) = hex ? hexdigit : nt_level;
1175 int (*getnybble)(const char *, Py_ssize_t) = hex ? hexdigit : nt_level;
1168 int level, maxlevel, off;
1176 int level, maxlevel, off;
1169
1177
1170 if (nodelen == 20 && node[0] == '\0' && memcmp(node, nullid, 20) == 0)
1178 if (nodelen == 20 && node[0] == '\0' && memcmp(node, nullid, 20) == 0)
1171 return -1;
1179 return -1;
1172
1180
1173 if (self->nt == NULL)
1181 if (self->nt == NULL)
1174 return -2;
1182 return -2;
1175
1183
1176 if (hex)
1184 if (hex)
1177 maxlevel = nodelen > 40 ? 40 : (int)nodelen;
1185 maxlevel = nodelen > 40 ? 40 : (int)nodelen;
1178 else
1186 else
1179 maxlevel = nodelen > 20 ? 40 : ((int)nodelen * 2);
1187 maxlevel = nodelen > 20 ? 40 : ((int)nodelen * 2);
1180
1188
1181 for (level = off = 0; level < maxlevel; level++) {
1189 for (level = off = 0; level < maxlevel; level++) {
1182 int k = getnybble(node, level);
1190 int k = getnybble(node, level);
1183 nodetree *n = &self->nt[off];
1191 nodetree *n = &self->nt[off];
1184 int v = n->children[k];
1192 int v = n->children[k];
1185
1193
1186 if (v < 0) {
1194 if (v < 0) {
1187 const char *n;
1195 const char *n;
1188 Py_ssize_t i;
1196 Py_ssize_t i;
1189
1197
1190 v = -v - 1;
1198 v = -v - 1;
1191 n = index_node(self, v);
1199 n = index_node(self, v);
1192 if (n == NULL)
1200 if (n == NULL)
1193 return -2;
1201 return -2;
1194 for (i = level; i < maxlevel; i++)
1202 for (i = level; i < maxlevel; i++)
1195 if (getnybble(node, i) != nt_level(n, i))
1203 if (getnybble(node, i) != nt_level(n, i))
1196 return -2;
1204 return -2;
1197 return v;
1205 return v;
1198 }
1206 }
1199 if (v == 0)
1207 if (v == 0)
1200 return -2;
1208 return -2;
1201 off = v;
1209 off = v;
1202 }
1210 }
1203 /* multiple matches against an ambiguous prefix */
1211 /* multiple matches against an ambiguous prefix */
1204 return -4;
1212 return -4;
1205 }
1213 }
1206
1214
1207 static int nt_new(indexObject *self)
1215 static int nt_new(indexObject *self)
1208 {
1216 {
1209 if (self->ntlength == self->ntcapacity) {
1217 if (self->ntlength == self->ntcapacity) {
1210 self->ntcapacity *= 2;
1218 self->ntcapacity *= 2;
1211 self->nt = realloc(self->nt,
1219 self->nt = realloc(self->nt,
1212 self->ntcapacity * sizeof(nodetree));
1220 self->ntcapacity * sizeof(nodetree));
1213 if (self->nt == NULL) {
1221 if (self->nt == NULL) {
1214 PyErr_SetString(PyExc_MemoryError, "out of memory");
1222 PyErr_SetString(PyExc_MemoryError, "out of memory");
1215 return -1;
1223 return -1;
1216 }
1224 }
1217 memset(&self->nt[self->ntlength], 0,
1225 memset(&self->nt[self->ntlength], 0,
1218 sizeof(nodetree) * (self->ntcapacity - self->ntlength));
1226 sizeof(nodetree) * (self->ntcapacity - self->ntlength));
1219 }
1227 }
1220 return self->ntlength++;
1228 return self->ntlength++;
1221 }
1229 }
1222
1230
1223 static int nt_insert(indexObject *self, const char *node, int rev)
1231 static int nt_insert(indexObject *self, const char *node, int rev)
1224 {
1232 {
1225 int level = 0;
1233 int level = 0;
1226 int off = 0;
1234 int off = 0;
1227
1235
1228 while (level < 40) {
1236 while (level < 40) {
1229 int k = nt_level(node, level);
1237 int k = nt_level(node, level);
1230 nodetree *n;
1238 nodetree *n;
1231 int v;
1239 int v;
1232
1240
1233 n = &self->nt[off];
1241 n = &self->nt[off];
1234 v = n->children[k];
1242 v = n->children[k];
1235
1243
1236 if (v == 0) {
1244 if (v == 0) {
1237 n->children[k] = -rev - 1;
1245 n->children[k] = -rev - 1;
1238 return 0;
1246 return 0;
1239 }
1247 }
1240 if (v < 0) {
1248 if (v < 0) {
1241 const char *oldnode = index_node(self, -v - 1);
1249 const char *oldnode = index_node(self, -v - 1);
1242 int noff;
1250 int noff;
1243
1251
1244 if (!oldnode || !memcmp(oldnode, node, 20)) {
1252 if (!oldnode || !memcmp(oldnode, node, 20)) {
1245 n->children[k] = -rev - 1;
1253 n->children[k] = -rev - 1;
1246 return 0;
1254 return 0;
1247 }
1255 }
1248 noff = nt_new(self);
1256 noff = nt_new(self);
1249 if (noff == -1)
1257 if (noff == -1)
1250 return -1;
1258 return -1;
1251 /* self->nt may have been changed by realloc */
1259 /* self->nt may have been changed by realloc */
1252 self->nt[off].children[k] = noff;
1260 self->nt[off].children[k] = noff;
1253 off = noff;
1261 off = noff;
1254 n = &self->nt[off];
1262 n = &self->nt[off];
1255 n->children[nt_level(oldnode, ++level)] = v;
1263 n->children[nt_level(oldnode, ++level)] = v;
1256 if (level > self->ntdepth)
1264 if (level > self->ntdepth)
1257 self->ntdepth = level;
1265 self->ntdepth = level;
1258 self->ntsplits += 1;
1266 self->ntsplits += 1;
1259 } else {
1267 } else {
1260 level += 1;
1268 level += 1;
1261 off = v;
1269 off = v;
1262 }
1270 }
1263 }
1271 }
1264
1272
1265 return -1;
1273 return -1;
1266 }
1274 }
1267
1275
1268 static int nt_init(indexObject *self)
1276 static int nt_init(indexObject *self)
1269 {
1277 {
1270 if (self->nt == NULL) {
1278 if (self->nt == NULL) {
1271 if (self->raw_length > INT_MAX) {
1279 if (self->raw_length > INT_MAX) {
1272 PyErr_SetString(PyExc_ValueError, "overflow in nt_init");
1280 PyErr_SetString(PyExc_ValueError, "overflow in nt_init");
1273 return -1;
1281 return -1;
1274 }
1282 }
1275 self->ntcapacity = self->raw_length < 4
1283 self->ntcapacity = self->raw_length < 4
1276 ? 4 : (int)self->raw_length / 2;
1284 ? 4 : (int)self->raw_length / 2;
1277
1285
1278 self->nt = calloc(self->ntcapacity, sizeof(nodetree));
1286 self->nt = calloc(self->ntcapacity, sizeof(nodetree));
1279 if (self->nt == NULL) {
1287 if (self->nt == NULL) {
1280 PyErr_NoMemory();
1288 PyErr_NoMemory();
1281 return -1;
1289 return -1;
1282 }
1290 }
1283 self->ntlength = 1;
1291 self->ntlength = 1;
1284 self->ntrev = (int)index_length(self) - 1;
1292 self->ntrev = (int)index_length(self) - 1;
1285 self->ntlookups = 1;
1293 self->ntlookups = 1;
1286 self->ntmisses = 0;
1294 self->ntmisses = 0;
1287 if (nt_insert(self, nullid, INT_MAX) == -1)
1295 if (nt_insert(self, nullid, INT_MAX) == -1)
1288 return -1;
1296 return -1;
1289 }
1297 }
1290 return 0;
1298 return 0;
1291 }
1299 }
1292
1300
1293 /*
1301 /*
1294 * Return values:
1302 * Return values:
1295 *
1303 *
1296 * -3: error (exception set)
1304 * -3: error (exception set)
1297 * -2: not found (no exception set)
1305 * -2: not found (no exception set)
1298 * rest: valid rev
1306 * rest: valid rev
1299 */
1307 */
1300 static int index_find_node(indexObject *self,
1308 static int index_find_node(indexObject *self,
1301 const char *node, Py_ssize_t nodelen)
1309 const char *node, Py_ssize_t nodelen)
1302 {
1310 {
1303 int rev;
1311 int rev;
1304
1312
1305 self->ntlookups++;
1313 self->ntlookups++;
1306 rev = nt_find(self, node, nodelen, 0);
1314 rev = nt_find(self, node, nodelen, 0);
1307 if (rev >= -1)
1315 if (rev >= -1)
1308 return rev;
1316 return rev;
1309
1317
1310 if (nt_init(self) == -1)
1318 if (nt_init(self) == -1)
1311 return -3;
1319 return -3;
1312
1320
1313 /*
1321 /*
1314 * For the first handful of lookups, we scan the entire index,
1322 * For the first handful of lookups, we scan the entire index,
1315 * and cache only the matching nodes. This optimizes for cases
1323 * and cache only the matching nodes. This optimizes for cases
1316 * like "hg tip", where only a few nodes are accessed.
1324 * like "hg tip", where only a few nodes are accessed.
1317 *
1325 *
1318 * After that, we cache every node we visit, using a single
1326 * After that, we cache every node we visit, using a single
1319 * scan amortized over multiple lookups. This gives the best
1327 * scan amortized over multiple lookups. This gives the best
1320 * bulk performance, e.g. for "hg log".
1328 * bulk performance, e.g. for "hg log".
1321 */
1329 */
1322 if (self->ntmisses++ < 4) {
1330 if (self->ntmisses++ < 4) {
1323 for (rev = self->ntrev - 1; rev >= 0; rev--) {
1331 for (rev = self->ntrev - 1; rev >= 0; rev--) {
1324 const char *n = index_node(self, rev);
1332 const char *n = index_node(self, rev);
1325 if (n == NULL)
1333 if (n == NULL)
1326 return -2;
1334 return -2;
1327 if (memcmp(node, n, nodelen > 20 ? 20 : nodelen) == 0) {
1335 if (memcmp(node, n, nodelen > 20 ? 20 : nodelen) == 0) {
1328 if (nt_insert(self, n, rev) == -1)
1336 if (nt_insert(self, n, rev) == -1)
1329 return -3;
1337 return -3;
1330 break;
1338 break;
1331 }
1339 }
1332 }
1340 }
1333 } else {
1341 } else {
1334 for (rev = self->ntrev - 1; rev >= 0; rev--) {
1342 for (rev = self->ntrev - 1; rev >= 0; rev--) {
1335 const char *n = index_node(self, rev);
1343 const char *n = index_node(self, rev);
1336 if (n == NULL) {
1344 if (n == NULL) {
1337 self->ntrev = rev + 1;
1345 self->ntrev = rev + 1;
1338 return -2;
1346 return -2;
1339 }
1347 }
1340 if (nt_insert(self, n, rev) == -1) {
1348 if (nt_insert(self, n, rev) == -1) {
1341 self->ntrev = rev + 1;
1349 self->ntrev = rev + 1;
1342 return -3;
1350 return -3;
1343 }
1351 }
1344 if (memcmp(node, n, nodelen > 20 ? 20 : nodelen) == 0) {
1352 if (memcmp(node, n, nodelen > 20 ? 20 : nodelen) == 0) {
1345 break;
1353 break;
1346 }
1354 }
1347 }
1355 }
1348 self->ntrev = rev;
1356 self->ntrev = rev;
1349 }
1357 }
1350
1358
1351 if (rev >= 0)
1359 if (rev >= 0)
1352 return rev;
1360 return rev;
1353 return -2;
1361 return -2;
1354 }
1362 }
1355
1363
1356 static PyObject *raise_revlog_error(void)
1364 static PyObject *raise_revlog_error(void)
1357 {
1365 {
1358 static PyObject *errclass;
1366 static PyObject *errclass;
1359 PyObject *mod = NULL, *errobj;
1367 PyObject *mod = NULL, *errobj;
1360
1368
1361 if (errclass == NULL) {
1369 if (errclass == NULL) {
1362 PyObject *dict;
1370 PyObject *dict;
1363
1371
1364 mod = PyImport_ImportModule("mercurial.error");
1372 mod = PyImport_ImportModule("mercurial.error");
1365 if (mod == NULL)
1373 if (mod == NULL)
1366 goto classfail;
1374 goto classfail;
1367
1375
1368 dict = PyModule_GetDict(mod);
1376 dict = PyModule_GetDict(mod);
1369 if (dict == NULL)
1377 if (dict == NULL)
1370 goto classfail;
1378 goto classfail;
1371
1379
1372 errclass = PyDict_GetItemString(dict, "RevlogError");
1380 errclass = PyDict_GetItemString(dict, "RevlogError");
1373 if (errclass == NULL) {
1381 if (errclass == NULL) {
1374 PyErr_SetString(PyExc_SystemError,
1382 PyErr_SetString(PyExc_SystemError,
1375 "could not find RevlogError");
1383 "could not find RevlogError");
1376 goto classfail;
1384 goto classfail;
1377 }
1385 }
1378 Py_INCREF(errclass);
1386 Py_INCREF(errclass);
1379 Py_DECREF(mod);
1387 Py_DECREF(mod);
1380 }
1388 }
1381
1389
1382 errobj = PyObject_CallFunction(errclass, NULL);
1390 errobj = PyObject_CallFunction(errclass, NULL);
1383 if (errobj == NULL)
1391 if (errobj == NULL)
1384 return NULL;
1392 return NULL;
1385 PyErr_SetObject(errclass, errobj);
1393 PyErr_SetObject(errclass, errobj);
1386 return errobj;
1394 return errobj;
1387
1395
1388 classfail:
1396 classfail:
1389 Py_XDECREF(mod);
1397 Py_XDECREF(mod);
1390 return NULL;
1398 return NULL;
1391 }
1399 }
1392
1400
1393 static PyObject *index_getitem(indexObject *self, PyObject *value)
1401 static PyObject *index_getitem(indexObject *self, PyObject *value)
1394 {
1402 {
1395 char *node;
1403 char *node;
1396 Py_ssize_t nodelen;
1404 Py_ssize_t nodelen;
1397 int rev;
1405 int rev;
1398
1406
1399 if (PyInt_Check(value))
1407 if (PyInt_Check(value))
1400 return index_get(self, PyInt_AS_LONG(value));
1408 return index_get(self, PyInt_AS_LONG(value));
1401
1409
1402 if (node_check(value, &node, &nodelen) == -1)
1410 if (node_check(value, &node, &nodelen) == -1)
1403 return NULL;
1411 return NULL;
1404 rev = index_find_node(self, node, nodelen);
1412 rev = index_find_node(self, node, nodelen);
1405 if (rev >= -1)
1413 if (rev >= -1)
1406 return PyInt_FromLong(rev);
1414 return PyInt_FromLong(rev);
1407 if (rev == -2)
1415 if (rev == -2)
1408 raise_revlog_error();
1416 raise_revlog_error();
1409 return NULL;
1417 return NULL;
1410 }
1418 }
1411
1419
1412 static int nt_partialmatch(indexObject *self, const char *node,
1420 static int nt_partialmatch(indexObject *self, const char *node,
1413 Py_ssize_t nodelen)
1421 Py_ssize_t nodelen)
1414 {
1422 {
1415 int rev;
1423 int rev;
1416
1424
1417 if (nt_init(self) == -1)
1425 if (nt_init(self) == -1)
1418 return -3;
1426 return -3;
1419
1427
1420 if (self->ntrev > 0) {
1428 if (self->ntrev > 0) {
1421 /* ensure that the radix tree is fully populated */
1429 /* ensure that the radix tree is fully populated */
1422 for (rev = self->ntrev - 1; rev >= 0; rev--) {
1430 for (rev = self->ntrev - 1; rev >= 0; rev--) {
1423 const char *n = index_node(self, rev);
1431 const char *n = index_node(self, rev);
1424 if (n == NULL)
1432 if (n == NULL)
1425 return -2;
1433 return -2;
1426 if (nt_insert(self, n, rev) == -1)
1434 if (nt_insert(self, n, rev) == -1)
1427 return -3;
1435 return -3;
1428 }
1436 }
1429 self->ntrev = rev;
1437 self->ntrev = rev;
1430 }
1438 }
1431
1439
1432 return nt_find(self, node, nodelen, 1);
1440 return nt_find(self, node, nodelen, 1);
1433 }
1441 }
1434
1442
1435 static PyObject *index_partialmatch(indexObject *self, PyObject *args)
1443 static PyObject *index_partialmatch(indexObject *self, PyObject *args)
1436 {
1444 {
1437 const char *fullnode;
1445 const char *fullnode;
1438 int nodelen;
1446 int nodelen;
1439 char *node;
1447 char *node;
1440 int rev, i;
1448 int rev, i;
1441
1449
1442 if (!PyArg_ParseTuple(args, "s#", &node, &nodelen))
1450 if (!PyArg_ParseTuple(args, "s#", &node, &nodelen))
1443 return NULL;
1451 return NULL;
1444
1452
1445 if (nodelen < 4) {
1453 if (nodelen < 4) {
1446 PyErr_SetString(PyExc_ValueError, "key too short");
1454 PyErr_SetString(PyExc_ValueError, "key too short");
1447 return NULL;
1455 return NULL;
1448 }
1456 }
1449
1457
1450 if (nodelen > 40) {
1458 if (nodelen > 40) {
1451 PyErr_SetString(PyExc_ValueError, "key too long");
1459 PyErr_SetString(PyExc_ValueError, "key too long");
1452 return NULL;
1460 return NULL;
1453 }
1461 }
1454
1462
1455 for (i = 0; i < nodelen; i++)
1463 for (i = 0; i < nodelen; i++)
1456 hexdigit(node, i);
1464 hexdigit(node, i);
1457 if (PyErr_Occurred()) {
1465 if (PyErr_Occurred()) {
1458 /* input contains non-hex characters */
1466 /* input contains non-hex characters */
1459 PyErr_Clear();
1467 PyErr_Clear();
1460 Py_RETURN_NONE;
1468 Py_RETURN_NONE;
1461 }
1469 }
1462
1470
1463 rev = nt_partialmatch(self, node, nodelen);
1471 rev = nt_partialmatch(self, node, nodelen);
1464
1472
1465 switch (rev) {
1473 switch (rev) {
1466 case -4:
1474 case -4:
1467 raise_revlog_error();
1475 raise_revlog_error();
1468 case -3:
1476 case -3:
1469 return NULL;
1477 return NULL;
1470 case -2:
1478 case -2:
1471 Py_RETURN_NONE;
1479 Py_RETURN_NONE;
1472 case -1:
1480 case -1:
1473 return PyString_FromStringAndSize(nullid, 20);
1481 return PyString_FromStringAndSize(nullid, 20);
1474 }
1482 }
1475
1483
1476 fullnode = index_node(self, rev);
1484 fullnode = index_node(self, rev);
1477 if (fullnode == NULL) {
1485 if (fullnode == NULL) {
1478 PyErr_Format(PyExc_IndexError,
1486 PyErr_Format(PyExc_IndexError,
1479 "could not access rev %d", rev);
1487 "could not access rev %d", rev);
1480 return NULL;
1488 return NULL;
1481 }
1489 }
1482 return PyString_FromStringAndSize(fullnode, 20);
1490 return PyString_FromStringAndSize(fullnode, 20);
1483 }
1491 }
1484
1492
1485 static PyObject *index_m_get(indexObject *self, PyObject *args)
1493 static PyObject *index_m_get(indexObject *self, PyObject *args)
1486 {
1494 {
1487 Py_ssize_t nodelen;
1495 Py_ssize_t nodelen;
1488 PyObject *val;
1496 PyObject *val;
1489 char *node;
1497 char *node;
1490 int rev;
1498 int rev;
1491
1499
1492 if (!PyArg_ParseTuple(args, "O", &val))
1500 if (!PyArg_ParseTuple(args, "O", &val))
1493 return NULL;
1501 return NULL;
1494 if (node_check(val, &node, &nodelen) == -1)
1502 if (node_check(val, &node, &nodelen) == -1)
1495 return NULL;
1503 return NULL;
1496 rev = index_find_node(self, node, nodelen);
1504 rev = index_find_node(self, node, nodelen);
1497 if (rev == -3)
1505 if (rev == -3)
1498 return NULL;
1506 return NULL;
1499 if (rev == -2)
1507 if (rev == -2)
1500 Py_RETURN_NONE;
1508 Py_RETURN_NONE;
1501 return PyInt_FromLong(rev);
1509 return PyInt_FromLong(rev);
1502 }
1510 }
1503
1511
1504 static int index_contains(indexObject *self, PyObject *value)
1512 static int index_contains(indexObject *self, PyObject *value)
1505 {
1513 {
1506 char *node;
1514 char *node;
1507 Py_ssize_t nodelen;
1515 Py_ssize_t nodelen;
1508
1516
1509 if (PyInt_Check(value)) {
1517 if (PyInt_Check(value)) {
1510 long rev = PyInt_AS_LONG(value);
1518 long rev = PyInt_AS_LONG(value);
1511 return rev >= -1 && rev < index_length(self);
1519 return rev >= -1 && rev < index_length(self);
1512 }
1520 }
1513
1521
1514 if (node_check(value, &node, &nodelen) == -1)
1522 if (node_check(value, &node, &nodelen) == -1)
1515 return -1;
1523 return -1;
1516
1524
1517 switch (index_find_node(self, node, nodelen)) {
1525 switch (index_find_node(self, node, nodelen)) {
1518 case -3:
1526 case -3:
1519 return -1;
1527 return -1;
1520 case -2:
1528 case -2:
1521 return 0;
1529 return 0;
1522 default:
1530 default:
1523 return 1;
1531 return 1;
1524 }
1532 }
1525 }
1533 }
1526
1534
1527 static inline void index_get_parents(indexObject *self, int rev, int *ps)
1535 static inline void index_get_parents(indexObject *self, int rev, int *ps)
1528 {
1536 {
1529 if (rev >= self->length - 1) {
1537 if (rev >= self->length - 1) {
1530 PyObject *tuple = PyList_GET_ITEM(self->added,
1538 PyObject *tuple = PyList_GET_ITEM(self->added,
1531 rev - self->length + 1);
1539 rev - self->length + 1);
1532 ps[0] = (int)PyInt_AS_LONG(PyTuple_GET_ITEM(tuple, 5));
1540 ps[0] = (int)PyInt_AS_LONG(PyTuple_GET_ITEM(tuple, 5));
1533 ps[1] = (int)PyInt_AS_LONG(PyTuple_GET_ITEM(tuple, 6));
1541 ps[1] = (int)PyInt_AS_LONG(PyTuple_GET_ITEM(tuple, 6));
1534 } else {
1542 } else {
1535 const char *data = index_deref(self, rev);
1543 const char *data = index_deref(self, rev);
1536 ps[0] = getbe32(data + 24);
1544 ps[0] = getbe32(data + 24);
1537 ps[1] = getbe32(data + 28);
1545 ps[1] = getbe32(data + 28);
1538 }
1546 }
1539 }
1547 }
1540
1548
1541 typedef uint64_t bitmask;
1549 typedef uint64_t bitmask;
1542
1550
1543 /*
1551 /*
1544 * Given a disjoint set of revs, return all candidates for the
1552 * Given a disjoint set of revs, return all candidates for the
1545 * greatest common ancestor. In revset notation, this is the set
1553 * greatest common ancestor. In revset notation, this is the set
1546 * "heads(::a and ::b and ...)"
1554 * "heads(::a and ::b and ...)"
1547 */
1555 */
1548 static PyObject *find_gca_candidates(indexObject *self, const int *revs,
1556 static PyObject *find_gca_candidates(indexObject *self, const int *revs,
1549 int revcount)
1557 int revcount)
1550 {
1558 {
1551 const bitmask allseen = (1ull << revcount) - 1;
1559 const bitmask allseen = (1ull << revcount) - 1;
1552 const bitmask poison = 1ull << revcount;
1560 const bitmask poison = 1ull << revcount;
1553 PyObject *gca = PyList_New(0);
1561 PyObject *gca = PyList_New(0);
1554 int i, v, interesting;
1562 int i, v, interesting;
1555 int maxrev = -1;
1563 int maxrev = -1;
1556 bitmask sp;
1564 bitmask sp;
1557 bitmask *seen;
1565 bitmask *seen;
1558
1566
1559 if (gca == NULL)
1567 if (gca == NULL)
1560 return PyErr_NoMemory();
1568 return PyErr_NoMemory();
1561
1569
1562 for (i = 0; i < revcount; i++) {
1570 for (i = 0; i < revcount; i++) {
1563 if (revs[i] > maxrev)
1571 if (revs[i] > maxrev)
1564 maxrev = revs[i];
1572 maxrev = revs[i];
1565 }
1573 }
1566
1574
1567 seen = calloc(sizeof(*seen), maxrev + 1);
1575 seen = calloc(sizeof(*seen), maxrev + 1);
1568 if (seen == NULL) {
1576 if (seen == NULL) {
1569 Py_DECREF(gca);
1577 Py_DECREF(gca);
1570 return PyErr_NoMemory();
1578 return PyErr_NoMemory();
1571 }
1579 }
1572
1580
1573 for (i = 0; i < revcount; i++)
1581 for (i = 0; i < revcount; i++)
1574 seen[revs[i]] = 1ull << i;
1582 seen[revs[i]] = 1ull << i;
1575
1583
1576 interesting = revcount;
1584 interesting = revcount;
1577
1585
1578 for (v = maxrev; v >= 0 && interesting; v--) {
1586 for (v = maxrev; v >= 0 && interesting; v--) {
1579 bitmask sv = seen[v];
1587 bitmask sv = seen[v];
1580 int parents[2];
1588 int parents[2];
1581
1589
1582 if (!sv)
1590 if (!sv)
1583 continue;
1591 continue;
1584
1592
1585 if (sv < poison) {
1593 if (sv < poison) {
1586 interesting -= 1;
1594 interesting -= 1;
1587 if (sv == allseen) {
1595 if (sv == allseen) {
1588 PyObject *obj = PyInt_FromLong(v);
1596 PyObject *obj = PyInt_FromLong(v);
1589 if (obj == NULL)
1597 if (obj == NULL)
1590 goto bail;
1598 goto bail;
1591 if (PyList_Append(gca, obj) == -1) {
1599 if (PyList_Append(gca, obj) == -1) {
1592 Py_DECREF(obj);
1600 Py_DECREF(obj);
1593 goto bail;
1601 goto bail;
1594 }
1602 }
1595 sv |= poison;
1603 sv |= poison;
1596 for (i = 0; i < revcount; i++) {
1604 for (i = 0; i < revcount; i++) {
1597 if (revs[i] == v)
1605 if (revs[i] == v)
1598 goto done;
1606 goto done;
1599 }
1607 }
1600 }
1608 }
1601 }
1609 }
1602 index_get_parents(self, v, parents);
1610 index_get_parents(self, v, parents);
1603
1611
1604 for (i = 0; i < 2; i++) {
1612 for (i = 0; i < 2; i++) {
1605 int p = parents[i];
1613 int p = parents[i];
1606 if (p == -1)
1614 if (p == -1)
1607 continue;
1615 continue;
1608 sp = seen[p];
1616 sp = seen[p];
1609 if (sv < poison) {
1617 if (sv < poison) {
1610 if (sp == 0) {
1618 if (sp == 0) {
1611 seen[p] = sv;
1619 seen[p] = sv;
1612 interesting++;
1620 interesting++;
1613 }
1621 }
1614 else if (sp != sv)
1622 else if (sp != sv)
1615 seen[p] |= sv;
1623 seen[p] |= sv;
1616 } else {
1624 } else {
1617 if (sp && sp < poison)
1625 if (sp && sp < poison)
1618 interesting--;
1626 interesting--;
1619 seen[p] = sv;
1627 seen[p] = sv;
1620 }
1628 }
1621 }
1629 }
1622 }
1630 }
1623
1631
1624 done:
1632 done:
1625 free(seen);
1633 free(seen);
1626 return gca;
1634 return gca;
1627 bail:
1635 bail:
1628 free(seen);
1636 free(seen);
1629 Py_XDECREF(gca);
1637 Py_XDECREF(gca);
1630 return NULL;
1638 return NULL;
1631 }
1639 }
1632
1640
1633 /*
1641 /*
1634 * Given a disjoint set of revs, return the subset with the longest
1642 * Given a disjoint set of revs, return the subset with the longest
1635 * path to the root.
1643 * path to the root.
1636 */
1644 */
1637 static PyObject *find_deepest(indexObject *self, PyObject *revs)
1645 static PyObject *find_deepest(indexObject *self, PyObject *revs)
1638 {
1646 {
1639 const Py_ssize_t revcount = PyList_GET_SIZE(revs);
1647 const Py_ssize_t revcount = PyList_GET_SIZE(revs);
1640 static const Py_ssize_t capacity = 24;
1648 static const Py_ssize_t capacity = 24;
1641 int *depth, *interesting = NULL;
1649 int *depth, *interesting = NULL;
1642 int i, j, v, ninteresting;
1650 int i, j, v, ninteresting;
1643 PyObject *dict = NULL, *keys = NULL;
1651 PyObject *dict = NULL, *keys = NULL;
1644 long *seen = NULL;
1652 long *seen = NULL;
1645 int maxrev = -1;
1653 int maxrev = -1;
1646 long final;
1654 long final;
1647
1655
1648 if (revcount > capacity) {
1656 if (revcount > capacity) {
1649 PyErr_Format(PyExc_OverflowError,
1657 PyErr_Format(PyExc_OverflowError,
1650 "bitset size (%ld) > capacity (%ld)",
1658 "bitset size (%ld) > capacity (%ld)",
1651 (long)revcount, (long)capacity);
1659 (long)revcount, (long)capacity);
1652 return NULL;
1660 return NULL;
1653 }
1661 }
1654
1662
1655 for (i = 0; i < revcount; i++) {
1663 for (i = 0; i < revcount; i++) {
1656 int n = (int)PyInt_AsLong(PyList_GET_ITEM(revs, i));
1664 int n = (int)PyInt_AsLong(PyList_GET_ITEM(revs, i));
1657 if (n > maxrev)
1665 if (n > maxrev)
1658 maxrev = n;
1666 maxrev = n;
1659 }
1667 }
1660
1668
1661 depth = calloc(sizeof(*depth), maxrev + 1);
1669 depth = calloc(sizeof(*depth), maxrev + 1);
1662 if (depth == NULL)
1670 if (depth == NULL)
1663 return PyErr_NoMemory();
1671 return PyErr_NoMemory();
1664
1672
1665 seen = calloc(sizeof(*seen), maxrev + 1);
1673 seen = calloc(sizeof(*seen), maxrev + 1);
1666 if (seen == NULL) {
1674 if (seen == NULL) {
1667 PyErr_NoMemory();
1675 PyErr_NoMemory();
1668 goto bail;
1676 goto bail;
1669 }
1677 }
1670
1678
1671 interesting = calloc(sizeof(*interesting), 2 << revcount);
1679 interesting = calloc(sizeof(*interesting), 2 << revcount);
1672 if (interesting == NULL) {
1680 if (interesting == NULL) {
1673 PyErr_NoMemory();
1681 PyErr_NoMemory();
1674 goto bail;
1682 goto bail;
1675 }
1683 }
1676
1684
1677 if (PyList_Sort(revs) == -1)
1685 if (PyList_Sort(revs) == -1)
1678 goto bail;
1686 goto bail;
1679
1687
1680 for (i = 0; i < revcount; i++) {
1688 for (i = 0; i < revcount; i++) {
1681 int n = (int)PyInt_AsLong(PyList_GET_ITEM(revs, i));
1689 int n = (int)PyInt_AsLong(PyList_GET_ITEM(revs, i));
1682 long b = 1l << i;
1690 long b = 1l << i;
1683 depth[n] = 1;
1691 depth[n] = 1;
1684 seen[n] = b;
1692 seen[n] = b;
1685 interesting[b] = 1;
1693 interesting[b] = 1;
1686 }
1694 }
1687
1695
1688 ninteresting = (int)revcount;
1696 ninteresting = (int)revcount;
1689
1697
1690 for (v = maxrev; v >= 0 && ninteresting > 1; v--) {
1698 for (v = maxrev; v >= 0 && ninteresting > 1; v--) {
1691 int dv = depth[v];
1699 int dv = depth[v];
1692 int parents[2];
1700 int parents[2];
1693 long sv;
1701 long sv;
1694
1702
1695 if (dv == 0)
1703 if (dv == 0)
1696 continue;
1704 continue;
1697
1705
1698 sv = seen[v];
1706 sv = seen[v];
1699 index_get_parents(self, v, parents);
1707 index_get_parents(self, v, parents);
1700
1708
1701 for (i = 0; i < 2; i++) {
1709 for (i = 0; i < 2; i++) {
1702 int p = parents[i];
1710 int p = parents[i];
1703 long nsp, sp;
1711 long nsp, sp;
1704 int dp;
1712 int dp;
1705
1713
1706 if (p == -1)
1714 if (p == -1)
1707 continue;
1715 continue;
1708
1716
1709 dp = depth[p];
1717 dp = depth[p];
1710 nsp = sp = seen[p];
1718 nsp = sp = seen[p];
1711 if (dp <= dv) {
1719 if (dp <= dv) {
1712 depth[p] = dv + 1;
1720 depth[p] = dv + 1;
1713 if (sp != sv) {
1721 if (sp != sv) {
1714 interesting[sv] += 1;
1722 interesting[sv] += 1;
1715 nsp = seen[p] = sv;
1723 nsp = seen[p] = sv;
1716 if (sp) {
1724 if (sp) {
1717 interesting[sp] -= 1;
1725 interesting[sp] -= 1;
1718 if (interesting[sp] == 0)
1726 if (interesting[sp] == 0)
1719 ninteresting -= 1;
1727 ninteresting -= 1;
1720 }
1728 }
1721 }
1729 }
1722 }
1730 }
1723 else if (dv == dp - 1) {
1731 else if (dv == dp - 1) {
1724 nsp = sp | sv;
1732 nsp = sp | sv;
1725 if (nsp == sp)
1733 if (nsp == sp)
1726 continue;
1734 continue;
1727 seen[p] = nsp;
1735 seen[p] = nsp;
1728 interesting[sp] -= 1;
1736 interesting[sp] -= 1;
1729 if (interesting[sp] == 0 && interesting[nsp] > 0)
1737 if (interesting[sp] == 0 && interesting[nsp] > 0)
1730 ninteresting -= 1;
1738 ninteresting -= 1;
1731 interesting[nsp] += 1;
1739 interesting[nsp] += 1;
1732 }
1740 }
1733 }
1741 }
1734 interesting[sv] -= 1;
1742 interesting[sv] -= 1;
1735 if (interesting[sv] == 0)
1743 if (interesting[sv] == 0)
1736 ninteresting -= 1;
1744 ninteresting -= 1;
1737 }
1745 }
1738
1746
1739 final = 0;
1747 final = 0;
1740 j = ninteresting;
1748 j = ninteresting;
1741 for (i = 0; i < (int)(2 << revcount) && j > 0; i++) {
1749 for (i = 0; i < (int)(2 << revcount) && j > 0; i++) {
1742 if (interesting[i] == 0)
1750 if (interesting[i] == 0)
1743 continue;
1751 continue;
1744 final |= i;
1752 final |= i;
1745 j -= 1;
1753 j -= 1;
1746 }
1754 }
1747 if (final == 0) {
1755 if (final == 0) {
1748 keys = PyList_New(0);
1756 keys = PyList_New(0);
1749 goto bail;
1757 goto bail;
1750 }
1758 }
1751
1759
1752 dict = PyDict_New();
1760 dict = PyDict_New();
1753 if (dict == NULL)
1761 if (dict == NULL)
1754 goto bail;
1762 goto bail;
1755
1763
1756 for (i = 0; i < revcount; i++) {
1764 for (i = 0; i < revcount; i++) {
1757 PyObject *key;
1765 PyObject *key;
1758
1766
1759 if ((final & (1 << i)) == 0)
1767 if ((final & (1 << i)) == 0)
1760 continue;
1768 continue;
1761
1769
1762 key = PyList_GET_ITEM(revs, i);
1770 key = PyList_GET_ITEM(revs, i);
1763 Py_INCREF(key);
1771 Py_INCREF(key);
1764 Py_INCREF(Py_None);
1772 Py_INCREF(Py_None);
1765 if (PyDict_SetItem(dict, key, Py_None) == -1) {
1773 if (PyDict_SetItem(dict, key, Py_None) == -1) {
1766 Py_DECREF(key);
1774 Py_DECREF(key);
1767 Py_DECREF(Py_None);
1775 Py_DECREF(Py_None);
1768 goto bail;
1776 goto bail;
1769 }
1777 }
1770 }
1778 }
1771
1779
1772 keys = PyDict_Keys(dict);
1780 keys = PyDict_Keys(dict);
1773
1781
1774 bail:
1782 bail:
1775 free(depth);
1783 free(depth);
1776 free(seen);
1784 free(seen);
1777 free(interesting);
1785 free(interesting);
1778 Py_XDECREF(dict);
1786 Py_XDECREF(dict);
1779
1787
1780 return keys;
1788 return keys;
1781 }
1789 }
1782
1790
1783 /*
1791 /*
1784 * Given a (possibly overlapping) set of revs, return all the
1792 * Given a (possibly overlapping) set of revs, return all the
1785 * common ancestors heads: heads(::args[0] and ::a[1] and ...)
1793 * common ancestors heads: heads(::args[0] and ::a[1] and ...)
1786 */
1794 */
1787 static PyObject *index_commonancestorsheads(indexObject *self, PyObject *args)
1795 static PyObject *index_commonancestorsheads(indexObject *self, PyObject *args)
1788 {
1796 {
1789 PyObject *ret = NULL;
1797 PyObject *ret = NULL;
1790 Py_ssize_t argcount, i, len;
1798 Py_ssize_t argcount, i, len;
1791 bitmask repeat = 0;
1799 bitmask repeat = 0;
1792 int revcount = 0;
1800 int revcount = 0;
1793 int *revs;
1801 int *revs;
1794
1802
1795 argcount = PySequence_Length(args);
1803 argcount = PySequence_Length(args);
1796 revs = malloc(argcount * sizeof(*revs));
1804 revs = malloc(argcount * sizeof(*revs));
1797 if (argcount > 0 && revs == NULL)
1805 if (argcount > 0 && revs == NULL)
1798 return PyErr_NoMemory();
1806 return PyErr_NoMemory();
1799 len = index_length(self) - 1;
1807 len = index_length(self) - 1;
1800
1808
1801 for (i = 0; i < argcount; i++) {
1809 for (i = 0; i < argcount; i++) {
1802 static const int capacity = 24;
1810 static const int capacity = 24;
1803 PyObject *obj = PySequence_GetItem(args, i);
1811 PyObject *obj = PySequence_GetItem(args, i);
1804 bitmask x;
1812 bitmask x;
1805 long val;
1813 long val;
1806
1814
1807 if (!PyInt_Check(obj)) {
1815 if (!PyInt_Check(obj)) {
1808 PyErr_SetString(PyExc_TypeError,
1816 PyErr_SetString(PyExc_TypeError,
1809 "arguments must all be ints");
1817 "arguments must all be ints");
1810 Py_DECREF(obj);
1818 Py_DECREF(obj);
1811 goto bail;
1819 goto bail;
1812 }
1820 }
1813 val = PyInt_AsLong(obj);
1821 val = PyInt_AsLong(obj);
1814 Py_DECREF(obj);
1822 Py_DECREF(obj);
1815 if (val == -1) {
1823 if (val == -1) {
1816 ret = PyList_New(0);
1824 ret = PyList_New(0);
1817 goto done;
1825 goto done;
1818 }
1826 }
1819 if (val < 0 || val >= len) {
1827 if (val < 0 || val >= len) {
1820 PyErr_SetString(PyExc_IndexError,
1828 PyErr_SetString(PyExc_IndexError,
1821 "index out of range");
1829 "index out of range");
1822 goto bail;
1830 goto bail;
1823 }
1831 }
1824 /* this cheesy bloom filter lets us avoid some more
1832 /* this cheesy bloom filter lets us avoid some more
1825 * expensive duplicate checks in the common set-is-disjoint
1833 * expensive duplicate checks in the common set-is-disjoint
1826 * case */
1834 * case */
1827 x = 1ull << (val & 0x3f);
1835 x = 1ull << (val & 0x3f);
1828 if (repeat & x) {
1836 if (repeat & x) {
1829 int k;
1837 int k;
1830 for (k = 0; k < revcount; k++) {
1838 for (k = 0; k < revcount; k++) {
1831 if (val == revs[k])
1839 if (val == revs[k])
1832 goto duplicate;
1840 goto duplicate;
1833 }
1841 }
1834 }
1842 }
1835 else repeat |= x;
1843 else repeat |= x;
1836 if (revcount >= capacity) {
1844 if (revcount >= capacity) {
1837 PyErr_Format(PyExc_OverflowError,
1845 PyErr_Format(PyExc_OverflowError,
1838 "bitset size (%d) > capacity (%d)",
1846 "bitset size (%d) > capacity (%d)",
1839 revcount, capacity);
1847 revcount, capacity);
1840 goto bail;
1848 goto bail;
1841 }
1849 }
1842 revs[revcount++] = (int)val;
1850 revs[revcount++] = (int)val;
1843 duplicate:;
1851 duplicate:;
1844 }
1852 }
1845
1853
1846 if (revcount == 0) {
1854 if (revcount == 0) {
1847 ret = PyList_New(0);
1855 ret = PyList_New(0);
1848 goto done;
1856 goto done;
1849 }
1857 }
1850 if (revcount == 1) {
1858 if (revcount == 1) {
1851 PyObject *obj;
1859 PyObject *obj;
1852 ret = PyList_New(1);
1860 ret = PyList_New(1);
1853 if (ret == NULL)
1861 if (ret == NULL)
1854 goto bail;
1862 goto bail;
1855 obj = PyInt_FromLong(revs[0]);
1863 obj = PyInt_FromLong(revs[0]);
1856 if (obj == NULL)
1864 if (obj == NULL)
1857 goto bail;
1865 goto bail;
1858 PyList_SET_ITEM(ret, 0, obj);
1866 PyList_SET_ITEM(ret, 0, obj);
1859 goto done;
1867 goto done;
1860 }
1868 }
1861
1869
1862 ret = find_gca_candidates(self, revs, revcount);
1870 ret = find_gca_candidates(self, revs, revcount);
1863 if (ret == NULL)
1871 if (ret == NULL)
1864 goto bail;
1872 goto bail;
1865
1873
1866 done:
1874 done:
1867 free(revs);
1875 free(revs);
1868 return ret;
1876 return ret;
1869
1877
1870 bail:
1878 bail:
1871 free(revs);
1879 free(revs);
1872 Py_XDECREF(ret);
1880 Py_XDECREF(ret);
1873 return NULL;
1881 return NULL;
1874 }
1882 }
1875
1883
1876 /*
1884 /*
1877 * Given a (possibly overlapping) set of revs, return the greatest
1885 * Given a (possibly overlapping) set of revs, return the greatest
1878 * common ancestors: those with the longest path to the root.
1886 * common ancestors: those with the longest path to the root.
1879 */
1887 */
1880 static PyObject *index_ancestors(indexObject *self, PyObject *args)
1888 static PyObject *index_ancestors(indexObject *self, PyObject *args)
1881 {
1889 {
1882 PyObject *gca = index_commonancestorsheads(self, args);
1890 PyObject *gca = index_commonancestorsheads(self, args);
1883 if (gca == NULL)
1891 if (gca == NULL)
1884 return NULL;
1892 return NULL;
1885
1893
1886 if (PyList_GET_SIZE(gca) <= 1) {
1894 if (PyList_GET_SIZE(gca) <= 1) {
1887 Py_INCREF(gca);
1895 Py_INCREF(gca);
1888 return gca;
1896 return gca;
1889 }
1897 }
1890
1898
1891 return find_deepest(self, gca);
1899 return find_deepest(self, gca);
1892 }
1900 }
1893
1901
1894 /*
1902 /*
1895 * Invalidate any trie entries introduced by added revs.
1903 * Invalidate any trie entries introduced by added revs.
1896 */
1904 */
1897 static void nt_invalidate_added(indexObject *self, Py_ssize_t start)
1905 static void nt_invalidate_added(indexObject *self, Py_ssize_t start)
1898 {
1906 {
1899 Py_ssize_t i, len = PyList_GET_SIZE(self->added);
1907 Py_ssize_t i, len = PyList_GET_SIZE(self->added);
1900
1908
1901 for (i = start; i < len; i++) {
1909 for (i = start; i < len; i++) {
1902 PyObject *tuple = PyList_GET_ITEM(self->added, i);
1910 PyObject *tuple = PyList_GET_ITEM(self->added, i);
1903 PyObject *node = PyTuple_GET_ITEM(tuple, 7);
1911 PyObject *node = PyTuple_GET_ITEM(tuple, 7);
1904
1912
1905 nt_insert(self, PyString_AS_STRING(node), -1);
1913 nt_insert(self, PyString_AS_STRING(node), -1);
1906 }
1914 }
1907
1915
1908 if (start == 0)
1916 if (start == 0)
1909 Py_CLEAR(self->added);
1917 Py_CLEAR(self->added);
1910 }
1918 }
1911
1919
1912 /*
1920 /*
1913 * Delete a numeric range of revs, which must be at the end of the
1921 * Delete a numeric range of revs, which must be at the end of the
1914 * range, but exclude the sentinel nullid entry.
1922 * range, but exclude the sentinel nullid entry.
1915 */
1923 */
1916 static int index_slice_del(indexObject *self, PyObject *item)
1924 static int index_slice_del(indexObject *self, PyObject *item)
1917 {
1925 {
1918 Py_ssize_t start, stop, step, slicelength;
1926 Py_ssize_t start, stop, step, slicelength;
1919 Py_ssize_t length = index_length(self);
1927 Py_ssize_t length = index_length(self);
1920 int ret = 0;
1928 int ret = 0;
1921
1929
1922 if (PySlice_GetIndicesEx((PySliceObject*)item, length,
1930 if (PySlice_GetIndicesEx((PySliceObject*)item, length,
1923 &start, &stop, &step, &slicelength) < 0)
1931 &start, &stop, &step, &slicelength) < 0)
1924 return -1;
1932 return -1;
1925
1933
1926 if (slicelength <= 0)
1934 if (slicelength <= 0)
1927 return 0;
1935 return 0;
1928
1936
1929 if ((step < 0 && start < stop) || (step > 0 && start > stop))
1937 if ((step < 0 && start < stop) || (step > 0 && start > stop))
1930 stop = start;
1938 stop = start;
1931
1939
1932 if (step < 0) {
1940 if (step < 0) {
1933 stop = start + 1;
1941 stop = start + 1;
1934 start = stop + step*(slicelength - 1) - 1;
1942 start = stop + step*(slicelength - 1) - 1;
1935 step = -step;
1943 step = -step;
1936 }
1944 }
1937
1945
1938 if (step != 1) {
1946 if (step != 1) {
1939 PyErr_SetString(PyExc_ValueError,
1947 PyErr_SetString(PyExc_ValueError,
1940 "revlog index delete requires step size of 1");
1948 "revlog index delete requires step size of 1");
1941 return -1;
1949 return -1;
1942 }
1950 }
1943
1951
1944 if (stop != length - 1) {
1952 if (stop != length - 1) {
1945 PyErr_SetString(PyExc_IndexError,
1953 PyErr_SetString(PyExc_IndexError,
1946 "revlog index deletion indices are invalid");
1954 "revlog index deletion indices are invalid");
1947 return -1;
1955 return -1;
1948 }
1956 }
1949
1957
1950 if (start < self->length - 1) {
1958 if (start < self->length - 1) {
1951 if (self->nt) {
1959 if (self->nt) {
1952 Py_ssize_t i;
1960 Py_ssize_t i;
1953
1961
1954 for (i = start + 1; i < self->length - 1; i++) {
1962 for (i = start + 1; i < self->length - 1; i++) {
1955 const char *node = index_node(self, i);
1963 const char *node = index_node(self, i);
1956
1964
1957 if (node)
1965 if (node)
1958 nt_insert(self, node, -1);
1966 nt_insert(self, node, -1);
1959 }
1967 }
1960 if (self->added)
1968 if (self->added)
1961 nt_invalidate_added(self, 0);
1969 nt_invalidate_added(self, 0);
1962 if (self->ntrev > start)
1970 if (self->ntrev > start)
1963 self->ntrev = (int)start;
1971 self->ntrev = (int)start;
1964 }
1972 }
1965 self->length = start + 1;
1973 self->length = start + 1;
1966 if (start < self->raw_length) {
1974 if (start < self->raw_length) {
1967 if (self->cache) {
1975 if (self->cache) {
1968 Py_ssize_t i;
1976 Py_ssize_t i;
1969 for (i = start; i < self->raw_length; i++)
1977 for (i = start; i < self->raw_length; i++)
1970 Py_CLEAR(self->cache[i]);
1978 Py_CLEAR(self->cache[i]);
1971 }
1979 }
1972 self->raw_length = start;
1980 self->raw_length = start;
1973 }
1981 }
1974 goto done;
1982 goto done;
1975 }
1983 }
1976
1984
1977 if (self->nt) {
1985 if (self->nt) {
1978 nt_invalidate_added(self, start - self->length + 1);
1986 nt_invalidate_added(self, start - self->length + 1);
1979 if (self->ntrev > start)
1987 if (self->ntrev > start)
1980 self->ntrev = (int)start;
1988 self->ntrev = (int)start;
1981 }
1989 }
1982 if (self->added)
1990 if (self->added)
1983 ret = PyList_SetSlice(self->added, start - self->length + 1,
1991 ret = PyList_SetSlice(self->added, start - self->length + 1,
1984 PyList_GET_SIZE(self->added), NULL);
1992 PyList_GET_SIZE(self->added), NULL);
1985 done:
1993 done:
1986 Py_CLEAR(self->headrevs);
1994 Py_CLEAR(self->headrevs);
1987 return ret;
1995 return ret;
1988 }
1996 }
1989
1997
1990 /*
1998 /*
1991 * Supported ops:
1999 * Supported ops:
1992 *
2000 *
1993 * slice deletion
2001 * slice deletion
1994 * string assignment (extend node->rev mapping)
2002 * string assignment (extend node->rev mapping)
1995 * string deletion (shrink node->rev mapping)
2003 * string deletion (shrink node->rev mapping)
1996 */
2004 */
1997 static int index_assign_subscript(indexObject *self, PyObject *item,
2005 static int index_assign_subscript(indexObject *self, PyObject *item,
1998 PyObject *value)
2006 PyObject *value)
1999 {
2007 {
2000 char *node;
2008 char *node;
2001 Py_ssize_t nodelen;
2009 Py_ssize_t nodelen;
2002 long rev;
2010 long rev;
2003
2011
2004 if (PySlice_Check(item) && value == NULL)
2012 if (PySlice_Check(item) && value == NULL)
2005 return index_slice_del(self, item);
2013 return index_slice_del(self, item);
2006
2014
2007 if (node_check(item, &node, &nodelen) == -1)
2015 if (node_check(item, &node, &nodelen) == -1)
2008 return -1;
2016 return -1;
2009
2017
2010 if (value == NULL)
2018 if (value == NULL)
2011 return self->nt ? nt_insert(self, node, -1) : 0;
2019 return self->nt ? nt_insert(self, node, -1) : 0;
2012 rev = PyInt_AsLong(value);
2020 rev = PyInt_AsLong(value);
2013 if (rev > INT_MAX || rev < 0) {
2021 if (rev > INT_MAX || rev < 0) {
2014 if (!PyErr_Occurred())
2022 if (!PyErr_Occurred())
2015 PyErr_SetString(PyExc_ValueError, "rev out of range");
2023 PyErr_SetString(PyExc_ValueError, "rev out of range");
2016 return -1;
2024 return -1;
2017 }
2025 }
2018
2026
2019 if (nt_init(self) == -1)
2027 if (nt_init(self) == -1)
2020 return -1;
2028 return -1;
2021 return nt_insert(self, node, (int)rev);
2029 return nt_insert(self, node, (int)rev);
2022 }
2030 }
2023
2031
2024 /*
2032 /*
2025 * Find all RevlogNG entries in an index that has inline data. Update
2033 * Find all RevlogNG entries in an index that has inline data. Update
2026 * the optional "offsets" table with those entries.
2034 * the optional "offsets" table with those entries.
2027 */
2035 */
2028 static Py_ssize_t inline_scan(indexObject *self, const char **offsets)
2036 static Py_ssize_t inline_scan(indexObject *self, const char **offsets)
2029 {
2037 {
2030 const char *data = PyString_AS_STRING(self->data);
2038 const char *data = PyString_AS_STRING(self->data);
2031 Py_ssize_t pos = 0;
2039 Py_ssize_t pos = 0;
2032 Py_ssize_t end = PyString_GET_SIZE(self->data);
2040 Py_ssize_t end = PyString_GET_SIZE(self->data);
2033 long incr = v1_hdrsize;
2041 long incr = v1_hdrsize;
2034 Py_ssize_t len = 0;
2042 Py_ssize_t len = 0;
2035
2043
2036 while (pos + v1_hdrsize <= end && pos >= 0) {
2044 while (pos + v1_hdrsize <= end && pos >= 0) {
2037 uint32_t comp_len;
2045 uint32_t comp_len;
2038 /* 3rd element of header is length of compressed inline data */
2046 /* 3rd element of header is length of compressed inline data */
2039 comp_len = getbe32(data + pos + 8);
2047 comp_len = getbe32(data + pos + 8);
2040 incr = v1_hdrsize + comp_len;
2048 incr = v1_hdrsize + comp_len;
2041 if (offsets)
2049 if (offsets)
2042 offsets[len] = data + pos;
2050 offsets[len] = data + pos;
2043 len++;
2051 len++;
2044 pos += incr;
2052 pos += incr;
2045 }
2053 }
2046
2054
2047 if (pos != end) {
2055 if (pos != end) {
2048 if (!PyErr_Occurred())
2056 if (!PyErr_Occurred())
2049 PyErr_SetString(PyExc_ValueError, "corrupt index file");
2057 PyErr_SetString(PyExc_ValueError, "corrupt index file");
2050 return -1;
2058 return -1;
2051 }
2059 }
2052
2060
2053 return len;
2061 return len;
2054 }
2062 }
2055
2063
2056 static int index_init(indexObject *self, PyObject *args)
2064 static int index_init(indexObject *self, PyObject *args)
2057 {
2065 {
2058 PyObject *data_obj, *inlined_obj;
2066 PyObject *data_obj, *inlined_obj;
2059 Py_ssize_t size;
2067 Py_ssize_t size;
2060
2068
2061 /* Initialize before argument-checking to avoid index_dealloc() crash. */
2069 /* Initialize before argument-checking to avoid index_dealloc() crash. */
2062 self->raw_length = 0;
2070 self->raw_length = 0;
2063 self->added = NULL;
2071 self->added = NULL;
2064 self->cache = NULL;
2072 self->cache = NULL;
2065 self->data = NULL;
2073 self->data = NULL;
2066 self->headrevs = NULL;
2074 self->headrevs = NULL;
2067 self->filteredrevs = Py_None;
2075 self->filteredrevs = Py_None;
2068 Py_INCREF(Py_None);
2076 Py_INCREF(Py_None);
2069 self->nt = NULL;
2077 self->nt = NULL;
2070 self->offsets = NULL;
2078 self->offsets = NULL;
2071
2079
2072 if (!PyArg_ParseTuple(args, "OO", &data_obj, &inlined_obj))
2080 if (!PyArg_ParseTuple(args, "OO", &data_obj, &inlined_obj))
2073 return -1;
2081 return -1;
2074 if (!PyString_Check(data_obj)) {
2082 if (!PyString_Check(data_obj)) {
2075 PyErr_SetString(PyExc_TypeError, "data is not a string");
2083 PyErr_SetString(PyExc_TypeError, "data is not a string");
2076 return -1;
2084 return -1;
2077 }
2085 }
2078 size = PyString_GET_SIZE(data_obj);
2086 size = PyString_GET_SIZE(data_obj);
2079
2087
2080 self->inlined = inlined_obj && PyObject_IsTrue(inlined_obj);
2088 self->inlined = inlined_obj && PyObject_IsTrue(inlined_obj);
2081 self->data = data_obj;
2089 self->data = data_obj;
2082
2090
2083 self->ntlength = self->ntcapacity = 0;
2091 self->ntlength = self->ntcapacity = 0;
2084 self->ntdepth = self->ntsplits = 0;
2092 self->ntdepth = self->ntsplits = 0;
2085 self->ntlookups = self->ntmisses = 0;
2093 self->ntlookups = self->ntmisses = 0;
2086 self->ntrev = -1;
2094 self->ntrev = -1;
2087 Py_INCREF(self->data);
2095 Py_INCREF(self->data);
2088
2096
2089 if (self->inlined) {
2097 if (self->inlined) {
2090 Py_ssize_t len = inline_scan(self, NULL);
2098 Py_ssize_t len = inline_scan(self, NULL);
2091 if (len == -1)
2099 if (len == -1)
2092 goto bail;
2100 goto bail;
2093 self->raw_length = len;
2101 self->raw_length = len;
2094 self->length = len + 1;
2102 self->length = len + 1;
2095 } else {
2103 } else {
2096 if (size % v1_hdrsize) {
2104 if (size % v1_hdrsize) {
2097 PyErr_SetString(PyExc_ValueError, "corrupt index file");
2105 PyErr_SetString(PyExc_ValueError, "corrupt index file");
2098 goto bail;
2106 goto bail;
2099 }
2107 }
2100 self->raw_length = size / v1_hdrsize;
2108 self->raw_length = size / v1_hdrsize;
2101 self->length = self->raw_length + 1;
2109 self->length = self->raw_length + 1;
2102 }
2110 }
2103
2111
2104 return 0;
2112 return 0;
2105 bail:
2113 bail:
2106 return -1;
2114 return -1;
2107 }
2115 }
2108
2116
2109 static PyObject *index_nodemap(indexObject *self)
2117 static PyObject *index_nodemap(indexObject *self)
2110 {
2118 {
2111 Py_INCREF(self);
2119 Py_INCREF(self);
2112 return (PyObject *)self;
2120 return (PyObject *)self;
2113 }
2121 }
2114
2122
2115 static void index_dealloc(indexObject *self)
2123 static void index_dealloc(indexObject *self)
2116 {
2124 {
2117 _index_clearcaches(self);
2125 _index_clearcaches(self);
2118 Py_XDECREF(self->filteredrevs);
2126 Py_XDECREF(self->filteredrevs);
2119 Py_XDECREF(self->data);
2127 Py_XDECREF(self->data);
2120 Py_XDECREF(self->added);
2128 Py_XDECREF(self->added);
2121 PyObject_Del(self);
2129 PyObject_Del(self);
2122 }
2130 }
2123
2131
2124 static PySequenceMethods index_sequence_methods = {
2132 static PySequenceMethods index_sequence_methods = {
2125 (lenfunc)index_length, /* sq_length */
2133 (lenfunc)index_length, /* sq_length */
2126 0, /* sq_concat */
2134 0, /* sq_concat */
2127 0, /* sq_repeat */
2135 0, /* sq_repeat */
2128 (ssizeargfunc)index_get, /* sq_item */
2136 (ssizeargfunc)index_get, /* sq_item */
2129 0, /* sq_slice */
2137 0, /* sq_slice */
2130 0, /* sq_ass_item */
2138 0, /* sq_ass_item */
2131 0, /* sq_ass_slice */
2139 0, /* sq_ass_slice */
2132 (objobjproc)index_contains, /* sq_contains */
2140 (objobjproc)index_contains, /* sq_contains */
2133 };
2141 };
2134
2142
2135 static PyMappingMethods index_mapping_methods = {
2143 static PyMappingMethods index_mapping_methods = {
2136 (lenfunc)index_length, /* mp_length */
2144 (lenfunc)index_length, /* mp_length */
2137 (binaryfunc)index_getitem, /* mp_subscript */
2145 (binaryfunc)index_getitem, /* mp_subscript */
2138 (objobjargproc)index_assign_subscript, /* mp_ass_subscript */
2146 (objobjargproc)index_assign_subscript, /* mp_ass_subscript */
2139 };
2147 };
2140
2148
2141 static PyMethodDef index_methods[] = {
2149 static PyMethodDef index_methods[] = {
2142 {"ancestors", (PyCFunction)index_ancestors, METH_VARARGS,
2150 {"ancestors", (PyCFunction)index_ancestors, METH_VARARGS,
2143 "return the gca set of the given revs"},
2151 "return the gca set of the given revs"},
2144 {"commonancestorsheads", (PyCFunction)index_commonancestorsheads,
2152 {"commonancestorsheads", (PyCFunction)index_commonancestorsheads,
2145 METH_VARARGS,
2153 METH_VARARGS,
2146 "return the heads of the common ancestors of the given revs"},
2154 "return the heads of the common ancestors of the given revs"},
2147 {"clearcaches", (PyCFunction)index_clearcaches, METH_NOARGS,
2155 {"clearcaches", (PyCFunction)index_clearcaches, METH_NOARGS,
2148 "clear the index caches"},
2156 "clear the index caches"},
2149 {"get", (PyCFunction)index_m_get, METH_VARARGS,
2157 {"get", (PyCFunction)index_m_get, METH_VARARGS,
2150 "get an index entry"},
2158 "get an index entry"},
2151 {"computephases", (PyCFunction)compute_phases, METH_VARARGS,
2159 {"computephases", (PyCFunction)compute_phases, METH_VARARGS,
2152 "compute phases"},
2160 "compute phases"},
2153 {"headrevs", (PyCFunction)index_headrevs, METH_VARARGS,
2161 {"headrevs", (PyCFunction)index_headrevs, METH_VARARGS,
2154 "get head revisions"}, /* Can do filtering since 3.2 */
2162 "get head revisions"}, /* Can do filtering since 3.2 */
2155 {"headrevsfiltered", (PyCFunction)index_headrevs, METH_VARARGS,
2163 {"headrevsfiltered", (PyCFunction)index_headrevs, METH_VARARGS,
2156 "get filtered head revisions"}, /* Can always do filtering */
2164 "get filtered head revisions"}, /* Can always do filtering */
2157 {"insert", (PyCFunction)index_insert, METH_VARARGS,
2165 {"insert", (PyCFunction)index_insert, METH_VARARGS,
2158 "insert an index entry"},
2166 "insert an index entry"},
2159 {"partialmatch", (PyCFunction)index_partialmatch, METH_VARARGS,
2167 {"partialmatch", (PyCFunction)index_partialmatch, METH_VARARGS,
2160 "match a potentially ambiguous node ID"},
2168 "match a potentially ambiguous node ID"},
2161 {"stats", (PyCFunction)index_stats, METH_NOARGS,
2169 {"stats", (PyCFunction)index_stats, METH_NOARGS,
2162 "stats for the index"},
2170 "stats for the index"},
2163 {NULL} /* Sentinel */
2171 {NULL} /* Sentinel */
2164 };
2172 };
2165
2173
2166 static PyGetSetDef index_getset[] = {
2174 static PyGetSetDef index_getset[] = {
2167 {"nodemap", (getter)index_nodemap, NULL, "nodemap", NULL},
2175 {"nodemap", (getter)index_nodemap, NULL, "nodemap", NULL},
2168 {NULL} /* Sentinel */
2176 {NULL} /* Sentinel */
2169 };
2177 };
2170
2178
2171 static PyTypeObject indexType = {
2179 static PyTypeObject indexType = {
2172 PyObject_HEAD_INIT(NULL)
2180 PyObject_HEAD_INIT(NULL)
2173 0, /* ob_size */
2181 0, /* ob_size */
2174 "parsers.index", /* tp_name */
2182 "parsers.index", /* tp_name */
2175 sizeof(indexObject), /* tp_basicsize */
2183 sizeof(indexObject), /* tp_basicsize */
2176 0, /* tp_itemsize */
2184 0, /* tp_itemsize */
2177 (destructor)index_dealloc, /* tp_dealloc */
2185 (destructor)index_dealloc, /* tp_dealloc */
2178 0, /* tp_print */
2186 0, /* tp_print */
2179 0, /* tp_getattr */
2187 0, /* tp_getattr */
2180 0, /* tp_setattr */
2188 0, /* tp_setattr */
2181 0, /* tp_compare */
2189 0, /* tp_compare */
2182 0, /* tp_repr */
2190 0, /* tp_repr */
2183 0, /* tp_as_number */
2191 0, /* tp_as_number */
2184 &index_sequence_methods, /* tp_as_sequence */
2192 &index_sequence_methods, /* tp_as_sequence */
2185 &index_mapping_methods, /* tp_as_mapping */
2193 &index_mapping_methods, /* tp_as_mapping */
2186 0, /* tp_hash */
2194 0, /* tp_hash */
2187 0, /* tp_call */
2195 0, /* tp_call */
2188 0, /* tp_str */
2196 0, /* tp_str */
2189 0, /* tp_getattro */
2197 0, /* tp_getattro */
2190 0, /* tp_setattro */
2198 0, /* tp_setattro */
2191 0, /* tp_as_buffer */
2199 0, /* tp_as_buffer */
2192 Py_TPFLAGS_DEFAULT, /* tp_flags */
2200 Py_TPFLAGS_DEFAULT, /* tp_flags */
2193 "revlog index", /* tp_doc */
2201 "revlog index", /* tp_doc */
2194 0, /* tp_traverse */
2202 0, /* tp_traverse */
2195 0, /* tp_clear */
2203 0, /* tp_clear */
2196 0, /* tp_richcompare */
2204 0, /* tp_richcompare */
2197 0, /* tp_weaklistoffset */
2205 0, /* tp_weaklistoffset */
2198 0, /* tp_iter */
2206 0, /* tp_iter */
2199 0, /* tp_iternext */
2207 0, /* tp_iternext */
2200 index_methods, /* tp_methods */
2208 index_methods, /* tp_methods */
2201 0, /* tp_members */
2209 0, /* tp_members */
2202 index_getset, /* tp_getset */
2210 index_getset, /* tp_getset */
2203 0, /* tp_base */
2211 0, /* tp_base */
2204 0, /* tp_dict */
2212 0, /* tp_dict */
2205 0, /* tp_descr_get */
2213 0, /* tp_descr_get */
2206 0, /* tp_descr_set */
2214 0, /* tp_descr_set */
2207 0, /* tp_dictoffset */
2215 0, /* tp_dictoffset */
2208 (initproc)index_init, /* tp_init */
2216 (initproc)index_init, /* tp_init */
2209 0, /* tp_alloc */
2217 0, /* tp_alloc */
2210 };
2218 };
2211
2219
2212 /*
2220 /*
2213 * returns a tuple of the form (index, index, cache) with elements as
2221 * returns a tuple of the form (index, index, cache) with elements as
2214 * follows:
2222 * follows:
2215 *
2223 *
2216 * index: an index object that lazily parses RevlogNG records
2224 * index: an index object that lazily parses RevlogNG records
2217 * cache: if data is inlined, a tuple (index_file_content, 0), else None
2225 * cache: if data is inlined, a tuple (index_file_content, 0), else None
2218 *
2226 *
2219 * added complications are for backwards compatibility
2227 * added complications are for backwards compatibility
2220 */
2228 */
2221 static PyObject *parse_index2(PyObject *self, PyObject *args)
2229 static PyObject *parse_index2(PyObject *self, PyObject *args)
2222 {
2230 {
2223 PyObject *tuple = NULL, *cache = NULL;
2231 PyObject *tuple = NULL, *cache = NULL;
2224 indexObject *idx;
2232 indexObject *idx;
2225 int ret;
2233 int ret;
2226
2234
2227 idx = PyObject_New(indexObject, &indexType);
2235 idx = PyObject_New(indexObject, &indexType);
2228 if (idx == NULL)
2236 if (idx == NULL)
2229 goto bail;
2237 goto bail;
2230
2238
2231 ret = index_init(idx, args);
2239 ret = index_init(idx, args);
2232 if (ret == -1)
2240 if (ret == -1)
2233 goto bail;
2241 goto bail;
2234
2242
2235 if (idx->inlined) {
2243 if (idx->inlined) {
2236 cache = Py_BuildValue("iO", 0, idx->data);
2244 cache = Py_BuildValue("iO", 0, idx->data);
2237 if (cache == NULL)
2245 if (cache == NULL)
2238 goto bail;
2246 goto bail;
2239 } else {
2247 } else {
2240 cache = Py_None;
2248 cache = Py_None;
2241 Py_INCREF(cache);
2249 Py_INCREF(cache);
2242 }
2250 }
2243
2251
2244 tuple = Py_BuildValue("NN", idx, cache);
2252 tuple = Py_BuildValue("NN", idx, cache);
2245 if (!tuple)
2253 if (!tuple)
2246 goto bail;
2254 goto bail;
2247 return tuple;
2255 return tuple;
2248
2256
2249 bail:
2257 bail:
2250 Py_XDECREF(idx);
2258 Py_XDECREF(idx);
2251 Py_XDECREF(cache);
2259 Py_XDECREF(cache);
2252 Py_XDECREF(tuple);
2260 Py_XDECREF(tuple);
2253 return NULL;
2261 return NULL;
2254 }
2262 }
2255
2263
2256 #define BUMPED_FIX 1
2264 #define BUMPED_FIX 1
2257 #define USING_SHA_256 2
2265 #define USING_SHA_256 2
2258
2266
2259 static PyObject *readshas(
2267 static PyObject *readshas(
2260 const char *source, unsigned char num, Py_ssize_t hashwidth)
2268 const char *source, unsigned char num, Py_ssize_t hashwidth)
2261 {
2269 {
2262 int i;
2270 int i;
2263 PyObject *list = PyTuple_New(num);
2271 PyObject *list = PyTuple_New(num);
2264 if (list == NULL) {
2272 if (list == NULL) {
2265 return NULL;
2273 return NULL;
2266 }
2274 }
2267 for (i = 0; i < num; i++) {
2275 for (i = 0; i < num; i++) {
2268 PyObject *hash = PyString_FromStringAndSize(source, hashwidth);
2276 PyObject *hash = PyString_FromStringAndSize(source, hashwidth);
2269 if (hash == NULL) {
2277 if (hash == NULL) {
2270 Py_DECREF(list);
2278 Py_DECREF(list);
2271 return NULL;
2279 return NULL;
2272 }
2280 }
2273 PyTuple_SetItem(list, i, hash);
2281 PyTuple_SetItem(list, i, hash);
2274 source += hashwidth;
2282 source += hashwidth;
2275 }
2283 }
2276 return list;
2284 return list;
2277 }
2285 }
2278
2286
2279 static PyObject *fm1readmarker(const char *data, uint32_t *msize)
2287 static PyObject *fm1readmarker(const char *data, uint32_t *msize)
2280 {
2288 {
2281 const char *meta;
2289 const char *meta;
2282
2290
2283 double mtime;
2291 double mtime;
2284 int16_t tz;
2292 int16_t tz;
2285 uint16_t flags;
2293 uint16_t flags;
2286 unsigned char nsuccs, nparents, nmetadata;
2294 unsigned char nsuccs, nparents, nmetadata;
2287 Py_ssize_t hashwidth = 20;
2295 Py_ssize_t hashwidth = 20;
2288
2296
2289 PyObject *prec = NULL, *parents = NULL, *succs = NULL;
2297 PyObject *prec = NULL, *parents = NULL, *succs = NULL;
2290 PyObject *metadata = NULL, *ret = NULL;
2298 PyObject *metadata = NULL, *ret = NULL;
2291 int i;
2299 int i;
2292
2300
2293 *msize = getbe32(data);
2301 *msize = getbe32(data);
2294 data += 4;
2302 data += 4;
2295 mtime = getbefloat64(data);
2303 mtime = getbefloat64(data);
2296 data += 8;
2304 data += 8;
2297 tz = getbeint16(data);
2305 tz = getbeint16(data);
2298 data += 2;
2306 data += 2;
2299 flags = getbeuint16(data);
2307 flags = getbeuint16(data);
2300 data += 2;
2308 data += 2;
2301
2309
2302 if (flags & USING_SHA_256) {
2310 if (flags & USING_SHA_256) {
2303 hashwidth = 32;
2311 hashwidth = 32;
2304 }
2312 }
2305
2313
2306 nsuccs = (unsigned char)(*data++);
2314 nsuccs = (unsigned char)(*data++);
2307 nparents = (unsigned char)(*data++);
2315 nparents = (unsigned char)(*data++);
2308 nmetadata = (unsigned char)(*data++);
2316 nmetadata = (unsigned char)(*data++);
2309
2317
2310 prec = PyString_FromStringAndSize(data, hashwidth);
2318 prec = PyString_FromStringAndSize(data, hashwidth);
2311 data += hashwidth;
2319 data += hashwidth;
2312 if (prec == NULL) {
2320 if (prec == NULL) {
2313 goto bail;
2321 goto bail;
2314 }
2322 }
2315
2323
2316 succs = readshas(data, nsuccs, hashwidth);
2324 succs = readshas(data, nsuccs, hashwidth);
2317 if (succs == NULL) {
2325 if (succs == NULL) {
2318 goto bail;
2326 goto bail;
2319 }
2327 }
2320 data += nsuccs * hashwidth;
2328 data += nsuccs * hashwidth;
2321
2329
2322 if (nparents == 1 || nparents == 2) {
2330 if (nparents == 1 || nparents == 2) {
2323 parents = readshas(data, nparents, hashwidth);
2331 parents = readshas(data, nparents, hashwidth);
2324 if (parents == NULL) {
2332 if (parents == NULL) {
2325 goto bail;
2333 goto bail;
2326 }
2334 }
2327 data += nparents * hashwidth;
2335 data += nparents * hashwidth;
2328 } else {
2336 } else {
2329 parents = Py_None;
2337 parents = Py_None;
2330 }
2338 }
2331
2339
2332 meta = data + (2 * nmetadata);
2340 meta = data + (2 * nmetadata);
2333 metadata = PyTuple_New(nmetadata);
2341 metadata = PyTuple_New(nmetadata);
2334 if (metadata == NULL) {
2342 if (metadata == NULL) {
2335 goto bail;
2343 goto bail;
2336 }
2344 }
2337 for (i = 0; i < nmetadata; i++) {
2345 for (i = 0; i < nmetadata; i++) {
2338 PyObject *tmp, *left = NULL, *right = NULL;
2346 PyObject *tmp, *left = NULL, *right = NULL;
2339 Py_ssize_t metasize = (unsigned char)(*data++);
2347 Py_ssize_t metasize = (unsigned char)(*data++);
2340 left = PyString_FromStringAndSize(meta, metasize);
2348 left = PyString_FromStringAndSize(meta, metasize);
2341 meta += metasize;
2349 meta += metasize;
2342 metasize = (unsigned char)(*data++);
2350 metasize = (unsigned char)(*data++);
2343 right = PyString_FromStringAndSize(meta, metasize);
2351 right = PyString_FromStringAndSize(meta, metasize);
2344 meta += metasize;
2352 meta += metasize;
2345 if (!left || !right) {
2353 if (!left || !right) {
2346 Py_XDECREF(left);
2354 Py_XDECREF(left);
2347 Py_XDECREF(right);
2355 Py_XDECREF(right);
2348 goto bail;
2356 goto bail;
2349 }
2357 }
2350 tmp = PyTuple_Pack(2, left, right);
2358 tmp = PyTuple_Pack(2, left, right);
2351 Py_DECREF(left);
2359 Py_DECREF(left);
2352 Py_DECREF(right);
2360 Py_DECREF(right);
2353 if (!tmp) {
2361 if (!tmp) {
2354 goto bail;
2362 goto bail;
2355 }
2363 }
2356 PyTuple_SetItem(metadata, i, tmp);
2364 PyTuple_SetItem(metadata, i, tmp);
2357 }
2365 }
2358 ret = Py_BuildValue("(OOHO(di)O)", prec, succs, flags,
2366 ret = Py_BuildValue("(OOHO(di)O)", prec, succs, flags,
2359 metadata, mtime, (int)tz * 60, parents);
2367 metadata, mtime, (int)tz * 60, parents);
2360 bail:
2368 bail:
2361 Py_XDECREF(prec);
2369 Py_XDECREF(prec);
2362 Py_XDECREF(succs);
2370 Py_XDECREF(succs);
2363 Py_XDECREF(metadata);
2371 Py_XDECREF(metadata);
2364 if (parents != Py_None)
2372 if (parents != Py_None)
2365 Py_XDECREF(parents);
2373 Py_XDECREF(parents);
2366 return ret;
2374 return ret;
2367 }
2375 }
2368
2376
2369
2377
2370 static PyObject *fm1readmarkers(PyObject *self, PyObject *args) {
2378 static PyObject *fm1readmarkers(PyObject *self, PyObject *args) {
2371 const char *data;
2379 const char *data;
2372 Py_ssize_t datalen;
2380 Py_ssize_t datalen;
2373 /* only unsigned long because python 2.4, should be Py_ssize_t */
2381 /* only unsigned long because python 2.4, should be Py_ssize_t */
2374 unsigned long offset, stop;
2382 unsigned long offset, stop;
2375 PyObject *markers = NULL;
2383 PyObject *markers = NULL;
2376
2384
2377 /* replace kk with nn when we drop Python 2.4 */
2385 /* replace kk with nn when we drop Python 2.4 */
2378 if (!PyArg_ParseTuple(args, "s#kk", &data, &datalen, &offset, &stop)) {
2386 if (!PyArg_ParseTuple(args, "s#kk", &data, &datalen, &offset, &stop)) {
2379 return NULL;
2387 return NULL;
2380 }
2388 }
2381 data += offset;
2389 data += offset;
2382 markers = PyList_New(0);
2390 markers = PyList_New(0);
2383 if (!markers) {
2391 if (!markers) {
2384 return NULL;
2392 return NULL;
2385 }
2393 }
2386 while (offset < stop) {
2394 while (offset < stop) {
2387 uint32_t msize;
2395 uint32_t msize;
2388 int error;
2396 int error;
2389 PyObject *record = fm1readmarker(data, &msize);
2397 PyObject *record = fm1readmarker(data, &msize);
2390 if (!record) {
2398 if (!record) {
2391 goto bail;
2399 goto bail;
2392 }
2400 }
2393 error = PyList_Append(markers, record);
2401 error = PyList_Append(markers, record);
2394 Py_DECREF(record);
2402 Py_DECREF(record);
2395 if (error) {
2403 if (error) {
2396 goto bail;
2404 goto bail;
2397 }
2405 }
2398 data += msize;
2406 data += msize;
2399 offset += msize;
2407 offset += msize;
2400 }
2408 }
2401 return markers;
2409 return markers;
2402 bail:
2410 bail:
2403 Py_DECREF(markers);
2411 Py_DECREF(markers);
2404 return NULL;
2412 return NULL;
2405 }
2413 }
2406
2414
2407 static char parsers_doc[] = "Efficient content parsing.";
2415 static char parsers_doc[] = "Efficient content parsing.";
2408
2416
2409 PyObject *encodedir(PyObject *self, PyObject *args);
2417 PyObject *encodedir(PyObject *self, PyObject *args);
2410 PyObject *pathencode(PyObject *self, PyObject *args);
2418 PyObject *pathencode(PyObject *self, PyObject *args);
2411 PyObject *lowerencode(PyObject *self, PyObject *args);
2419 PyObject *lowerencode(PyObject *self, PyObject *args);
2412
2420
2413 static PyMethodDef methods[] = {
2421 static PyMethodDef methods[] = {
2414 {"pack_dirstate", pack_dirstate, METH_VARARGS, "pack a dirstate\n"},
2422 {"pack_dirstate", pack_dirstate, METH_VARARGS, "pack a dirstate\n"},
2415 {"parse_manifest", parse_manifest, METH_VARARGS, "parse a manifest\n"},
2423 {"parse_manifest", parse_manifest, METH_VARARGS, "parse a manifest\n"},
2416 {"parse_dirstate", parse_dirstate, METH_VARARGS, "parse a dirstate\n"},
2424 {"parse_dirstate", parse_dirstate, METH_VARARGS, "parse a dirstate\n"},
2417 {"parse_index2", parse_index2, METH_VARARGS, "parse a revlog index\n"},
2425 {"parse_index2", parse_index2, METH_VARARGS, "parse a revlog index\n"},
2418 {"asciilower", asciilower, METH_VARARGS, "lowercase an ASCII string\n"},
2426 {"asciilower", asciilower, METH_VARARGS, "lowercase an ASCII string\n"},
2419 {"encodedir", encodedir, METH_VARARGS, "encodedir a path\n"},
2427 {"encodedir", encodedir, METH_VARARGS, "encodedir a path\n"},
2420 {"pathencode", pathencode, METH_VARARGS, "fncache-encode a path\n"},
2428 {"pathencode", pathencode, METH_VARARGS, "fncache-encode a path\n"},
2421 {"lowerencode", lowerencode, METH_VARARGS, "lower-encode a path\n"},
2429 {"lowerencode", lowerencode, METH_VARARGS, "lower-encode a path\n"},
2422 {"fm1readmarkers", fm1readmarkers, METH_VARARGS,
2430 {"fm1readmarkers", fm1readmarkers, METH_VARARGS,
2423 "parse v1 obsolete markers\n"},
2431 "parse v1 obsolete markers\n"},
2424 {NULL, NULL}
2432 {NULL, NULL}
2425 };
2433 };
2426
2434
2427 void dirs_module_init(PyObject *mod);
2435 void dirs_module_init(PyObject *mod);
2428 void manifest_module_init(PyObject *mod);
2436 void manifest_module_init(PyObject *mod);
2429
2437
2430 static void module_init(PyObject *mod)
2438 static void module_init(PyObject *mod)
2431 {
2439 {
2432 /* This module constant has two purposes. First, it lets us unit test
2440 /* This module constant has two purposes. First, it lets us unit test
2433 * the ImportError raised without hard-coding any error text. This
2441 * the ImportError raised without hard-coding any error text. This
2434 * means we can change the text in the future without breaking tests,
2442 * means we can change the text in the future without breaking tests,
2435 * even across changesets without a recompile. Second, its presence
2443 * even across changesets without a recompile. Second, its presence
2436 * can be used to determine whether the version-checking logic is
2444 * can be used to determine whether the version-checking logic is
2437 * present, which also helps in testing across changesets without a
2445 * present, which also helps in testing across changesets without a
2438 * recompile. Note that this means the pure-Python version of parsers
2446 * recompile. Note that this means the pure-Python version of parsers
2439 * should not have this module constant. */
2447 * should not have this module constant. */
2440 PyModule_AddStringConstant(mod, "versionerrortext", versionerrortext);
2448 PyModule_AddStringConstant(mod, "versionerrortext", versionerrortext);
2441
2449
2442 dirs_module_init(mod);
2450 dirs_module_init(mod);
2443 manifest_module_init(mod);
2451 manifest_module_init(mod);
2444
2452
2445 indexType.tp_new = PyType_GenericNew;
2453 indexType.tp_new = PyType_GenericNew;
2446 if (PyType_Ready(&indexType) < 0 ||
2454 if (PyType_Ready(&indexType) < 0 ||
2447 PyType_Ready(&dirstateTupleType) < 0)
2455 PyType_Ready(&dirstateTupleType) < 0)
2448 return;
2456 return;
2449 Py_INCREF(&indexType);
2457 Py_INCREF(&indexType);
2450 PyModule_AddObject(mod, "index", (PyObject *)&indexType);
2458 PyModule_AddObject(mod, "index", (PyObject *)&indexType);
2451 Py_INCREF(&dirstateTupleType);
2459 Py_INCREF(&dirstateTupleType);
2452 PyModule_AddObject(mod, "dirstatetuple",
2460 PyModule_AddObject(mod, "dirstatetuple",
2453 (PyObject *)&dirstateTupleType);
2461 (PyObject *)&dirstateTupleType);
2454
2462
2455 nullentry = Py_BuildValue("iiiiiiis#", 0, 0, 0,
2463 nullentry = Py_BuildValue("iiiiiiis#", 0, 0, 0,
2456 -1, -1, -1, -1, nullid, 20);
2464 -1, -1, -1, -1, nullid, 20);
2457 if (nullentry)
2465 if (nullentry)
2458 PyObject_GC_UnTrack(nullentry);
2466 PyObject_GC_UnTrack(nullentry);
2459 }
2467 }
2460
2468
2461 static int check_python_version(void)
2469 static int check_python_version(void)
2462 {
2470 {
2463 PyObject *sys = PyImport_ImportModule("sys"), *ver;
2471 PyObject *sys = PyImport_ImportModule("sys"), *ver;
2464 long hexversion;
2472 long hexversion;
2465 if (!sys)
2473 if (!sys)
2466 return -1;
2474 return -1;
2467 ver = PyObject_GetAttrString(sys, "hexversion");
2475 ver = PyObject_GetAttrString(sys, "hexversion");
2468 Py_DECREF(sys);
2476 Py_DECREF(sys);
2469 if (!ver)
2477 if (!ver)
2470 return -1;
2478 return -1;
2471 hexversion = PyInt_AsLong(ver);
2479 hexversion = PyInt_AsLong(ver);
2472 Py_DECREF(ver);
2480 Py_DECREF(ver);
2473 /* sys.hexversion is a 32-bit number by default, so the -1 case
2481 /* sys.hexversion is a 32-bit number by default, so the -1 case
2474 * should only occur in unusual circumstances (e.g. if sys.hexversion
2482 * should only occur in unusual circumstances (e.g. if sys.hexversion
2475 * is manually set to an invalid value). */
2483 * is manually set to an invalid value). */
2476 if ((hexversion == -1) || (hexversion >> 16 != PY_VERSION_HEX >> 16)) {
2484 if ((hexversion == -1) || (hexversion >> 16 != PY_VERSION_HEX >> 16)) {
2477 PyErr_Format(PyExc_ImportError, "%s: The Mercurial extension "
2485 PyErr_Format(PyExc_ImportError, "%s: The Mercurial extension "
2478 "modules were compiled with Python " PY_VERSION ", but "
2486 "modules were compiled with Python " PY_VERSION ", but "
2479 "Mercurial is currently using Python with sys.hexversion=%ld: "
2487 "Mercurial is currently using Python with sys.hexversion=%ld: "
2480 "Python %s\n at: %s", versionerrortext, hexversion,
2488 "Python %s\n at: %s", versionerrortext, hexversion,
2481 Py_GetVersion(), Py_GetProgramFullPath());
2489 Py_GetVersion(), Py_GetProgramFullPath());
2482 return -1;
2490 return -1;
2483 }
2491 }
2484 return 0;
2492 return 0;
2485 }
2493 }
2486
2494
2487 #ifdef IS_PY3K
2495 #ifdef IS_PY3K
2488 static struct PyModuleDef parsers_module = {
2496 static struct PyModuleDef parsers_module = {
2489 PyModuleDef_HEAD_INIT,
2497 PyModuleDef_HEAD_INIT,
2490 "parsers",
2498 "parsers",
2491 parsers_doc,
2499 parsers_doc,
2492 -1,
2500 -1,
2493 methods
2501 methods
2494 };
2502 };
2495
2503
2496 PyMODINIT_FUNC PyInit_parsers(void)
2504 PyMODINIT_FUNC PyInit_parsers(void)
2497 {
2505 {
2498 PyObject *mod;
2506 PyObject *mod;
2499
2507
2500 if (check_python_version() == -1)
2508 if (check_python_version() == -1)
2501 return;
2509 return;
2502 mod = PyModule_Create(&parsers_module);
2510 mod = PyModule_Create(&parsers_module);
2503 module_init(mod);
2511 module_init(mod);
2504 return mod;
2512 return mod;
2505 }
2513 }
2506 #else
2514 #else
2507 PyMODINIT_FUNC initparsers(void)
2515 PyMODINIT_FUNC initparsers(void)
2508 {
2516 {
2509 PyObject *mod;
2517 PyObject *mod;
2510
2518
2511 if (check_python_version() == -1)
2519 if (check_python_version() == -1)
2512 return;
2520 return;
2513 mod = Py_InitModule3("parsers", methods, parsers_doc);
2521 mod = Py_InitModule3("parsers", methods, parsers_doc);
2514 module_init(mod);
2522 module_init(mod);
2515 }
2523 }
2516 #endif
2524 #endif
General Comments 0
You need to be logged in to leave comments. Login now