Commit Graph

1047 Commits

Author SHA1 Message Date
Jacek Sieka 21cbe3a91a
chore: cleanups (#1092)
* remove cruft
* remove redundant error handling (reduces warnings)
* remove redundant copying
2024-05-08 14:33:26 +02:00
diegomrsantos 88e233db81
fix: Asynchronous task [sendMsgSlow()] was cancelled [FutureDefect] (#1094) 2024-05-07 15:44:14 +02:00
Jacek Sieka 84659af45b
avoid latency/copy when sending low-priority messages to fast peers (#1060) 2024-05-02 12:26:16 +02:00
Jacek Sieka aef44ed1ce
salt `idontwant` (#1090) 2024-05-02 12:18:55 +02:00
Jacek Sieka 02c96fc003
Improve memory efficiency of seen cache (#1073) 2024-05-01 18:38:24 +02:00
Diego 2b5319622c
Revert "always allow new data be received if the recvWindow is > 0"
This reverts commit 5cbb473d1b.
2024-04-25 15:01:29 +02:00
Diego 5cbb473d1b
always allow new data be received if the recvWindow is > 0 2024-04-25 14:55:19 +02:00
Ivan FB b30b2656d5
fix: reset accept fut in stop (#1082)
Co-authored-by: diegomrsantos <diego@status.im>
2024-04-17 22:44:41 +02:00
diegomrsantos 89cad5a3ba
fix: remove explicit param from GossipSubParams constructor (#1080) 2024-04-09 20:14:59 +02:00
Ludovic Chenut 09b3e11956
fix: valueOr and withValue utilities (#1079) 2024-04-04 17:15:50 +02:00
Etan Kissling 03f67d3db5
add support for setting protocol handlers with `{.raises.}` annotation (#1064) 2024-03-28 09:42:31 +01:00
diegomrsantos bb97a9de79
improvement: create a new gossipsub constructor (#1078) 2024-03-27 11:54:15 +01:00
diegomrsantos 1a707e1264
feat: add max number of elements to non-prio queue (#1077) 2024-03-25 22:00:11 +01:00
Álex Cabeza Romero 458b0885dd
fix(issue-1052): Single topic for RPC Message (#1061) 2024-03-25 12:06:34 +01:00
Jacek Sieka a2027003cd
Avoid unnecessary rate limit message copy (#1067) 2024-03-21 13:11:40 +00:00
Etan Kissling c5db35d9b0
annotate `upgrademngrs` with `{.async: (raises).}` (#1068) 2024-03-21 08:19:57 +01:00
Jacek Sieka d1e51beb7f
Remove `secio` (#1072) 2024-03-20 14:53:56 +01:00
Etan Kissling 275d649287
move `header.length` check in `yamux` to original location (#1069) 2024-03-20 13:35:44 +01:00
Jacek Sieka 467b5b4f0c
avoid cancelling send future (#1075) 2024-03-20 10:54:32 +00:00
Ivan FB fdf53d18cd
libp2p/dialer.nim: tiny log change to make it clearer a connection upgrade (#1071) 2024-03-18 11:38:23 +01:00
Etan Kissling 48a3ac06ff
`{.async: (raises).}` for `MultistreamSelect` (#1066) 2024-03-12 21:05:53 +01:00
Etan Kissling 49a92e5641
avoid pointless exception raising in `dcutr/server` (#1063) 2024-03-12 18:29:01 +01:00
Etan Kissling 08a48faf41
`{.async: (raises).}` annotations for `protocols/secure` (#1059) 2024-03-07 11:22:22 +00:00
Etan Kissling 61b299e411
`{.async: (raises).}` for `relay/utils.nim` (#1058) 2024-03-07 10:45:25 +01:00
Etan Kissling ca01ee06a8
clean up triple lookup and avoid `KeyError` when adding muxer (#1057) 2024-03-06 06:49:45 +01:00
Etan Kissling 6c43ab3fce
default `MultiAddress` param for `newStandardSwitch` does not raise (#1056) 2024-03-06 06:48:13 +01:00
Jacek Sieka ae13a0d583
Send priority with queue fix (#1051)
Co-authored-by: Diego <diego@status.im>
2024-03-05 15:05:21 +00:00
Etan Kissling 28609597d1
add `{.async: (raises).}` to `libp2p/stream` modules (#1050)
Co-authored-by: Dmitriy Ryajov <dryajov@gmail.com>
Co-authored-by: Jacek Sieka <jacek@status.im>
2024-03-05 07:06:27 +00:00
Etan Kissling 8294d5b9df
document known `--mm:orc` crash (#1039) 2024-03-04 19:34:09 +01:00
Etan Kissling 78e83889ee
define proper parent error type for `YamuxError` (#1040) 2024-03-04 19:26:27 +01:00
Etan Kissling 7603b8de5e
catch `WebSocketError` in `wstransport` (#1049) 2024-03-04 00:27:35 +01:00
Etan Kissling 8cccd54125
avoid triple lookup in `m.flushed` yamux table (#1045) 2024-03-04 00:27:13 +01:00
Etan Kissling 18e00a741b
avoid `KeyError` in edge case of yamux handler (#1044) 2024-03-04 00:24:18 +01:00
Etan Kissling ee264fdf11
in yamux, do not write `{Rst}` packet to stream that's in use (#1041) 2024-03-04 00:23:42 +01:00
Etan Kissling 9059a8aced
use `race` instead of `or` to avoid lockup (#1042) 2024-03-04 00:06:32 +01:00
Etan Kissling 0b753e7cf2
don't forget closing the stream when final `{Fin}` fails in yamux (#1043) 2024-03-04 00:05:59 +01:00
Etan Kissling d43c5feab0
do not log yamux buffers without sanitization (trace log level) (#1046) 2024-03-04 00:04:37 +01:00
Etan Kissling 1609fd7197
change `SecioError` and `NoiseError` to descendants of `LPStreamError` (#1047) 2024-03-04 00:04:25 +01:00
Etan Kissling 42cd78e95b
remove unused `LPStreamError` types (#1048) 2024-03-04 00:03:44 +01:00
Etan Kissling 44cada9c55
use new Chronos `trackCounter` APIs for leaks checks in tests (#1038) 2024-03-03 18:13:37 +01:00
Etan Kissling 6c873481ac
move `allFutureThrowing` helper to tests (#1037)
Co-authored-by: Jacek Sieka <jacek@status.im>
2024-03-01 18:06:26 +01:00
Etan Kissling d08ce17144
remove unused `MultiBase.encode(..., Cid)` function (#1036) 2024-03-01 14:07:52 +01:00
Etan Kissling 53e3825e07
fix typo in `ProtoMessage.toString()` (#1033) 2024-02-29 15:56:47 +01:00
Eugene Kabanov fec632d28d
Fix empty path crash issue for MultiAddresses `unix`, `ip6zone`, `dns***`. (#1025)
This issue was discovered by @0xTylerHolmes . Thank you!
2024-02-22 15:57:11 +01:00
Ludovic Chenut 349496e40f
feat: Yamux timeout (#1029) 2024-02-22 10:21:34 +01:00
diegomrsantos 7faa0fac23
fix: allFuturesThrowing compilation issue on daily (#1026) 2024-02-19 19:46:34 +01:00
Diego c5e4f8e12d
Revert "feat: message prioritization with immediate peer-published dispatch and queuing for other msgs (#1015)"
This reverts commit fe4ff79885.
2024-02-19 13:47:37 +01:00
diegomrsantos fe4ff79885
feat: message prioritization with immediate peer-published dispatch and queuing for other msgs (#1015) 2024-02-16 10:54:16 +01:00
Ludovic Chenut c1dfd58772
fix: yamux metrics (#1022) 2024-02-08 12:36:58 +01:00
Ludovic Chenut eb0890cd6f
docs: add comments and improve yamux readability (#1006) 2024-02-02 15:14:02 +01:00