Searched refs:transport (Results 1 - 25 of 28) sorted by relevance

12

/pkg/src/util/qual-simulator/
H A DMakefile29 cp ../../modules/client/transport/stats.py .
/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_https.py43 from pkg.client.transport.exception import TransportFailures
/pkg/src/modules/publish/
H A Dtransaction.py202 """Provides a publishing interface that uses client transport."""
218 self.transport = xport
238 if self.transport.publish_cache_contains(self.publisher):
271 self.transport.publish_cache_repository(self.publisher, repo)
303 self.transport.publish_add(self.publisher,
374 self.transport.cfg.max_transfer_checks:
378 csize, chashes = self.transport.get_compressed_attrs(
511 self.transport.publish_add_file(self.publisher,
531 self.transport.publish_add_manifest(self.publisher,
561 state, fmri = self.transport
[all...]
/pkg/src/
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 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 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/util/publish/
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,
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 Dpkglint.py48 import pkg.client.transport.exception as tx namespace
/pkg/src/modules/client/
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...]
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 Dapi.py222 instance._img.transport.stats.dump()
686 self._img.transport.stats.dump()
1116 self._img.transport.stats.dump()
2760 self._img.transport.stats.dump()
3012 errors contacting this repository are stored in the transport
3038 self._img.transport.stats.dump()
3294 pubs = self._img.transport.get_publisherdata(
3366 pub.transport = self._img.transport
4515 self._img.transport
[all...]
H A Dpkgplan.py551 mfile = self.image.transport.multi_file(self.destination_fmri,
572 dest.data = self.image.transport.action_cached(fmri,
H A Dimageconfig.py53 from pkg.client.transport.exception import TransportFailures
134 # Publisher transport information.
225 # Publisher transport information.
1078 def __init__(self, img_cfg, pkg_counts, imgdir, transport,
1089 The 'transport' object is the image's transport.
1146 # pkg.client.transport.engine.CurlTransportEngine.__setup_handle(..)
1147 # pkg.client.transport.repo.get_syspub_info(..)
1152 pubs, props = transport.get_syspub_data(
H A Dimageplan.py213 if self.image.transport:
214 self.image.transport.shutdown()
3587 return self.image.transport.get_content(pub, hash_val,
3672 self.image.transport.prefetch_manifests(prefetch_mfsts,
4742 self.image.transport.stats.reset()
4802 self.image.transport.shutdown()
/pkg/src/modules/client/transport/
H A Dmdetect.py32 import pkg.client.transport.exception as tx namespace
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 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 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/modules/actions/
H A Dlicense.py199 any required transport operations.
223 return img.transport.get_content(alt_pub, hash_attr_val,
H A Dfile.py123 data = pkgplan.image.transport.get_datastream(pub,
/pkg/src/modules/
H A Dpipeutils.py373 a pipe as a transport. We override the minimum number of parent
387 a pipe as a transport. We override the minimum number of parent
424 self.__pipe_file = PipeFile(fd, "client-transport")
443 """Close the pipe associated with this transport."""
489 self.__pipe_file = PipeFile(fd, "server-transport")
650 transport=self.__piped_transport,

Completed in 277 milliseconds

12