| /external/webrtc/webrtc/call/ |
| D | bitrate_estimator_tests.cc | 107 virtual ~BitrateEstimatorTest() { EXPECT_TRUE(streams_.empty()); } in ~BitrateEstimatorTest()
143 std::for_each(streams_.begin(), streams_.end(), in TearDown()
149 while (!streams_.empty()) { in TearDown()
150 delete streams_.back(); in TearDown()
151 streams_.pop_back(); in TearDown()
259 std::vector<Stream*> streams_; member in webrtc::BitrateEstimatorTest
272 streams_.push_back(new Stream(this, false)); in TEST_F()
283 streams_.push_back(new Stream(this, true)); in TEST_F()
294 streams_.push_back(new Stream(this, false)); in TEST_F()
301 streams_.push_back(new Stream(this, true)); 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/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()
|
| D | zero_copy_stream_impl.h | 321 ZeroCopyInputStream* const* streams_;
|
| /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_ GUARDED_BY(mu_);
|
| D | execution_tracker.h | 57 std::vector<StreamPool::Ptr> streams_; variable
|
| /external/webrtc/talk/session/media/ |
| D | mediasession.h | 242 return streams_; in streams()
247 return streams_; in mutable_streams()
250 streams_.push_back(stream); in AddStream()
254 streams_.push_back(StreamParams::CreateLegacy(ssrc)); in AddLegacyStream()
259 streams_.push_back(sp); in AddLegacyStream()
264 for (cricket::StreamParamsVec::iterator it = streams_.begin(); in SetCnameIfEmpty()
265 it != streams_.end(); ++it) { in SetCnameIfEmpty()
271 if (streams_.empty()) { in first_ssrc()
274 return streams_[0].first_ssrc(); in first_ssrc()
277 if (streams_.empty()) { in has_ssrcs()
[all …]
|
| /external/webrtc/webrtc/voice_engine/test/auto_test/fakes/ |
| D | conference_transport.cc | 89 while (!streams_.empty()) { in ~ConferenceTransport()
90 auto stream = streams_.begin(); in ~ConferenceTransport()
124 auto it = streams_.find(sender_ssrc); in GetReceiverChannelForSsrc()
125 if (it != streams_.end()) { in GetReceiverChannelForSsrc()
249 streams_[remote_ssrc] = std::make_pair(new_sender, new_receiver); in AddStream()
256 auto it = streams_.find(id); in RemoveStream()
257 if (it == streams_.end()) { in RemoveStream()
266 streams_.erase(it); in RemoveStream()
|
| D | conference_transport.h | 139 std::map<unsigned int, std::pair<int, int>> streams_
|
| /external/webrtc/webrtc/modules/remote_bitrate_estimator/ |
| D | remote_bitrate_estimator_unittest_helper.cc | 121 for (StreamMap::iterator it = streams_.begin(); it != streams_.end(); in ~StreamGenerator()
125 streams_.clear(); in ~StreamGenerator()
130 streams_[stream->ssrc()] = stream; in AddStream()
142 ASSERT_GE(streams_.size(), 0u); in SetBitrateBps()
144 for (StreamMap::iterator it = streams_.begin(); it != streams_.end(); ++it) { in SetBitrateBps()
149 for (StreamMap::iterator it = streams_.begin(); it != streams_.end(); ++it) { in SetBitrateBps()
163 streams_[ssrc]->set_rtp_timestamp_offset(offset); in set_rtp_timestamp_offset()
173 StreamMap::iterator it = std::min_element(streams_.begin(), streams_.end(), in GenerateFrame()
187 it = std::min_element(streams_.begin(), streams_.end(), RtpStream::Compare); in GenerateFrame()
|
| D | remote_bitrate_estimator_unittest_helper.h | 140 StreamMap streams_; variable
|
| /external/webrtc/talk/media/sctp/ |
| D | sctpdataengine_unittest.cc | 172 void OnStreamClosed(uint32_t stream) { streams_.push_back(stream); } in OnStreamClosed()
175 return std::count(streams_.begin(), streams_.end(), stream); in StreamCloseCount()
179 return std::find(streams_.begin(), streams_.end(), stream) in WasStreamClosed()
180 != streams_.end(); in WasStreamClosed()
184 std::vector<uint32_t> streams_; member in SignalChannelClosedObserver
199 streams_.push_back(stream); in OnStreamClosed()
203 return std::count(streams_.begin(), streams_.end(), stream); in StreamCloseCount()
209 std::vector<int> streams_; member in SignalChannelClosedReopener
|
| /external/webrtc/webrtc/base/ |
| D | logging.cc | 113 LogMessage::StreamList LogMessage::streams_ GUARDED_BY(g_log_crit);
206 for (auto& kv : streams_) { in ~LogMessage()
244 for (auto& kv : streams_) { in GetLogToStream()
254 streams_.push_back(std::make_pair(stream, min_sev)); in AddLogToStream()
260 for (StreamList::iterator it = streams_.begin(); it != streams_.end(); ++it) { in RemoveLogToStream()
262 streams_.erase(it); in RemoveLogToStream()
333 for (auto& kv : streams_) { in UpdateMinLogSeverity()
|
| D | logging.h | 226 static StreamList 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::__anon708f55650111::GrpcTpuDriver
1030 streams_.clear(); in Reset()
|
| /external/tensorflow/tensorflow/stream_executor/ |
| D | device_memory_allocator.h | 266 std::map<int, Stream> streams_ GUARDED_BY(mutex_);
|
| D | stream_executor_pimpl.cc | 945 if (!streams_.count(device_ordinal)) { in GetStream()
946 auto p = streams_.emplace(std::piecewise_construct, in GetStream()
952 return &streams_.at(device_ordinal); in GetStream()
|
| /external/tensorflow/tensorflow/core/common_runtime/gpu/ |
| D | gpu_device.cc | 245 &streams_[key_type(tf_gpu_id.value(), stream_group_within_gpu)]; in GetOrCreate()
306 std::map<key_type, StreamGroup> streams_; member in tensorflow::BaseGPUDevice::StreamGroupFactory
|