Home
last modified time | relevance | path

Searched refs:TERMINATED (Results 1 – 25 of 44) sorted by relevance

12

/external/guava/guava-tests/test/com/google/common/util/concurrent/
DAbstractServiceTest.java63 assertEquals(State.TERMINATED, service.state()); in testNoOpServiceStartStop()
67 ImmutableList.of(State.STARTING, State.RUNNING, State.STOPPING, State.TERMINATED), in testNoOpServiceStartStop()
78 assertEquals(State.TERMINATED, service.state()); in testNoOpServiceStartAndWaitStopAndWait()
88 assertEquals(State.TERMINATED, service.state()); in testNoOpServiceStartAsyncAndAwaitStopAsyncAndAwait()
99 assertEquals(State.TERMINATED, service.state()); in testNoOpServiceStopIdempotence()
101 ImmutableList.of(State.STARTING, State.RUNNING, State.STOPPING, State.TERMINATED), in testNoOpServiceStopIdempotence()
112 assertEquals(State.TERMINATED, service.state()); in testNoOpServiceStopIdempotenceAfterWait()
123 assertEquals(State.TERMINATED, service.state()); in testNoOpServiceStopIdempotenceDoubleWait()
135 assertEquals(State.TERMINATED, service.state()); in testNoOpServiceStartStopAndWaitUninterruptible()
180 assertEquals(State.TERMINATED, service.state()); in testManualServiceStartStop()
[all …]
DServiceTest.java24 import static com.google.common.util.concurrent.Service.State.TERMINATED;
36 assertLessThan(NEW, TERMINATED); in testStateOrdering()
46 assertLessThan(STOPPING, TERMINATED); in testStateOrdering()
DAbstractExecutionThreadServiceTest.java83 assertEquals(Service.State.TERMINATED, service.state()); in testServiceStartStop()
96 assertEquals(Service.State.TERMINATED, service.state()); in testServiceStopIdempotence()
98 assertEquals(Service.State.TERMINATED, service.state()); in testServiceStopIdempotence()
115 assertEquals(Service.State.TERMINATED, service.state()); in testServiceExitingOnItsOwn()
118 assertEquals(Service.State.TERMINATED, service.state()); in testServiceExitingOnItsOwn()
341 assertEquals(Service.State.TERMINATED, service.state()); in testStopWhileStarting_runNotCalled()
350 assertEquals(Service.State.TERMINATED, service.state()); in testStop_noStart()
DAbstractIdleServiceTest.java55 assertEquals(Service.State.TERMINATED, service.state()); in testServiceStartStop()
132 assertEquals(Service.State.TERMINATED, service.state()); in testStop_withoutStart()
144 assertEquals(Service.State.TERMINATED, service.state()); in testStop_afterStart()
DServiceManagerTest.java184 assertState(manager, Service.State.TERMINATED, a, b); in testServiceStartStop()
234 assertState(manager, Service.State.TERMINATED, a); in testFailRun()
255 assertState(manager, Service.State.TERMINATED, a, c); in testFailStop()
366 assertThat(manager.servicesByState().keySet()).containsExactly(Service.State.TERMINATED); in testDoCancelStart()
/external/guava/android/guava-tests/test/com/google/common/util/concurrent/
DAbstractServiceTest.java63 assertEquals(State.TERMINATED, service.state()); in testNoOpServiceStartStop()
67 ImmutableList.of(State.STARTING, State.RUNNING, State.STOPPING, State.TERMINATED), in testNoOpServiceStartStop()
78 assertEquals(State.TERMINATED, service.state()); in testNoOpServiceStartAndWaitStopAndWait()
88 assertEquals(State.TERMINATED, service.state()); in testNoOpServiceStartAsyncAndAwaitStopAsyncAndAwait()
99 assertEquals(State.TERMINATED, service.state()); in testNoOpServiceStopIdempotence()
101 ImmutableList.of(State.STARTING, State.RUNNING, State.STOPPING, State.TERMINATED), in testNoOpServiceStopIdempotence()
112 assertEquals(State.TERMINATED, service.state()); in testNoOpServiceStopIdempotenceAfterWait()
123 assertEquals(State.TERMINATED, service.state()); in testNoOpServiceStopIdempotenceDoubleWait()
135 assertEquals(State.TERMINATED, service.state()); in testNoOpServiceStartStopAndWaitUninterruptible()
180 assertEquals(State.TERMINATED, service.state()); in testManualServiceStartStop()
[all …]
DServiceTest.java24 import static com.google.common.util.concurrent.Service.State.TERMINATED;
36 assertLessThan(NEW, TERMINATED); in testStateOrdering()
46 assertLessThan(STOPPING, TERMINATED); in testStateOrdering()
DAbstractExecutionThreadServiceTest.java83 assertEquals(Service.State.TERMINATED, service.state()); in testServiceStartStop()
96 assertEquals(Service.State.TERMINATED, service.state()); in testServiceStopIdempotence()
98 assertEquals(Service.State.TERMINATED, service.state()); in testServiceStopIdempotence()
115 assertEquals(Service.State.TERMINATED, service.state()); in testServiceExitingOnItsOwn()
118 assertEquals(Service.State.TERMINATED, service.state()); in testServiceExitingOnItsOwn()
341 assertEquals(Service.State.TERMINATED, service.state()); in testStopWhileStarting_runNotCalled()
350 assertEquals(Service.State.TERMINATED, service.state()); in testStop_noStart()
DAbstractIdleServiceTest.java55 assertEquals(Service.State.TERMINATED, service.state()); in testServiceStartStop()
132 assertEquals(Service.State.TERMINATED, service.state()); in testStop_withoutStart()
144 assertEquals(Service.State.TERMINATED, service.state()); in testStop_afterStart()
DServiceManagerTest.java184 assertState(manager, Service.State.TERMINATED, a, b); in testServiceStartStop()
234 assertState(manager, Service.State.TERMINATED, a); in testFailRun()
255 assertState(manager, Service.State.TERMINATED, a, c); in testFailStop()
366 assertThat(manager.servicesByState().keySet()).containsExactly(Service.State.TERMINATED); in testDoCancelStart()
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/scheduling/
DCoroutineScheduler.kt277 private const val TERMINATED = 1 in <lambda>() constant
314 assert { state === WorkerState.TERMINATED } // Expected TERMINATED state in <lambda>()
326 currentWorker?.tryReleaseCpu(WorkerState.TERMINATED) in <lambda>()
490 if (worker.state === WorkerState.TERMINATED) return NOT_ADDED in <lambda>()
570 WorkerState.TERMINATED -> ++terminated in <lambda>()
612 name = "$schedulerName-worker-${if (index == 0) "TERMINATED" else index.toString()}" in <lambda>()
669 TERMINATED -> false // already terminated in <lambda>()
722 while (!isTerminated && state != WorkerState.TERMINATED) { in <lambda>()
744 tryReleaseCpu(WorkerState.TERMINATED) in <lambda>()
780 if (currentState !== WorkerState.TERMINATED) { in <lambda>()
[all …]
/external/nist-sip/java/gov/nist/javax/sip/stack/
DSIPServerTransaction.java755 this.setState(TransactionState.TERMINATED); in processRequest()
811 && TransactionState.TERMINATED != getRealState() && requestOf != null) { in processRequest()
828 && getRealState() == TransactionState.TERMINATED in processRequest()
947 this.setState(TransactionState.TERMINATED); in sendMessage()
978 this.setState(TransactionState.TERMINATED); in sendMessage()
1019 this.setState(TransactionState.TERMINATED); in sendMessage()
1059 this.setState(TransactionState.TERMINATED); in sendMessage()
1083 this.setState(TransactionState.TERMINATED); in sendMessage()
1149 this.setState(TransactionState.TERMINATED); in fireReliableResponseRetransmissionTimer()
1185 this.setState(TransactionState.TERMINATED); in fireTimeoutTimer()
[all …]
DSIPClientTransaction.java431 this.setState(TransactionState.TERMINATED); in sendMessage()
460 this.setState(TransactionState.TERMINATED); in sendMessage()
480 this.setState(TransactionState.TERMINATED); in sendMessage()
509 if ((TransactionState.COMPLETED == this.getState() || TransactionState.TERMINATED == this in processResponse()
541 this.setState(TransactionState.TERMINATED); in processResponse()
632 this.setState(TransactionState.TERMINATED); in nonInviteClientTransaction()
654 this.setState(TransactionState.TERMINATED); in nonInviteClientTransaction()
727 if (TransactionState.TERMINATED == this.getState()) { in inviteClientTransaction()
763 this.setState(TransactionState.TERMINATED); in inviteClientTransaction()
817 this.setState(TransactionState.TERMINATED); in inviteClientTransaction()
[all …]
DSIPTransaction.java176 public static final TransactionState TERMINATED_STATE = TransactionState.TERMINATED;
528 if (newState != TransactionState.TERMINATED in setState()
533 if (newState != TransactionState.TERMINATED) in setState()
536 if (currentState != TransactionState.TERMINATED) in setState()
820 this.setState(TransactionState.TERMINATED); in raiseErrorEvent()
1119 setState(TransactionState.TERMINATED); in raiseIOExceptionEvent()
/external/guava/android/guava/src/com/google/common/util/concurrent/
DAbstractService.java25 import static com.google.common.util.concurrent.Service.State.TERMINATED;
269 snapshot = new StateSnapshot(TERMINATED);
283 case TERMINATED:
329 checkCurrentState(TERMINATED);
339 checkCurrentState(TERMINATED);
421 case TERMINATED:
427 snapshot = new StateSnapshot(TERMINATED);
450 case TERMINATED:
537 case TERMINATED:
DServiceManager.java30 import static com.google.common.util.concurrent.Service.State.TERMINATED;
469 || states.contains(TERMINATED) in isSatisfied()
486 return states.count(TERMINATED) + states.count(FAILED) == numberOfServices; in isSatisfied()
588 + Multimaps.filterKeys(servicesByState, not(in(EnumSet.of(TERMINATED, FAILED))))); in awaitStopped()
696 } else if (states.count(TERMINATED) + states.count(FAILED) == numberOfServices) { in transitionService()
802 state.transitionService(service, from, TERMINATED); in terminated()
DService.java214 TERMINATED { enumConstant
/external/guava/guava/src/com/google/common/util/concurrent/
DAbstractService.java25 import static com.google.common.util.concurrent.Service.State.TERMINATED;
269 snapshot = new StateSnapshot(TERMINATED);
283 case TERMINATED:
329 checkCurrentState(TERMINATED);
339 checkCurrentState(TERMINATED);
421 case TERMINATED:
427 snapshot = new StateSnapshot(TERMINATED);
450 case TERMINATED:
537 case TERMINATED:
DServiceManager.java30 import static com.google.common.util.concurrent.Service.State.TERMINATED;
469 || states.contains(TERMINATED) in isSatisfied()
486 return states.count(TERMINATED) + states.count(FAILED) == numberOfServices; in isSatisfied()
588 + Multimaps.filterKeys(servicesByState, not(in(EnumSet.of(TERMINATED, FAILED))))); in awaitStopped()
696 } else if (states.count(TERMINATED) + states.count(FAILED) == numberOfServices) { in transitionService()
805 state.transitionService(service, from, TERMINATED); in terminated()
DService.java214 TERMINATED { enumConstant
/external/nist-sip/java/javax/sip/
DDialogState.java6 TERMINATED; enumConstant
10 public static final int _TERMINATED = TERMINATED.ordinal();
DTransactionState.java9 TERMINATED; enumConstant
/external/autotest/site_utils/rpm_control_system/
Dfrontend_server.py24 TERMINATED = -1 variable
336 heap_entry[RPM_COUNT] = TERMINATED
356 while top_of_heap[RPM_COUNT] is TERMINATED:
/external/nist-sip/java/javax/sip/header/
DSubscriptionStateHeader.java19 String TERMINATED = "Terminated"; field
/external/nist-sip/java/gov/nist/javax/sip/
DEventScanner.java269 .setState(TransactionState.TERMINATED); in deliverEvent()
300 .getState().equals(DialogState.TERMINATED))) in deliverEvent()

12