← Back to branch summary

~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/smart/vfs.py

  • Committer: Martin Pool
  • Date: 2005-06-28 03:02:31 UTC
  • Revision ID: mbp@sourcefrog.net-20050628030231-d311e4ebcd467ef4
Merge John's import-speedup branch:

                                                                                         
  777 John Arbash Meinel <john@arbash-meinel.com>       Sun 2005-06-26 22:20:32 -0500
      revision-id: john@arbash-meinel.com-20050627032031-e82a50db3863b18e
      bzr selftest was not using the correct bzr

  776 John Arbash Meinel <john@arbash-meinel.com>       Sun 2005-06-26 22:20:22 -0500
      revision-id: john@arbash-meinel.com-20050627032021-c9f21fde989ddaee
      Add was using an old mutter

  775 John Arbash Meinel <john@arbash-meinel.com>       Sun 2005-06-26 22:02:33 -0500
      revision-id: john@arbash-meinel.com-20050627030233-9165cfe98fc63298
      Cleaned up to be less different

  774 John Arbash Meinel <john@arbash-meinel.com>       Sun 2005-06-26 21:54:53 -0500
      revision-id: john@arbash-meinel.com-20050627025452-4260d0e744edef43
      Allow BZR_PLUGIN_PATH='' to negate plugin loading.

  773 John Arbash Meinel <john@arbash-meinel.com>       Sun 2005-06-26 21:49:34 -0500
      revision-id: john@arbash-meinel.com-20050627024933-b7158f67b7b9eae5
      Finished the previous cleanup (allowing load_plugins to be called twice)

  772 John Arbash Meinel <john@arbash-meinel.com>       Sun 2005-06-26 21:45:08 -0500
      revision-id: john@arbash-meinel.com-20050627024508-723b1df510d196fc
      Work on making the tests pass. versioning.py is calling run_cmd directly, but plugins have been loaded.

  771 John Arbash Meinel <john@arbash-meinel.com>       Sun 2005-06-26 21:32:29 -0500
      revision-id: john@arbash-meinel.com-20050627023228-79972744d7c53e15
      Got it down a little bit more by removing import of tree and inventory.

  770 John Arbash Meinel <john@arbash-meinel.com>       Sun 2005-06-26 21:26:05 -0500
      revision-id: john@arbash-meinel.com-20050627022604-350b9773ef622f95
      Reducing the number of import from bzrlib/__init__.py and bzrlib/branch.py

  769 John Arbash Meinel <john@arbash-meinel.com>       Sun 2005-06-26 20:32:25 -0500
      revision-id: john@arbash-meinel.com-20050627013225-32dd044f10d23948
      Updated revision.py and xml.py to include SubElement.

  768 John Arbash Meinel <john@arbash-meinel.com>       Sun 2005-06-26 20:03:56 -0500
      revision-id: john@arbash-meinel.com-20050627010356-ee66919e1c377faf
      Minor typo

  767 John Arbash Meinel <john@arbash-meinel.com>       Sun 2005-06-26 20:03:13 -0500
      revision-id: john@arbash-meinel.com-20050627010312-40d024007eb85051
      Caching the import

  766 John Arbash Meinel <john@arbash-meinel.com>       Sun 2005-06-26 19:51:47 -0500
      revision-id: john@arbash-meinel.com-20050627005147-5281c99e48ed1834
      Created wrapper functions for lazy import of ElementTree

  765 John Arbash Meinel <john@arbash-meinel.com>       Sun 2005-06-26 19:46:37 -0500
      revision-id: john@arbash-meinel.com-20050627004636-bf432902004a94c5
      Removed all of the test imports of cElementTree

  764 John Arbash Meinel <john@arbash-meinel.com>       Sun 2005-06-26 19:43:59 -0500
      revision-id: john@arbash-meinel.com-20050627004358-d137fbe9570dd71b
      Trying to make bzr startup faster.

Show diffs side-by-side

added added

removed removed

Lines of Context:
bzrlib/smart/vfs.py
1
 
# Copyright (C) 2006-2010 Canonical Ltd
2
 
#
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.
7
 
#
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.
12
 
#
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., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
16
 
 
17
 
"""VFS operations for the smart server.
18
 
 
19
 
This module defines the smart server methods that are low-level file operations
20
 
higher-level concepts like branches and revisions.
21
 
 
22
 
These methods, plus 'hello' and 'get_bundle', are version 1 of the smart server
23
 
protocol, as implemented in bzr 0.11 and later.
24
 
"""
25
 
 
26
 
import os
27
 
 
28
 
from bzrlib import errors
29
 
from bzrlib import urlutils
30
 
from bzrlib.smart import request
31
 
 
32
 
 
33
 
def _deserialise_optional_mode(mode):
34
 
    # XXX: FIXME this should be on the protocol object.  Later protocol versions
35
 
    # might serialise modes differently.
36
 
    if mode == '':
37
 
        return None
38
 
    else:
39
 
        return int(mode)
40
 
 
41
 
 
42
 
def vfs_enabled():
43
 
    """Is the VFS enabled ?
44
 
 
45
 
    the VFS is disabled when the BZR_NO_SMART_VFS environment variable is set.
46
 
 
47
 
    :return: True if it is enabled.
48
 
    """
49
 
    return not 'BZR_NO_SMART_VFS' in os.environ
50
 
 
51
 
 
52
 
class VfsRequest(request.SmartServerRequest):
53
 
    """Base class for VFS requests.
54
 
 
55
 
    VFS requests are disabled if vfs_enabled() returns False.
56
 
    """
57
 
 
58
 
    def _check_enabled(self):
59
 
        if not vfs_enabled():
60
 
            raise errors.DisabledMethod(self.__class__.__name__)
61
 
 
62
 
    def translate_client_path(self, relpath):
63
 
        # VFS requests are made with escaped paths so the escaping done in
64
 
        # SmartServerRequest.translate_client_path leads to double escaping.
65
 
        # Remove it here -- the fact that the result is still escaped means
66
 
        # that the str() will not fail on valid input.
67
 
        x = request.SmartServerRequest.translate_client_path(self, relpath)
68
 
        return str(urlutils.unescape(x))
69
 
 
70
 
 
71
 
class HasRequest(VfsRequest):
72
 
 
73
 
    def do(self, relpath):
74
 
        relpath = self.translate_client_path(relpath)
75
 
        r = self._backing_transport.has(relpath) and 'yes' or 'no'
76
 
        return request.SuccessfulSmartServerResponse((r,))
77
 
 
78
 
 
79
 
class GetRequest(VfsRequest):
80
 
 
81
 
    def do(self, relpath):
82
 
        relpath = self.translate_client_path(relpath)
83
 
        backing_bytes = self._backing_transport.get_bytes(relpath)
84
 
        return request.SuccessfulSmartServerResponse(('ok',), backing_bytes)
85
 
 
86
 
 
87
 
class AppendRequest(VfsRequest):
88
 
 
89
 
    def do(self, relpath, mode):
90
 
        relpath = self.translate_client_path(relpath)
91
 
        self._relpath = relpath
92
 
        self._mode = _deserialise_optional_mode(mode)
93
 
 
94
 
    def do_body(self, body_bytes):
95
 
        old_length = self._backing_transport.append_bytes(
96
 
            self._relpath, body_bytes, self._mode)
97
 
        return request.SuccessfulSmartServerResponse(('appended', '%d' % old_length))
98
 
 
99
 
 
100
 
class DeleteRequest(VfsRequest):
101
 
 
102
 
    def do(self, relpath):
103
 
        relpath = self.translate_client_path(relpath)
104
 
        self._backing_transport.delete(relpath)
105
 
        return request.SuccessfulSmartServerResponse(('ok', ))
106
 
 
107
 
 
108
 
class IterFilesRecursiveRequest(VfsRequest):
109
 
 
110
 
    def do(self, relpath):
111
 
        if not relpath.endswith('/'):
112
 
            relpath += '/'
113
 
        relpath = self.translate_client_path(relpath)
114
 
        transport = self._backing_transport.clone(relpath)
115
 
        filenames = transport.iter_files_recursive()
116
 
        return request.SuccessfulSmartServerResponse(('names',) + tuple(filenames))
117
 
 
118
 
 
119
 
class ListDirRequest(VfsRequest):
120
 
 
121
 
    def do(self, relpath):
122
 
        if not relpath.endswith('/'):
123
 
            relpath += '/'
124
 
        relpath = self.translate_client_path(relpath)
125
 
        filenames = self._backing_transport.list_dir(relpath)
126
 
        return request.SuccessfulSmartServerResponse(('names',) + tuple(filenames))
127
 
 
128
 
 
129
 
class MkdirRequest(VfsRequest):
130
 
 
131
 
    def do(self, relpath, mode):
132
 
        relpath = self.translate_client_path(relpath)
133
 
        self._backing_transport.mkdir(relpath,
134
 
                                      _deserialise_optional_mode(mode))
135
 
        return request.SuccessfulSmartServerResponse(('ok',))
136
 
 
137
 
 
138
 
class MoveRequest(VfsRequest):
139
 
 
140
 
    def do(self, rel_from, rel_to):
141
 
        rel_from = self.translate_client_path(rel_from)
142
 
        rel_to = self.translate_client_path(rel_to)
143
 
        self._backing_transport.move(rel_from, rel_to)
144
 
        return request.SuccessfulSmartServerResponse(('ok',))
145
 
 
146
 
 
147
 
class PutRequest(VfsRequest):
148
 
 
149
 
    def do(self, relpath, mode):
150
 
        relpath = self.translate_client_path(relpath)
151
 
        self._relpath = relpath
152
 
        self._mode = _deserialise_optional_mode(mode)
153
 
 
154
 
    def do_body(self, body_bytes):
155
 
        self._backing_transport.put_bytes(self._relpath, body_bytes, self._mode)
156
 
        return request.SuccessfulSmartServerResponse(('ok',))
157
 
 
158
 
 
159
 
class PutNonAtomicRequest(VfsRequest):
160
 
 
161
 
    def do(self, relpath, mode, create_parent, dir_mode):
162
 
        relpath = self.translate_client_path(relpath)
163
 
        self._relpath = relpath
164
 
        self._dir_mode = _deserialise_optional_mode(dir_mode)
165
 
        self._mode = _deserialise_optional_mode(mode)
166
 
        # a boolean would be nicer XXX
167
 
        self._create_parent = (create_parent == 'T')
168
 
 
169
 
    def do_body(self, body_bytes):
170
 
        self._backing_transport.put_bytes_non_atomic(self._relpath,
171
 
                body_bytes,
172
 
                mode=self._mode,
173
 
                create_parent_dir=self._create_parent,
174
 
                dir_mode=self._dir_mode)
175
 
        return request.SuccessfulSmartServerResponse(('ok',))
176
 
 
177
 
 
178
 
class ReadvRequest(VfsRequest):
179
 
 
180
 
    def do(self, relpath):
181
 
        relpath = self.translate_client_path(relpath)
182
 
        self._relpath = relpath
183
 
 
184
 
    def do_body(self, body_bytes):
185
 
        """accept offsets for a readv request."""
186
 
        offsets = self._deserialise_offsets(body_bytes)
187
 
        backing_bytes = ''.join(bytes for offset, bytes in
188
 
            self._backing_transport.readv(self._relpath, offsets))
189
 
        return request.SuccessfulSmartServerResponse(('readv',), backing_bytes)
190
 
 
191
 
    def _deserialise_offsets(self, text):
192
 
        # XXX: FIXME this should be on the protocol object.
193
 
        offsets = []
194
 
        for line in text.split('\n'):
195
 
            if not line:
196
 
                continue
197
 
            start, length = line.split(',')
198
 
            offsets.append((int(start), int(length)))
199
 
        return offsets
200
 
 
201
 
 
202
 
class RenameRequest(VfsRequest):
203
 
 
204
 
    def do(self, rel_from, rel_to):
205
 
        rel_from = self.translate_client_path(rel_from)
206
 
        rel_to = self.translate_client_path(rel_to)
207
 
        self._backing_transport.rename(rel_from, rel_to)
208
 
        return request.SuccessfulSmartServerResponse(('ok', ))
209
 
 
210
 
 
211
 
class RmdirRequest(VfsRequest):
212
 
 
213
 
    def do(self, relpath):
214
 
        relpath = self.translate_client_path(relpath)
215
 
        self._backing_transport.rmdir(relpath)
216
 
        return request.SuccessfulSmartServerResponse(('ok', ))
217
 
 
218
 
 
219
 
class StatRequest(VfsRequest):
220
 
 
221
 
    def do(self, relpath):
222
 
        if not relpath.endswith('/'):
223
 
            relpath += '/'
224
 
        relpath = self.translate_client_path(relpath)
225
 
        stat = self._backing_transport.stat(relpath)
226
 
        return request.SuccessfulSmartServerResponse(
227
 
            ('stat', str(stat.st_size), oct(stat.st_mode)))
228