MCPcopy Create free account

hub / github.com/aleph-zero-foundation/AlephBFT / functions

Functions770 in github.com/aleph-zero-foundation/AlephBFT

⨍ Functions 770◇ Types & classes 171
↓ 5 callersFunctionencode_all
(items: Vec<UncheckedSignedUnit>)
consensus/src/backup/loader.rs:206
↓ 5 callersFunctionfull_unit_to_unchecked_signed_unit
( full_unit: FullUnit, keychain: &Keychain, )
consensus/src/units/testing.rs:93
↓ 5 callersFunctionhandle_task_termination
(task_handle: T, target: &'static str, name: &'static str)
consensus/src/terminator.rs:169
↓ 5 callersMethodhash
(&self)
consensus/src/dag/reconstruction/mod.rs:49
↓ 5 callersMethodkeychain
(&self, node: NodeIndex)
consensus/src/testing/alerts.rs:86
↓ 5 callersFunctionleaf
(mut terminator: Terminator)
consensus/src/terminator.rs:190
↓ 5 callersFunctionproduce_units
(rounds: usize, session_id: SessionId)
consensus/src/backup/loader.rs:163
↓ 5 callersFunctionrandom_unit_with_parents
( creator: NodeIndex, parents: &Vec<U>, round: Round, )
consensus/src/units/testing.rs:151
↓ 5 callersFunctionreconstructed
( dag: Vec<Vec<TestingFullUnit>>, )
consensus/src/dag/reconstruction/dag.rs:144
↓ 5 callersMethodsend_message_for_network
( &mut self, notification: Addressed<DisseminationMessage<UFH::Hasher, UFH::Data, MK::Signatur
consensus/src/consensus/service.rs:188
↓ 4 callersMethodadd_unit
Add a unit to the store.
consensus/src/extension/units.rs:26
↓ 4 callersMethodcollect_multisigned_hashes
( mut self, expected_multisigs: usize, )
rmc/src/service.rs:226
↓ 4 callersMethodcontrol_hash
(&self)
consensus/src/dag/reconstruction/parents.rs:66
↓ 4 callersFunctioncreate_unit_with_minimal_parents
(n_members: NodeCount)
consensus/src/creation/creator.rs:111
↓ 4 callersMethodcrucial_channel_closed
(&mut self, channel_name: &str)
consensus/src/consensus/service.rs:83
↓ 4 callersFunctiondont_create_unit_below_parents_threshold
(n_members: NodeCount)
consensus/src/creation/creator.rs:149
↓ 4 callersFunctionfull_unit_to_signed_unit
(full_unit: FullUnit, keychain: &Keychain)
consensus/src/units/testing.rs:81
↓ 4 callersMethodget_mut
(&mut self, node_id: NodeIndex)
crypto/src/node.rs:161
↓ 4 callersMethodhash
(&self)
consensus/src/alerts/mod.rs:64
↓ 4 callersMethodhash
(&self)
consensus/src/testing/dag.rs:51
↓ 4 callersMethodin_round
Get the list of unit hashes from the given round. Panics if called for a round greater or equal to the round of the highest head of a removed batch.
consensus/src/extension/units.rs:43
↓ 4 callersMethodindex
(&self)
consensus/src/collection/service.rs:93
↓ 4 callersMethodindex
(&self)
consensus/src/dissemination/task.rs:189
↓ 4 callersMethodinto_signable
(self)
crypto/src/signature.rs:108
↓ 4 callersMethodis_complete
Chceck if the partial multisignature is complete.
crypto/src/signature.rs:377
↓ 4 callersMethodremove_batch
Remove a batch of units, deterministically ordered based on the given head.
consensus/src/extension/units.rs:58
↓ 4 callersMethodrun
( mut self, data_from_backup: Vec<UncheckedSignedUnit<UFH::Hasher, UFH::Data, MK::Signature>>,
consensus/src/consensus/service.rs:207
↓ 4 callersMethodsend_message_for_network
( &mut self, message: AlertMessage<H, D, MK::Signature, MK::PartialMultisignature>, re
consensus/src/alerts/service.rs:90
↓ 4 callersFunctiontest_message
()
crypto/src/signature.rs:511
↓ 4 callersFunctiontest_multi_keychain
(node_count: NodeCount, index: NodeIndex)
crypto/src/signature.rs:562
↓ 3 callersMethodadd_parents
Add parents of a unit to the Dag.
consensus/src/dag/mod.rs:132
↓ 3 callersFunctionalert_confirmed
(make_known: bool, good_commitment: bool)
consensus/src/alerts/handler.rs:648
↓ 3 callersMethodalready_completed
(&self, hash: &H)
rmc/src/handler.rs:125
↓ 3 callersMethodas_unit
(&self)
consensus/src/dag/reconstruction/parents.rs:70
↓ 3 callersMethodcontrol_hash
(&self)
consensus/src/dag/reconstruction/mod.rs:57
↓ 3 callersFunctioncrashed_nodes_recover
Tests that finalization continues after some nodes restart. Performs the following steps: 1. Spawns `n_members` nodes. 2. Waits for at least `n_memb
consensus/src/testing/crash_recovery.rs:178
↓ 3 callersMethodcurrent_round
(&self)
consensus/src/creation/creator.rs:24
↓ 3 callersMethoddelay_config
(&self)
consensus/src/config.rs:89
↓ 3 callersMethodelements
(&self)
crypto/src/node.rs:237
↓ 3 callersFunctionfinish
(killers: Vec<oneshot::Sender<()>>, mut handles: Vec<tokio::task::JoinHandle<()>>)
consensus/src/testing/creation.rs:115
↓ 3 callersMethodget_exit
When ready, returns reason why we should exit. `Ok` should be interpreted as "all good, our parent decided to gracefully exit". `Err` is returned when
consensus/src/terminator.rs:55
↓ 3 callersMethodhandle_dag_result
( &mut self, result: DagResult<UFH::Hasher, UFH::Data, MK>, )
consensus/src/consensus/handler.rs:105
↓ 3 callersMethodhandle_multisigned
(&mut self, multisigned: Multisigned<H::Hash, MK>)
consensus/src/alerts/service.rs:158
↓ 3 callersMethodhandle_newest_unit_request
Handle an incoming request for the newest unit of a given node we know of.
consensus/src/dissemination/responder.rs:105
↓ 3 callersMethodhandle_result
(&mut self, result: ConsensusResult<UFH::Hasher, UFH::Data, MK>)
consensus/src/consensus/service.rs:88
↓ 3 callersMethodhashes_by
(&self, creator: NodeIndex)
consensus/src/units/store.rs:59
↓ 3 callersFunctionhonest_members_agree_on_batches_byzantine
( n_members: NodeCount, n_honest: NodeCount, n_batches: usize, )
consensus/src/testing/byzantine.rs:253
↓ 3 callersMethodload_backup
( &mut self, )
consensus/src/backup/loader.rs:124
↓ 3 callersMethodon_network_alert
May return a `ForkingNotification`, which should be propagated
consensus/src/alerts/handler.rs:190
↓ 3 callersMethodon_reconstructed_unit
(&mut self, unit: ReconstructedUnit)
consensus/src/testing/dag.rs:144
↓ 3 callersMethodon_signed_hash
Update the internal state with the signed hash. If the hash is incorrectly signed then [`Error::BadSignature`] is returned. If Adding this signature c
rmc/src/handler.rs:64
↓ 3 callersFunctionpreunit_to_unchecked_signed_unit
( pu: PreUnit, session_id: SessionId, keychain: &Keychain, )
consensus/src/collection/service.rs:364
↓ 3 callersFunctionrandom_reconstructed_unit_with_parents
( creator: NodeIndex, parents: &Vec<U>, keychain: &Keychain, round: Round, )
consensus/src/units/testing.rs:163
↓ 3 callersMethodreceive
Receives the next unit finalized by this node. Appends it to `batches` and returns it.
consensus/src/testing/crash_recovery.rs:43
↓ 3 callersFunctionrun_session
Starts the consensus algorithm as an async task. It stops establishing consensus for new data items after reaching the threshold specified in [`Config
consensus/src/consensus/mod.rs:32
↓ 3 callersFunctionsetup_test
(n_members: NodeCount)
consensus/src/testing/creation.rs:61
↓ 3 callersMethodtop_round
Highest round among units in the store.
consensus/src/units/store.rs:19
↓ 3 callersMethodtry_send
(&self, message: &Message, address: &Address)
examples/blockchain/src/network.rs:207
↓ 3 callersMethodunchecked_signed_unit
( &self, creator: NodeIndex, round: Round, variant: u32, )
consensus/src/testing/alerts.rs:120
↓ 3 callersMethodunexpected_notification
(&mut self, notification: TestNotification)
consensus/src/testing/alerts.rs:197
↓ 3 callersFunctionverify_backup
(buf: &mut &[u8])
consensus/src/testing/crash_recovery.rs:142
↓ 3 callersMethodwait
(&mut self)
consensus/src/testing/alerts.rs:206
↓ 2 callersMethodaccumulate
(&mut self, other: ReconstructionResult<U>)
consensus/src/dag/reconstruction/mod.rs:184
↓ 2 callersMethodadd_task_after
(&mut self, task: T, delta: Duration)
rmc/src/scheduler.rs:89
↓ 2 callersMethodadd_unit
Add a unit to the extender. Might return several batches of ordered units as a result.
consensus/src/extension/extender.rs:43
↓ 2 callersMethodadd_voter
Add a single voter and compute their vote. This might end up electing or eliminating the candidate. Might panic if called for a unit before its parent
consensus/src/extension/election.rs:131
↓ 2 callersMethodalert_with_commitment
( &self, sender: NodeIndex, proof: TestForkProof, commitment: Vec<UncheckedSig
consensus/src/testing/alerts.rs:135
↓ 2 callersFunctionapply_signatures
( handler: &mut Handler<Signable, Keychain>, hash: &Signable, count: NodeCount,
rmc/src/handler.rs:142
↓ 2 callersMethodbroadcast_delay
(&self)
consensus/src/dissemination/task.rs:198
↓ 2 callersMethodbroadcast_message
(&self, message: TestMessage, node_index: NodeIndex)
rmc/src/service.rs:181
↓ 2 callersMethodcanonical_by_hash
only call this for canonical units
consensus/src/units/store.rs:66
↓ 2 callersMethodcmp
Compare tasks so that earlier times come first in a max-heap.
consensus/src/task_queue.rs:23
↓ 2 callersFunctionconnect_nodes
( spawner: &Spawner, n_members: NodeCount, networks: Vec<(Network, ReconnectSender)>, )
consensus/src/testing/crash_recovery.rs:56
↓ 2 callersMethodconnect_peer
(&mut self, peer: NodeIndex)
mock/src/network.rs:162
↓ 2 callersMethoddata
(&self)
consensus/src/units/mod.rs:131
↓ 2 callersFunctiondefault_coord_request_delay
200, 1000, 3000, 6000, 9000, ... Note that the first request always gets send immediately, so these are delays for _after_ a request is sent for the n
consensus/src/config.rs:191
↓ 2 callersFunctiondefault_coord_request_recipients
3, 3, 3, 1, 1, 1, 1, ...
consensus/src/config.rs:200
↓ 2 callersFunctiondefault_delay_config
Creates a [`DelayConfig`] with default parameters, suggested by the creators of this package.
consensus/src/config.rs:166
↓ 2 callersFunctiondelay_config_for_tests
()
consensus/src/config.rs:225
↓ 2 callersFunctionexponential_slowdown
( t: usize, base_delay: f64, start_exp_delay: usize, exp_base: f64, )
consensus/src/config.rs:97
↓ 2 callersFunctiongen_config
(node_ix: NodeIndex, n_members: NodeCount, delay_config: DelayConfig)
consensus/src/testing/mod.rs:54
↓ 2 callersMethodget
(&self, node_id: NodeIndex)
crypto/src/node.rs:157
↓ 2 callersMethodhandle_election_result
(&mut self, result: ElectionResult<U>)
consensus/src/extension/extender.rs:26
↓ 2 callersMethodhandle_message
( &mut self, message: TestMessage, node_index: NodeIndex, use_
rmc/src/service.rs:187
↓ 2 callersMethodhandle_parents_reconstruction_result
( &mut self, reconstruction_result: ReconstructionResult<U>, )
consensus/src/dag/reconstruction/mod.rs:210
↓ 2 callersMethodhandle_signed_hash
(&mut self, signed: Signed<Indexed<H>, MK>)
rmc/src/handler.rs:79
↓ 2 callersMethodhighest_round
The highest round among all added units, or 0 if there are none.
consensus/src/extension/units.rs:53
↓ 2 callersMethodincoming_alert
(&mut self, alert: TestAlert)
consensus/src/testing/alerts.rs:157
↓ 2 callersMethodindex
(&self)
crypto/src/signature.rs:144
↓ 2 callersMethodindex
(&self)
consensus/src/collection/mod.rs:48
↓ 2 callersMethodinto_range
(self)
crypto/src/node.rs:75
↓ 2 callersMethoditem_count
(&self)
crypto/src/node.rs:177
↓ 2 callersMethodkill
Kills this node.
consensus/src/testing/crash_recovery.rs:50
↓ 2 callersMethodmax_round
(&self)
consensus/src/config.rs:92
↓ 2 callersFunctionminimal_reconstructed_dag_units_up_to
Constructs a DAG so that in each round (except round 0) it has at least 2N/3 + 1 parents, where N is number of nodes in the DAG. At least one node fro
consensus/src/units/testing.rs:225
↓ 2 callersMethodmsg
(&self)
mock/src/crypto/signature.rs:16
↓ 2 callersMethodmut_hashes_by
(&mut self, creator: NodeIndex)
consensus/src/units/store.rs:53
↓ 2 callersMethodn_members
Returns number of all members in abft consensus
consensus/src/units/control_hash.rs:93
↓ 2 callersMethodnode_count
(&self)
crypto/src/signature.rs:460
↓ 2 callersMethodnode_count
(&self)
mock/src/crypto/keychain.rs:34
← previousnext →101–200 of 770, ranked by callers