Home
last modified time | relevance | path

Searched refs:GetState (Results 1 – 25 of 122) sorted by relevance

12345

/external/webrtc/webrtc/base/
Dsocket_unittest.cc200 EXPECT_EQ(AsyncSocket::CS_CLOSED, client->GetState()); in ConnectInternal()
209 EXPECT_EQ(AsyncSocket::CS_CONNECTING, server->GetState()); in ConnectInternal()
222 EXPECT_EQ(AsyncSocket::CS_CONNECTING, client->GetState()); in ConnectInternal()
234 EXPECT_EQ(AsyncSocket::CS_CONNECTED, accepted->GetState()); in ConnectInternal()
239 EXPECT_EQ_WAIT(AsyncSocket::CS_CONNECTED, client->GetState(), kTimeout); in ConnectInternal()
271 EXPECT_EQ(AsyncSocket::CS_CONNECTING, client->GetState()); in ConnectWithDnsLookupInternal()
283 EXPECT_EQ(AsyncSocket::CS_CONNECTED, accepted->GetState()); in ConnectWithDnsLookupInternal()
288 EXPECT_EQ_WAIT(AsyncSocket::CS_CONNECTED, client->GetState(), kTimeout); in ConnectWithDnsLookupInternal()
317 EXPECT_EQ_WAIT(AsyncSocket::CS_CLOSED, client->GetState(), kTimeout); in ConnectFailInternal()
351 WAIT_(client->GetState() == AsyncSocket::CS_CLOSED, kTimeout, in ConnectWithDnsLookupFailInternal()
[all …]
Dssladapter_unittest.cc65 rtc::AsyncSocket::ConnState GetState() const { in GetState() function in SSLAdapterTestDummyClient
66 return ssl_adapter_->GetState(); in GetState()
118 if (socket->GetState() != rtc::AsyncSocket::CS_CLOSED) { in OnSSLAdapterCloseEvent()
168 || ssl_stream_adapter_->GetState() != rtc::SS_OPEN) { in Send()
289 ASSERT_EQ(rtc::AsyncSocket::CS_CLOSED, client_->GetState()); in TestHandshake()
295 ASSERT_EQ(rtc::AsyncSocket::CS_CONNECTING, client_->GetState()); in TestHandshake()
305 EXPECT_EQ_WAIT(rtc::AsyncSocket::CS_CONNECTED, client_->GetState(), in TestHandshake()
312 EXPECT_EQ_WAIT(rtc::AsyncSocket::CS_CLOSED, client_->GetState(), in TestHandshake()
Dvirtualsocket_unittest.cc249 EXPECT_EQ(client->GetState(), AsyncSocket::CS_CLOSED); in ConnectTest()
260 EXPECT_EQ(server->GetState(), AsyncSocket::CS_CONNECTING); in ConnectTest()
274 EXPECT_EQ(client->GetState(), AsyncSocket::CS_CONNECTING); in ConnectTest()
281 EXPECT_EQ(client->GetState(), AsyncSocket::CS_CONNECTING); in ConnectTest()
292 EXPECT_EQ(accepted->GetState(), AsyncSocket::CS_CONNECTED); in ConnectTest()
299 EXPECT_EQ(client->GetState(), AsyncSocket::CS_CONNECTED); in ConnectTest()
335 EXPECT_EQ(client->GetState(), AsyncSocket::CS_CLOSED); in ConnectToNonListenerTest()
369 EXPECT_EQ(client->GetState(), AsyncSocket::CS_CLOSED); in CloseDuringConnectTest()
391 EXPECT_EQ(client->GetState(), AsyncSocket::CS_CLOSED); in CloseDuringConnectTest()
414 EXPECT_EQ(accepted->GetState(), AsyncSocket::CS_CONNECTED); in CloseDuringConnectTest()
[all …]
Dstream.h68 virtual StreamState GetState() const = 0;
248 StreamState GetState() const override;
353 StreamState GetState() const override;
384 StreamState GetState() const override;
430 StreamState GetState() const override;
525 StreamState GetState() const override;
602 StreamState GetState() const override;
Dmultipart_unittest.cc34 EXPECT_EQ(rtc::SS_OPENING, multipart.GetState()); in TEST()
39 EXPECT_EQ(rtc::SS_OPEN, multipart.GetState()); in TEST()
49 EXPECT_EQ(rtc::SS_CLOSED, multipart.GetState()); in TEST()
Dtask.h102 int GetState() const { return state_; } in GetState() function
103 bool HasError() const { return (GetState() == STATE_ERROR); } in HasError()
Dsocketpool.cc71 if (stream->GetState() == SS_CLOSED) { in ReturnConnectedStream()
177 if ((stream_->GetState() == SS_OPEN) && (remote == remote_)) { in RequestConnectedStream()
252 ASSERT(SS_CLOSED != stream->GetState()); in RequestConnectedStream()
257 << ((SS_OPEN == stream->GetState()) ? " Connected" in RequestConnectedStream()
Dphysicalsocketserver_unittest.cc134 EXPECT_EQ(AsyncSocket::CS_CLOSED, client1->GetState()); in ConnectInternalAcceptError()
140 EXPECT_EQ(AsyncSocket::CS_CLOSED, client2->GetState()); in ConnectInternalAcceptError()
149 EXPECT_EQ(AsyncSocket::CS_CONNECTING, server->GetState()); in ConnectInternalAcceptError()
162 EXPECT_EQ(AsyncSocket::CS_CONNECTING, client1->GetState()); in ConnectInternalAcceptError()
185 EXPECT_EQ(AsyncSocket::CS_CONNECTING, client2->GetState()); in ConnectInternalAcceptError()
Dhttpbase_unittest.cc201 EXPECT_EQ(SS_OPENING, http_stream->GetState()); in VerifyDocumentStreamIsOpening()
214 EXPECT_EQ(SS_OPEN, http_stream->GetState()); in VerifyDocumentStreamOpenEvent()
226 EXPECT_EQ(SS_OPEN, http_stream->GetState()); in ReadDocumentStreamData()
251 EXPECT_EQ(SS_CLOSED, http_stream->GetState()); in VerifyDocumentStreamIsEOS()
479 EXPECT_EQ(SS_OPEN, http_stream->GetState()); in TEST_F()
Dsslstreamadapterhelper.cc66 StreamState SSLStreamAdapterHelper::GetState() const { in GetState() function in rtc::SSLStreamAdapterHelper
128 if (StreamAdapterInterface::GetState() != SS_OPEN) { in StartSSL()
Dasyncsocket.cc95 AsyncSocket::ConnState AsyncSocketAdapter::GetState() const { in GetState() function in rtc::AsyncSocketAdapter
96 return socket_->GetState(); in GetState()
Dsocketstream.cc47 StreamState SocketStream::GetState() const { in GetState() function in rtc::SocketStream
49 switch (socket_->GetState()) { in GetState()
Dproxy_unittest.cc93 EXPECT_EQ(Socket::CS_CONNECTING, proxy_socket->GetState()); in TEST_F()
95 EXPECT_EQ(Socket::CS_CONNECTED, proxy_socket->GetState()); in TEST_F()
/external/webrtc/webrtc/libjingle/xmpp/
Dpresenceouttask.cc23 if (GetState() != STATE_INIT && GetState() != STATE_START) in Send()
34 if (GetState() != STATE_INIT && GetState() != STATE_START) in SendDirected()
45 if (GetState() != STATE_INIT && GetState() != STATE_START) in SendProbe()
/external/libweave/src/
Daccess_api_handler.cc137 CHECK(command->GetState() == Command::State::kQueued) in Block()
138 << EnumToString(command->GetState()); in Block()
166 CHECK(command->GetState() == Command::State::kQueued) in Unblock()
167 << EnumToString(command->GetState()); in Unblock()
189 CHECK(command->GetState() == Command::State::kQueued) in List()
190 << EnumToString(command->GetState()); in List()
Daccess_api_handler_unittest.cc87 component_manager_.FindCommand(id)->GetState()); in AddCommand()
91 std::unique_ptr<base::DictionaryValue> GetState() { in GetState() function in weave::AccessApiHandlerTest
181 EXPECT_JSON_EQ(expected, *GetState()); in TEST_F()
205 EXPECT_JSON_EQ(expected, *GetState()); in TEST_F()
229 EXPECT_JSON_EQ(expected, *GetState()); in TEST_F()
Dbase_api_handler.cc128 CHECK(command->GetState() == Command::State::kQueued) in UpdateBaseConfiguration()
129 << EnumToString(command->GetState()); in UpdateBaseConfiguration()
173 CHECK(command->GetState() == Command::State::kQueued) in UpdateDeviceInfo()
174 << EnumToString(command->GetState()); in UpdateDeviceInfo()
/external/webrtc/webrtc/examples/peerconnection/client/
Dpeer_connection_client.cc162 ASSERT(control_socket_->GetState() == rtc::Socket::CS_CLOSED); in SendToPeer()
184 control_socket_->GetState() != rtc::Socket::CS_CLOSED; in IsSendingMessage()
191 if (hanging_get_->GetState() != rtc::Socket::CS_CLOSED) in SignOut()
194 if (control_socket_->GetState() == rtc::Socket::CS_CLOSED) { in SignOut()
228 ASSERT(control_socket_->GetState() == rtc::Socket::CS_CLOSED); in ConnectControlSocket()
376 ASSERT(hanging_get_->GetState() == rtc::Socket::CS_CLOSED); in OnRead()
420 if (hanging_get_->GetState() == rtc::Socket::CS_CLOSED && in OnHangingGetRead()
/external/webrtc/webrtc/modules/video_coding/
Djitter_buffer.cc52 return pair.second->GetState() != kStateEmpty; in HasNonEmptyState()
100 if (oldest_frame->GetState() == kStateEmpty && size() > 1) { in CleanUpOldOrEmptyFrames()
464 if (decodable_frames_.Front()->GetState() == kStateComplete) { in CompleteSequenceWithNextFrame()
486 decodable_frames_.Front()->GetState() != kStateComplete) { in NextCompleteTimestamp()
504 decodable_frames_.Front()->GetState() != kStateComplete) { in NextCompleteTimestamp()
515 decodable_frames_.Front()->GetState() != kStateComplete) { in NextCompleteTimestamp()
543 if (oldest_frame->GetState() < kStateComplete) { in NextMaybeIncompleteTimestamp()
552 oldest_frame->GetState() != kStateComplete) { in NextMaybeIncompleteTimestamp()
586 if (frame->GetState() == kStateComplete) { in ExtractAndSetDecode()
735 VCMFrameBufferStateEnum previous_state = frame->GetState(); in InsertPacket()
[all …]
Dframe_buffer.h39 VCMFrameBufferStateEnum GetState() const;
41 VCMFrameBufferStateEnum GetState(uint32_t& timeStamp) const;
Dframe_buffer.cc236 VCMFrameBufferStateEnum VCMFrameBuffer::GetState() const { in GetState() function in webrtc::VCMFrameBuffer
241 VCMFrameBufferStateEnum VCMFrameBuffer::GetState(uint32_t& timeStamp) const { in GetState() function in webrtc::VCMFrameBuffer
243 return GetState(); in GetState()
/external/gptfdisk/
Dgdisk.cc34 if (theGPT.GetState() != use_gpt) in main()
41 if (theGPT.GetState() != use_gpt) in main()
/external/webrtc/webrtc/p2p/base/
Ddtlstransportchannel.h36 rtc::StreamState GetState() const override { return state_; } in GetState() function
164 TransportChannelState GetState() const override { in GetState() function
165 return channel_->GetState(); in GetState()
/external/chromium-trace/catapult/devil/devil/android/sdk/
Dadb_wrapper_devicetest.py76 while self._adb.GetState() == 'device':
79 self.assertEqual(self._adb.GetState(), 'device')
/external/webrtc/talk/media/devices/
Dfilevideocapturer.cc58 if (rtc::SS_CLOSED == video_file_.GetState()) { in RecordFrame()
236 if (rtc::SS_CLOSED == video_file_.GetState()) { in Start()
326 if (rtc::SS_CLOSED == video_file_.GetState()) { in ReadFrame()

12345