Function report_func

python/tests/stress_test_db.py:38–39

(replier, report_type, *report_args)

    report_queue = Queue()

    def report_func(replier, report_type, *report_args):
        report_queue.put((replier, report_type, report_args))

    # each replier receives all events and sends report events to receive_queue
    repliers = []