mercurial/obsolete.py

22328:fba8c1a4ce21

    # Kept separate from flushmarkers(), it will be reused for
    # markers exchange.
    if addheader:
        yield _pack('>B', _fm0version)
    for marker in markers:
        yield _encodeonemarker(marker)


def _encodeonemarker(marker):
    pre, sucs, flags, metadata, date, parents = marker
    metadata = decodemeta(metadata)
    metadata['date'] = '%d %i' % date
    if parents is not None:
        if not parents:

    - split in chunks smaller than 5300 bytes"""
    keys = {}
    parts = []
    currentlen = _maxpayload * 2  # ensure we create a new part
    for marker in markers:
        nextdata = _encodeonemarker(marker)
        if (len(nextdata) + currentlen > _maxpayload):
            currentpart = []
            currentlen = 0
            parts.append(currentpart)
        currentpart.append(nextdata)

22329:ed37aa74d208

    # Kept separate from flushmarkers(), it will be reused for
    # markers exchange.
    if addheader:
        yield _pack('>B', _fm0version)
    for marker in markers:
        yield _fm0encodeonemarker(marker)


def _fm0encodeonemarker(marker):
    pre, sucs, flags, metadata, date, parents = marker
    metadata = decodemeta(metadata)
    metadata['date'] = '%d %i' % date
    if parents is not None:
        if not parents:

    - split in chunks smaller than 5300 bytes"""
    keys = {}
    parts = []
    currentlen = _maxpayload * 2  # ensure we create a new part
    for marker in markers:
        nextdata = _fm0encodeonemarker(marker)
        if (len(nextdata) + currentlen > _maxpayload):
            currentpart = []
            currentlen = 0
            parts.append(currentpart)
        currentpart.append(nextdata)