Searched refs:streamActive (Results 1 – 3 of 3) sorted by relevance
159 streamActive streamState = iota const
756 if !s.compareAndSwapState(streamActive, streamWriteDone) {759 } else if s.getState() != streamActive {
604 s.compareAndSwapState(streamActive, streamReadDone)