/external/webrtc/modules/video_coding/ |
D | video_codec_initializer_unittest.cc | 92 if (!VideoCodecInitializer::SetupCodec(config_, streams_, &codec_out_)) { in InitializeCodec() 141 std::vector<VideoStream> streams_; member in webrtc::VideoCodecInitializerTest 151 streams_.push_back(DefaultStream()); in TEST_F() 166 streams_.push_back(inactive_stream); in TEST_F() 179 streams_.push_back(DefaultScreenshareStream()); in TEST_F() 194 streams_.push_back(DefaultScreenshareStream()); in TEST_F() 197 streams_.push_back(video_stream); in TEST_F() 203 streams_[0].target_bitrate_bps + streams_[1].max_bitrate_bps; in TEST_F() 208 EXPECT_EQ(static_cast<uint32_t>(streams_[0].target_bitrate_bps), in TEST_F() 210 EXPECT_EQ(static_cast<uint32_t>(streams_[1].max_bitrate_bps), in TEST_F() [all …]
|
/external/tensorflow/tensorflow/core/kernels/boosted_trees/quantiles/ |
D | quantile_stream_resource.h | 40 streams_.reserve(num_streams_); in BoostedTreesQuantileStreamResource() 43 streams_.push_back(QuantileStream(epsilon, max_elements)); in BoostedTreesQuantileStreamResource() 52 QuantileStream* stream(const int64 index) { return &streams_[index]; } in stream() 71 streams_.clear(); in ResetStreams() 72 streams_.reserve(num_streams_); in ResetStreams() 74 streams_.push_back(QuantileStream(epsilon_, max_elements_)); in ResetStreams() 85 std::vector<QuantileStream> streams_; variable
|
/external/openscreen/osp/impl/quic/ |
D | quic_service_common.cc | 78 OSP_DCHECK(streams_.empty()); in ~ServiceConnectionDelegate() 83 streams_.emplace(stream_id, std::move(stream_pair)); in AddStreamPair() 88 auto stream_entry = streams_.find(connection->stream()->id()); in DropProtocolConnection() 89 if (stream_entry == streams_.end()) in DropProtocolConnection() 132 auto stream_entry = streams_.find(stream->id()); in OnReceived() 133 if (stream_entry == streams_.end()) in OnReceived() 142 auto stream_entry = streams_.find(stream_id); in OnClose() 143 if (stream_entry == streams_.end()) in OnClose() 156 streams_.erase(stream_entry); in OnClose()
|
D | quic_service_common.h | 102 bool has_streams() const { return !streams_.empty(); } in has_streams() 123 std::map<uint64_t, ServiceStreamPair> streams_; variable
|
D | quic_connection_impl.h | 99 std::vector<QuicStream*> streams_; variable
|
/external/webrtc/call/ |
D | bitrate_estimator_tests.cc | 105 virtual ~BitrateEstimatorTest() { EXPECT_TRUE(streams_.empty()); } in ~BitrateEstimatorTest() 152 for (auto* stream : streams_) { in TearDown() 156 streams_.clear(); in TearDown() 245 std::vector<Stream*> streams_; member in webrtc::BitrateEstimatorTest 259 streams_.push_back(new Stream(this)); in TEST_F() 272 streams_.push_back(new Stream(this)); in TEST_F() 283 streams_.push_back(new Stream(this)); in TEST_F() 292 streams_.push_back(new Stream(this)); in TEST_F() 305 streams_.push_back(new Stream(this)); in TEST_F() 314 streams_.push_back(new Stream(this)); in TEST_F() [all …]
|
/external/protobuf/src/google/protobuf/io/ |
D | zero_copy_stream_impl.cc | 313 : streams_(streams), stream_count_(count), bytes_retired_(0) { in ConcatenatingInputStream() 318 if (streams_[0]->Next(data, size)) return true; in Next() 321 bytes_retired_ += streams_[0]->ByteCount(); in Next() 322 ++streams_; in Next() 332 streams_[0]->BackUp(count); in BackUp() 342 int64 target_byte_count = streams_[0]->ByteCount() + count; in Skip() 343 if (streams_[0]->Skip(count)) return true; in Skip() 347 int64 final_byte_count = streams_[0]->ByteCount(); in Skip() 353 ++streams_; in Skip() 364 return bytes_retired_ + streams_[0]->ByteCount(); in ByteCount()
|
/external/tensorflow/tensorflow/compiler/xla/service/ |
D | stream_pool.cc | 27 if (!streams_.empty()) { in BorrowStream() 29 stream = std::move(streams_.back()); in BorrowStream() 30 streams_.pop_back(); in BorrowStream() 60 streams_.emplace_back(stream); in ReturnStream()
|
D | execution_tracker.cc | 32 streams_(std::move(streams)), in AsyncExecution() 35 for (const auto& stream : streams_) { in AsyncExecution() 41 for (auto& stream : streams_) { in BlockUntilDone()
|
D | stream_pool.h | 59 std::vector<std::unique_ptr<se::Stream>> streams_ TF_GUARDED_BY(mu_);
|
D | execution_tracker.h | 57 std::vector<StreamPool::Ptr> streams_; variable
|
/external/webrtc/modules/remote_bitrate_estimator/ |
D | remote_bitrate_estimator_unittest_helper.cc | 128 for (StreamMap::iterator it = streams_.begin(); it != streams_.end(); ++it) { in ~StreamGenerator() 131 streams_.clear(); in ~StreamGenerator() 136 streams_[stream->ssrc()] = stream; in AddStream() 148 ASSERT_GE(streams_.size(), 0u); in SetBitrateBps() 150 for (StreamMap::iterator it = streams_.begin(); it != streams_.end(); ++it) { in SetBitrateBps() 155 for (StreamMap::iterator it = streams_.begin(); it != streams_.end(); ++it) { in SetBitrateBps() 169 streams_[ssrc]->set_rtp_timestamp_offset(offset); in set_rtp_timestamp_offset() 180 std::min_element(streams_.begin(), streams_.end(), RtpStream::Compare); in GenerateFrame() 194 it = std::min_element(streams_.begin(), streams_.end(), RtpStream::Compare); in GenerateFrame()
|
D | remote_bitrate_estimator_unittest_helper.h | 144 StreamMap streams_; variable
|
/external/webrtc/pc/ |
D | audio_rtp_receiver.cc | 104 std::vector<std::string> stream_ids(streams_.size()); in stream_ids() 105 for (size_t i = 0; i < streams_.size(); ++i) in stream_ids() 106 stream_ids[i] = streams_[i]->id(); in stream_ids() 190 for (const auto& existing_stream : streams_) { in SetStreams() 206 for (const auto& existing_stream : streams_) { in SetStreams() 217 streams_ = streams; in SetStreams()
|
D | video_rtp_receiver.cc | 75 std::vector<std::string> stream_ids(streams_.size()); in stream_ids() 76 for (size_t i = 0; i < streams_.size(); ++i) in stream_ids() 77 stream_ids[i] = streams_[i]->id(); in stream_ids() 206 for (const auto& existing_stream : streams_) { in SetStreams() 222 for (const auto& existing_stream : streams_) { in SetStreams() 233 streams_ = streams; in SetStreams()
|
D | audio_rtp_receiver.h | 68 return streams_; in streams() 122 std::vector<rtc::scoped_refptr<MediaStreamInterface>> streams_; variable
|
D | video_rtp_receiver.h | 70 return streams_; in streams() 134 std::vector<rtc::scoped_refptr<MediaStreamInterface>> streams_; variable
|
/external/webrtc/modules/pacing/ |
D | round_robin_packet_queue.cc | 250 const auto& top_packet = streams_.find(ssrc)->second.packet_queue.top(); in LeadingAudioPacketEnqueueTime() 295 for (const auto& stream : streams_) { in SetIncludeOverhead() 308 for (const auto& stream : streams_) { in SetTransportOverhead() 324 auto stream_info_it = streams_.find(packet.Ssrc()); in Push() 325 if (stream_info_it == streams_.end()) { in Push() 326 stream_info_it = streams_.emplace(packet.Ssrc(), Stream()).first; in Push() 391 auto stream_info_it = streams_.find(ssrc); in GetHighestPriorityStream() 392 RTC_CHECK(stream_info_it != streams_.end()); in GetHighestPriorityStream()
|
D | round_robin_packet_queue.h | 166 std::map<uint32_t, Stream> streams_; variable
|
/external/webrtc/rtc_base/ |
D | logging.cc | 90 ABSL_CONST_INIT LogSink* LogMessage::streams_ RTC_GUARDED_BY(g_log_mutex_) = 200 for (LogSink* entry = streams_; entry != nullptr; entry = entry->next_) { in ~LogMessage() 259 for (LogSink* entry = streams_; entry != nullptr; entry = entry->next_) { in GetLogToStream() 270 stream->next_ = streams_; in AddLogToStream() 271 streams_ = stream; in AddLogToStream() 278 for (LogSink** entry = &streams_; *entry != nullptr; in RemoveLogToStream() 285 streams_empty_.store(streams_ == nullptr, std::memory_order_relaxed); in RemoveLogToStream() 341 for (LogSink* entry = streams_; entry != nullptr; entry = entry->next_) { in UpdateMinLogSeverity()
|
/external/openscreen/osp/impl/quic/testing/ |
D | fake_quic_connection.cc | 61 streams_.emplace(result->id(), result.get()); in MakeIncomingStream() 79 streams_.emplace(result->id(), result.get()); in MakeOutgoingStream() 87 for (auto& stream : streams_) { in Close()
|
D | fake_quic_connection.h | 56 std::map<uint64_t, FakeQuicStream*>& streams() { return streams_; } in streams() 74 std::map<uint64_t, FakeQuicStream*> streams_; variable
|
/external/webrtc/modules/congestion_controller/goog_cc/ |
D | delay_based_bwe_unittest_helper.cc | 90 streams_.push_back(std::unique_ptr<RtpStream>(stream)); in AddStream() 102 ASSERT_GE(streams_.size(), 0u); in SetBitrateBps() 104 for (const auto& stream : streams_) { in SetBitrateBps() 109 for (const auto& stream : streams_) { in SetBitrateBps() 129 std::min_element(streams_.begin(), streams_.end(), RtpStream::Compare); in GenerateFrame() 143 it = std::min_element(streams_.begin(), streams_.end(), RtpStream::Compare); in GenerateFrame()
|
D | delay_based_bwe_unittest_helper.h | 110 std::vector<std::unique_ptr<RtpStream>> streams_; variable
|
/external/tensorflow/tensorflow/compiler/xla/python/tpu_driver/ |
D | grpc_tpu_driver.cc | 326 streams_[core_id] = AllocateStream(core_id); in GrpcTpuDriver() 329 CHECK_GT(streams_.size(), 0) << "Can't find any TPU chip in the system."; in GrpcTpuDriver() 350 return streams_[core_id]->Allocate(core_id, region, num_bytes, wait_for); in Allocate() 355 return streams_[core_id]->Allocate(core_id, region, shape, wait_for); in Allocate() 361 return streams_[core_id]->AllocateTuple(core_id, region, children, in AllocateTuple() 395 return streams_[0]->CompileProgram(source, num_replicas, wait_for); in CompileProgram() 400 return streams_[core_id]->LoadProgram(core_id, handle, wait_for); in LoadProgram() 436 absl::flat_hash_map<int32_t, std::unique_ptr<GrpcTpuStream>> streams_; member in tpu_driver::__anon4073f9c10111::GrpcTpuDriver 1032 streams_.clear(); in Reset()
|