~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/transport/remote.py

NEWS section template into a separate file

Show diffs side-by-side

added added

removed removed

Lines of Context:
12
12
#
13
13
# You should have received a copy of the GNU General Public License
14
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
 
15
# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
16
16
 
17
17
"""RemoteTransport client for the smart-server.
18
18
 
28
28
    config,
29
29
    debug,
30
30
    errors,
 
31
    remote,
31
32
    trace,
32
33
    transport,
33
34
    urlutils,
34
35
    )
35
36
from bzrlib.smart import client, medium
36
 
from bzrlib.symbol_versioning import (deprecated_method, one_four)
 
37
from bzrlib.symbol_versioning import (
 
38
    deprecated_method,
 
39
    )
37
40
 
38
41
 
39
42
class _SmartStat(object):
51
54
 
52
55
    The connection has a notion of the current directory to which it's
53
56
    connected; this is incorporated in filenames passed to the server.
54
 
    
55
 
    This supports some higher-level RPC operations and can also be treated 
 
57
 
 
58
    This supports some higher-level RPC operations and can also be treated
56
59
    like a Transport to do file-like operations.
57
60
 
58
61
    The connection can be made over a tcp socket, an ssh pipe or a series of
60
63
    RemoteTCPTransport, etc.
61
64
    """
62
65
 
 
66
    # When making a readv request, cap it at requesting 5MB of data
 
67
    _max_readv_bytes = 5*1024*1024
 
68
 
63
69
    # IMPORTANT FOR IMPLEMENTORS: RemoteTransport MUST NOT be given encoding
64
70
    # responsibilities: Put those on SmartClient or similar. This is vital for
65
71
    # the ability to support multiple versions of the smart protocol over time:
66
 
    # RemoteTransport is an adapter from the Transport object model to the 
 
72
    # RemoteTransport is an adapter from the Transport object model to the
67
73
    # SmartClient model, not an encoder.
68
74
 
69
75
    # FIXME: the medium parameter should be private, only the tests requires
86
92
            should only be used for testing purposes; normally this is
87
93
            determined from the medium.
88
94
        """
89
 
        super(RemoteTransport, self).__init__(url,
90
 
                                              _from_transport=_from_transport)
 
95
        super(RemoteTransport, self).__init__(
 
96
            url, _from_transport=_from_transport)
91
97
 
92
98
        # The medium is the connection, except when we need to share it with
93
99
        # other objects (RemoteBzrDir, RemoteRepository etc). In these cases
94
100
        # what we want to share is really the shared connection.
95
101
 
96
 
        if _from_transport is None:
 
102
        if (_from_transport is not None
 
103
            and isinstance(_from_transport, RemoteTransport)):
 
104
            _client = _from_transport._client
 
105
        elif _from_transport is None:
97
106
            # If no _from_transport is specified, we need to intialize the
98
107
            # shared medium.
99
108
            credentials = None
129
138
        # No credentials
130
139
        return None, None
131
140
 
 
141
    def _report_activity(self, bytes, direction):
 
142
        """See Transport._report_activity.
 
143
 
 
144
        Does nothing; the smart medium will report activity triggered by a
 
145
        RemoteTransport.
 
146
        """
 
147
        pass
 
148
 
132
149
    def is_readonly(self):
133
150
        """Smart server transport can do read/write file operations."""
134
151
        try:
143
160
        elif resp == ('no', ):
144
161
            return False
145
162
        else:
146
 
            self._translate_error(resp)
147
 
        raise errors.UnexpectedSmartServerResponse(resp)
 
163
            raise errors.UnexpectedSmartServerResponse(resp)
148
164
 
149
165
    def get_smart_client(self):
150
166
        return self._get_connection()
152
168
    def get_smart_medium(self):
153
169
        return self._get_connection()
154
170
 
155
 
    @deprecated_method(one_four)
156
 
    def get_shared_medium(self):
157
 
        return self._get_shared_connection()
158
 
 
159
171
    def _remote_path(self, relpath):
160
172
        """Returns the Unicode version of the absolute path for relpath."""
161
173
        return self._combine_paths(self._path, relpath)
162
174
 
163
175
    def _call(self, method, *args):
164
 
        try:
165
 
            resp = self._call2(method, *args)
166
 
        except errors.ErrorFromSmartServer, err:
167
 
            self._translate_error(err.error_tuple)
168
 
        self._translate_error(resp)
 
176
        resp = self._call2(method, *args)
 
177
        self._ensure_ok(resp)
169
178
 
170
179
    def _call2(self, method, *args):
171
180
        """Call a method on the remote server."""
172
181
        try:
173
182
            return self._client.call(method, *args)
174
183
        except errors.ErrorFromSmartServer, err:
175
 
            self._translate_error(err.error_tuple)
 
184
            # The first argument, if present, is always a path.
 
185
            if args:
 
186
                context = {'relpath': args[0]}
 
187
            else:
 
188
                context = {}
 
189
            self._translate_error(err, **context)
176
190
 
177
191
    def _call_with_body_bytes(self, method, args, body):
178
192
        """Call a method on the remote server with body bytes."""
179
193
        try:
180
194
            return self._client.call_with_body_bytes(method, args, body)
181
195
        except errors.ErrorFromSmartServer, err:
182
 
            self._translate_error(err.error_tuple)
 
196
            # The first argument, if present, is always a path.
 
197
            if args:
 
198
                context = {'relpath': args[0]}
 
199
            else:
 
200
                context = {}
 
201
            self._translate_error(err, **context)
183
202
 
184
203
    def has(self, relpath):
185
204
        """Indicate whether a remote file of the given name exists or not.
192
211
        elif resp == ('no', ):
193
212
            return False
194
213
        else:
195
 
            self._translate_error(resp)
 
214
            raise errors.UnexpectedSmartServerResponse(resp)
196
215
 
197
216
    def get(self, relpath):
198
217
        """Return file-like object reading the contents of a remote file.
199
 
        
 
218
 
200
219
        :see: Transport.get_bytes()/get_file()
201
220
        """
202
221
        return StringIO(self.get_bytes(relpath))
206
225
        try:
207
226
            resp, response_handler = self._client.call_expecting_body('get', remote)
208
227
        except errors.ErrorFromSmartServer, err:
209
 
            self._translate_error(err.error_tuple, relpath)
 
228
            self._translate_error(err, relpath)
210
229
        if resp != ('ok', ):
211
230
            response_handler.cancel_read_body()
212
231
            raise errors.UnexpectedSmartServerResponse(resp)
221
240
    def mkdir(self, relpath, mode=None):
222
241
        resp = self._call2('mkdir', self._remote_path(relpath),
223
242
            self._serialise_optional_mode(mode))
224
 
        self._translate_error(resp)
225
243
 
226
244
    def open_write_stream(self, relpath, mode=None):
227
245
        """See Transport.open_write_stream."""
243
261
        resp = self._call_with_body_bytes('put',
244
262
            (self._remote_path(relpath), self._serialise_optional_mode(mode)),
245
263
            upload_contents)
246
 
        self._translate_error(resp)
 
264
        self._ensure_ok(resp)
247
265
        return len(upload_contents)
248
266
 
249
267
    def put_bytes_non_atomic(self, relpath, bytes, mode=None,
260
278
            (self._remote_path(relpath), self._serialise_optional_mode(mode),
261
279
             create_parent_str, self._serialise_optional_mode(dir_mode)),
262
280
            bytes)
263
 
        self._translate_error(resp)
 
281
        self._ensure_ok(resp)
264
282
 
265
283
    def put_file(self, relpath, upload_file, mode=None):
266
284
        # its not ideal to seek back, but currently put_non_atomic_file depends
282
300
 
283
301
    def append_file(self, relpath, from_file, mode=None):
284
302
        return self.append_bytes(relpath, from_file.read(), mode)
285
 
        
 
303
 
286
304
    def append_bytes(self, relpath, bytes, mode=None):
287
305
        resp = self._call_with_body_bytes(
288
306
            'append',
290
308
            bytes)
291
309
        if resp[0] == 'appended':
292
310
            return int(resp[1])
293
 
        self._translate_error(resp)
 
311
        raise errors.UnexpectedSmartServerResponse(resp)
294
312
 
295
313
    def delete(self, relpath):
296
314
        resp = self._call2('delete', self._remote_path(relpath))
297
 
        self._translate_error(resp)
 
315
        self._ensure_ok(resp)
298
316
 
299
317
    def external_url(self):
300
318
        """See bzrlib.transport.Transport.external_url."""
304
322
    def recommended_page_size(self):
305
323
        """Return the recommended page size for this transport."""
306
324
        return 64 * 1024
307
 
        
 
325
 
308
326
    def _readv(self, relpath, offsets):
309
327
        if not offsets:
310
328
            return
312
330
        offsets = list(offsets)
313
331
 
314
332
        sorted_offsets = sorted(offsets)
315
 
        # turn the list of offsets into a stack
316
 
        offset_stack = iter(offsets)
317
 
        cur_offset_and_size = offset_stack.next()
318
333
        coalesced = list(self._coalesce_offsets(sorted_offsets,
319
334
                               limit=self._max_readv_combine,
320
 
                               fudge_factor=self._bytes_to_read_before_seek))
321
 
 
322
 
        try:
323
 
            result = self._client.call_with_body_readv_array(
324
 
                ('readv', self._remote_path(relpath),),
325
 
                [(c.start, c.length) for c in coalesced])
326
 
            resp, response_handler = result
327
 
        except errors.ErrorFromSmartServer, err:
328
 
            self._translate_error(err.error_tuple)
329
 
 
330
 
        if resp[0] != 'readv':
331
 
            # This should raise an exception
332
 
            response_handler.cancel_read_body()
333
 
            raise errors.UnexpectedSmartServerResponse(resp)
334
 
 
 
335
                               fudge_factor=self._bytes_to_read_before_seek,
 
336
                               max_size=self._max_readv_bytes))
 
337
 
 
338
        # now that we've coallesced things, avoid making enormous requests
 
339
        requests = []
 
340
        cur_request = []
 
341
        cur_len = 0
 
342
        for c in coalesced:
 
343
            if c.length + cur_len > self._max_readv_bytes:
 
344
                requests.append(cur_request)
 
345
                cur_request = [c]
 
346
                cur_len = c.length
 
347
                continue
 
348
            cur_request.append(c)
 
349
            cur_len += c.length
 
350
        if cur_request:
 
351
            requests.append(cur_request)
 
352
        if 'hpss' in debug.debug_flags:
 
353
            trace.mutter('%s.readv %s offsets => %s coalesced'
 
354
                         ' => %s requests (%s)',
 
355
                         self.__class__.__name__, len(offsets), len(coalesced),
 
356
                         len(requests), sum(map(len, requests)))
 
357
        # Cache the results, but only until they have been fulfilled
 
358
        data_map = {}
 
359
        # turn the list of offsets into a single stack to iterate
 
360
        offset_stack = iter(offsets)
 
361
        # using a list so it can be modified when passing down and coming back
 
362
        next_offset = [offset_stack.next()]
 
363
        for cur_request in requests:
 
364
            try:
 
365
                result = self._client.call_with_body_readv_array(
 
366
                    ('readv', self._remote_path(relpath),),
 
367
                    [(c.start, c.length) for c in cur_request])
 
368
                resp, response_handler = result
 
369
            except errors.ErrorFromSmartServer, err:
 
370
                self._translate_error(err, relpath)
 
371
 
 
372
            if resp[0] != 'readv':
 
373
                # This should raise an exception
 
374
                response_handler.cancel_read_body()
 
375
                raise errors.UnexpectedSmartServerResponse(resp)
 
376
 
 
377
            for res in self._handle_response(offset_stack, cur_request,
 
378
                                             response_handler,
 
379
                                             data_map,
 
380
                                             next_offset):
 
381
                yield res
 
382
 
 
383
    def _handle_response(self, offset_stack, coalesced, response_handler,
 
384
                         data_map, next_offset):
 
385
        cur_offset_and_size = next_offset[0]
335
386
        # FIXME: this should know how many bytes are needed, for clarity.
336
387
        data = response_handler.read_body_bytes()
337
 
        # Cache the results, but only until they have been fulfilled
338
 
        data_map = {}
 
388
        data_offset = 0
339
389
        for c_offset in coalesced:
340
390
            if len(data) < c_offset.length:
341
391
                raise errors.ShortReadvError(relpath, c_offset.start,
342
392
                            c_offset.length, actual=len(data))
343
393
            for suboffset, subsize in c_offset.ranges:
344
394
                key = (c_offset.start+suboffset, subsize)
345
 
                data_map[key] = data[suboffset:suboffset+subsize]
346
 
            data = data[c_offset.length:]
 
395
                this_data = data[data_offset+suboffset:
 
396
                                 data_offset+suboffset+subsize]
 
397
                # Special case when the data is in-order, rather than packing
 
398
                # into a map and then back out again. Benchmarking shows that
 
399
                # this has 100% hit rate, but leave in the data_map work just
 
400
                # in case.
 
401
                # TODO: Could we get away with using buffer() to avoid the
 
402
                #       memory copy?  Callers would need to realize they may
 
403
                #       not have a real string.
 
404
                if key == cur_offset_and_size:
 
405
                    yield cur_offset_and_size[0], this_data
 
406
                    cur_offset_and_size = next_offset[0] = offset_stack.next()
 
407
                else:
 
408
                    data_map[key] = this_data
 
409
            data_offset += c_offset.length
347
410
 
348
411
            # Now that we've read some data, see if we can yield anything back
349
412
            while cur_offset_and_size in data_map:
350
413
                this_data = data_map.pop(cur_offset_and_size)
351
414
                yield cur_offset_and_size[0], this_data
352
 
                cur_offset_and_size = offset_stack.next()
 
415
                cur_offset_and_size = next_offset[0] = offset_stack.next()
353
416
 
354
417
    def rename(self, rel_from, rel_to):
355
418
        self._call('rename',
364
427
    def rmdir(self, relpath):
365
428
        resp = self._call('rmdir', self._remote_path(relpath))
366
429
 
367
 
    def _translate_error(self, resp, orig_path=None):
368
 
        """Raise an exception from a response"""
369
 
        if resp is None:
370
 
            what = None
371
 
        else:
372
 
            what = resp[0]
373
 
        if what == 'ok':
374
 
            return
375
 
        elif what == 'NoSuchFile':
376
 
            if orig_path is not None:
377
 
                error_path = orig_path
378
 
            else:
379
 
                error_path = resp[1]
380
 
            raise errors.NoSuchFile(error_path)
381
 
        elif what == 'error':
382
 
            raise errors.SmartProtocolError(unicode(resp[1]))
383
 
        elif what == 'FileExists':
384
 
            raise errors.FileExists(resp[1])
385
 
        elif what == 'DirectoryNotEmpty':
386
 
            raise errors.DirectoryNotEmpty(resp[1])
387
 
        elif what == 'ShortReadvError':
388
 
            raise errors.ShortReadvError(resp[1], int(resp[2]),
389
 
                                         int(resp[3]), int(resp[4]))
390
 
        elif what in ('UnicodeEncodeError', 'UnicodeDecodeError'):
391
 
            encoding = str(resp[1]) # encoding must always be a string
392
 
            val = resp[2]
393
 
            start = int(resp[3])
394
 
            end = int(resp[4])
395
 
            reason = str(resp[5]) # reason must always be a string
396
 
            if val.startswith('u:'):
397
 
                val = val[2:].decode('utf-8')
398
 
            elif val.startswith('s:'):
399
 
                val = val[2:].decode('base64')
400
 
            if what == 'UnicodeDecodeError':
401
 
                raise UnicodeDecodeError(encoding, val, start, end, reason)
402
 
            elif what == 'UnicodeEncodeError':
403
 
                raise UnicodeEncodeError(encoding, val, start, end, reason)
404
 
        elif what == "ReadOnlyError":
405
 
            raise errors.TransportNotPossible('readonly transport')
406
 
        elif what == "ReadError":
407
 
            if orig_path is not None:
408
 
                error_path = orig_path
409
 
            else:
410
 
                error_path = resp[1]
411
 
            raise errors.ReadError(error_path)
412
 
        elif what == "PermissionDenied":
413
 
            if orig_path is not None:
414
 
                error_path = orig_path
415
 
            else:
416
 
                error_path = resp[1]
417
 
            raise errors.PermissionDenied(error_path)
418
 
        else:
419
 
            raise errors.SmartProtocolError('unexpected smart server error: %r' % (resp,))
 
430
    def _ensure_ok(self, resp):
 
431
        if resp[0] != 'ok':
 
432
            raise errors.UnexpectedSmartServerResponse(resp)
 
433
 
 
434
    def _translate_error(self, err, relpath=None):
 
435
        remote._translate_error(err, path=relpath)
420
436
 
421
437
    def disconnect(self):
422
438
        self.get_smart_medium().disconnect()
423
439
 
424
 
    def delete_tree(self, relpath):
425
 
        raise errors.TransportNotPossible('readonly transport')
426
 
 
427
440
    def stat(self, relpath):
428
441
        resp = self._call2('stat', self._remote_path(relpath))
429
442
        if resp[0] == 'stat':
430
443
            return _SmartStat(int(resp[1]), int(resp[2], 8))
431
 
        else:
432
 
            self._translate_error(resp)
 
444
        raise errors.UnexpectedSmartServerResponse(resp)
433
445
 
434
446
    ## def lock_read(self, relpath):
435
447
    ##     """Lock the given file for shared (read) access.
451
463
        resp = self._call2('list_dir', self._remote_path(relpath))
452
464
        if resp[0] == 'names':
453
465
            return [name.encode('ascii') for name in resp[1:]]
454
 
        else:
455
 
            self._translate_error(resp)
 
466
        raise errors.UnexpectedSmartServerResponse(resp)
456
467
 
457
468
    def iter_files_recursive(self):
458
469
        resp = self._call2('iter_files_recursive', self._remote_path(''))
459
470
        if resp[0] == 'names':
460
471
            return resp[1:]
461
 
        else:
462
 
            self._translate_error(resp)
 
472
        raise errors.UnexpectedSmartServerResponse(resp)
463
473
 
464
474
 
465
475
class RemoteTCPTransport(RemoteTransport):
466
476
    """Connection to smart server over plain tcp.
467
 
    
 
477
 
468
478
    This is essentially just a factory to get 'RemoteTransport(url,
469
479
        SmartTCPClientMedium).
470
480
    """
498
508
    """
499
509
 
500
510
    def _build_medium(self):
501
 
        # ssh will prompt the user for a password if needed and if none is
502
 
        # provided but it will not give it back, so no credentials can be
503
 
        # stored.
504
511
        location_config = config.LocationConfig(self.base)
505
512
        bzr_remote_path = location_config.get_bzr_remote_path()
 
513
        user = self._user
 
514
        if user is None:
 
515
            auth = config.AuthenticationConfig()
 
516
            user = auth.get_user('ssh', self._host, self._port)
506
517
        client_medium = medium.SmartSSHClientMedium(self._host, self._port,
507
 
            self._user, self._password, self.base,
 
518
            user, self._password, self.base,
508
519
            bzr_remote_path=bzr_remote_path)
509
 
        return client_medium, None
 
520
        return client_medium, (user, self._password)
510
521
 
511
522
 
512
523
class RemoteHTTPTransport(RemoteTransport):
513
524
    """Just a way to connect between a bzr+http:// url and http://.
514
 
    
 
525
 
515
526
    This connection operates slightly differently than the RemoteSSHTransport.
516
527
    It uses a plain http:// transport underneath, which defines what remote
517
528
    .bzr/smart URL we are connected to. From there, all paths that are sent are
566
577
                                   _from_transport=self,
567
578
                                   http_transport=self._http_transport)
568
579
 
 
580
    def _redirected_to(self, source, target):
 
581
        """See transport._redirected_to"""
 
582
        redirected = self._http_transport._redirected_to(source, target)
 
583
        if (redirected is not None
 
584
            and isinstance(redirected, type(self._http_transport))):
 
585
            return RemoteHTTPTransport('bzr+' + redirected.external_url(),
 
586
                                       http_transport=redirected)
 
587
        else:
 
588
            # Either None or a transport for a different protocol
 
589
            return redirected
 
590
 
 
591
 
 
592
class HintingSSHTransport(transport.Transport):
 
593
    """Simple transport that handles ssh:// and points out bzr+ssh://."""
 
594
 
 
595
    def __init__(self, url):
 
596
        raise errors.UnsupportedProtocol(url,
 
597
            'bzr supports bzr+ssh to operate over ssh, use "bzr+%s".' % url)
 
598
 
569
599
 
570
600
def get_test_permutations():
571
601
    """Return (transport, server) permutations for testing."""