Home
last modified time | relevance | path

Searched refs:streams_ (Results 1 – 25 of 38) sorted by relevance

12

/external/webrtc/modules/video_coding/
Dvideo_codec_initializer_unittest.cc92 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/
Dquantile_stream_resource.h40 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/
Dquic_service_common.cc78 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()
Dquic_service_common.h102 bool has_streams() const { return !streams_.empty(); } in has_streams()
123 std::map<uint64_t, ServiceStreamPair> streams_; variable
Dquic_connection_impl.h99 std::vector<QuicStream*> streams_; variable
/external/webrtc/call/
Dbitrate_estimator_tests.cc105 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/
Dzero_copy_stream_impl.cc313 : 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/
Dstream_pool.cc27 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()
Dexecution_tracker.cc32 streams_(std::move(streams)), in AsyncExecution()
35 for (const auto& stream : streams_) { in AsyncExecution()
41 for (auto& stream : streams_) { in BlockUntilDone()
Dstream_pool.h59 std::vector<std::unique_ptr<se::Stream>> streams_ TF_GUARDED_BY(mu_);
Dexecution_tracker.h57 std::vector<StreamPool::Ptr> streams_; variable
/external/webrtc/modules/remote_bitrate_estimator/
Dremote_bitrate_estimator_unittest_helper.cc128 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()
Dremote_bitrate_estimator_unittest_helper.h144 StreamMap streams_; variable
/external/webrtc/pc/
Daudio_rtp_receiver.cc104 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()
Dvideo_rtp_receiver.cc75 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()
Daudio_rtp_receiver.h68 return streams_; in streams()
122 std::vector<rtc::scoped_refptr<MediaStreamInterface>> streams_; variable
Dvideo_rtp_receiver.h70 return streams_; in streams()
134 std::vector<rtc::scoped_refptr<MediaStreamInterface>> streams_; variable
/external/webrtc/modules/pacing/
Dround_robin_packet_queue.cc250 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()
Dround_robin_packet_queue.h166 std::map<uint32_t, Stream> streams_; variable
/external/webrtc/rtc_base/
Dlogging.cc90 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/
Dfake_quic_connection.cc61 streams_.emplace(result->id(), result.get()); in MakeIncomingStream()
79 streams_.emplace(result->id(), result.get()); in MakeOutgoingStream()
87 for (auto& stream : streams_) { in Close()
Dfake_quic_connection.h56 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/
Ddelay_based_bwe_unittest_helper.cc90 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()
Ddelay_based_bwe_unittest_helper.h110 std::vector<std::unique_ptr<RtpStream>> streams_; variable
/external/tensorflow/tensorflow/compiler/xla/python/tpu_driver/
Dgrpc_tpu_driver.cc326 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()

12