Lorenzo Delgado
5c46220e72
add eth topic to all the logs scope ( #568 )
2022-12-06 14:54:03 +01:00
KonradStaniec
22d0ac81e1
Fix defect when writing over send buffer ( #564 )
...
* Fix defect when writing over send buffer
2022-11-30 09:34:08 +01:00
Justin Traglia
e7d3de6ebf
Fix some typos ( #557 )
2022-11-16 17:44:00 +01:00
andri lim
10870d8b15
Revert #544 "Fix related to nim devel branch" ( #551 )
...
This reverts commit:
5d13052dd9
e1bdf1741a
d238693571
2022-11-09 18:57:04 +01:00
jangko
5d13052dd9
refactor: compile with nim-devel
2022-11-08 11:08:25 +07:00
Kim De Mey
bd8d9c65a3
Seperate discv5 protocol message encoding from packet encoding ( #539 )
...
And some additional clean-ups
2022-10-10 12:13:20 +02:00
KonradStaniec
2556b090ea
Add user data to utp ( #525 )
2022-08-12 15:09:59 +02:00
KonradStaniec
a5ea6a9a90
Add connection limits to utp ( #522 )
2022-08-04 15:55:39 +02:00
Kim De Mey
9d7e4b031a
Clean-up of several compiler warnings ( #519 )
2022-07-09 10:55:15 +02:00
Kim De Mey
c67e48be1d
Change info log to debug in uTP router connect ( #517 )
...
These uTP logs are common and should be under debug,
else they spam on application level.
Probably accidentally changed in https://github.com/status-im/nim-eth/pull/508
2022-07-04 12:13:46 +02:00
Jacek Sieka
1b516682bd
bearssl: use split api ( #510 )
2022-06-17 22:45:37 +02:00
KonradStaniec
dffaa78cbe
Install cancel callback on whole connection future ( #508 )
2022-05-30 10:28:10 +02:00
Kim De Mey
01684a2130
Adjust uTP log levels to be more user focused ( #502 )
...
Also cleanup several whitespace and line char limits
2022-04-12 21:11:01 +02:00
KonradStaniec
eb785207ae
Make packet size configurable ( #497 )
...
* Make packet size configurable
2022-04-04 13:44:32 +02:00
KonradStaniec
c28597fee5
Change closing proc ( #492 )
2022-03-28 12:35:08 +02:00
KonradStaniec
f79b79f826
Fix defect in uTP buffer ( #493 )
2022-03-24 15:56:00 +01:00
KonradStaniec
e794c149f5
Fix compilation error ( #490 )
2022-03-18 15:53:51 +01:00
KonradStaniec
0e20fd6565
Utp improvements ( #489 )
...
* Move connection finalization to separate function
* Do not process data unless in correct state
2022-03-18 08:13:17 +01:00
KonradStaniec
f16f175412
Add metrics to utp router ( #488 )
...
* Add metrics to utp router
2022-03-17 10:53:46 +01:00
KonradStaniec
dff9040cc1
Fix bug when reading till eof ( #483 )
2022-03-03 22:38:13 +01:00
KonradStaniec
8ef6b13b1b
Add event loop to socket ( #475 )
...
- add eventLoop to control all incoming events
- change semantic of write to asynchronously block only when send buffer is full, and not when bytes do not fit into send window
- change handling of receive buffer, to start dropping packets if the reorder buffer and receive buffer are full. Old behaviour was to async block unless there is space which could lead to resource exhaustion attacks
2022-02-24 18:22:44 +01:00
KonradStaniec
779d767b02
Add more tests stressing conccurent reading and writing on utp socket ( #474 )
...
* Add more tests stressing concurrent reading and writing
* Fix bug when remote window dropped below packet size
2022-02-10 08:05:44 +01:00
KonradStaniec
5791afccc3
Implement fast resend logic for selective acks ( #468 )
...
* Implement fast resend logic for selective acks
2022-01-27 11:07:40 +01:00
KonradStaniec
7afd44d33e
Implement fast resend logic ( #466 )
2022-01-26 09:49:34 +01:00
KonradStaniec
9a7b1afe9b
Add custom talkreq implementation ( #464 )
...
* Add custom talkreq implementation to utp over discv5
2022-01-24 11:58:35 +01:00
KonradStaniec
4e2b340af6
Fix sudden window drop bug ( #465 )
...
Fixes problem which caused drop of maxWindow to the size of
only one packet in case of only one packet hitting timeout.
2022-01-21 14:48:01 +01:00
KonradStaniec
45348e7664
Add more logs to utp ( #463 )
...
* Add more logs to utp
* Change initial timeout for inc socket to positive value
2022-01-20 13:20:30 +01:00
KonradStaniec
b2dab4be08
Re-send acks for old duplicated packets ( #462 )
...
* Re-send acks for old duplicated packets
2022-01-20 09:22:53 +01:00
Kim De Mey
26ab9b078e
Minor adjustments in utp_discv5_protocol ( #459 )
...
- Move SocketConfig parameter location
- Reuse rng from disc5 protocol
- add exports
- Some whitespace clean-up
2022-01-10 13:49:36 +01:00
KonradStaniec
0f18272315
Test vectors upt decoding/encoding ( #458 )
2022-01-07 10:38:36 +01:00
KonradStaniec
fcb0ff521c
Improve logging in uTP ( #457 )
...
* Improve logging
2022-01-07 10:38:19 +01:00
KonradStaniec
9c8e9d9f64
Handle selective acks ( #456 )
...
* Handle selective acks
2022-01-04 09:52:38 +01:00
KonradStaniec
664072fff7
Minor improvements from pr comments ( #455 )
2021-12-28 08:08:05 +01:00
Kim De Mey
2c236f6495
Style fixes according to --styleCheck:usages ( #452 )
...
Currently only setting `--styleCheck:hint` as there are some
dependency fixes required and the compiler seems to trip over the
findnode MessageKind, findnode Message field and the findNode
proc. Also over protocol.Protocol usage.
2021-12-20 13:14:50 +01:00
KonradStaniec
0cfe7df817
Handle packets with selective acks ( #451 )
...
* Handle packets with selective acks
2021-12-15 13:35:17 +01:00
KonradStaniec
b56e19a590
Improve handling of timestamps ( #446 )
...
* Improve handling of timestamps
2021-12-10 16:28:00 +01:00
Kim De Mey
41d2d3c991
Utp top level raises & some clean-up ( #445 )
...
* Add few missing top level raises Defect in uTP
- Add top level {.push raises: [Defect].}
- remove some local raises, including some unneeded
CatchableErrors.
- Don't export messageHandler (avoiding annoying naming collisions)
- export utp_router as those connection callbacks are in the API
* Add some missing copyright clauses
* Some ident and max line length cleanup
* Rename utp_discv5_protocol.nim to be more consistent
2021-12-10 11:12:24 +01:00
KonradStaniec
09959d2a3f
Update timestamp and ackNr on packet resend ( #444 )
...
* Update timestamp and ackNr on packet resend
2021-12-10 10:18:00 +01:00
KonradStaniec
b4066a5688
Ledbat congestion control ( #443 )
...
* Return delay to remote peer
* Initial ledbat window calculation
* Add tests for window grow and decay
* Add delay histograms
* Add calculation of clock drift
2021-12-09 10:52:21 +01:00
KonradStaniec
e7bc10ab00
Add config for max snd buffer size ( #440 )
...
* Add config for max snd buffer size
2021-12-02 16:51:44 +01:00
KonradStaniec
3c8915cae1
Track send buffer and properly handle back pressoure when window is to small to process data ( #437 )
...
* Add separate datastructure to keep track of window
* Asynchronously block write until until new space in snd buffer
* Introduce write loop
* Properly handle write cancellation
* Proper handling of sending fin packet
* Reset remote window after configured amount of time
2021-12-02 15:46:18 +01:00
KonradStaniec
139c6fa2a8
Track current bytes in flight ( #434 )
2021-11-24 17:49:13 +01:00
KonradStaniec
ce296ff76e
Make initial state of socket configurable ( #428 )
...
* Make initial state of socket configurable
2021-11-19 11:36:46 +01:00
KonradStaniec
d5e5ec9f90
Add possibility to connect with requested conneciton id ( #425 )
...
* Improve error handling when initiating connection
* Add api to connect with requested id
* Add callback to allow only specific incoming peers
2021-11-18 10:05:56 +01:00
KonradStaniec
73d9bf4c80
Add ackNr validation ( #424 )
2021-11-15 11:32:00 +01:00
KonradStaniec
8139aae346
Advertise correct rcv buffer size ( #423 )
...
* Advertise correct rcv buffer size
2021-11-12 10:58:49 +01:00
KonradStaniec
b671f6c901
Handling of fin packet ( #421 )
...
* Handling of connection finalization by sending and receiving FIN packets
2021-11-09 15:29:59 +01:00
KonradStaniec
7a113ffa48
Add handling of reset packet ( #420 )
...
* Add handling of reset packet
2021-11-05 09:41:41 +01:00
KonradStaniec
d4cc42241d
Add handling of out of order packets ( #418 )
...
* Add handling of out of order packets
2021-11-04 07:38:46 +01:00
KonradStaniec
34bac6e703
Utp code cleanup ( #417 )
...
* Refactor tests and move socket to separate file
* Move sockets handling to separate class
* Abstract over underlying transport
* Fix bug with receiving duplicated SYN packet
* Fix race condition in connect
2021-10-28 11:41:43 +02:00