/brz/remove-bazaar

To get this branch, use:
bzr branch http://gegoxaren.bato24.eu/bzr/brz/remove-bazaar

« back to all changes in this revision

Viewing changes to bzrlib/remotebranch.py

  • Committer: Martin Pool
  • Date: 2005-05-31 08:10:44 UTC
  • Revision ID: mbp@sourcefrog.net-20050531081044-0f6d28e39b8e19de
- replace Branch.lock(mode) with separate lock_read and lock_write 
  methods

Show diffs side-by-side

added added

removed removed

Lines of Context:
bzrlib/remotebranch.py
38
38
 
39
39
ENABLE_URLGRABBER = True
40
40
 
41
 
from bzrlib.errors import BzrError
42
 
 
43
 
class GetFailed(BzrError):
44
 
    def __init__(self, url, status):
45
 
        BzrError.__init__(self, "Get %s failed with status %s" % (url, status))
46
 
        self.url = url
47
 
        self.status = status
48
41
 
49
42
if ENABLE_URLGRABBER:
50
43
    import urlgrabber
57
50
                url += '.gz'
58
51
            mutter("grab url %s" % url)
59
52
            url_f = urlgrabber.urlopen(url, keepalive=1, close_connection=0)
60
 
            if url_f.status != 200:
61
 
                raise GetFailed(url, url_f.status)
62
53
            if not compressed:
63
54
                return url_f
64
55
            else:
118
109
 
119
110
        self.inventory_store = RemoteStore(baseurl + '/.bzr/inventory-store/')
120
111
        self.text_store = RemoteStore(baseurl + '/.bzr/text-store/')
121
 
        self.revision_store = RemoteStore(baseurl + '/.bzr/revision-store/')
122
112
 
123
113
    def __str__(self):
124
114
        b = getattr(self, 'baseurl', 'undefined')
132
122
        return get_url(self.baseurl + '/.bzr/' + filename, False)
133
123
 
134
124
 
135
 
    def lock_read(self):
136
 
        # no locking for remote branches yet
137
 
        pass
138
 
 
139
 
    def lock_write(self):
140
 
        from errors import LockError
141
 
        raise LockError("write lock not supported for remote branch %s"
142
 
                        % self.baseurl)
 
125
    def lock(self, mode):
 
126
        if mode != 'r':
 
127
            raise BzrError('lock mode %r not supported for remote branch %r' % (mode, self))
143
128
 
144
129
    def unlock(self):
145
130
        pass
152
137
        pl = len(self.baseurl)
153
138
        return path[pl:].lstrip('/')
154
139
 
155
 
 
156
140
    def get_revision(self, revision_id):
157
 
        from bzrlib.revision import Revision
158
 
        from bzrlib.xml import unpack_xml
159
 
        revf = self.revision_store[revision_id]
160
 
        r = unpack_xml(Revision, revf)
 
141
        from revision import Revision
 
142
        revf = get_url(self.baseurl + '/.bzr/revision-store/' + revision_id,
 
143
                       True)
 
144
        r = Revision.read_xml(revf)
161
145
        if r.revision_id != revision_id:
162
146
            raise BzrCheckError('revision stored as {%s} actually contains {%s}'
163
147
                                % (revision_id, r.revision_id))
176
160
        
177
161
    def __getitem__(self, fileid):
178
162
        p = self._path(fileid)
179
 
        try:
180
 
            return get_url(p, compressed=True)
181
 
        except:
182
 
            raise KeyError(fileid)
 
163
        return get_url(p, compressed=True)
183
164
    
184
165
 
 
166
def simple_walk():
 
167
    """For experimental purposes, traverse many parts of a remote branch"""
 
168
    from revision import Revision
 
169
    from branch import Branch
 
170
    from inventory import Inventory
 
171
 
 
172
    got_invs = {}
 
173
    got_texts = {}
 
174
 
 
175
    print 'read history'
 
176
    history = get_url('/.bzr/revision-history').readlines()
 
177
    num_revs = len(history)
 
178
    for i, rev_id in enumerate(history):
 
179
        rev_id = rev_id.rstrip()
 
180
        print 'read revision %d/%d' % (i, num_revs)
 
181
 
 
182
        # python gzip needs a seekable file (!!) but the HTTP response
 
183
        # isn't, so we need to buffer it
 
184
 
 
185
        rev_f = get_url('/.bzr/revision-store/%s' % rev_id,
 
186
                        compressed=True)
 
187
 
 
188
        rev = Revision.read_xml(rev_f)
 
189
        print rev.message
 
190
        inv_id = rev.inventory_id
 
191
        if inv_id not in got_invs:
 
192
            print 'get inventory %s' % inv_id
 
193
            inv_f = get_url('/.bzr/inventory-store/%s' % inv_id,
 
194
                            compressed=True)
 
195
            inv = Inventory.read_xml(inv_f)
 
196
            print '%4d inventory entries' % len(inv)
 
197
 
 
198
            for path, ie in inv.iter_entries():
 
199
                text_id = ie.text_id
 
200
                if text_id == None:
 
201
                    continue
 
202
                if text_id in got_texts:
 
203
                    continue
 
204
                print '  fetch %s text {%s}' % (path, text_id)
 
205
                text_f = get_url('/.bzr/text-store/%s' % text_id,
 
206
                                 compressed=True)
 
207
                got_texts[text_id] = True
 
208
 
 
209
            got_invs.add[inv_id] = True
 
210
 
 
211
        print '----'
 
212
 
 
213
 
 
214
def try_me():
 
215
    BASE_URL = 'http://bazaar-ng.org/bzr/bzr.dev/'
 
216
    b = RemoteBranch(BASE_URL)
 
217
    ## print '\n'.join(b.revision_history())
 
218
    from log import show_log
 
219
    show_log(b)
 
220
 
 
221
 
 
222
if __name__ == '__main__':
 
223
    try_me()
185
224