equal
deleted
inserted
replaced
136 class httppeer(wireproto.wirepeer): |
136 class httppeer(wireproto.wirepeer): |
137 def __init__(self, ui, path): |
137 def __init__(self, ui, path): |
138 self._path = path |
138 self._path = path |
139 self._caps = None |
139 self._caps = None |
140 self._urlopener = None |
140 self._urlopener = None |
141 self._requestbuilder = None |
141 # This is an its own attribute to facilitate extensions overriding |
|
142 # the default type. |
|
143 self._requestbuilder = urlreq.request |
142 u = util.url(path) |
144 u = util.url(path) |
143 if u.query or u.fragment: |
145 if u.query or u.fragment: |
144 raise error.Abort(_('unsupported URL component: "%s"') % |
146 raise error.Abort(_('unsupported URL component: "%s"') % |
145 (u.query or u.fragment)) |
147 (u.query or u.fragment)) |
146 |
148 |
149 |
151 |
150 self._ui = ui |
152 self._ui = ui |
151 ui.debug('using %s\n' % self._url) |
153 ui.debug('using %s\n' % self._url) |
152 |
154 |
153 self._urlopener = urlmod.opener(ui, authinfo) |
155 self._urlopener = urlmod.opener(ui, authinfo) |
154 self._requestbuilder = urlreq.request |
|
155 |
156 |
156 def __del__(self): |
157 def __del__(self): |
157 urlopener = getattr(self, '_urlopener', None) |
158 urlopener = getattr(self, '_urlopener', None) |
158 if urlopener: |
159 if urlopener: |
159 for h in urlopener.handlers: |
160 for h in urlopener.handlers: |