Lines Matching defs:self
21 def __init__(self, sample): argument
24 def start(self): argument
27 def end(self): argument
30 def __enter__(self): argument
34 def __exit__(self, *args, **kwargs): argument
39 def __init__(self, stats): argument
44 def measure(self): argument
47 def __enter__(self): argument
50 def __exit__(self, *args, **kwargs): argument
53 def add(self, elapsed): argument
57 def end(self): argument
65 def __init__(self): argument
68 def reset(self): argument
76 def add(self, elapsed): argument
91 def start_sample(self): argument
95 def average(self): argument
101 def stdev(self): argument
106 def todict(self): argument
161 def __init__(self, db, cursor, upstream): argument
168 def __init__(self, reader, writer, db, request_stats, backfill_queue, upstream, read_only): argument
191 def validate_proto_version(self): argument
194 async def process_requests(self): argument
205 async def dispatch_message(self, msg): argument
219 async def handle_get(self, request): argument
229 async def get_unihash(self, cursor, method, taskhash, fetch_all=False): argument
268 async def handle_get_outhash(self, request): argument
278 async def get_outhash(self, cursor, method, outhash, taskhash): argument
304 def update_unified(self, cursor, data): argument
319 async def handle_get_stream(self, request): argument
375 async def handle_report(self, data): argument
456 async def handle_equivreport(self, data): argument
480 async def handle_get_stats(self, request): argument
487 async def handle_reset_stats(self, request): argument
495 async def handle_backfill_wait(self, request): argument
502 def query_equivalent(self, cursor, method, taskhash): argument
515 def __init__(self, db, upstream=None, read_only=False): argument
526 def accept_client(self, reader, writer): argument
530 def _backfill_worker(self): argument
558 def run_loop_forever(self): argument