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