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

cleanups/wip

This commit is contained in:
Giovanni Petrantoni 2020-07-16 21:53:45 +09:00
parent f708874170
commit b3aad9e1ef
1 changed files with 4 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
libp2p/protocols/pubsub/pubsubpeer.nim
View File

@ -27,15 +27,6 @@ declareCounter(libp2p_pubsub_skipped_received_messages, "number of received skip
declareCounter(libp2p_pubsub_skipped_sent_messages, "number of sent skipped messages", labels = ["id"]) declareCounter(libp2p_pubsub_skipped_sent_messages, "number of sent skipped messages", labels = ["id"])
type type
TopicScoreParams = object
topicWeight: float
timeInMeshWeight: float
timeInMeshQuantum: Duration
timeInMeshCap: float
PeerScoreParams = object
topics: Table[string, TopicScoreParams]
PubSubObserver* = ref object PubSubObserver* = ref object
onRecv*: proc(peer: PubSubPeer; msgs: var RPCMsg) {.gcsafe, raises: [Defect].} onRecv*: proc(peer: PubSubPeer; msgs: var RPCMsg) {.gcsafe, raises: [Defect].}
onSend*: proc(peer: PubSubPeer; msgs: var RPCMsg) {.gcsafe, raises: [Defect].} onSend*: proc(peer: PubSubPeer; msgs: var RPCMsg) {.gcsafe, raises: [Defect].}
@ -52,6 +43,10 @@ type
observers*: ref seq[PubSubObserver] # ref as in smart_ptr observers*: ref seq[PubSubObserver] # ref as in smart_ptr
refs: int # how many active connections this peer has refs: int # how many active connections this peer has
# gossip 1.1 related
graftTime*: Moment
meshTime*: Duration
RPCHandler* = proc(peer: PubSubPeer, msg: seq[RPCMsg]): Future[void] {.gcsafe.} RPCHandler* = proc(peer: PubSubPeer, msg: seq[RPCMsg]): Future[void] {.gcsafe.}
func score*(p: PubSubPeer): float64 = func score*(p: PubSubPeer): float64 =