connection count handler
(ctx actor.Context, req *GetConnectionCntReq)
| 136 | |
| 137 | //connection count handler |
| 138 | func (this *P2PActor) handleGetConnectionCntReq(ctx actor.Context, req *GetConnectionCntReq) { |
| 139 | cnt := this.server.GetConnectionCnt() |
| 140 | if ctx.Sender() != nil { |
| 141 | resp := &GetConnectionCntRsp{ |
| 142 | Cnt: cnt, |
| 143 | } |
| 144 | ctx.Sender().Request(resp, ctx.Self()) |
| 145 | } |
| 146 | } |
| 147 | |
| 148 | //max peer blockheight handler |
| 149 | func (this *P2PActor) handleGetMaxPeerBlockHeightReq(ctx actor.Context, req *GetMaxPeerBlockHeightReq) { |
no test coverage detected