← Back to branch summary

~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/smart/vfs.py

  • Committer: Canonical.com Patch Queue Manager
  • Date: 2007-12-20 16:16:34 UTC
  • mfrom: (3123.5.18 hardlinks)
  • Revision ID: pqm@pqm.ubuntu.com-20071220161634-2kcjb650o21ydko4
Accelerate build_tree using similar workingtrees (abentley)

Show diffs side-by-side

added added

removed removed

Lines of Context:
bzrlib/smart/vfs.py
63
63
class HasRequest(VfsRequest):
64
64
 
65
65
    def do(self, relpath):
66
 
        relpath = self.translate_client_path(relpath)
67
66
        r = self._backing_transport.has(relpath) and 'yes' or 'no'
68
67
        return request.SuccessfulSmartServerResponse((r,))
69
68
 
71
70
class GetRequest(VfsRequest):
72
71
 
73
72
    def do(self, relpath):
74
 
        relpath = self.translate_client_path(relpath)
75
73
        try:
76
74
            backing_bytes = self._backing_transport.get_bytes(relpath)
77
75
        except errors.ReadError:
78
76
            # cannot read the file
79
77
            return request.FailedSmartServerResponse(('ReadError', ))
80
 
        except errors.PermissionDenied:
81
 
            return request.FailedSmartServerResponse(('PermissionDenied',))
82
78
        return request.SuccessfulSmartServerResponse(('ok',), backing_bytes)
83
79
 
84
80
 
85
81
class AppendRequest(VfsRequest):
86
82
 
87
83
    def do(self, relpath, mode):
88
 
        relpath = self.translate_client_path(relpath)
89
84
        self._relpath = relpath
90
85
        self._mode = _deserialise_optional_mode(mode)
91
86
    
98
93
class DeleteRequest(VfsRequest):
99
94
 
100
95
    def do(self, relpath):
101
 
        relpath = self.translate_client_path(relpath)
102
96
        self._backing_transport.delete(relpath)
103
97
        return request.SuccessfulSmartServerResponse(('ok', ))
104
98
 
106
100
class IterFilesRecursiveRequest(VfsRequest):
107
101
 
108
102
    def do(self, relpath):
109
 
        if not relpath.endswith('/'):
110
 
            relpath += '/'
111
 
        relpath = self.translate_client_path(relpath)
112
103
        transport = self._backing_transport.clone(relpath)
113
104
        filenames = transport.iter_files_recursive()
114
105
        return request.SuccessfulSmartServerResponse(('names',) + tuple(filenames))
117
108
class ListDirRequest(VfsRequest):
118
109
 
119
110
    def do(self, relpath):
120
 
        if not relpath.endswith('/'):
121
 
            relpath += '/'
122
 
        relpath = self.translate_client_path(relpath)
123
111
        filenames = self._backing_transport.list_dir(relpath)
124
112
        return request.SuccessfulSmartServerResponse(('names',) + tuple(filenames))
125
113
 
127
115
class MkdirRequest(VfsRequest):
128
116
 
129
117
    def do(self, relpath, mode):
130
 
        relpath = self.translate_client_path(relpath)
131
118
        self._backing_transport.mkdir(relpath,
132
119
                                      _deserialise_optional_mode(mode))
133
120
        return request.SuccessfulSmartServerResponse(('ok',))
136
123
class MoveRequest(VfsRequest):
137
124
 
138
125
    def do(self, rel_from, rel_to):
139
 
        rel_from = self.translate_client_path(rel_from)
140
 
        rel_to = self.translate_client_path(rel_to)
141
126
        self._backing_transport.move(rel_from, rel_to)
142
127
        return request.SuccessfulSmartServerResponse(('ok',))
143
128
 
145
130
class PutRequest(VfsRequest):
146
131
 
147
132
    def do(self, relpath, mode):
148
 
        relpath = self.translate_client_path(relpath)
149
133
        self._relpath = relpath
150
134
        self._mode = _deserialise_optional_mode(mode)
151
135
 
157
141
class PutNonAtomicRequest(VfsRequest):
158
142
 
159
143
    def do(self, relpath, mode, create_parent, dir_mode):
160
 
        relpath = self.translate_client_path(relpath)
161
144
        self._relpath = relpath
162
145
        self._dir_mode = _deserialise_optional_mode(dir_mode)
163
146
        self._mode = _deserialise_optional_mode(mode)
176
159
class ReadvRequest(VfsRequest):
177
160
 
178
161
    def do(self, relpath):
179
 
        relpath = self.translate_client_path(relpath)
180
162
        self._relpath = relpath
181
163
 
182
164
    def do_body(self, body_bytes):
200
182
class RenameRequest(VfsRequest):
201
183
 
202
184
    def do(self, rel_from, rel_to):
203
 
        rel_from = self.translate_client_path(rel_from)
204
 
        rel_to = self.translate_client_path(rel_to)
205
185
        self._backing_transport.rename(rel_from, rel_to)
206
186
        return request.SuccessfulSmartServerResponse(('ok', ))
207
187
 
209
189
class RmdirRequest(VfsRequest):
210
190
 
211
191
    def do(self, relpath):
212
 
        relpath = self.translate_client_path(relpath)
213
192
        self._backing_transport.rmdir(relpath)
214
193
        return request.SuccessfulSmartServerResponse(('ok', ))
215
194
 
217
196
class StatRequest(VfsRequest):
218
197
 
219
198
    def do(self, relpath):
220
 
        if not relpath.endswith('/'):
221
 
            relpath += '/'
222
 
        relpath = self.translate_client_path(relpath)
223
199
        stat = self._backing_transport.stat(relpath)
224
200
        return request.SuccessfulSmartServerResponse(
225
201
            ('stat', str(stat.st_size), oct(stat.st_mode)))