connection state handler
(ctx actor.Context, req *GetConnectionStateReq)
| 169 | |
| 170 | //connection state handler |
| 171 | func (this *P2PActor) handleGetConnectionStateReq(ctx actor.Context, req *GetConnectionStateReq) { |
| 172 | state := this.server.GetConnectionState() |
| 173 | if ctx.Sender() != nil { |
| 174 | resp := &GetConnectionStateRsp{ |
| 175 | State: state, |
| 176 | } |
| 177 | ctx.Sender().Request(resp, ctx.Self()) |
| 178 | } |
| 179 | } |
| 180 | |
| 181 | //timestamp handler |
| 182 | func (this *P2PActor) handleGetTimeReq(ctx actor.Context, req *GetTimeReq) { |
no test coverage detected