This commit is contained in:
Raycho Mukelov 2023-09-16 23:11:17 +03:00
parent ebbd506cf6
commit d9c0cccc37
1 changed files with 2 additions and 2 deletions

View File

@ -50,7 +50,7 @@ proc RaftPipesRead(node: BasicRaftNode, port: int) =
rs.pack(r)
fwFD.write(rs.data)
proc TestRaftMessageSendCallbackCreate(conf: RaftPeersConfContainer, node: BasicRaftNode, port: int): RaftMessageSendCallback =
proc TestRaftMessageSendCallbackCreate(conf: RaftPeersConfContainer): RaftMessageSendCallback =
proc (msg: RaftMessageBase): Future[RaftMessageResponseBase] {.async, gcsafe.} =
var
host: string
@ -96,7 +96,7 @@ proc main() {.async.} =
port = conf[idx].port
peersIds.del(idx)
node = BasicRaftNode.new(nodeId, peersIds, TestRaftMessageSendCallbackCreate(conf, node, port))
node = BasicRaftNode.new(nodeId, peersIds, TestRaftMessageSendCallbackCreate(conf))
RaftNodeStart(node)
spawn RaftPipesRead(node, port)