def METHOD_NAME(self):
    self.log.info(
        "Test that we request transactions from all our peers, eventually"
    )
    txid = 0xDEADBEEF
    self.log.info("Announce the txid from each incoming peer to node 0")
    msg = msg_inv([CInv(t=1, h=txid)])
    for p in self.nodes[0].p2ps:
        p.send_message(msg)
        p.sync_with_ping()
    outstanding_peer_index = [i for i in range(len(self.nodes[0].p2ps))]
    def getdata_found(peer_index):
        p = self.nodes[0].p2ps[peer_index]
        with mininode_lock:
            return (
                p.last_message.get("getdata")
                and p.last_message["getdata"].inv[-1].hash == txid
            )
    node_0_mocktime = int(time.time())
    while outstanding_peer_index:
        node_0_mocktime += MAX_GETDATA_INBOUND_WAIT
        self.nodes[0].setmocktime(node_0_mocktime)
        wait_until(lambda: any(getdata_found(i) for i in outstanding_peer_index))
        for i in outstanding_peer_index:
            if getdata_found(i):
                outstanding_peer_index.remove(i)
    self.nodes[0].setmocktime(0)
    self.log.info("All outstanding peers received a getdata")