ASocket 关闭的时候总是回调。 @param so closing socket @param e caught exception, null for none.
(@NotNull AsyncSocket so, @Nullable Throwable e)
| 332 | * @param e caught exception, null for none. |
| 333 | */ |
| 334 | public void OnSocketClose(@NotNull AsyncSocket so, @Nullable Throwable e) throws Exception { |
| 335 | if (socketMap.remove(so.getSessionId(), so)) { |
| 336 | closedRecvCountHandle.getAndAdd(this, so.getRecvCount()); |
| 337 | closedRecvSizeHandle.getAndAdd(this, so.getRecvSize()); |
| 338 | closedSendCountHandle.getAndAdd(this, so.getSendCount()); |
| 339 | closedSendSizeHandle.getAndAdd(this, so.getSendSize()); |
| 340 | closedSendRawSizeHandle.getAndAdd(this, so.getSendRawSize()); |
| 341 | } |
| 342 | } |
| 343 | |
| 344 | /** |
| 345 | * 可靠rpc调用:一般用于重新发送没有返回结果的rpc。 |
no test coverage detected