diff --git a/forward-msgs-non-priority/libp2p.html b/forward-msgs-non-priority/libp2p.html index db18c6b6d..181d77814 100644 --- a/forward-msgs-non-priority/libp2p.html +++ b/forward-msgs-non-priority/libp2p.html @@ -260,7 +260,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/builders.html b/forward-msgs-non-priority/libp2p/builders.html index f4885c20e..665c6c62c 100644 --- a/forward-msgs-non-priority/libp2p/builders.html +++ b/forward-msgs-non-priority/libp2p/builders.html @@ -801,7 +801,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/connmanager.html b/forward-msgs-non-priority/libp2p/connmanager.html index b39f0d45b..de8109abc 100644 --- a/forward-msgs-non-priority/libp2p/connmanager.html +++ b/forward-msgs-non-priority/libp2p/connmanager.html @@ -857,7 +857,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/crypto/chacha20poly1305.html b/forward-msgs-non-priority/libp2p/crypto/chacha20poly1305.html index 086b13431..861155fe9 100644 --- a/forward-msgs-non-priority/libp2p/crypto/chacha20poly1305.html +++ b/forward-msgs-non-priority/libp2p/crypto/chacha20poly1305.html @@ -391,7 +391,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/crypto/crypto.html b/forward-msgs-non-priority/libp2p/crypto/crypto.html index 3b0a921cf..6f456810c 100644 --- a/forward-msgs-non-priority/libp2p/crypto/crypto.html +++ b/forward-msgs-non-priority/libp2p/crypto/crypto.html @@ -1703,7 +1703,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/crypto/curve25519.html b/forward-msgs-non-priority/libp2p/crypto/curve25519.html index 72b02969a..3e6269b97 100644 --- a/forward-msgs-non-priority/libp2p/crypto/curve25519.html +++ b/forward-msgs-non-priority/libp2p/crypto/curve25519.html @@ -398,7 +398,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/crypto/ecnist.html b/forward-msgs-non-priority/libp2p/crypto/ecnist.html index f27174617..4a1e67f12 100644 --- a/forward-msgs-non-priority/libp2p/crypto/ecnist.html +++ b/forward-msgs-non-priority/libp2p/crypto/ecnist.html @@ -1450,7 +1450,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/crypto/ed25519/constants.html b/forward-msgs-non-priority/libp2p/crypto/ed25519/constants.html index ebe9bc08d..de3001c90 100644 --- a/forward-msgs-non-priority/libp2p/crypto/ed25519/constants.html +++ b/forward-msgs-non-priority/libp2p/crypto/ed25519/constants.html @@ -3040,7 +3040,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/crypto/ed25519/ed25519.html b/forward-msgs-non-priority/libp2p/crypto/ed25519/ed25519.html index 1a3f788e1..1f35653ac 100644 --- a/forward-msgs-non-priority/libp2p/crypto/ed25519/ed25519.html +++ b/forward-msgs-non-priority/libp2p/crypto/ed25519/ed25519.html @@ -940,7 +940,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/crypto/hkdf.html b/forward-msgs-non-priority/libp2p/crypto/hkdf.html index 822423ed4..e2e3cc6f2 100644 --- a/forward-msgs-non-priority/libp2p/crypto/hkdf.html +++ b/forward-msgs-non-priority/libp2p/crypto/hkdf.html @@ -275,7 +275,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/crypto/minasn1.html b/forward-msgs-non-priority/libp2p/crypto/minasn1.html index 5b835d073..8fea1f27d 100644 --- a/forward-msgs-non-priority/libp2p/crypto/minasn1.html +++ b/forward-msgs-non-priority/libp2p/crypto/minasn1.html @@ -1195,7 +1195,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/crypto/rsa.html b/forward-msgs-non-priority/libp2p/crypto/rsa.html index b5adbf9c7..f7198b265 100644 --- a/forward-msgs-non-priority/libp2p/crypto/rsa.html +++ b/forward-msgs-non-priority/libp2p/crypto/rsa.html @@ -1029,7 +1029,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/crypto/secp.html b/forward-msgs-non-priority/libp2p/crypto/secp.html index b72eee757..0e0561ed3 100644 --- a/forward-msgs-non-priority/libp2p/crypto/secp.html +++ b/forward-msgs-non-priority/libp2p/crypto/secp.html @@ -908,7 +908,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/dial.html b/forward-msgs-non-priority/libp2p/dial.html index baebd894a..3ff2a768a 100644 --- a/forward-msgs-non-priority/libp2p/dial.html +++ b/forward-msgs-non-priority/libp2p/dial.html @@ -381,7 +381,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/dialer.html b/forward-msgs-non-priority/libp2p/dialer.html index 5d31bbaca..c90501bad 100644 --- a/forward-msgs-non-priority/libp2p/dialer.html +++ b/forward-msgs-non-priority/libp2p/dialer.html @@ -450,7 +450,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/errors.html b/forward-msgs-non-priority/libp2p/errors.html index da9929e97..0e38c20fe 100644 --- a/forward-msgs-non-priority/libp2p/errors.html +++ b/forward-msgs-non-priority/libp2p/errors.html @@ -357,7 +357,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/multiaddress.html b/forward-msgs-non-priority/libp2p/multiaddress.html index 8a90b6a84..da7fa0e92 100644 --- a/forward-msgs-non-priority/libp2p/multiaddress.html +++ b/forward-msgs-non-priority/libp2p/multiaddress.html @@ -2551,7 +2551,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/multibase.html b/forward-msgs-non-priority/libp2p/multibase.html index e9a0aaa6a..074cf9464 100644 --- a/forward-msgs-non-priority/libp2p/multibase.html +++ b/forward-msgs-non-priority/libp2p/multibase.html @@ -396,7 +396,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/multicodec.html b/forward-msgs-non-priority/libp2p/multicodec.html index 46858bb24..f831f7e61 100644 --- a/forward-msgs-non-priority/libp2p/multicodec.html +++ b/forward-msgs-non-priority/libp2p/multicodec.html @@ -481,7 +481,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/multihash.html b/forward-msgs-non-priority/libp2p/multihash.html index 6945d1051..9a100e5d9 100644 --- a/forward-msgs-non-priority/libp2p/multihash.html +++ b/forward-msgs-non-priority/libp2p/multihash.html @@ -689,7 +689,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/multistream.html b/forward-msgs-non-priority/libp2p/multistream.html index c1bbcd45d..218bf8f30 100644 --- a/forward-msgs-non-priority/libp2p/multistream.html +++ b/forward-msgs-non-priority/libp2p/multistream.html @@ -539,7 +539,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/muxers/mplex/coder.html b/forward-msgs-non-priority/libp2p/muxers/mplex/coder.html index bf536fc21..c84ac7e01 100644 --- a/forward-msgs-non-priority/libp2p/muxers/mplex/coder.html +++ b/forward-msgs-non-priority/libp2p/muxers/mplex/coder.html @@ -391,7 +391,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/muxers/mplex/mplex.html b/forward-msgs-non-priority/libp2p/muxers/mplex/mplex.html index 2b2d184f5..dc8c5f526 100644 --- a/forward-msgs-non-priority/libp2p/muxers/mplex/mplex.html +++ b/forward-msgs-non-priority/libp2p/muxers/mplex/mplex.html @@ -415,7 +415,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/muxers/muxer.html b/forward-msgs-non-priority/libp2p/muxers/muxer.html index d38dd7374..a31b00ac7 100644 --- a/forward-msgs-non-priority/libp2p/muxers/muxer.html +++ b/forward-msgs-non-priority/libp2p/muxers/muxer.html @@ -533,7 +533,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/muxers/yamux/yamux.html b/forward-msgs-non-priority/libp2p/muxers/yamux/yamux.html index bb6e72f96..696192816 100644 --- a/forward-msgs-non-priority/libp2p/muxers/yamux/yamux.html +++ b/forward-msgs-non-priority/libp2p/muxers/yamux/yamux.html @@ -608,7 +608,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/nameresolving/nameresolver.html b/forward-msgs-non-priority/libp2p/nameresolving/nameresolver.html index d1330ef4c..a293124fe 100644 --- a/forward-msgs-non-priority/libp2p/nameresolving/nameresolver.html +++ b/forward-msgs-non-priority/libp2p/nameresolving/nameresolver.html @@ -375,7 +375,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/observedaddrmanager.html b/forward-msgs-non-priority/libp2p/observedaddrmanager.html index 5c28927d8..568cc6883 100644 --- a/forward-msgs-non-priority/libp2p/observedaddrmanager.html +++ b/forward-msgs-non-priority/libp2p/observedaddrmanager.html @@ -360,7 +360,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/peerid.html b/forward-msgs-non-priority/libp2p/peerid.html index ee2fcfd3d..ee3f3991e 100644 --- a/forward-msgs-non-priority/libp2p/peerid.html +++ b/forward-msgs-non-priority/libp2p/peerid.html @@ -806,7 +806,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/peerinfo.html b/forward-msgs-non-priority/libp2p/peerinfo.html index 38ada67e7..7244ebbcc 100644 --- a/forward-msgs-non-priority/libp2p/peerinfo.html +++ b/forward-msgs-non-priority/libp2p/peerinfo.html @@ -484,7 +484,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/protobuf/minprotobuf.html b/forward-msgs-non-priority/libp2p/protobuf/minprotobuf.html index f94fee75d..217257080 100644 --- a/forward-msgs-non-priority/libp2p/protobuf/minprotobuf.html +++ b/forward-msgs-non-priority/libp2p/protobuf/minprotobuf.html @@ -931,7 +931,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/protocols/connectivity/autonat/core.html b/forward-msgs-non-priority/libp2p/protocols/connectivity/autonat/core.html index c222574fb..6a09968d0 100644 --- a/forward-msgs-non-priority/libp2p/protocols/connectivity/autonat/core.html +++ b/forward-msgs-non-priority/libp2p/protocols/connectivity/autonat/core.html @@ -508,7 +508,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/protocols/connectivity/autonat/server.html b/forward-msgs-non-priority/libp2p/protocols/connectivity/autonat/server.html index 7fba9a81d..fd5551502 100644 --- a/forward-msgs-non-priority/libp2p/protocols/connectivity/autonat/server.html +++ b/forward-msgs-non-priority/libp2p/protocols/connectivity/autonat/server.html @@ -302,7 +302,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/protocols/connectivity/relay/client.html b/forward-msgs-non-priority/libp2p/protocols/connectivity/relay/client.html index d968af0fc..dbccb94d3 100644 --- a/forward-msgs-non-priority/libp2p/protocols/connectivity/relay/client.html +++ b/forward-msgs-non-priority/libp2p/protocols/connectivity/relay/client.html @@ -468,7 +468,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/protocols/connectivity/relay/messages.html b/forward-msgs-non-priority/libp2p/protocols/connectivity/relay/messages.html index 40e6b0d00..e159d32cc 100644 --- a/forward-msgs-non-priority/libp2p/protocols/connectivity/relay/messages.html +++ b/forward-msgs-non-priority/libp2p/protocols/connectivity/relay/messages.html @@ -722,7 +722,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/protocols/connectivity/relay/rconn.html b/forward-msgs-non-priority/libp2p/protocols/connectivity/relay/rconn.html index fd8f37061..60346edc8 100644 --- a/forward-msgs-non-priority/libp2p/protocols/connectivity/relay/rconn.html +++ b/forward-msgs-non-priority/libp2p/protocols/connectivity/relay/rconn.html @@ -377,7 +377,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/protocols/connectivity/relay/relay.html b/forward-msgs-non-priority/libp2p/protocols/connectivity/relay/relay.html index f094e158b..3b3554921 100644 --- a/forward-msgs-non-priority/libp2p/protocols/connectivity/relay/relay.html +++ b/forward-msgs-non-priority/libp2p/protocols/connectivity/relay/relay.html @@ -567,7 +567,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/protocols/connectivity/relay/rtransport.html b/forward-msgs-non-priority/libp2p/protocols/connectivity/relay/rtransport.html index 464225739..0f4e58c90 100644 --- a/forward-msgs-non-priority/libp2p/protocols/connectivity/relay/rtransport.html +++ b/forward-msgs-non-priority/libp2p/protocols/connectivity/relay/rtransport.html @@ -414,7 +414,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/protocols/connectivity/relay/utils.html b/forward-msgs-non-priority/libp2p/protocols/connectivity/relay/utils.html index e1030f4bd..ed9191907 100644 --- a/forward-msgs-non-priority/libp2p/protocols/connectivity/relay/utils.html +++ b/forward-msgs-non-priority/libp2p/protocols/connectivity/relay/utils.html @@ -368,7 +368,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/protocols/identify.html b/forward-msgs-non-priority/libp2p/protocols/identify.html index de28592b9..0940bb733 100644 --- a/forward-msgs-non-priority/libp2p/protocols/identify.html +++ b/forward-msgs-non-priority/libp2p/protocols/identify.html @@ -636,7 +636,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/protocols/ping.html b/forward-msgs-non-priority/libp2p/protocols/ping.html index 9a4106c36..12d962e57 100644 --- a/forward-msgs-non-priority/libp2p/protocols/ping.html +++ b/forward-msgs-non-priority/libp2p/protocols/ping.html @@ -414,7 +414,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/protocols/protocol.html b/forward-msgs-non-priority/libp2p/protocols/protocol.html index 3ea827e4a..4ea4000c9 100644 --- a/forward-msgs-non-priority/libp2p/protocols/protocol.html +++ b/forward-msgs-non-priority/libp2p/protocols/protocol.html @@ -467,7 +467,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/protocols/pubsub.html b/forward-msgs-non-priority/libp2p/protocols/pubsub.html index 6030d9137..e155f7bcc 100644 --- a/forward-msgs-non-priority/libp2p/protocols/pubsub.html +++ b/forward-msgs-non-priority/libp2p/protocols/pubsub.html @@ -239,7 +239,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/protocols/pubsub/errors.html b/forward-msgs-non-priority/libp2p/protocols/pubsub/errors.html index 05be709fa..83fdb7da0 100644 --- a/forward-msgs-non-priority/libp2p/protocols/pubsub/errors.html +++ b/forward-msgs-non-priority/libp2p/protocols/pubsub/errors.html @@ -255,7 +255,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/protocols/pubsub/floodsub.html b/forward-msgs-non-priority/libp2p/protocols/pubsub/floodsub.html index 56a681e35..01bacd60f 100644 --- a/forward-msgs-non-priority/libp2p/protocols/pubsub/floodsub.html +++ b/forward-msgs-non-priority/libp2p/protocols/pubsub/floodsub.html @@ -468,7 +468,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/protocols/pubsub/gossipsub.html b/forward-msgs-non-priority/libp2p/protocols/pubsub/gossipsub.html index f433e5ec1..55133f150 100644 --- a/forward-msgs-non-priority/libp2p/protocols/pubsub/gossipsub.html +++ b/forward-msgs-non-priority/libp2p/protocols/pubsub/gossipsub.html @@ -568,7 +568,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/protocols/pubsub/gossipsub/behavior.html b/forward-msgs-non-priority/libp2p/protocols/pubsub/gossipsub/behavior.html index da14540f6..b2bfa16b6 100644 --- a/forward-msgs-non-priority/libp2p/protocols/pubsub/gossipsub/behavior.html +++ b/forward-msgs-non-priority/libp2p/protocols/pubsub/gossipsub/behavior.html @@ -496,7 +496,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/protocols/pubsub/gossipsub/scoring.html b/forward-msgs-non-priority/libp2p/protocols/pubsub/gossipsub/scoring.html index b13353415..193e23753 100644 --- a/forward-msgs-non-priority/libp2p/protocols/pubsub/gossipsub/scoring.html +++ b/forward-msgs-non-priority/libp2p/protocols/pubsub/gossipsub/scoring.html @@ -447,7 +447,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/protocols/pubsub/gossipsub/types.html b/forward-msgs-non-priority/libp2p/protocols/pubsub/gossipsub/types.html index 235fb5032..fc39cf315 100644 --- a/forward-msgs-non-priority/libp2p/protocols/pubsub/gossipsub/types.html +++ b/forward-msgs-non-priority/libp2p/protocols/pubsub/gossipsub/types.html @@ -780,7 +780,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/protocols/pubsub/mcache.html b/forward-msgs-non-priority/libp2p/protocols/pubsub/mcache.html index a4d8adffc..590be8de5 100644 --- a/forward-msgs-non-priority/libp2p/protocols/pubsub/mcache.html +++ b/forward-msgs-non-priority/libp2p/protocols/pubsub/mcache.html @@ -403,7 +403,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/protocols/pubsub/peertable.html b/forward-msgs-non-priority/libp2p/protocols/pubsub/peertable.html index 58e2d8e89..bd18ab74c 100644 --- a/forward-msgs-non-priority/libp2p/protocols/pubsub/peertable.html +++ b/forward-msgs-non-priority/libp2p/protocols/pubsub/peertable.html @@ -370,7 +370,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/protocols/pubsub/pubsub.html b/forward-msgs-non-priority/libp2p/protocols/pubsub/pubsub.html index 4d41156ae..4bc882236 100644 --- a/forward-msgs-non-priority/libp2p/protocols/pubsub/pubsub.html +++ b/forward-msgs-non-priority/libp2p/protocols/pubsub/pubsub.html @@ -1159,7 +1159,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/protocols/pubsub/pubsubpeer.html b/forward-msgs-non-priority/libp2p/protocols/pubsub/pubsubpeer.html index 8755e1411..dd127798e 100644 --- a/forward-msgs-non-priority/libp2p/protocols/pubsub/pubsubpeer.html +++ b/forward-msgs-non-priority/libp2p/protocols/pubsub/pubsubpeer.html @@ -237,8 +237,7 @@ window.addEventListener("DOMContentLoaded", main2); appScore*: float64 behaviourPenalty*: float64 overheadRateLimitOpt*: Opt[TokenBucket] - rpcmessagequeue: RpcMessageQueue - queueProcessingTask: Future[void]">PubSubPeer + rpcmessagequeue: RpcMessageQueue">PubSubPeer
  • PubSubPeerEvent
  • @@ -248,6 +247,12 @@ window.addEventListener("DOMContentLoaded", main2);
  • RPCHandler
  • +
  • RpcMessageQueue
  • @@ -464,16 +469,15 @@ class="link-seesrc" target="_blank">Source appScore*: float64 behaviourPenalty*: float64 overheadRateLimitOpt*: Opt[TokenBucket] - rpcmessagequeue: RpcMessageQueue - queueProcessingTask: Future[void] + rpcmessagequeue: RpcMessageQueue
      Source -  Edit +  Edit
    @@ -511,9 +515,26 @@ class="link-seesrc" target="_blank">Source   Source -  Edit +  Edit + + + +
    +
    RpcMessageQueue = ref object
    +  priorityQueue: AsyncQueue[seq[byte]]
    +  nonPriorityQueue: AsyncQueue[seq[byte]]
    +  messageAvailableEvent: AsyncEvent
    +  queueProcessingTask: Future[void]
    +
    +
    + + +  Source +  Edit
    @@ -528,9 +549,9 @@ class="link-seesrc" target="_blank">Source   Source -  Edit +  Edit @@ -540,9 +561,9 @@ class="link-seesrc" target="_blank">Source   Source -  Edit +  Edit @@ -552,9 +573,9 @@ class="link-seesrc" target="_blank">Source   Source -  Edit +  Edit @@ -564,9 +585,9 @@ class="link-seesrc" target="_blank">Source   Source -  Edit +  Edit @@ -576,9 +597,9 @@ class="link-seesrc" target="_blank">Source   Source -  Edit +  Edit @@ -589,9 +610,9 @@ class="link-seesrc" target="_blank">Source   Source -  Edit +  Edit @@ -601,9 +622,9 @@ class="link-seesrc" target="_blank">Source   Source -  Edit +  Edit @@ -613,9 +634,9 @@ class="link-seesrc" target="_blank">Source   Source -  Edit +  Edit @@ -625,9 +646,9 @@ class="link-seesrc" target="_blank">Source   Source -  Edit +  Edit @@ -640,9 +661,9 @@ class="link-seesrc" target="_blank">Source   Source -  Edit +  Edit @@ -652,9 +673,9 @@ class="link-seesrc" target="_blank">Source   Source -  Edit +  Edit @@ -665,9 +686,9 @@ class="link-seesrc" target="_blank">Source   Source -  Edit +  Edit @@ -679,9 +700,9 @@ class="link-seesrc" target="_blank">Source   Source -  Edit +  Edit @@ -693,9 +714,9 @@ class="link-seesrc" target="_blank">Source   Source -  Edit +  Edit @@ -705,9 +726,9 @@ class="link-seesrc" target="_blank">Source   Source -  Edit +  Edit @@ -717,9 +738,9 @@ class="link-seesrc" target="_blank">Source   Source -  Edit +  Edit @@ -734,9 +755,9 @@ class="link-seesrc" target="_blank">Source   Source -  Edit +  Edit @@ -755,7 +776,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/protocols/pubsub/rpc/message.html b/forward-msgs-non-priority/libp2p/protocols/pubsub/rpc/message.html index d0642c125..dbab986af 100644 --- a/forward-msgs-non-priority/libp2p/protocols/pubsub/rpc/message.html +++ b/forward-msgs-non-priority/libp2p/protocols/pubsub/rpc/message.html @@ -342,7 +342,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/protocols/pubsub/rpc/messages.html b/forward-msgs-non-priority/libp2p/protocols/pubsub/rpc/messages.html index 63235b188..8110d74f1 100644 --- a/forward-msgs-non-priority/libp2p/protocols/pubsub/rpc/messages.html +++ b/forward-msgs-non-priority/libp2p/protocols/pubsub/rpc/messages.html @@ -645,7 +645,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/protocols/pubsub/rpc/protobuf.html b/forward-msgs-non-priority/libp2p/protocols/pubsub/rpc/protobuf.html index c8533e028..98f60858f 100644 --- a/forward-msgs-non-priority/libp2p/protocols/pubsub/rpc/protobuf.html +++ b/forward-msgs-non-priority/libp2p/protocols/pubsub/rpc/protobuf.html @@ -596,7 +596,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/protocols/pubsub/rpcmessagequeue.html b/forward-msgs-non-priority/libp2p/protocols/pubsub/rpcmessagequeue.html index 653115c1d..e34d755fc 100644 --- a/forward-msgs-non-priority/libp2p/protocols/pubsub/rpcmessagequeue.html +++ b/forward-msgs-non-priority/libp2p/protocols/pubsub/rpcmessagequeue.html @@ -207,8 +207,8 @@ window.addEventListener("DOMContentLoaded", main2); @@ -239,11 +239,6 @@ window.addEventListener("DOMContentLoaded", main2);
  • getPriorityMessage(rpcMessageQueue: RpcMessageQueue): Opt[seq[byte]]
  • - - @@ -271,8 +266,8 @@ class="link-seesrc" target="_blank">Source
    RpcMessageQueue = ref object
    -  priorityQueue: AsyncQueue[seq[byte]]
    -  nonPriorityQueue: AsyncQueue[seq[byte]]
    +  priorityQueue*: AsyncQueue[seq[byte]]
    +  nonPriorityQueue*: AsyncQueue[seq[byte]]
     
    @@ -323,9 +318,9 @@ class="link-seesrc" target="_blank">Source   Source -  Edit +  Edit
    @@ -336,9 +331,9 @@ class="link-seesrc" target="_blank">Source   Source -  Edit +  Edit @@ -349,21 +344,9 @@ class="link-seesrc" target="_blank">Source   Source -  Edit - - - -
    -
    proc new(T: typedesc[RpcMessageQueue]): T:type {....raises: [].}
    -
    - - -  Source -  Edit +  Edit
    @@ -377,7 +360,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/protocols/pubsub/timedcache.html b/forward-msgs-non-priority/libp2p/protocols/pubsub/timedcache.html index fcff704a2..f852307d2 100644 --- a/forward-msgs-non-priority/libp2p/protocols/pubsub/timedcache.html +++ b/forward-msgs-non-priority/libp2p/protocols/pubsub/timedcache.html @@ -422,7 +422,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/protocols/rendezvous.html b/forward-msgs-non-priority/libp2p/protocols/rendezvous.html index 2a34f0f0b..d678f9441 100644 --- a/forward-msgs-non-priority/libp2p/protocols/rendezvous.html +++ b/forward-msgs-non-priority/libp2p/protocols/rendezvous.html @@ -530,7 +530,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/protocols/secure/noise.html b/forward-msgs-non-priority/libp2p/protocols/secure/noise.html index f2cbf715f..52f45c57d 100644 --- a/forward-msgs-non-priority/libp2p/protocols/secure/noise.html +++ b/forward-msgs-non-priority/libp2p/protocols/secure/noise.html @@ -561,7 +561,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/protocols/secure/secure.html b/forward-msgs-non-priority/libp2p/protocols/secure/secure.html index 6ae15d924..e0d822587 100644 --- a/forward-msgs-non-priority/libp2p/protocols/secure/secure.html +++ b/forward-msgs-non-priority/libp2p/protocols/secure/secure.html @@ -547,7 +547,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/routing_record.html b/forward-msgs-non-priority/libp2p/routing_record.html index 9d9bbdef0..026f0f9cb 100644 --- a/forward-msgs-non-priority/libp2p/routing_record.html +++ b/forward-msgs-non-priority/libp2p/routing_record.html @@ -422,7 +422,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/signed_envelope.html b/forward-msgs-non-priority/libp2p/signed_envelope.html index 6cdbab50f..8d716d76c 100644 --- a/forward-msgs-non-priority/libp2p/signed_envelope.html +++ b/forward-msgs-non-priority/libp2p/signed_envelope.html @@ -503,7 +503,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/stream/bufferstream.html b/forward-msgs-non-priority/libp2p/stream/bufferstream.html index 5d9a1c266..ba14cf664 100644 --- a/forward-msgs-non-priority/libp2p/stream/bufferstream.html +++ b/forward-msgs-non-priority/libp2p/stream/bufferstream.html @@ -513,7 +513,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/stream/chronosstream.html b/forward-msgs-non-priority/libp2p/stream/chronosstream.html index c0071d978..8cb8e0f8f 100644 --- a/forward-msgs-non-priority/libp2p/stream/chronosstream.html +++ b/forward-msgs-non-priority/libp2p/stream/chronosstream.html @@ -497,7 +497,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/stream/connection.html b/forward-msgs-non-priority/libp2p/stream/connection.html index 45f8097d4..22c97be25 100644 --- a/forward-msgs-non-priority/libp2p/stream/connection.html +++ b/forward-msgs-non-priority/libp2p/stream/connection.html @@ -500,7 +500,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/stream/lpstream.html b/forward-msgs-non-priority/libp2p/stream/lpstream.html index da322b200..5d5d855ae 100644 --- a/forward-msgs-non-priority/libp2p/stream/lpstream.html +++ b/forward-msgs-non-priority/libp2p/stream/lpstream.html @@ -1113,7 +1113,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/stream/streamseq.html b/forward-msgs-non-priority/libp2p/stream/streamseq.html index 0badca943..3dc5b3486 100644 --- a/forward-msgs-non-priority/libp2p/stream/streamseq.html +++ b/forward-msgs-non-priority/libp2p/stream/streamseq.html @@ -442,7 +442,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/switch.html b/forward-msgs-non-priority/libp2p/switch.html index cf11661da..4a5d21050 100644 --- a/forward-msgs-non-priority/libp2p/switch.html +++ b/forward-msgs-non-priority/libp2p/switch.html @@ -750,7 +750,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/transcoder.html b/forward-msgs-non-priority/libp2p/transcoder.html index dfec6e1e6..7c3a9fb29 100644 --- a/forward-msgs-non-priority/libp2p/transcoder.html +++ b/forward-msgs-non-priority/libp2p/transcoder.html @@ -266,7 +266,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/transports/tcptransport.html b/forward-msgs-non-priority/libp2p/transports/tcptransport.html index 620dc31d0..495da3b81 100644 --- a/forward-msgs-non-priority/libp2p/transports/tcptransport.html +++ b/forward-msgs-non-priority/libp2p/transports/tcptransport.html @@ -477,7 +477,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/transports/transport.html b/forward-msgs-non-priority/libp2p/transports/transport.html index 5b1af508c..34d70ec54 100644 --- a/forward-msgs-non-priority/libp2p/transports/transport.html +++ b/forward-msgs-non-priority/libp2p/transports/transport.html @@ -488,7 +488,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/transports/wstransport.html b/forward-msgs-non-priority/libp2p/transports/wstransport.html index 15cb1949b..7ed553dfb 100644 --- a/forward-msgs-non-priority/libp2p/transports/wstransport.html +++ b/forward-msgs-non-priority/libp2p/transports/wstransport.html @@ -554,7 +554,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/upgrademngrs/muxedupgrade.html b/forward-msgs-non-priority/libp2p/upgrademngrs/muxedupgrade.html index 545af6054..0c5a7975b 100644 --- a/forward-msgs-non-priority/libp2p/upgrademngrs/muxedupgrade.html +++ b/forward-msgs-non-priority/libp2p/upgrademngrs/muxedupgrade.html @@ -350,7 +350,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/upgrademngrs/upgrade.html b/forward-msgs-non-priority/libp2p/upgrademngrs/upgrade.html index 992fd8d25..ba89aa284 100644 --- a/forward-msgs-non-priority/libp2p/upgrademngrs/upgrade.html +++ b/forward-msgs-non-priority/libp2p/upgrademngrs/upgrade.html @@ -370,7 +370,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/utility.html b/forward-msgs-non-priority/libp2p/utility.html index 3073ce510..867a13c40 100644 --- a/forward-msgs-non-priority/libp2p/utility.html +++ b/forward-msgs-non-priority/libp2p/utility.html @@ -435,7 +435,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/utils/future.html b/forward-msgs-non-priority/libp2p/utils/future.html index b27a5c8b1..3210adf84 100644 --- a/forward-msgs-non-priority/libp2p/utils/future.html +++ b/forward-msgs-non-priority/libp2p/utils/future.html @@ -271,7 +271,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/utils/heartbeat.html b/forward-msgs-non-priority/libp2p/utils/heartbeat.html index 9e8f93d8d..ca49a9afa 100644 --- a/forward-msgs-non-priority/libp2p/utils/heartbeat.html +++ b/forward-msgs-non-priority/libp2p/utils/heartbeat.html @@ -245,7 +245,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/utils/offsettedseq.html b/forward-msgs-non-priority/libp2p/utils/offsettedseq.html index 8bc8b0006..a83d2eddd 100644 --- a/forward-msgs-non-priority/libp2p/utils/offsettedseq.html +++ b/forward-msgs-non-priority/libp2p/utils/offsettedseq.html @@ -512,7 +512,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/utils/semaphore.html b/forward-msgs-non-priority/libp2p/utils/semaphore.html index f2ed4c830..2be53da28 100644 --- a/forward-msgs-non-priority/libp2p/utils/semaphore.html +++ b/forward-msgs-non-priority/libp2p/utils/semaphore.html @@ -362,7 +362,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/varint.html b/forward-msgs-non-priority/libp2p/varint.html index 61c89a687..f3aaeda87 100644 --- a/forward-msgs-non-priority/libp2p/varint.html +++ b/forward-msgs-non-priority/libp2p/varint.html @@ -725,7 +725,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/vbuffer.html b/forward-msgs-non-priority/libp2p/vbuffer.html index 2bbfe58b6..a989b0326 100644 --- a/forward-msgs-non-priority/libp2p/vbuffer.html +++ b/forward-msgs-non-priority/libp2p/vbuffer.html @@ -636,7 +636,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/libp2p/wire.html b/forward-msgs-non-priority/libp2p/wire.html index 3c3671edf..c11d85352 100644 --- a/forward-msgs-non-priority/libp2p/wire.html +++ b/forward-msgs-non-priority/libp2p/wire.html @@ -604,7 +604,7 @@ class="link-seesrc" target="_blank">Source diff --git a/forward-msgs-non-priority/theindex.html b/forward-msgs-non-priority/theindex.html index fc9745e5b..7e138a86e 100644 --- a/forward-msgs-non-priority/theindex.html +++ b/forward-msgs-non-priority/theindex.html @@ -3184,8 +3184,6 @@ window.addEventListener('DOMContentLoaded', main); overheadRateLimitOpt: Opt[TokenBucket] = Opt.none(TokenBucket)): T:type" href="libp2p/protocols/pubsub/pubsubpeer.html#new%2Ctypedesc%5BPubSubPeer%5D%2CPeerId%2CGetConn%2COnEvent%2Cstring%2Cint%2COpt%5BTokenBucket%5D">pubsubpeer: new(T: typedesc[PubSubPeer]; peerId: PeerId; getConn: GetConn; onEvent: OnEvent; codec: string; maxMessageSize: int; overheadRateLimitOpt: Opt[TokenBucket] = Opt.none(TokenBucket)): T:type -
  • rpcmessagequeue: new(T: typedesc[RpcMessageQueue]): T:type
  • rendezvous: new(T: typedesc[RendezVous]; rng: ref HmacDrbgContext = newRng()): T:type
  • RpcMessageQueue:
    RPCMsg:
      @@ -5340,7 +5340,7 @@ window.addEventListener('DOMContentLoaded', main);