1
0
mirror of synced 2025-02-14 00:37:03 +00:00

548 Commits

Author SHA1 Message Date
Roman
336ee493e6
fix: remove unnecessary check for validator swarm 2024-10-29 22:20:44 +08:00
Roman
57ef85f191
fix: implement clippy suggestions 2024-10-29 21:58:24 +08:00
Roman Zajic
25c243da3d
Merge branch 'master' into chore-da-behavior-membership-tests 2024-10-29 21:41:15 +08:00
Roman
868614eb8a
fix: remove select for executor swarm 2024-10-29 21:38:08 +08:00
Roman Zajic
6567a2d890
fix: Codecov workflow conflicting output directory (#862)
* fix: change conflicting output directory name

* test: try to remove unwanted software

* test: run on self-hosted

* fix: remove dispatch on push
2024-10-29 20:27:05 +08:00
Roman
8b114e6d42
test: increase executor timeout for self-hosted 2024-10-29 18:16:37 +08:00
Roman Zajic
0bfdad6485
Merge branch 'master' into chore-da-behavior-membership-tests 2024-10-29 17:38:39 +08:00
Youngjoon Lee
0c0aae0712
Mix: Packet algorithms (#859)
* add keyset

* add packet

* add comments

* add comments

* use functions in sphinx
2024-10-29 17:51:52 +09:00
Roman
eae257615a
fix: add one more retry for executor swarm 2024-10-29 16:30:09 +08:00
Roman
1fddd4ee81
fix: make validator swarm polling more deterministic 2024-10-29 16:29:07 +08:00
Roman
8216868f76
fix: increment retry counter 2024-10-29 12:37:43 +08:00
Roman
7d2e0c8570
fix: add retry counter for executor 2024-10-29 11:09:50 +08:00
Roman
2c39014468
fix: formatting 2024-10-29 11:05:35 +08:00
Roman
fdb9998958
fix: let executor wait for all messages 2024-10-29 10:59:05 +08:00
Roman
8c2041cfac
fix: increase timeouts 2024-10-29 10:44:57 +08:00
Roman
044de28153
fix: re-balance timeouts 2024-10-29 10:26:37 +08:00
Roman
2c0c00d2a0
fix: extend timeout more 2024-10-29 10:10:02 +08:00
Roman Zajic
f7c0585abd
Merge branch 'master' into chore-da-behavior-membership-tests 2024-10-29 09:25:27 +08:00
Daniel Sanchez
9d52297cdf
Mix: temporal as stream extension (#861)
* forward msgs immediately without any processing

* Mix: Offload transmission rate and message processing from libp2p behaviour/handler

* Mix: Core skeleton used in `MixService`

* rename Processor to MessageBlend

* Mix: Implement Persistent Transmission (Tier 1) (#845)

* Mix: Add Persistent Transmission (Tier 1)

* add test

* define Coin struct with Uniform distribution for fast repeated sampling

* use ChaCha12Rng for Coin

* improve comment

* Mix: Implement Temporal Processor (Tier 2) (#846)

* Mix: Add Persistent Transmission (Tier 1)

* Mix: Implement TemporalProcessor

* use pub(crate)

* Mix: Use TemporalProcessor in MessageBlend (#847)

* Mix: Add Persistent Transmission (Tier 1)

* Mix: Implement TemporalProcessor

* Mix: Use TemporalProcessor in MessageBlend

* remove duplicate members in Cargo.toml

* Implement persistent transmission as stream trait extension

* Replicate test for stream version

* Temporal processor as stream extension

---------

Co-authored-by: Youngjoon Lee <5462944+youngjoon-lee@users.noreply.github.com>
2024-10-28 17:12:50 +01:00
Daniel Sanchez
e207743f69
Mix: Persistent rate as stream + Extension (#860)
* forward msgs immediately without any processing

* Mix: Offload transmission rate and message processing from libp2p behaviour/handler

* Mix: Core skeleton used in `MixService`

* rename Processor to MessageBlend

* Mix: Implement Persistent Transmission (Tier 1) (#845)

* Mix: Add Persistent Transmission (Tier 1)

* add test

* define Coin struct with Uniform distribution for fast repeated sampling

* use ChaCha12Rng for Coin

* improve comment

* Mix: Implement Temporal Processor (Tier 2) (#846)

* Mix: Add Persistent Transmission (Tier 1)

* Mix: Implement TemporalProcessor

* use pub(crate)

* Mix: Use TemporalProcessor in MessageBlend (#847)

* Mix: Add Persistent Transmission (Tier 1)

* Mix: Implement TemporalProcessor

* Mix: Use TemporalProcessor in MessageBlend

* remove duplicate members in Cargo.toml

* Implement persistent transmission as stream trait extension

* Replicate test for stream version

---------

Co-authored-by: Youngjoon Lee <5462944+youngjoon-lee@users.noreply.github.com>
2024-10-28 15:24:40 +01:00
Roman
4f0231ff26
fix: extend timeout to accommodate slow runner 2024-10-28 20:32:54 +08:00
Roman
c4abaf479d
fix: move futures to shared function section
- remove simple tests
2024-10-28 20:11:07 +08:00
Roman Zajic
61bafc3c8f
Merge branch 'master' into chore-da-behavior-membership-tests 2024-10-28 19:48:00 +08:00
Roman
eac478d56d
fix: add assertions for counts 2024-10-28 19:47:32 +08:00
Roman
dd4525fc5e
fix: subnet 1 membership 2024-10-28 19:18:02 +08:00
Roman
a9880f5f7f
fix: assignment to wrong collection 2024-10-28 19:04:00 +08:00
Roman
8975923e97
fix: rewrite run_validator_swarm to count messages 2024-10-28 19:02:14 +08:00
Youngjoon Lee
7aea30132d
Mix: Implement PersistsentTransmission & Temporal/CryptoProcessor and use them in MixService (#844)
* forward msgs immediately without any processing

* Mix: Offload transmission rate and message processing from libp2p behaviour/handler

* Mix: Core skeleton used in `MixService`

* rename Processor to MessageBlend

* Mix: Implement Persistent Transmission (Tier 1) (#845)

* Mix: Add Persistent Transmission (Tier 1)

* add test

* define Coin struct with Uniform distribution for fast repeated sampling

* use ChaCha12Rng for Coin

* improve comment

* Mix: Implement Temporal Processor (Tier 2) (#846)

* Mix: Add Persistent Transmission (Tier 1)

* Mix: Implement TemporalProcessor

* use pub(crate)

* Mix: Use TemporalProcessor in MessageBlend (#847)

* Mix: Add Persistent Transmission (Tier 1)

* Mix: Implement TemporalProcessor

* Mix: Use TemporalProcessor in MessageBlend

* remove duplicate members in Cargo.toml
2024-10-28 17:32:39 +09:00
Roman
47ed7641cb
fix: add message counting to validator tasks 2024-10-28 15:18:59 +08:00
Roman
5be2adec5c
fix: add forgotten await and cleanup 2024-10-28 11:01:01 +08:00
Roman
4bb706c6cc
test: get everything into motion 2024-10-27 19:58:01 +08:00
Roman
7400f6329a
test: generate 2 groups of executors and validators 2024-10-26 19:41:52 +08:00
Roman
91577aaeac
test: check incoming data structure and content 2024-10-26 15:53:44 +08:00
Roman Zajic
c41566e604
Merge branch 'master' into chore-da-behavior-membership-tests 2024-10-26 14:13:15 +08:00
gusto
bebb15f921
Cli: Deserialization and runtime fixes (#854)
* Deserialization and runtime fixes for cli

* Disable dissemination test
2024-10-25 14:56:37 +03:00
gusto
461a7beaf8
Ignore reconstruction test in CI (#856) 2024-10-25 13:48:13 +03:00
gusto
5a2c41574a
Tests: Local debugging setup using grafana (#855)
* Local debug setup for integration tests

* Tests debugging setup readme

* Clippy too smart
2024-10-25 13:39:07 +03:00
Roman
ecd45c12e4
test: calling poll on validator_behaviour 2024-10-25 16:27:35 +08:00
Roman Zajic
b7e8eb627c
Merge branch 'master' into chore-da-behavior-membership-tests 2024-10-25 09:50:12 +08:00
gusto
938bcd7926
Nomos tracing crate (#849)
* tmp grafana stack

* Testnet configure otlp tracing

* tmp: Configurable loki and tempo in cfgsync

* Rename nomos-log to nomos-tracing-service

* nomos-tracing crate for tracing layer creation

* Use multiple layers in nomos-tracing-service

* Tracing in tests and testnet

* Tempo volume instead of local host dir
2024-10-24 19:33:04 +03:00
Daniel Sanchez
733f50b521
Abort tasks for da networks backends (#853)
* Abort tasks for da networks backends

* fmt
2024-10-24 18:17:33 +02:00
gusto
193ff82980
Cli: Dissemination and retrieval (#851)
* Remove chat and dissemination from nomos-cli

* Dissemination using executor http client in nomos-cli

* Blob retrieval from indexer using executor http client

* Range reqeust type from nomos-node

* Split executor and validator commands
2024-10-24 16:21:27 +03:00
Youngjoon Lee
ce24a03a23
Mix: Offload transmission rate and message processing from libp2p behaviour/handler (#843) 2024-10-24 21:00:26 +09:00
gusto
97330a763f
Reconstruct from incomplete blobs (#852) 2024-10-24 12:01:19 +03:00
Roman Zajic
835b106688
Merge branch 'master' into chore-da-behavior-membership-tests 2024-10-24 11:20:45 +08:00
Youngjoon Lee
929fb1b7b1
forward msgs immediately without any processing (#841) 2024-10-24 11:44:35 +09:00
Roman
54e6939141
fix: have executors and validators in the same subnet_id = 0 2024-10-23 18:26:28 +08:00
Roman
3eeafc819c
fix: address to contain p2p address 2024-10-23 15:44:11 +08:00
Roman Zajic
7a63118bd3
Merge branch 'master' into chore-da-behavior-membership-tests 2024-10-23 13:25:45 +08:00
Roman Zajic
ca786fd264
fix: Coverage workflow to run on ubuntu-22.04 (#836)
* fix: remove Remove unwanted software step

* fix: return Remove unwanted software step
- change to run ubuntu-latest to not occupy self-hosted runner

* fix: remove redundant condition

* fix: remove Checkout submodules step

* test: run on ubuntu-22.04

* test: without Remove unwanted software

* fix: remove on push trigger
2024-10-23 11:12:01 +08:00