equal
deleted
inserted
replaced
110 # Save remote branchmap. We will use it later to speed up branchcache |
110 # Save remote branchmap. We will use it later to speed up branchcache |
111 # creation. |
111 # creation. |
112 rbranchmap = None |
112 rbranchmap = None |
113 if remote.capable('branchmap'): |
113 if remote.capable('branchmap'): |
114 rbranchmap = remote.branchmap() |
114 rbranchmap = remote.branchmap() |
|
115 |
|
116 repo.ui.status(_('streaming all changes\n')) |
115 |
117 |
116 fp = remote.stream_out() |
118 fp = remote.stream_out() |
117 l = fp.readline() |
119 l = fp.readline() |
118 try: |
120 try: |
119 resp = int(l) |
121 resp = int(l) |
243 Like "streamout," the status line added by the wire protocol is not handled |
245 Like "streamout," the status line added by the wire protocol is not handled |
244 by this function. |
246 by this function. |
245 """ |
247 """ |
246 lock = repo.lock() |
248 lock = repo.lock() |
247 try: |
249 try: |
248 repo.ui.status(_('streaming all changes\n')) |
|
249 repo.ui.status(_('%d files to transfer, %s of data\n') % |
250 repo.ui.status(_('%d files to transfer, %s of data\n') % |
250 (filecount, util.bytecount(bytecount))) |
251 (filecount, util.bytecount(bytecount))) |
251 handled_bytes = 0 |
252 handled_bytes = 0 |
252 repo.ui.progress(_('clone'), 0, total=bytecount) |
253 repo.ui.progress(_('clone'), 0, total=bytecount) |
253 start = time.time() |
254 start = time.time() |