logos-messaging/logos-messaging-nim
1
0
Fork 0
mirror of https://github.com/logos-messaging/logos-messaging-nim.git synced 2026-01-07 08:23:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

new metric and reduce msgSize in lp tester

Browse Source
This commit is contained in:
Prem Chaitanya Prathi 2025-04-11 14:40:26 +05:30
parent bbd3133933
commit f9dcdce5e6
3 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
examples/lightpush_publisher_mix.nim
View File

@ -161,8 +161,7 @@ proc setupAndPublish(rng: ref HmacDrbgContext, conf: LPMixConf) {.async.} =
Morbi accumsan elementum ligula ut fringilla. Praesent in ex metus. Phasellus urna est, tempus sit amet elementum vitae, sollicitudin vel ipsum. Fusce hendrerit eleifend dignissim. Maecenas tempor dapibus dui quis laoreet. Cras tincidunt sed ipsum sed pellentesque. Proin ut tellus nec ipsum varius interdum. Curabitur id velit ligula. Etiam sapien nulla, cursus sodales orci eu, porta lobortis nunc. Nunc at dapibus velit. Nulla et nunc vehicula, condimentum erat quis, elementum dolor. Quisque eu metus fermentum, vestibulum tellus at, sollicitudin odio. Ut vel neque justo. Morbi accumsan elementum ligula ut fringilla. Praesent in ex metus. Phasellus urna est, tempus sit amet elementum vitae, sollicitudin vel ipsum. Fusce hendrerit eleifend dignissim. Maecenas tempor dapibus dui quis laoreet. Cras tincidunt sed ipsum sed pellentesque. Proin ut tellus nec ipsum varius interdum. Curabitur id velit ligula. Etiam sapien nulla, cursus sodales orci eu, porta lobortis nunc. Nunc at dapibus velit. Nulla et nunc vehicula, condimentum erat quis, elementum dolor. Quisque eu metus fermentum, vestibulum tellus at, sollicitudin odio. Ut vel neque justo.
Praesent porta porta velit, vel porttitor sem. Donec sagittis at nulla venenatis iaculis. Nullam vel eleifend felis. Nullam a pellentesque lectus. Aliquam tincidunt semper dui sed bibendum. Donec hendrerit, urna et cursus dictum, neque neque convallis magna, id condimentum sem urna quis massa. Fusce non quam vulputate, fermentum mauris at, malesuada ipsum. Mauris id pellentesque libero. Donec vel erat ullamcorper, dapibus quam id, imperdiet urna. Praesent sed ligula ut est pellentesque pharetra quis et diam. Ut placerat lorem eget mi fermentum aliquet. Praesent porta porta velit, vel porttitor sem. Donec sagittis at nulla venenatis iaculis. Nullam vel eleifend felis. Nullam a pellentesque lectus. Aliquam tincidunt semper dui sed bibendum. Donec hendrerit, urna et cursus dictum, neque neque convallis magna, id condimentum sem urna quis massa. Fusce non quam vulputate, fermentum mauris at, malesuada ipsum. Mauris id pellentesque libero. Donec vel erat ullamcorper, dapibus quam id, imperdiet urna. Praesent sed ligula ut est pellentesque pharetra quis et diam. Ut placerat lorem eget mi fermentum aliquet.
This is message #""" & This is message #""" &
$i & $i & """ sent from a publisher using mix. End of transmission."""
""" sent from a publisher using mix.Testing larger message transmission over the Waku network is important for understanding performance characteristics under various conditions. End of transmission."""
let message = WakuMessage( let message = WakuMessage(
payload: toBytes(text), # content of the message payload: toBytes(text), # content of the message
contentTopic: LightpushContentTopic, # content topic to publish to contentTopic: LightpushContentTopic, # content topic to publish to

2
vendor/mix vendored

@ -1 +1 @@
Subproject commit be0ed0de37d71945075fd6c16537510e8fbc8a65 Subproject commit 9c74e4a356c7cd0bf45be13c20702a8dd15edc04

5
waku/node/waku_node.nim
View File

@ -28,7 +28,8 @@ import
mix/mix_node, mix/mix_node,
mix/mix_protocol, mix/mix_protocol,
mix/curve25519, mix/curve25519,
mix/protocol mix/protocol,
mix/mix_metrics
import import
../waku_core, ../waku_core,
@ -308,7 +309,7 @@ proc populateMixNodePool*(node: WakuNode) {.async.} =
let mixNodePubInfo = let mixNodePubInfo =
createMixPubInfo(maddrWithPeerId.value, intoCurve25519Key(peerMixPubKey)) createMixPubInfo(maddrWithPeerId.value, intoCurve25519Key(peerMixPubKey))
mixNodes[remotePeers[i].peerId] = mixNodePubInfo mixNodes[remotePeers[i].peerId] = mixNodePubInfo
mix_pool_size.set(len(mixNodes))
# set the mix node pool # set the mix node pool
node.mix.setNodePool(mixNodes) node.mix.setNodePool(mixNodes)
trace "mix node pool updated", poolSize = node.mix.getNodePoolSize() trace "mix node pool updated", poolSize = node.mix.getNodePoolSize()