This is an archive of the discontinued Mercurial Phabricator instance.

Diff	ID	Description	Created	Lint	Unit
Base		Base
Diff 1	8082		Apr 12 2018, 3:59 PM	★	★
Diff 2	8128		Apr 13 2018, 3:14 PM	★	★
Diff 3	8174	rHG65b86ee69383a8bb7fd16d2e9f83b0cba0e87dca	Apr 13 2018, 2:14 PM	★	★

Status	Author	Revision
Closed	indygreg	D3335 wireproto: expose repository formats via capabilities
Closed	indygreg	D3334 wireprotoframing: record when new stream is encountered
Closed	indygreg	D3333 wireprotoframing: use value passed into function
Closed	indygreg	D3332 httppeer: handle error response from client reactor
Closed	indygreg	D3299 wireproto: add media type to version 2 capabilities response
Closed	indygreg	D3298 debugcommands: use command executor for invoking commands
Closed	indygreg	D3297 httppeer: implement command executor for version 2 peer
Closed	indygreg	D3318 repository: remove ipeercommands from ipeerbase
Closed	indygreg	D3317 wireproto: properly call clonebundles command
Closed	indygreg	D3316 exchange: use command executor for getbundle
Closed	indygreg	D3315 exchange: use command executor for pushkey
Closed	indygreg	D3314 wireproto: use command executor for unbundle
Closed	indygreg	D3296 debugcommands: perform handshake when obtaining httpv2 peer
Closed	indygreg	D3295 wireproto: rename HTTPV2 so it less like HTTP/2
Closed	indygreg	D3294 bundlerepo: use command executor for wire protocol commands
Closed	indygreg	D3293 bundlerepo: rename "other" to "peer"
Closed	indygreg	D3292 bookmarks: use command executor for wire protocol commands
Closed	indygreg	D3291 hg: use command executor for wire protocol commands
Closed	indygreg	D3290 logexchange: use command executor for wire protocol commands
Closed	indygreg	D3289 streamclone: use command executor for wire protocol commands
Closed	indygreg	D3288 discovery: use command executor interface
Closed	indygreg	D3287 discovery: don't redundantly call branchmap
Closed	indygreg	D3273 wireproto: convert legacy commands to command executor
Closed	indygreg	D3272 treediscovery: switch to command executor interface
Closed	indygreg	D3271 wireproto: remove iterbatch() from peer interface (API)
Closed	indygreg	D3270 largefiles: use command executor for batch operation
Closed	indygreg	D3269 wireproto: implement batching on peer executor interface
Closed	indygreg	D3268 wireproto: implement command executor interface for version 1 peers
Closed	indygreg	D3267 repository: define new interface for running commands
Closed	indygreg	D3266 pycompat: export a handle on concurrent.futures
Closed	indygreg	D3265 setup: add packages for concurrent.futures
Closed	indygreg	D3264 futures: switch to absolute and relative imports
Closed	indygreg	D3263 tests: silence pyflakes for thirdparty/concurrent
Closed	indygreg	D3262 futures: get rid of extend_path
Closed	indygreg	D3261 thirdparty: vendor futures 3.2.0
Closed	indygreg	D3260 peer: scatter module to the wind (API)
Closed	indygreg	D3259 wireproto: move version 1 peer functionality to standalone module (API)
Closed	indygreg	D3258 wireproto: move gboptsmap to wireprototypes and rename (API)
Closed	indygreg	D3257 wireproto: move value encoding functions to wireprototypes (API)
Closed	indygreg	D3256 httppeer: basic implementation of capabilities interface
Closed	indygreg	D3255 repository: split capabilities methods into separate interface
Closed	indygreg	D3254 httppeer: implement ipeerconnection

Diff 8128

mercurial/streamclone.py


	repo = pullop.repo			repo = pullop.repo
	remote = pullop.remote			remote = pullop.remote

	# Save remote branchmap. We will use it later to speed up branchcache			# Save remote branchmap. We will use it later to speed up branchcache
	# creation.			# creation.
	rbranchmap = None			rbranchmap = None
	if remote.capable('branchmap'):			if remote.capable('branchmap'):
	rbranchmap = remote.branchmap()			with remote.commandexecutor() as e:
				rbranchmap = e.callcommand('branchmap', {}).result()

	repo.ui.status(_('streaming all changes\n'))			repo.ui.status(_('streaming all changes\n'))

	fp = remote.stream_out()			with remote.commandexecutor() as e:
				fp = e.callcommand('stream_out', {}).result()

				# TODO strictly speaking, this code should all be inside the context
				# manager because the context manager is supposed to ensure all wire state
				# is flushed when exiting. But the legacy peers don't do this, so it
				# doesn't matter.
	l = fp.readline()			l = fp.readline()
	try:			try:
	resp = int(l)			resp = int(l)
	except ValueError:			except ValueError:
	raise error.ResponseError(			raise error.ResponseError(
	_('unexpected response from remote server:'), l)			_('unexpected response from remote server:'), l)
	if resp == 1:			if resp == 1:
	raise error.Abort(_('operation forbidden by server'))			raise error.Abort(_('operation forbidden by server'))

This is an archive of the discontinued Mercurial Phabricator instance.

streamclone: use command executor for wire protocol commandsClosedPublic

Details

Diff Detail

Event Timeline

Revision ContentsChangeset List

Diff 8128

mercurial/streamclone.py

streamclone: use command executor for wire protocol commands
ClosedPublic

Revision Contents
Changeset List