def sync_mempools(self, nodes=None, wait=1, timeout=60, flush_scheduler=True):
    '\n        Wait until everybody has the same transactions in their memory\n        pools\n        '
    rpc_connections = (nodes or self.nodes)
    stop_time = (time.time() + timeout)
    while (time.time() <= stop_time):
        pool = [set(r.getrawmempool()) for r in rpc_connections]
        if (pool.count(pool[0]) == len(rpc_connections)):
            if flush_scheduler:
                for r in rpc_connections:
                    r.syncwithvalidationinterfacequeue()
            return
        assert all([len(x.getpeerinfo()) for x in rpc_connections])
        time.sleep(wait)
    raise AssertionError('Mempool sync timed out after {}s:{}'.format(timeout, ''.join(('\n  {!r}'.format(m) for m in pool))))
Wait until everybody has the same transactions in their memory
pools
def sync_mempools(self, nodes=None, wait=1, timeout=60, flush_scheduler=True):
    '\n        Wait until everybody has the same transactions in their memory\n        pools\n        '
    rpc_connections = (nodes or self.nodes)
    stop_time = (time.time() + timeout)
    while (time.time() <= stop_time):
        pool = [set(r.getrawmempool()) for r in rpc_connections]
        if (pool.count(pool[0]) == len(rpc_connections)):
            if flush_scheduler:
                for r in rpc_connections:
                    r.syncwithvalidationinterfacequeue()
            return
        assert all([len(x.getpeerinfo()) for x in rpc_connections])
        time.sleep(wait)
    raise AssertionError('Mempool sync timed out after {}s:{}'.format(timeout, .join(('\n  {!r}'.format(m) for m in pool))))