/external/nist-sip/java/javax/sip/ |
TransactionState.java | 9 TERMINATED;
|
DialogState.java | 6 TERMINATED; 10 public static final int _TERMINATED = TERMINATED.ordinal();
|
/external/guava/guava-tests/test/com/google/common/util/concurrent/ |
ServiceTest.java | 24 import static com.google.common.util.concurrent.Service.State.TERMINATED; 37 assertLessThan(NEW, TERMINATED); 47 assertLessThan(STOPPING, TERMINATED);
|
AbstractServiceTest.java | 65 assertEquals(State.TERMINATED, service.state()); 73 State.TERMINATED), 84 assertEquals(State.TERMINATED, service.state()); 94 assertEquals(State.TERMINATED, service.state()); 105 assertEquals(State.TERMINATED, service.state()); 111 State.TERMINATED), 122 assertEquals(State.TERMINATED, service.state()); 133 assertEquals(State.TERMINATED, service.state()); 146 assertEquals(State.TERMINATED, service.state()); 189 assertEquals(State.TERMINATED, service.state()) 866 @Override public synchronized void terminated(State from) { method in class:AbstractServiceTest.RecordingListener [all...] |
AbstractExecutionThreadServiceTest.java | 75 assertEquals(Service.State.TERMINATED, service.state()); 89 assertEquals(Service.State.TERMINATED, service.state()); 91 assertEquals(Service.State.TERMINATED, service.state()); 109 assertEquals(Service.State.TERMINATED, service.state()); 113 assertEquals(Service.State.TERMINATED, service.state()); 320 assertEquals(Service.State.TERMINATED, service.state()); 329 assertEquals(Service.State.TERMINATED, service.state());
|
AbstractIdleServiceTest.java | 54 assertEquals(Service.State.TERMINATED, service.state()); 125 assertEquals(Service.State.TERMINATED, service.state()); 137 assertEquals(Service.State.TERMINATED, service.state()); 172 assertEquals("TestService [TERMINATED]", service.toString());
|
ServiceManagerTest.java | 167 assertState(manager, Service.State.TERMINATED, a, b); 217 assertState(manager, Service.State.TERMINATED, a); 238 assertState(manager, Service.State.TERMINATED, a, c); 529 * terminated() listeners.
|
JSR166TestCase.java | 734 else if (s == Thread.State.TERMINATED) 782 if (t.getState() != Thread.State.TERMINATED) { [all...] |
MoreExecutorsTest.java | 129 assertEquals(Thread.State.TERMINATED, otherThread.getState()); 239 assertEquals(Thread.State.TERMINATED, otherThread.getState()); 673 final AtomicBoolean terminated = new AtomicBoolean(); local 681 terminated.set(shutdownAndAwaitTermination(service, 1L, SECONDS)); 691 assertFalse(terminated.get());
|
/external/nist-sip/java/javax/sip/header/ |
SubscriptionStateHeader.java | 19 String TERMINATED = "Terminated";
|
/external/guava/guava/src/com/google/common/util/concurrent/ |
AbstractService.java | 27 import static com.google.common.util.concurrent.Service.State.TERMINATED; 82 return new Callback<Listener>("terminated({from = " + from + "})") { 84 listener.terminated(from); 194 snapshot = new StateSnapshot(TERMINATED); 195 terminated(NEW); 207 case TERMINATED: 255 checkCurrentState(TERMINATED); 264 checkCurrentState(TERMINATED); 328 * the service to transition from {@link State#STOPPING} to {@link State#TERMINATED}. 345 snapshot = new StateSnapshot(TERMINATED); [all...] |
Service.java | 36 * <li>{@linkplain State#TERMINATED TERMINATED} 43 * and {@link State#TERMINATED} states are terminal states, once a service enters either of these 80 * {@linkplain State#NEW new}, it is {@linkplain State#TERMINATED terminated} without having been 94 * {@code State#TERMINATED} when this method is called then this will throw an 110 * {@code State#TERMINATED} when this method is called then this will throw an 118 * Waits for the {@link Service} to reach the {@linkplain State#TERMINATED terminated state}. 128 * {@link Service.State#TERMINATED terminated} or {@link Service.State#FAILED failed}) for no 288 public void terminated(State from) {} method in class:Service.Listener [all...] |
ServiceManager.java | 31 import static com.google.common.util.concurrent.Service.State.TERMINATED; 155 * {@linkplain State#FAILED fail}/{@linkplain State#TERMINATED terminate} before all other 162 * {@linkplain State#TERMINATED terminated} or {@linkplain State#FAILED failed}. 334 * services will either be {@linkplain Service.State#TERMINATED terminated} or {@linkplain 343 * this method returns all services will either be {@linkplain Service.State#TERMINATED 344 * terminated} or {@linkplain Service.State#FAILED failed}. 443 // All services have started or some service has terminated/failed. 446 || states.contains(TERMINATED) 758 @Override public void terminated(State from) { method in class:ServiceManager.ServiceListener [all...] |
/external/nist-sip/java/gov/nist/javax/sip/stack/ |
SIPServerTransaction.java | 116 * | Terminated|<---------------+ 159 * +-------------->| Terminated| 261 // If the transaction has terminated, 363 // If the transaction has terminated, 562 // Invite Server transactions linger in the terminated state in the [all...] |
SIPClientTransaction.java | 120 * | Terminated|<--------------+ 162 * transitions | Terminated|<------------------+ 222 // If the transaction has terminated, 241 // Client transaction terminated. Kill connection if 269 // terminated, 431 this.setState(TransactionState.TERMINATED); 460 this.setState(TransactionState.TERMINATED); 480 this.setState(TransactionState.TERMINATED); 509 if ((TransactionState.COMPLETED == this.getState() || TransactionState.TERMINATED == this 541 this.setState(TransactionState.TERMINATED); [all...] |
SIPTransaction.java | 174 * Terminated state. 176 public static final TransactionState TERMINATED_STATE = TransactionState.TERMINATED; 253 // after the Transaction goes to terminated state. 268 * table after it goes into terminated state. This allows connection caching 528 if (newState != TransactionState.TERMINATED 533 if (newState != TransactionState.TERMINATED) 536 if (currentState != TransactionState.TERMINATED) 645 * Tests if this transaction has terminated. 647 * @return Trus if this transaction is terminated, false if not. 786 * terminated [all...] |
SIPDialog.java | 336 if (getState() != DialogState.TERMINATED) { 356 if (SIPDialog.this.getState() != DialogState.TERMINATED) { 409 * be terminated. 419 && transaction.getState() != javax.sip.TransactionState.TERMINATED) { 838 // Do nothing if the dialog state is terminated. [all...] |
/external/autotest/site_utils/rpm_control_system/ |
frontend_server.py | 25 TERMINATED = -1 426 # Set this entry's RPM_COUNT to TERMINATED (-1). 427 heap_entry[RPM_COUNT] = TERMINATED 433 # Re-sort the heap and remove any terminated dispatchers. 441 a non-terminated dispatcher at the top. 447 while top_of_heap[RPM_COUNT] is TERMINATED:
|
/external/grpc-grpc/src/python/grpcio_testing/grpc_testing/ |
_common.py | 110 'terminated', 116 TERMINATED = ServerRpcRead(None, False, True)
|
/external/caliper/caliper/src/test/java/com/google/caliper/runner/ |
StreamServiceTest.java | 86 if (service != null && service.state() != State.FAILED && service.state() != State.TERMINATED) { 187 if (state != State.TERMINATED) { 191 fail("Expected service to be terminated but was: " + state); 228 @Override public void terminated(State from) {
|
/external/nist-sip/java/gov/nist/javax/sip/ |
EventScanner.java | 177 // to the listener (tx == INVITE ST, terminated upon sending 264 // Set the tx state to terminated so it is removed from the 269 .setState(TransactionState.TERMINATED); 300 .getState().equals(DialogState.TERMINATED)))
|
DialogFilter.java | 542 * and you do not get transaction terminated events on ACK. [all...] |
SipProviderImpl.java | 360 if (dialog != null && dialog.getState() == DialogState.TERMINATED) { 363 // ("Found a terminated dialog -- possible re-use of old tag 748 if ( st != null && st.getState() != TransactionState.TERMINATED && this.isAutomaticDialogSupportEnabled()) { [all...] |
/external/drrickorang/LoopbackApp/app/src/main/java/org/drrickorang/loopback/ |
CaptureHolder.java | 109 if (mCaptureThread != null && mCaptureThread.getState() != Thread.State.TERMINATED) {
|
/external/grpc-grpc/src/python/grpcio_testing/grpc_testing/_server/ |
_handler.py | 88 return _common.TERMINATED
|