Limit Snapshot to Conn
This commit is contained in:
parent
5a8ad6b40f
commit
1ea5ede442
1 changed files with 9 additions and 10 deletions
|
|
@ -130,18 +130,16 @@ impl InstanceConfig {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// TODO Make Snapshot a Conn snapshot, not an Instance snapshot
|
/// Snapshot of a [`Conn`]'s state immediately after receiving a packet.
|
||||||
/// Snapshot of an instance at a specific point in time, usually after just
|
#[derive(Debug, Clone)]
|
||||||
/// receiving a packet.
|
|
||||||
#[derive(Debug)]
|
|
||||||
pub struct Snapshot {
|
pub struct Snapshot {
|
||||||
pub config: InstanceConfig,
|
|
||||||
pub conn_tx: ConnTx,
|
pub conn_tx: ConnTx,
|
||||||
pub state: State,
|
pub state: State,
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Debug)]
|
#[derive(Debug)]
|
||||||
pub struct Event {
|
pub struct Event {
|
||||||
|
pub config: InstanceConfig,
|
||||||
pub packet: ParsedPacket,
|
pub packet: ParsedPacket,
|
||||||
pub snapshot: Snapshot,
|
pub snapshot: Snapshot,
|
||||||
}
|
}
|
||||||
|
|
@ -284,13 +282,14 @@ impl Instance {
|
||||||
{
|
{
|
||||||
loop {
|
loop {
|
||||||
let packet = conn.recv().await?;
|
let packet = conn.recv().await?;
|
||||||
|
let snapshot = Snapshot {
|
||||||
|
conn_tx: conn.tx().clone(),
|
||||||
|
state: conn.state().clone(),
|
||||||
|
};
|
||||||
let event = Event {
|
let event = Event {
|
||||||
|
config: config.clone(),
|
||||||
packet,
|
packet,
|
||||||
snapshot: Snapshot {
|
snapshot,
|
||||||
config: config.clone(),
|
|
||||||
conn_tx: conn.tx().clone(),
|
|
||||||
state: conn.state().clone(),
|
|
||||||
},
|
|
||||||
};
|
};
|
||||||
|
|
||||||
match &event.packet.content {
|
match &event.packet.content {
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue