vacp2p/mix
1
0
Fork 0
mirror of https://github.com/vacp2p/mix.git synced 2026-01-09 22:18:09 -05:00
Code Issues Packages Projects Releases Wiki Activity

changed to yamux

Browse Source
This commit is contained in:
akshaya
2025-07-02 11:18:45 -04:00
parent f02adc65a1
commit 4a14436a5a
2 changed files with 8 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
mix/examples/poc_noresp_ping.nim
View File

@@ -1,7 +1,9 @@
import chronicles, chronos, results, strutils
import std/[enumerate, sysrand]
import libp2p
import libp2p/[crypto/secp, multiaddress, builders, protocols/ping, switch]
import
libp2p/
[crypto/secp, multiaddress, builders, muxers/yamux/yamux, protocols/ping, switch]
import
../[entry_connection, entry_connection_callbacks, mix_node, mix_protocol, protocol],
../protocols/noresp_ping
@@ -15,15 +17,12 @@ proc cryptoRandomInt(max: int): Result[int, string] =
return ok(int(value mod uint64(max)))
proc createSwitch(libp2pPrivKey: SkPrivateKey, multiAddr: MultiAddress): Switch =
let
inTimeout: Duration = 5.minutes
outTimeout: Duration = 5.minutes
result = SwitchBuilder
.new()
.withPrivateKey(PrivateKey(scheme: Secp256k1, skkey: libp2pPrivKey))
.withAddress(multiAddr)
.withRng(crypto.newRng())
.withMplex(inTimeout, outTimeout)
.withYamux()
.withTcpTransport()
.withNoise()
.build()

9
mix/protocols/test_noresp_ping.nim
View File

@@ -1,16 +1,15 @@
import chronicles, chronos, std/sysrand
import libp2p/[crypto/secp, multiaddress, builders, transports/tcptransport]
import
libp2p/
[crypto/secp, multiaddress, builders, muxers/yamux/yamux, transports/tcptransport]
import ./noresp_ping
proc createSwitch(multiAddr: MultiAddress): Switch =
let
inTimeout: Duration = 5.minutes
outTimeout: Duration = 5.minutes
result = SwitchBuilder
.new()
.withAddress(multiAddr)
.withRng(crypto.newRng())
.withMplex(inTimeout, outTimeout)
.withYamux()
.withTcpTransport()
.withNoise()
.build()