/external/tensorflow/tensorflow/compiler/xla/service/ |
stream_pool.cc | 27 if (!streams_.empty()) { 29 stream = std::move(streams_.back()); 30 streams_.pop_back(); 60 streams_.emplace_back(stream);
|
execution_tracker.cc | 32 streams_(std::move(streams)), 35 for (const auto& stream : streams_) { 41 for (auto& stream : streams_) {
|
stream_pool.h | 59 std::vector<std::unique_ptr<se::Stream>> streams_ GUARDED_BY(mu_);
|
execution_tracker.h | 57 std::vector<StreamPool::Ptr> streams_; member in class:xla::AsyncExecution
|
/external/tensorflow/tensorflow/core/kernels/boosted_trees/quantiles/ |
quantile_stream_resource.h | 40 streams_.reserve(num_streams_); 43 streams_.push_back(QuantileStream(epsilon, max_elements)); 52 QuantileStream* stream(const int64 index) { return &streams_[index]; } 77 std::vector<QuantileStream> streams_; member in class:tensorflow::BoostedTreesQuantileStreamResource 79 // Stores the boundaries. Same size as streams_.
|
/external/webrtc/webrtc/call/ |
bitrate_estimator_tests.cc | 107 virtual ~BitrateEstimatorTest() { EXPECT_TRUE(streams_.empty()); } 143 std::for_each(streams_.begin(), streams_.end(), 149 while (!streams_.empty()) { 150 delete streams_.back(); 151 streams_.pop_back(); 259 std::vector<Stream*> streams_; member in class:webrtc::BitrateEstimatorTest 272 streams_.push_back(new Stream(this, false)); 283 streams_.push_back(new Stream(this, true)); 294 streams_.push_back(new Stream(this, false)) [all...] |
/external/protobuf/src/google/protobuf/io/ |
zero_copy_stream_impl.cc | 354 : streams_(streams), stream_count_(count), bytes_retired_(0) { 362 if (streams_[0]->Next(data, size)) return true; 365 bytes_retired_ += streams_[0]->ByteCount(); 366 ++streams_; 376 streams_[0]->BackUp(count); 386 int64 target_byte_count = streams_[0]->ByteCount() + count; 387 if (streams_[0]->Skip(count)) return true; 391 int64 final_byte_count = streams_[0]->ByteCount(); 397 ++streams_; 408 return bytes_retired_ + streams_[0]->ByteCount() [all...] |
zero_copy_stream_impl.h | 319 // As streams are retired, streams_ is incremented and count_ is 321 ZeroCopyInputStream* const* streams_; member in class:google::protobuf::io::ConcatenatingInputStream
|
/external/webrtc/talk/session/media/ |
mediasession.h | 242 return streams_; 247 return streams_; 250 streams_.push_back(stream); 254 streams_.push_back(StreamParams::CreateLegacy(ssrc)); 259 streams_.push_back(sp); 264 for (cricket::StreamParamsVec::iterator it = streams_.begin(); 265 it != streams_.end(); ++it) { 271 if (streams_.empty()) { 274 return streams_[0].first_ssrc(); 277 if (streams_.empty()) 304 StreamParamsVec streams_; member in class:cricket::MediaContentDescription [all...] |
/external/webrtc/webrtc/voice_engine/test/auto_test/fakes/ |
conference_transport.cc | 89 while (!streams_.empty()) { 90 auto stream = streams_.begin(); 124 auto it = streams_.find(sender_ssrc); 125 if (it != streams_.end()) { 249 streams_[remote_ssrc] = std::make_pair(new_sender, new_receiver); 256 auto it = streams_.find(id); 257 if (it == streams_.end()) { 266 streams_.erase(it);
|
conference_transport.h | 139 std::map<unsigned int, std::pair<int, int>> streams_
|
/external/webrtc/webrtc/modules/remote_bitrate_estimator/ |
remote_bitrate_estimator_unittest_helper.cc | 121 for (StreamMap::iterator it = streams_.begin(); it != streams_.end(); 125 streams_.clear(); 130 streams_[stream->ssrc()] = stream; 142 ASSERT_GE(streams_.size(), 0u); 144 for (StreamMap::iterator it = streams_.begin(); it != streams_.end(); ++it) { 149 for (StreamMap::iterator it = streams_.begin(); it != streams_.end(); ++it) { 163 streams_[ssrc]->set_rtp_timestamp_offset(offset) [all...] |
remote_bitrate_estimator_unittest_helper.h | 140 StreamMap streams_; member in class:webrtc::testing::StreamGenerator
|
/external/webrtc/webrtc/base/ |
logging.cc | 105 // Global lock for log subsystem, only needed to serialize access to streams_. 113 LogMessage::StreamList LogMessage::streams_ GUARDED_BY(g_log_crit); 206 for (auto& kv : streams_) { 244 for (auto& kv : streams_) { 254 streams_.push_back(std::make_pair(stream, min_sev)); 260 for (StreamList::iterator it = streams_.begin(); it != streams_.end(); ++it) { 262 streams_.erase(it); 333 for (auto& kv : streams_) {
|
logging.h | 226 static StreamList streams_; member in class:rtc::LogMessage
|
/external/webrtc/talk/media/sctp/ |
sctpdataengine_unittest.cc | 172 void OnStreamClosed(uint32_t stream) { streams_.push_back(stream); } 175 return std::count(streams_.begin(), streams_.end(), stream); 179 return std::find(streams_.begin(), streams_.end(), stream) 180 != streams_.end(); 184 std::vector<uint32_t> streams_; member in class:SignalChannelClosedObserver 199 streams_.push_back(stream); 203 return std::count(streams_.begin(), streams_.end(), stream) 209 std::vector<int> streams_; member in class:SignalChannelClosedReopener [all...] |
/external/tensorflow/tensorflow/core/common_runtime/gpu/ |
gpu_device.cc | 243 &streams_[key_type(tf_gpu_id.value(), stream_group_within_gpu)]; 290 std::map<key_type, StreamGroup> streams_; 345 DCHECK(streams_[i]); 388 streams_.push_back(StreamGroupFactory::Global().GetOrCreate( 391 i, streams_.back()->compute, streams_.back()->host_to_device, 392 streams_.back()->device_to_host, streams_.back()->device_to_device)); 395 gpu_device_info_->stream = streams_[0]->compute; 451 return streams_.size() > 1 [all...] |
gpu_device.h | 146 gtl::InlinedVector<StreamGroup*, 4> streams_; member in class:tensorflow::BaseGPUDevice
|