status-im
/
op-geth
mirror of https://github.com/status-im/op-geth.git
2
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

p2p: added limiter function to limit package broadcasting

This commit is contained in:
obscuren 2015-04-14 12:47:31 +02:00
parent b7e1b686aa
commit 474aa924ca
1 changed files with 13 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
p2p/server.go
View File

@ -136,6 +136,12 @@ func (srv *Server) SuggestPeer(n *discover.Node) {
// Broadcast sends an RLP-encoded message to all connected peers. // Broadcast sends an RLP-encoded message to all connected peers.
// This method is deprecated and will be removed later. // This method is deprecated and will be removed later.
func (srv *Server) Broadcast(protocol string, code uint64, data interface{}) error { func (srv *Server) Broadcast(protocol string, code uint64, data interface{}) error {
return srv.BroadcastLimited(protocol, code, func(i float64) float64 { return i }, data)
}
// BroadcastsRange an RLP-encoded message to a random set of peers using the limit function to limit the amount
// of peers.
func (srv *Server) BroadcastLimited(protocol string, code uint64, limit func(float64) float64, data interface{}) error {
var payload []byte var payload []byte
if data != nil { if data != nil {
var err error var err error
@ -146,7 +152,13 @@ func (srv *Server) Broadcast(protocol string, code uint64, data interface{}) err
} }
srv.lock.RLock() srv.lock.RLock()
defer srv.lock.RUnlock() defer srv.lock.RUnlock()
i, max := 0, int(limit(float64(len(srv.peers))))
for _, peer := range srv.peers { for _, peer := range srv.peers {
if i >= max {
break
}
if peer != nil { if peer != nil {
var msg = Msg{Code: code} var msg = Msg{Code: code}
if data != nil { if data != nil {
@ -154,6 +166,7 @@ func (srv *Server) Broadcast(protocol string, code uint64, data interface{}) err
msg.Size = uint32(len(payload)) msg.Size = uint32(len(payload))
} }
peer.writeProtoMsg(protocol, msg) peer.writeProtoMsg(protocol, msg)
i++
} }
} }
return nil return nil