Searched defs:transport (Results 1 - 17 of 17) sorted by relevance

/pkg/src/tests/cli/
H A Dt_publish_api.py37 import pkg.client.transport.transport as transport namespace
59 xport_cfg = transport.GenericTransportCfg()
61 xport = transport.Transport(xport_cfg)
85 xport_cfg = transport.GenericTransportCfg()
87 xport = transport.Transport(xport_cfg)
H A Dt_pkgrecv.py38 import pkg.client.transport.transport as transport namespace
570 xport, xport_cfg = transport.setup_transport()
594 xport, xport_cfg = transport.setup_transport()
1376 xport, xport_cfg = transport.setup_transport()
H A Dt_pkg_sysrepo.py39 import pkg.client.transport.exception as tx namespace
662 """Test that the transport for communicating with the depots is
/pkg/src/modules/client/transport/
H A Dmdetect.py32 import pkg.client.transport.exception as tx namespace
H A Dfileobj.py29 import pkg.client.transport.exception as tx namespace
37 transport engine. This is only necessary if the underlying
38 transport doesn't have its own streaming interface and the
267 """Used by the underlying transport before handing this
270 All callers must still catch transport exceptions, however."""
347 """Run the transport until headers arrive. When the data
372 """A callback given to transport engine that writes data
384 """A callback given to the transport engine. It reads header
385 information from the transport. This function saves
H A Dengine.py47 import pkg.client.transport.exception as tx namespace
48 import pkg.client.transport.fileobj as fileobj namespace
60 of the methods that it contains. Leave that to transport-specific
65 """Concrete class of TransportEngine for libcurl transport."""
67 def __init__(self, transport, max_conn=20):
69 # Backpointer to transport object
70 self.__xport = transport
129 """Add a URL to the transport engine. Caller must supply
138 stored as part of the transport stats accounting.
157 reset the transport an
[all...]
H A Drepo.py46 import pkg.client.transport.exception as tx namespace
55 """The TransportRepo class handles transport requests.
236 """Walk a list of transport errors, examine the
379 Repouri is a TransportRepoURI object. Engine is a transport
580 # by the transport engine as soon as they occur.
610 # We set 'system=True' to cause the transport to override any
685 # by the transport engine as soon as they occur.
739 # by the transport engine as soon as they occur.
1097 # implemented in the transport code.
1160 # repository transport issu
[all...]
H A Dtransport.py49 import pkg.client.transport.engine as engine namespace
50 import pkg.client.transport.exception as tx namespace
51 import pkg.client.transport.mdetect as mdetect namespace
52 import pkg.client.transport.repo as trepo namespace
53 import pkg.client.transport.stats as tstats namespace
73 """Contains configuration needed by the transport for proper
75 it to a transport instance when it is initialized. This is the base
89 # file needs to be uploaded for the transport.
318 # should be ok as transport will
335 # later when transport attempt
[all...]
/pkg/src/util/publish/
H A Dpkglint.py48 import pkg.client.transport.exception as tx namespace
H A Dpkgmerge.py47 import pkg.client.transport.transport as transport namespace
295 # initialize transport
296 # we use a single endpoint for now, since the transport code
302 xport, xport_cfg = transport.setup_transport()
308 transport.setup_publisher(source_list,
338 pub.transport = xport
340 # Use separate transport for destination repository in case
342 dest_xport, dest_xport_cfg = transport
[all...]
H A Dpkgsurf.py87 import pkg.client.transport.transport as transport namespace
200 src_pub.transport = xport
418 # We use bulk prefetching for faster transport of the manifests.
427 # transport. Retryable errors during prefetch are ignored and
736 ref_xport, ref_xport_cfg = transport.setup_transport()
739 transport.setup_publisher(ref_repo_uri, "ref", ref_xport,
/pkg/src/
H A Dpublish.py52 import pkg.client.transport.transport as transport namespace
734 xport, xport_cfg = transport.setup_transport()
735 targ_pub = transport.setup_publisher(repo_uri, "default",
H A Dsign.py49 import pkg.client.transport.transport as transport namespace
110 src_pub.transport = xport
243 xport, xport_cfg = transport.setup_transport()
248 transport.setup_publisher(repo_uri, "source", xport,
H A Dpull.py48 import pkg.client.transport.transport as transport namespace
381 src_pub.transport = txport
388 # transport issue, let the failure happen whenever some other
446 if arg in ["plan", "transport", "mogrify"]:
542 # Create transport and transport config
543 xport, xport_cfg = transport.setup_transport()
548 # per publisher, create destination as separate transport i
[all...]
H A Dpkgrepo.py79 import pkg.client.transport.transport as transport namespace
316 # Create transport and transport config.
317 xport, xport_cfg = transport.setup_transport()
328 src_pub = transport.setup_publisher(str(repo_uri), pub, xport,
543 # Setup transport so configuration can be retrieved.
644 # Assign transport information.
816 # Setup transport s
[all...]
/pkg/src/modules/client/
H A Dpublisher.py142 """Class representing a repository URI and any transport-related
543 used to allow the transport to properly track repo statistics for
610 uniquely for the transport system. Normally, this would be done
615 the proxy used to reach that URI. Note that in the transport
619 made in pkg.client.transport.engine.__cleanup_requests(..)"""
671 This is to allow the transport to try different paths to
1197 transport = None variable in class:Publisher
1206 transport=None, sticky=True, props=None, revoked_ca_certs=EmptyI,
1231 self.transport = transport
[all...]
H A Dimage.py63 import pkg.client.transport.transport as transport namespace
82 from pkg.client.transport.exception import InvalidContentException
230 self.transport = transport.Transport(
231 transport.ImageTransportCfg(self))
570 self.imgdir, self.transport,
710 # This ensures all old transport configuration is thrown away.
711 self.transport
[all...]

Completed in 247 milliseconds