Cross Reference: /pkg/src/modules/client/transport/engine.py

Lines Matching refs:url
98                         eh.url = None
125         def add_url(self, url, filepath=None, writefunc=None, header=None,
137                 'proxy' is the persistent proxy value for this url and is
143                 t = TransportRequest(url, filepath=filepath,
192                                 url = h.url
195                                 ex = tx.TransportStallError(url,
237                         url = h.url
240                         proto = urlsplit(url)[0]
304                                     url, reason=proto_reason, repourl=urlstem,
310                                 ex = tx.TransportFrameworkError(en, url, em,
334                         url = h.url
337                         proto = urlsplit(url)[0]
388                                 success.append(url)
398                                     respcode, url, reason=proto_reason,
417                                             url=url, reason=reason,
459                                 raise tx.ExcessiveTransientFailure(rs.url,
502                     if hasattr(tf, "url") and tf.url in urllist
525         def get_url(self, url, header=None, sslcert=None, sslkey=None,
535                 'proxy' is the persistent proxy value for this url and is
545                 fobj = fileobj.StreamingFileObj(url, self, ccancel=ccancel)
551                 t = TransportRequest(url, writefunc=fobj.get_write_func(),
562         def get_url_header(self, url, header=None, sslcert=None, sslkey=None,
570                 'proxy' is the persistent proxy value for this url and is
577                 fobj = fileobj.StreamingFileObj(url, self, ccancel=ccancel)
583                 t = TransportRequest(url, writefunc=fobj.get_write_func(),
630                         url, uuid = self.__orphans.pop()
631                         self.remove_request(url, uuid)
653         def orphaned_request(self, url, uuid):
661                 self.__orphans.add((url, uuid))
663         def remove_request(self, url, uuid):
671                         if h.url == url and h.uuid == uuid and \
687                         if t.url == url and t.uuid == uuid:
692                         if ex.url == url and ex.uuid == uuid:
720         def send_data(self, url, data=None, header=None, sslcert=None,
734                 fobj = fileobj.StreamingFileObj(url, self, ccancel=ccancel)
740                 t = TransportRequest(url, writefunc=fobj.get_write_func(),
862                 # Set request url.  Also set attribute on handle.
863                 hdl.setopt(pycurl.URL, treq.url)
864                 hdl.url = treq.url
867                 # The repourl is the url stem that identifies the
898                             " function.".format(treq.url))
913                 proto = urlsplit(treq.url)[0]
954                                     "is required.".format(treq.url))
967                                     "required.".format(treq.url))
1048                 hdl.url = None
1063         def __init__(self, url, filepath=None, writefunc=None,
1071                 url - The url that the transport engine should retrieve
1125                 It's a subset of url.  It's also used by the stats system.
1153                 TransportRepoURI.key() which is currently the (url, proxy)
1157                 self.url = url