This is an archive of the discontinued Mercurial Phabricator instance.

Status	Author	Revision
Closed	valentin.gatienbaron	D9999 sshpeer: enable+fix warning about sshpeers not being closed explicitly
Closed	valentin.gatienbaron	D9998 sshpeer: add a develwarning if an sshpeer is not closed explicitly
Closed	valentin.gatienbaron	D9997 remotefilelog: rework workaround for sshpeer deadlocks
Closed	valentin.gatienbaron	D9996 sshpeer: add a method to check if a doublepipe is closed
Closed	valentin.gatienbaron	D9995 sshpeer: make sshpeer.close() close the underlying connection

Diff 25632

	if data is None:			if data is None:
	return meth()			return meth()
	else:			else:
	return meth(data)			return meth(data)

	def close(self):			def close(self):
	return self._main.close()			return self._main.close()

				@property
				def closed(self):
				return self._main.closed

	def flush(self):			def flush(self):
	return self._main.flush()			return self._main.flush()


	def _cleanuppipes(ui, pipei, pipeo, pipee):			def _cleanuppipes(ui, pipei, pipeo, pipee):
	"""Clean up pipes used by an SSH connection."""			"""Clean up pipes used by an SSH connection."""
	if pipeo:			if pipeo:
	pipeo.close()			pipeo.close()

	def badmethod(self):			def badmethod(self):
	pass			pass


	class dummypipe(object):			class dummypipe(object):
	def close(self):			def close(self):
	pass			pass

				@property
				def closed(self):
				pass


	def main():			def main():
	ui = uimod.ui()			ui = uimod.ui()
	# Needed so we can open a local repo with obsstore without a warning.			# Needed so we can open a local repo with obsstore without a warning.
	ui.setconfig(b'experimental', b'evolution.createmarkers', True)			ui.setconfig(b'experimental', b'evolution.createmarkers', True)

	checkzobject(badpeer())			checkzobject(badpeer())