| /external/pigweed/pw_rpc/public/pw_rpc/internal/ |
| D | base_server_writer.h | 44 BaseServerWriter(BaseServerWriter&& other) : state_(kClosed) { in BaseServerWriter()
65 constexpr BaseServerWriter() : state_{kClosed} {} in BaseServerWriter()
93 enum { kClosed, kOpen } state_; enumerator
|
| /external/webrtc/pc/ |
| D | rtp_data_channel.cc | 128 if (state_ == kClosed) in Close()
273 if (state_ == kClosed) { in CloseAbruptlyWithError()
285 SetState(kClosed); in CloseAbruptlyWithError()
318 SetState(kClosed); in UpdateState()
322 case kClosed: in UpdateState()
339 } else if (state_ == kClosed) { in SetState()
|
| D | dtls_transport_unittest.cc | 95 ASSERT_EQ(DtlsTransportState::kClosed, in TEST_F()
119 ASSERT_TRUE_WAIT(observer_.state() == DtlsTransportState::kClosed, in TEST_F()
142 ASSERT_TRUE_WAIT(observer_.state() == DtlsTransportState::kClosed, in TEST_F()
156 ASSERT_TRUE_WAIT(observer_.state() == DtlsTransportState::kClosed, in TEST_F()
|
| D | sctp_transport.cc | 75 UpdateInformation(SctpTransportState::kClosed); in Clear()
114 UpdateInformation(SctpTransportState::kClosed); in Start()
173 UpdateInformation(SctpTransportState::kClosed); in OnDtlsStateChange()
|
| D | sctp_data_channel.cc | 243 if (state_ == kClosed) in Close()
336 if (sid == config_.id && state_ != kClosing && state_ != kClosed) { in OnClosingProcedureStartedRemotely()
358 SetState(kClosed); in OnClosingProcedureComplete()
471 if (state_ == kClosed) { in CloseAbruptlyWithError()
489 SetState(kClosed); in CloseAbruptlyWithError()
547 case kClosed: in UpdateState()
564 } else if (state_ == kClosed) { in SetState()
|
| D | sctp_transport_unittest.cc | 156 ASSERT_EQ(SctpTransportState::kClosed, sctp_transport->Information().state()); in TEST()
178 ASSERT_EQ_WAIT(SctpTransportState::kClosed, observer_.State(), in TEST_F()
207 ASSERT_EQ_WAIT(SctpTransportState::kClosed, observer_.State(), in TEST_F()
|
| D | dtls_transport.cc | 30 return DtlsTransportState::kClosed; in TranslateState()
141 info_ = DtlsTransportInformation(DtlsTransportState::kClosed); in UpdateInformation()
|
| D | data_channel_unittest.cc | 156 EXPECT_EQ(webrtc::DataChannelInterface::kClosed, in TEST_F()
403 EXPECT_EQ_WAIT(webrtc::DataChannelInterface::kClosed, in TEST_F()
559 webrtc::DataChannelInterface::kClosed == webrtc_data_channel_->state() || in TEST_F()
571 EXPECT_EQ(webrtc::DataChannelInterface::kClosed, in TEST_F()
593 EXPECT_EQ(webrtc::DataChannelInterface::kClosed, in TEST_F()
638 EXPECT_EQ_WAIT(webrtc::DataChannelInterface::kClosed, in TEST_F()
|
| D | peer_connection_end_to_end_unittest.cc | 188 EXPECT_EQ_WAIT(DataChannelInterface::kClosed, local_dc->state(), kMaxWait); in CloseDataChannels()
189 EXPECT_EQ_WAIT(DataChannelInterface::kClosed, in CloseDataChannels()
647 EXPECT_EQ_WAIT(DataChannelInterface::kClosed, caller_dc->state(), kMaxWait); in TEST_P()
709 EXPECT_EQ_WAIT(DataChannelInterface::kClosed, caller_dc->state(), kMaxWait); in TEST_P()
734 EXPECT_EQ(DataChannelInterface::kClosed, in TEST_P()
|
| D | peer_connection_signaling_unittest.cc | 272 case SignalingState::kClosed: { in CreatePeerConnectionInState()
283 RTC_DCHECK_EQ(SignalingState::kClosed, wrapper->signaling_state()); in CreatePeerConnectionInState()
294 if (wrapper->signaling_state() != SignalingState::kClosed) { in TEST_P()
747 EXPECT_EQ(PeerConnection::kClosed, caller->pc()->signaling_state()); in TEST_P()
767 EXPECT_EQ(PeerConnection::kClosed, caller->pc()->signaling_state()); in TEST_P()
|
| /external/pigweed/pw_rpc/ |
| D | base_server_writer.cc | 36 other.state_ = kClosed; in operator =()
100 state_ = kClosed; in Close()
|
| /external/webrtc/api/ |
| D | data_channel_interface.h | 114 kClosed enumerator
125 case kClosed: in DataStateString()
|
| D | sctp_transport_interface.h | 28 kClosed, // Closed by local or remote party. enumerator
|
| D | dtls_transport_interface.h | 33 kClosed, // Intentionally closed. enumerator
|
| /external/openscreen/platform/impl/ |
| D | stream_socket_posix.cc | 58 OSP_DCHECK(state_ != TcpSocketState::kClosed); in ~StreamSocketPosix()
127 OSP_DCHECK(state_ != TcpSocketState::kClosed); in Close()
128 state_ = TcpSocketState::kClosed; in Close()
|
| D | socket_state.h | 32 kClosed enumerator
|
| D | tls_connection_factory_posix.cc | 134 if (socket->state() == TcpSocketState::kClosed) { in Listen()
241 if (connection->socket_->state() == TcpSocketState::kClosed) { in Connect()
286 if (connection->socket_->state() == TcpSocketState::kClosed) { in Accept()
|
| /external/tensorflow/tensorflow/compiler/xla/pjrt/distributed/ |
| D | service.cc | 38 state_ = State::kClosed; in ~DistributedRuntimeServiceImpl()
186 state_ = State::kClosed; in Shutdown()
191 state_ = State::kClosed; in Shutdown()
301 state_ = State::kClosed; in HeartbeatLoop()
|
| /external/openscreen/osp/impl/presentation/ |
| D | presentation_connection.cc | 78 state_ = State::kClosed; in OnClosed()
138 if (state_ == State::kClosed || state_ == State::kTerminated) in Close()
141 state_ = State::kClosed; in Close()
|
| D | presentation_connection_unittest.cc | 219 receiver.Close(Connection::CloseReason::kClosed); in TEST_F()
221 EXPECT_EQ(Connection::State::kClosed, controller.state()); in TEST_F()
222 EXPECT_EQ(Connection::State::kClosed, receiver.state()); in TEST_F()
|
| /external/openscreen/osp/public/presentation/ |
| D | presentation_connection.h | 43 kClosed = 0, enumerator
56 kClosed, enumerator
|
| /external/webrtc/api/transport/ |
| D | enums.h | 27 kClosed, enumerator
|
| /external/webrtc/p2p/base/ |
| D | dtls_transport_internal.cc | 29 return webrtc::DtlsTransportState::kClosed; in ConvertDtlsTransportState()
|
| /external/libchrome/mojo/core/ports/ |
| D | port.h | 97 kClosed enumerator
|
| /external/webrtc/sdk/objc/api/peerconnection/ |
| D | RTCDataChannel.mm | 189 return webrtc::DataChannelInterface::DataState::kClosed;
202 case webrtc::DataChannelInterface::DataState::kClosed:
|