Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
45 commits
Select commit Hold shift + click to select a range
92df222
initial impl.
algonautshant Feb 25, 2020
f4e2d8a
more changes to src and tests
algonautshant Feb 25, 2020
b48b7b1
a few fixes.
algonautshant Feb 26, 2020
a9c85f9
not exporting phonebookImpl
algonautshant Feb 26, 2020
0b14a80
fixes to tests
algonautshant Feb 27, 2020
abbde14
simplifying NewWebsocketNetwork api
algonautshant Feb 27, 2020
0484b41
fixes
algonautshant Feb 27, 2020
46e8228
fixing a test failure: TestNetworkImplFullStackLong/AgreementVoteTag
algonautshant Feb 27, 2020
c5a38aa
addressing Tsachi's comments
algonautshant Feb 27, 2020
9cfb906
initial impl.
algonautshant Feb 25, 2020
4fee158
more changes to src and tests
algonautshant Feb 25, 2020
094be42
a few fixes.
algonautshant Feb 26, 2020
ae43b1b
initial impl.
algonautshant Feb 25, 2020
8b310af
more changes to src and tests
algonautshant Feb 25, 2020
3fee8a7
not exporting phonebookImpl
algonautshant Feb 26, 2020
e7098ba
fixes
algonautshant Feb 27, 2020
1a31f5f
addressing Tsachi's comments
algonautshant Feb 27, 2020
fd0a251
initial impl.
algonautshant Feb 25, 2020
870445b
more changes to src and tests
algonautshant Feb 25, 2020
c980ab4
not exporting phonebookImpl
algonautshant Feb 26, 2020
0470157
fixes
algonautshant Feb 27, 2020
c200f15
addressing Tsachi's comments
algonautshant Feb 27, 2020
3bdb6b8
initial impl.
algonautshant Feb 25, 2020
aa284b8
more changes to src and tests
algonautshant Feb 25, 2020
ab4ffaf
not exporting phonebookImpl
algonautshant Feb 26, 2020
0631430
fixes
algonautshant Feb 27, 2020
8d8105e
fixing rebase merge fallout.
algonautshant Feb 28, 2020
7ab4ee9
initial impl.
algonautshant Feb 25, 2020
c2aad82
more changes to src and tests
algonautshant Feb 25, 2020
887adaa
a few fixes.
algonautshant Feb 26, 2020
91c125c
initial impl.
algonautshant Feb 25, 2020
705565c
more changes to src and tests
algonautshant Feb 25, 2020
9c3e671
not exporting phonebookImpl
algonautshant Feb 26, 2020
ad7ffaf
fixes
algonautshant Feb 27, 2020
7997e66
addressing Tsachi's comments
algonautshant Feb 27, 2020
79c4ea5
initial impl.
algonautshant Feb 25, 2020
317b972
more changes to src and tests
algonautshant Feb 25, 2020
cb19057
not exporting phonebookImpl
algonautshant Feb 26, 2020
34423e5
fixes
algonautshant Feb 27, 2020
50525fa
initial impl.
algonautshant Feb 25, 2020
3c4f0a6
more changes to src and tests
algonautshant Feb 25, 2020
cf00e9f
fixes
algonautshant Feb 27, 2020
1d47104
fixing rebase fallout
algonautshant Feb 28, 2020
b3520b4
Addressing Pavel's comments.
algonautshant Mar 1, 2020
bd583b8
Fixing test TestNetworkImplFullStackQuick
algonautshant Mar 2, 2020
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 3 additions & 3 deletions agreement/gossip/networkFull_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -60,9 +60,9 @@ func spinNetwork(t *testing.T, nodesCount int) ([]*networkImpl, []*messageCounte
start := time.Now()
nodesAddresses := []string{}
gossipNodes := []network.GossipNode{}
phonebooks := make([]*network.ThreadsafePhonebook, nodesCount)
phonebooks := make([]network.Phonebook, nodesCount)
for nodeIdx := 0; nodeIdx < nodesCount; nodeIdx++ {
phonebooks[nodeIdx] = network.MakeThreadsafePhonebook(cfg.ConnectionsRateLimitingCount,
phonebooks[nodeIdx] = network.MakePhonebook(cfg.ConnectionsRateLimitingCount,
time.Duration(cfg.ConnectionsRateLimitingWindowSeconds)*time.Second)
gossipNode, err := network.NewWebsocketGossipNode(log.With("node", nodeIdx), cfg, phonebooks[nodeIdx], "go-test-agreement-network-genesis", config.Devtestnet)
if err != nil {
Expand All @@ -78,7 +78,7 @@ func spinNetwork(t *testing.T, nodesCount int) ([]*networkImpl, []*messageCounte
for nodeIdx, gossipNode := range gossipNodes {
others := []string{}
others = append(others, nodesAddresses[nodeIdx+1:]...)
phonebooks[nodeIdx].ReplacePeerList(others)
phonebooks[nodeIdx].ReplacePeerList(others, "")
log.Debugf("phonebook[%d] %#v", nodeIdx, others)
gossipNode.RequestConnectOutgoing(false, nil) // no disconnect.
}
Expand Down
4 changes: 2 additions & 2 deletions cmd/netdummy/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -47,9 +47,9 @@ func main() {
log.SetLevel(logging.Debug)
log.SetOutput(os.Stderr)

addrs := network.MakeArrayPhonebook(conf.ConnectionsRateLimitingCount,
addrs := network.MakePhonebook(conf.ConnectionsRateLimitingCount,
time.Duration(conf.ConnectionsRateLimitingWindowSeconds)*time.Second)
addrs.Entries.ReplacePeerList([]string{*serverAddress})
addrs.ReplacePeerList([]string{*serverAddress}, conf.DNSBootstrapID)

var nodes []network.GossipNode
for i := 0; i < *numClients; i++ {
Expand Down
4 changes: 2 additions & 2 deletions network/dialer.go
Original file line number Diff line number Diff line change
Expand Up @@ -30,14 +30,14 @@ type netDialer interface {

// Dialer establish tcp-level connection with the destination
type Dialer struct {
phonebook *MultiPhonebook
phonebook Phonebook
innerDialer netDialer
resolver *net.Resolver
}

// makeRateLimitingDialer creates a rate limiting dialer that would limit the connections
// according to the entries in the phonebook.
func makeRateLimitingDialer(phonebook *MultiPhonebook, resolver *dnssec.Resolver) Dialer {
func makeRateLimitingDialer(phonebook Phonebook, resolver *dnssec.Resolver) Dialer {
var innerDialer netDialer = &net.Dialer{
Timeout: 30 * time.Second,
KeepAlive: 30 * time.Second,
Expand Down
Loading