ee281310c0
move trace log
2020-06-08 10:40:08 -06:00
82b4ed8f44
use declareCounter rather then gauge for certain metrics
2020-06-07 16:41:23 +09:00
a6a2a81711
Start adding some metrics to pubsub ( #192 )
...
* Start adding some metrics to pubsub
In order to visualize it's functionality
Still WIP
* more metrics
* add per topic metrics
* finishup with requested metrics
* add a metrisServer define to start local server
* PR fixes and cleanup
2020-06-07 09:15:21 +02:00
130c64f33a
don't return nil in dial ( #205 )
...
* dont return nil in dial
* don't crash on pubsub send
2020-06-05 18:17:05 -06:00
2aebae56c0
Don't rely on the side-effects from doAssert
2020-06-05 19:12:10 +03:00
828a80ec8f
Make the MultiAddress.init function used in NBC non-failing
2020-06-05 17:51:22 +03:00
5960d42c50
remove casts from ( #203 )
2020-06-02 20:21:11 -06:00
bb8bff2195
add sparse message propagation tests to gossipsub ( #202 )
...
* add sparce tests to gossipsub
* add send hooks
* remove `all`
2020-06-02 17:53:38 -06:00
285884c20c
Close peers ( #201 )
...
* wip
* exceptions and resource cleanup
* correct peerlifetime on disconnect
* emulate defered
* remove comment
2020-06-02 11:32:42 -06:00
c7298f34f4
additional comments
2020-06-02 09:10:27 -06:00
71640da8f2
remove close from read/write methods
2020-06-02 09:10:27 -06:00
1b4876d26d
emulate `defered`
2020-06-02 09:10:27 -06:00
abf659a01a
more consistent dialing proto selecting logic
2020-06-02 09:10:27 -06:00
86e1c8169c
decorate observers hooks with {.raises: [Defect].}
...
move hooks logic out into standalone procs
License: MIT
Signed-off-by: Dmitriy Ryajov <dryajov@gmail.com>
2020-06-02 09:10:27 -06:00
4df151a3a3
typos
2020-06-02 09:10:27 -06:00
27a7f8c948
move EOF flag after local close and comments
2020-06-02 09:10:27 -06:00
815282a5da
remove all()
2020-06-02 09:10:27 -06:00
293b7da295
typo
2020-06-02 09:10:27 -06:00
6e0eb93d4f
remove readloops
2020-06-02 09:10:27 -06:00
abc12d0fb5
move stram close to a better location
2020-06-02 09:10:27 -06:00
daef00fc7b
don't crash schlesi-dev
2020-06-02 09:10:27 -06:00
640c3bdc45
better exception handling and resource cleanup
2020-06-02 09:10:27 -06:00
7ff76d76b6
better exceptions
2020-06-02 09:10:27 -06:00
95774b2b81
better cleanup
2020-06-02 09:10:27 -06:00
9c2f31262e
wip: try handling child stream exceptions
2020-06-02 09:10:27 -06:00
e3f8f53620
initStream method and better exceptions handling
2020-06-02 09:10:27 -06:00
d3b79b002e
better exceptions and don't fail writes
2020-06-02 09:10:27 -06:00
74f8b5b5f1
resource cleanup
2020-06-02 09:10:27 -06:00
93e5805c01
better exception handling
2020-06-02 09:10:27 -06:00
d83ce4c932
exceptions and resource cleanup
2020-06-02 09:10:27 -06:00
d4bdb42046
gossipsub fixes
2020-06-02 09:10:27 -06:00
9d3cc9647b
fix merge
2020-06-02 09:10:27 -06:00
3d9c0bffba
read from stream
2020-06-02 09:10:27 -06:00
048b1db1ad
revert back allread
2020-06-02 09:10:27 -06:00
8e9716f5c3
remove on transport close cleanup
2020-06-02 09:10:27 -06:00
cf76edb0dd
make noise work again
2020-06-02 09:10:27 -06:00
5158d96eaf
close connection on chronos close
2020-06-02 09:10:27 -06:00
46daed9a38
wip
2020-06-02 09:10:27 -06:00
0f691cbafd
add eof and closed handling
2020-06-02 09:10:27 -06:00
62da2a05c3
wip: rework with proper half-closed
2020-06-02 09:10:27 -06:00
98117a3068
call write until all is written out
2020-06-02 09:10:27 -06:00
802299e69a
breakout from publish loop
2020-06-02 09:10:27 -06:00
7e31210455
cover missing case in MultiAddress.init ( #198 )
...
* cover missing case in MultiAddress.init
* raise assert on marker in protocol
* unify inits for markers / non-markers
* fix string
2020-06-01 14:41:45 +02:00
88dbeebf17
add side effect annotations ( #197 )
2020-06-01 09:25:16 +02:00
37b98ad45c
Secure managers are now sorted, giving priority to noise ( #191 )
...
* Secure managers are now sorted, giving priority to noise
* fix nimble test command
* Fix native tests
* fix directchat sample
* Could not write to connection - reduce verbosity
* fix interop testing
* Remove more tables
* test interop fixes
* directchat fix
* fix interop/remove some deprecation
2020-06-01 08:41:32 +02:00
6affcda937
Less exceptions more results ( #188 )
...
* Less exceptions more results
* Fix daemonapi and interop tests
* Add multibase
* wip multiaddress
* fix the build, consuming new result types
* fix standard setup
* Simplify match, rename into MaError, add more exaustive err text
* Fix the CI issues
* Fix directchat build
* daemon api fixes
* better err messages formatting
Co-authored-by: Zahary Karadjov <zahary@gmail.com>
2020-05-31 16:22:49 +02:00
7c9e5c2f7a
"Could not write to connection" message split between trace and debug due to log size
2020-05-30 23:47:56 +09:00
b88bfc05f8
Make GossipSub initPubSub method public ( #193 )
...
This means we can use it from other protocols that inherit GossipSub. Otherwise,
a lot of internal state (heartbeat lock etc) doesn't get initialized properly.
2020-05-29 09:35:03 -06:00
7b6e1c0688
Gossipsub interop ( #189 )
...
* interop fixes
* add custom messageid provider and fix seqno
* use ECDSA for speed
* adding messageid tests
* breakout from publish loop
* addressing review comments
* remove unneded var
* dont stop broadcasting on failed peers
2020-05-27 12:33:49 -06:00
536555138c
fix "future" typo
2020-05-26 16:08:09 +09:00
Dmitriy Ryajov
Giovanni Petrantoni
Giovanni Petrantoni
Zahary Karadjov
Jacek Sieka
Oskar Thorén