mirror of
https://github.com/logos-storage/swarmsim.git
synced 2026-01-03 14:23:08 +00:00
remove message type checks and uncheckedDeliver
This commit is contained in:
parent
de6bf48b57
commit
31d7ad731e
@ -109,8 +109,8 @@ method atScheduledTime*(self: ExpirationTimer, engine: EventDrivenEngine): void
|
||||
proc sampleSwarm(self: DHTTracker, message: SampleSwarm, network: Network) =
|
||||
discard
|
||||
|
||||
method uncheckedDeliver*(self: DHTTracker, message: Message,
|
||||
engine: EventDrivenEngine, network: Network) =
|
||||
method deliver*(self: DHTTracker, message: Message, engine: EventDrivenEngine,
|
||||
network: Network) =
|
||||
|
||||
if message of PeerAnnouncement:
|
||||
self.addPeer(PeerAnnouncement(message), engine)
|
||||
|
||||
@ -7,16 +7,8 @@ export eventdrivenengine
|
||||
export Protocol
|
||||
export Message
|
||||
|
||||
method uncheckedDeliver(
|
||||
self: Protocol,
|
||||
message: Message,
|
||||
engine: EventDrivenEngine,
|
||||
network: Network
|
||||
): void {.base.} =
|
||||
method deliver*(self: Protocol, message: Message, engine: EventDrivenEngine,
|
||||
network: Network): void {.base.} =
|
||||
raise newException(CatchableError, "Method without implementation override")
|
||||
|
||||
proc deliver*(self: Protocol, message: Message, engine: EventDrivenEngine,
|
||||
network: Network): void =
|
||||
self.uncheckedDeliver(message, engine, network)
|
||||
|
||||
proc protocolName*[T: Protocol](self: type T): string = name(T)
|
||||
|
||||
@ -7,7 +7,7 @@ type
|
||||
Inbox* = ref object of Protocol
|
||||
messages*: seq[Message]
|
||||
|
||||
method uncheckedDeliver*(
|
||||
method deliver*(
|
||||
self: Inbox,
|
||||
message: Message,
|
||||
engine: EventDrivenEngine,
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user