Function
processPing
(f *ProxyFrame, sendch *common.Channel, proxyconn *ProxyConn, pongflag *int32, pongtime *int64)
Source from the content-addressed store, hash-verified
| 550 | } |
| 551 | |
| 552 | func processPing(f *ProxyFrame, sendch *common.Channel, proxyconn *ProxyConn, pongflag *int32, pongtime *int64) { |
| 553 | atomic.AddInt32(pongflag, 1) |
| 554 | *pongtime = f.PingFrame.Time |
| 555 | } |
| 556 | |
| 557 | func processPong(f *ProxyFrame, sendch *common.Channel, proxyconn *ProxyConn, showping bool) { |
| 558 | elapse := time.Duration(time.Now().UnixNano() - f.PongFrame.Time) |
Tested by
no test coverage detected