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

Replace OutgoingStreamer with Server in comments

Browse source
This commit is contained in:
Balint Gabor 2018-01-31 14:44:43 +01:00
parent 2aa9791fc7
commit 9bafb029ad
2 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
swarm/network/stream/delivery.go
View file

@ -51,7 +51,7 @@ func NewDelivery(overlay network.Overlay, db *storage.DBAPI) *Delivery {
return d return d
} }
// SwarmChunkServer implements OutgoingStreamer // SwarmChunkServer implements Server
type SwarmChunkServer struct { type SwarmChunkServer struct {
deliveryC chan []byte deliveryC chan []byte
batchC chan []byte batchC chan []byte

4
swarm/network/stream/syncer.go
View file

@ -33,7 +33,7 @@ const (
BatchSize = 128 BatchSize = 128
) )
// SwarmSyncerServer implements an OutgoingStreamer for history syncing on bins // SwarmSyncerServer implements an Server for history syncing on bins
// offered streams: // offered streams:
// * live request delivery with or without checkback // * live request delivery with or without checkback
// * (live/non-live historical) chunk syncing per proximity bin // * (live/non-live historical) chunk syncing per proximity bin
@ -67,7 +67,7 @@ func RegisterSwarmSyncerServer(streamer *Registry, db *storage.DBAPI) {
// TODO: make this work for HISTORY too // TODO: make this work for HISTORY too
return NewSwarmSyncerServer(false, po, db) return NewSwarmSyncerServer(false, po, db)
}) })
// streamer.RegisterOutgoingStreamer(stream, func(p *Peer) (OutgoingStreamer, error) { // streamer.RegisterServerFunc(stream, func(p *Peer) (Server, error) {
// return NewOutgoingProvableSwarmSyncer(po, db) // return NewOutgoingProvableSwarmSyncer(po, db)
// }) // })
} }