| /external/webrtc/webrtc/modules/rtp_rtcp/source/ |
| D | producer_fec_unittest.cc | 45 producer_ = new ProducerFec(fec_); in SetUp()
50 delete producer_; in TearDown()
55 ProducerFec* producer_; member in webrtc::ProducerFecTest
82 producer_->SetFecParameters(¶ms, 0); in TEST_F()
91 producer_->AddRtpPacketAndGenerateFec(packet, p.payload_size, in TEST_F()
93 uint16_t num_fec_packets = producer_->NumAvailableFecPackets(); in TEST_F()
97 producer_->GetFecPackets(kRedPayloadType, 99, 100, p.header_size); in TEST_F()
117 producer_->SetFecParameters(¶ms, 0); // Expecting one FEC packet. in TEST_F()
122 EXPECT_EQ(0, producer_->AddRtpPacketAndGenerateFec(rtp_packet->data, in TEST_F()
127 EXPECT_TRUE(producer_->FecAvailable()); in TEST_F()
[all …]
|
| /external/perfetto/src/tracing/test/ |
| D | tracing_integration_test.cc | 132 kProducerSockName, &producer_, "perfetto.mock_producer", in SetUp()
136 EXPECT_CALL(producer_, OnConnect()).WillOnce(Invoke(on_producer_connect)); in SetUp()
152 ASSERT_TRUE(testing::Mock::VerifyAndClearExpectations(&producer_)); in SetUp()
162 EXPECT_CALL(producer_, OnDisconnect()) in TearDown()
174 ASSERT_TRUE(testing::Mock::VerifyAndClearExpectations(&producer_)); in TearDown()
218 MockProducer producer_; member in perfetto::TracingIntegrationTest
238 EXPECT_CALL(producer_, OnTracingSetup()); in TEST_F()
244 EXPECT_CALL(producer_, SetupDataSource(_, _)) in TEST_F()
251 EXPECT_CALL(producer_, StartDataSource(_, _)) in TEST_F()
340 EXPECT_CALL(producer_, StopDataSource(_)); in TEST_F()
[all …]
|
| /external/perfetto/test/ |
| D | test_helper.h | 82 runner_->PostTaskAndWaitForTesting([this]() { producer_.reset(); }); in ~ProbesProducerThread()
88 producer_.reset(new ProbesProducer()); in Connect()
89 producer_->ConnectWithRetries(producer_socket_.c_str(), runner_->get()); in Connect()
97 std::unique_ptr<ProbesProducer> producer_; variable
112 producer_.reset( in FakeProducerThread()
118 runner_->PostTaskAndWaitForTesting([this]() { producer_.reset(); }); in ~FakeProducerThread()
123 producer_->Connect(producer_socket_.c_str(), std::move(connect_callback_), in Connect()
131 FakeProducer* producer() { return producer_.get(); } in producer()
143 producer_->ProduceStartupEventBatch(config, shm_arbiter_.get(), callback); in ProduceStartupEventBatch()
150 std::unique_ptr<FakeProducer> producer_; variable
|
| D | end_to_end_shared_memory_fuzzer.cc | 122 runner_->PostTaskAndWaitForTesting([this]() { producer_.reset(); }); in ~FuzzerFakeProducerThread()
128 producer_.reset(new FakeProducer("android.perfetto.FakeProducer", data_, in Connect()
130 producer_->Connect(TEST_PRODUCER_SOCK_NAME, runner_->get()); in Connect()
137 std::unique_ptr<FakeProducer> producer_; member in perfetto::shm_fuzz::__anon2faf07b90111::FuzzerFakeProducerThread
|
| /external/perfetto/src/tracing/ipc/producer/ |
| D | producer_ipc_client_impl.cc | 69 : producer_(producer), in ProducerIPCClientImpl()
169 producer_->OnDisconnect(); in OnDisconnect()
182 producer_->OnConnect(); in OnConnectionInitialized()
203 producer_->SetupDataSource(dsid, req.config()); in OnServiceRequest()
214 producer_->SetupDataSource(dsid, cfg); in OnServiceRequest()
216 producer_->StartDataSource(dsid, cfg); in OnServiceRequest()
222 producer_->StopDataSource(dsid); in OnServiceRequest()
247 producer_->OnTracingSetup(); in OnServiceRequest()
258 producer_->Flush( in OnServiceRequest()
270 producer_->ClearIncrementalState( in OnServiceRequest()
|
| D | producer_ipc_client_impl.h | 104 Producer* const producer_; variable
|
| /external/libchrome/mojo/public/cpp/system/ |
| D | string_data_pipe_producer.cc | 60 : producer_(std::move(producer)), in StringDataPipeProducer()
78 WriteDataToProducerHandle(producer_.get(), data.data(), &size); in Write()
92 watcher_.Watch(producer_.get(), MOJO_HANDLE_SIGNAL_WRITABLE, in Write()
111 WriteDataToProducerHandle(producer_.get(), data_view_.data(), &size); in OnProducerHandleReady()
|
| D | string_data_pipe_producer.h | 78 ScopedDataPipeProducerHandle producer_; variable
|
| D | file_data_pipe_producer.h | 104 ScopedDataPipeProducerHandle producer_; variable
|
| D | file_data_pipe_producer.cc | 239 : producer_(std::move(producer)), in FileDataPipeProducer()
284 producer_ = std::move(producer); in OnWriteComplete()
|
| /external/libchrome/mojo/core/ |
| D | data_pipe_unittest.cc | 51 : producer_(MOJO_HANDLE_INVALID), consumer_(MOJO_HANDLE_INVALID) {} in DataPipeTest()
54 if (producer_ != MOJO_HANDLE_INVALID) in ~DataPipeTest()
55 CHECK_EQ(MOJO_RESULT_OK, MojoClose(producer_)); in ~DataPipeTest()
77 return MojoCreateDataPipe(options, &producer_, &consumer_); in Create()
87 return MojoWriteData(producer_, elements, num_bytes, &options); in WriteData()
132 return MojoBeginWriteData(producer_, nullptr, elements, num_bytes); in BeginWriteData()
136 return MojoEndWriteData(producer_, num_bytes_written, nullptr); in EndWriteData()
140 MojoResult rv = MojoClose(producer_); in CloseProducer()
141 producer_ = MOJO_HANDLE_INVALID; in CloseProducer()
151 MojoHandle producer_, consumer_; member in mojo::core::__anonca347a760111::DataPipeTest
[all …]
|
| /external/perfetto/src/profiling/memory/ |
| D | heapprofd_producer.cc | 745 auto it = producer_->pending_processes_.find(self->peer_pid()); in OnDisconnect()
746 if (it == producer_->pending_processes_.end()) { in OnDisconnect()
752 producer_->pending_processes_.erase(it); in OnDisconnect()
763 producer_->HandleClientConnection(std::move(new_connection), peer_process); in OnNewIncomingConnection()
768 auto it = producer_->pending_processes_.find(self->peer_pid()); in OnDataAvailable()
769 if (it == producer_->pending_processes_.end()) { in OnDataAvailable()
785 producer_->data_sources_.find(pending_process.data_source_instance_id); in OnDataAvailable()
786 if (ds_it == producer_->data_sources_.end()) { in OnDataAvailable()
787 producer_->pending_processes_.erase(it); in OnDataAvailable()
793 producer_->pending_processes_.erase(it); in OnDataAvailable()
[all …]
|
| D | heapprofd_producer.h | 102 SocketDelegate(HeapprofdProducer* producer) : producer_(producer) {} in SocketDelegate()
111 HeapprofdProducer* producer_;
|
| /external/swiftshader/third_party/llvm-7.0/llvm/utils/unittest/googlemock/include/gmock/ |
| D | gmock-actions.h | 205 delete producer_;
206 producer_ = new FixedValueProducer(x);
214 delete producer_;
215 producer_ = new FactoryValueProducer(factory);
220 delete producer_;
221 producer_ = NULL;
225 static bool IsSet() { return producer_ != NULL; }
237 return producer_ == NULL ?
238 internal::BuiltInDefaultValue<T>::Get() : producer_->Produce();
269 static ValueProducer* producer_;
[all …]
|
| /external/googletest/googlemock/include/gmock/ |
| D | gmock-actions.h | 193 delete producer_;
194 producer_ = new FixedValueProducer(x);
202 delete producer_;
203 producer_ = new FactoryValueProducer(factory);
208 delete producer_;
209 producer_ = nullptr;
213 static bool IsSet() { return producer_ != nullptr; }
225 return producer_ == nullptr ? internal::BuiltInDefaultValue<T>::Get()
226 : producer_->Produce();
257 static ValueProducer* producer_;
[all …]
|
| /external/perfetto/src/tracing/core/ |
| D | tracing_service_impl.cc | 319 task_runner_->PostTask(std::bind(&Producer::OnConnect, endpoint->producer_)); in ConnectProducer()
2982 producer_(producer), in ProducerEndpointImpl()
2990 producer_->OnDisconnect(); in ~ProducerEndpointImpl()
3135 weak_this->producer_->StopDataSource(ds_inst_id); in StopDataSource()
3178 weak_this->producer_->OnTracingSetup(); in OnTracingSetup()
3189 weak_this->producer_->Flush(flush_request_id, data_sources.data(), in Flush()
3203 weak_this->producer_->SetupDataSource(ds_id, std::move(config)); in SetupDataSource()
3214 weak_this->producer_->StartDataSource(ds_id, std::move(config)); in StartDataSource()
3244 weak_this->producer_->ClearIncrementalState(data_sources.data(), in ClearIncrementalState()
|
| D | tracing_service_impl.h | 140 Producer* producer_; variable
|
| /external/libchrome/libchrome_tools/patch/ |
| D | mojom_disable_trace_and_mem_dump.patch | 243 - std::move(producer_), file_task_runner,
252 + // std::move(producer_), file_task_runner,
|