Home
last modified time | relevance | path

Searched refs:SHUTDOWN (Results 1 – 25 of 56) sorted by relevance

123

/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DConnectivityStateManagerTest.java22 import static io.grpc.ConnectivityState.SHUTDOWN;
238 state.gotoState(SHUTDOWN);
239 assertEquals(SHUTDOWN, state.getState());
242 assertEquals(SHUTDOWN, state.getState());
DInternalSubchannelTest.java23 import static io.grpc.ConnectivityState.SHUTDOWN;
741 assertEquals(SHUTDOWN, internalSubchannel.getState()); in shutdownBeforeTransportCreated()
746 assertEquals(SHUTDOWN, internalSubchannel.getState()); in shutdownBeforeTransportCreated()
772 assertEquals(SHUTDOWN, internalSubchannel.getState()); in shutdownBeforeTransportReady()
806 assertEquals(SHUTDOWN, internalSubchannel.getState()); in obtainTransportAfterShutdown()
811 assertEquals(SHUTDOWN, internalSubchannel.getState()); in obtainTransportAfterShutdown()
/external/tensorflow/tensorflow/contrib/mpi_collectives/
Dmpi_message.proto48 // SHUTDOWN if all MPI processes should shut down.
55 SHUTDOWN = 4; enumerator
58 // Empty if the type is DONE or SHUTDOWN.
/external/grpc-grpc/doc/
Dwait-for-ready.md4 If an RPC is issued but the channel is in `TRANSIENT_FAILURE` or `SHUTDOWN`
14 as the channel is `SHUTDOWN` or the RPC's deadline is reached.
Dconnectivity-semantics-and-api.md50 SHUTDOWN: This channel has started shutting down. Any new RPCs should fail
68 <th>SHUTDOWN</th>
104 <th>SHUTDOWN</th>
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DInternalSubchannel.java22 import static io.grpc.ConnectivityState.SHUTDOWN;
328 Preconditions.checkState(state.getState() != SHUTDOWN, in gotoState()
392 if (state.getState() == SHUTDOWN) { in shutdown()
396 gotoNonErrorState(SHUTDOWN); in shutdown()
587 if (state.getState() == SHUTDOWN) { in transportShutdown()
626 if (state.getState() == SHUTDOWN && transports.isEmpty()) { in transportTerminated()
DConnectivityStateManager.java64 if (state != newState && state != ConnectivityState.SHUTDOWN) { in gotoState()
/external/toybox/toys/pending/
Dinit.c41 #define SHUTDOWN 0x40 macro
306 if (x->action & (SHUTDOWN|ONCE|SYSINIT|CTRLALTDEL|WAIT)) { in run_action_from_list()
309 if (x->action & (SHUTDOWN|SYSINIT|CTRLALTDEL|WAIT)) waitforpid(pid); in run_action_from_list()
324 run_action_from_list(SHUTDOWN); in set_default()
/external/grpc-grpc-java/core/src/main/java/io/grpc/
DPickFirstBalancerFactory.java21 import static io.grpc.ConnectivityState.SHUTDOWN;
94 if (subchannel != this.subchannel || currentState == SHUTDOWN) { in handleSubchannelState()
DConnectivityState.java71 SHUTDOWN enumConstant
/external/tcpdump/tests/
Dforces2vvv.out664 1) [SHUTDOWN]
667 1) [SHUTDOWN]
670 1) [SHUTDOWN]
673 1) [SHUTDOWN ACK]
676 1) [SHUTDOWN COMPLETE]
679 1) [SHUTDOWN ACK]
682 1) [SHUTDOWN COMPLETE]
685 1) [SHUTDOWN ACK]
688 1) [SHUTDOWN COMPLETE]
727 1) [SHUTDOWN]
[all …]
Dforces2vv.out273 1) [SHUTDOWN]
276 1) [SHUTDOWN]
279 1) [SHUTDOWN]
282 1) [SHUTDOWN ACK]
285 1) [SHUTDOWN COMPLETE]
288 1) [SHUTDOWN ACK]
291 1) [SHUTDOWN COMPLETE]
294 1) [SHUTDOWN ACK]
297 1) [SHUTDOWN COMPLETE]
/external/grpc-grpc/src/python/grpcio_tests/tests/unit/
D_channel_connectivity_test.py118 self.assertNotIn(grpc.ChannelConnectivity.SHUTDOWN,
122 self.assertNotIn(grpc.ChannelConnectivity.SHUTDOWN,
D_api_test.py93 grpc.ChannelConnectivity.SHUTDOWN,
/external/libhevc/encoder/
Dosal_select_engine.h47 #define SHUTDOWN 2 macro
/external/grpc-grpc/src/cpp/thread_manager/
Dthread_manager.h44 enum WorkStatus { WORK_FOUND, SHUTDOWN, TIMEOUT }; enumerator
/external/grpc-grpc/include/grpcpp/impl/codegen/
Dcompletion_queue.h116 SHUTDOWN, ///< The completion queue has been shutdown and fully-drained enumerator
173 GPR_CLOCK_REALTIME)) != SHUTDOWN); in Next()
/external/grpc-grpc/src/python/grpcio/grpc/beta/
Dinterfaces.py24 ChannelConnectivity.FATAL_FAILURE = ChannelConnectivity.SHUTDOWN
/external/grpc-grpc/src/cpp/common/
Dcompletion_queue_cc.cc61 return SHUTDOWN; in AsyncNextInternal()
/external/compiler-rt/lib/tsan/tests/rtl/
Dtsan_test_util_posix.cc239 SHUTDOWN, enumerator
385 if (ev->type == Event::SHUTDOWN) { in ScopedThreadCallback()
425 Event event(Event::SHUTDOWN); in ~ScopedThread()
/external/grpc-grpc-java/core/src/main/java/io/grpc/util/
DRoundRobinLoadBalancerFactory.java23 import static io.grpc.ConnectivityState.SHUTDOWN;
201 if (stateInfo.getState() == SHUTDOWN && stickinessState != null) { in handleSubchannelState()
214 ConnectivityStateInfo.forNonError(SHUTDOWN); in shutdownSubchannel()
/external/iptables/extensions/
Dlibxt_sctp.man10 Chunk types: DATA INIT INIT_ACK SACK HEARTBEAT HEARTBEAT_ACK ABORT SHUTDOWN SHUTDOWN_ACK ERROR COOK…
/external/python/cpython3/Lib/multiprocessing/
Dmanagers.py458 SHUTDOWN = 2 variable in State
499 elif self._state.value == State.SHUTDOWN:
523 elif self._state.value == State.SHUTDOWN:
626 elif self._state.value == State.SHUTDOWN:
662 state.value = State.SHUTDOWN
/external/grpc-grpc/src/python/grpcio/grpc/
D_common.py36 grpc.ChannelConnectivity.SHUTDOWN,
/external/grpc-grpc/test/cpp/thread_manager/
Dthread_manager_test.cc88 return SHUTDOWN; in PollForWork()

123