From c8f51a2e6dd62732c9327c0969c46dda966739e7 Mon Sep 17 00:00:00 2001 From: Balint Gabor Date: Fri, 12 Jan 2018 09:39:26 +0100 Subject: [PATCH] Temporarily comment out unfinished code --- swarm/network/lightnode.go | 30 ++++++++++++++---------------- 1 file changed, 14 insertions(+), 16 deletions(-) diff --git a/swarm/network/lightnode.go b/swarm/network/lightnode.go index b351e87dcf..8ee7f5b22e 100644 --- a/swarm/network/lightnode.go +++ b/swarm/network/lightnode.go @@ -169,19 +169,17 @@ func RegisterRemoteSectionServer(s *Streamer, db *DbAccess, rf func([]byte) *sto // RegisterRemoteDownloader registers RemoteDownloader incoming streamer // on downstream light node -func RegisterRemoteDownloader(s *Streamer, db *DbAccess) { - s.RegisterIncomingStreamer("REMOTE_DOWNLOADER", func(p *StreamerPeer, t []byte) (IncomingStreamer, error) { - return NewRemoteDownloader(t, db), nil - }) -} - -// RegisterRemoteDownloadServer registers RemoteDownloadServer outgoing streamer on -// upstream light server node -func RegisterRemoteDownloadServer(s *Streamer, db *DbAccess, rf func([]byte) *storage.LazyChunkReader) { - s.RegisterOutgoingStreamer("REMOTE_DOWNLOADER", func(p *StreamerPeer, t []byte) (OutgoingStreamer, error) { - r := rf(t) - return NewRemoteDownloadServer(db, r), nil - }) -} - -func NewRemoteDownloader() +// func RegisterRemoteDownloader(s *Streamer, db *DbAccess) { +// s.RegisterIncomingStreamer("REMOTE_DOWNLOADER", func(p *StreamerPeer, t []byte) (IncomingStreamer, error) { +// return NewRemoteDownloader(t, db), nil +// }) +// } +// +// // RegisterRemoteDownloadServer registers RemoteDownloadServer outgoing streamer on +// // upstream light server node +// func RegisterRemoteDownloadServer(s *Streamer, db *DbAccess, rf func([]byte) *storage.LazyChunkReader) { +// s.RegisterOutgoingStreamer("REMOTE_DOWNLOADER", func(p *StreamerPeer, t []byte) (OutgoingStreamer, error) { +// r := rf(t) +// return NewRemoteDownloadServer(db, r), nil +// }) +// }