← Back to branch summary

~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/remotebranch.py

  • Committer: Martin Pool
  • Date: 2005-06-27 01:26:11 UTC
  • Revision ID: mbp@sourcefrog.net-20050627012611-4effb7007553fde1
- tweak rsync upload script

Show diffs side-by-side

added added

removed removed

Lines of Context:
bzrlib/remotebranch.py
25
25
 
26
26
 
27
27
import gzip
28
 
from sets import Set
29
28
from cStringIO import StringIO
30
29
import urllib2
31
30
 
100
99
 
101
100
 
102
101
class RemoteBranch(Branch):
103
 
    def __init__(self, baseurl, find_root=True, lock_mode='r'):
 
102
    def __init__(self, baseurl, find_root=True):
104
103
        """Create new proxy for a remote branch."""
105
 
        if lock_mode not in ('', 'r'):
106
 
            raise BzrError('lock mode %r is not supported for remote branches'
107
 
                           % lock_mode)
108
 
 
109
104
        if find_root:
110
105
            self.baseurl = _find_remote_root(baseurl)
111
106
        else:
112
107
            self.baseurl = baseurl
113
108
            self._check_format()
114
109
 
 
110
        self.inventory_store = RemoteStore(baseurl + '/.bzr/inventory-store/')
 
111
        self.text_store = RemoteStore(baseurl + '/.bzr/text-store/')
 
112
        self.revision_store = RemoteStore(baseurl + '/.bzr/revision-store/')
 
113
 
115
114
    def __str__(self):
116
 
        return '%s(%r)' % (self.__class__.__name__, self.baseurl)
 
115
        b = getattr(self, 'baseurl', 'undefined')
 
116
        return '%s(%r)' % (self.__class__.__name__, b)
117
117
 
118
118
    __repr__ = __str__
119
119
 
122
122
            raise BzrError("file mode %r not supported for remote branches" % mode)
123
123
        return get_url(self.baseurl + '/.bzr/' + filename, False)
124
124
 
125
 
    def _need_readlock(self):
126
 
        # remote branch always safe for read
127
 
        pass
128
 
 
129
 
    def _need_writelock(self):
130
 
        raise BzrError("cannot get write lock on HTTP remote branch")
 
125
 
 
126
    def lock_read(self):
 
127
        # no locking for remote branches yet
 
128
        pass
 
129
 
 
130
    def lock_write(self):
 
131
        from errors import LockError
 
132
        raise LockError("write lock not supported for remote branch %s"
 
133
                        % self.baseurl)
 
134
 
 
135
    def unlock(self):
 
136
        pass
 
137
    
131
138
 
132
139
    def relpath(self, path):
133
140
        if not path.startswith(self.baseurl):
138
145
 
139
146
    def get_revision(self, revision_id):
140
147
        from revision import Revision
141
 
        revf = get_url(self.baseurl + '/.bzr/revision-store/' + revision_id,
142
 
                       True)
 
148
        revf = self.revision_store[revision_id]
143
149
        r = Revision.read_xml(revf)
144
150
        if r.revision_id != revision_id:
145
151
            raise BzrCheckError('revision stored as {%s} actually contains {%s}'
146
152
                                % (revision_id, r.revision_id))
147
153
        return r
 
154
 
 
155
 
 
156
class RemoteStore(object):
 
157
    def __init__(self, baseurl):
 
158
        self._baseurl = baseurl
 
159
        
 
160
 
 
161
    def _path(self, name):
 
162
        if '/' in name:
 
163
            raise ValueError('invalid store id', name)
 
164
        return self._baseurl + '/' + name
 
165
        
 
166
    def __getitem__(self, fileid):
 
167
        p = self._path(fileid)
 
168
        return get_url(p, compressed=True)
148
169
    
149
170
 
150
171
def simple_walk():
 
172
    """For experimental purposes, traverse many parts of a remote branch"""
151
173
    from revision import Revision
152
174
    from branch import Branch
153
175
    from inventory import Inventory
154
176
 
155
 
    got_invs = Set()
156
 
    got_texts = Set()
 
177
    got_invs = {}
 
178
    got_texts = {}
157
179
 
158
180
    print 'read history'
159
181
    history = get_url('/.bzr/revision-history').readlines()
187
209
                print '  fetch %s text {%s}' % (path, text_id)
188
210
                text_f = get_url('/.bzr/text-store/%s' % text_id,
189
211
                                 compressed=True)
190
 
                got_texts.add(text_id)
 
212
                got_texts[text_id] = True
191
213
 
192
 
            got_invs.add(inv_id)
 
214
            got_invs.add[inv_id] = True
193
215
 
194
216
        print '----'
195
217