diff --git a/swarm/network/stream/stream.go b/swarm/network/stream/stream.go index 62fc5db7f9..32e107823b 100644 --- a/swarm/network/stream/stream.go +++ b/swarm/network/stream/stream.go @@ -734,7 +734,7 @@ func (c *clientParams) clientCreated() { close(c.clientCreatedC) } -//Return the streamer spec to callers +//GetSpec returns the streamer spec to callers //This used to be a global variable but for simulations with //multiple nodes its fields (notably the Hook) would be overwritten func (r *Registry) GetSpec() *protocols.Spec { @@ -742,11 +742,10 @@ func (r *Registry) GetSpec() *protocols.Spec { } func (r *Registry) createSpec() { - // Spec is the spec of the streamer protocol var spec = &protocols.Spec{ Name: "stream", - Version: 7, + Version: 8, MaxMsgSize: 10 * 1024 * 1024, Messages: []interface{}{ UnsubscribeMsg{}, @@ -772,8 +771,6 @@ func (r *Registry) Protocols() []p2p.Protocol { Version: r.spec.Version, Length: r.spec.Length(), Run: r.runProtocol, - // NodeInfo: , - // PeerInfo: , }, } } diff --git a/swarm/swap/swap.go b/swarm/swap/swap.go index 7821f035df..137eb141d9 100644 --- a/swarm/swap/swap.go +++ b/swarm/swap/swap.go @@ -69,7 +69,7 @@ func (s *Swap) Add(amount int64, peer *protocols.Peer) (err error) { return err } -//Get a peer's balance +//GetPeerBalance returns the balance for a given peer func (swap *Swap) GetPeerBalance(peer enode.ID) (int64, error) { swap.lock.RLock() defer swap.lock.RUnlock() diff --git a/swarm/swap/swap_test.go b/swarm/swap/swap_test.go index 2c1f54792f..f2e3ba168a 100644 --- a/swarm/swap/swap_test.go +++ b/swarm/swap/swap_test.go @@ -1,4 +1,4 @@ -// Copyreeeeight 2018 The go-ethereum Authors +// Copyright 2018 The go-ethereum Authors // This file is part of the go-ethereum library. // // The go-ethereum library is free software: you can redistribute it and/or modify