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

Rename priorityqueues to priorityqueue

Browse source
This commit is contained in:
Balint Gabor 2018-01-02 17:09:20 +01:00
parent ca2882fc81
commit 974536d1cf
2 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

0
swarm/network/priorityqueues/priorityqueues.go → swarm/network/priorityqueue/priorityqueue.go
View file

8
swarm/network/streamer.go
View file

@ -24,7 +24,7 @@ import (
"github.com/ethereum/go-ethereum/common" "github.com/ethereum/go-ethereum/common"
"github.com/ethereum/go-ethereum/p2p/protocols" "github.com/ethereum/go-ethereum/p2p/protocols"
bv "github.com/ethereum/go-ethereum/swarm/network/bitvector" bv "github.com/ethereum/go-ethereum/swarm/network/bitvector"
pq "github.com/ethereum/go-ethereum/swarm/network/priorityqueues" pq "github.com/ethereum/go-ethereum/swarm/network/priorityqueue"
) )
const ( const (
@ -34,7 +34,7 @@ const (
Mid Mid
High High
Top Top
PriorityQueues // number of queues PriorityQueue // number of queues
PriorityQueueCap = 3 // queue capacity PriorityQueueCap = 3 // queue capacity
) )
@ -177,7 +177,7 @@ type IncomingStreamer interface {
type StreamerPeer struct { type StreamerPeer struct {
Peer Peer
streamer *Streamer streamer *Streamer
pq *pq.PriorityQueues pq *pq.PriorityQueue
outgoingLock sync.RWMutex outgoingLock sync.RWMutex
incomingLock sync.RWMutex incomingLock sync.RWMutex
outgoing map[Stream]OutgoingStreamer outgoing map[Stream]OutgoingStreamer
@ -188,7 +188,7 @@ type StreamerPeer struct {
// NewStreamerPeer is the constructor for StreamerPeer // NewStreamerPeer is the constructor for StreamerPeer
func NewStreamerPeer(p Peer, streamer *Streamer) *StreamerPeer { func NewStreamerPeer(p Peer, streamer *Streamer) *StreamerPeer {
self := &StreamerPeer{ self := &StreamerPeer{
pq: pq.New(PriorityQueues, PriorityQueueCap), pq: pq.New(PriorityQueue, PriorityQueueCap),
streamer: streamer, streamer: streamer,
outgoing: make(map[Stream]OutgoingStreamer), outgoing: make(map[Stream]OutgoingStreamer),
incoming: make(map[Stream]IncomingStreamer), incoming: make(map[Stream]IncomingStreamer),