logos-blockchain/logos-blockchain-simulations
1
0
Fork 0
mirror of https://github.com/logos-blockchain/logos-blockchain-simulations.git synced 2026-01-02 21:23:11 +00:00
Code Issues Packages Projects Releases Wiki Activity

add Created history event

Browse Source
This commit is contained in:
Youngjoon Lee 2025-02-05 16:33:30 +09:00
parent cc2fd20988
commit 84df069ee8
No known key found for this signature in database
GPG Key ID: D94003D91DE12141
1 changed files with 17 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
simlib/blendnet-sims/src/node/blend/mod.rs
View File

@ -50,10 +50,10 @@ pub struct BlendMessage {
}
impl BlendMessage {
pub fn new(message: Vec<u8>) -> Self {
pub fn new(message: Vec<u8>, node_id: NodeId, step_id: usize) -> Self {
Self {
message,
history: Vec::new(),
history: vec![MessageHistoryEvent::Created { node_id, step_id }],
}
}
}
@ -66,6 +66,11 @@ impl PayloadSize for BlendMessage {
#[derive(Debug, Clone, Serialize, Deserialize)]
enum MessageHistoryEvent {
Created {
#[serde(with = "node_id_serde")]
node_id: NodeId,
step_id: usize,
},
PersistentTransmissionScheduled {
#[serde(with = "node_id_serde")]
node_id: NodeId,
@ -464,7 +469,11 @@ impl Node for BlendNode {
.crypto_processor
.wrap_message(payload.as_bytes())
.unwrap();
self.schedule_persistent_transmission(BlendMessage::new(message));
self.schedule_persistent_transmission(BlendMessage::new(
message,
self.id,
self.state.step_id,
));
}
}
@ -542,7 +551,11 @@ impl Node for BlendNode {
.crypto_processor
.wrap_message(payload.as_bytes())
.unwrap();
self.schedule_persistent_transmission(BlendMessage::new(message));
self.schedule_persistent_transmission(BlendMessage::new(
message,
self.id,
self.state.step_id,
));
}
// Proceed persistent transmission