 Alexander Simmerl
|
5796e879b9
|
Introduce option to skip duplicate ip check
In some scenarios like tests we want to disable the guard which prevents
peers connecting from the same ip.
Fixes #1632
Closes #1634
|
7 years ago |
 Anton Kaliaev
|
4da81aa0b7
|
commented out TestPEXReactorRunning
|
7 years ago |
|
Anton Kaliaev
|
67068a34f2
|
log requesting addresses
|
7 years ago |
|
Anton Kaliaev
|
2a0e9f93ce
|
provide arg to error
BEFORE:
```
E[05-24|11:55:37.229] Dialing failed pex=0 addr=022ec801d79025caab3afbbf816d92ff8450d040@127.0.0.2:6593 err="Connect to self: <nil>" attempts=0
```
AFTER:
```
E[05-24|11:55:37.229] Dialing failed pex=0 addr=022ec801d79025caab3afbbf816d92ff8450d040@127.0.0.2:6593 err="Connect to self: 022ec801d79025caab3afbbf816d92ff8450d040@127.0.0.2:6593" attempts=0
```
|
7 years ago |
 Zach Ramsay
|
423fef1416
|
docs: use absolute links (#1617)
|
7 years ago |
|
Alexander Simmerl
|
186d38dd8a
|
Use different loopback addresses for test switch
|
7 years ago |
|
Alexander Simmerl
|
01fd102dba
|
Incoporate review feedback
|
7 years ago |
|
Alexander Simmerl
|
e11f3167ff
|
Fix pex reactor test
|
7 years ago |
|
Alexander Simmerl
|
7d98cfd3d6
|
Test duplicate IP guard in peer set
|
7 years ago |
|
Alexander Simmerl
|
4848e88737
|
Fix persistent peer switch test
|
7 years ago |
|
Zach Ramsay
|
60d7486de2
|
docs: fix dead links, closes #1608
|
7 years ago |
|
Alexander Simmerl
|
91b6d3f18c
|
Do not set address for self error
|
7 years ago |
|
Alexander Simmerl
|
20e9dd0737
|
Return fake IP even when there is no conn
|
7 years ago |
|
Alexander Simmerl
|
0cd92a4948
|
Fix race in test suffix
|
7 years ago |
|
Alexander Simmerl
|
d596ed1bc2
|
Let peerConn handle IPs in for tests
|
7 years ago |
|
Anton Kaliaev
|
5a041baa36
|
nice output for msgBytes
Closes #1227
|
7 years ago |
|
Alexander Simmerl
|
b698a9febc
|
Remove double locking in HasIP
|
7 years ago |
|
Alexander Simmerl
|
c5f45275ec
|
Use remotePeer for test switch
|
7 years ago |
|
Alexander Simmerl
|
77f09f5b5e
|
Move to ne.IP
|
7 years ago |
 Ethan Buchman
|
1fe41be929
|
p2p: prevent connections from same ip
|
7 years ago |
|
Ethan Buchman
|
68a0b3f95b
|
version bump. add roadmap back. minor fixes
|
7 years ago |
 Jae Kwon
|
edbec10f9e
|
Expose peer stats for dump_consensus_state
|
7 years ago |
|
Ethan Buchman
|
b6c062c451
|
fixes from review
|
7 years ago |
|
Ethan Buchman
|
c195772de1
|
p2p: small lint
|
7 years ago |
|
Ethan Buchman
|
fae94a44a2
|
p2p/pex: some addrbook fixes
* fix before/after in isBad()
* allow multiple IPs per ID even if ID isOld
|
7 years ago |
|
Ethan Buchman
|
3a30ee75b9
|
minor fixes
|
7 years ago |
|
Ethan Buchman
|
3498b676a6
|
update spec and addrbook.go
|
7 years ago |
|
Ethan Buchman
|
6157c700dd
|
forgot errors file
|
7 years ago |
|
Ethan Buchman
|
c90bf77566
|
rpc: add n_peers to /net_info
|
7 years ago |
|
Ethan Buchman
|
6805ddf1b8
|
p2p: change some logs from Error to Debug. #1476
|
7 years ago |
|
Ethan Buchman
|
2761861b6b
|
p2p: MinNumOutboundPeers. Closes #1501
|
7 years ago |
|
Ethan Buchman
|
64569b15e5
|
fix build and test
|
7 years ago |
|
Ethan Buchman
|
0450e35d67
|
some comments
|
7 years ago |
|
Ethan Buchman
|
aaa81092e7
|
p2p: some comments and a log line
|
7 years ago |
|
Ethan Buchman
|
3ee1d7909e
|
p2p: explicit netaddress errors
|
7 years ago |
|
Ethan Buchman
|
32268a8135
|
limit maxPexMessageSize based on maxAddressSize
|
7 years ago |
|
Ethan Buchman
|
40c79235c0
|
p2p: dont require minor versions to match in handshake
|
7 years ago |
|
Ethan Buchman
|
c23909eecf
|
p2p/pex: minor cleanup and comments
|
7 years ago |
|
Ethan Buchman
|
936d1a0e68
|
some notes about the p2p layer
|
7 years ago |
|
Ethan Buchman
|
0cbbb61962
|
minor cleanup
|
7 years ago |
|
Ethan Buchman
|
94e823cc91
|
p2p: NodeInfo.Channels is HexBytes
|
7 years ago |
|
Anton Kaliaev
|
3a0edc561d
|
log error from AddrBook#AddAddress in DialPeersAsync
Refs #1434
|
7 years ago |
 Thomas Corbière
|
ab00bf7c8b
|
standardize PRNG access (#1411)
* replace math/rand with tmlibs equivalent.
* update tmlibs dependency
|
7 years ago |
 Vladislav Dmitriyev
|
7c22e47629
|
Replaced NodeInfo's pubkey to ID (#1443)
* Replaced NodeInfo PubKey to NodeID
* Fixed tests and replaced NodeID with ID
* Removed unnecessary method ID()
* Fixed codec_test.go
* Fixed codec_test.go
* Removed unnecessary bracket
* Fixed all tests
* Fixed peer_set_test.go
* Fixed peer_test.go
* Fixed common_test.go
* Fixed common_test.go
* Renamed node_id to id
* Removed peer.ID() from RPC net.go
* Replaced NodeInfo pubKey to ID
* Fixed codec_test.go
* Fixed peer_set_test.go
* Fix pex_reactor_test.go
* Refactored code for privateKey initiali
* Fixed peer_set_test.go
* Fixed test.proto and removed orphan string in codec_test.go
* Fixed pointer to a string
* generate node_key when running tendermint init
* [docs] prefix IPs with node IDs
Refs #1429
* gen_node_key cmd
* [docs/specification/secure-p2p] add a note about config
* fix data race
Closes #1442
```
WARNING: DATA RACE
Write at 0x00c4209de7c8 by goroutine 23:
github.com/tendermint/tendermint/types.(*Block).fillHeader()
/home/vagrant/go/src/github.com/tendermint/tendermint/types/block.go:88 +0x157
github.com/tendermint/tendermint/types.(*Block).Hash()
/home/vagrant/go/src/github.com/tendermint/tendermint/types/block.go:104 +0x121
github.com/tendermint/tendermint/types.(*Block).HashesTo()
/home/vagrant/go/src/github.com/tendermint/tendermint/types/block.go:135 +0x4f
github.com/tendermint/tendermint/consensus.(*ConsensusState).enterPrecommit()
/home/vagrant/go/src/github.com/tendermint/tendermint/consensus/state.go:1037 +0x182d
github.com/tendermint/tendermint/consensus.(*ConsensusState).addVote()
/home/vagrant/go/src/github.com/tendermint/tendermint/consensus/state.go:1425 +0x1a6c
github.com/tendermint/tendermint/consensus.(*ConsensusState).tryAddVote()
/home/vagrant/go/src/github.com/tendermint/tendermint/consensus/state.go:1318 +0x77
github.com/tendermint/tendermint/consensus.(*ConsensusState).handleMsg()
/home/vagrant/go/src/github.com/tendermint/tendermint/consensus/state.go:581 +0x7a9
github.com/tendermint/tendermint/consensus.(*ConsensusState).receiveRoutine()
/home/vagrant/go/src/github.com/tendermint/tendermint/consensus/state.go:539 +0x6c3
Previous read at 0x00c4209de7c8 by goroutine 47:
github.com/tendermint/tendermint/vendor/github.com/tendermint/tmlibs/common.(*HexBytes).MarshalJSON()
<autogenerated>:1 +0x52
github.com/tendermint/tendermint/vendor/github.com/tendermint/go-amino.invokeMarshalJSON()
/home/vagrant/go/src/github.com/tendermint/tendermint/vendor/github.com/tendermint/go-amino/json-encode.go:433 +0x88
github.com/tendermint/tendermint/vendor/github.com/tendermint/go-amino.(*Codec)._encodeReflectJSON()
/home/vagrant/go/src/github.com/tendermint/tendermint/vendor/github.com/tendermint/go-amino/json-encode.go:82 +0x8d2
github.com/tendermint/tendermint/vendor/github.com/tendermint/go-amino.(*Codec).encodeReflectJSON()
/home/vagrant/go/src/github.com/tendermint/tendermint/vendor/github.com/tendermint/go-amino/json-encode.go:50 +0x10e
github.com/tendermint/tendermint/vendor/github.com/tendermint/go-amino.(*Codec).encodeReflectJSONStruct()
/home/vagrant/go/src/github.com/tendermint/tendermint/vendor/github.com/tendermint/go-amino/json-encode.go:348 +0x539
github.com/tendermint/tendermint/vendor/github.com/tendermint/go-amino.(*Codec)._encodeReflectJSON()
/home/vagrant/go/src/github.com/tendermint/tendermint/vendor/github.com/tendermint/go-amino/json-encode.go:119 +0x83f
github.com/tendermint/tendermint/vendor/github.com/tendermint/go-amino.(*Codec).encodeReflectJSON()
/home/vagrant/go/src/github.com/tendermint/tendermint/vendor/github.com/tendermint/go-amino/json-encode.go:50 +0x10e
github.com/tendermint/tendermint/vendor/github.com/tendermint/go-amino.(*Codec).encodeReflectJSONStruct()
/home/vagrant/go/src/github.com/tendermint/tendermint/vendor/github.com/tendermint/go-amino/json-encode.go:348 +0x539
github.com/tendermint/tendermint/vendor/github.com/tendermint/go-amino.(*Codec)._encodeReflectJSON()
/home/vagrant/go/src/github.com/tendermint/tendermint/vendor/github.com/tendermint/go-amino/json-encode.go:119 +0x83f
github.com/tendermint/tendermint/vendor/github.com/tendermint/go-amino.(*Codec).encodeReflectJSON()
/home/vagrant/go/src/github.com/tendermint/tendermint/vendor/github.com/tendermint/go-amino/json-encode.go:50 +0x10e
github.com/tendermint/tendermint/vendor/github.com/tendermint/go-amino.(*Codec).encodeReflectJSONStruct()
/home/vagrant/go/src/github.com/tendermint/tendermint/vendor/github.com/tendermint/go-amino/json-encode.go:348 +0x539
github.com/tendermint/tendermint/vendor/github.com/tendermint/go-amino.(*Codec)._encodeReflectJSON()
/home/vagrant/go/src/github.com/tendermint/tendermint/vendor/github.com/tendermint/go-amino/json-encode.go:119 +0x83f
github.com/tendermint/tendermint/vendor/github.com/tendermint/go-amino.(*Codec).encodeReflectJSON()
/home/vagrant/go/src/github.com/tendermint/tendermint/vendor/github.com/tendermint/go-amino/json-encode.go:50 +0x10e
github.com/tendermint/tendermint/vendor/github.com/tendermint/go-amino.(*Codec).encodeReflectJSONStruct()
/home/vagrant/go/src/github.com/tendermint/tendermint/vendor/github.com/tendermint/go-amino/json-encode.go:348 +0x539
github.com/tendermint/tendermint/vendor/github.com/tendermint/go-amino.(*Codec)._encodeReflectJSON()
/home/vagrant/go/src/github.com/tendermint/tendermint/vendor/github.com/tendermint/go-amino/json-encode.go:119 +0x83f
github.com/tendermint/tendermint/vendor/github.com/tendermint/go-amino.(*Codec).encodeReflectJSON()
/home/vagrant/go/src/github.com/tendermint/tendermint/vendor/github.com/tendermint/go-amino/json-encode.go:50 +0x10e
github.com/tendermint/tendermint/vendor/github.com/tendermint/go-amino.(*Codec).MarshalJSON()
/home/vagrant/go/src/github.com/tendermint/tendermint/vendor/github.com/tendermint/go-amino/amino.go:296 +0x182
github.com/tendermint/tendermint/rpc/lib/types.NewRPCSuccessResponse()
/home/vagrant/go/src/github.com/tendermint/tendermint/rpc/lib/types/types.go:100 +0x12c
github.com/tendermint/tendermint/rpc/lib/server.makeJSONRPCHandler.func1()
/home/vagrant/go/src/github.com/tendermint/tendermint/rpc/lib/server/handlers.go:152 +0xab7
net/http.HandlerFunc.ServeHTTP()
/usr/lib/go-1.9/src/net/http/server.go:1918 +0x51
net/http.(*ServeMux).ServeHTTP()
/usr/lib/go-1.9/src/net/http/server.go:2254 +0xa2
github.com/tendermint/tendermint/rpc/lib/server.RecoverAndLogHandler.func1()
/home/vagrant/go/src/github.com/tendermint/tendermint/rpc/lib/server/http_server.go:138 +0x4fa
net/http.HandlerFunc.ServeHTTP()
/usr/lib/go-1.9/src/net/http/server.go:1918 +0x51
net/http.serverHandler.ServeHTTP()
/usr/lib/go-1.9/src/net/http/server.go:2619 +0xbc
net/http.(*conn).serve()
/usr/lib/go-1.9/src/net/http/server.go:1801 +0x83b
Goroutine 23 (running) created at:
github.com/tendermint/tendermint/consensus.(*ConsensusState).OnStart()
/home/vagrant/go/src/github.com/tendermint/tendermint/consensus/state.go:250 +0x35b
github.com/tendermint/tendermint/vendor/github.com/tendermint/tmlibs/common.(*BaseService).Start()
/home/vagrant/go/src/github.com/tendermint/tendermint/vendor/github.com/tendermint/tmlibs/common/service.go:130 +0x5fc
github.com/tendermint/tendermint/consensus.(*ConsensusReactor).OnStart()
/home/vagrant/go/src/github.com/tendermint/tendermint/consensus/reactor.go:69 +0x1b4
github.com/tendermint/tendermint/vendor/github.com/tendermint/tmlibs/common.(*BaseService).Start()
/home/vagrant/go/src/github.com/tendermint/tendermint/vendor/github.com/tendermint/tmlibs/common/service.go:130 +0x5fc
github.com/tendermint/tendermint/consensus.(*ConsensusReactor).Start()
<autogenerated>:1 +0x43
github.com/tendermint/tendermint/p2p.(*Switch).OnStart()
/home/vagrant/go/src/github.com/tendermint/tendermint/p2p/switch.go:177 +0x124
github.com/tendermint/tendermint/vendor/github.com/tendermint/tmlibs/common.(*BaseService).Start()
/home/vagrant/go/src/github.com/tendermint/tendermint/vendor/github.com/tendermint/tmlibs/common/service.go:130 +0x5fc
github.com/tendermint/tendermint/node.(*Node).OnStart()
/home/vagrant/go/src/github.com/tendermint/tendermint/node/node.go:416 +0xa1b
github.com/tendermint/tendermint/vendor/github.com/tendermint/tmlibs/common.(*BaseService).Start()
/home/vagrant/go/src/github.com/tendermint/tendermint/vendor/github.com/tendermint/tmlibs/common/service.go:130 +0x5fc
github.com/tendermint/tendermint/rpc/test.StartTendermint()
/home/vagrant/go/src/github.com/tendermint/tendermint/rpc/test/helpers.go:100 +0x5b
github.com/tendermint/tendermint/rpc/client_test.TestMain()
/home/vagrant/go/src/github.com/tendermint/tendermint/rpc/client/main_test.go:17 +0x4c
main.main()
github.com/tendermint/tendermint/rpc/client/_test/_testmain.go:76 +0x1cd
Goroutine 47 (running) created at:
net/http.(*Server).Serve()
/usr/lib/go-1.9/src/net/http/server.go:2720 +0x37c
net/http.Serve()
/usr/lib/go-1.9/src/net/http/server.go:2323 +0xe2
github.com/tendermint/tendermint/rpc/lib/server.StartHTTPServer.func1()
/home/vagrant/go/src/github.com/tendermint/tendermint/rpc/lib/server/http_server.go:35 +0xb3
```
* removed excessive comment
Refs https://github.com/tendermint/tendermint/pull/1446#discussion_r180353446
* use the tag interface for pubsub. (#1438)
* use the tag interface for pubsub.
* update tmlibs.
* Fix unresolved conflict.
* improve `show_node_id` (#1433)
* fix show_node_id
* make LoadNodeKey public
* make LoadNodeKey public
* remove if
* remove if
|
7 years ago |
 suyuhuang
|
384b3ea065
|
improve `show_node_id` (#1433)
* fix show_node_id
* make LoadNodeKey public
* make LoadNodeKey public
* remove if
* remove if
|
7 years ago |
|
Ethan Buchman
|
1a1e4e767b
|
check max msg size in DecodeMessage
|
7 years ago |
|
Ethan Buchman
|
c68d406195
|
fix tests
|
7 years ago |
|
Ethan Buchman
|
02c0835e9b
|
fixes post merge
|
7 years ago |
 Javed Khan
|
5d8767e656
|
p2p: don't use dial funcn in peerconfig
|
7 years ago |
|
Javed Khan
|
54adb790f2
|
p2p: switch - reconnect only if persistent
|
7 years ago |
