161     def __init__(self, db, cursor, upstream):  argument
164         self.upstream = upstream
168     def __init__(self, reader, writer, db, request_stats, backfill_queue, upstream, read_only):  argument
174         self.upstream = upstream
195         if self.upstream is not None:
196             self.upstream_client = await create_async_client(self.upstream)
323             upstream = None
355                     upstream = await self.upstream_client.get_unihash(method, taskhash)
356                     if upstream:
357                         msg = ("%s\n" % upstream).encode("utf-8")
372             if upstream is not None:
423                     # Query upstream to see if it has a unihash we can use
515     def __init__(self, db, upstream=None, read_only=False):  argument
516         if upstream and read_only:
517             raise bb.asyncrpc.ServerError("Read-only hashserv cannot pull from an upstream server")
523         self.upstream = upstream
527 …nt(reader, writer, self.db, self.request_stats, self.backfill_queue, self.upstream, self.read_only)
532             client = await create_async_client(self.upstream)
549         if self.upstream is not None: