/brz/remove-bazaar : contents of bzrlib/tests/test_transport

: (revision 2977.1.5)

To get this branch, use:

bzr branch
http://gegoxaren.bato24.eu/bzr/brz/remove-bazaar

2018.18.22 by Martin Pool merge bzr.dev	1	# Copyright (C) 2004, 2005, 2006, 2007 Canonical Ltd
1887.1.1 by Adeodato Simó Do not separate paragraphs in the copyright statement with blank lines,	2	#
1530.1.3 by Robert Collins transport implementations now tested consistently.	3	# This program is free software; you can redistribute it and/or modify
	4	# it under the terms of the GNU General Public License as published by
	5	# the Free Software Foundation; either version 2 of the License, or
	6	# (at your option) any later version.
1887.1.1 by Adeodato Simó Do not separate paragraphs in the copyright statement with blank lines,	7	#
1530.1.3 by Robert Collins transport implementations now tested consistently.	8	# This program is distributed in the hope that it will be useful,
	9	# but WITHOUT ANY WARRANTY; without even the implied warranty of
	10	# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
	11	# GNU General Public License for more details.
1887.1.1 by Adeodato Simó Do not separate paragraphs in the copyright statement with blank lines,	12	#
1530.1.3 by Robert Collins transport implementations now tested consistently.	13	# You should have received a copy of the GNU General Public License
	14	# along with this program; if not, write to the Free Software
	15	# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
	16
	17	"""Tests for Transport implementations.
	18
	19	Transport implementations tested here are supplied by
	20	TransportTestProviderAdapter.
	21	"""
	22
	23	import os
	24	from cStringIO import StringIO
2018.5.131 by Andrew Bennetts Be strict about unicode passed to transport.put_{bytes,file} and SmartClient.call_with_body_bytes, fixing part of TestLockableFiles_RemoteLockDir.test_read_write.	25	from StringIO import StringIO as pyStringIO
1530.1.15 by Robert Collins Move put mode tests into test_transport_implementation.	26	import stat
	27	import sys
2553.2.5 by Robert Collins And overhaul TransportTestProviderAdapter too.	28	import unittest
1530.1.3 by Robert Collins transport implementations now tested consistently.	29
1755.3.7 by John Arbash Meinel Clean up and write tests for permissions. Now we use fstat which should be cheap, and lets us check the permissions and the file size	30	from bzrlib import (
2001.3.2 by John Arbash Meinel Force all transports to raise ShortReadvError if they can	31	errors,
1755.3.7 by John Arbash Meinel Clean up and write tests for permissions. Now we use fstat which should be cheap, and lets us check the permissions and the file size	32	osutils,
	33	urlutils,
	34	)
2400.2.1 by Robert Collins Split out the improvement to Transport.local_abspath to raise NotLocalURL from the hpss-faster-copy branch. (Martin Pool, Ian Clatworthy)	35	from bzrlib.errors import (ConnectionError,
	36	DirectoryNotEmpty,
	37	FileExists,
	38	InvalidURL,
	39	LockError,
	40	NoSmartServer,
	41	NoSuchFile,
	42	NotLocalUrl,
	43	PathError,
	44	TransportNotPossible,
	45	)
1685.1.9 by John Arbash Meinel Updated LocalTransport so that it's base is now a URL rather than a local path. This helps consistency with all other functions. To do so, I added local_abspath() which returns the local path, and local_path_to/from_url	46	from bzrlib.osutils import getcwd
2018.5.139 by Andrew Bennetts Merge from bzr.dev, resolving conflicts.	47	from bzrlib.smart import medium
2553.2.5 by Robert Collins And overhaul TransportTestProviderAdapter too.	48	from bzrlib.tests import TestCaseInTempDir, TestScenarioApplier, TestSkipped
1871.1.2 by Robert Collins Reduce code duplication in transport-parameterised tests.	49	from bzrlib.tests.test_transport import TestTransportImplementation
2485.8.25 by Vincent Ladeuil Separate abspath from _remote_path, the intents are different.	50	from bzrlib.transport import (
	51	ConnectedTransport,
	52	get_transport,
2485.8.50 by Vincent Ladeuil merge bzr.dev @ 2584 resolving conflicts	53	_get_transport_modules,
2485.8.25 by Vincent Ladeuil Separate abspath from _remote_path, the intents are different.	54	)
	55	from bzrlib.transport.memory import MemoryTransport
1530.1.3 by Robert Collins transport implementations now tested consistently.	56
	57
2553.2.5 by Robert Collins And overhaul TransportTestProviderAdapter too.	58	class TransportTestProviderAdapter(TestScenarioApplier):
	59	"""A tool to generate a suite testing all transports for a single test.
	60
	61	This is done by copying the test once for each transport and injecting
	62	the transport_class and transport_server classes into each copy. Each copy
	63	is also given a new id() to make it easy to identify.
	64	"""
	65
	66	def __init__(self):
	67	self.scenarios = self._test_permutations()
	68
	69	def get_transport_test_permutations(self, module):
	70	"""Get the permutations module wants to have tested."""
	71	if getattr(module, 'get_test_permutations', None) is None:
	72	raise AssertionError("transport module %s doesn't provide get_test_permutations()"
	73	% module.__name__)
	74	##warning("transport module %s doesn't provide get_test_permutations()"
	75	## % module.__name__)
	76	return []
	77	return module.get_test_permutations()
	78
	79	def _test_permutations(self):
	80	"""Return a list of the klass, server_factory pairs to test."""
	81	result = []
	82	for module in _get_transport_modules():
	83	try:
	84	permutations = self.get_transport_test_permutations(
	85	reduce(getattr, (module).split('.')[1:], __import__(module)))
	86	for (klass, server_factory) in permutations:
	87	scenario = (server_factory.__name__,
	88	{"transport_class":klass,
	89	"transport_server":server_factory})
	90	result.append(scenario)
	91	except errors.DependencyNotPresent, e:
	92	# Continue even if a dependency prevents us
	93	# from running this test
	94	pass
	95	return result
	96
	97
	98
1871.1.2 by Robert Collins Reduce code duplication in transport-parameterised tests.	99	class TransportTests(TestTransportImplementation):
	100
2018.5.24 by Andrew Bennetts Setting NO_SMART_VFS in environment will disable VFS methods in the smart server. (Robert Collins, John Arbash Meinel, Andrew Bennetts)	101	def setUp(self):
	102	super(TransportTests, self).setUp()
2402.1.2 by Andrew Bennetts Deal with review comments.	103	self._captureVar('BZR_NO_SMART_VFS', None)
2018.5.24 by Andrew Bennetts Setting NO_SMART_VFS in environment will disable VFS methods in the smart server. (Robert Collins, John Arbash Meinel, Andrew Bennetts)	104
1530.1.3 by Robert Collins transport implementations now tested consistently.	105	def check_transport_contents(self, content, transport, relpath):
	106	"""Check that transport.get(relpath).read() == content."""
1530.1.21 by Robert Collins Review feedback fixes.	107	self.assertEqualDiff(content, transport.get(relpath).read())
1530.1.15 by Robert Collins Move put mode tests into test_transport_implementation.	108
2475.3.2 by John Arbash Meinel Add Transport.ensure_base()	109	def test_ensure_base_missing(self):
	110	""".ensure_base() should create the directory if it doesn't exist"""
	111	t = self.get_transport()
	112	t_a = t.clone('a')
	113	if t_a.is_readonly():
	114	self.assertRaises(TransportNotPossible,
	115	t_a.ensure_base)
	116	return
	117	self.assertTrue(t_a.ensure_base())
	118	self.assertTrue(t.has('a'))
	119
	120	def test_ensure_base_exists(self):
	121	""".ensure_base() should just be happy if it already exists"""
	122	t = self.get_transport()
	123	if t.is_readonly():
	124	return
	125
	126	t.mkdir('a')
	127	t_a = t.clone('a')
	128	# ensure_base returns False if it didn't create the base
	129	self.assertFalse(t_a.ensure_base())
	130
	131	def test_ensure_base_missing_parent(self):
	132	""".ensure_base() will fail if the parent dir doesn't exist"""
	133	t = self.get_transport()
	134	if t.is_readonly():
	135	return
	136
	137	t_a = t.clone('a')
	138	t_b = t_a.clone('b')
	139	self.assertRaises(NoSuchFile, t_b.ensure_base)
	140
2634.1.1 by Robert Collins (robertc) Reinstate the accidentally backed out external_url patch.	141	def test_external_url(self):
	142	""".external_url either works or raises InProcessTransport."""
	143	t = self.get_transport()
	144	try:
	145	t.external_url()
	146	except errors.InProcessTransport:
	147	pass
	148
1530.1.3 by Robert Collins transport implementations now tested consistently.	149	def test_has(self):
	150	t = self.get_transport()
	151
	152	files = ['a', 'b', 'e', 'g', '%']
	153	self.build_tree(files, transport=t)
	154	self.assertEqual(True, t.has('a'))
	155	self.assertEqual(False, t.has('c'))
1685.1.45 by John Arbash Meinel Moved url functions into bzrlib.urlutils	156	self.assertEqual(True, t.has(urlutils.escape('%')))
1530.1.3 by Robert Collins transport implementations now tested consistently.	157	self.assertEqual(list(t.has_multi(['a', 'b', 'c', 'd', 'e', 'f', 'g', 'h'])),
	158	[True, True, False, False, True, False, True, False])
	159	self.assertEqual(True, t.has_any(['a', 'b', 'c']))
1685.1.45 by John Arbash Meinel Moved url functions into bzrlib.urlutils	160	self.assertEqual(False, t.has_any(['c', 'd', 'f', urlutils.escape('%%')]))
1530.1.3 by Robert Collins transport implementations now tested consistently.	161	self.assertEqual(list(t.has_multi(iter(['a', 'b', 'c', 'd', 'e', 'f', 'g', 'h']))),
	162	[True, True, False, False, True, False, True, False])
	163	self.assertEqual(False, t.has_any(['c', 'c', 'c']))
	164	self.assertEqual(True, t.has_any(['b', 'b', 'b']))
	165
1986.1.10 by Robert Collins Merge from bzr.dev, fixing found bugs handling 'has('/')' in MemoryTransport and SFTP transports.	166	def test_has_root_works(self):
	167	current_transport = self.get_transport()
	168	self.assertTrue(current_transport.has('/'))
	169	root = current_transport.clone('/')
	170	self.assertTrue(root.has(''))
	171
1530.1.3 by Robert Collins transport implementations now tested consistently.	172	def test_get(self):
	173	t = self.get_transport()
	174
	175	files = ['a', 'b', 'e', 'g']
	176	contents = ['contents of a\n',
	177	'contents of b\n',
	178	'contents of e\n',
	179	'contents of g\n',
	180	]
1551.2.39 by abentley Fix line endings in tests	181	self.build_tree(files, transport=t, line_endings='binary')
1530.1.3 by Robert Collins transport implementations now tested consistently.	182	self.check_transport_contents('contents of a\n', t, 'a')
	183	content_f = t.get_multi(files)
	184	for content, f in zip(contents, content_f):
	185	self.assertEqual(content, f.read())
	186
	187	content_f = t.get_multi(iter(files))
	188	for content, f in zip(contents, content_f):
	189	self.assertEqual(content, f.read())
	190
	191	self.assertRaises(NoSuchFile, t.get, 'c')
	192	self.assertListRaises(NoSuchFile, t.get_multi, ['a', 'b', 'c'])
	193	self.assertListRaises(NoSuchFile, t.get_multi, iter(['a', 'b', 'c']))
	194
2052.6.2 by Robert Collins Merge bzr.dev.	195	def test_get_directory_read_gives_ReadError(self):
2052.6.2 by Robert Collins Merge bzr.dev.	196	"""consistent errors for read() on a file returned by get()."""
2052.6.1 by Robert Collins ``Transport.get`` has had its interface made more clear for ease of use.	197	t = self.get_transport()
	198	if t.is_readonly():
	199	self.build_tree(['a directory/'])
	200	else:
	201	t.mkdir('a%20directory')
	202	# getting the file must either work or fail with a PathError
	203	try:
	204	a_file = t.get('a%20directory')
2052.6.2 by Robert Collins Merge bzr.dev.	205	except (errors.PathError, errors.RedirectRequested):
2052.6.1 by Robert Collins ``Transport.get`` has had its interface made more clear for ease of use.	206	# early failure return immediately.
	207	return
	208	# having got a file, read() must either work (i.e. http reading a dir listing) or
	209	# fail with ReadError
	210	try:
	211	a_file.read()
	212	except errors.ReadError:
	213	pass
	214
1955.3.3 by John Arbash Meinel Implement and test 'get_bytes'	215	def test_get_bytes(self):
	216	t = self.get_transport()
	217
	218	files = ['a', 'b', 'e', 'g']
	219	contents = ['contents of a\n',
	220	'contents of b\n',
	221	'contents of e\n',
	222	'contents of g\n',
	223	]
	224	self.build_tree(files, transport=t, line_endings='binary')
	225	self.check_transport_contents('contents of a\n', t, 'a')
	226
	227	for content, fname in zip(contents, files):
	228	self.assertEqual(content, t.get_bytes(fname))
	229
	230	self.assertRaises(NoSuchFile, t.get_bytes, 'c')
	231
2671.3.9 by Robert Collins Review feedback and fix VFat emulated transports to not claim to have unix permissions.	232	def test_get_with_open_write_stream_sees_all_content(self):
2671.3.4 by Robert Collins Sync up with open file streams on get/get_bytes.	233	t = self.get_transport()
	234	if t.is_readonly():
	235	return
2671.3.9 by Robert Collins Review feedback and fix VFat emulated transports to not claim to have unix permissions.	236	handle = t.open_write_stream('foo')
2671.3.4 by Robert Collins Sync up with open file streams on get/get_bytes.	237	try:
2671.3.6 by Robert Collins Review feedback.	238	handle.write('b')
2671.3.4 by Robert Collins Sync up with open file streams on get/get_bytes.	239	self.assertEqual('b', t.get('foo').read())
	240	finally:
2671.3.6 by Robert Collins Review feedback.	241	handle.close()
2671.3.4 by Robert Collins Sync up with open file streams on get/get_bytes.	242
2671.3.9 by Robert Collins Review feedback and fix VFat emulated transports to not claim to have unix permissions.	243	def test_get_bytes_with_open_write_stream_sees_all_content(self):
2671.3.4 by Robert Collins Sync up with open file streams on get/get_bytes.	244	t = self.get_transport()
	245	if t.is_readonly():
	246	return
2671.3.9 by Robert Collins Review feedback and fix VFat emulated transports to not claim to have unix permissions.	247	handle = t.open_write_stream('foo')
2671.3.4 by Robert Collins Sync up with open file streams on get/get_bytes.	248	try:
2671.3.6 by Robert Collins Review feedback.	249	handle.write('b')
2671.3.4 by Robert Collins Sync up with open file streams on get/get_bytes.	250	self.assertEqual('b', t.get_bytes('foo'))
	251	self.assertEqual('b', t.get('foo').read())
	252	finally:
2671.3.6 by Robert Collins Review feedback.	253	handle.close()
2671.3.4 by Robert Collins Sync up with open file streams on get/get_bytes.	254
1955.3.1 by John Arbash Meinel Add put_bytes() and a base-level implementation for it	255	def test_put_bytes(self):
	256	t = self.get_transport()
	257
	258	if t.is_readonly():
	259	self.assertRaises(TransportNotPossible,
	260	t.put_bytes, 'a', 'some text for a\n')
	261	return
	262
	263	t.put_bytes('a', 'some text for a\n')
	264	self.failUnless(t.has('a'))
	265	self.check_transport_contents('some text for a\n', t, 'a')
	266
	267	# The contents should be overwritten
	268	t.put_bytes('a', 'new text for a\n')
	269	self.check_transport_contents('new text for a\n', t, 'a')
	270
	271	self.assertRaises(NoSuchFile,
	272	t.put_bytes, 'path/doesnt/exist/c', 'contents')
1530.1.3 by Robert Collins transport implementations now tested consistently.	273
1955.3.27 by John Arbash Meinel rename non_atomic_put_* to put_*non_atomic, and re-order the functions	274	def test_put_bytes_non_atomic(self):
	275	t = self.get_transport()
	276
	277	if t.is_readonly():
	278	self.assertRaises(TransportNotPossible,
	279	t.put_bytes_non_atomic, 'a', 'some text for a\n')
	280	return
	281
	282	self.failIf(t.has('a'))
	283	t.put_bytes_non_atomic('a', 'some text for a\n')
	284	self.failUnless(t.has('a'))
	285	self.check_transport_contents('some text for a\n', t, 'a')
	286	# Put also replaces contents
	287	t.put_bytes_non_atomic('a', 'new\ncontents for\na\n')
	288	self.check_transport_contents('new\ncontents for\na\n', t, 'a')
	289
	290	# Make sure we can create another file
	291	t.put_bytes_non_atomic('d', 'contents for\nd\n')
	292	# And overwrite 'a' with empty contents
	293	t.put_bytes_non_atomic('a', '')
	294	self.check_transport_contents('contents for\nd\n', t, 'd')
	295	self.check_transport_contents('', t, 'a')
	296
	297	self.assertRaises(NoSuchFile, t.put_bytes_non_atomic, 'no/such/path',
	298	'contents\n')
	299	# Now test the create_parent flag
	300	self.assertRaises(NoSuchFile, t.put_bytes_non_atomic, 'dir/a',
	301	'contents\n')
	302	self.failIf(t.has('dir/a'))
	303	t.put_bytes_non_atomic('dir/a', 'contents for dir/a\n',
	304	create_parent_dir=True)
	305	self.check_transport_contents('contents for dir/a\n', t, 'dir/a')
	306
	307	# But we still get NoSuchFile if we can't make the parent dir
	308	self.assertRaises(NoSuchFile, t.put_bytes_non_atomic, 'not/there/a',
	309	'contents\n',
	310	create_parent_dir=True)
	311
	312	def test_put_bytes_permissions(self):
	313	t = self.get_transport()
	314
	315	if t.is_readonly():
	316	return
	317	if not t._can_roundtrip_unix_modebits():
	318	# Can't roundtrip, so no need to run this test
	319	return
	320	t.put_bytes('mode644', 'test text\n', mode=0644)
	321	self.assertTransportMode(t, 'mode644', 0644)
	322	t.put_bytes('mode666', 'test text\n', mode=0666)
	323	self.assertTransportMode(t, 'mode666', 0666)
	324	t.put_bytes('mode600', 'test text\n', mode=0600)
	325	self.assertTransportMode(t, 'mode600', 0600)
	326	# Yes, you can put_bytes a file such that it becomes readonly
	327	t.put_bytes('mode400', 'test text\n', mode=0400)
	328	self.assertTransportMode(t, 'mode400', 0400)
	329
	330	# The default permissions should be based on the current umask
	331	umask = osutils.get_umask()
	332	t.put_bytes('nomode', 'test text\n', mode=None)
	333	self.assertTransportMode(t, 'nomode', 0666 & ~umask)
	334
	335	def test_put_bytes_non_atomic_permissions(self):
	336	t = self.get_transport()
	337
338	if t.is_readonly():
339	return
340	if not t._can_roundtrip_unix_modebits():
341	# Can't roundtrip, so no need to run this test
342	return
343	t.put_bytes_non_atomic('mode644', 'test text\n', mode=0644)
344	self.assertTransportMode(t, 'mode644', 0644)
345	t.put_bytes_non_atomic('mode666', 'test text\n', mode=0666)
346	self.assertTransportMode(t, 'mode666', 0666)
347	t.put_bytes_non_atomic('mode600', 'test text\n', mode=0600)
348	self.assertTransportMode(t, 'mode600', 0600)
349	t.put_bytes_non_atomic('mode400', 'test text\n', mode=0400)
350	self.assertTransportMode(t, 'mode400', 0400)
351
352	# The default permissions should be based on the current umask
353	umask = osutils.get_umask()
354	t.put_bytes_non_atomic('nomode', 'test text\n', mode=None)
355	self.assertTransportMode(t, 'nomode', 0666 & ~umask)
1946.2.12 by John Arbash Meinel Add ability to pass a directory mode to non_atomic_put	356
	357	# We should also be able to set the mode for a parent directory
	358	# when it is created
	359	t.put_bytes_non_atomic('dir700/mode664', 'test text\n', mode=0664,
	360	dir_mode=0700, create_parent_dir=True)
	361	self.assertTransportMode(t, 'dir700', 0700)
	362	t.put_bytes_non_atomic('dir770/mode664', 'test text\n', mode=0664,
	363	dir_mode=0770, create_parent_dir=True)
	364	self.assertTransportMode(t, 'dir770', 0770)
	365	t.put_bytes_non_atomic('dir777/mode664', 'test text\n', mode=0664,
	366	dir_mode=0777, create_parent_dir=True)
	367	self.assertTransportMode(t, 'dir777', 0777)
1955.3.27 by John Arbash Meinel rename non_atomic_put_* to put_*non_atomic, and re-order the functions	368
	369	def test_put_file(self):
	370	t = self.get_transport()
	371
	372	if t.is_readonly():
	373	self.assertRaises(TransportNotPossible,
	374	t.put_file, 'a', StringIO('some text for a\n'))
	375	return
	376
2745.5.2 by Robert Collins * ``bzrlib.transport.Transport.put_file`` now returns the number of bytes	377	result = t.put_file('a', StringIO('some text for a\n'))
	378	# put_file returns the length of the data written
	379	self.assertEqual(16, result)
1955.3.27 by John Arbash Meinel rename non_atomic_put_* to put_*non_atomic, and re-order the functions	380	self.failUnless(t.has('a'))
	381	self.check_transport_contents('some text for a\n', t, 'a')
	382	# Put also replaces contents
2745.5.2 by Robert Collins * ``bzrlib.transport.Transport.put_file`` now returns the number of bytes	383	result = t.put_file('a', StringIO('new\ncontents for\na\n'))
	384	self.assertEqual(19, result)
1955.3.27 by John Arbash Meinel rename non_atomic_put_* to put_*non_atomic, and re-order the functions	385	self.check_transport_contents('new\ncontents for\na\n', t, 'a')
	386	self.assertRaises(NoSuchFile,
	387	t.put_file, 'path/doesnt/exist/c',
	388	StringIO('contents'))
	389
	390	def test_put_file_non_atomic(self):
	391	t = self.get_transport()
	392
	393	if t.is_readonly():
	394	self.assertRaises(TransportNotPossible,
	395	t.put_file_non_atomic, 'a', StringIO('some text for a\n'))
	396	return
	397
	398	self.failIf(t.has('a'))
	399	t.put_file_non_atomic('a', StringIO('some text for a\n'))
	400	self.failUnless(t.has('a'))
	401	self.check_transport_contents('some text for a\n', t, 'a')
	402	# Put also replaces contents
	403	t.put_file_non_atomic('a', StringIO('new\ncontents for\na\n'))
	404	self.check_transport_contents('new\ncontents for\na\n', t, 'a')
	405
	406	# Make sure we can create another file
	407	t.put_file_non_atomic('d', StringIO('contents for\nd\n'))
	408	# And overwrite 'a' with empty contents
	409	t.put_file_non_atomic('a', StringIO(''))
	410	self.check_transport_contents('contents for\nd\n', t, 'd')
	411	self.check_transport_contents('', t, 'a')
	412
	413	self.assertRaises(NoSuchFile, t.put_file_non_atomic, 'no/such/path',
	414	StringIO('contents\n'))
	415	# Now test the create_parent flag
	416	self.assertRaises(NoSuchFile, t.put_file_non_atomic, 'dir/a',
	417	StringIO('contents\n'))
	418	self.failIf(t.has('dir/a'))
	419	t.put_file_non_atomic('dir/a', StringIO('contents for dir/a\n'),
1955.3.20 by John Arbash Meinel Add non_atomic_put_bytes() and tests for it	420	create_parent_dir=True)
1946.1.8 by John Arbash Meinel Update non_atomic_put to have a create_parent_dir flag	421	self.check_transport_contents('contents for dir/a\n', t, 'dir/a')
	422
	423	# But we still get NoSuchFile if we can't make the parent dir
1955.3.27 by John Arbash Meinel rename non_atomic_put_* to put_*non_atomic, and re-order the functions	424	self.assertRaises(NoSuchFile, t.put_file_non_atomic, 'not/there/a',
1955.3.20 by John Arbash Meinel Add non_atomic_put_bytes() and tests for it	425	StringIO('contents\n'),
	426	create_parent_dir=True)
	427
1955.3.7 by John Arbash Meinel Fix the deprecation warnings in the transport tests themselves	428	def test_put_file_permissions(self):
1955.3.18 by John Arbash Meinel [merge] Transport.non_atomic_put()	429
1530.1.15 by Robert Collins Move put mode tests into test_transport_implementation.	430	t = self.get_transport()
	431
	432	if t.is_readonly():
	433	return
1711.4.32 by John Arbash Meinel Skip permission tests on win32 no modebits	434	if not t._can_roundtrip_unix_modebits():
	435	# Can't roundtrip, so no need to run this test
	436	return
1955.3.7 by John Arbash Meinel Fix the deprecation warnings in the transport tests themselves	437	t.put_file('mode644', StringIO('test text\n'), mode=0644)
1530.1.21 by Robert Collins Review feedback fixes.	438	self.assertTransportMode(t, 'mode644', 0644)
1955.3.7 by John Arbash Meinel Fix the deprecation warnings in the transport tests themselves	439	t.put_file('mode666', StringIO('test text\n'), mode=0666)
1530.1.21 by Robert Collins Review feedback fixes.	440	self.assertTransportMode(t, 'mode666', 0666)
1955.3.7 by John Arbash Meinel Fix the deprecation warnings in the transport tests themselves	441	t.put_file('mode600', StringIO('test text\n'), mode=0600)
1530.1.21 by Robert Collins Review feedback fixes.	442	self.assertTransportMode(t, 'mode600', 0600)
1530.1.15 by Robert Collins Move put mode tests into test_transport_implementation.	443	# Yes, you can put a file such that it becomes readonly
1955.3.7 by John Arbash Meinel Fix the deprecation warnings in the transport tests themselves	444	t.put_file('mode400', StringIO('test text\n'), mode=0400)
1530.1.21 by Robert Collins Review feedback fixes.	445	self.assertTransportMode(t, 'mode400', 0400)
1755.3.7 by John Arbash Meinel Clean up and write tests for permissions. Now we use fstat which should be cheap, and lets us check the permissions and the file size	446	# The default permissions should be based on the current umask
	447	umask = osutils.get_umask()
1955.3.7 by John Arbash Meinel Fix the deprecation warnings in the transport tests themselves	448	t.put_file('nomode', StringIO('test text\n'), mode=None)
1755.3.7 by John Arbash Meinel Clean up and write tests for permissions. Now we use fstat which should be cheap, and lets us check the permissions and the file size	449	self.assertTransportMode(t, 'nomode', 0666 & ~umask)
1530.1.16 by Robert Collins Move mkdir and copy_to permissions tests to test_transport_impleentation.	450
1955.3.27 by John Arbash Meinel rename non_atomic_put_* to put_*non_atomic, and re-order the functions	451	def test_put_file_non_atomic_permissions(self):
	452	t = self.get_transport()
	453
	454	if t.is_readonly():
	455	return
	456	if not t._can_roundtrip_unix_modebits():
	457	# Can't roundtrip, so no need to run this test
	458	return
	459	t.put_file_non_atomic('mode644', StringIO('test text\n'), mode=0644)
	460	self.assertTransportMode(t, 'mode644', 0644)
	461	t.put_file_non_atomic('mode666', StringIO('test text\n'), mode=0666)
	462	self.assertTransportMode(t, 'mode666', 0666)
	463	t.put_file_non_atomic('mode600', StringIO('test text\n'), mode=0600)
	464	self.assertTransportMode(t, 'mode600', 0600)
	465	# Yes, you can put_file_non_atomic a file such that it becomes readonly
	466	t.put_file_non_atomic('mode400', StringIO('test text\n'), mode=0400)
	467	self.assertTransportMode(t, 'mode400', 0400)
	468
	469	# The default permissions should be based on the current umask
	470	umask = osutils.get_umask()
	471	t.put_file_non_atomic('nomode', StringIO('test text\n'), mode=None)
	472	self.assertTransportMode(t, 'nomode', 0666 & ~umask)
	473
1946.2.12 by John Arbash Meinel Add ability to pass a directory mode to non_atomic_put	474	# We should also be able to set the mode for a parent directory
	475	# when it is created
	476	sio = StringIO()
	477	t.put_file_non_atomic('dir700/mode664', sio, mode=0664,
	478	dir_mode=0700, create_parent_dir=True)
	479	self.assertTransportMode(t, 'dir700', 0700)
	480	t.put_file_non_atomic('dir770/mode664', sio, mode=0664,
	481	dir_mode=0770, create_parent_dir=True)
	482	self.assertTransportMode(t, 'dir770', 0770)
	483	t.put_file_non_atomic('dir777/mode664', sio, mode=0664,
	484	dir_mode=0777, create_parent_dir=True)
	485	self.assertTransportMode(t, 'dir777', 0777)
	486
2018.5.131 by Andrew Bennetts Be strict about unicode passed to transport.put_{bytes,file} and SmartClient.call_with_body_bytes, fixing part of TestLockableFiles_RemoteLockDir.test_read_write.	487	def test_put_bytes_unicode(self):
	488	# Expect put_bytes to raise AssertionError or UnicodeEncodeError if
	489	# given unicode "bytes". UnicodeEncodeError doesn't really make sense
	490	# (we don't want to encode unicode here at all, callers should be
	491	# strictly passing bytes to put_bytes), but we allow it for backwards
	492	# compatibility. At some point we should use a specific exception.
2414.1.2 by Andrew Bennetts Deal with review comments.	493	# See https://bugs.launchpad.net/bzr/+bug/106898.
2018.5.131 by Andrew Bennetts Be strict about unicode passed to transport.put_{bytes,file} and SmartClient.call_with_body_bytes, fixing part of TestLockableFiles_RemoteLockDir.test_read_write.	494	t = self.get_transport()
	495	if t.is_readonly():
	496	return
	497	unicode_string = u'\u1234'
	498	self.assertRaises(
	499	(AssertionError, UnicodeEncodeError),
	500	t.put_bytes, 'foo', unicode_string)
	501
	502	def test_put_file_unicode(self):
	503	# Like put_bytes, except with a StringIO.StringIO of a unicode string.
	504	# This situation can happen (and has) if code is careless about the type
	505	# of "string" they initialise/write to a StringIO with. We cannot use
	506	# cStringIO, because it never returns unicode from read.
	507	# Like put_bytes, UnicodeEncodeError isn't quite the right exception to
	508	# raise, but we raise it for hysterical raisins.
	509	t = self.get_transport()
	510	if t.is_readonly():
	511	return
	512	unicode_file = pyStringIO(u'\u1234')
	513	self.assertRaises(UnicodeEncodeError, t.put_file, 'foo', unicode_file)
	514
1530.1.3 by Robert Collins transport implementations now tested consistently.	515	def test_mkdir(self):
	516	t = self.get_transport()
	517
	518	if t.is_readonly():
	519	# cannot mkdir on readonly transports. We're not testing for
	520	# cache coherency because cache behaviour is not currently
	521	# defined for the transport interface.
	522	self.assertRaises(TransportNotPossible, t.mkdir, '.')
	523	self.assertRaises(TransportNotPossible, t.mkdir, 'new_dir')
	524	self.assertRaises(TransportNotPossible, t.mkdir_multi, ['new_dir'])
	525	self.assertRaises(TransportNotPossible, t.mkdir, 'path/doesnt/exist')
	526	return
	527	# Test mkdir
	528	t.mkdir('dir_a')
	529	self.assertEqual(t.has('dir_a'), True)
	530	self.assertEqual(t.has('dir_b'), False)
	531
	532	t.mkdir('dir_b')
	533	self.assertEqual(t.has('dir_b'), True)
	534
	535	t.mkdir_multi(['dir_c', 'dir_d'])
	536
	537	t.mkdir_multi(iter(['dir_e', 'dir_f']))
	538	self.assertEqual(list(t.has_multi(
	539	['dir_a', 'dir_b', 'dir_c', 'dir_q',
	540	'dir_d', 'dir_e', 'dir_f', 'dir_b'])),
	541	[True, True, True, False,
	542	True, True, True, True])
	543
	544	# we were testing that a local mkdir followed by a transport
	545	# mkdir failed thusly, but given that we * in one process * do not
	546	# concurrently fiddle with disk dirs and then use transport to do
	547	# things, the win here seems marginal compared to the constraint on
	548	# the interface. RBC 20051227
	549	t.mkdir('dir_g')
	550	self.assertRaises(FileExists, t.mkdir, 'dir_g')
	551
	552	# Test get/put in sub-directories
1955.3.11 by John Arbash Meinel Clean up the rest of the api calls to deprecated functions in the test suite, and make sure Transport._pump is only accepting files, not strings	553	t.put_bytes('dir_a/a', 'contents of dir_a/a')
	554	t.put_file('dir_b/b', StringIO('contents of dir_b/b'))
1530.1.3 by Robert Collins transport implementations now tested consistently.	555	self.check_transport_contents('contents of dir_a/a', t, 'dir_a/a')
	556	self.check_transport_contents('contents of dir_b/b', t, 'dir_b/b')
	557
1530.1.4 by Robert Collins integrate Memory tests into transport interface tests.	558	# mkdir of a dir with an absent parent
	559	self.assertRaises(NoSuchFile, t.mkdir, 'missing/dir')
	560
1530.1.16 by Robert Collins Move mkdir and copy_to permissions tests to test_transport_impleentation.	561	def test_mkdir_permissions(self):
	562	t = self.get_transport()
	563	if t.is_readonly():
	564	return
1608.2.7 by Martin Pool Rename supports_unix_modebits to _can_roundtrip_unix_modebits for clarity	565	if not t._can_roundtrip_unix_modebits():
1608.2.5 by Martin Pool Add Transport.supports_unix_modebits, so tests can	566	# no sense testing on this transport
	567	return
1530.1.16 by Robert Collins Move mkdir and copy_to permissions tests to test_transport_impleentation.	568	# Test mkdir with a mode
	569	t.mkdir('dmode755', mode=0755)
1530.1.21 by Robert Collins Review feedback fixes.	570	self.assertTransportMode(t, 'dmode755', 0755)
1530.1.16 by Robert Collins Move mkdir and copy_to permissions tests to test_transport_impleentation.	571	t.mkdir('dmode555', mode=0555)
1530.1.21 by Robert Collins Review feedback fixes.	572	self.assertTransportMode(t, 'dmode555', 0555)
1530.1.16 by Robert Collins Move mkdir and copy_to permissions tests to test_transport_impleentation.	573	t.mkdir('dmode777', mode=0777)
1530.1.21 by Robert Collins Review feedback fixes.	574	self.assertTransportMode(t, 'dmode777', 0777)
1530.1.16 by Robert Collins Move mkdir and copy_to permissions tests to test_transport_impleentation.	575	t.mkdir('dmode700', mode=0700)
1530.1.21 by Robert Collins Review feedback fixes.	576	self.assertTransportMode(t, 'dmode700', 0700)
1530.1.16 by Robert Collins Move mkdir and copy_to permissions tests to test_transport_impleentation.	577	t.mkdir_multi(['mdmode755'], mode=0755)
1530.1.21 by Robert Collins Review feedback fixes.	578	self.assertTransportMode(t, 'mdmode755', 0755)
1530.1.16 by Robert Collins Move mkdir and copy_to permissions tests to test_transport_impleentation.	579
1755.3.7 by John Arbash Meinel Clean up and write tests for permissions. Now we use fstat which should be cheap, and lets us check the permissions and the file size	580	# Default mode should be based on umask
	581	umask = osutils.get_umask()
	582	t.mkdir('dnomode', mode=None)
	583	self.assertTransportMode(t, 'dnomode', 0777 & ~umask)
	584
2671.3.2 by Robert Collins Start open_file_stream logic.	585	def test_opening_a_file_stream_creates_file(self):
	586	t = self.get_transport()
	587	if t.is_readonly():
	588	return
2671.3.9 by Robert Collins Review feedback and fix VFat emulated transports to not claim to have unix permissions.	589	handle = t.open_write_stream('foo')
2671.3.2 by Robert Collins Start open_file_stream logic.	590	try:
	591	self.assertEqual('', t.get_bytes('foo'))
	592	finally:
2671.3.6 by Robert Collins Review feedback.	593	handle.close()
2671.3.2 by Robert Collins Start open_file_stream logic.	594
2671.3.3 by Robert Collins Add mode parameter to Transport.open_file_stream.	595	def test_opening_a_file_stream_can_set_mode(self):
	596	t = self.get_transport()
	597	if t.is_readonly():
	598	return
	599	if not t._can_roundtrip_unix_modebits():
	600	# Can't roundtrip, so no need to run this test
	601	return
	602	def check_mode(name, mode, expected):
2671.3.9 by Robert Collins Review feedback and fix VFat emulated transports to not claim to have unix permissions.	603	handle = t.open_write_stream(name, mode=mode)
2671.3.6 by Robert Collins Review feedback.	604	handle.close()
2671.3.3 by Robert Collins Add mode parameter to Transport.open_file_stream.	605	self.assertTransportMode(t, name, expected)
	606	check_mode('mode644', 0644, 0644)
	607	check_mode('mode666', 0666, 0666)
	608	check_mode('mode600', 0600, 0600)
	609	# The default permissions should be based on the current umask
	610	check_mode('nomode', None, 0666 & ~osutils.get_umask())
	611
1530.1.3 by Robert Collins transport implementations now tested consistently.	612	def test_copy_to(self):
1534.4.21 by Robert Collins Extend the copy_to tests to smoke test server-to-same-server copies to catch optimised code paths, and fix sftps optimised code path by removing dead code.	613	# FIXME: test: same server to same server (partly done)
	614	# same protocol two servers
	615	# and different protocols (done for now except for MemoryTransport.
	616	# - RBC 20060122
	617
	618	def simple_copy_files(transport_from, transport_to):
	619	files = ['a', 'b', 'c', 'd']
	620	self.build_tree(files, transport=transport_from)
1563.2.3 by Robert Collins Change the return signature of transport.append and append_multi to return the length of the pre-append content.	621	self.assertEqual(4, transport_from.copy_to(files, transport_to))
1534.4.21 by Robert Collins Extend the copy_to tests to smoke test server-to-same-server copies to catch optimised code paths, and fix sftps optimised code path by removing dead code.	622	for f in files:
	623	self.check_transport_contents(transport_to.get(f).read(),
	624	transport_from, f)
	625
1530.1.3 by Robert Collins transport implementations now tested consistently.	626	t = self.get_transport()
1685.1.42 by John Arbash Meinel A couple more fixes to make sure memory:/// works correctly.	627	temp_transport = MemoryTransport('memory:///')
1534.4.21 by Robert Collins Extend the copy_to tests to smoke test server-to-same-server copies to catch optimised code paths, and fix sftps optimised code path by removing dead code.	628	simple_copy_files(t, temp_transport)
	629	if not t.is_readonly():
	630	t.mkdir('copy_to_simple')
	631	t2 = t.clone('copy_to_simple')
	632	simple_copy_files(t, t2)
1530.1.3 by Robert Collins transport implementations now tested consistently.	633
	634
	635	# Test that copying into a missing directory raises
	636	# NoSuchFile
	637	if t.is_readonly():
1530.1.21 by Robert Collins Review feedback fixes.	638	self.build_tree(['e/', 'e/f'])
1530.1.3 by Robert Collins transport implementations now tested consistently.	639	else:
	640	t.mkdir('e')
1955.3.11 by John Arbash Meinel Clean up the rest of the api calls to deprecated functions in the test suite, and make sure Transport._pump is only accepting files, not strings	641	t.put_bytes('e/f', 'contents of e')
1530.1.3 by Robert Collins transport implementations now tested consistently.	642	self.assertRaises(NoSuchFile, t.copy_to, ['e/f'], temp_transport)
	643	temp_transport.mkdir('e')
	644	t.copy_to(['e/f'], temp_transport)
	645
	646	del temp_transport
1685.1.42 by John Arbash Meinel A couple more fixes to make sure memory:/// works correctly.	647	temp_transport = MemoryTransport('memory:///')
1530.1.3 by Robert Collins transport implementations now tested consistently.	648
	649	files = ['a', 'b', 'c', 'd']
	650	t.copy_to(iter(files), temp_transport)
	651	for f in files:
	652	self.check_transport_contents(temp_transport.get(f).read(),
	653	t, f)
	654	del temp_transport
	655
1530.1.16 by Robert Collins Move mkdir and copy_to permissions tests to test_transport_impleentation.	656	for mode in (0666, 0644, 0600, 0400):
1685.1.42 by John Arbash Meinel A couple more fixes to make sure memory:/// works correctly.	657	temp_transport = MemoryTransport("memory:///")
1530.1.16 by Robert Collins Move mkdir and copy_to permissions tests to test_transport_impleentation.	658	t.copy_to(files, temp_transport, mode=mode)
	659	for f in files:
1530.1.21 by Robert Collins Review feedback fixes.	660	self.assertTransportMode(temp_transport, f, mode)
1530.1.16 by Robert Collins Move mkdir and copy_to permissions tests to test_transport_impleentation.	661
1955.3.15 by John Arbash Meinel Deprecate 'Transport.append' in favor of Transport.append_file or Transport.append_bytes	662	def test_append_file(self):
	663	t = self.get_transport()
	664
	665	if t.is_readonly():
1530.1.3 by Robert Collins transport implementations now tested consistently.	666	self.assertRaises(TransportNotPossible,
1955.3.15 by John Arbash Meinel Deprecate 'Transport.append' in favor of Transport.append_file or Transport.append_bytes	667	t.append_file, 'a', 'add\nsome\nmore\ncontents\n')
1955.3.2 by John Arbash Meinel Implement and test 'Transport.append_bytes', cleanup the tests of plain append	668	return
1955.3.10 by John Arbash Meinel clean up append, append_bytes, and append_multi tests	669	t.put_bytes('a', 'diff\ncontents for\na\n')
	670	t.put_bytes('b', 'contents\nfor b\n')
1955.3.2 by John Arbash Meinel Implement and test 'Transport.append_bytes', cleanup the tests of plain append	671
	672	self.assertEqual(20,
1955.3.15 by John Arbash Meinel Deprecate 'Transport.append' in favor of Transport.append_file or Transport.append_bytes	673	t.append_file('a', StringIO('add\nsome\nmore\ncontents\n')))
1530.1.3 by Robert Collins transport implementations now tested consistently.	674
	675	self.check_transport_contents(
	676	'diff\ncontents for\na\nadd\nsome\nmore\ncontents\n',
	677	t, 'a')
	678
1955.3.10 by John Arbash Meinel clean up append, append_bytes, and append_multi tests	679	# a file with no parent should fail..
	680	self.assertRaises(NoSuchFile,
1955.3.15 by John Arbash Meinel Deprecate 'Transport.append' in favor of Transport.append_file or Transport.append_bytes	681	t.append_file, 'missing/path', StringIO('content'))
1955.3.10 by John Arbash Meinel clean up append, append_bytes, and append_multi tests	682
	683	# And we can create new files, too
	684	self.assertEqual(0,
1955.3.15 by John Arbash Meinel Deprecate 'Transport.append' in favor of Transport.append_file or Transport.append_bytes	685	t.append_file('c', StringIO('some text\nfor a missing file\n')))
1955.3.10 by John Arbash Meinel clean up append, append_bytes, and append_multi tests	686	self.check_transport_contents('some text\nfor a missing file\n',
	687	t, 'c')
	688
	689	def test_append_bytes(self):
	690	t = self.get_transport()
	691
	692	if t.is_readonly():
	693	self.assertRaises(TransportNotPossible,
	694	t.append_bytes, 'a', 'add\nsome\nmore\ncontents\n')
	695	return
	696
	697	self.assertEqual(0, t.append_bytes('a', 'diff\ncontents for\na\n'))
	698	self.assertEqual(0, t.append_bytes('b', 'contents\nfor b\n'))
	699
	700	self.assertEqual(20,
	701	t.append_bytes('a', 'add\nsome\nmore\ncontents\n'))
	702
	703	self.check_transport_contents(
	704	'diff\ncontents for\na\nadd\nsome\nmore\ncontents\n',
	705	t, 'a')
	706
	707	# a file with no parent should fail..
	708	self.assertRaises(NoSuchFile,
	709	t.append_bytes, 'missing/path', 'content')
	710
	711	def test_append_multi(self):
	712	t = self.get_transport()
	713
	714	if t.is_readonly():
	715	return
	716	t.put_bytes('a', 'diff\ncontents for\na\n'
	717	'add\nsome\nmore\ncontents\n')
	718	t.put_bytes('b', 'contents\nfor b\n')
	719
1955.3.2 by John Arbash Meinel Implement and test 'Transport.append_bytes', cleanup the tests of plain append	720	self.assertEqual((43, 15),
	721	t.append_multi([('a', StringIO('and\nthen\nsome\nmore\n')),
	722	('b', StringIO('some\nmore\nfor\nb\n'))]))
	723
1530.1.3 by Robert Collins transport implementations now tested consistently.	724	self.check_transport_contents(
	725	'diff\ncontents for\na\n'
	726	'add\nsome\nmore\ncontents\n'
	727	'and\nthen\nsome\nmore\n',
	728	t, 'a')
	729	self.check_transport_contents(
	730	'contents\nfor b\n'
	731	'some\nmore\nfor\nb\n',
	732	t, 'b')
	733
1955.3.2 by John Arbash Meinel Implement and test 'Transport.append_bytes', cleanup the tests of plain append	734	self.assertEqual((62, 31),
	735	t.append_multi(iter([('a', StringIO('a little bit more\n')),
	736	('b', StringIO('from an iterator\n'))])))
1530.1.3 by Robert Collins transport implementations now tested consistently.	737	self.check_transport_contents(
	738	'diff\ncontents for\na\n'
	739	'add\nsome\nmore\ncontents\n'
	740	'and\nthen\nsome\nmore\n'
	741	'a little bit more\n',
	742	t, 'a')
	743	self.check_transport_contents(
	744	'contents\nfor b\n'
	745	'some\nmore\nfor\nb\n'
	746	'from an iterator\n',
	747	t, 'b')
	748
1955.3.2 by John Arbash Meinel Implement and test 'Transport.append_bytes', cleanup the tests of plain append	749	self.assertEqual((80, 0),
	750	t.append_multi([('a', StringIO('some text in a\n')),
	751	('d', StringIO('missing file r\n'))]))
	752
1530.1.3 by Robert Collins transport implementations now tested consistently.	753	self.check_transport_contents(
	754	'diff\ncontents for\na\n'
	755	'add\nsome\nmore\ncontents\n'
	756	'and\nthen\nsome\nmore\n'
	757	'a little bit more\n'
	758	'some text in a\n',
	759	t, 'a')
	760	self.check_transport_contents('missing file r\n', t, 'd')
	761
1955.3.15 by John Arbash Meinel Deprecate 'Transport.append' in favor of Transport.append_file or Transport.append_bytes	762	def test_append_file_mode(self):
1955.3.10 by John Arbash Meinel clean up append, append_bytes, and append_multi tests	763	"""Check that append accepts a mode parameter"""
1666.1.6 by Robert Collins Make knit the default format.	764	# check append accepts a mode
	765	t = self.get_transport()
	766	if t.is_readonly():
1955.3.10 by John Arbash Meinel clean up append, append_bytes, and append_multi tests	767	self.assertRaises(TransportNotPossible,
1955.3.15 by John Arbash Meinel Deprecate 'Transport.append' in favor of Transport.append_file or Transport.append_bytes	768	t.append_file, 'f', StringIO('f'), mode=None)
1666.1.6 by Robert Collins Make knit the default format.	769	return
1955.3.15 by John Arbash Meinel Deprecate 'Transport.append' in favor of Transport.append_file or Transport.append_bytes	770	t.append_file('f', StringIO('f'), mode=None)
1666.1.6 by Robert Collins Make knit the default format.	771
1955.3.2 by John Arbash Meinel Implement and test 'Transport.append_bytes', cleanup the tests of plain append	772	def test_append_bytes_mode(self):
	773	# check append_bytes accepts a mode
	774	t = self.get_transport()
	775	if t.is_readonly():
1955.3.10 by John Arbash Meinel clean up append, append_bytes, and append_multi tests	776	self.assertRaises(TransportNotPossible,
	777	t.append_bytes, 'f', 'f', mode=None)
1955.3.2 by John Arbash Meinel Implement and test 'Transport.append_bytes', cleanup the tests of plain append	778	return
1955.3.10 by John Arbash Meinel clean up append, append_bytes, and append_multi tests	779	t.append_bytes('f', 'f', mode=None)
1955.3.2 by John Arbash Meinel Implement and test 'Transport.append_bytes', cleanup the tests of plain append	780
1530.1.3 by Robert Collins transport implementations now tested consistently.	781	def test_delete(self):
	782	# TODO: Test Transport.delete
	783	t = self.get_transport()
	784
	785	# Not much to do with a readonly transport
	786	if t.is_readonly():
1534.4.9 by Robert Collins Add a readonly decorator for transports.	787	self.assertRaises(TransportNotPossible, t.delete, 'missing')
1530.1.3 by Robert Collins transport implementations now tested consistently.	788	return
	789
1955.3.11 by John Arbash Meinel Clean up the rest of the api calls to deprecated functions in the test suite, and make sure Transport._pump is only accepting files, not strings	790	t.put_bytes('a', 'a little bit of text\n')
1530.1.3 by Robert Collins transport implementations now tested consistently.	791	self.failUnless(t.has('a'))
	792	t.delete('a')
	793	self.failIf(t.has('a'))
	794
	795	self.assertRaises(NoSuchFile, t.delete, 'a')
	796
1955.3.11 by John Arbash Meinel Clean up the rest of the api calls to deprecated functions in the test suite, and make sure Transport._pump is only accepting files, not strings	797	t.put_bytes('a', 'a text\n')
	798	t.put_bytes('b', 'b text\n')
	799	t.put_bytes('c', 'c text\n')
1530.1.3 by Robert Collins transport implementations now tested consistently.	800	self.assertEqual([True, True, True],
	801	list(t.has_multi(['a', 'b', 'c'])))
	802	t.delete_multi(['a', 'c'])
	803	self.assertEqual([False, True, False],
	804	list(t.has_multi(['a', 'b', 'c'])))
	805	self.failIf(t.has('a'))
	806	self.failUnless(t.has('b'))
	807	self.failIf(t.has('c'))
	808
	809	self.assertRaises(NoSuchFile,
	810	t.delete_multi, ['a', 'b', 'c'])
	811
	812	self.assertRaises(NoSuchFile,
	813	t.delete_multi, iter(['a', 'b', 'c']))
	814
1955.3.11 by John Arbash Meinel Clean up the rest of the api calls to deprecated functions in the test suite, and make sure Transport._pump is only accepting files, not strings	815	t.put_bytes('a', 'another a text\n')
	816	t.put_bytes('c', 'another c text\n')
1530.1.3 by Robert Collins transport implementations now tested consistently.	817	t.delete_multi(iter(['a', 'b', 'c']))
	818
	819	# We should have deleted everything
	820	# SftpServer creates control files in the
	821	# working directory, so we can just do a
	822	# plain "listdir".
	823	# self.assertEqual([], os.listdir('.'))
	824
2671.3.1 by Robert Collins * New method ``bzrlib.transport.Transport.get_recommended_page_size``.	825	def test_recommended_page_size(self):
	826	"""Transports recommend a page size for partial access to files."""
	827	t = self.get_transport()
	828	self.assertIsInstance(t.recommended_page_size(), int)
	829
1534.4.15 by Robert Collins Remove shutil dependency in upgrade - create a delete_tree method for transports.	830	def test_rmdir(self):
	831	t = self.get_transport()
	832	# Not much to do with a readonly transport
	833	if t.is_readonly():
	834	self.assertRaises(TransportNotPossible, t.rmdir, 'missing')
	835	return
	836	t.mkdir('adir')
	837	t.mkdir('adir/bdir')
	838	t.rmdir('adir/bdir')
1948.3.12 by Vincent LADEUIL Fix Aaron's third review remarks.	839	# ftp may not be able to raise NoSuchFile for lack of
	840	# details when failing
	841	self.assertRaises((NoSuchFile, PathError), t.rmdir, 'adir/bdir')
1534.4.15 by Robert Collins Remove shutil dependency in upgrade - create a delete_tree method for transports.	842	t.rmdir('adir')
1948.3.12 by Vincent LADEUIL Fix Aaron's third review remarks.	843	self.assertRaises((NoSuchFile, PathError), t.rmdir, 'adir')
1534.4.15 by Robert Collins Remove shutil dependency in upgrade - create a delete_tree method for transports.	844
1553.5.10 by Martin Pool New DirectoryNotEmpty exception, and raise this from local and memory	845	def test_rmdir_not_empty(self):
	846	"""Deleting a non-empty directory raises an exception
	847
	848	sftp (and possibly others) don't give us a specific "directory not
	849	empty" exception -- we can just see that the operation failed.
	850	"""
	851	t = self.get_transport()
	852	if t.is_readonly():
	853	return
	854	t.mkdir('adir')
	855	t.mkdir('adir/bdir')
	856	self.assertRaises(PathError, t.rmdir, 'adir')
	857
2338.5.1 by Andrew Bennetts Fix bug in MemoryTransport.rmdir.	858	def test_rmdir_empty_but_similar_prefix(self):
	859	"""rmdir does not get confused by sibling paths.
	860
	861	A naive implementation of MemoryTransport would refuse to rmdir
	862	".bzr/branch" if there is a ".bzr/branch-format" directory, because it
	863	uses "path.startswith(dir)" on all file paths to determine if directory
	864	is empty.
	865	"""
	866	t = self.get_transport()
	867	if t.is_readonly():
	868	return
	869	t.mkdir('foo')
	870	t.put_bytes('foo-bar', '')
	871	t.mkdir('foo-baz')
	872	t.rmdir('foo')
	873	self.assertRaises((NoSuchFile, PathError), t.rmdir, 'foo')
	874	self.failUnless(t.has('foo-bar'))
	875
1553.5.13 by Martin Pool New Transport.rename that mustn't overwrite	876	def test_rename_dir_succeeds(self):
	877	t = self.get_transport()
	878	if t.is_readonly():
	879	raise TestSkipped("transport is readonly")
	880	t.mkdir('adir')
	881	t.mkdir('adir/asubdir')
	882	t.rename('adir', 'bdir')
	883	self.assertTrue(t.has('bdir/asubdir'))
	884	self.assertFalse(t.has('adir'))
	885
	886	def test_rename_dir_nonempty(self):
	887	"""Attempting to replace a nonemtpy directory should fail"""
	888	t = self.get_transport()
	889	if t.is_readonly():
	890	raise TestSkipped("transport is readonly")
	891	t.mkdir('adir')
	892	t.mkdir('adir/asubdir')
	893	t.mkdir('bdir')
	894	t.mkdir('bdir/bsubdir')
1910.7.17 by Andrew Bennetts Various cosmetic changes.	895	# any kind of PathError would be OK, though we normally expect
1910.7.17 by Andrew Bennetts Various cosmetic changes.	896	# DirectoryNotEmpty
1553.5.13 by Martin Pool New Transport.rename that mustn't overwrite	897	self.assertRaises(PathError, t.rename, 'bdir', 'adir')
	898	# nothing was changed so it should still be as before
	899	self.assertTrue(t.has('bdir/bsubdir'))
	900	self.assertFalse(t.has('adir/bdir'))
	901	self.assertFalse(t.has('adir/bsubdir'))
	902
1534.4.15 by Robert Collins Remove shutil dependency in upgrade - create a delete_tree method for transports.	903	def test_delete_tree(self):
	904	t = self.get_transport()
	905
	906	# Not much to do with a readonly transport
	907	if t.is_readonly():
	908	self.assertRaises(TransportNotPossible, t.delete_tree, 'missing')
	909	return
	910
	911	# and does it like listing ?
	912	t.mkdir('adir')
	913	try:
	914	t.delete_tree('adir')
	915	except TransportNotPossible:
	916	# ok, this transport does not support delete_tree
	917	return
	918
	919	# did it delete that trivial case?
	920	self.assertRaises(NoSuchFile, t.stat, 'adir')
	921
	922	self.build_tree(['adir/',
	923	'adir/file',
	924	'adir/subdir/',
	925	'adir/subdir/file',
	926	'adir/subdir2/',
	927	'adir/subdir2/file',
	928	], transport=t)
	929
	930	t.delete_tree('adir')
	931	# adir should be gone now.
	932	self.assertRaises(NoSuchFile, t.stat, 'adir')
	933
1530.1.3 by Robert Collins transport implementations now tested consistently.	934	def test_move(self):
	935	t = self.get_transport()
	936
	937	if t.is_readonly():
	938	return
	939
	940	# TODO: I would like to use os.listdir() to
	941	# make sure there are no extra files, but SftpServer
	942	# creates control files in the working directory
	943	# perhaps all of this could be done in a subdirectory
	944
1955.3.11 by John Arbash Meinel Clean up the rest of the api calls to deprecated functions in the test suite, and make sure Transport._pump is only accepting files, not strings	945	t.put_bytes('a', 'a first file\n')
1530.1.3 by Robert Collins transport implementations now tested consistently.	946	self.assertEquals([True, False], list(t.has_multi(['a', 'b'])))
	947
	948	t.move('a', 'b')
	949	self.failUnless(t.has('b'))
	950	self.failIf(t.has('a'))
	951
	952	self.check_transport_contents('a first file\n', t, 'b')
	953	self.assertEquals([False, True], list(t.has_multi(['a', 'b'])))
	954
	955	# Overwrite a file
1955.3.11 by John Arbash Meinel Clean up the rest of the api calls to deprecated functions in the test suite, and make sure Transport._pump is only accepting files, not strings	956	t.put_bytes('c', 'c this file\n')
1530.1.3 by Robert Collins transport implementations now tested consistently.	957	t.move('c', 'b')
	958	self.failIf(t.has('c'))
	959	self.check_transport_contents('c this file\n', t, 'b')
	960
	961	# TODO: Try to write a test for atomicity
	962	# TODO: Test moving into a non-existant subdirectory
	963	# TODO: Test Transport.move_multi
	964
	965	def test_copy(self):
	966	t = self.get_transport()
	967
	968	if t.is_readonly():
	969	return
	970
1955.3.11 by John Arbash Meinel Clean up the rest of the api calls to deprecated functions in the test suite, and make sure Transport._pump is only accepting files, not strings	971	t.put_bytes('a', 'a file\n')
1530.1.3 by Robert Collins transport implementations now tested consistently.	972	t.copy('a', 'b')
	973	self.check_transport_contents('a file\n', t, 'b')
	974
	975	self.assertRaises(NoSuchFile, t.copy, 'c', 'd')
	976	os.mkdir('c')
	977	# What should the assert be if you try to copy a
	978	# file over a directory?
	979	#self.assertRaises(Something, t.copy, 'a', 'c')
1955.3.11 by John Arbash Meinel Clean up the rest of the api calls to deprecated functions in the test suite, and make sure Transport._pump is only accepting files, not strings	980	t.put_bytes('d', 'text in d\n')
1530.1.3 by Robert Collins transport implementations now tested consistently.	981	t.copy('d', 'b')
	982	self.check_transport_contents('text in d\n', t, 'b')
	983
	984	# TODO: test copy_multi
	985
	986	def test_connection_error(self):
1910.7.17 by Andrew Bennetts Various cosmetic changes.	987	"""ConnectionError is raised when connection is impossible.
	988
	989	The error may be raised from either the constructor or the first
	990	operation on the transport.
	991	"""
1530.1.9 by Robert Collins Test bogus urls with http in the new infrastructure.	992	try:
	993	url = self._server.get_bogus_url()
	994	except NotImplementedError:
	995	raise TestSkipped("Transport %s has no bogus URL support." %
	996	self._server.__class__)
2485.8.38 by Vincent Ladeuil Finish sftp refactoring. Test suite passing.	997	t = get_transport(url)
	998	self.assertRaises((ConnectionError, NoSuchFile), t.get, '.bzr/branch')
1530.1.3 by Robert Collins transport implementations now tested consistently.	999
	1000	def test_stat(self):
	1001	# TODO: Test stat, just try once, and if it throws, stop testing
	1002	from stat import S_ISDIR, S_ISREG
	1003
	1004	t = self.get_transport()
	1005
	1006	try:
	1007	st = t.stat('.')
	1008	except TransportNotPossible, e:
	1009	# This transport cannot stat
	1010	return
	1011
	1012	paths = ['a', 'b/', 'b/c', 'b/d/', 'b/d/e']
	1013	sizes = [14, 0, 16, 0, 18]
1551.2.39 by abentley Fix line endings in tests	1014	self.build_tree(paths, transport=t, line_endings='binary')
1530.1.3 by Robert Collins transport implementations now tested consistently.	1015
	1016	for path, size in zip(paths, sizes):
	1017	st = t.stat(path)
	1018	if path.endswith('/'):
	1019	self.failUnless(S_ISDIR(st.st_mode))
	1020	# directory sizes are meaningless
	1021	else:
	1022	self.failUnless(S_ISREG(st.st_mode))
	1023	self.assertEqual(size, st.st_size)
	1024
	1025	remote_stats = list(t.stat_multi(paths))
	1026	remote_iter_stats = list(t.stat_multi(iter(paths)))
	1027
	1028	self.assertRaises(NoSuchFile, t.stat, 'q')
	1029	self.assertRaises(NoSuchFile, t.stat, 'b/a')
	1030
	1031	self.assertListRaises(NoSuchFile, t.stat_multi, ['a', 'c', 'd'])
	1032	self.assertListRaises(NoSuchFile, t.stat_multi, iter(['a', 'c', 'd']))
1534.4.15 by Robert Collins Remove shutil dependency in upgrade - create a delete_tree method for transports.	1033	self.build_tree(['subdir/', 'subdir/file'], transport=t)
	1034	subdir = t.clone('subdir')
	1035	subdir.stat('./file')
1534.4.26 by Robert Collins Move working tree initialisation out from Branch.initialize, deprecated Branch.initialize to Branch.create.	1036	subdir.stat('.')
1530.1.3 by Robert Collins transport implementations now tested consistently.	1037
	1038	def test_list_dir(self):
	1039	# TODO: Test list_dir, just try once, and if it throws, stop testing
	1040	t = self.get_transport()
	1041
	1042	if not t.listable():
	1043	self.assertRaises(TransportNotPossible, t.list_dir, '.')
	1044	return
	1045
	1046	def sorted_list(d):
	1047	l = list(t.list_dir(d))
	1048	l.sort()
	1049	return l
	1050
1910.7.1 by Andrew Bennetts Make sure list_dir always returns url-escaped names.	1051	self.assertEqual([], sorted_list('.'))
1534.4.15 by Robert Collins Remove shutil dependency in upgrade - create a delete_tree method for transports.	1052	# c2 is precisely one letter longer than c here to test that
	1053	# suffixing is not confused.
1959.2.1 by John Arbash Meinel David Allouche: Make transports return escaped paths	1054	# a%25b checks that quoting is done consistently across transports
	1055	tree_names = ['a', 'a%25b', 'b', 'c/', 'c/d', 'c/e', 'c2/']
2120.3.1 by John Arbash Meinel Fix MemoryTransport.list_dir() implementation, and update tests	1056
1534.4.9 by Robert Collins Add a readonly decorator for transports.	1057	if not t.is_readonly():
1959.2.1 by John Arbash Meinel David Allouche: Make transports return escaped paths	1058	self.build_tree(tree_names, transport=t)
1534.4.9 by Robert Collins Add a readonly decorator for transports.	1059	else:
2120.3.1 by John Arbash Meinel Fix MemoryTransport.list_dir() implementation, and update tests	1060	self.build_tree(tree_names)
1530.1.3 by Robert Collins transport implementations now tested consistently.	1061
1959.2.1 by John Arbash Meinel David Allouche: Make transports return escaped paths	1062	self.assertEqual(
1959.2.3 by John Arbash Meinel Remove some unicode string notations	1063	['a', 'a%2525b', 'b', 'c', 'c2'], sorted_list('.'))
1910.7.1 by Andrew Bennetts Make sure list_dir always returns url-escaped names.	1064	self.assertEqual(['d', 'e'], sorted_list('c'))
1530.1.3 by Robert Collins transport implementations now tested consistently.	1065
1534.4.9 by Robert Collins Add a readonly decorator for transports.	1066	if not t.is_readonly():
	1067	t.delete('c/d')
	1068	t.delete('b')
	1069	else:
2120.3.1 by John Arbash Meinel Fix MemoryTransport.list_dir() implementation, and update tests	1070	os.unlink('c/d')
	1071	os.unlink('b')
1534.4.9 by Robert Collins Add a readonly decorator for transports.	1072
1959.2.3 by John Arbash Meinel Remove some unicode string notations	1073	self.assertEqual(['a', 'a%2525b', 'c', 'c2'], sorted_list('.'))
1910.7.1 by Andrew Bennetts Make sure list_dir always returns url-escaped names.	1074	self.assertEqual(['e'], sorted_list('c'))
1530.1.3 by Robert Collins transport implementations now tested consistently.	1075
1662.1.12 by Martin Pool Translate unknown sftp errors to PathError, no NoSuchFile	1076	self.assertListRaises(PathError, t.list_dir, 'q')
	1077	self.assertListRaises(PathError, t.list_dir, 'c/f')
	1078	self.assertListRaises(PathError, t.list_dir, 'a')
1530.1.3 by Robert Collins transport implementations now tested consistently.	1079
1910.7.1 by Andrew Bennetts Make sure list_dir always returns url-escaped names.	1080	def test_list_dir_result_is_url_escaped(self):
	1081	t = self.get_transport()
	1082	if not t.listable():
	1083	raise TestSkipped("transport not listable")
	1084
	1085	if not t.is_readonly():
	1086	self.build_tree(['a/', 'a/%'], transport=t)
	1087	else:
	1088	self.build_tree(['a/', 'a/%'])
	1089
1910.7.2 by Andrew Bennetts Also assert that list_dir returns plain str objects.	1090	names = list(t.list_dir('a'))
	1091	self.assertEqual(['%25'], names)
	1092	self.assertIsInstance(names[0], str)
1910.7.1 by Andrew Bennetts Make sure list_dir always returns url-escaped names.	1093
2485.8.25 by Vincent Ladeuil Separate abspath from _remote_path, the intents are different.	1094	def test_clone_preserve_info(self):
	1095	t1 = self.get_transport()
	1096	if not isinstance(t1, ConnectedTransport):
	1097	raise TestSkipped("not a connected transport")
	1098
	1099	t2 = t1.clone('subdir')
	1100	self.assertEquals(t1._scheme, t2._scheme)
	1101	self.assertEquals(t1._user, t2._user)
	1102	self.assertEquals(t1._password, t2._password)
	1103	self.assertEquals(t1._host, t2._host)
	1104	self.assertEquals(t1._port, t2._port)
	1105
2485.8.39 by Vincent Ladeuil Add tests around connection reuse.	1106	def test__reuse_for(self):
	1107	t = self.get_transport()
	1108	if not isinstance(t, ConnectedTransport):
	1109	raise TestSkipped("not a connected transport")
	1110
	1111	def new_url(scheme=None, user=None, password=None,
	1112	host=None, port=None, path=None):
2900.2.16 by Vincent Ladeuil Make hhtp proxy aware of AuthenticationConfig (for password).	1113	"""Build a new url from t.base changing only parts of it.
2485.8.39 by Vincent Ladeuil Add tests around connection reuse.	1114
	1115	Only the parameters different from None will be changed.
	1116	"""
2485.8.53 by Vincent Ladeuil Apply test_connection_sharing to all transports to make smart	1117	if scheme is None: scheme = t._scheme
	1118	if user is None: user = t._user
2485.8.39 by Vincent Ladeuil Add tests around connection reuse.	1119	if password is None: password = t._password
2485.8.53 by Vincent Ladeuil Apply test_connection_sharing to all transports to make smart	1120	if user is None: user = t._user
	1121	if host is None: host = t._host
	1122	if port is None: port = t._port
	1123	if path is None: path = t._path
2485.8.39 by Vincent Ladeuil Add tests around connection reuse.	1124	return t._unsplit_url(scheme, user, password, host, port, path)
	1125
2900.2.16 by Vincent Ladeuil Make hhtp proxy aware of AuthenticationConfig (for password).	1126	if t._scheme == 'ftp':
	1127	scheme = 'sftp'
	1128	else:
	1129	scheme = 'ftp'
	1130	self.assertIsNot(t, t._reuse_for(new_url(scheme=scheme)))
2485.8.39 by Vincent Ladeuil Add tests around connection reuse.	1131	if t._user == 'me':
	1132	user = 'you'
	1133	else:
	1134	user = 'me'
	1135	self.assertIsNot(t, t._reuse_for(new_url(user=user)))
	1136	# passwords are not taken into account because:
	1137	# - it makes no sense to have two different valid passwords for the
	1138	# same user
	1139	# - _password in ConnectedTransport is intended to collect what the
	1140	# user specified from the command-line and there are cases where the
	1141	# new url can contain no password (if the url was built from an
	1142	# existing transport.base for example)
	1143	# - password are considered part of the credentials provided at
	1144	# connection creation time and as such may not be present in the url
	1145	# (they may be typed by the user when prompted for example)
	1146	self.assertIs(t, t._reuse_for(new_url(password='from space')))
	1147	# We will not connect, we can use a invalid host
	1148	self.assertIsNot(t, t._reuse_for(new_url(host=t._host + 'bar')))
	1149	if t._port == 1234:
	1150	port = 4321
	1151	else:
	1152	port = 1234
	1153	self.assertIsNot(t, t._reuse_for(new_url(port=port)))
	1154
2485.8.53 by Vincent Ladeuil Apply test_connection_sharing to all transports to make smart	1155	def test_connection_sharing(self):
	1156	t = self.get_transport()
	1157	if not isinstance(t, ConnectedTransport):
	1158	raise TestSkipped("not a connected transport")
	1159
	1160	c = t.clone('subdir')
2485.8.54 by Vincent Ladeuil Refactor medium uses by making a distinction betweem shared and real medium.	1161	# Some transports will create the connection only when needed
2485.8.53 by Vincent Ladeuil Apply test_connection_sharing to all transports to make smart	1162	t.has('surely_not') # Force connection
	1163	self.assertIs(t._get_connection(), c._get_connection())
	1164
2485.8.54 by Vincent Ladeuil Refactor medium uses by making a distinction betweem shared and real medium.	1165	# Temporary failure, we need to create a new dummy connection
2485.8.53 by Vincent Ladeuil Apply test_connection_sharing to all transports to make smart	1166	new_connection = object()
	1167	t._set_connection(new_connection)
2485.8.54 by Vincent Ladeuil Refactor medium uses by making a distinction betweem shared and real medium.	1168	# Check that both transports use the same connection
2485.8.53 by Vincent Ladeuil Apply test_connection_sharing to all transports to make smart	1169	self.assertIs(new_connection, t._get_connection())
	1170	self.assertIs(new_connection, c._get_connection())
	1171
2485.8.39 by Vincent Ladeuil Add tests around connection reuse.	1172	def test_reuse_connection_for_various_paths(self):
	1173	t = self.get_transport()
	1174	if not isinstance(t, ConnectedTransport):
	1175	raise TestSkipped("not a connected transport")
	1176
	1177	t.has('surely_not') # Force connection
	1178	self.assertIsNot(None, t._get_connection())
	1179
	1180	subdir = t._reuse_for(t.base + 'whatever/but/deep/down/the/path')
	1181	self.assertIsNot(t, subdir)
	1182	self.assertIs(t._get_connection(), subdir._get_connection())
	1183
	1184	home = subdir._reuse_for(t.base + 'home')
	1185	self.assertIs(t._get_connection(), home._get_connection())
	1186	self.assertIs(subdir._get_connection(), home._get_connection())
	1187
1530.1.3 by Robert Collins transport implementations now tested consistently.	1188	def test_clone(self):
	1189	# TODO: Test that clone moves up and down the filesystem
	1190	t1 = self.get_transport()
	1191
	1192	self.build_tree(['a', 'b/', 'b/c'], transport=t1)
	1193
	1194	self.failUnless(t1.has('a'))
	1195	self.failUnless(t1.has('b/c'))
	1196	self.failIf(t1.has('c'))
	1197
	1198	t2 = t1.clone('b')
	1199	self.assertEqual(t1.base + 'b/', t2.base)
	1200
	1201	self.failUnless(t2.has('c'))
	1202	self.failIf(t2.has('a'))
	1203
	1204	t3 = t2.clone('..')
	1205	self.failUnless(t3.has('a'))
	1206	self.failIf(t3.has('c'))
	1207
	1208	self.failIf(t1.has('b/d'))
	1209	self.failIf(t2.has('d'))
	1210	self.failIf(t3.has('b/d'))
	1211
	1212	if t1.is_readonly():
	1213	open('b/d', 'wb').write('newfile\n')
	1214	else:
1955.3.11 by John Arbash Meinel Clean up the rest of the api calls to deprecated functions in the test suite, and make sure Transport._pump is only accepting files, not strings	1215	t2.put_bytes('d', 'newfile\n')
1530.1.3 by Robert Collins transport implementations now tested consistently.	1216
	1217	self.failUnless(t1.has('b/d'))
	1218	self.failUnless(t2.has('d'))
	1219	self.failUnless(t3.has('b/d'))
	1220
1910.15.1 by Andrew Bennetts More tests for abspath and clone behaviour	1221	def test_clone_to_root(self):
	1222	orig_transport = self.get_transport()
	1223	# Repeatedly go up to a parent directory until we're at the root
	1224	# directory of this transport
	1225	root_transport = orig_transport
1986.1.10 by Robert Collins Merge from bzr.dev, fixing found bugs handling 'has('/')' in MemoryTransport and SFTP transports.	1226	new_transport = root_transport.clone("..")
2245.6.1 by Alexander Belchenko win32 UNC path: recursive cloning UNC path to root stops on //HOST, not on //	1227	# as we are walking up directories, the path must be
1986.1.10 by Robert Collins Merge from bzr.dev, fixing found bugs handling 'has('/')' in MemoryTransport and SFTP transports.	1228	# growing less, except at the top
	1229	self.assertTrue(len(new_transport.base) < len(root_transport.base)
	1230	or new_transport.base == root_transport.base)
	1231	while new_transport.base != root_transport.base:
	1232	root_transport = new_transport
	1233	new_transport = root_transport.clone("..")
2245.6.1 by Alexander Belchenko win32 UNC path: recursive cloning UNC path to root stops on //HOST, not on //	1234	# as we are walking up directories, the path must be
1986.1.10 by Robert Collins Merge from bzr.dev, fixing found bugs handling 'has('/')' in MemoryTransport and SFTP transports.	1235	# growing less, except at the top
	1236	self.assertTrue(len(new_transport.base) < len(root_transport.base)
	1237	or new_transport.base == root_transport.base)
1910.15.1 by Andrew Bennetts More tests for abspath and clone behaviour	1238
	1239	# Cloning to "/" should take us to exactly the same location.
	1240	self.assertEqual(root_transport.base, orig_transport.clone("/").base)
1986.1.10 by Robert Collins Merge from bzr.dev, fixing found bugs handling 'has('/')' in MemoryTransport and SFTP transports.	1241	# the abspath of "/" from the original transport should be the same
	1242	# as the base at the root:
	1243	self.assertEqual(orig_transport.abspath("/"), root_transport.base)
1910.15.1 by Andrew Bennetts More tests for abspath and clone behaviour	1244
1910.15.5 by Andrew Bennetts Transport behaviour at the root of the URL is now defined and tested.	1245	# At the root, the URL must still end with / as its a directory
	1246	self.assertEqual(root_transport.base[-1], '/')
	1247
	1248	def test_clone_from_root(self):
	1249	"""At the root, cloning to a simple dir should just do string append."""
	1250	orig_transport = self.get_transport()
	1251	root_transport = orig_transport.clone('/')
	1252	self.assertEqual(root_transport.base + '.bzr/',
	1253	root_transport.clone('.bzr').base)
	1254
1910.15.1 by Andrew Bennetts More tests for abspath and clone behaviour	1255	def test_base_url(self):
	1256	t = self.get_transport()
	1257	self.assertEqual('/', t.base[-1])
	1258
1530.1.3 by Robert Collins transport implementations now tested consistently.	1259	def test_relpath(self):
	1260	t = self.get_transport()
	1261	self.assertEqual('', t.relpath(t.base))
	1262	# base ends with /
	1263	self.assertEqual('', t.relpath(t.base[:-1]))
	1264	# subdirs which dont exist should still give relpaths.
	1265	self.assertEqual('foo', t.relpath(t.base + 'foo'))
	1266	# trailing slash should be the same.
	1267	self.assertEqual('foo', t.relpath(t.base + 'foo/'))
	1268
1636.1.1 by Robert Collins Fix calling relpath() and abspath() on transports at their root.	1269	def test_relpath_at_root(self):
	1270	t = self.get_transport()
	1271	# clone all the way to the top
	1272	new_transport = t.clone('..')
	1273	while new_transport.base != t.base:
	1274	t = new_transport
	1275	new_transport = t.clone('..')
	1276	# we must be able to get a relpath below the root
	1277	self.assertEqual('', t.relpath(t.base))
	1278	# and a deeper one should work too
	1279	self.assertEqual('foo/bar', t.relpath(t.base + 'foo/bar'))
	1280
1530.1.3 by Robert Collins transport implementations now tested consistently.	1281	def test_abspath(self):
	1282	# smoke test for abspath. Corner cases for backends like unix fs's
	1283	# that have aliasing problems like symlinks should go in backend
	1284	# specific test cases.
	1285	transport = self.get_transport()
2485.8.21 by Vincent Ladeuil Simplify debug.	1286
1530.1.3 by Robert Collins transport implementations now tested consistently.	1287	self.assertEqual(transport.base + 'relpath',
	1288	transport.abspath('relpath'))
	1289
1910.15.1 by Andrew Bennetts More tests for abspath and clone behaviour	1290	# This should work without raising an error.
	1291	transport.abspath("/")
	1292
	1293	# the abspath of "/" and "/foo/.." should result in the same location
	1294	self.assertEqual(transport.abspath("/"), transport.abspath("/foo/.."))
	1295
2070.3.1 by Andrew Bennetts Fix memory_transport.abspath('/foo')	1296	self.assertEqual(transport.clone("/").abspath('foo'),
	1297	transport.abspath("/foo"))
	1298
1685.1.9 by John Arbash Meinel Updated LocalTransport so that it's base is now a URL rather than a local path. This helps consistency with all other functions. To do so, I added local_abspath() which returns the local path, and local_path_to/from_url	1299	def test_local_abspath(self):
	1300	transport = self.get_transport()
	1301	try:
	1302	p = transport.local_abspath('.')
2018.18.4 by Martin Pool Change Transport.local_abspath to raise NotLocalUrl, and test.	1303	except (errors.NotLocalUrl, TransportNotPossible), e:
2018.18.22 by Martin Pool merge bzr.dev	1304	# should be formattable
2018.18.4 by Martin Pool Change Transport.local_abspath to raise NotLocalUrl, and test.	1305	s = str(e)
1685.1.9 by John Arbash Meinel Updated LocalTransport so that it's base is now a URL rather than a local path. This helps consistency with all other functions. To do so, I added local_abspath() which returns the local path, and local_path_to/from_url	1306	else:
	1307	self.assertEqual(getcwd(), p)
	1308
1636.1.1 by Robert Collins Fix calling relpath() and abspath() on transports at their root.	1309	def test_abspath_at_root(self):
	1310	t = self.get_transport()
	1311	# clone all the way to the top
	1312	new_transport = t.clone('..')
	1313	while new_transport.base != t.base:
	1314	t = new_transport
	1315	new_transport = t.clone('..')
	1316	# we must be able to get a abspath of the root when we ask for
	1317	# t.abspath('..') - this due to our choice that clone('..')
	1318	# should return the root from the root, combined with the desire that
	1319	# the url from clone('..') and from abspath('..') should be the same.
	1320	self.assertEqual(t.base, t.abspath('..'))
	1321	# '' should give us the root
	1322	self.assertEqual(t.base, t.abspath(''))
	1323	# and a path should append to the url
	1324	self.assertEqual(t.base + 'foo', t.abspath('foo'))
	1325
1530.1.3 by Robert Collins transport implementations now tested consistently.	1326	def test_iter_files_recursive(self):
1530.1.4 by Robert Collins integrate Memory tests into transport interface tests.	1327	transport = self.get_transport()
	1328	if not transport.listable():
1553.5.13 by Martin Pool New Transport.rename that mustn't overwrite	1329	self.assertRaises(TransportNotPossible,
1530.1.4 by Robert Collins integrate Memory tests into transport interface tests.	1330	transport.iter_files_recursive)
	1331	return
1553.5.13 by Martin Pool New Transport.rename that mustn't overwrite	1332	self.build_tree(['isolated/',
1530.1.4 by Robert Collins integrate Memory tests into transport interface tests.	1333	'isolated/dir/',
	1334	'isolated/dir/foo',
	1335	'isolated/dir/bar',
1959.2.1 by John Arbash Meinel David Allouche: Make transports return escaped paths	1336	'isolated/dir/b%25z', # make sure quoting is correct
1530.1.4 by Robert Collins integrate Memory tests into transport interface tests.	1337	'isolated/bar'],
	1338	transport=transport)
1530.1.3 by Robert Collins transport implementations now tested consistently.	1339	paths = set(transport.iter_files_recursive())
1553.5.13 by Martin Pool New Transport.rename that mustn't overwrite	1340	# nb the directories are not converted
	1341	self.assertEqual(paths,
	1342	set(['isolated/dir/foo',
	1343	'isolated/dir/bar',
1959.2.1 by John Arbash Meinel David Allouche: Make transports return escaped paths	1344	'isolated/dir/b%2525z',
1553.5.13 by Martin Pool New Transport.rename that mustn't overwrite	1345	'isolated/bar']))
	1346	sub_transport = transport.clone('isolated')
	1347	paths = set(sub_transport.iter_files_recursive())
1959.2.1 by John Arbash Meinel David Allouche: Make transports return escaped paths	1348	self.assertEqual(paths,
	1349	set(['dir/foo', 'dir/bar', 'dir/b%2525z', 'bar']))
	1350
	1351	def test_copy_tree(self):
	1352	# TODO: test file contents and permissions are preserved. This test was
	1353	# added just to ensure that quoting was handled correctly.
	1354	# -- David Allouche 2006-08-11
	1355	transport = self.get_transport()
	1356	if not transport.listable():
	1357	self.assertRaises(TransportNotPossible,
	1358	transport.iter_files_recursive)
	1359	return
	1360	if transport.is_readonly():
	1361	return
	1362	self.build_tree(['from/',
	1363	'from/dir/',
	1364	'from/dir/foo',
	1365	'from/dir/bar',
	1366	'from/dir/b%25z', # make sure quoting is correct
	1367	'from/bar'],
	1368	transport=transport)
	1369	transport.copy_tree('from', 'to')
	1370	paths = set(transport.iter_files_recursive())
	1371	self.assertEqual(paths,
	1372	set(['from/dir/foo',
	1373	'from/dir/bar',
	1374	'from/dir/b%2525z',
	1375	'from/bar',
	1376	'to/dir/foo',
	1377	'to/dir/bar',
	1378	'to/dir/b%2525z',
	1379	'to/bar',]))
1185.85.76 by John Arbash Meinel Adding an InvalidURL so transports can report they expect utf-8 quoted paths. Updated tests	1380
	1381	def test_unicode_paths(self):
1685.1.57 by Martin Pool [broken] Skip unicode blackbox tests if not supported by filesystem	1382	"""Test that we can read/write files with Unicode names."""
1185.85.76 by John Arbash Meinel Adding an InvalidURL so transports can report they expect utf-8 quoted paths. Updated tests	1383	t = self.get_transport()
	1384
1711.7.36 by John Arbash Meinel Use different filenames to avoid path collisions on win32 w/ FAT32	1385	# With FAT32 and certain encodings on win32
	1386	# '\xe5' and '\xe4' actually map to the same file
	1387	# adding a suffix kicks in the 'preserving but insensitive'
	1388	# route, and maintains the right files
	1389	files = [u'\xe5.1', # a w/ circle iso-8859-1
	1390	u'\xe4.2', # a w/ dots iso-8859-1
1185.85.76 by John Arbash Meinel Adding an InvalidURL so transports can report they expect utf-8 quoted paths. Updated tests	1391	u'\u017d', # Z with umlat iso-8859-2
	1392	u'\u062c', # Arabic j
	1393	u'\u0410', # Russian A
	1394	u'\u65e5', # Kanji person
	1395	]
	1396
1685.1.72 by Wouter van Heyst StubSFTPServer should use bytestreams rather than unicode	1397	try:
1711.4.13 by John Arbash Meinel Use line_endings='binary' for win32	1398	self.build_tree(files, transport=t, line_endings='binary')
1685.1.72 by Wouter van Heyst StubSFTPServer should use bytestreams rather than unicode	1399	except UnicodeError:
	1400	raise TestSkipped("cannot handle unicode paths in current encoding")
1185.85.76 by John Arbash Meinel Adding an InvalidURL so transports can report they expect utf-8 quoted paths. Updated tests	1401
	1402	# A plain unicode string is not a valid url
	1403	for fname in files:
	1404	self.assertRaises(InvalidURL, t.get, fname)
	1405
	1406	for fname in files:
	1407	fname_utf8 = fname.encode('utf-8')
	1408	contents = 'contents of %s\n' % (fname_utf8,)
1685.1.45 by John Arbash Meinel Moved url functions into bzrlib.urlutils	1409	self.check_transport_contents(contents, t, urlutils.escape(fname))
1185.85.76 by John Arbash Meinel Adding an InvalidURL so transports can report they expect utf-8 quoted paths. Updated tests	1410
1534.4.26 by Robert Collins Move working tree initialisation out from Branch.initialize, deprecated Branch.initialize to Branch.create.	1411	def test_connect_twice_is_same_content(self):
2485.8.21 by Vincent Ladeuil Simplify debug.	1412	# check that our server (whatever it is) is accessible reliably
1534.4.26 by Robert Collins Move working tree initialisation out from Branch.initialize, deprecated Branch.initialize to Branch.create.	1413	# via get_transport and multiple connections share content.
	1414	transport = self.get_transport()
	1415	if transport.is_readonly():
	1416	return
1955.3.11 by John Arbash Meinel Clean up the rest of the api calls to deprecated functions in the test suite, and make sure Transport._pump is only accepting files, not strings	1417	transport.put_bytes('foo', 'bar')
2485.8.21 by Vincent Ladeuil Simplify debug.	1418	transport3 = self.get_transport()
2485.8.21 by Vincent Ladeuil Simplify debug.	1419	self.check_transport_contents('bar', transport3, 'foo')
1534.4.26 by Robert Collins Move working tree initialisation out from Branch.initialize, deprecated Branch.initialize to Branch.create.	1420	# its base should be usable.
2485.8.25 by Vincent Ladeuil Separate abspath from _remote_path, the intents are different.	1421	transport4 = get_transport(transport.base)
2485.8.21 by Vincent Ladeuil Simplify debug.	1422	self.check_transport_contents('bar', transport4, 'foo')
1534.4.26 by Robert Collins Move working tree initialisation out from Branch.initialize, deprecated Branch.initialize to Branch.create.	1423
	1424	# now opening at a relative url should give use a sane result:
	1425	transport.mkdir('newdir')
2485.8.25 by Vincent Ladeuil Separate abspath from _remote_path, the intents are different.	1426	transport5 = get_transport(transport.base + "newdir")
2485.8.21 by Vincent Ladeuil Simplify debug.	1427	transport6 = transport5.clone('..')
2485.8.21 by Vincent Ladeuil Simplify debug.	1428	self.check_transport_contents('bar', transport6, 'foo')
1534.4.26 by Robert Collins Move working tree initialisation out from Branch.initialize, deprecated Branch.initialize to Branch.create.	1429
	1430	def test_lock_write(self):
1910.16.1 by Andrew Bennetts lock_read and lock_write may raise TransportNotPossible.	1431	"""Test transport-level write locks.
	1432
	1433	These are deprecated and transports may decline to support them.
	1434	"""
1534.4.26 by Robert Collins Move working tree initialisation out from Branch.initialize, deprecated Branch.initialize to Branch.create.	1435	transport = self.get_transport()
	1436	if transport.is_readonly():
	1437	self.assertRaises(TransportNotPossible, transport.lock_write, 'foo')
	1438	return
1955.3.11 by John Arbash Meinel Clean up the rest of the api calls to deprecated functions in the test suite, and make sure Transport._pump is only accepting files, not strings	1439	transport.put_bytes('lock', '')
1910.16.1 by Andrew Bennetts lock_read and lock_write may raise TransportNotPossible.	1440	try:
	1441	lock = transport.lock_write('lock')
1752.3.6 by Andrew Bennetts Merge from test-tweaks	1442	except TransportNotPossible:
1910.16.1 by Andrew Bennetts lock_read and lock_write may raise TransportNotPossible.	1443	return
1534.4.26 by Robert Collins Move working tree initialisation out from Branch.initialize, deprecated Branch.initialize to Branch.create.	1444	# TODO make this consistent on all platforms:
	1445	# self.assertRaises(LockError, transport.lock_write, 'lock')
	1446	lock.unlock()
	1447
	1448	def test_lock_read(self):
1910.16.1 by Andrew Bennetts lock_read and lock_write may raise TransportNotPossible.	1449	"""Test transport-level read locks.
	1450
	1451	These are deprecated and transports may decline to support them.
	1452	"""
1534.4.26 by Robert Collins Move working tree initialisation out from Branch.initialize, deprecated Branch.initialize to Branch.create.	1453	transport = self.get_transport()
	1454	if transport.is_readonly():
	1455	file('lock', 'w').close()
	1456	else:
1955.3.11 by John Arbash Meinel Clean up the rest of the api calls to deprecated functions in the test suite, and make sure Transport._pump is only accepting files, not strings	1457	transport.put_bytes('lock', '')
1910.16.1 by Andrew Bennetts lock_read and lock_write may raise TransportNotPossible.	1458	try:
	1459	lock = transport.lock_read('lock')
1752.3.6 by Andrew Bennetts Merge from test-tweaks	1460	except TransportNotPossible:
1910.16.1 by Andrew Bennetts lock_read and lock_write may raise TransportNotPossible.	1461	return
1534.4.26 by Robert Collins Move working tree initialisation out from Branch.initialize, deprecated Branch.initialize to Branch.create.	1462	# TODO make this consistent on all platforms:
	1463	# self.assertRaises(LockError, transport.lock_read, 'lock')
	1464	lock.unlock()
1185.85.80 by John Arbash Meinel [merge] jam-integration 1527, including branch-formats, help text, misc bug fixes.	1465
1594.2.5 by Robert Collins Readv patch from Johan Rydberg giving knits partial download support.	1466	def test_readv(self):
	1467	transport = self.get_transport()
	1468	if transport.is_readonly():
	1469	file('a', 'w').write('0123456789')
	1470	else:
1955.3.11 by John Arbash Meinel Clean up the rest of the api calls to deprecated functions in the test suite, and make sure Transport._pump is only accepting files, not strings	1471	transport.put_bytes('a', '0123456789')
1185.85.76 by John Arbash Meinel Adding an InvalidURL so transports can report they expect utf-8 quoted paths. Updated tests	1472
2004.1.22 by v.ladeuil+lp at free Implements Range header handling for GET requests. Fix a test.	1473	d = list(transport.readv('a', ((0, 1),)))
	1474	self.assertEqual(d[0], (0, '0'))
	1475
1594.2.17 by Robert Collins Better readv coalescing, now with test, and progress during knit index reading.	1476	d = list(transport.readv('a', ((0, 1), (1, 1), (3, 2), (9, 1))))
1594.2.5 by Robert Collins Readv patch from Johan Rydberg giving knits partial download support.	1477	self.assertEqual(d[0], (0, '0'))
1594.2.17 by Robert Collins Better readv coalescing, now with test, and progress during knit index reading.	1478	self.assertEqual(d[1], (1, '1'))
	1479	self.assertEqual(d[2], (3, '34'))
	1480	self.assertEqual(d[3], (9, '9'))
1786.1.8 by John Arbash Meinel [merge] Johan Rydberg test updates	1481
1864.5.2 by John Arbash Meinel always read in sorted order, and return in requested order, but only cache what is currently out of order	1482	def test_readv_out_of_order(self):
	1483	transport = self.get_transport()
	1484	if transport.is_readonly():
	1485	file('a', 'w').write('0123456789')
	1486	else:
1955.3.11 by John Arbash Meinel Clean up the rest of the api calls to deprecated functions in the test suite, and make sure Transport._pump is only accepting files, not strings	1487	transport.put_bytes('a', '01234567890')
1864.5.2 by John Arbash Meinel always read in sorted order, and return in requested order, but only cache what is currently out of order	1488
	1489	d = list(transport.readv('a', ((1, 1), (9, 1), (0, 1), (3, 2))))
	1490	self.assertEqual(d[0], (1, '1'))
	1491	self.assertEqual(d[1], (9, '9'))
	1492	self.assertEqual(d[2], (0, '0'))
	1493	self.assertEqual(d[3], (3, '34'))
1752.2.40 by Andrew Bennetts Merge from bzr.dev.	1494
2745.5.1 by Robert Collins * New parameter on ``bzrlib.transport.Transport.readv``	1495	def test_readv_with_adjust_for_latency(self):
	1496	transport = self.get_transport()
	1497	# the adjust for latency flag expands the data region returned
	1498	# according to a per-transport heuristic, so testing is a little
	1499	# tricky as we need more data than the largest combining that our
	1500	# transports do. To accomodate this we generate random data and cross
	1501	# reference the returned data with the random data. To avoid doing
	1502	# multiple large random byte look ups we do several tests on the same
	1503	# backing data.
	1504	content = osutils.rand_bytes(200*1024)
2745.5.3 by Robert Collins * Move transport logging into a new transport class	1505	content_size = len(content)
2745.5.1 by Robert Collins * New parameter on ``bzrlib.transport.Transport.readv``	1506	if transport.is_readonly():
	1507	file('a', 'w').write(content)
	1508	else:
	1509	transport.put_bytes('a', content)
	1510	def check_result_data(result_vector):
	1511	for item in result_vector:
	1512	data_len = len(item[1])
	1513	self.assertEqual(content[item[0]:item[0] + data_len], item[1])
	1514
	1515	# start corner case
	1516	result = list(transport.readv('a', ((0, 30),),
2745.5.3 by Robert Collins * Move transport logging into a new transport class	1517	adjust_for_latency=True, upper_limit=content_size))
2745.5.1 by Robert Collins * New parameter on ``bzrlib.transport.Transport.readv``	1518	# we expect 1 result, from 0, to something > 30
	1519	self.assertEqual(1, len(result))
	1520	self.assertEqual(0, result[0][0])
	1521	self.assertTrue(len(result[0][1]) >= 30)
	1522	check_result_data(result)
	1523	# end of file corner case
	1524	result = list(transport.readv('a', ((204700, 100),),
2745.5.3 by Robert Collins * Move transport logging into a new transport class	1525	adjust_for_latency=True, upper_limit=content_size))
2745.5.1 by Robert Collins * New parameter on ``bzrlib.transport.Transport.readv``	1526	# we expect 1 result, from 204800- its length, to the end
	1527	self.assertEqual(1, len(result))
	1528	data_len = len(result[0][1])
	1529	self.assertEqual(204800-data_len, result[0][0])
	1530	self.assertTrue(data_len >= 100)
	1531	check_result_data(result)
	1532	# out of order ranges are made in order
	1533	result = list(transport.readv('a', ((204700, 100), (0, 50)),
2745.5.3 by Robert Collins * Move transport logging into a new transport class	1534	adjust_for_latency=True, upper_limit=content_size))
2745.5.1 by Robert Collins * New parameter on ``bzrlib.transport.Transport.readv``	1535	# we expect 2 results, in order, start and end.
	1536	self.assertEqual(2, len(result))
	1537	# start
	1538	data_len = len(result[0][1])
	1539	self.assertEqual(0, result[0][0])
	1540	self.assertTrue(data_len >= 30)
	1541	# end
	1542	data_len = len(result[1][1])
	1543	self.assertEqual(204800-data_len, result[1][0])
	1544	self.assertTrue(data_len >= 100)
	1545	check_result_data(result)
	1546	# close ranges get combined (even if out of order)
	1547	for request_vector in [((400,50), (800, 234)), ((800, 234), (400,50))]:
	1548	result = list(transport.readv('a', request_vector,
2745.5.3 by Robert Collins * Move transport logging into a new transport class	1549	adjust_for_latency=True, upper_limit=content_size))
2745.5.1 by Robert Collins * New parameter on ``bzrlib.transport.Transport.readv``	1550	self.assertEqual(1, len(result))
	1551	data_len = len(result[0][1])
	1552	# minimmum length is from 400 to 1034 - 634
	1553	self.assertTrue(data_len >= 634)
	1554	# must contain the region 400 to 1034
	1555	self.assertTrue(result[0][0] <= 400)
	1556	self.assertTrue(result[0][0] + data_len >= 1034)
	1557	check_result_data(result)
2890.1.2 by Robert Collins More readv adjust for latency tests and bugfixes.	1558	# test from observed failure case.
	1559	if transport.is_readonly():
	1560	file('a', 'w').write('a'10241024)
	1561	else:
	1562	transport.put_bytes('a', 'a'10241024)
	1563	broken_vector = [(465219, 800), (225221, 800), (445548, 800),
	1564	(225037, 800), (221357, 800), (437077, 800), (947670, 800),
	1565	(465373, 800), (947422, 800)]
	1566	results = list(transport.readv('a', broken_vector, True, 1024*1024))
	1567	found_items = [False]*9
	1568	for pos, (start, length) in enumerate(broken_vector):
	1569	# check the range is covered by the result
	1570	for offset, data in results:
	1571	if offset <= start and start + length <= offset + len(data):
	1572	found_items[pos] = True
	1573	self.assertEqual([True]*9, found_items)
2745.5.1 by Robert Collins * New parameter on ``bzrlib.transport.Transport.readv``	1574
2671.3.9 by Robert Collins Review feedback and fix VFat emulated transports to not claim to have unix permissions.	1575	def test_get_with_open_write_stream_sees_all_content(self):
2671.3.5 by Robert Collins * New methods on ``bzrlib.transport.Transport`` ``open_file_stream`` and	1576	t = self.get_transport()
	1577	if t.is_readonly():
	1578	return
2671.3.9 by Robert Collins Review feedback and fix VFat emulated transports to not claim to have unix permissions.	1579	handle = t.open_write_stream('foo')
2671.3.5 by Robert Collins * New methods on ``bzrlib.transport.Transport`` ``open_file_stream`` and	1580	try:
2671.3.6 by Robert Collins Review feedback.	1581	handle.write('bcd')
2671.3.5 by Robert Collins * New methods on ``bzrlib.transport.Transport`` ``open_file_stream`` and	1582	self.assertEqual([(0, 'b'), (2, 'd')], list(t.readv('foo', ((0,1), (2,1)))))
	1583	finally:
2671.3.6 by Robert Collins Review feedback.	1584	handle.close()
2671.3.5 by Robert Collins * New methods on ``bzrlib.transport.Transport`` ``open_file_stream`` and	1585
2018.2.3 by Andrew Bennetts Starting factoring out the smart server client "medium" from the protocol.	1586	def test_get_smart_medium(self):
	1587	"""All transports must either give a smart medium, or know they can't.
	1588	"""
	1589	transport = self.get_transport()
	1590	try:
2018.5.2 by Andrew Bennetts Start splitting bzrlib/transport/smart.py into a package.	1591	client_medium = transport.get_smart_medium()
	1592	self.assertIsInstance(client_medium, medium.SmartClientMedium)
2018.2.3 by Andrew Bennetts Starting factoring out the smart server client "medium" from the protocol.	1593	except errors.NoSmartMedium:
	1594	# as long as we got it we're fine
	1595	pass
	1596
2001.3.2 by John Arbash Meinel Force all transports to raise ShortReadvError if they can	1597	def test_readv_short_read(self):
	1598	transport = self.get_transport()
	1599	if transport.is_readonly():
	1600	file('a', 'w').write('0123456789')
	1601	else:
	1602	transport.put_bytes('a', '01234567890')
	1603
	1604	# This is intentionally reading off the end of the file
	1605	# since we are sure that it cannot get there
2000.3.9 by v.ladeuil+lp at free The tests that would have help avoid bug #73948 and all that mess :)	1606	self.assertListRaises((errors.ShortReadvError, errors.InvalidRange,
	1607	# Can be raised by paramiko
	1608	AssertionError),
2001.3.2 by John Arbash Meinel Force all transports to raise ShortReadvError if they can	1609	transport.readv, 'a', [(1,1), (8,10)])
	1610
	1611	# This is trying to seek past the end of the file, it should
	1612	# also raise a special error
2000.3.9 by v.ladeuil+lp at free The tests that would have help avoid bug #73948 and all that mess :)	1613	self.assertListRaises((errors.ShortReadvError, errors.InvalidRange),
2001.3.2 by John Arbash Meinel Force all transports to raise ShortReadvError if they can	1614	transport.readv, 'a', [(12,2)])