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

Temporarily comment out unfinished code

Browse source
This commit is contained in:
Balint Gabor 2018-01-12 09:39:26 +01:00
parent 00c7ab9178
commit c8f51a2e6d
1 changed files with 14 additions and 16 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

30
swarm/network/lightnode.go
View file

@ -169,19 +169,17 @@ func RegisterRemoteSectionServer(s *Streamer, db *DbAccess, rf func([]byte) *sto
// RegisterRemoteDownloader registers RemoteDownloader incoming streamer // RegisterRemoteDownloader registers RemoteDownloader incoming streamer
// on downstream light node // on downstream light node
func RegisterRemoteDownloader(s *Streamer, db *DbAccess) { // func RegisterRemoteDownloader(s *Streamer, db *DbAccess) {
s.RegisterIncomingStreamer("REMOTE_DOWNLOADER", func(p *StreamerPeer, t []byte) (IncomingStreamer, error) { // s.RegisterIncomingStreamer("REMOTE_DOWNLOADER", func(p *StreamerPeer, t []byte) (IncomingStreamer, error) {
return NewRemoteDownloader(t, db), nil // return NewRemoteDownloader(t, db), nil
}) // })
} // }
//
// RegisterRemoteDownloadServer registers RemoteDownloadServer outgoing streamer on // // RegisterRemoteDownloadServer registers RemoteDownloadServer outgoing streamer on
// upstream light server node // // upstream light server node
func RegisterRemoteDownloadServer(s *Streamer, db *DbAccess, rf func([]byte) *storage.LazyChunkReader) { // func RegisterRemoteDownloadServer(s *Streamer, db *DbAccess, rf func([]byte) *storage.LazyChunkReader) {
s.RegisterOutgoingStreamer("REMOTE_DOWNLOADER", func(p *StreamerPeer, t []byte) (OutgoingStreamer, error) { // s.RegisterOutgoingStreamer("REMOTE_DOWNLOADER", func(p *StreamerPeer, t []byte) (OutgoingStreamer, error) {
r := rf(t) // r := rf(t)
return NewRemoteDownloadServer(db, r), nil // return NewRemoteDownloadServer(db, r), nil
}) // })
} // }
func NewRemoteDownloader()