Searched refs:State (Results 1 – 5 of 5) sorted by relevance
37 private State state;42 enum State { enum in StreamConsumer58 state = State.WAITING; in StreamConsumer()70 changeState(State.CONSUMING, State.WAITING); in giveStreamAndStartConsuming()80 changeState(State.SHOULD_STOP_CONSUMING, State.CONSUMING); in processFinished()106 changeState(State.FINISHED, State.WAITING); in shutdown()115 if (checkState(State.SHOULD_STOP_CONSUMING)) { in consume()123 while (checkState(State.CONSUMING)) { in consume()131 if (checkState(State.SHOULD_STOP_CONSUMING)) { in consume()132 changeState(State.WAITING, State.SHOULD_STOP_CONSUMING); in consume()[all …]
50 thread.getState() != Thread.State.NEW) { in getHeapTaskDaemon()
166 } while (t.getState() != Thread.State.BLOCKED); in doStateTests()
202 RegionState state = r->State(); in SetFromSpace()
275 RegionState State() const { in State() function