Lines Matching refs:repo
143 def __init__(self, repo, dconf, request_pub_func=None):
158 self.repo = repo
189 repo.write_config()
191 if repo.mirror or not repo.root:
193 if not repo.cfg.get_property("publisher", "prefix"):
195 elif repo.read_only:
228 if not repo.supports(op, int(ver)):
248 for pub in self.repo.publishers:
275 self.__bgtask.put(self.repo.refresh_index)
340 prefix = self.repo.cfg.get_property("publisher",
346 pub = self.repo.get_publisher(prefix)
351 repo = pub.repository
352 if repo:
353 rs = repo.refresh_seconds
378 old_pubs = self.repo.publishers
379 self.repo.reload()
389 list(map(self.__map_pub_ops, self.repo.publishers - old_pubs))
451 elif op == "open" and pub not in self.repo.publishers:
512 res_list = self.repo.search(query_str_lst,
582 fpath = self.repo.catalog_1(name,
603 pubs = self.repo.publishers
627 fpath = self.repo.manifest(pfmri,
703 fpath = self.repo.file(fhash, pub=self._get_req_pub())
752 fpath = self.repo.file(fhash,
806 trans_id = self.repo.open(client_release, pfmri)
846 trans_id = self.repo.append(client_release, pfmri)
896 pfmri, pstate = self.repo.close(trans_id,
947 self.__bgtask.put(self.repo.rebuild,
952 self.__bgtask.put(self.repo.rebuild,
957 self.__bgtask.put(self.repo.rebuild,
962 self.__bgtask.put(self.repo.add_content,
966 self.__bgtask.put(self.repo.refresh_index,
970 self.__bgtask.put(self.repo.add_content,
996 self.repo.abandon(trans_id)
1068 self.repo.add(trans_id, action)
1119 self.repo.add_file(trans_id, data, basename, size)
1151 self.repo.add_manifest(trans_id, data)
1183 self.__bgtask.put(self.repo.refresh_index,
1206 pubs = self.repo.publishers
1229 pub = self.repo.cfg.get_property(
1233 fpath = self.repo.manifest(pfmri, pub=pub)
1257 lpath = self.repo.file(entry.hash, pub=pub)
1301 pub for pub in self.repo.get_publishers()
1333 pubs = self.repo.get_publishers()
1336 pub = self.repo.get_publisher(prefix)
1362 pub = self.repo.get_publisher(rstore.publisher)
1414 pubs = self.repo.publishers
1446 for rstore in self.repo.rstores:
1469 dump_struct = self.repo.get_status()
1524 def __init__(self, repo, dconf):
1527 DepotHTTP.__init__(self, repo, dconf)
1533 self.repo.write_config()
1745 pubs = self.repo.publishers
1769 fpath = self.repo.manifest(pfmri,
1805 fpath = self.repo.file(v, pub=self._get_req_pub())
1818 fpath = self.repo.file(fhash, pub=self._get_req_pub())
1871 fpath = self.repo.catalog_1(name,