diff --git a/internal/jsre/deps/web3.js b/internal/jsre/deps/web3.js index 9bb899384b..22acb9f863 100644 --- a/internal/jsre/deps/web3.js +++ b/internal/jsre/deps/web3.js @@ -2307,7 +2307,7 @@ var toChecksumAddress = function (address) { }; /** - * Transforms given string to valid 20 bytes-length addres with 0x prefix + * Transforms given string to valid 20 bytes-length address with 0x prefix * * @method toAddress * @param {String} address diff --git a/p2p/protocols/protocol.go b/p2p/protocols/protocol.go index 7b04069edf..bb934ca45a 100644 --- a/p2p/protocols/protocol.go +++ b/p2p/protocols/protocol.go @@ -183,7 +183,7 @@ type Peer struct { // NewPeer constructs a new peer // this constructor is called by the p2p.Protocol#Run function -// the first two arguments are comming the arguments passed to p2p.Protocol.Run function +// the first two arguments are coming the arguments passed to p2p.Protocol.Run function // the third argument is the CodeMap describing the protocol messages and options func NewPeer(p *p2p.Peer, rw p2p.MsgReadWriter, spec *Spec) *Peer { return &Peer{ diff --git a/p2p/protocols/protocol_test.go b/p2p/protocols/protocol_test.go index c79d34eee6..8216bb956a 100644 --- a/p2p/protocols/protocol_test.go +++ b/p2p/protocols/protocol_test.go @@ -154,18 +154,18 @@ func protocolTester(t *testing.T, pp *p2ptest.TestPeerPool) *p2ptest.ProtocolTes func protoHandshakeExchange(id discover.NodeID, proto *protoHandshake) []p2ptest.Exchange { return []p2ptest.Exchange{ - p2ptest.Exchange{ + { Expects: []p2ptest.Expect{ - p2ptest.Expect{ + { Code: 0, Msg: &protoHandshake{42, "420"}, Peer: id, }, }, }, - p2ptest.Exchange{ + { Triggers: []p2ptest.Trigger{ - p2ptest.Trigger{ + { Code: 0, Msg: proto, Peer: id, @@ -207,18 +207,18 @@ func TestProtoHandshakeSuccess(t *testing.T) { func moduleHandshakeExchange(id discover.NodeID, resp uint) []p2ptest.Exchange { return []p2ptest.Exchange{ - p2ptest.Exchange{ + { Expects: []p2ptest.Expect{ - p2ptest.Expect{ + { Code: 1, Msg: &hs0{42}, Peer: id, }, }, }, - p2ptest.Exchange{ + { Triggers: []p2ptest.Trigger{ - p2ptest.Trigger{ + { Code: 1, Msg: &hs0{resp}, Peer: id, @@ -255,42 +255,42 @@ func TestModuleHandshakeSuccess(t *testing.T) { func testMultiPeerSetup(a, b discover.NodeID) []p2ptest.Exchange { return []p2ptest.Exchange{ - p2ptest.Exchange{ + { Label: "primary handshake", Expects: []p2ptest.Expect{ - p2ptest.Expect{ + { Code: 0, Msg: &protoHandshake{42, "420"}, Peer: a, }, - p2ptest.Expect{ + { Code: 0, Msg: &protoHandshake{42, "420"}, Peer: b, }, }, }, - p2ptest.Exchange{ + { Label: "module handshake", Triggers: []p2ptest.Trigger{ - p2ptest.Trigger{ + { Code: 0, Msg: &protoHandshake{42, "420"}, Peer: a, }, - p2ptest.Trigger{ + { Code: 0, Msg: &protoHandshake{42, "420"}, Peer: b, }, }, Expects: []p2ptest.Expect{ - p2ptest.Expect{ + { Code: 1, Msg: &hs0{42}, Peer: a, }, - p2ptest.Expect{ + { Code: 1, Msg: &hs0{42}, Peer: b, @@ -298,10 +298,10 @@ func testMultiPeerSetup(a, b discover.NodeID) []p2ptest.Exchange { }, }, - p2ptest.Exchange{Label: "alternative module handshake", Triggers: []p2ptest.Trigger{p2ptest.Trigger{Code: 1, Msg: &hs0{41}, Peer: a}, - p2ptest.Trigger{Code: 1, Msg: &hs0{41}, Peer: b}}}, - p2ptest.Exchange{Label: "repeated module handshake", Triggers: []p2ptest.Trigger{p2ptest.Trigger{Code: 1, Msg: &hs0{1}, Peer: a}}}, - p2ptest.Exchange{Label: "receiving repeated module handshake", Expects: []p2ptest.Expect{p2ptest.Expect{Code: 1, Msg: &hs0{43}, Peer: a}}}} + {Label: "alternative module handshake", Triggers: []p2ptest.Trigger{{Code: 1, Msg: &hs0{41}, Peer: a}, + {Code: 1, Msg: &hs0{41}, Peer: b}}}, + {Label: "repeated module handshake", Triggers: []p2ptest.Trigger{{Code: 1, Msg: &hs0{1}, Peer: a}}}, + {Label: "receiving repeated module handshake", Expects: []p2ptest.Expect{{Code: 1, Msg: &hs0{43}, Peer: a}}}} } func runMultiplePeers(t *testing.T, peer int, errs ...error) { @@ -327,7 +327,7 @@ func runMultiplePeers(t *testing.T, peer int, errs ...error) { // peer 0 sends kill request for peer with index s.TestExchanges(p2ptest.Exchange{ Triggers: []p2ptest.Trigger{ - p2ptest.Trigger{ + { Code: 2, Msg: &kill{s.IDs[peer]}, Peer: s.IDs[0], @@ -338,7 +338,7 @@ func runMultiplePeers(t *testing.T, peer int, errs ...error) { // the peer not killed sends a drop request s.TestExchanges(p2ptest.Exchange{ Triggers: []p2ptest.Trigger{ - p2ptest.Trigger{ + { Code: 3, Msg: &drop{}, Peer: s.IDs[(peer+1)%2], diff --git a/pot/doc.go b/pot/doc.go index 47d0357d93..4c0a03065d 100644 --- a/pot/doc.go +++ b/pot/doc.go @@ -48,8 +48,8 @@ concurrent routines, Pot * retrieval, insertion and deletion by key involves log(n) pointer lookups * for any item retrieval (defined as common prefix on the binary key) -* provide syncronous iterators respecting proximity ordering wrt any item -* provide asyncronous iterator (for parallel execution of operations) over n items +* provide synchronous iterators respecting proximity ordering wrt any item +* provide asynchronous iterator (for parallel execution of operations) over n items * allows cheap iteration over ranges * asymmetric concurrent merge (union) diff --git a/pot/pot.go b/pot/pot.go index 87f51af49c..dfda84804d 100644 --- a/pot/pot.go +++ b/pot/pot.go @@ -559,7 +559,7 @@ func (t *Pot) eachBin(val Val, pof Pof, po int, f func(int, int, func(func(val V } -// EachNeighbour is a syncronous iterator over neighbours of any target val +// EachNeighbour is a synchronous iterator over neighbours of any target val // the order of elements retrieved reflect proximity order to the target // TODO: add maximum proxbin to start range of iteration func (t *Pot) EachNeighbour(val Val, pof Pof, f func(Val, int) bool) bool { @@ -615,7 +615,7 @@ func (t *Pot) eachNeighbour(val Val, pof Pof, f func(Val, int) bool) bool { return true } -// EachNeighbourAsync called on (val, max, maxPos, f, wait) is an asyncronous iterator +// EachNeighbourAsync called on (val, max, maxPos, f, wait) is an asynchronous iterator // over elements not closer than maxPos wrt val. // val does not need to be match an element of the Pot, but if it does, and // maxPos is keylength than it is included in the iteration @@ -762,7 +762,7 @@ func (t *Pot) eachNeighbourAsync(val Val, pof Pof, max int, maxPos int, f func(V // getPos called on (n) returns the forking node at PO n and its index if it exists // otherwise nil -// caller is suppoed to hold the lock +// caller is supposed to hold the lock func (t *Pot) getPos(po int) (n *Pot, i int) { for i, n = range t.bins { if po > n.po { diff --git a/swarm/network/discovery_test.go b/swarm/network/discovery_test.go index 50e1f468b6..695f9fbcb4 100644 --- a/swarm/network/discovery_test.go +++ b/swarm/network/discovery_test.go @@ -47,7 +47,7 @@ func TestDiscovery(t *testing.T) { s.TestExchanges(p2ptest.Exchange{ Label: "outgoing SubPeersMsg", Expects: []p2ptest.Expect{ - p2ptest.Expect{ + { Code: 3, Msg: &subPeersMsg{Depth: 0}, Peer: s.ProtocolTester.IDs[0], diff --git a/swarm/network/kademlia.go b/swarm/network/kademlia.go index 376ba9ad5a..d7bb7be6d7 100644 --- a/swarm/network/kademlia.go +++ b/swarm/network/kademlia.go @@ -424,7 +424,7 @@ func (k *Kademlia) callable(val pot.Val) OverlayAddr { return e.addr() } -// BaseAddr return the kademlia base addres +// BaseAddr return the kademlia base address func (k *Kademlia) BaseAddr() []byte { return k.base } diff --git a/swarm/network/protocol.go b/swarm/network/protocol.go index f133c6084d..0cf682fb98 100644 --- a/swarm/network/protocol.go +++ b/swarm/network/protocol.go @@ -262,7 +262,7 @@ func NewBzzTestPeer(p *protocols.Peer, addr *BzzAddr) *BzzPeer { } } -// Off returns the overlay peer record for offline persistance +// Off returns the overlay peer record for offline persistence func (p *BzzPeer) Off() OverlayAddr { return p.BzzAddr } diff --git a/swarm/network/protocol_test.go b/swarm/network/protocol_test.go index c603da7e8e..208f830fbf 100644 --- a/swarm/network/protocol_test.go +++ b/swarm/network/protocol_test.go @@ -70,18 +70,18 @@ func (t *testStore) Save(key string, v []byte) error { func HandshakeMsgExchange(lhs, rhs *HandshakeMsg, id discover.NodeID) []p2ptest.Exchange { return []p2ptest.Exchange{ - p2ptest.Exchange{ + { Expects: []p2ptest.Expect{ - p2ptest.Expect{ + { Code: 0, Msg: lhs, Peer: id, }, }, }, - p2ptest.Exchange{ + { Triggers: []p2ptest.Trigger{ - p2ptest.Trigger{ + { Code: 0, Msg: rhs, Peer: id, diff --git a/swarm/network/stream/delivery_test.go b/swarm/network/stream/delivery_test.go index 183ea2b9e9..2f291a7957 100644 --- a/swarm/network/stream/delivery_test.go +++ b/swarm/network/stream/delivery_test.go @@ -57,7 +57,7 @@ func TestStreamerRetrieveRequest(t *testing.T) { err = tester.TestExchanges(p2ptest.Exchange{ Label: "RetrieveRequestMsg", Expects: []p2ptest.Expect{ - p2ptest.Expect{ + { Code: 5, Msg: &RetrieveRequestMsg{ Key: hash0[:], @@ -97,7 +97,7 @@ func TestStreamerUpstreamRetrieveRequestMsgExchangeWithoutStore(t *testing.T) { err = tester.TestExchanges(p2ptest.Exchange{ Label: "RetrieveRequestMsg", Triggers: []p2ptest.Trigger{ - p2ptest.Trigger{ + { Code: 5, Msg: &RetrieveRequestMsg{ Key: chunk.Key[:], @@ -106,7 +106,7 @@ func TestStreamerUpstreamRetrieveRequestMsgExchangeWithoutStore(t *testing.T) { }, }, Expects: []p2ptest.Expect{ - p2ptest.Expect{ + { Code: 1, Msg: &OfferedHashesMsg{ HandoverProof: nil, @@ -154,7 +154,7 @@ func TestStreamerUpstreamRetrieveRequestMsgExchange(t *testing.T) { err = tester.TestExchanges(p2ptest.Exchange{ Label: "RetrieveRequestMsg", Triggers: []p2ptest.Trigger{ - p2ptest.Trigger{ + { Code: 5, Msg: &RetrieveRequestMsg{ Key: hash, @@ -163,7 +163,7 @@ func TestStreamerUpstreamRetrieveRequestMsgExchange(t *testing.T) { }, }, Expects: []p2ptest.Expect{ - p2ptest.Expect{ + { Code: 1, Msg: &OfferedHashesMsg{ HandoverProof: &HandoverProof{ @@ -194,7 +194,7 @@ func TestStreamerUpstreamRetrieveRequestMsgExchange(t *testing.T) { err = tester.TestExchanges(p2ptest.Exchange{ Label: "RetrieveRequestMsg", Triggers: []p2ptest.Trigger{ - p2ptest.Trigger{ + { Code: 5, Msg: &RetrieveRequestMsg{ Key: hash, @@ -204,7 +204,7 @@ func TestStreamerUpstreamRetrieveRequestMsgExchange(t *testing.T) { }, }, Expects: []p2ptest.Expect{ - p2ptest.Expect{ + { Code: 6, Msg: &ChunkDeliveryMsg{ Key: hash, @@ -256,7 +256,7 @@ func TestStreamerDownstreamChunkDeliveryMsgExchange(t *testing.T) { err = tester.TestExchanges(p2ptest.Exchange{ Label: "Subscribe message", Expects: []p2ptest.Expect{ - p2ptest.Expect{ + { Code: 4, Msg: &SubscribeMsg{ Stream: "foo", @@ -272,7 +272,7 @@ func TestStreamerDownstreamChunkDeliveryMsgExchange(t *testing.T) { p2ptest.Exchange{ Label: "ChunkDeliveryRequest message", Triggers: []p2ptest.Trigger{ - p2ptest.Trigger{ + { Code: 6, Msg: &ChunkDeliveryMsg{ Key: chunkKey, diff --git a/swarm/network/stream/peer.go b/swarm/network/stream/peer.go index 12810789d9..c1e64bd740 100644 --- a/swarm/network/stream/peer.go +++ b/swarm/network/stream/peer.go @@ -36,7 +36,7 @@ var ( errClientNotFound = errors.New("client not found") ) -// Peer is the Peer extention for the streaming protocol +// Peer is the Peer extension for the streaming protocol type Peer struct { *protocols.Peer streamer *Registry diff --git a/swarm/network/stream/streamer_test.go b/swarm/network/stream/streamer_test.go index 951e008a53..a2aabc7f82 100644 --- a/swarm/network/stream/streamer_test.go +++ b/swarm/network/stream/streamer_test.go @@ -113,7 +113,7 @@ func TestStreamerDownstreamSubscribeUnsubscribeMsgExchange(t *testing.T) { err = tester.TestExchanges(p2ptest.Exchange{ Label: "Subscribe message", Expects: []p2ptest.Expect{ - p2ptest.Expect{ + { Code: 4, Msg: &SubscribeMsg{ Stream: "foo", @@ -139,7 +139,7 @@ func TestStreamerDownstreamSubscribeUnsubscribeMsgExchange(t *testing.T) { err = tester.TestExchanges(p2ptest.Exchange{ Label: "Unsubscribe message", Expects: []p2ptest.Expect{ - p2ptest.Expect{ + { Code: 0, Msg: &UnsubscribeMsg{ Stream: "foo", @@ -173,7 +173,7 @@ func TestStreamerUpstreamSubscribeUnsubscribeMsgExchange(t *testing.T) { err = tester.TestExchanges(p2ptest.Exchange{ Label: "Subscribe message", Triggers: []p2ptest.Trigger{ - p2ptest.Trigger{ + { Code: 4, Msg: &SubscribeMsg{ Stream: "foo", @@ -186,7 +186,7 @@ func TestStreamerUpstreamSubscribeUnsubscribeMsgExchange(t *testing.T) { }, }, Expects: []p2ptest.Expect{ - p2ptest.Expect{ + { Code: 1, Msg: &OfferedHashesMsg{ Stream: "foo", @@ -210,7 +210,7 @@ func TestStreamerUpstreamSubscribeUnsubscribeMsgExchange(t *testing.T) { err = tester.TestExchanges(p2ptest.Exchange{ Label: "unsubscribe message", Triggers: []p2ptest.Trigger{ - p2ptest.Trigger{ + { Code: 0, Msg: &UnsubscribeMsg{ Stream: "foo", @@ -244,7 +244,7 @@ func TestStreamerUpstreamSubscribeErrorMsgExchange(t *testing.T) { err = tester.TestExchanges(p2ptest.Exchange{ Label: "Subscribe message", Triggers: []p2ptest.Trigger{ - p2ptest.Trigger{ + { Code: 4, Msg: &SubscribeMsg{ Stream: "bar", @@ -257,7 +257,7 @@ func TestStreamerUpstreamSubscribeErrorMsgExchange(t *testing.T) { }, }, Expects: []p2ptest.Expect{ - p2ptest.Expect{ + { Code: 7, Msg: &SubscribeErrorMsg{ Error: "stream bar not registered", @@ -295,7 +295,7 @@ func TestStreamerDownstreamOfferedHashesMsgExchange(t *testing.T) { err = tester.TestExchanges(p2ptest.Exchange{ Label: "Subscribe message", Expects: []p2ptest.Expect{ - p2ptest.Expect{ + { Code: 4, Msg: &SubscribeMsg{ Stream: "foo", @@ -311,7 +311,7 @@ func TestStreamerDownstreamOfferedHashesMsgExchange(t *testing.T) { p2ptest.Exchange{ Label: "WantedHashes message", Triggers: []p2ptest.Trigger{ - p2ptest.Trigger{ + { Code: 1, Msg: &OfferedHashesMsg{ HandoverProof: &HandoverProof{ @@ -326,7 +326,7 @@ func TestStreamerDownstreamOfferedHashesMsgExchange(t *testing.T) { }, }, Expects: []p2ptest.Expect{ - p2ptest.Expect{ + { Code: 2, Msg: &WantedHashesMsg{ Stream: "foo", diff --git a/swarm/pss/handshake.go b/swarm/pss/handshake.go index 15f2a32a00..80aa729111 100644 --- a/swarm/pss/handshake.go +++ b/swarm/pss/handshake.go @@ -254,7 +254,7 @@ func (self *HandshakeController) cleanHandshake(pubkeyid string, topic *Topic, i func (self *HandshakeController) clean() { peerpubkeys := self.handshakes for pubkeyid, peertopics := range peerpubkeys { - for topic, _ := range peertopics { + for topic := range peertopics { self.cleanHandshake(pubkeyid, &topic, true, true) } } @@ -475,7 +475,7 @@ func (self *HandshakeAPI) AddHandshake(topic Topic) error { return nil } -// Deactivate handshake functionalty on a topic +// Deactivate handshake functionality on a topic func (self *HandshakeAPI) RemoveHandshake(topic *Topic) error { if _, ok := self.ctrl.deregisterFuncs[*topic]; ok { self.ctrl.deregisterFuncs[*topic]() diff --git a/swarm/pss/pss.go b/swarm/pss/pss.go index 9fc187eda6..bb3540844d 100644 --- a/swarm/pss/pss.go +++ b/swarm/pss/pss.go @@ -190,7 +190,7 @@ var pssSpec = &protocols.Spec{ func (self *Pss) Protocols() []p2p.Protocol { return []p2p.Protocol{ - p2p.Protocol{ + { Name: pssSpec.Name, Version: pssSpec.Version, Length: pssSpec.Length(), @@ -209,7 +209,7 @@ func (self *Pss) Run(p *p2p.Peer, rw p2p.MsgReadWriter) error { func (self *Pss) APIs() []rpc.API { apis := []rpc.API{ - rpc.API{ + { Namespace: "pss", Version: "1.0", Service: NewAPI(self), @@ -418,7 +418,7 @@ func (self *Pss) generateSymmetricKey(topic Topic, address *PssAddress, addToCac // If addtocache is set to true, the key will be added to the cache of keys // used to attempt symmetric decryption of incoming messages. // -// Returns a string id that can be used to retreive the key bytes +// Returns a string id that can be used to retrieve the key bytes // from the whisper backend (see pss.GetSymmetricKey()) func (self *Pss) SetSymmetricKey(key []byte, topic Topic, address *PssAddress, addtocache bool) (string, error) { keyid, err := self.w.AddSymKeyDirect(key) diff --git a/swarm/pss/pss_test.go b/swarm/pss/pss_test.go index 94dde1fb92..c674bbec40 100644 --- a/swarm/pss/pss_test.go +++ b/swarm/pss/pss_test.go @@ -858,7 +858,7 @@ func benchmarkSymKeySend(b *testing.B) { } symkey, err := ps.w.GetSymKey(symkeyid) if err != nil { - b.Fatalf("could not retreive symkey: %v", err) + b.Fatalf("could not retrieve symkey: %v", err) } ps.SetSymmetricKey(symkey, topic, &to, false) @@ -951,7 +951,7 @@ func benchmarkSymkeyBruteforceChangeaddr(b *testing.B) { } symkey, err := ps.w.GetSymKey(keyid) if err != nil { - b.Fatalf("could not retreive symkey %s: %v", keyid, err) + b.Fatalf("could not retrieve symkey %s: %v", keyid, err) } wparams := &whisper.MessageParams{ TTL: defaultWhisperTTL, @@ -1035,7 +1035,7 @@ func benchmarkSymkeyBruteforceSameaddr(b *testing.B) { } symkey, err := ps.w.GetSymKey(keyid) if err != nil { - b.Fatalf("could not retreive symkey %s: %v", keyid, err) + b.Fatalf("could not retrieve symkey %s: %v", keyid, err) } wparams := &whisper.MessageParams{ TTL: defaultWhisperTTL, diff --git a/swarm/storage/dbstore.go b/swarm/storage/dbstore.go index 17a7534646..b7127bc5a3 100644 --- a/swarm/storage/dbstore.go +++ b/swarm/storage/dbstore.go @@ -98,7 +98,7 @@ type DbStore struct { // TODO: Instead of passing the distance function, just pass the address from which distances are calculated // to avoid the appearance of a pluggable distance metric and opportunities of bugs associated with providing -// a function diferent from the one that is actually used. +// a function different from the one that is actually used. func NewDbStore(path string, hash SwarmHasher, capacity uint64, po func(Key) uint8) (s *DbStore, err error) { s = new(DbStore) s.hashfunc = hash