Home
last modified time | relevance | path

Searched refs:ReadState (Results 1 – 2 of 2) sorted by path

/unit/src/java/nginx/unit/websocket/
H A DWsFrameBase.java90 private volatile ReadState readState = ReadState.WAITING;
751 protected enum ReadState { enum in WsFrameBase
761 ReadState(boolean isSuspended) { in ReadState() method in WsFrameBase.ReadState
775 ReadState.SUSPENDING_WAIT)) { in suspend()
804 if (readState != ReadState.SUSPENDED) { in suspend()
824 if (readState != ReadState.WAITING) { in resume()
843 ReadState.WAITING)) { in resume()
849 ReadState.PROCESSING)) { in resume()
855 ReadState.WAITING)) { in resume()
872 protected ReadState getReadState() { in getReadState()
[all …]
H A DWsFrameClient.java63 if (!changeReadState(ReadState.WAITING, ReadState.PROCESSING)) { in processSocketRead()
68 if (!changeReadState(ReadState.SUSPENDING_PROCESS, ReadState.SUSPENDED)) { in processSocketRead()
103 changeReadState(ReadState.CLOSING); in processSocketRead()
107 if (!changeReadState(ReadState.SUSPENDING_WAIT, ReadState.SUSPENDED)) { in processSocketRead()
120 changeReadState(ReadState.CLOSING); in close()
183 if (!changeReadState(ReadState.PROCESSING, ReadState.WAITING)) { in doResumeProcessing()
189 if (!changeReadState(ReadState.SUSPENDING_PROCESS, ReadState.SUSPENDED)) { in doResumeProcessing()