forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-08-17 01:13:45 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

swarm/network: Remove unnecessary comments

Browse source
This commit is contained in:
Balint Gabor 2018-01-16 12:21:22 +01:00
parent a4fbb7b2d9
commit cc939a9ca5
2 changed files with 0 additions and 25 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
swarm/network/request_test.go
View file

@ -45,7 +45,6 @@ import (
) )
func TestStreamerRetrieveRequest(t *testing.T) { func TestStreamerRetrieveRequest(t *testing.T) {
// TODO: we only need streamer
tester, streamer, _, teardown, err := newStreamerTester(t) tester, streamer, _, teardown, err := newStreamerTester(t)
defer teardown() defer teardown()
if err != nil { if err != nil {
@ -76,7 +75,6 @@ func TestStreamerRetrieveRequest(t *testing.T) {
} }
func TestStreamerUpstreamRetrieveRequestMsgExchangeWithoutStore(t *testing.T) { func TestStreamerUpstreamRetrieveRequestMsgExchangeWithoutStore(t *testing.T) {
// TODO: we only need streamer
tester, streamer, _, teardown, err := newStreamerTester(t) tester, streamer, _, teardown, err := newStreamerTester(t)
defer teardown() defer teardown()
if err != nil { if err != nil {
@ -131,7 +129,6 @@ func TestStreamerUpstreamRetrieveRequestMsgExchangeWithoutStore(t *testing.T) {
// upstream request server receives a retrieve Request and responds with // upstream request server receives a retrieve Request and responds with
// offered hashes or delivery if skipHash is set to true // offered hashes or delivery if skipHash is set to true
func TestStreamerUpstreamRetrieveRequestMsgExchange(t *testing.T) { func TestStreamerUpstreamRetrieveRequestMsgExchange(t *testing.T) {
// TODO: we only need streamer
tester, streamer, localStore, teardown, err := newStreamerTester(t) tester, streamer, localStore, teardown, err := newStreamerTester(t)
defer teardown() defer teardown()
if err != nil { if err != nil {
@ -223,7 +220,6 @@ func TestStreamerUpstreamRetrieveRequestMsgExchange(t *testing.T) {
} }
func TestStreamerDownstreamChunkDeliveryMsgExchange(t *testing.T) { func TestStreamerDownstreamChunkDeliveryMsgExchange(t *testing.T) {
// TODO: we only need streamer
tester, streamer, localStore, teardown, err := newStreamerTester(t) tester, streamer, localStore, teardown, err := newStreamerTester(t)
defer teardown() defer teardown()
if err != nil { if err != nil {
@ -284,18 +280,6 @@ func TestStreamerDownstreamChunkDeliveryMsgExchange(t *testing.T) {
Peer: peerID, Peer: peerID,
}, },
}, },
// Expects: []p2ptest.Expect{
// p2ptest.Expect{
// Code: 2,
// Msg: &WantedHashesMsg{
// Stream: "foo",
// Want: []byte{5},
// From: 8,
// To: 0,
// },
// Peer: peerID,
// },
// },
}) })
if err != nil { if err != nil {

9
swarm/network/streamer_test.go
View file

@ -36,7 +36,6 @@ import (
// log.Root().SetHandler(log.CallerFileHandler(log.LvlFilterHandler(log.LvlWarn, log.StreamHandler(os.Stderr, log.TerminalFormat(true))))) // log.Root().SetHandler(log.CallerFileHandler(log.LvlFilterHandler(log.LvlWarn, log.StreamHandler(os.Stderr, log.TerminalFormat(true)))))
// } // }
// TODO: extract newStreamer
func newStreamerTester(t *testing.T) (*p2ptest.ProtocolTester, *Streamer, *storage.LocalStore, func(), error) { func newStreamerTester(t *testing.T) (*p2ptest.ProtocolTester, *Streamer, *storage.LocalStore, func(), error) {
// setup // setup
addr := RandomAddr() // tested peers peer address addr := RandomAddr() // tested peers peer address
@ -78,11 +77,6 @@ func newStreamerTester(t *testing.T) (*p2ptest.ProtocolTester, *Streamer, *stora
return protocolTester, streamer, localStore, teardown, nil return protocolTester, streamer, localStore, teardown, nil
} }
// TODO
// func newStreamer() (*Streamer, error) {
//
// }
func TestStreamerSubscribe(t *testing.T) { func TestStreamerSubscribe(t *testing.T) {
tester, streamer, _, teardown, err := newStreamerTester(t) tester, streamer, _, teardown, err := newStreamerTester(t)
defer teardown() defer teardown()
@ -147,7 +141,6 @@ func (self *testOutgoingStreamer) GetData([]byte) []byte {
} }
func TestStreamerDownstreamSubscribeMsgExchange(t *testing.T) { func TestStreamerDownstreamSubscribeMsgExchange(t *testing.T) {
// TODO: we only need streamer
tester, streamer, _, teardown, err := newStreamerTester(t) tester, streamer, _, teardown, err := newStreamerTester(t)
defer teardown() defer teardown()
if err != nil { if err != nil {
@ -190,7 +183,6 @@ func TestStreamerDownstreamSubscribeMsgExchange(t *testing.T) {
} }
func TestStreamerUpstreamSubscribeMsgExchange(t *testing.T) { func TestStreamerUpstreamSubscribeMsgExchange(t *testing.T) {
// TODO: we only need streamer
tester, streamer, _, teardown, err := newStreamerTester(t) tester, streamer, _, teardown, err := newStreamerTester(t)
defer teardown() defer teardown()
if err != nil { if err != nil {
@ -244,7 +236,6 @@ func TestStreamerUpstreamSubscribeMsgExchange(t *testing.T) {
} }
func TestStreamerDownstreamOfferedHashesMsgExchange(t *testing.T) { func TestStreamerDownstreamOfferedHashesMsgExchange(t *testing.T) {
// TODO: we only need streamer
tester, streamer, _, teardown, err := newStreamerTester(t) tester, streamer, _, teardown, err := newStreamerTester(t)
defer teardown() defer teardown()
if err != nil { if err != nil {