Home
last modified time | relevance | path

Searched refs:streams_ (Results 1 - 8 of 8) sorted by relevance

/third_party/protobuf/src/google/protobuf/io/
H A Dzero_copy_stream_impl.cc315 : streams_(streams), stream_count_(count), bytes_retired_(0) { in ConcatenatingInputStream()
320 if (streams_[0]->Next(data, size)) return true; in Next()
323 bytes_retired_ += streams_[0]->ByteCount(); in Next()
324 ++streams_; in Next()
334 streams_[0]->BackUp(count); in BackUp()
344 int64 target_byte_count = streams_[0]->ByteCount() + count; in Skip()
345 if (streams_[0]->Skip(count)) return true; in Skip()
349 int64 final_byte_count = streams_[0]->ByteCount(); in Skip()
355 ++streams_; in Skip()
366 return bytes_retired_ + streams_[ in ByteCount()
[all...]
H A Dzero_copy_stream_impl.h321 // As streams are retired, streams_ is incremented and count_ is
323 ZeroCopyInputStream* const* streams_; member in google::protobuf::io::ConcatenatingInputStream
/third_party/nghttp2/src/
H A Dshrpx_http2_session.h263 DList<StreamData> streams_; member in shrpx::Http2Session
H A Dshrpx_http2_session.cc296 auto streams = std::move(streams_); in disconnect()
749 streams_.remove(sd); in remove_stream_data()
773 streams_.append(sd.release()); in submit_request()
2250 streams_.append(promised_sd.release()); in handle_downstream_push_promise()
/third_party/node/src/
H A Dnode_http2.cc533 for (const auto& [id, stream] : streams_) { in ~Http2Session()
536 streams_.clear(); in ~Http2Session()
544 tracker->TrackField("streams", streams_); in MemoryInfo()
736 auto s = streams_.find(id); in FindStream()
737 return s != streams_.end() ? s->second : BaseObjectPtr<Http2Stream>(); in FindStream()
745 std::min(streams_.max_size(), static_cast<size_t>(maxConcurrentStreams)); in CanAddStream()
748 return streams_.size() < maxSize && in CanAddStream()
754 streams_[stream->id()] = BaseObjectPtr<Http2Stream>(stream); in AddStream()
755 size_t size = streams_.size(); in AddStream()
764 if (streams_ in RemoveStream()
[all...]
H A Dnode_http2.h892 std::unordered_map<int32_t, BaseObjectPtr<Http2Stream>> streams_; member in node::http2::Http2Session
/third_party/skia/third_party/externals/swiftshader/include/vulkan/
H A Dvulkan_structs.hpp26913 streams_, global() member in VULKAN_HPP_NAMESPACE::GeneratedCommandsInfoNV::VULKAN_HPP_NAMESPACE
[all...]
/third_party/vulkan-headers/include/vulkan/
H A Dvulkan_structs.hpp38843 VULKAN_HPP_NAMESPACE::ArrayProxyNoTemporaries<const VULKAN_HPP_NAMESPACE::IndirectCommandsStreamNV> const & streams_, global() member in GeneratedCommandsInfoNV::VULKAN_HPP_NAMESPACE
[all...]

Completed in 105 milliseconds