Show More
@@ -30,6 +30,7 b' class httppeer(wireproto.wirepeer):' | |||
|
30 | 30 | self.caps = None |
|
31 | 31 | self.handler = None |
|
32 | 32 | self.urlopener = None |
|
33 | self.requestbuilder = None | |
|
33 | 34 | u = util.url(path) |
|
34 | 35 | if u.query or u.fragment: |
|
35 | 36 | raise util.Abort(_('unsupported URL component: "%s"') % |
@@ -42,6 +43,7 b' class httppeer(wireproto.wirepeer):' | |||
|
42 | 43 | self.ui.debug('using %s\n' % self._url) |
|
43 | 44 | |
|
44 | 45 | self.urlopener = url.opener(ui, authinfo) |
|
46 | self.requestbuilder = urllib2.Request | |
|
45 | 47 | |
|
46 | 48 | def __del__(self): |
|
47 | 49 | if self.urlopener: |
@@ -111,7 +113,7 b' class httppeer(wireproto.wirepeer):' | |||
|
111 | 113 | q += sorted(args.items()) |
|
112 | 114 | qs = '?%s' % urllib.urlencode(q) |
|
113 | 115 | cu = "%s%s" % (self._url, qs) |
|
114 |
req = |
|
|
116 | req = self.requestbuilder(cu, data, headers) | |
|
115 | 117 | if data is not None: |
|
116 | 118 | self.ui.debug("sending %s bytes\n" % size) |
|
117 | 119 | req.add_unredirected_header('Content-Length', '%d' % size) |
General Comments 0
You need to be logged in to leave comments.
Login now