Code

Implementation of Mempool Syncer#2832

Code

Open

Eligioo wants to merge 14 commits intoalbatrossnimiq/core-rs-albatross:albatrossfrom stefan/mempool-syncernimiq/core-rs-albatross:stefan/mempool-syncerCopy head branch name to clipboard

+1,222-107

Commits

Commits on Dec 10, 2024

• Mempool syncer: implementation.

  Show description for c623925
  Eligioo

  committed
  c623925

  Copy full SHA for c623925

• Utils: extend FuturesOrdered and FuturesUnordered wrappers with extend method

  Eligioo

  committed
  d88dedf

  Copy full SHA for d88dedf

• Mempool syncer: organize tests

  Eligioo

  committed
  62e256c

  Copy full SHA for 62e256c

• Mempool syncer: prevent flooding peers with requests

  Eligioo

  committed
  fca23e2

  Copy full SHA for fca23e2

• Consensus: mechanism to be able to subscribe for consensus sync events

  Eligioo

  committed
  17ac4d3

  Copy full SHA for 17ac4d3

• Mempool task: subscribe to consensus sync and network events to maintain a collection of peers that are in live sync

  Eligioo

  committed
  4cc6e50

  Copy full SHA for 4cc6e50

• Mempool syncer: spawn request handlers regardless of whether the mempool syncer is active

  Eligioo

  committed
  87e2b67

  Copy full SHA for 87e2b67

• Mempool syncer: functionality to add peers to discover its mempool

  Eligioo

  committed
  c3c8dae

  Copy full SHA for c3c8dae

• Consensus: acquire the consensus sync event subscription through the ConsensusProxy rather than the Consensus directly

  Eligioo

  committed
  6f3f67d

  Copy full SHA for 6f3f67d

• Test utils: move consensus constructor into the test_utils crate

  Eligioo

  committed
  06a2151

  Copy full SHA for 06a2151

• Mempool syncer: subscribe to consensus sync events in order add new peers dynamically

  Eligioo

  committed
  1a8079b

  Copy full SHA for 1a8079b

• Mempool syncer: minor improvements

  Show description for 6442d0d
  Eligioo

  committed
  6442d0d

  Copy full SHA for 6442d0d

• Mempool syncer: check peer for necessary service flag when adding it dynamically

  Eligioo

  committed
  0a950b9

  Copy full SHA for 0a950b9

• Mempool syncer: fix merge conflicts

  Eligioo

  committed
  0bc22d5

  Copy full SHA for 0bc22d5