Mvp workflow and core modules functionality about bitconch-core HOT 5 CLOSED

Receive data from a gossip socket:
Ncp::new() --> streamer::blob_receiver() --> Blob::recv_from(sock);

from bitconch-core.

RPU(Request Processing Unit)

from bitconch-core.

NCP(Network Control Plane)

Receive packets by UDP socket
streamer::blob_receiver();

Send received packets by UDP socket
streamer::responder();

Crdt::listen();
|
handle_blob();
|
Process request based on Request Protocol defined in crdt
Crdt::handle_protocol();

from bitconch-core.

TPU(Transaction Process Unit)

workflow:

Clients --> Fetch Stage --> SigVerify Stage --> Banking Stage --> WriteStage Stage --> Validators

Fetch Stage:
Receive packet from client
streamer::receiver(socket, exit.clone(), sender.clone(), "fetch-stage"))

SigVerify Stage:
Verify received packets
let r = if sigverify_disabled {
sigverify::ed25519_verify_disabled(&batch)
} else {
sigverify::ed25519_verify(&batch)
};

Banking Stage:
Start NUM_THREADS thread to processing packets:
BankingStage::process_packets();

BankingStage::process_transactions();
bank.process_transactions();

Write Stage:
recover and open the ledger for writing
LedgerWriter::recover(ledger_path);

Process any Entry items that have been published by the RecordStage.
WriteStagei::write_and_send_entries()

vote_stage::send_leader_vote()

from bitconch-core.

Transaction Validation Unit

Fetch Stage:
Picked up incoming blobs from the replicate socket and repair socketJ:
BlobFetchStage::new_multi_socket(blob_sockets, exit.clone()); -->
streamer::blob_receiver(socket, exit.clone(), sender.clone());

Retransmit Stage:
RetransmitStage::new(
&crdt,
window,
entry_height,
Arc::new(retransmit_socket),
repair_socket,
blob_fetch_receiver,
); ----->
Crdt::retransmit(&crdt, b, sock);

Replicate Stage:
Transactions in blobs are processed and applied to the bank:
ReplicateStage::new(
keypair,
bank.clone(),
crdt,
blob_window_receiver,
ledger_path,
exit.clone(),
); --->

• streamer::responder("replicate_stage", Arc::new(send), vote_blob_receiver);
• LedgerWriter::open(p, false);

from bitconch-core.