message: test: Fix intermittent rpc_net issue
diff: @@ -21,7 +21,6 @@ from test_framework.test_framework import BitcoinTestFramework
  from test_framework.util import (
  assert_approx,
  assert_equal,
  - assert_greater_than_or_equal,
  assert_greater_than,
  assert_raises_rpc_error,
  p2p_port,
  @@ -114,10 +113,10 @@ class NetTest(BitcoinTestFramework):
  self.wait_until(lambda: (self.nodes[0].getnettotals()['totalbytessent'] >= net_totals_before['totalbytessent'] + 32 * 2), timeout=1)
  self.wait_until(lambda: (self.nodes[0].getnettotals()['totalbytesrecv'] >= net_totals_before['totalbytesrecv'] + 32 * 2), timeout=1)
  - peer_info_after = self.nodes[0].getpeerinfo()
  - for before, after in zip(peer_info_before, peer_info_after):
  - assert_greater_than_or_equal(after['bytesrecv_per_msg'].get('pong', 0), before['bytesrecv_per_msg'].get('pong', 0) + 32)
  - assert_greater_than_or_equal(after['bytessent_per_msg'].get('ping', 0), before['bytessent_per_msg'].get('ping', 0) + 32)
  + for peer_before in peer_info_before:
  + peer_after = lambda: next(p for p in self.nodes[0].getpeerinfo() if p['id'] == peer_before['id'])
  + self.wait_until(lambda: peer_after()['bytesrecv_per_msg'].get('pong', 0) >= peer_before['bytesrecv_per_msg'].get('pong', 0) + 32, timeout=1)
  + self.wait_until(lambda: peer_after()['bytessent_per_msg'].get('ping', 0) >= peer_before['bytessent_per_msg'].get('ping', 0) + 32, timeout=1)
  def test_getnetworkinfo(self):
  self.log.info("Test getnetworkinfo")
  