← 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-09-13 05:22:41 UTC
  • Revision ID: mbp@sourcefrog.net-20050913052241-52dbd8e8ced620f6
- better BZR_DEBUG trace output

Show diffs side-by-side

added added

removed removed

Lines of Context:
bzrlib/remotebranch.py
26
26
 
27
27
import gzip
28
28
from cStringIO import StringIO
29
 
import os
30
29
import urllib2
31
 
import urlparse
32
30
 
33
31
from bzrlib.errors import BzrError, BzrCheckError
34
 
from bzrlib.branch import Branch, BZR_BRANCH_FORMAT
 
32
from bzrlib.branch import Branch, BZR_BRANCH_FORMAT_5
35
33
from bzrlib.trace import mutter
36
 
from bzrlib.xml import serializer_v4
 
34
from bzrlib.xml5 import serializer_v5
 
35
 
 
36
# velocitynet.com.au transparently proxies connections and thereby
 
37
# breaks keep-alive -- sucks!
37
38
 
38
39
 
39
40
ENABLE_URLGRABBER = False
84
85
    orig_url = url
85
86
    while True:
86
87
        try:
87
 
            fmt_url = url + '/.bzr/branch-format'
88
 
            ff = get_url(fmt_url)
 
88
            ff = get_url(url + '/.bzr/branch-format')
 
89
 
89
90
            fmt = ff.read()
90
91
            ff.close()
91
92
 
92
 
            fmt = fmt.rstrip('\r\n')
93
 
            if fmt != BZR_BRANCH_FORMAT.rstrip('\r\n'):
 
93
            if fmt != BZR_BRANCH_FORMAT_5:
94
94
                raise BzrError("sorry, branch format %r not supported at url %s"
95
95
                               % (fmt, url))
96
96
            
98
98
        except urllib2.URLError:
99
99
            pass
100
100
 
101
 
        scheme, host, path = list(urlparse.urlparse(url))[:3]
102
 
        # discard params, query, fragment
103
 
        
104
 
        # strip off one component of the path component
105
 
        idx = path.rfind('/')
106
 
        if idx == -1 or path == '/':
107
 
            raise BzrError('no branch root found for URL %s'
108
 
                           ' or enclosing directories'
109
 
                           % orig_url)
110
 
        path = path[:idx]
111
 
        url = urlparse.urlunparse((scheme, host, path, '', '', ''))
 
101
        try:
 
102
            idx = url.rindex('/')
 
103
        except ValueError:
 
104
            raise BzrError('no branch root found for URL %s' % orig_url)
 
105
 
 
106
        url = url[:idx]        
112
107
        
113
108
 
114
109
 
116
111
    def __init__(self, baseurl, find_root=True):
117
112
        """Create new proxy for a remote branch."""
118
113
        if find_root:
119
 
            self.base = _find_remote_root(baseurl)
 
114
            self.baseurl = _find_remote_root(baseurl)
120
115
        else:
121
 
            self.base = baseurl
 
116
            self.baseurl = baseurl
122
117
            self._check_format()
123
118
 
124
119
        self.inventory_store = RemoteStore(baseurl + '/.bzr/inventory-store/')
134
129
    def controlfile(self, filename, mode):
135
130
        if mode not in ('rb', 'rt', 'r'):
136
131
            raise BzrError("file mode %r not supported for remote branches" % mode)
137
 
        return get_url(self.base + '/.bzr/' + filename, False)
 
132
        return get_url(self.baseurl + '/.bzr/' + filename, False)
138
133
 
139
134
 
140
135
    def lock_read(self):
144
139
    def lock_write(self):
145
140
        from errors import LockError
146
141
        raise LockError("write lock not supported for remote branch %s"
147
 
                        % self.base)
 
142
                        % self.baseurl)
148
143
 
149
144
    def unlock(self):
150
145
        pass
151
146
    
152
147
 
153
148
    def relpath(self, path):
154
 
        if not path.startswith(self.base):
 
149
        if not path.startswith(self.baseurl):
155
150
            raise BzrError('path %r is not under base URL %r'
156
 
                           % (path, self.base))
157
 
        pl = len(self.base)
 
151
                           % (path, self.baseurl))
 
152
        pl = len(self.baseurl)
158
153
        return path[pl:].lstrip('/')
159
154
 
160
155
 
161
156
    def get_revision(self, revision_id):
 
157
        from bzrlib.revision import Revision
162
158
        try:
163
159
            revf = self.revision_store[revision_id]
164
160
        except KeyError:
165
161
            raise NoSuchRevision(self, revision_id)
166
 
        r = serializer_v4.read_revision(revf)
 
162
        r = serializer_v5.read_revision(revf)
167
163
        if r.revision_id != revision_id:
168
164
            raise BzrCheckError('revision stored as {%s} actually contains {%s}'
169
165
                                % (revision_id, r.revision_id))
184
180
        p = self._path(fileid)
185
181
        try:
186
182
            return get_url(p, compressed=True)
187
 
        except urllib2.URLError:
 
183
        except:
188
184
            raise KeyError(fileid)
189
185
    
190
186