Searched refs:pub (Results 1 - 25 of 69) sorted by relevance

123

/pkg/src/modules/server/
H A Dface.py60 def feed(depot, request, response, pub):
64 if not depot.repo.get_catalog(pub).updates:
67 return pkg.server.feed.handle(depot, request, response, pub)
69 def __render_template(depot, request, path, pub, http_depot=None):
71 base = api.BaseInterface(request, depot, pub)
75 "pub": pub, "http_depot": http_depot}))
87 def respond(depot, request, response, pub, http_depot=None):
92 if pub and os.path.exists(os.path.join(depot.web_root, pub))
[all...]
H A Dfeed.py210 def get_updates_needed(repo, ts, pub):
215 c = repo.get_catalog(pub)
245 def update(request, depot, last, cf, pub):
261 cat = depot.repo.get_catalog(pub)
293 for name in reversed(get_updates_needed(depot.repo, feed_ts, pub)):
306 def __get_cache_pathname(depot, pub):
307 if not pub:
309 return os.path.join(depot.tmp_root, "publisher", pub, CACHE_FILENAME)
311 def __clear_cache(depot, pub):
312 if not pub
[all...]
H A Ddepot.py248 for pub in self.repo.publishers:
249 pub = pub.replace(".", "_")
250 pubattr = getattr(self, pub, None)
253 setattr(self, pub, pubattr)
346 pub = self.repo.get_publisher(prefix)
348 # Couldn't get pub.
351 repo = pub.repository
415 pub = self._get_req_pub()
417 if not pub an
[all...]
H A Drepository.py384 file_root=None, log_obj=None, mirror=False, pub=None,
409 self.publisher = pub
1345 p5ipath = os.path.join(self.root, "pub.p5i")
1806 def update_publisher(self, pub):
1818 p5ipath = os.path.join(self.root, "pub.p5i")
1844 p5i.write(ef, [pub])
1852 p5i.write(fp, [pub])
1931 "permissions is shown.").format(reason["pub"])
1932 del reason["pub"]
2054 def __verify_signature(self, path, pfmri, pub, trust_anchor
[all...]
/pkg/src/tests/api/
H A Dt_p5i.py104 pub = publisher.Publisher("bobcat", alias="cat",
107 return pub
113 pub = self.__get_bobcat_pub()
125 p5i.write(fobj, [pub], pkg_names=pnames)
141 pub, pkg_names = results[0]
143 self.assertEqual(pub.prefix, "bobcat")
144 self.assertEqual(pub.alias, "cat")
145 repo = pub.repository
155 pub, pkg_names = results[1]
156 self.assertEqual(pub, Non
[all...]
H A Dt_imageconfig.py77 pub = self.ic.publishers["sfbay.sun.com"]
78 self.assertEqual(pub.alias, "zruty")
79 repo = pub.repository
97 self.assertNotEqual(pub.client_uuid, None)
104 pub = self.ic.publishers["sfbay.sun.com"]
105 uuid = pub.client_uuid
H A Dt_api_refresh.py87 pub = api_obj.get_publishers()[0]
90 ts1 = pub.catalog.last_modified
93 statedir = pub.catalog.meta_root
107 pub = api_obj.get_publishers()[0]
108 ts2 = pub.catalog.last_modified
117 pub = api_obj.get_publishers()[0]
118 ts2 = pub.catalog.last_modified
125 pub = api_obj.get_publishers()[0]
126 ts2 = pub.catalog.last_modified
194 pub
[all...]
H A Dt_api.py370 pub = api_obj.get_publisher(prefix="bobcat")
371 self.assertEqual(pub.prefix, "bobcat")
383 self.assertEqual(pub.prefix, pubs[0].prefix)
384 self.assertEqual(id(pub), id(pubs[0]))
388 self.assertNotEqual(id(pub), id(cpub))
401 pub = api_obj.get_publisher(prefix="bobcat")
402 self.assertEqual(pub.alias, "cat")
403 repo = pub.repository
412 cpub = api_obj.get_publisher(alias=pub.alias, duplicate=True)
414 self.assertEqual(getattr(pub,
[all...]
/pkg/src/tests/cli/
H A Dt_publish_api.py58 pub = publisher.Publisher(prefix="repo1", repository=repo)
60 xport_cfg.add_publisher(pub)
68 xport=xport, pub=pub)
84 pub = publisher.Publisher(prefix="repo1", repository=repo)
86 xport_cfg.add_publisher(pub)
94 xport=xport, pub=pub)
H A Dt_pkg_depotd.py295 pub, name, ver = pfmri.tuple()
314 self.assertEqual(info_dic["Publisher"], pub)
599 def get_feed(durl, pub=""):
603 if pub:
604 pub = "{0}/".format(pub)
607 pub))
618 pub = repo.get_publisher("test")
619 pub_repo = pub.repository
622 pub
[all...]
/pkg/src/modules/client/
H A Dsigpolicy.py49 def process_signatures(self, sigs, acts, pub, trust_anchors,
52 ("acts") using the publisher ("pub") as the repository for
100 def process_signatures(self, sigs, acts, pub, trust_anchors,
107 s.retrieve_chain_certs(pub)
119 def process_signatures(self, sigs, acts, pub, trust_anchors,
126 s.verify_sig(acts, pub, trust_anchors, use_crls)
137 def process_signatures(self, sigs, acts, pub, trust_anchors,
148 bool(s.verify_sig(acts, pub, trust_anchors,
152 raise apx.RequiredSignaturePolicyException(pub)
172 def process_signatures(self, sigs, acts, pub, trust_anchor
[all...]
H A Dimage.py615 for pub in self.cfg.publishers.values():
619 repo = pub.repository
646 for pub in self.cfg.publishers.values():
650 repo = pub.repository
1164 """Returns a list of tuples of the form (dir, readonly, pub,
1167 be written to, 'pub' is the prefix of the publisher that
1170 If 'pub' is None, the cache directory is intended for all
1192 for pub in self.gen_publishers(inc_disabled=True):
1193 froot = os.path.join(pub.meta_root, "file")
1197 cdirs.append((froot, readonly, pub
[all...]
H A Dapi.py3129 (pub, stem, ver), entry, actions = t
3187 pub, stem, ver = t
3259 pub, stem, ver = t
3360 for pub in pubs:
3363 meta_root = os.path.join(tmpdir, str(id(pub)))
3365 pub.meta_root = meta_root
3366 pub.transport = self._img.transport
3367 repo = pub.repository
3371 progtrack.refresh_start_pub(pub)
3373 pub
[all...]
/pkg/src/modules/client/transport/
H A Dtransport.py92 def add_cache(self, path, layout=None, pub=None, readonly=True):
97 specified 'pub', its 'readonly' status will be updated.
104 'pub' is an optional publisher prefix to restrict usage of this
110 can exist for each 'pub' at a time."""
115 if not pub:
116 pub = "__all"
118 pub_caches = self.__caches.setdefault(pub, [])
159 def get_caches(self, pub=None, readonly=True):
164 'pub' is an optional publisher prefix. If provided, caches
175 if isinstance(pub, publishe
[all...]
H A Drepo.py45 import pkg.client.publisher as pub namespace
60 def do_search(self, data, header=None, ccancel=None, pub=None):
66 progtrack=None, pub=None, revalidate=False, redownload=False):
80 def get_datastream(self, fhash, version, header=None, ccancel=None, pub=None):
86 def get_files(self, filelist, dest, progtrack, version, header=None, pub=None):
94 def get_manifest(self, fmri, header=None, ccancel=None, pub=None):
101 def get_manifests(self, mfstlist, dest, progtrack=None, pub=None):
177 def publish_rebuild(self, header=None, pub=None):
183 def publish_rebuild_indexes(self, header=None, pub=None):
188 def publish_rebuild_packages(self, header=None, pub
[all...]
/pkg/src/util/apache2/sysrepo/
H A Dsysrepo_p5p.py119 def need_update(self, pub, hsh):
126 "{htdocs_path}/{pub}/{hsh}/sysrepo.timestamp".format(
169 def _file_response(self, path, pub):
176 pub=pub)
182 def _catalog_response(self, path, pub, hsh):
188 "{htdocs_path}/{pub}/{hsh}/catalog/1/{cat_part}".format(
205 pub=pub)
220 def _manifest_response(self, path, pub)
[all...]
/pkg/src/svc/
H A Dsvc-pkg-mirror231 typeset pub=$2
236 $PKGREPO -s "$repo" set publisher/prefix=$pub
297 pub=${publishers[$i]}
298 sslkey=$($PKG -R $ref_image publisher $pub \
301 sslcert=$($PKG -R $ref_image publisher $pub \
315 if [ "$pub" != "$publisher" ]; then
320 configured for publisher $pub"
338 pubs[$index]=$pub
354 pub=${pubs[$i]}
363 "$https_proxy" "$clone" "$pub"
[all...]
/pkg/src/modules/
H A Dp5p.py703 pub = self.__pubs.get(pfmri.publisher,
705 if not pub:
707 pub = repo.get_publisher(
709 assert pub
759 def extract_catalog1(self, part, path, pub=None):
768 'pub' is an optional publisher prefix. If not provided, the
778 if not pub or p.prefix == pub
783 if not pub:
785 pub
[all...]
H A Dcatalog.py439 (pub, stem)
440 for pub in self.publishers(pubs=pubs)
441 for stem in self.__data[pub]
446 (pub, stem, self.__data[pub][stem][-1])
447 for pub, stem in stems
452 (pub, stem, entry)
453 for pub, stem in stems
454 for entry in reversed(self.__data[pub][stem])
457 (pub, ste
[all...]
H A Dp5s.py108 pub = publisher.Publisher(prefix, alias=alias,
112 pub.properties["signature-policy"] = v
115 pub.properties["signature-required-names"] = v
140 pub.repository = repo
141 pubs.append(pub)
/pkg/src/
H A Dpkgrepo.py268 for pub in packages:
270 _("Removing packages for publisher {0} ...").format(pub))
271 repo.remove_packages(packages[pub], progtrack=progtrack,
272 pub=pub)
323 pub = "target"
325 pub = prefix
328 src_pub = transport.setup_publisher(str(repo_uri), pub, xport,
683 for pub in pub_data:
684 pub_idx[pub
[all...]
H A Dpublish.py178 xport, pub = setup_transport_and_pubs(repo_uri, remote=False)
182 repo_props=repo_props, xport=xport, pub=pub)
214 xport, pub = setup_transport_and_pubs(repo_uri)
216 t = trans.Transaction(repo_uri, pkg_name=pargs[0], xport=xport, pub=pub)
244 xport, pub = setup_transport_and_pubs(repo_uri)
246 t = trans.Transaction(repo_uri, pkg_name=pargs[0], xport=xport, pub=pub)
279 xport, pub
[all...]
H A Dsysrepo.py296 for pub in api_inst.get_publishers():
297 if pub.disabled:
299 repo = pub.repository
306 if pub.prefix not in no_uri_pubs:
308 pub.prefix, no_uri_pubs))
439 # map URIs to (pub.prefix, cert, key, hash, proxy, utype) tuples
444 for pub in api_inst.get_publishers():
445 if pub.disabled:
448 prefix = pub.prefix
449 repo = pub
[all...]
/pkg/src/util/publish/
H A Dpkgsurf.py245 def get_manifest(repo, pub, pfmri):
246 """ Retrieve a manifest with FMRI 'pfmri' of publisher 'pub' from
249 path = repo.manifest(pfmri, pub)
403 def do_reversion(pub, ref_pub, target_repo, ref_xport, changes, ignores,
410 target_cat = target_repo.get_catalog(pub=pub)
473 dm = get_manifest(target_repo, pub, pfmri)
638 opath = target_repo.manifest(latest_pkgs[p], pub)
640 path = target_repo.manifest(pfmri, pub)
657 omani = get_manifest(target_repo, pub, pfmr
[all...]
H A Dpkgmerge.py161 def load_catalog(repouri, pub):
164 pub.repository.origins = [repouri]
165 pub.refresh(full_refresh=True, immediate=True)
170 for entry in pub.catalog.fmris_by_version(name)
172 for name in pub.catalog.names()
176 pub.remove_meta_root()
179 pub.repository = pub.repository
192 mfst_str = xport.get_manifest(fmri, pub=repouri, content_only=True)
313 known_pubs = set([pub
[all...]

Completed in 121 milliseconds

123