flowcontrol

Sep 24, 2018

Changes in this version

+ type ClientManager struct

+ func NewClientManager(rcTarget, maxSimReq, maxRcSum uint64) *ClientManager

+ func (self *ClientManager) Stop()

+ type ClientNode struct

+ func NewClientNode(cm *ClientManager, params *ServerParams) *ClientNode

+ func (peer *ClientNode) AcceptRequest() (uint64, bool)

+ func (peer *ClientNode) Remove(cm *ClientManager)

+ func (peer *ClientNode) RequestProcessed(cost uint64) (bv, realCost uint64)

+ type ServerNode struct

+ func NewServerNode(params *ServerParams) *ServerNode

+ func (peer *ServerNode) CanSend(maxCost uint64) (time.Duration, float64)

+ func (peer *ServerNode) GotReply(reqID, bv uint64)

+ func (peer *ServerNode) QueueRequest(reqID, maxCost uint64)

+ type ServerParams struct

+ BufLimit uint64

+ MinRecharge uint64