72 outgoing.missing, outgoing.missing) |
72 outgoing.missing, outgoing.missing) |
73 transmit = [] |
73 transmit = [] |
74 for node in boxedges: |
74 for node in boxedges: |
75 transmit.extend(obsolete.successormarkers(urepo[node])) |
75 transmit.extend(obsolete.successormarkers(urepo[node])) |
76 xmit, total = len(transmit), len(repo.obsstore._all) |
76 xmit, total = len(transmit), len(repo.obsstore._all) |
77 repo.ui.status('about to transmit %d obsolete markers (%d markers total)\n' |
77 repo.ui.status( |
78 % (xmit, total)) |
78 'boxpush: about to transmit %d obsolete markers (%d markers total)\n' |
|
79 % (xmit, total)) |
79 parts, size, chunk = [], 0, 0 |
80 parts, size, chunk = [], 0, 0 |
80 for marker in transmit: |
81 for marker in transmit: |
81 enc = obsolete._encodeonemarker(_markertuple(marker)) |
82 enc = obsolete._encodeonemarker(_markertuple(marker)) |
82 parts.append(enc) |
83 parts.append(enc) |
83 size += len(enc) |
84 size += len(enc) |
84 if size > obsolete._maxpayload: |
85 if size > obsolete._maxpayload: |
85 repo.ui.note( |
86 repo.ui.note( |
86 'obsolete boxpush: sending a chunk of obsolete markers\n') |
87 'boxpush: sending a chunk of obsolete markers\n') |
87 data = ''.join([obsolete._pack('>B', _fmversion)], parts) |
88 data = ''.join([obsolete._pack('>B', _fmversion)], parts) |
88 remote.pushkey('obsolete', 'dump%d' % chunk, base85.b85encode(data)) |
89 remote.pushkey('obsolete', 'dump%d' % chunk, base85.b85encode(data)) |
89 parts, size = [], 0 |
90 parts, size = [], 0 |
90 chunk += 1 |
91 chunk += 1 |
91 |
92 |