Home
last modified time | relevance | path

Searched refs:observer_ (Results 1 – 25 of 50) sorted by relevance

12

/external/libchrome/base/threading/
Dscoped_blocking_call_unittest.cc33 internal::SetBlockingObserverForCurrentThread(&observer_); in ScopedBlockingCallTest()
40 testing::StrictMock<MockBlockingObserver> observer_; member in base::__anonb36ba3010111::ScopedBlockingCallTest
49 EXPECT_CALL(observer_, BlockingStarted(BlockingType::MAY_BLOCK)); in TEST_F()
51 testing::Mock::VerifyAndClear(&observer_); in TEST_F()
52 EXPECT_CALL(observer_, BlockingEnded()); in TEST_F()
56 EXPECT_CALL(observer_, BlockingStarted(BlockingType::WILL_BLOCK)); in TEST_F()
58 testing::Mock::VerifyAndClear(&observer_); in TEST_F()
59 EXPECT_CALL(observer_, BlockingEnded()); in TEST_F()
63 EXPECT_CALL(observer_, BlockingStarted(BlockingType::MAY_BLOCK)); in TEST_F()
65 testing::Mock::VerifyAndClear(&observer_); in TEST_F()
[all …]
/external/webrtc/talk/app/webrtc/
Ddtlsidentitystore_unittest.cc84 observer_( in DtlsIdentityStoreTest()
99 rtc::scoped_refptr<MockDtlsIdentityRequestObserver> observer_; member in DtlsIdentityStoreTest
105 store_->RequestIdentity(rtc::KT_RSA, observer_.get()); in TEST_F()
106 EXPECT_TRUE_WAIT(observer_->LastRequestSucceeded(), kTimeoutMs); in TEST_F()
110 observer_->Reset(); in TEST_F()
113 store_->RequestIdentity(rtc::KT_RSA, observer_.get()); in TEST_F()
114 EXPECT_FALSE(observer_->call_back_called()); in TEST_F()
115 EXPECT_TRUE_WAIT(observer_->LastRequestSucceeded(), kTimeoutMs); in TEST_F()
122 store_->RequestIdentity(rtc::KT_ECDSA, observer_.get()); in TEST_F()
123 EXPECT_TRUE_WAIT(observer_->LastRequestSucceeded(), kTimeoutMs); in TEST_F()
[all …]
Ddtmfsender_unittest.cc143 observer_(new rtc::RefCountedObject<FakeDtmfObserver>()), in DtmfSenderTest()
148 dtmf_->RegisterObserver(observer_.get()); in DtmfSenderTest()
220 const std::vector<std::string>& tones = observer_->tones(); in VerifyOnObserver()
234 rtc::scoped_ptr<FakeDtmfObserver> observer_; member in DtmfSenderTest
250 EXPECT_TRUE_WAIT(observer_->completed(), kMaxWaitMs); in TEST_F()
266 EXPECT_TRUE_WAIT(observer_->tones().size() == 1, kMaxWaitMs); in TEST_F()
272 EXPECT_TRUE_WAIT(observer_->completed(), kMaxWaitMs); in TEST_F()
287 EXPECT_TRUE_WAIT(observer_->tones().size() == 1, kMaxWaitMs); in TEST_F()
292 EXPECT_EQ(1U, observer_->tones().size()); in TEST_F()
301 EXPECT_TRUE_WAIT(observer_->tones().size() == 1, kMaxWaitMs); in TEST_F()
[all …]
Dpeerconnectioninterface_unittest.cc577 std::move(dtls_identity_store), &observer_); in CreatePeerConnection()
579 observer_.SetPeerConnectionInterface(pc_.get()); in CreatePeerConnection()
580 EXPECT_EQ(PeerConnectionInterface::kStable, observer_.state_); in CreatePeerConnection()
591 &observer_); in CreatePeerConnectionExpectFail()
620 observer_.SetPeerConnectionInterface(NULL); in ReleasePeerConnection()
633 EXPECT_TRUE_WAIT(observer_.renegotiation_needed_, kTimeout); in AddVideoStream()
634 observer_.renegotiation_needed_ = false; in AddVideoStream()
645 EXPECT_TRUE_WAIT(observer_.renegotiation_needed_, kTimeout); in AddVoiceStream()
646 observer_.renegotiation_needed_ = false; in AddVoiceStream()
663 EXPECT_TRUE_WAIT(observer_.renegotiation_needed_, kTimeout); in AddAudioVideoStream()
[all …]
Ddtmfsender.cc95 observer_(NULL), in DtmfSender()
118 observer_ = observer; in RegisterObserver()
122 observer_ = NULL; in UnregisterObserver()
202 if (observer_) { in DoInsertDtmf()
203 observer_->OnToneChange(std::string()); in DoInsertDtmf()
236 if (observer_) { in DoInsertDtmf()
237 observer_->OnToneChange(tones_.substr(first_tone_pos, 1)); in DoInsertDtmf()
Ddatachannel_unittest.cc99 observer_.reset(new FakeDataChannelObserver()); in AddObserver()
100 webrtc_data_channel_->RegisterObserver(observer_.get()); in AddObserver()
105 rtc::scoped_ptr<FakeDataChannelObserver> observer_; member in SctpDataChannelTest
158 EXPECT_EQ(0U, observer_->on_buffered_amount_change_count()); in TEST_F()
168 EXPECT_EQ(number_of_packets, observer_->on_buffered_amount_change_count()); in TEST_F()
180 EXPECT_EQ(1U, observer_->on_buffered_amount_change_count()); in TEST_F()
185 EXPECT_EQ(2U, observer_->on_buffered_amount_change_count()); in TEST_F()
196 EXPECT_EQ(1U, observer_->on_buffered_amount_change_count()); in TEST_F()
201 EXPECT_EQ(1U, observer_->on_buffered_amount_change_count()); in TEST_F()
207 EXPECT_EQ(2U, observer_->on_buffered_amount_change_count()); in TEST_F()
[all …]
Ddatachannel.cc145 observer_(NULL), in DataChannel()
216 observer_ = observer; in RegisterObserver()
221 observer_ = NULL; in UnregisterObserver()
384 if (state_ == kOpen && observer_) { in OnDataReceived()
385 observer_->OnMessage(*buffer.get()); in OnDataReceived()
488 if (observer_) { in SetState()
489 observer_->OnStateChange(); in SetState()
509 if (!observer_) { in DeliverQueuedReceivedData()
515 observer_->OnMessage(*buffer); in DeliverQueuedReceivedData()
538 if (observer_ && buffered_amount() < start_buffered_amount) { in SendQueuedDataMessages()
[all …]
Dpeerconnectionfactory_unittest.cc142 NullPeerConnectionObserver observer_; member in PeerConnectionFactoryTest
187 std::move(dtls_identity_store), &observer_)); in TEST_F()
217 std::move(dtls_identity_store), &observer_)); in TEST_F()
246 std::move(dtls_identity_store), &observer_)); in TEST_F()
267 std::move(dtls_identity_store), &observer_)); in TEST_F()
292 std::move(dtls_identity_store), &observer_)); in TEST_F()
327 std::move(dtls_identity_store), &observer_)); in TEST_F()
Dwebrtcsession_unittest.cc410 allocator_.get(), &observer_)); in Init()
415 observer_.ice_connection_state_); in Init()
417 observer_.ice_gathering_state_); in Init()
610 observer_.ice_gathering_state_, in InitiateCall()
1122 EXPECT_TRUE_WAIT(observer_.oncandidatesready_, kIceCandidatesTimeout); in TestSessionCandidatesWithBundleRtcpMux()
1123 EXPECT_EQ(expected_candidate_num, observer_.mline_0_candidates_.size()); in TestSessionCandidatesWithBundleRtcpMux()
1125 EXPECT_EQ(0, observer_.mline_1_candidates_.size()); in TestSessionCandidatesWithBundleRtcpMux()
1127 EXPECT_EQ(expected_candidate_num, observer_.mline_1_candidates_.size()); in TestSessionCandidatesWithBundleRtcpMux()
1256 observer_.ice_gathering_state_); in SetupLoopbackCall()
1259 observer_.ice_connection_state_); in SetupLoopbackCall()
[all …]
Dpeerconnection.cc566 observer_(NULL), in PeerConnection()
599 observer_ = observer; in Initialize()
708 observer_->OnRenegotiationNeeded(); in AddStream()
734 observer_->OnRenegotiationNeeded(); in RemoveStream()
851 observer_->OnRenegotiationNeeded(); in CreateDataChannel()
1119 observer_->OnAddStream(new_stream); in SetRemoteDescription()
1304 observer_->OnIceConnectionChange(ice_connection_state_); in OnIceConnectionChange()
1314 observer_->OnIceGatheringChange(ice_gathering_state_); in OnIceGatheringChange()
1319 observer_->OnIceCandidate(candidate); in OnIceCandidate()
1324 observer_->OnIceComplete(); in OnIceComplete()
[all …]
/external/v8/src/interpreter/
Dbytecode-register-allocator.h31 observer_(nullptr) {} in BytecodeRegisterAllocator()
38 if (observer_) { in NewRegister()
39 observer_->RegisterAllocateEvent(reg); in NewRegister()
49 if (observer_) { in NewRegisterList()
50 observer_->RegisterListAllocateEvent(reg_list); in NewRegisterList()
80 if (observer_) { in ReleaseRegisters()
81 observer_->RegisterListFreeEvent(RegisterList(register_index, count)); in ReleaseRegisters()
95 void set_observer(Observer* observer) { observer_ = observer; } in set_observer()
103 Observer* observer_; variable
/external/webrtc/webrtc/video/
Doveruse_frame_detector_unittest.cc56 observer_.reset(new MockCpuOveruseObserver()); in SetUp()
63 observer_.get(), this)); in ReinitializeOveruseDetector()
109 rtc::scoped_ptr<MockCpuOveruseObserver> observer_; member in webrtc::OveruseFrameDetectorTest
119 EXPECT_CALL(*(observer_.get()), OveruseDetected()).Times(1); in TEST_F()
125 EXPECT_CALL(*(observer_.get()), OveruseDetected()).Times(1); in TEST_F()
128 EXPECT_CALL(*(observer_.get()), NormalUsage()).Times(testing::AtLeast(1)); in TEST_F()
135 EXPECT_CALL(*(observer_.get()), OveruseDetected()).Times(0); in TEST_F()
137 EXPECT_CALL(*(observer_.get()), NormalUsage()).Times(0); in TEST_F()
142 EXPECT_CALL(*(observer_.get()), OveruseDetected()).Times(2); in TEST_F()
145 EXPECT_CALL(*(observer_.get()), NormalUsage()).Times(testing::AtLeast(1)); in TEST_F()
[all …]
Dencoded_frame_callback_adapter.cc20 EncodedFrameObserver* observer) : observer_(observer) { in EncodedFrameCallbackAdapter()
29 RTC_DCHECK(observer_ != nullptr); in Encoded()
32 observer_->EncodedFrameCallback(frame); in Encoded()
Doveruse_frame_detector.cc172 observer_(observer), in OveruseFrameDetector()
324 if (observer_ != NULL) in Process()
325 observer_->OveruseDetected(); in Process()
330 if (observer_ != NULL) in Process()
331 observer_->NormalUsage(); in Process()
/external/libchrome/mojo/public/cpp/system/
Dfile_data_pipe_producer.cc71 observer_(std::move(observer)) {} in FileSequenceState()
172 if (observer_) in TransferSomeBytes()
173 observer_->OnBytesRead(pipe_buffer, 0u, read_error); in TransferSomeBytes()
176 if (observer_) { in TransferSomeBytes()
177 observer_->OnBytesRead(pipe_buffer, static_cast<size_t>(read_size), in TransferSomeBytes()
208 if (observer_) { in Finish()
209 observer_->OnDoneReading(); in Finish()
210 observer_ = nullptr; in Finish()
231 std::unique_ptr<Observer> observer_; member in mojo::FileDataPipeProducer::FileSequenceState
240 observer_(std::move(observer)), in FileDataPipeProducer()
/external/libchrome/base/
Dscoped_observer.h23 explicit ScopedObserver(Observer* observer) : observer_(observer) {} in ScopedObserver()
32 source->AddObserver(observer_); in Add()
40 source->RemoveObserver(observer_); in Remove()
45 sources_[i]->RemoveObserver(observer_); in RemoveAll()
56 Observer* observer_;
/external/webrtc/webrtc/test/
Drtp_rtcp_observer.h87 observer_(observer), in PacketTransport()
98 action = observer_->OnSendRtp(packet, length); in SendRtp()
100 action = observer_->OnReceiveRtp(packet, length); in SendRtp()
118 action = observer_->OnSendRtcp(packet, length); in SendRtcp()
120 action = observer_->OnReceiveRtcp(packet, length); in SendRtcp()
133 RtpRtcpObserver* const observer_; variable
/external/pdfium/core/fxcrt/
Dshared_copy_on_write_unittest.cpp35 : name_(name), observer_(observer) { in Object()
38 Object(const Object& that) : name_(that.name_), observer_(that.observer_) { in Object()
39 observer_->OnConstruct(name_); in Object()
41 ~Object() override { observer_->OnDestruct(name_); } in ~Object()
45 Observer* observer_; member in fxcrt::__anonf5ea37e30111::Object
/external/webrtc/webrtc/call/
Dcongestion_controller.cc42 : observer_(observer), in WrappingBitrateEstimator()
45 rbe_(new RemoteBitrateEstimatorSingleStream(observer_, clock_)), in WrappingBitrateEstimator()
127 rbe_.reset(new RemoteBitrateEstimatorAbsSendTime(observer_, clock_)); in PickEstimator()
129 rbe_.reset(new RemoteBitrateEstimatorSingleStream(observer_, clock_)); in PickEstimator()
134 RemoteBitrateObserver* observer_; member in webrtc::__anon9ac7c0410111::WrappingBitrateEstimator
/external/webrtc/webrtc/modules/rtp_rtcp/source/
Dbitrate.cc27 observer_(observer) { in Bitrate()
119 if (observer_) in Process()
120 observer_->BitrateUpdated(stats); in Process()
/external/webrtc/webrtc/p2p/stunprober/
Dstunprober.cc280 observer_ = observer; in Prepare()
285 observer_ = observer; in Start()
559 if (observer_) { in ReportOnPrepared()
560 observer_->OnPrepared(this, status); in ReportOnPrepared()
565 if (observer_) { in ReportOnFinished()
566 observer_->OnFinished(this, status); in ReportOnFinished()
/external/webrtc/webrtc/modules/remote_bitrate_estimator/
Dremote_bitrate_estimator_single_stream.cc54 observer_(observer), in RemoteBitrateEstimatorSingleStream()
58 assert(observer_); in RemoteBitrateEstimatorSingleStream()
183 observer_->OnReceiveBitrateChanged(ssrcs, target_bitrate); in UpdateEstimate()
/external/webrtc/webrtc/system_wrappers/source/
Dscoped_vector_unittest.cc34 observer_->OnLifeCycleDestroy(this); in ~LifeCycleObject()
41 : observer_(observer) { in LifeCycleObject()
42 observer_->OnLifeCycleConstruct(this); in LifeCycleObject()
45 Observer* observer_; member in webrtc::__anonf7148d500111::LifeCycleObject
/external/webrtc/webrtc/modules/remote_bitrate_estimator/test/estimators/
Dnada.cc158 observer_(observer), in NadaBweSender()
165 observer_(observer), in NadaBweSender()
233 observer_->OnNetworkChanged(1000 * bitrate_kbps_, 0, rtt_ms); in GiveFeedback()
/external/v8/src/profiler/
Dprofiler-listener.h83 observer_->CodeEventHandler(evt_rec); in DispatchCodeEvent()
87 CodeEventObserver* observer_; variable

12