##// END OF EJS Templates
pushvars: add a coreconfigitem for push.pushvars.server...
Pulkit Goyal -
r33834:057d31ce default
parent child Browse files
Show More
@@ -1,1894 +1,1894 b''
1 1 # bundle2.py - generic container format to transmit arbitrary data.
2 2 #
3 3 # Copyright 2013 Facebook, Inc.
4 4 #
5 5 # This software may be used and distributed according to the terms of the
6 6 # GNU General Public License version 2 or any later version.
7 7 """Handling of the new bundle2 format
8 8
9 9 The goal of bundle2 is to act as an atomically packet to transmit a set of
10 10 payloads in an application agnostic way. It consist in a sequence of "parts"
11 11 that will be handed to and processed by the application layer.
12 12
13 13
14 14 General format architecture
15 15 ===========================
16 16
17 17 The format is architectured as follow
18 18
19 19 - magic string
20 20 - stream level parameters
21 21 - payload parts (any number)
22 22 - end of stream marker.
23 23
24 24 the Binary format
25 25 ============================
26 26
27 27 All numbers are unsigned and big-endian.
28 28
29 29 stream level parameters
30 30 ------------------------
31 31
32 32 Binary format is as follow
33 33
34 34 :params size: int32
35 35
36 36 The total number of Bytes used by the parameters
37 37
38 38 :params value: arbitrary number of Bytes
39 39
40 40 A blob of `params size` containing the serialized version of all stream level
41 41 parameters.
42 42
43 43 The blob contains a space separated list of parameters. Parameters with value
44 44 are stored in the form `<name>=<value>`. Both name and value are urlquoted.
45 45
46 46 Empty name are obviously forbidden.
47 47
48 48 Name MUST start with a letter. If this first letter is lower case, the
49 49 parameter is advisory and can be safely ignored. However when the first
50 50 letter is capital, the parameter is mandatory and the bundling process MUST
51 51 stop if he is not able to proceed it.
52 52
53 53 Stream parameters use a simple textual format for two main reasons:
54 54
55 55 - Stream level parameters should remain simple and we want to discourage any
56 56 crazy usage.
57 57 - Textual data allow easy human inspection of a bundle2 header in case of
58 58 troubles.
59 59
60 60 Any Applicative level options MUST go into a bundle2 part instead.
61 61
62 62 Payload part
63 63 ------------------------
64 64
65 65 Binary format is as follow
66 66
67 67 :header size: int32
68 68
69 69 The total number of Bytes used by the part header. When the header is empty
70 70 (size = 0) this is interpreted as the end of stream marker.
71 71
72 72 :header:
73 73
74 74 The header defines how to interpret the part. It contains two piece of
75 75 data: the part type, and the part parameters.
76 76
77 77 The part type is used to route an application level handler, that can
78 78 interpret payload.
79 79
80 80 Part parameters are passed to the application level handler. They are
81 81 meant to convey information that will help the application level object to
82 82 interpret the part payload.
83 83
84 84 The binary format of the header is has follow
85 85
86 86 :typesize: (one byte)
87 87
88 88 :parttype: alphanumerical part name (restricted to [a-zA-Z0-9_:-]*)
89 89
90 90 :partid: A 32bits integer (unique in the bundle) that can be used to refer
91 91 to this part.
92 92
93 93 :parameters:
94 94
95 95 Part's parameter may have arbitrary content, the binary structure is::
96 96
97 97 <mandatory-count><advisory-count><param-sizes><param-data>
98 98
99 99 :mandatory-count: 1 byte, number of mandatory parameters
100 100
101 101 :advisory-count: 1 byte, number of advisory parameters
102 102
103 103 :param-sizes:
104 104
105 105 N couple of bytes, where N is the total number of parameters. Each
106 106 couple contains (<size-of-key>, <size-of-value) for one parameter.
107 107
108 108 :param-data:
109 109
110 110 A blob of bytes from which each parameter key and value can be
111 111 retrieved using the list of size couples stored in the previous
112 112 field.
113 113
114 114 Mandatory parameters comes first, then the advisory ones.
115 115
116 116 Each parameter's key MUST be unique within the part.
117 117
118 118 :payload:
119 119
120 120 payload is a series of `<chunksize><chunkdata>`.
121 121
122 122 `chunksize` is an int32, `chunkdata` are plain bytes (as much as
123 123 `chunksize` says)` The payload part is concluded by a zero size chunk.
124 124
125 125 The current implementation always produces either zero or one chunk.
126 126 This is an implementation limitation that will ultimately be lifted.
127 127
128 128 `chunksize` can be negative to trigger special case processing. No such
129 129 processing is in place yet.
130 130
131 131 Bundle processing
132 132 ============================
133 133
134 134 Each part is processed in order using a "part handler". Handler are registered
135 135 for a certain part type.
136 136
137 137 The matching of a part to its handler is case insensitive. The case of the
138 138 part type is used to know if a part is mandatory or advisory. If the Part type
139 139 contains any uppercase char it is considered mandatory. When no handler is
140 140 known for a Mandatory part, the process is aborted and an exception is raised.
141 141 If the part is advisory and no handler is known, the part is ignored. When the
142 142 process is aborted, the full bundle is still read from the stream to keep the
143 143 channel usable. But none of the part read from an abort are processed. In the
144 144 future, dropping the stream may become an option for channel we do not care to
145 145 preserve.
146 146 """
147 147
148 148 from __future__ import absolute_import, division
149 149
150 150 import errno
151 151 import re
152 152 import string
153 153 import struct
154 154 import sys
155 155
156 156 from .i18n import _
157 157 from . import (
158 158 changegroup,
159 159 error,
160 160 obsolete,
161 161 phases,
162 162 pushkey,
163 163 pycompat,
164 164 tags,
165 165 url,
166 166 util,
167 167 )
168 168
169 169 urlerr = util.urlerr
170 170 urlreq = util.urlreq
171 171
172 172 _pack = struct.pack
173 173 _unpack = struct.unpack
174 174
175 175 _fstreamparamsize = '>i'
176 176 _fpartheadersize = '>i'
177 177 _fparttypesize = '>B'
178 178 _fpartid = '>I'
179 179 _fpayloadsize = '>i'
180 180 _fpartparamcount = '>BB'
181 181
182 182 _fphasesentry = '>i20s'
183 183
184 184 preferedchunksize = 4096
185 185
186 186 _parttypeforbidden = re.compile('[^a-zA-Z0-9_:-]')
187 187
188 188 def outdebug(ui, message):
189 189 """debug regarding output stream (bundling)"""
190 190 if ui.configbool('devel', 'bundle2.debug'):
191 191 ui.debug('bundle2-output: %s\n' % message)
192 192
193 193 def indebug(ui, message):
194 194 """debug on input stream (unbundling)"""
195 195 if ui.configbool('devel', 'bundle2.debug'):
196 196 ui.debug('bundle2-input: %s\n' % message)
197 197
198 198 def validateparttype(parttype):
199 199 """raise ValueError if a parttype contains invalid character"""
200 200 if _parttypeforbidden.search(parttype):
201 201 raise ValueError(parttype)
202 202
203 203 def _makefpartparamsizes(nbparams):
204 204 """return a struct format to read part parameter sizes
205 205
206 206 The number parameters is variable so we need to build that format
207 207 dynamically.
208 208 """
209 209 return '>'+('BB'*nbparams)
210 210
211 211 parthandlermapping = {}
212 212
213 213 def parthandler(parttype, params=()):
214 214 """decorator that register a function as a bundle2 part handler
215 215
216 216 eg::
217 217
218 218 @parthandler('myparttype', ('mandatory', 'param', 'handled'))
219 219 def myparttypehandler(...):
220 220 '''process a part of type "my part".'''
221 221 ...
222 222 """
223 223 validateparttype(parttype)
224 224 def _decorator(func):
225 225 lparttype = parttype.lower() # enforce lower case matching.
226 226 assert lparttype not in parthandlermapping
227 227 parthandlermapping[lparttype] = func
228 228 func.params = frozenset(params)
229 229 return func
230 230 return _decorator
231 231
232 232 class unbundlerecords(object):
233 233 """keep record of what happens during and unbundle
234 234
235 235 New records are added using `records.add('cat', obj)`. Where 'cat' is a
236 236 category of record and obj is an arbitrary object.
237 237
238 238 `records['cat']` will return all entries of this category 'cat'.
239 239
240 240 Iterating on the object itself will yield `('category', obj)` tuples
241 241 for all entries.
242 242
243 243 All iterations happens in chronological order.
244 244 """
245 245
246 246 def __init__(self):
247 247 self._categories = {}
248 248 self._sequences = []
249 249 self._replies = {}
250 250
251 251 def add(self, category, entry, inreplyto=None):
252 252 """add a new record of a given category.
253 253
254 254 The entry can then be retrieved in the list returned by
255 255 self['category']."""
256 256 self._categories.setdefault(category, []).append(entry)
257 257 self._sequences.append((category, entry))
258 258 if inreplyto is not None:
259 259 self.getreplies(inreplyto).add(category, entry)
260 260
261 261 def getreplies(self, partid):
262 262 """get the records that are replies to a specific part"""
263 263 return self._replies.setdefault(partid, unbundlerecords())
264 264
265 265 def __getitem__(self, cat):
266 266 return tuple(self._categories.get(cat, ()))
267 267
268 268 def __iter__(self):
269 269 return iter(self._sequences)
270 270
271 271 def __len__(self):
272 272 return len(self._sequences)
273 273
274 274 def __nonzero__(self):
275 275 return bool(self._sequences)
276 276
277 277 __bool__ = __nonzero__
278 278
279 279 class bundleoperation(object):
280 280 """an object that represents a single bundling process
281 281
282 282 Its purpose is to carry unbundle-related objects and states.
283 283
284 284 A new object should be created at the beginning of each bundle processing.
285 285 The object is to be returned by the processing function.
286 286
287 287 The object has very little content now it will ultimately contain:
288 288 * an access to the repo the bundle is applied to,
289 289 * a ui object,
290 290 * a way to retrieve a transaction to add changes to the repo,
291 291 * a way to record the result of processing each part,
292 292 * a way to construct a bundle response when applicable.
293 293 """
294 294
295 295 def __init__(self, repo, transactiongetter, captureoutput=True):
296 296 self.repo = repo
297 297 self.ui = repo.ui
298 298 self.records = unbundlerecords()
299 299 self.reply = None
300 300 self.captureoutput = captureoutput
301 301 self.hookargs = {}
302 302 self._gettransaction = transactiongetter
303 303
304 304 def gettransaction(self):
305 305 transaction = self._gettransaction()
306 306
307 307 if self.hookargs:
308 308 # the ones added to the transaction supercede those added
309 309 # to the operation.
310 310 self.hookargs.update(transaction.hookargs)
311 311 transaction.hookargs = self.hookargs
312 312
313 313 # mark the hookargs as flushed. further attempts to add to
314 314 # hookargs will result in an abort.
315 315 self.hookargs = None
316 316
317 317 return transaction
318 318
319 319 def addhookargs(self, hookargs):
320 320 if self.hookargs is None:
321 321 raise error.ProgrammingError('attempted to add hookargs to '
322 322 'operation after transaction started')
323 323 self.hookargs.update(hookargs)
324 324
325 325 class TransactionUnavailable(RuntimeError):
326 326 pass
327 327
328 328 def _notransaction():
329 329 """default method to get a transaction while processing a bundle
330 330
331 331 Raise an exception to highlight the fact that no transaction was expected
332 332 to be created"""
333 333 raise TransactionUnavailable()
334 334
335 335 def applybundle(repo, unbundler, tr, source=None, url=None, **kwargs):
336 336 # transform me into unbundler.apply() as soon as the freeze is lifted
337 337 if isinstance(unbundler, unbundle20):
338 338 tr.hookargs['bundle2'] = '1'
339 339 if source is not None and 'source' not in tr.hookargs:
340 340 tr.hookargs['source'] = source
341 341 if url is not None and 'url' not in tr.hookargs:
342 342 tr.hookargs['url'] = url
343 343 return processbundle(repo, unbundler, lambda: tr)
344 344 else:
345 345 # the transactiongetter won't be used, but we might as well set it
346 346 op = bundleoperation(repo, lambda: tr)
347 347 _processchangegroup(op, unbundler, tr, source, url, **kwargs)
348 348 return op
349 349
350 350 def processbundle(repo, unbundler, transactiongetter=None, op=None):
351 351 """This function process a bundle, apply effect to/from a repo
352 352
353 353 It iterates over each part then searches for and uses the proper handling
354 354 code to process the part. Parts are processed in order.
355 355
356 356 Unknown Mandatory part will abort the process.
357 357
358 358 It is temporarily possible to provide a prebuilt bundleoperation to the
359 359 function. This is used to ensure output is properly propagated in case of
360 360 an error during the unbundling. This output capturing part will likely be
361 361 reworked and this ability will probably go away in the process.
362 362 """
363 363 if op is None:
364 364 if transactiongetter is None:
365 365 transactiongetter = _notransaction
366 366 op = bundleoperation(repo, transactiongetter)
367 367 # todo:
368 368 # - replace this is a init function soon.
369 369 # - exception catching
370 370 unbundler.params
371 371 if repo.ui.debugflag:
372 372 msg = ['bundle2-input-bundle:']
373 373 if unbundler.params:
374 374 msg.append(' %i params' % len(unbundler.params))
375 375 if op._gettransaction is None or op._gettransaction is _notransaction:
376 376 msg.append(' no-transaction')
377 377 else:
378 378 msg.append(' with-transaction')
379 379 msg.append('\n')
380 380 repo.ui.debug(''.join(msg))
381 381 iterparts = enumerate(unbundler.iterparts())
382 382 part = None
383 383 nbpart = 0
384 384 try:
385 385 for nbpart, part in iterparts:
386 386 _processpart(op, part)
387 387 except Exception as exc:
388 388 # Any exceptions seeking to the end of the bundle at this point are
389 389 # almost certainly related to the underlying stream being bad.
390 390 # And, chances are that the exception we're handling is related to
391 391 # getting in that bad state. So, we swallow the seeking error and
392 392 # re-raise the original error.
393 393 seekerror = False
394 394 try:
395 395 for nbpart, part in iterparts:
396 396 # consume the bundle content
397 397 part.seek(0, 2)
398 398 except Exception:
399 399 seekerror = True
400 400
401 401 # Small hack to let caller code distinguish exceptions from bundle2
402 402 # processing from processing the old format. This is mostly
403 403 # needed to handle different return codes to unbundle according to the
404 404 # type of bundle. We should probably clean up or drop this return code
405 405 # craziness in a future version.
406 406 exc.duringunbundle2 = True
407 407 salvaged = []
408 408 replycaps = None
409 409 if op.reply is not None:
410 410 salvaged = op.reply.salvageoutput()
411 411 replycaps = op.reply.capabilities
412 412 exc._replycaps = replycaps
413 413 exc._bundle2salvagedoutput = salvaged
414 414
415 415 # Re-raising from a variable loses the original stack. So only use
416 416 # that form if we need to.
417 417 if seekerror:
418 418 raise exc
419 419 else:
420 420 raise
421 421 finally:
422 422 repo.ui.debug('bundle2-input-bundle: %i parts total\n' % nbpart)
423 423
424 424 return op
425 425
426 426 def _processchangegroup(op, cg, tr, source, url, **kwargs):
427 427 ret = cg.apply(op.repo, tr, source, url, **kwargs)
428 428 op.records.add('changegroup', {
429 429 'return': ret,
430 430 })
431 431 return ret
432 432
433 433 def _processpart(op, part):
434 434 """process a single part from a bundle
435 435
436 436 The part is guaranteed to have been fully consumed when the function exits
437 437 (even if an exception is raised)."""
438 438 status = 'unknown' # used by debug output
439 439 hardabort = False
440 440 try:
441 441 try:
442 442 handler = parthandlermapping.get(part.type)
443 443 if handler is None:
444 444 status = 'unsupported-type'
445 445 raise error.BundleUnknownFeatureError(parttype=part.type)
446 446 indebug(op.ui, 'found a handler for part %r' % part.type)
447 447 unknownparams = part.mandatorykeys - handler.params
448 448 if unknownparams:
449 449 unknownparams = list(unknownparams)
450 450 unknownparams.sort()
451 451 status = 'unsupported-params (%s)' % unknownparams
452 452 raise error.BundleUnknownFeatureError(parttype=part.type,
453 453 params=unknownparams)
454 454 status = 'supported'
455 455 except error.BundleUnknownFeatureError as exc:
456 456 if part.mandatory: # mandatory parts
457 457 raise
458 458 indebug(op.ui, 'ignoring unsupported advisory part %s' % exc)
459 459 return # skip to part processing
460 460 finally:
461 461 if op.ui.debugflag:
462 462 msg = ['bundle2-input-part: "%s"' % part.type]
463 463 if not part.mandatory:
464 464 msg.append(' (advisory)')
465 465 nbmp = len(part.mandatorykeys)
466 466 nbap = len(part.params) - nbmp
467 467 if nbmp or nbap:
468 468 msg.append(' (params:')
469 469 if nbmp:
470 470 msg.append(' %i mandatory' % nbmp)
471 471 if nbap:
472 472 msg.append(' %i advisory' % nbmp)
473 473 msg.append(')')
474 474 msg.append(' %s\n' % status)
475 475 op.ui.debug(''.join(msg))
476 476
477 477 # handler is called outside the above try block so that we don't
478 478 # risk catching KeyErrors from anything other than the
479 479 # parthandlermapping lookup (any KeyError raised by handler()
480 480 # itself represents a defect of a different variety).
481 481 output = None
482 482 if op.captureoutput and op.reply is not None:
483 483 op.ui.pushbuffer(error=True, subproc=True)
484 484 output = ''
485 485 try:
486 486 handler(op, part)
487 487 finally:
488 488 if output is not None:
489 489 output = op.ui.popbuffer()
490 490 if output:
491 491 outpart = op.reply.newpart('output', data=output,
492 492 mandatory=False)
493 493 outpart.addparam(
494 494 'in-reply-to', pycompat.bytestr(part.id), mandatory=False)
495 495 # If exiting or interrupted, do not attempt to seek the stream in the
496 496 # finally block below. This makes abort faster.
497 497 except (SystemExit, KeyboardInterrupt):
498 498 hardabort = True
499 499 raise
500 500 finally:
501 501 # consume the part content to not corrupt the stream.
502 502 if not hardabort:
503 503 part.seek(0, 2)
504 504
505 505
506 506 def decodecaps(blob):
507 507 """decode a bundle2 caps bytes blob into a dictionary
508 508
509 509 The blob is a list of capabilities (one per line)
510 510 Capabilities may have values using a line of the form::
511 511
512 512 capability=value1,value2,value3
513 513
514 514 The values are always a list."""
515 515 caps = {}
516 516 for line in blob.splitlines():
517 517 if not line:
518 518 continue
519 519 if '=' not in line:
520 520 key, vals = line, ()
521 521 else:
522 522 key, vals = line.split('=', 1)
523 523 vals = vals.split(',')
524 524 key = urlreq.unquote(key)
525 525 vals = [urlreq.unquote(v) for v in vals]
526 526 caps[key] = vals
527 527 return caps
528 528
529 529 def encodecaps(caps):
530 530 """encode a bundle2 caps dictionary into a bytes blob"""
531 531 chunks = []
532 532 for ca in sorted(caps):
533 533 vals = caps[ca]
534 534 ca = urlreq.quote(ca)
535 535 vals = [urlreq.quote(v) for v in vals]
536 536 if vals:
537 537 ca = "%s=%s" % (ca, ','.join(vals))
538 538 chunks.append(ca)
539 539 return '\n'.join(chunks)
540 540
541 541 bundletypes = {
542 542 "": ("", 'UN'), # only when using unbundle on ssh and old http servers
543 543 # since the unification ssh accepts a header but there
544 544 # is no capability signaling it.
545 545 "HG20": (), # special-cased below
546 546 "HG10UN": ("HG10UN", 'UN'),
547 547 "HG10BZ": ("HG10", 'BZ'),
548 548 "HG10GZ": ("HG10GZ", 'GZ'),
549 549 }
550 550
551 551 # hgweb uses this list to communicate its preferred type
552 552 bundlepriority = ['HG10GZ', 'HG10BZ', 'HG10UN']
553 553
554 554 class bundle20(object):
555 555 """represent an outgoing bundle2 container
556 556
557 557 Use the `addparam` method to add stream level parameter. and `newpart` to
558 558 populate it. Then call `getchunks` to retrieve all the binary chunks of
559 559 data that compose the bundle2 container."""
560 560
561 561 _magicstring = 'HG20'
562 562
563 563 def __init__(self, ui, capabilities=()):
564 564 self.ui = ui
565 565 self._params = []
566 566 self._parts = []
567 567 self.capabilities = dict(capabilities)
568 568 self._compengine = util.compengines.forbundletype('UN')
569 569 self._compopts = None
570 570
571 571 def setcompression(self, alg, compopts=None):
572 572 """setup core part compression to <alg>"""
573 573 if alg in (None, 'UN'):
574 574 return
575 575 assert not any(n.lower() == 'compression' for n, v in self._params)
576 576 self.addparam('Compression', alg)
577 577 self._compengine = util.compengines.forbundletype(alg)
578 578 self._compopts = compopts
579 579
580 580 @property
581 581 def nbparts(self):
582 582 """total number of parts added to the bundler"""
583 583 return len(self._parts)
584 584
585 585 # methods used to defines the bundle2 content
586 586 def addparam(self, name, value=None):
587 587 """add a stream level parameter"""
588 588 if not name:
589 589 raise ValueError('empty parameter name')
590 590 if name[0] not in string.letters:
591 591 raise ValueError('non letter first character: %r' % name)
592 592 self._params.append((name, value))
593 593
594 594 def addpart(self, part):
595 595 """add a new part to the bundle2 container
596 596
597 597 Parts contains the actual applicative payload."""
598 598 assert part.id is None
599 599 part.id = len(self._parts) # very cheap counter
600 600 self._parts.append(part)
601 601
602 602 def newpart(self, typeid, *args, **kwargs):
603 603 """create a new part and add it to the containers
604 604
605 605 As the part is directly added to the containers. For now, this means
606 606 that any failure to properly initialize the part after calling
607 607 ``newpart`` should result in a failure of the whole bundling process.
608 608
609 609 You can still fall back to manually create and add if you need better
610 610 control."""
611 611 part = bundlepart(typeid, *args, **kwargs)
612 612 self.addpart(part)
613 613 return part
614 614
615 615 # methods used to generate the bundle2 stream
616 616 def getchunks(self):
617 617 if self.ui.debugflag:
618 618 msg = ['bundle2-output-bundle: "%s",' % self._magicstring]
619 619 if self._params:
620 620 msg.append(' (%i params)' % len(self._params))
621 621 msg.append(' %i parts total\n' % len(self._parts))
622 622 self.ui.debug(''.join(msg))
623 623 outdebug(self.ui, 'start emission of %s stream' % self._magicstring)
624 624 yield self._magicstring
625 625 param = self._paramchunk()
626 626 outdebug(self.ui, 'bundle parameter: %s' % param)
627 627 yield _pack(_fstreamparamsize, len(param))
628 628 if param:
629 629 yield param
630 630 for chunk in self._compengine.compressstream(self._getcorechunk(),
631 631 self._compopts):
632 632 yield chunk
633 633
634 634 def _paramchunk(self):
635 635 """return a encoded version of all stream parameters"""
636 636 blocks = []
637 637 for par, value in self._params:
638 638 par = urlreq.quote(par)
639 639 if value is not None:
640 640 value = urlreq.quote(value)
641 641 par = '%s=%s' % (par, value)
642 642 blocks.append(par)
643 643 return ' '.join(blocks)
644 644
645 645 def _getcorechunk(self):
646 646 """yield chunk for the core part of the bundle
647 647
648 648 (all but headers and parameters)"""
649 649 outdebug(self.ui, 'start of parts')
650 650 for part in self._parts:
651 651 outdebug(self.ui, 'bundle part: "%s"' % part.type)
652 652 for chunk in part.getchunks(ui=self.ui):
653 653 yield chunk
654 654 outdebug(self.ui, 'end of bundle')
655 655 yield _pack(_fpartheadersize, 0)
656 656
657 657
658 658 def salvageoutput(self):
659 659 """return a list with a copy of all output parts in the bundle
660 660
661 661 This is meant to be used during error handling to make sure we preserve
662 662 server output"""
663 663 salvaged = []
664 664 for part in self._parts:
665 665 if part.type.startswith('output'):
666 666 salvaged.append(part.copy())
667 667 return salvaged
668 668
669 669
670 670 class unpackermixin(object):
671 671 """A mixin to extract bytes and struct data from a stream"""
672 672
673 673 def __init__(self, fp):
674 674 self._fp = fp
675 675
676 676 def _unpack(self, format):
677 677 """unpack this struct format from the stream
678 678
679 679 This method is meant for internal usage by the bundle2 protocol only.
680 680 They directly manipulate the low level stream including bundle2 level
681 681 instruction.
682 682
683 683 Do not use it to implement higher-level logic or methods."""
684 684 data = self._readexact(struct.calcsize(format))
685 685 return _unpack(format, data)
686 686
687 687 def _readexact(self, size):
688 688 """read exactly <size> bytes from the stream
689 689
690 690 This method is meant for internal usage by the bundle2 protocol only.
691 691 They directly manipulate the low level stream including bundle2 level
692 692 instruction.
693 693
694 694 Do not use it to implement higher-level logic or methods."""
695 695 return changegroup.readexactly(self._fp, size)
696 696
697 697 def getunbundler(ui, fp, magicstring=None):
698 698 """return a valid unbundler object for a given magicstring"""
699 699 if magicstring is None:
700 700 magicstring = changegroup.readexactly(fp, 4)
701 701 magic, version = magicstring[0:2], magicstring[2:4]
702 702 if magic != 'HG':
703 703 ui.debug(
704 704 "error: invalid magic: %r (version %r), should be 'HG'\n"
705 705 % (magic, version))
706 706 raise error.Abort(_('not a Mercurial bundle'))
707 707 unbundlerclass = formatmap.get(version)
708 708 if unbundlerclass is None:
709 709 raise error.Abort(_('unknown bundle version %s') % version)
710 710 unbundler = unbundlerclass(ui, fp)
711 711 indebug(ui, 'start processing of %s stream' % magicstring)
712 712 return unbundler
713 713
714 714 class unbundle20(unpackermixin):
715 715 """interpret a bundle2 stream
716 716
717 717 This class is fed with a binary stream and yields parts through its
718 718 `iterparts` methods."""
719 719
720 720 _magicstring = 'HG20'
721 721
722 722 def __init__(self, ui, fp):
723 723 """If header is specified, we do not read it out of the stream."""
724 724 self.ui = ui
725 725 self._compengine = util.compengines.forbundletype('UN')
726 726 self._compressed = None
727 727 super(unbundle20, self).__init__(fp)
728 728
729 729 @util.propertycache
730 730 def params(self):
731 731 """dictionary of stream level parameters"""
732 732 indebug(self.ui, 'reading bundle2 stream parameters')
733 733 params = {}
734 734 paramssize = self._unpack(_fstreamparamsize)[0]
735 735 if paramssize < 0:
736 736 raise error.BundleValueError('negative bundle param size: %i'
737 737 % paramssize)
738 738 if paramssize:
739 739 params = self._readexact(paramssize)
740 740 params = self._processallparams(params)
741 741 return params
742 742
743 743 def _processallparams(self, paramsblock):
744 744 """"""
745 745 params = util.sortdict()
746 746 for p in paramsblock.split(' '):
747 747 p = p.split('=', 1)
748 748 p = [urlreq.unquote(i) for i in p]
749 749 if len(p) < 2:
750 750 p.append(None)
751 751 self._processparam(*p)
752 752 params[p[0]] = p[1]
753 753 return params
754 754
755 755
756 756 def _processparam(self, name, value):
757 757 """process a parameter, applying its effect if needed
758 758
759 759 Parameter starting with a lower case letter are advisory and will be
760 760 ignored when unknown. Those starting with an upper case letter are
761 761 mandatory and will this function will raise a KeyError when unknown.
762 762
763 763 Note: no option are currently supported. Any input will be either
764 764 ignored or failing.
765 765 """
766 766 if not name:
767 767 raise ValueError('empty parameter name')
768 768 if name[0] not in string.letters:
769 769 raise ValueError('non letter first character: %r' % name)
770 770 try:
771 771 handler = b2streamparamsmap[name.lower()]
772 772 except KeyError:
773 773 if name[0].islower():
774 774 indebug(self.ui, "ignoring unknown parameter %r" % name)
775 775 else:
776 776 raise error.BundleUnknownFeatureError(params=(name,))
777 777 else:
778 778 handler(self, name, value)
779 779
780 780 def _forwardchunks(self):
781 781 """utility to transfer a bundle2 as binary
782 782
783 783 This is made necessary by the fact the 'getbundle' command over 'ssh'
784 784 have no way to know then the reply end, relying on the bundle to be
785 785 interpreted to know its end. This is terrible and we are sorry, but we
786 786 needed to move forward to get general delta enabled.
787 787 """
788 788 yield self._magicstring
789 789 assert 'params' not in vars(self)
790 790 paramssize = self._unpack(_fstreamparamsize)[0]
791 791 if paramssize < 0:
792 792 raise error.BundleValueError('negative bundle param size: %i'
793 793 % paramssize)
794 794 yield _pack(_fstreamparamsize, paramssize)
795 795 if paramssize:
796 796 params = self._readexact(paramssize)
797 797 self._processallparams(params)
798 798 yield params
799 799 assert self._compengine.bundletype == 'UN'
800 800 # From there, payload might need to be decompressed
801 801 self._fp = self._compengine.decompressorreader(self._fp)
802 802 emptycount = 0
803 803 while emptycount < 2:
804 804 # so we can brainlessly loop
805 805 assert _fpartheadersize == _fpayloadsize
806 806 size = self._unpack(_fpartheadersize)[0]
807 807 yield _pack(_fpartheadersize, size)
808 808 if size:
809 809 emptycount = 0
810 810 else:
811 811 emptycount += 1
812 812 continue
813 813 if size == flaginterrupt:
814 814 continue
815 815 elif size < 0:
816 816 raise error.BundleValueError('negative chunk size: %i')
817 817 yield self._readexact(size)
818 818
819 819
820 820 def iterparts(self):
821 821 """yield all parts contained in the stream"""
822 822 # make sure param have been loaded
823 823 self.params
824 824 # From there, payload need to be decompressed
825 825 self._fp = self._compengine.decompressorreader(self._fp)
826 826 indebug(self.ui, 'start extraction of bundle2 parts')
827 827 headerblock = self._readpartheader()
828 828 while headerblock is not None:
829 829 part = unbundlepart(self.ui, headerblock, self._fp)
830 830 yield part
831 831 part.seek(0, 2)
832 832 headerblock = self._readpartheader()
833 833 indebug(self.ui, 'end of bundle2 stream')
834 834
835 835 def _readpartheader(self):
836 836 """reads a part header size and return the bytes blob
837 837
838 838 returns None if empty"""
839 839 headersize = self._unpack(_fpartheadersize)[0]
840 840 if headersize < 0:
841 841 raise error.BundleValueError('negative part header size: %i'
842 842 % headersize)
843 843 indebug(self.ui, 'part header size: %i' % headersize)
844 844 if headersize:
845 845 return self._readexact(headersize)
846 846 return None
847 847
848 848 def compressed(self):
849 849 self.params # load params
850 850 return self._compressed
851 851
852 852 def close(self):
853 853 """close underlying file"""
854 854 if util.safehasattr(self._fp, 'close'):
855 855 return self._fp.close()
856 856
857 857 formatmap = {'20': unbundle20}
858 858
859 859 b2streamparamsmap = {}
860 860
861 861 def b2streamparamhandler(name):
862 862 """register a handler for a stream level parameter"""
863 863 def decorator(func):
864 864 assert name not in formatmap
865 865 b2streamparamsmap[name] = func
866 866 return func
867 867 return decorator
868 868
869 869 @b2streamparamhandler('compression')
870 870 def processcompression(unbundler, param, value):
871 871 """read compression parameter and install payload decompression"""
872 872 if value not in util.compengines.supportedbundletypes:
873 873 raise error.BundleUnknownFeatureError(params=(param,),
874 874 values=(value,))
875 875 unbundler._compengine = util.compengines.forbundletype(value)
876 876 if value is not None:
877 877 unbundler._compressed = True
878 878
879 879 class bundlepart(object):
880 880 """A bundle2 part contains application level payload
881 881
882 882 The part `type` is used to route the part to the application level
883 883 handler.
884 884
885 885 The part payload is contained in ``part.data``. It could be raw bytes or a
886 886 generator of byte chunks.
887 887
888 888 You can add parameters to the part using the ``addparam`` method.
889 889 Parameters can be either mandatory (default) or advisory. Remote side
890 890 should be able to safely ignore the advisory ones.
891 891
892 892 Both data and parameters cannot be modified after the generation has begun.
893 893 """
894 894
895 895 def __init__(self, parttype, mandatoryparams=(), advisoryparams=(),
896 896 data='', mandatory=True):
897 897 validateparttype(parttype)
898 898 self.id = None
899 899 self.type = parttype
900 900 self._data = data
901 901 self._mandatoryparams = list(mandatoryparams)
902 902 self._advisoryparams = list(advisoryparams)
903 903 # checking for duplicated entries
904 904 self._seenparams = set()
905 905 for pname, __ in self._mandatoryparams + self._advisoryparams:
906 906 if pname in self._seenparams:
907 907 raise error.ProgrammingError('duplicated params: %s' % pname)
908 908 self._seenparams.add(pname)
909 909 # status of the part's generation:
910 910 # - None: not started,
911 911 # - False: currently generated,
912 912 # - True: generation done.
913 913 self._generated = None
914 914 self.mandatory = mandatory
915 915
916 916 def __repr__(self):
917 917 cls = "%s.%s" % (self.__class__.__module__, self.__class__.__name__)
918 918 return ('<%s object at %x; id: %s; type: %s; mandatory: %s>'
919 919 % (cls, id(self), self.id, self.type, self.mandatory))
920 920
921 921 def copy(self):
922 922 """return a copy of the part
923 923
924 924 The new part have the very same content but no partid assigned yet.
925 925 Parts with generated data cannot be copied."""
926 926 assert not util.safehasattr(self.data, 'next')
927 927 return self.__class__(self.type, self._mandatoryparams,
928 928 self._advisoryparams, self._data, self.mandatory)
929 929
930 930 # methods used to defines the part content
931 931 @property
932 932 def data(self):
933 933 return self._data
934 934
935 935 @data.setter
936 936 def data(self, data):
937 937 if self._generated is not None:
938 938 raise error.ReadOnlyPartError('part is being generated')
939 939 self._data = data
940 940
941 941 @property
942 942 def mandatoryparams(self):
943 943 # make it an immutable tuple to force people through ``addparam``
944 944 return tuple(self._mandatoryparams)
945 945
946 946 @property
947 947 def advisoryparams(self):
948 948 # make it an immutable tuple to force people through ``addparam``
949 949 return tuple(self._advisoryparams)
950 950
951 951 def addparam(self, name, value='', mandatory=True):
952 952 """add a parameter to the part
953 953
954 954 If 'mandatory' is set to True, the remote handler must claim support
955 955 for this parameter or the unbundling will be aborted.
956 956
957 957 The 'name' and 'value' cannot exceed 255 bytes each.
958 958 """
959 959 if self._generated is not None:
960 960 raise error.ReadOnlyPartError('part is being generated')
961 961 if name in self._seenparams:
962 962 raise ValueError('duplicated params: %s' % name)
963 963 self._seenparams.add(name)
964 964 params = self._advisoryparams
965 965 if mandatory:
966 966 params = self._mandatoryparams
967 967 params.append((name, value))
968 968
969 969 # methods used to generates the bundle2 stream
970 970 def getchunks(self, ui):
971 971 if self._generated is not None:
972 972 raise error.ProgrammingError('part can only be consumed once')
973 973 self._generated = False
974 974
975 975 if ui.debugflag:
976 976 msg = ['bundle2-output-part: "%s"' % self.type]
977 977 if not self.mandatory:
978 978 msg.append(' (advisory)')
979 979 nbmp = len(self.mandatoryparams)
980 980 nbap = len(self.advisoryparams)
981 981 if nbmp or nbap:
982 982 msg.append(' (params:')
983 983 if nbmp:
984 984 msg.append(' %i mandatory' % nbmp)
985 985 if nbap:
986 986 msg.append(' %i advisory' % nbmp)
987 987 msg.append(')')
988 988 if not self.data:
989 989 msg.append(' empty payload')
990 990 elif util.safehasattr(self.data, 'next'):
991 991 msg.append(' streamed payload')
992 992 else:
993 993 msg.append(' %i bytes payload' % len(self.data))
994 994 msg.append('\n')
995 995 ui.debug(''.join(msg))
996 996
997 997 #### header
998 998 if self.mandatory:
999 999 parttype = self.type.upper()
1000 1000 else:
1001 1001 parttype = self.type.lower()
1002 1002 outdebug(ui, 'part %s: "%s"' % (pycompat.bytestr(self.id), parttype))
1003 1003 ## parttype
1004 1004 header = [_pack(_fparttypesize, len(parttype)),
1005 1005 parttype, _pack(_fpartid, self.id),
1006 1006 ]
1007 1007 ## parameters
1008 1008 # count
1009 1009 manpar = self.mandatoryparams
1010 1010 advpar = self.advisoryparams
1011 1011 header.append(_pack(_fpartparamcount, len(manpar), len(advpar)))
1012 1012 # size
1013 1013 parsizes = []
1014 1014 for key, value in manpar:
1015 1015 parsizes.append(len(key))
1016 1016 parsizes.append(len(value))
1017 1017 for key, value in advpar:
1018 1018 parsizes.append(len(key))
1019 1019 parsizes.append(len(value))
1020 1020 paramsizes = _pack(_makefpartparamsizes(len(parsizes) // 2), *parsizes)
1021 1021 header.append(paramsizes)
1022 1022 # key, value
1023 1023 for key, value in manpar:
1024 1024 header.append(key)
1025 1025 header.append(value)
1026 1026 for key, value in advpar:
1027 1027 header.append(key)
1028 1028 header.append(value)
1029 1029 ## finalize header
1030 1030 headerchunk = ''.join(header)
1031 1031 outdebug(ui, 'header chunk size: %i' % len(headerchunk))
1032 1032 yield _pack(_fpartheadersize, len(headerchunk))
1033 1033 yield headerchunk
1034 1034 ## payload
1035 1035 try:
1036 1036 for chunk in self._payloadchunks():
1037 1037 outdebug(ui, 'payload chunk size: %i' % len(chunk))
1038 1038 yield _pack(_fpayloadsize, len(chunk))
1039 1039 yield chunk
1040 1040 except GeneratorExit:
1041 1041 # GeneratorExit means that nobody is listening for our
1042 1042 # results anyway, so just bail quickly rather than trying
1043 1043 # to produce an error part.
1044 1044 ui.debug('bundle2-generatorexit\n')
1045 1045 raise
1046 1046 except BaseException as exc:
1047 1047 bexc = util.forcebytestr(exc)
1048 1048 # backup exception data for later
1049 1049 ui.debug('bundle2-input-stream-interrupt: encoding exception %s'
1050 1050 % bexc)
1051 1051 tb = sys.exc_info()[2]
1052 1052 msg = 'unexpected error: %s' % bexc
1053 1053 interpart = bundlepart('error:abort', [('message', msg)],
1054 1054 mandatory=False)
1055 1055 interpart.id = 0
1056 1056 yield _pack(_fpayloadsize, -1)
1057 1057 for chunk in interpart.getchunks(ui=ui):
1058 1058 yield chunk
1059 1059 outdebug(ui, 'closing payload chunk')
1060 1060 # abort current part payload
1061 1061 yield _pack(_fpayloadsize, 0)
1062 1062 pycompat.raisewithtb(exc, tb)
1063 1063 # end of payload
1064 1064 outdebug(ui, 'closing payload chunk')
1065 1065 yield _pack(_fpayloadsize, 0)
1066 1066 self._generated = True
1067 1067
1068 1068 def _payloadchunks(self):
1069 1069 """yield chunks of a the part payload
1070 1070
1071 1071 Exists to handle the different methods to provide data to a part."""
1072 1072 # we only support fixed size data now.
1073 1073 # This will be improved in the future.
1074 1074 if (util.safehasattr(self.data, 'next')
1075 1075 or util.safehasattr(self.data, '__next__')):
1076 1076 buff = util.chunkbuffer(self.data)
1077 1077 chunk = buff.read(preferedchunksize)
1078 1078 while chunk:
1079 1079 yield chunk
1080 1080 chunk = buff.read(preferedchunksize)
1081 1081 elif len(self.data):
1082 1082 yield self.data
1083 1083
1084 1084
1085 1085 flaginterrupt = -1
1086 1086
1087 1087 class interrupthandler(unpackermixin):
1088 1088 """read one part and process it with restricted capability
1089 1089
1090 1090 This allows to transmit exception raised on the producer size during part
1091 1091 iteration while the consumer is reading a part.
1092 1092
1093 1093 Part processed in this manner only have access to a ui object,"""
1094 1094
1095 1095 def __init__(self, ui, fp):
1096 1096 super(interrupthandler, self).__init__(fp)
1097 1097 self.ui = ui
1098 1098
1099 1099 def _readpartheader(self):
1100 1100 """reads a part header size and return the bytes blob
1101 1101
1102 1102 returns None if empty"""
1103 1103 headersize = self._unpack(_fpartheadersize)[0]
1104 1104 if headersize < 0:
1105 1105 raise error.BundleValueError('negative part header size: %i'
1106 1106 % headersize)
1107 1107 indebug(self.ui, 'part header size: %i\n' % headersize)
1108 1108 if headersize:
1109 1109 return self._readexact(headersize)
1110 1110 return None
1111 1111
1112 1112 def __call__(self):
1113 1113
1114 1114 self.ui.debug('bundle2-input-stream-interrupt:'
1115 1115 ' opening out of band context\n')
1116 1116 indebug(self.ui, 'bundle2 stream interruption, looking for a part.')
1117 1117 headerblock = self._readpartheader()
1118 1118 if headerblock is None:
1119 1119 indebug(self.ui, 'no part found during interruption.')
1120 1120 return
1121 1121 part = unbundlepart(self.ui, headerblock, self._fp)
1122 1122 op = interruptoperation(self.ui)
1123 1123 _processpart(op, part)
1124 1124 self.ui.debug('bundle2-input-stream-interrupt:'
1125 1125 ' closing out of band context\n')
1126 1126
1127 1127 class interruptoperation(object):
1128 1128 """A limited operation to be use by part handler during interruption
1129 1129
1130 1130 It only have access to an ui object.
1131 1131 """
1132 1132
1133 1133 def __init__(self, ui):
1134 1134 self.ui = ui
1135 1135 self.reply = None
1136 1136 self.captureoutput = False
1137 1137
1138 1138 @property
1139 1139 def repo(self):
1140 1140 raise error.ProgrammingError('no repo access from stream interruption')
1141 1141
1142 1142 def gettransaction(self):
1143 1143 raise TransactionUnavailable('no repo access from stream interruption')
1144 1144
1145 1145 class unbundlepart(unpackermixin):
1146 1146 """a bundle part read from a bundle"""
1147 1147
1148 1148 def __init__(self, ui, header, fp):
1149 1149 super(unbundlepart, self).__init__(fp)
1150 1150 self._seekable = (util.safehasattr(fp, 'seek') and
1151 1151 util.safehasattr(fp, 'tell'))
1152 1152 self.ui = ui
1153 1153 # unbundle state attr
1154 1154 self._headerdata = header
1155 1155 self._headeroffset = 0
1156 1156 self._initialized = False
1157 1157 self.consumed = False
1158 1158 # part data
1159 1159 self.id = None
1160 1160 self.type = None
1161 1161 self.mandatoryparams = None
1162 1162 self.advisoryparams = None
1163 1163 self.params = None
1164 1164 self.mandatorykeys = ()
1165 1165 self._payloadstream = None
1166 1166 self._readheader()
1167 1167 self._mandatory = None
1168 1168 self._chunkindex = [] #(payload, file) position tuples for chunk starts
1169 1169 self._pos = 0
1170 1170
1171 1171 def _fromheader(self, size):
1172 1172 """return the next <size> byte from the header"""
1173 1173 offset = self._headeroffset
1174 1174 data = self._headerdata[offset:(offset + size)]
1175 1175 self._headeroffset = offset + size
1176 1176 return data
1177 1177
1178 1178 def _unpackheader(self, format):
1179 1179 """read given format from header
1180 1180
1181 1181 This automatically compute the size of the format to read."""
1182 1182 data = self._fromheader(struct.calcsize(format))
1183 1183 return _unpack(format, data)
1184 1184
1185 1185 def _initparams(self, mandatoryparams, advisoryparams):
1186 1186 """internal function to setup all logic related parameters"""
1187 1187 # make it read only to prevent people touching it by mistake.
1188 1188 self.mandatoryparams = tuple(mandatoryparams)
1189 1189 self.advisoryparams = tuple(advisoryparams)
1190 1190 # user friendly UI
1191 1191 self.params = util.sortdict(self.mandatoryparams)
1192 1192 self.params.update(self.advisoryparams)
1193 1193 self.mandatorykeys = frozenset(p[0] for p in mandatoryparams)
1194 1194
1195 1195 def _payloadchunks(self, chunknum=0):
1196 1196 '''seek to specified chunk and start yielding data'''
1197 1197 if len(self._chunkindex) == 0:
1198 1198 assert chunknum == 0, 'Must start with chunk 0'
1199 1199 self._chunkindex.append((0, self._tellfp()))
1200 1200 else:
1201 1201 assert chunknum < len(self._chunkindex), \
1202 1202 'Unknown chunk %d' % chunknum
1203 1203 self._seekfp(self._chunkindex[chunknum][1])
1204 1204
1205 1205 pos = self._chunkindex[chunknum][0]
1206 1206 payloadsize = self._unpack(_fpayloadsize)[0]
1207 1207 indebug(self.ui, 'payload chunk size: %i' % payloadsize)
1208 1208 while payloadsize:
1209 1209 if payloadsize == flaginterrupt:
1210 1210 # interruption detection, the handler will now read a
1211 1211 # single part and process it.
1212 1212 interrupthandler(self.ui, self._fp)()
1213 1213 elif payloadsize < 0:
1214 1214 msg = 'negative payload chunk size: %i' % payloadsize
1215 1215 raise error.BundleValueError(msg)
1216 1216 else:
1217 1217 result = self._readexact(payloadsize)
1218 1218 chunknum += 1
1219 1219 pos += payloadsize
1220 1220 if chunknum == len(self._chunkindex):
1221 1221 self._chunkindex.append((pos, self._tellfp()))
1222 1222 yield result
1223 1223 payloadsize = self._unpack(_fpayloadsize)[0]
1224 1224 indebug(self.ui, 'payload chunk size: %i' % payloadsize)
1225 1225
1226 1226 def _findchunk(self, pos):
1227 1227 '''for a given payload position, return a chunk number and offset'''
1228 1228 for chunk, (ppos, fpos) in enumerate(self._chunkindex):
1229 1229 if ppos == pos:
1230 1230 return chunk, 0
1231 1231 elif ppos > pos:
1232 1232 return chunk - 1, pos - self._chunkindex[chunk - 1][0]
1233 1233 raise ValueError('Unknown chunk')
1234 1234
1235 1235 def _readheader(self):
1236 1236 """read the header and setup the object"""
1237 1237 typesize = self._unpackheader(_fparttypesize)[0]
1238 1238 self.type = self._fromheader(typesize)
1239 1239 indebug(self.ui, 'part type: "%s"' % self.type)
1240 1240 self.id = self._unpackheader(_fpartid)[0]
1241 1241 indebug(self.ui, 'part id: "%s"' % pycompat.bytestr(self.id))
1242 1242 # extract mandatory bit from type
1243 1243 self.mandatory = (self.type != self.type.lower())
1244 1244 self.type = self.type.lower()
1245 1245 ## reading parameters
1246 1246 # param count
1247 1247 mancount, advcount = self._unpackheader(_fpartparamcount)
1248 1248 indebug(self.ui, 'part parameters: %i' % (mancount + advcount))
1249 1249 # param size
1250 1250 fparamsizes = _makefpartparamsizes(mancount + advcount)
1251 1251 paramsizes = self._unpackheader(fparamsizes)
1252 1252 # make it a list of couple again
1253 1253 paramsizes = list(zip(paramsizes[::2], paramsizes[1::2]))
1254 1254 # split mandatory from advisory
1255 1255 mansizes = paramsizes[:mancount]
1256 1256 advsizes = paramsizes[mancount:]
1257 1257 # retrieve param value
1258 1258 manparams = []
1259 1259 for key, value in mansizes:
1260 1260 manparams.append((self._fromheader(key), self._fromheader(value)))
1261 1261 advparams = []
1262 1262 for key, value in advsizes:
1263 1263 advparams.append((self._fromheader(key), self._fromheader(value)))
1264 1264 self._initparams(manparams, advparams)
1265 1265 ## part payload
1266 1266 self._payloadstream = util.chunkbuffer(self._payloadchunks())
1267 1267 # we read the data, tell it
1268 1268 self._initialized = True
1269 1269
1270 1270 def read(self, size=None):
1271 1271 """read payload data"""
1272 1272 if not self._initialized:
1273 1273 self._readheader()
1274 1274 if size is None:
1275 1275 data = self._payloadstream.read()
1276 1276 else:
1277 1277 data = self._payloadstream.read(size)
1278 1278 self._pos += len(data)
1279 1279 if size is None or len(data) < size:
1280 1280 if not self.consumed and self._pos:
1281 1281 self.ui.debug('bundle2-input-part: total payload size %i\n'
1282 1282 % self._pos)
1283 1283 self.consumed = True
1284 1284 return data
1285 1285
1286 1286 def tell(self):
1287 1287 return self._pos
1288 1288
1289 1289 def seek(self, offset, whence=0):
1290 1290 if whence == 0:
1291 1291 newpos = offset
1292 1292 elif whence == 1:
1293 1293 newpos = self._pos + offset
1294 1294 elif whence == 2:
1295 1295 if not self.consumed:
1296 1296 self.read()
1297 1297 newpos = self._chunkindex[-1][0] - offset
1298 1298 else:
1299 1299 raise ValueError('Unknown whence value: %r' % (whence,))
1300 1300
1301 1301 if newpos > self._chunkindex[-1][0] and not self.consumed:
1302 1302 self.read()
1303 1303 if not 0 <= newpos <= self._chunkindex[-1][0]:
1304 1304 raise ValueError('Offset out of range')
1305 1305
1306 1306 if self._pos != newpos:
1307 1307 chunk, internaloffset = self._findchunk(newpos)
1308 1308 self._payloadstream = util.chunkbuffer(self._payloadchunks(chunk))
1309 1309 adjust = self.read(internaloffset)
1310 1310 if len(adjust) != internaloffset:
1311 1311 raise error.Abort(_('Seek failed\n'))
1312 1312 self._pos = newpos
1313 1313
1314 1314 def _seekfp(self, offset, whence=0):
1315 1315 """move the underlying file pointer
1316 1316
1317 1317 This method is meant for internal usage by the bundle2 protocol only.
1318 1318 They directly manipulate the low level stream including bundle2 level
1319 1319 instruction.
1320 1320
1321 1321 Do not use it to implement higher-level logic or methods."""
1322 1322 if self._seekable:
1323 1323 return self._fp.seek(offset, whence)
1324 1324 else:
1325 1325 raise NotImplementedError(_('File pointer is not seekable'))
1326 1326
1327 1327 def _tellfp(self):
1328 1328 """return the file offset, or None if file is not seekable
1329 1329
1330 1330 This method is meant for internal usage by the bundle2 protocol only.
1331 1331 They directly manipulate the low level stream including bundle2 level
1332 1332 instruction.
1333 1333
1334 1334 Do not use it to implement higher-level logic or methods."""
1335 1335 if self._seekable:
1336 1336 try:
1337 1337 return self._fp.tell()
1338 1338 except IOError as e:
1339 1339 if e.errno == errno.ESPIPE:
1340 1340 self._seekable = False
1341 1341 else:
1342 1342 raise
1343 1343 return None
1344 1344
1345 1345 # These are only the static capabilities.
1346 1346 # Check the 'getrepocaps' function for the rest.
1347 1347 capabilities = {'HG20': (),
1348 1348 'error': ('abort', 'unsupportedcontent', 'pushraced',
1349 1349 'pushkey'),
1350 1350 'listkeys': (),
1351 1351 'pushkey': (),
1352 1352 'digests': tuple(sorted(util.DIGESTS.keys())),
1353 1353 'remote-changegroup': ('http', 'https'),
1354 1354 'hgtagsfnodes': (),
1355 1355 }
1356 1356
1357 1357 def getrepocaps(repo, allowpushback=False):
1358 1358 """return the bundle2 capabilities for a given repo
1359 1359
1360 1360 Exists to allow extensions (like evolution) to mutate the capabilities.
1361 1361 """
1362 1362 caps = capabilities.copy()
1363 1363 caps['changegroup'] = tuple(sorted(
1364 1364 changegroup.supportedincomingversions(repo)))
1365 1365 if obsolete.isenabled(repo, obsolete.exchangeopt):
1366 1366 supportedformat = tuple('V%i' % v for v in obsolete.formats)
1367 1367 caps['obsmarkers'] = supportedformat
1368 1368 if allowpushback:
1369 1369 caps['pushback'] = ()
1370 1370 cpmode = repo.ui.config('server', 'concurrent-push-mode')
1371 1371 if cpmode == 'check-related':
1372 1372 caps['checkheads'] = ('related',)
1373 1373 return caps
1374 1374
1375 1375 def bundle2caps(remote):
1376 1376 """return the bundle capabilities of a peer as dict"""
1377 1377 raw = remote.capable('bundle2')
1378 1378 if not raw and raw != '':
1379 1379 return {}
1380 1380 capsblob = urlreq.unquote(remote.capable('bundle2'))
1381 1381 return decodecaps(capsblob)
1382 1382
1383 1383 def obsmarkersversion(caps):
1384 1384 """extract the list of supported obsmarkers versions from a bundle2caps dict
1385 1385 """
1386 1386 obscaps = caps.get('obsmarkers', ())
1387 1387 return [int(c[1:]) for c in obscaps if c.startswith('V')]
1388 1388
1389 1389 def writenewbundle(ui, repo, source, filename, bundletype, outgoing, opts,
1390 1390 vfs=None, compression=None, compopts=None):
1391 1391 if bundletype.startswith('HG10'):
1392 1392 cg = changegroup.getchangegroup(repo, source, outgoing, version='01')
1393 1393 return writebundle(ui, cg, filename, bundletype, vfs=vfs,
1394 1394 compression=compression, compopts=compopts)
1395 1395 elif not bundletype.startswith('HG20'):
1396 1396 raise error.ProgrammingError('unknown bundle type: %s' % bundletype)
1397 1397
1398 1398 caps = {}
1399 1399 if 'obsolescence' in opts:
1400 1400 caps['obsmarkers'] = ('V1',)
1401 1401 bundle = bundle20(ui, caps)
1402 1402 bundle.setcompression(compression, compopts)
1403 1403 _addpartsfromopts(ui, repo, bundle, source, outgoing, opts)
1404 1404 chunkiter = bundle.getchunks()
1405 1405
1406 1406 return changegroup.writechunks(ui, chunkiter, filename, vfs=vfs)
1407 1407
1408 1408 def _addpartsfromopts(ui, repo, bundler, source, outgoing, opts):
1409 1409 # We should eventually reconcile this logic with the one behind
1410 1410 # 'exchange.getbundle2partsgenerator'.
1411 1411 #
1412 1412 # The type of input from 'getbundle' and 'writenewbundle' are a bit
1413 1413 # different right now. So we keep them separated for now for the sake of
1414 1414 # simplicity.
1415 1415
1416 1416 # we always want a changegroup in such bundle
1417 1417 cgversion = opts.get('cg.version')
1418 1418 if cgversion is None:
1419 1419 cgversion = changegroup.safeversion(repo)
1420 1420 cg = changegroup.getchangegroup(repo, source, outgoing,
1421 1421 version=cgversion)
1422 1422 part = bundler.newpart('changegroup', data=cg.getchunks())
1423 1423 part.addparam('version', cg.version)
1424 1424 if 'clcount' in cg.extras:
1425 1425 part.addparam('nbchanges', str(cg.extras['clcount']),
1426 1426 mandatory=False)
1427 1427 if opts.get('phases') and repo.revs('%ln and secret()',
1428 1428 outgoing.missingheads):
1429 1429 part.addparam('targetphase', '%d' % phases.secret, mandatory=False)
1430 1430
1431 1431 addparttagsfnodescache(repo, bundler, outgoing)
1432 1432
1433 1433 if opts.get('obsolescence', False):
1434 1434 obsmarkers = repo.obsstore.relevantmarkers(outgoing.missing)
1435 1435 buildobsmarkerspart(bundler, obsmarkers)
1436 1436
1437 1437 if opts.get('phases', False):
1438 1438 headsbyphase = phases.subsetphaseheads(repo, outgoing.missing)
1439 1439 phasedata = []
1440 1440 for phase in phases.allphases:
1441 1441 for head in headsbyphase[phase]:
1442 1442 phasedata.append(_pack(_fphasesentry, phase, head))
1443 1443 bundler.newpart('phase-heads', data=''.join(phasedata))
1444 1444
1445 1445 def addparttagsfnodescache(repo, bundler, outgoing):
1446 1446 # we include the tags fnode cache for the bundle changeset
1447 1447 # (as an optional parts)
1448 1448 cache = tags.hgtagsfnodescache(repo.unfiltered())
1449 1449 chunks = []
1450 1450
1451 1451 # .hgtags fnodes are only relevant for head changesets. While we could
1452 1452 # transfer values for all known nodes, there will likely be little to
1453 1453 # no benefit.
1454 1454 #
1455 1455 # We don't bother using a generator to produce output data because
1456 1456 # a) we only have 40 bytes per head and even esoteric numbers of heads
1457 1457 # consume little memory (1M heads is 40MB) b) we don't want to send the
1458 1458 # part if we don't have entries and knowing if we have entries requires
1459 1459 # cache lookups.
1460 1460 for node in outgoing.missingheads:
1461 1461 # Don't compute missing, as this may slow down serving.
1462 1462 fnode = cache.getfnode(node, computemissing=False)
1463 1463 if fnode is not None:
1464 1464 chunks.extend([node, fnode])
1465 1465
1466 1466 if chunks:
1467 1467 bundler.newpart('hgtagsfnodes', data=''.join(chunks))
1468 1468
1469 1469 def buildobsmarkerspart(bundler, markers):
1470 1470 """add an obsmarker part to the bundler with <markers>
1471 1471
1472 1472 No part is created if markers is empty.
1473 1473 Raises ValueError if the bundler doesn't support any known obsmarker format.
1474 1474 """
1475 1475 if not markers:
1476 1476 return None
1477 1477
1478 1478 remoteversions = obsmarkersversion(bundler.capabilities)
1479 1479 version = obsolete.commonversion(remoteversions)
1480 1480 if version is None:
1481 1481 raise ValueError('bundler does not support common obsmarker format')
1482 1482 stream = obsolete.encodemarkers(markers, True, version=version)
1483 1483 return bundler.newpart('obsmarkers', data=stream)
1484 1484
1485 1485 def writebundle(ui, cg, filename, bundletype, vfs=None, compression=None,
1486 1486 compopts=None):
1487 1487 """Write a bundle file and return its filename.
1488 1488
1489 1489 Existing files will not be overwritten.
1490 1490 If no filename is specified, a temporary file is created.
1491 1491 bz2 compression can be turned off.
1492 1492 The bundle file will be deleted in case of errors.
1493 1493 """
1494 1494
1495 1495 if bundletype == "HG20":
1496 1496 bundle = bundle20(ui)
1497 1497 bundle.setcompression(compression, compopts)
1498 1498 part = bundle.newpart('changegroup', data=cg.getchunks())
1499 1499 part.addparam('version', cg.version)
1500 1500 if 'clcount' in cg.extras:
1501 1501 part.addparam('nbchanges', str(cg.extras['clcount']),
1502 1502 mandatory=False)
1503 1503 chunkiter = bundle.getchunks()
1504 1504 else:
1505 1505 # compression argument is only for the bundle2 case
1506 1506 assert compression is None
1507 1507 if cg.version != '01':
1508 1508 raise error.Abort(_('old bundle types only supports v1 '
1509 1509 'changegroups'))
1510 1510 header, comp = bundletypes[bundletype]
1511 1511 if comp not in util.compengines.supportedbundletypes:
1512 1512 raise error.Abort(_('unknown stream compression type: %s')
1513 1513 % comp)
1514 1514 compengine = util.compengines.forbundletype(comp)
1515 1515 def chunkiter():
1516 1516 yield header
1517 1517 for chunk in compengine.compressstream(cg.getchunks(), compopts):
1518 1518 yield chunk
1519 1519 chunkiter = chunkiter()
1520 1520
1521 1521 # parse the changegroup data, otherwise we will block
1522 1522 # in case of sshrepo because we don't know the end of the stream
1523 1523 return changegroup.writechunks(ui, chunkiter, filename, vfs=vfs)
1524 1524
1525 1525 def combinechangegroupresults(op):
1526 1526 """logic to combine 0 or more addchangegroup results into one"""
1527 1527 results = [r.get('return', 0)
1528 1528 for r in op.records['changegroup']]
1529 1529 changedheads = 0
1530 1530 result = 1
1531 1531 for ret in results:
1532 1532 # If any changegroup result is 0, return 0
1533 1533 if ret == 0:
1534 1534 result = 0
1535 1535 break
1536 1536 if ret < -1:
1537 1537 changedheads += ret + 1
1538 1538 elif ret > 1:
1539 1539 changedheads += ret - 1
1540 1540 if changedheads > 0:
1541 1541 result = 1 + changedheads
1542 1542 elif changedheads < 0:
1543 1543 result = -1 + changedheads
1544 1544 return result
1545 1545
1546 1546 @parthandler('changegroup', ('version', 'nbchanges', 'treemanifest',
1547 1547 'targetphase'))
1548 1548 def handlechangegroup(op, inpart):
1549 1549 """apply a changegroup part on the repo
1550 1550
1551 1551 This is a very early implementation that will massive rework before being
1552 1552 inflicted to any end-user.
1553 1553 """
1554 1554 tr = op.gettransaction()
1555 1555 unpackerversion = inpart.params.get('version', '01')
1556 1556 # We should raise an appropriate exception here
1557 1557 cg = changegroup.getunbundler(unpackerversion, inpart, None)
1558 1558 # the source and url passed here are overwritten by the one contained in
1559 1559 # the transaction.hookargs argument. So 'bundle2' is a placeholder
1560 1560 nbchangesets = None
1561 1561 if 'nbchanges' in inpart.params:
1562 1562 nbchangesets = int(inpart.params.get('nbchanges'))
1563 1563 if ('treemanifest' in inpart.params and
1564 1564 'treemanifest' not in op.repo.requirements):
1565 1565 if len(op.repo.changelog) != 0:
1566 1566 raise error.Abort(_(
1567 1567 "bundle contains tree manifests, but local repo is "
1568 1568 "non-empty and does not use tree manifests"))
1569 1569 op.repo.requirements.add('treemanifest')
1570 1570 op.repo._applyopenerreqs()
1571 1571 op.repo._writerequirements()
1572 1572 extrakwargs = {}
1573 1573 targetphase = inpart.params.get('targetphase')
1574 1574 if targetphase is not None:
1575 1575 extrakwargs['targetphase'] = int(targetphase)
1576 1576 ret = _processchangegroup(op, cg, tr, 'bundle2', 'bundle2',
1577 1577 expectedtotal=nbchangesets, **extrakwargs)
1578 1578 if op.reply is not None:
1579 1579 # This is definitely not the final form of this
1580 1580 # return. But one need to start somewhere.
1581 1581 part = op.reply.newpart('reply:changegroup', mandatory=False)
1582 1582 part.addparam(
1583 1583 'in-reply-to', pycompat.bytestr(inpart.id), mandatory=False)
1584 1584 part.addparam('return', '%i' % ret, mandatory=False)
1585 1585 assert not inpart.read()
1586 1586
1587 1587 _remotechangegroupparams = tuple(['url', 'size', 'digests'] +
1588 1588 ['digest:%s' % k for k in util.DIGESTS.keys()])
1589 1589 @parthandler('remote-changegroup', _remotechangegroupparams)
1590 1590 def handleremotechangegroup(op, inpart):
1591 1591 """apply a bundle10 on the repo, given an url and validation information
1592 1592
1593 1593 All the information about the remote bundle to import are given as
1594 1594 parameters. The parameters include:
1595 1595 - url: the url to the bundle10.
1596 1596 - size: the bundle10 file size. It is used to validate what was
1597 1597 retrieved by the client matches the server knowledge about the bundle.
1598 1598 - digests: a space separated list of the digest types provided as
1599 1599 parameters.
1600 1600 - digest:<digest-type>: the hexadecimal representation of the digest with
1601 1601 that name. Like the size, it is used to validate what was retrieved by
1602 1602 the client matches what the server knows about the bundle.
1603 1603
1604 1604 When multiple digest types are given, all of them are checked.
1605 1605 """
1606 1606 try:
1607 1607 raw_url = inpart.params['url']
1608 1608 except KeyError:
1609 1609 raise error.Abort(_('remote-changegroup: missing "%s" param') % 'url')
1610 1610 parsed_url = util.url(raw_url)
1611 1611 if parsed_url.scheme not in capabilities['remote-changegroup']:
1612 1612 raise error.Abort(_('remote-changegroup does not support %s urls') %
1613 1613 parsed_url.scheme)
1614 1614
1615 1615 try:
1616 1616 size = int(inpart.params['size'])
1617 1617 except ValueError:
1618 1618 raise error.Abort(_('remote-changegroup: invalid value for param "%s"')
1619 1619 % 'size')
1620 1620 except KeyError:
1621 1621 raise error.Abort(_('remote-changegroup: missing "%s" param') % 'size')
1622 1622
1623 1623 digests = {}
1624 1624 for typ in inpart.params.get('digests', '').split():
1625 1625 param = 'digest:%s' % typ
1626 1626 try:
1627 1627 value = inpart.params[param]
1628 1628 except KeyError:
1629 1629 raise error.Abort(_('remote-changegroup: missing "%s" param') %
1630 1630 param)
1631 1631 digests[typ] = value
1632 1632
1633 1633 real_part = util.digestchecker(url.open(op.ui, raw_url), size, digests)
1634 1634
1635 1635 tr = op.gettransaction()
1636 1636 from . import exchange
1637 1637 cg = exchange.readbundle(op.repo.ui, real_part, raw_url)
1638 1638 if not isinstance(cg, changegroup.cg1unpacker):
1639 1639 raise error.Abort(_('%s: not a bundle version 1.0') %
1640 1640 util.hidepassword(raw_url))
1641 1641 ret = _processchangegroup(op, cg, tr, 'bundle2', 'bundle2')
1642 1642 if op.reply is not None:
1643 1643 # This is definitely not the final form of this
1644 1644 # return. But one need to start somewhere.
1645 1645 part = op.reply.newpart('reply:changegroup')
1646 1646 part.addparam(
1647 1647 'in-reply-to', pycompat.bytestr(inpart.id), mandatory=False)
1648 1648 part.addparam('return', '%i' % ret, mandatory=False)
1649 1649 try:
1650 1650 real_part.validate()
1651 1651 except error.Abort as e:
1652 1652 raise error.Abort(_('bundle at %s is corrupted:\n%s') %
1653 1653 (util.hidepassword(raw_url), str(e)))
1654 1654 assert not inpart.read()
1655 1655
1656 1656 @parthandler('reply:changegroup', ('return', 'in-reply-to'))
1657 1657 def handlereplychangegroup(op, inpart):
1658 1658 ret = int(inpart.params['return'])
1659 1659 replyto = int(inpart.params['in-reply-to'])
1660 1660 op.records.add('changegroup', {'return': ret}, replyto)
1661 1661
1662 1662 @parthandler('check:heads')
1663 1663 def handlecheckheads(op, inpart):
1664 1664 """check that head of the repo did not change
1665 1665
1666 1666 This is used to detect a push race when using unbundle.
1667 1667 This replaces the "heads" argument of unbundle."""
1668 1668 h = inpart.read(20)
1669 1669 heads = []
1670 1670 while len(h) == 20:
1671 1671 heads.append(h)
1672 1672 h = inpart.read(20)
1673 1673 assert not h
1674 1674 # Trigger a transaction so that we are guaranteed to have the lock now.
1675 1675 if op.ui.configbool('experimental', 'bundle2lazylocking'):
1676 1676 op.gettransaction()
1677 1677 if sorted(heads) != sorted(op.repo.heads()):
1678 1678 raise error.PushRaced('repository changed while pushing - '
1679 1679 'please try again')
1680 1680
1681 1681 @parthandler('check:updated-heads')
1682 1682 def handlecheckupdatedheads(op, inpart):
1683 1683 """check for race on the heads touched by a push
1684 1684
1685 1685 This is similar to 'check:heads' but focus on the heads actually updated
1686 1686 during the push. If other activities happen on unrelated heads, it is
1687 1687 ignored.
1688 1688
1689 1689 This allow server with high traffic to avoid push contention as long as
1690 1690 unrelated parts of the graph are involved."""
1691 1691 h = inpart.read(20)
1692 1692 heads = []
1693 1693 while len(h) == 20:
1694 1694 heads.append(h)
1695 1695 h = inpart.read(20)
1696 1696 assert not h
1697 1697 # trigger a transaction so that we are guaranteed to have the lock now.
1698 1698 if op.ui.configbool('experimental', 'bundle2lazylocking'):
1699 1699 op.gettransaction()
1700 1700
1701 1701 currentheads = set()
1702 1702 for ls in op.repo.branchmap().itervalues():
1703 1703 currentheads.update(ls)
1704 1704
1705 1705 for h in heads:
1706 1706 if h not in currentheads:
1707 1707 raise error.PushRaced('repository changed while pushing - '
1708 1708 'please try again')
1709 1709
1710 1710 @parthandler('output')
1711 1711 def handleoutput(op, inpart):
1712 1712 """forward output captured on the server to the client"""
1713 1713 for line in inpart.read().splitlines():
1714 1714 op.ui.status(_('remote: %s\n') % line)
1715 1715
1716 1716 @parthandler('replycaps')
1717 1717 def handlereplycaps(op, inpart):
1718 1718 """Notify that a reply bundle should be created
1719 1719
1720 1720 The payload contains the capabilities information for the reply"""
1721 1721 caps = decodecaps(inpart.read())
1722 1722 if op.reply is None:
1723 1723 op.reply = bundle20(op.ui, caps)
1724 1724
1725 1725 class AbortFromPart(error.Abort):
1726 1726 """Sub-class of Abort that denotes an error from a bundle2 part."""
1727 1727
1728 1728 @parthandler('error:abort', ('message', 'hint'))
1729 1729 def handleerrorabort(op, inpart):
1730 1730 """Used to transmit abort error over the wire"""
1731 1731 raise AbortFromPart(inpart.params['message'],
1732 1732 hint=inpart.params.get('hint'))
1733 1733
1734 1734 @parthandler('error:pushkey', ('namespace', 'key', 'new', 'old', 'ret',
1735 1735 'in-reply-to'))
1736 1736 def handleerrorpushkey(op, inpart):
1737 1737 """Used to transmit failure of a mandatory pushkey over the wire"""
1738 1738 kwargs = {}
1739 1739 for name in ('namespace', 'key', 'new', 'old', 'ret'):
1740 1740 value = inpart.params.get(name)
1741 1741 if value is not None:
1742 1742 kwargs[name] = value
1743 1743 raise error.PushkeyFailed(inpart.params['in-reply-to'], **kwargs)
1744 1744
1745 1745 @parthandler('error:unsupportedcontent', ('parttype', 'params'))
1746 1746 def handleerrorunsupportedcontent(op, inpart):
1747 1747 """Used to transmit unknown content error over the wire"""
1748 1748 kwargs = {}
1749 1749 parttype = inpart.params.get('parttype')
1750 1750 if parttype is not None:
1751 1751 kwargs['parttype'] = parttype
1752 1752 params = inpart.params.get('params')
1753 1753 if params is not None:
1754 1754 kwargs['params'] = params.split('\0')
1755 1755
1756 1756 raise error.BundleUnknownFeatureError(**kwargs)
1757 1757
1758 1758 @parthandler('error:pushraced', ('message',))
1759 1759 def handleerrorpushraced(op, inpart):
1760 1760 """Used to transmit push race error over the wire"""
1761 1761 raise error.ResponseError(_('push failed:'), inpart.params['message'])
1762 1762
1763 1763 @parthandler('listkeys', ('namespace',))
1764 1764 def handlelistkeys(op, inpart):
1765 1765 """retrieve pushkey namespace content stored in a bundle2"""
1766 1766 namespace = inpart.params['namespace']
1767 1767 r = pushkey.decodekeys(inpart.read())
1768 1768 op.records.add('listkeys', (namespace, r))
1769 1769
1770 1770 @parthandler('pushkey', ('namespace', 'key', 'old', 'new'))
1771 1771 def handlepushkey(op, inpart):
1772 1772 """process a pushkey request"""
1773 1773 dec = pushkey.decode
1774 1774 namespace = dec(inpart.params['namespace'])
1775 1775 key = dec(inpart.params['key'])
1776 1776 old = dec(inpart.params['old'])
1777 1777 new = dec(inpart.params['new'])
1778 1778 # Grab the transaction to ensure that we have the lock before performing the
1779 1779 # pushkey.
1780 1780 if op.ui.configbool('experimental', 'bundle2lazylocking'):
1781 1781 op.gettransaction()
1782 1782 ret = op.repo.pushkey(namespace, key, old, new)
1783 1783 record = {'namespace': namespace,
1784 1784 'key': key,
1785 1785 'old': old,
1786 1786 'new': new}
1787 1787 op.records.add('pushkey', record)
1788 1788 if op.reply is not None:
1789 1789 rpart = op.reply.newpart('reply:pushkey')
1790 1790 rpart.addparam(
1791 1791 'in-reply-to', pycompat.bytestr(inpart.id), mandatory=False)
1792 1792 rpart.addparam('return', '%i' % ret, mandatory=False)
1793 1793 if inpart.mandatory and not ret:
1794 1794 kwargs = {}
1795 1795 for key in ('namespace', 'key', 'new', 'old', 'ret'):
1796 1796 if key in inpart.params:
1797 1797 kwargs[key] = inpart.params[key]
1798 1798 raise error.PushkeyFailed(partid=str(inpart.id), **kwargs)
1799 1799
1800 1800 def _readphaseheads(inpart):
1801 1801 headsbyphase = [[] for i in phases.allphases]
1802 1802 entrysize = struct.calcsize(_fphasesentry)
1803 1803 while True:
1804 1804 entry = inpart.read(entrysize)
1805 1805 if len(entry) < entrysize:
1806 1806 if entry:
1807 1807 raise error.Abort(_('bad phase-heads bundle part'))
1808 1808 break
1809 1809 phase, node = struct.unpack(_fphasesentry, entry)
1810 1810 headsbyphase[phase].append(node)
1811 1811 return headsbyphase
1812 1812
1813 1813 @parthandler('phase-heads')
1814 1814 def handlephases(op, inpart):
1815 1815 """apply phases from bundle part to repo"""
1816 1816 headsbyphase = _readphaseheads(inpart)
1817 1817 phases.updatephases(op.repo.unfiltered(), op.gettransaction(), headsbyphase)
1818 1818
1819 1819 @parthandler('reply:pushkey', ('return', 'in-reply-to'))
1820 1820 def handlepushkeyreply(op, inpart):
1821 1821 """retrieve the result of a pushkey request"""
1822 1822 ret = int(inpart.params['return'])
1823 1823 partid = int(inpart.params['in-reply-to'])
1824 1824 op.records.add('pushkey', {'return': ret}, partid)
1825 1825
1826 1826 @parthandler('obsmarkers')
1827 1827 def handleobsmarker(op, inpart):
1828 1828 """add a stream of obsmarkers to the repo"""
1829 1829 tr = op.gettransaction()
1830 1830 markerdata = inpart.read()
1831 1831 if op.ui.config('experimental', 'obsmarkers-exchange-debug'):
1832 1832 op.ui.write(('obsmarker-exchange: %i bytes received\n')
1833 1833 % len(markerdata))
1834 1834 # The mergemarkers call will crash if marker creation is not enabled.
1835 1835 # we want to avoid this if the part is advisory.
1836 1836 if not inpart.mandatory and op.repo.obsstore.readonly:
1837 1837 op.repo.ui.debug('ignoring obsolescence markers, feature not enabled')
1838 1838 return
1839 1839 new = op.repo.obsstore.mergemarkers(tr, markerdata)
1840 1840 op.repo.invalidatevolatilesets()
1841 1841 if new:
1842 1842 op.repo.ui.status(_('%i new obsolescence markers\n') % new)
1843 1843 op.records.add('obsmarkers', {'new': new})
1844 1844 if op.reply is not None:
1845 1845 rpart = op.reply.newpart('reply:obsmarkers')
1846 1846 rpart.addparam(
1847 1847 'in-reply-to', pycompat.bytestr(inpart.id), mandatory=False)
1848 1848 rpart.addparam('new', '%i' % new, mandatory=False)
1849 1849
1850 1850
1851 1851 @parthandler('reply:obsmarkers', ('new', 'in-reply-to'))
1852 1852 def handleobsmarkerreply(op, inpart):
1853 1853 """retrieve the result of a pushkey request"""
1854 1854 ret = int(inpart.params['new'])
1855 1855 partid = int(inpart.params['in-reply-to'])
1856 1856 op.records.add('obsmarkers', {'new': ret}, partid)
1857 1857
1858 1858 @parthandler('hgtagsfnodes')
1859 1859 def handlehgtagsfnodes(op, inpart):
1860 1860 """Applies .hgtags fnodes cache entries to the local repo.
1861 1861
1862 1862 Payload is pairs of 20 byte changeset nodes and filenodes.
1863 1863 """
1864 1864 # Grab the transaction so we ensure that we have the lock at this point.
1865 1865 if op.ui.configbool('experimental', 'bundle2lazylocking'):
1866 1866 op.gettransaction()
1867 1867 cache = tags.hgtagsfnodescache(op.repo.unfiltered())
1868 1868
1869 1869 count = 0
1870 1870 while True:
1871 1871 node = inpart.read(20)
1872 1872 fnode = inpart.read(20)
1873 1873 if len(node) < 20 or len(fnode) < 20:
1874 1874 op.ui.debug('ignoring incomplete received .hgtags fnodes data\n')
1875 1875 break
1876 1876 cache.setfnode(node, fnode)
1877 1877 count += 1
1878 1878
1879 1879 cache.write()
1880 1880 op.ui.debug('applied %i hgtags fnodes cache entries\n' % count)
1881 1881
1882 1882 @parthandler('pushvars')
1883 1883 def bundle2getvars(op, part):
1884 1884 '''unbundle a bundle2 containing shellvars on the server'''
1885 1885 # An option to disable unbundling on server-side for security reasons
1886 if op.ui.configbool('push', 'pushvars.server', False):
1886 if op.ui.configbool('push', 'pushvars.server'):
1887 1887 hookargs = {}
1888 1888 for key, value in part.advisoryparams:
1889 1889 key = key.upper()
1890 1890 # We want pushed variables to have USERVAR_ prepended so we know
1891 1891 # they came from the --pushvar flag.
1892 1892 key = "USERVAR_" + key
1893 1893 hookargs[key] = value
1894 1894 op.addhookargs(hookargs)
@@ -1,595 +1,598 b''
1 1 # configitems.py - centralized declaration of configuration option
2 2 #
3 3 # Copyright 2017 Pierre-Yves David <pierre-yves.david@octobus.net>
4 4 #
5 5 # This software may be used and distributed according to the terms of the
6 6 # GNU General Public License version 2 or any later version.
7 7
8 8 from __future__ import absolute_import
9 9
10 10 import functools
11 11
12 12 from . import (
13 13 error,
14 14 )
15 15
16 16 def loadconfigtable(ui, extname, configtable):
17 17 """update config item known to the ui with the extension ones"""
18 18 for section, items in configtable.items():
19 19 knownitems = ui._knownconfig.setdefault(section, {})
20 20 knownkeys = set(knownitems)
21 21 newkeys = set(items)
22 22 for key in sorted(knownkeys & newkeys):
23 23 msg = "extension '%s' overwrite config item '%s.%s'"
24 24 msg %= (extname, section, key)
25 25 ui.develwarn(msg, config='warn-config')
26 26
27 27 knownitems.update(items)
28 28
29 29 class configitem(object):
30 30 """represent a known config item
31 31
32 32 :section: the official config section where to find this item,
33 33 :name: the official name within the section,
34 34 :default: default value for this item,
35 35 :alias: optional list of tuples as alternatives.
36 36 """
37 37
38 38 def __init__(self, section, name, default=None, alias=()):
39 39 self.section = section
40 40 self.name = name
41 41 self.default = default
42 42 self.alias = list(alias)
43 43
44 44 coreitems = {}
45 45
46 46 def _register(configtable, *args, **kwargs):
47 47 item = configitem(*args, **kwargs)
48 48 section = configtable.setdefault(item.section, {})
49 49 if item.name in section:
50 50 msg = "duplicated config item registration for '%s.%s'"
51 51 raise error.ProgrammingError(msg % (item.section, item.name))
52 52 section[item.name] = item
53 53
54 54 # special value for case where the default is derived from other values
55 55 dynamicdefault = object()
56 56
57 57 # Registering actual config items
58 58
59 59 def getitemregister(configtable):
60 60 return functools.partial(_register, configtable)
61 61
62 62 coreconfigitem = getitemregister(coreitems)
63 63
64 64 coreconfigitem('auth', 'cookiefile',
65 65 default=None,
66 66 )
67 67 # bookmarks.pushing: internal hack for discovery
68 68 coreconfigitem('bookmarks', 'pushing',
69 69 default=list,
70 70 )
71 71 # bundle.mainreporoot: internal hack for bundlerepo
72 72 coreconfigitem('bundle', 'mainreporoot',
73 73 default='',
74 74 )
75 75 # bundle.reorder: experimental config
76 76 coreconfigitem('bundle', 'reorder',
77 77 default='auto',
78 78 )
79 79 coreconfigitem('censor', 'policy',
80 80 default='abort',
81 81 )
82 82 coreconfigitem('chgserver', 'idletimeout',
83 83 default=3600,
84 84 )
85 85 coreconfigitem('chgserver', 'skiphash',
86 86 default=False,
87 87 )
88 88 coreconfigitem('cmdserver', 'log',
89 89 default=None,
90 90 )
91 91 coreconfigitem('color', 'mode',
92 92 default='auto',
93 93 )
94 94 coreconfigitem('color', 'pagermode',
95 95 default=dynamicdefault,
96 96 )
97 97 coreconfigitem('commands', 'status.relative',
98 98 default=False,
99 99 )
100 100 coreconfigitem('commands', 'status.skipstates',
101 101 default=[],
102 102 )
103 103 coreconfigitem('commands', 'status.verbose',
104 104 default=False,
105 105 )
106 106 coreconfigitem('commands', 'update.requiredest',
107 107 default=False,
108 108 )
109 109 coreconfigitem('devel', 'all-warnings',
110 110 default=False,
111 111 )
112 112 coreconfigitem('devel', 'bundle2.debug',
113 113 default=False,
114 114 )
115 115 coreconfigitem('devel', 'check-locks',
116 116 default=False,
117 117 )
118 118 coreconfigitem('devel', 'check-relroot',
119 119 default=False,
120 120 )
121 121 coreconfigitem('devel', 'default-date',
122 122 default=None,
123 123 )
124 124 coreconfigitem('devel', 'deprec-warn',
125 125 default=False,
126 126 )
127 127 coreconfigitem('devel', 'disableloaddefaultcerts',
128 128 default=False,
129 129 )
130 130 coreconfigitem('devel', 'legacy.exchange',
131 131 default=list,
132 132 )
133 133 coreconfigitem('devel', 'servercafile',
134 134 default='',
135 135 )
136 136 coreconfigitem('devel', 'serverexactprotocol',
137 137 default='',
138 138 )
139 139 coreconfigitem('devel', 'serverrequirecert',
140 140 default=False,
141 141 )
142 142 coreconfigitem('devel', 'strip-obsmarkers',
143 143 default=True,
144 144 )
145 145 coreconfigitem('email', 'charsets',
146 146 default=list,
147 147 )
148 148 coreconfigitem('email', 'method',
149 149 default='smtp',
150 150 )
151 151 coreconfigitem('experimental', 'bundle-phases',
152 152 default=False,
153 153 )
154 154 coreconfigitem('experimental', 'bundle2-advertise',
155 155 default=True,
156 156 )
157 157 coreconfigitem('experimental', 'bundle2-output-capture',
158 158 default=False,
159 159 )
160 160 coreconfigitem('experimental', 'bundle2.pushback',
161 161 default=False,
162 162 )
163 163 coreconfigitem('experimental', 'bundle2lazylocking',
164 164 default=False,
165 165 )
166 166 coreconfigitem('experimental', 'bundlecomplevel',
167 167 default=None,
168 168 )
169 169 coreconfigitem('experimental', 'changegroup3',
170 170 default=False,
171 171 )
172 172 coreconfigitem('experimental', 'clientcompressionengines',
173 173 default=list,
174 174 )
175 175 coreconfigitem('experimental', 'crecordtest',
176 176 default=None,
177 177 )
178 178 coreconfigitem('experimental', 'disablecopytrace',
179 179 default=False,
180 180 )
181 181 coreconfigitem('experimental', 'editortmpinhg',
182 182 default=False,
183 183 )
184 184 coreconfigitem('experimental', 'stabilization',
185 185 default=list,
186 186 alias=[('experimental', 'evolution')],
187 187 )
188 188 coreconfigitem('experimental', 'stabilization.bundle-obsmarker',
189 189 default=False,
190 190 alias=[('experimental', 'evolution.bundle-obsmarker')],
191 191 )
192 192 coreconfigitem('experimental', 'stabilization.track-operation',
193 193 default=False,
194 194 alias=[('experimental', 'evolution.track-operation')]
195 195 )
196 196 coreconfigitem('experimental', 'exportableenviron',
197 197 default=list,
198 198 )
199 199 coreconfigitem('experimental', 'extendedheader.index',
200 200 default=None,
201 201 )
202 202 coreconfigitem('experimental', 'extendedheader.similarity',
203 203 default=False,
204 204 )
205 205 coreconfigitem('experimental', 'format.compression',
206 206 default='zlib',
207 207 )
208 208 coreconfigitem('experimental', 'graphshorten',
209 209 default=False,
210 210 )
211 211 coreconfigitem('experimental', 'hook-track-tags',
212 212 default=False,
213 213 )
214 214 coreconfigitem('experimental', 'httppostargs',
215 215 default=False,
216 216 )
217 217 coreconfigitem('experimental', 'manifestv2',
218 218 default=False,
219 219 )
220 220 coreconfigitem('experimental', 'mergedriver',
221 221 default=None,
222 222 )
223 223 coreconfigitem('experimental', 'obsmarkers-exchange-debug',
224 224 default=False,
225 225 )
226 226 coreconfigitem('experimental', 'revertalternateinteractivemode',
227 227 default=True,
228 228 )
229 229 coreconfigitem('experimental', 'revlogv2',
230 230 default=None,
231 231 )
232 232 coreconfigitem('experimental', 'spacemovesdown',
233 233 default=False,
234 234 )
235 235 coreconfigitem('experimental', 'treemanifest',
236 236 default=False,
237 237 )
238 238 coreconfigitem('experimental', 'updatecheck',
239 239 default=None,
240 240 )
241 241 coreconfigitem('format', 'aggressivemergedeltas',
242 242 default=False,
243 243 )
244 244 coreconfigitem('format', 'chunkcachesize',
245 245 default=None,
246 246 )
247 247 coreconfigitem('format', 'dotencode',
248 248 default=True,
249 249 )
250 250 coreconfigitem('format', 'generaldelta',
251 251 default=False,
252 252 )
253 253 coreconfigitem('format', 'manifestcachesize',
254 254 default=None,
255 255 )
256 256 coreconfigitem('format', 'maxchainlen',
257 257 default=None,
258 258 )
259 259 coreconfigitem('format', 'obsstore-version',
260 260 default=None,
261 261 )
262 262 coreconfigitem('format', 'usefncache',
263 263 default=True,
264 264 )
265 265 coreconfigitem('format', 'usegeneraldelta',
266 266 default=True,
267 267 )
268 268 coreconfigitem('format', 'usestore',
269 269 default=True,
270 270 )
271 271 coreconfigitem('hostsecurity', 'ciphers',
272 272 default=None,
273 273 )
274 274 coreconfigitem('hostsecurity', 'disabletls10warning',
275 275 default=False,
276 276 )
277 277 coreconfigitem('http_proxy', 'always',
278 278 default=False,
279 279 )
280 280 coreconfigitem('http_proxy', 'host',
281 281 default=None,
282 282 )
283 283 coreconfigitem('http_proxy', 'no',
284 284 default=list,
285 285 )
286 286 coreconfigitem('http_proxy', 'passwd',
287 287 default=None,
288 288 )
289 289 coreconfigitem('http_proxy', 'user',
290 290 default=None,
291 291 )
292 292 coreconfigitem('merge', 'followcopies',
293 293 default=True,
294 294 )
295 295 coreconfigitem('pager', 'ignore',
296 296 default=list,
297 297 )
298 298 coreconfigitem('patch', 'eol',
299 299 default='strict',
300 300 )
301 301 coreconfigitem('patch', 'fuzz',
302 302 default=2,
303 303 )
304 304 coreconfigitem('paths', 'default',
305 305 default=None,
306 306 )
307 307 coreconfigitem('paths', 'default-push',
308 308 default=None,
309 309 )
310 310 coreconfigitem('phases', 'checksubrepos',
311 311 default='follow',
312 312 )
313 313 coreconfigitem('phases', 'publish',
314 314 default=True,
315 315 )
316 316 coreconfigitem('profiling', 'enabled',
317 317 default=False,
318 318 )
319 319 coreconfigitem('profiling', 'format',
320 320 default='text',
321 321 )
322 322 coreconfigitem('profiling', 'freq',
323 323 default=1000,
324 324 )
325 325 coreconfigitem('profiling', 'limit',
326 326 default=30,
327 327 )
328 328 coreconfigitem('profiling', 'nested',
329 329 default=0,
330 330 )
331 331 coreconfigitem('profiling', 'sort',
332 332 default='inlinetime',
333 333 )
334 334 coreconfigitem('profiling', 'statformat',
335 335 default='hotpath',
336 336 )
337 337 coreconfigitem('progress', 'assume-tty',
338 338 default=False,
339 339 )
340 340 coreconfigitem('progress', 'changedelay',
341 341 default=1,
342 342 )
343 343 coreconfigitem('progress', 'clear-complete',
344 344 default=True,
345 345 )
346 346 coreconfigitem('progress', 'debug',
347 347 default=False,
348 348 )
349 349 coreconfigitem('progress', 'delay',
350 350 default=3,
351 351 )
352 352 coreconfigitem('progress', 'disable',
353 353 default=False,
354 354 )
355 355 coreconfigitem('progress', 'estimate',
356 356 default=2,
357 357 )
358 358 coreconfigitem('progress', 'refresh',
359 359 default=0.1,
360 360 )
361 361 coreconfigitem('progress', 'width',
362 362 default=dynamicdefault,
363 363 )
364 coreconfigitem('push', 'pushvars.server',
365 default=False,
366 )
364 367 coreconfigitem('server', 'bundle1',
365 368 default=True,
366 369 )
367 370 coreconfigitem('server', 'bundle1gd',
368 371 default=None,
369 372 )
370 373 coreconfigitem('server', 'compressionengines',
371 374 default=list,
372 375 )
373 376 coreconfigitem('server', 'concurrent-push-mode',
374 377 default='strict',
375 378 )
376 379 coreconfigitem('server', 'disablefullbundle',
377 380 default=False,
378 381 )
379 382 coreconfigitem('server', 'maxhttpheaderlen',
380 383 default=1024,
381 384 )
382 385 coreconfigitem('server', 'preferuncompressed',
383 386 default=False,
384 387 )
385 388 coreconfigitem('server', 'uncompressed',
386 389 default=True,
387 390 )
388 391 coreconfigitem('server', 'uncompressedallowsecret',
389 392 default=False,
390 393 )
391 394 coreconfigitem('server', 'validate',
392 395 default=False,
393 396 )
394 397 coreconfigitem('server', 'zliblevel',
395 398 default=-1,
396 399 )
397 400 coreconfigitem('smtp', 'host',
398 401 default=None,
399 402 )
400 403 coreconfigitem('smtp', 'local_hostname',
401 404 default=None,
402 405 )
403 406 coreconfigitem('smtp', 'password',
404 407 default=None,
405 408 )
406 409 coreconfigitem('smtp', 'tls',
407 410 default='none',
408 411 )
409 412 coreconfigitem('smtp', 'username',
410 413 default=None,
411 414 )
412 415 coreconfigitem('sparse', 'missingwarning',
413 416 default=True,
414 417 )
415 418 coreconfigitem('trusted', 'groups',
416 419 default=list,
417 420 )
418 421 coreconfigitem('trusted', 'users',
419 422 default=list,
420 423 )
421 424 coreconfigitem('ui', '_usedassubrepo',
422 425 default=False,
423 426 )
424 427 coreconfigitem('ui', 'allowemptycommit',
425 428 default=False,
426 429 )
427 430 coreconfigitem('ui', 'archivemeta',
428 431 default=True,
429 432 )
430 433 coreconfigitem('ui', 'askusername',
431 434 default=False,
432 435 )
433 436 coreconfigitem('ui', 'clonebundlefallback',
434 437 default=False,
435 438 )
436 439 coreconfigitem('ui', 'clonebundleprefers',
437 440 default=list,
438 441 )
439 442 coreconfigitem('ui', 'clonebundles',
440 443 default=True,
441 444 )
442 445 coreconfigitem('ui', 'color',
443 446 default='auto',
444 447 )
445 448 coreconfigitem('ui', 'commitsubrepos',
446 449 default=False,
447 450 )
448 451 coreconfigitem('ui', 'debug',
449 452 default=False,
450 453 )
451 454 coreconfigitem('ui', 'debugger',
452 455 default=None,
453 456 )
454 457 coreconfigitem('ui', 'fallbackencoding',
455 458 default=None,
456 459 )
457 460 coreconfigitem('ui', 'forcecwd',
458 461 default=None,
459 462 )
460 463 coreconfigitem('ui', 'forcemerge',
461 464 default=None,
462 465 )
463 466 coreconfigitem('ui', 'formatdebug',
464 467 default=False,
465 468 )
466 469 coreconfigitem('ui', 'formatjson',
467 470 default=False,
468 471 )
469 472 coreconfigitem('ui', 'formatted',
470 473 default=None,
471 474 )
472 475 coreconfigitem('ui', 'graphnodetemplate',
473 476 default=None,
474 477 )
475 478 coreconfigitem('ui', 'http2debuglevel',
476 479 default=None,
477 480 )
478 481 coreconfigitem('ui', 'interactive',
479 482 default=None,
480 483 )
481 484 coreconfigitem('ui', 'interface',
482 485 default=None,
483 486 )
484 487 coreconfigitem('ui', 'logblockedtimes',
485 488 default=False,
486 489 )
487 490 coreconfigitem('ui', 'logtemplate',
488 491 default=None,
489 492 )
490 493 coreconfigitem('ui', 'merge',
491 494 default=None,
492 495 )
493 496 coreconfigitem('ui', 'mergemarkers',
494 497 default='basic',
495 498 )
496 499 coreconfigitem('ui', 'mergemarkertemplate',
497 500 default=('{node|short} '
498 501 '{ifeq(tags, "tip", "", '
499 502 'ifeq(tags, "", "", "{tags} "))}'
500 503 '{if(bookmarks, "{bookmarks} ")}'
501 504 '{ifeq(branch, "default", "", "{branch} ")}'
502 505 '- {author|user}: {desc|firstline}')
503 506 )
504 507 coreconfigitem('ui', 'nontty',
505 508 default=False,
506 509 )
507 510 coreconfigitem('ui', 'origbackuppath',
508 511 default=None,
509 512 )
510 513 coreconfigitem('ui', 'paginate',
511 514 default=True,
512 515 )
513 516 coreconfigitem('ui', 'patch',
514 517 default=None,
515 518 )
516 519 coreconfigitem('ui', 'portablefilenames',
517 520 default='warn',
518 521 )
519 522 coreconfigitem('ui', 'promptecho',
520 523 default=False,
521 524 )
522 525 coreconfigitem('ui', 'quiet',
523 526 default=False,
524 527 )
525 528 coreconfigitem('ui', 'quietbookmarkmove',
526 529 default=False,
527 530 )
528 531 coreconfigitem('ui', 'remotecmd',
529 532 default='hg',
530 533 )
531 534 coreconfigitem('ui', 'report_untrusted',
532 535 default=True,
533 536 )
534 537 coreconfigitem('ui', 'rollback',
535 538 default=True,
536 539 )
537 540 coreconfigitem('ui', 'slash',
538 541 default=False,
539 542 )
540 543 coreconfigitem('ui', 'ssh',
541 544 default='ssh',
542 545 )
543 546 coreconfigitem('ui', 'statuscopies',
544 547 default=False,
545 548 )
546 549 coreconfigitem('ui', 'strict',
547 550 default=False,
548 551 )
549 552 coreconfigitem('ui', 'style',
550 553 default='',
551 554 )
552 555 coreconfigitem('ui', 'supportcontact',
553 556 default=None,
554 557 )
555 558 coreconfigitem('ui', 'textwidth',
556 559 default=78,
557 560 )
558 561 coreconfigitem('ui', 'timeout',
559 562 default='600',
560 563 )
561 564 coreconfigitem('ui', 'traceback',
562 565 default=False,
563 566 )
564 567 coreconfigitem('ui', 'tweakdefaults',
565 568 default=False,
566 569 )
567 570 coreconfigitem('ui', 'usehttp2',
568 571 default=False,
569 572 )
570 573 coreconfigitem('ui', 'username',
571 574 alias=[('ui', 'user')]
572 575 )
573 576 coreconfigitem('ui', 'verbose',
574 577 default=False,
575 578 )
576 579 coreconfigitem('verify', 'skipflags',
577 580 default=None,
578 581 )
579 582 coreconfigitem('worker', 'backgroundclose',
580 583 default=dynamicdefault,
581 584 )
582 585 # Windows defaults to a limit of 512 open files. A buffer of 128
583 586 # should give us enough headway.
584 587 coreconfigitem('worker', 'backgroundclosemaxqueue',
585 588 default=384,
586 589 )
587 590 coreconfigitem('worker', 'backgroundcloseminfilecount',
588 591 default=2048,
589 592 )
590 593 coreconfigitem('worker', 'backgroundclosethreadcount',
591 594 default=4,
592 595 )
593 596 coreconfigitem('worker', 'numcpus',
594 597 default=None,
595 598 )
General Comments 0
You need to be logged in to leave comments. Login now