|
@ -5,11 +5,7 @@ |
|
|
-compile({inline_size, 128}). |
|
|
-compile({inline_size, 128}). |
|
|
|
|
|
|
|
|
-export([ |
|
|
-export([ |
|
|
getQueue/1 |
|
|
|
|
|
, addQueue/2 |
|
|
|
|
|
, delQueue/1 |
|
|
|
|
|
, clearQueue/0 |
|
|
|
|
|
, cancelTimer/1 |
|
|
|
|
|
|
|
|
cancelTimer/1 |
|
|
, dealClose/3 |
|
|
, dealClose/3 |
|
|
, reconnectTimer/2 |
|
|
, reconnectTimer/2 |
|
|
, agencyReply/2 |
|
|
, agencyReply/2 |
|
@ -19,22 +15,6 @@ |
|
|
, updateReconnectState/1 |
|
|
, updateReconnectState/1 |
|
|
]). |
|
|
]). |
|
|
|
|
|
|
|
|
-spec getQueue(pos_integer()) -> undefined | miRequest(). |
|
|
|
|
|
getQueue(RequestsIndex) -> |
|
|
|
|
|
erlang:get(RequestsIndex). |
|
|
|
|
|
|
|
|
|
|
|
-spec addQueue(pos_integer(), miRequest()) -> undefined. |
|
|
|
|
|
addQueue(RequestsIndex, MiRequest) -> |
|
|
|
|
|
erlang:put(RequestsIndex, MiRequest). |
|
|
|
|
|
|
|
|
|
|
|
-spec delQueue(pos_integer()) -> miRequest(). |
|
|
|
|
|
delQueue(RequestsIndex) -> |
|
|
|
|
|
erlang:erase(RequestsIndex). |
|
|
|
|
|
|
|
|
|
|
|
-spec clearQueue() -> term(). |
|
|
|
|
|
clearQueue() -> |
|
|
|
|
|
erlang:erase(). |
|
|
|
|
|
|
|
|
|
|
|
-spec dealClose(srvState(), cliState(), term()) -> {ok, srvState(), cliState()}. |
|
|
-spec dealClose(srvState(), cliState(), term()) -> {ok, srvState(), cliState()}. |
|
|
dealClose(SrvState, #cliState{requestsIns = RequestsIns, requestsOuts = RequestsOuts, curInfo = CurInfo} = ClientState, Reply) -> |
|
|
dealClose(SrvState, #cliState{requestsIns = RequestsIns, requestsOuts = RequestsOuts, curInfo = CurInfo} = ClientState, Reply) -> |
|
|
agencyReply(CurInfo, Reply), |
|
|
agencyReply(CurInfo, Reply), |
|
|