Home
last modified time | relevance | path

Searched refs:stream_ (Results 1 – 25 of 130) sorted by relevance

123456

/third_party/boost/boost/spirit/home/support/detail/lexer/
Ddebug.hpp45 basic_rules<CharT> &rules_, ostream &stream_) in dump() argument
55 lexer_state (stream_); in dump()
56 stream_ << rules_.state (dfa_) << std::endl << std::endl; in dump()
58 dump_ex (iter_, stream_); in dump()
63 ostream &stream_) in dump() argument
73 lexer_state (stream_); in dump()
74 stream_ << dfa_ << std::endl << std::endl; in dump()
76 dump_ex (iter_, stream_); in dump()
84 ostream &stream_) in dump_ex() argument
90 state (stream_); in dump_ex()
[all …]
/third_party/skia/third_party/externals/sfntly/cpp/src/sfntly/data/
Dfont_input_stream.cc24 : stream_(is), position_(0), length_(0), bounded_(false) { in FontInputStream()
28 : stream_(is), position_(0), length_(length), bounded_(true) { in FontInputStream()
38 if (stream_) in Length()
39 return stream_->Length(); in Length()
44 if (stream_) in Available()
45 return stream_->Available(); in Available()
50 if (stream_) { in Close()
51 stream_->Close(); in Close()
56 if (stream_) { in Mark()
57 stream_->Mark(readlimit); in Mark()
[all …]
Dfont_output_stream.cc24 : stream_(os), in FontOutputStream()
33 if (stream_) { in Write()
34 stream_->Write(b); in Write()
48 assert(stream_); in Write()
58 stream_->Write(b, off, len); in Write()
64 assert(stream_); in Write()
73 stream_->Write(b, off, len); in Write()
117 if (stream_) { in Flush()
118 stream_->Flush(); in Flush()
123 if (stream_) { in Close()
[all …]
/third_party/flutter/skia/third_party/externals/sfntly/cpp/src/sfntly/data/
Dfont_input_stream.cc24 : stream_(is), position_(0), length_(0), bounded_(false) { in FontInputStream()
28 : stream_(is), position_(0), length_(length), bounded_(true) { in FontInputStream()
38 if (stream_) in Length()
39 return stream_->Length(); in Length()
44 if (stream_) in Available()
45 return stream_->Available(); in Available()
50 if (stream_) { in Close()
51 stream_->Close(); in Close()
56 if (stream_) { in Mark()
57 stream_->Mark(readlimit); in Mark()
[all …]
Dfont_output_stream.cc24 : stream_(os), in FontOutputStream()
33 if (stream_) { in Write()
34 stream_->Write(b); in Write()
48 assert(stream_); in Write()
58 stream_->Write(b, off, len); in Write()
64 assert(stream_); in Write()
73 stream_->Write(b, off, len); in Write()
117 if (stream_) { in Flush()
118 stream_->Flush(); in Flush()
123 if (stream_) { in Close()
[all …]
/third_party/protobuf/src/google/protobuf/util/internal/
Dprotostream_objectsource.cc119 : stream_(stream), in ProtoStreamObjectSource()
139 : stream_(stream), in ProtoStreamObjectSource()
201 uint32 tag = stream_->ReadTag(), last_tag = tag + 1; in WriteMessage()
226 WireFormat::SkipField(stream_, tag, in WriteMessage()
228 tag = stream_->ReadTag(); in WriteMessage()
243 tag = stream_->ReadTag(); in WriteMessage()
266 tag_to_return = stream_->ReadTag(); in RenderList()
270 } while ((tag_to_return = stream_->ReadTag()) == list_tag); in RenderList()
285 stream_->ReadVarint32(&buffer32); // message length in RenderMap()
286 int old_limit = stream_->PushLimit(buffer32); in RenderMap()
[all …]
Djson_objectwriter.h94 stream_(out), in JsonObjectWriter()
171 explicit ByteSinkWrapper(io::CodedOutputStream* stream) : stream_(stream) {} in ByteSinkWrapper()
176 stream_->WriteRaw(bytes, n); in Append()
180 io::CodedOutputStream* stream_;
223 out = stream_->GetDirectBufferForNBytesAndAdvance(len); in NewLine()
233 stream_->WriteRaw(indent_string_.c_str(), indent_string_.length()); in NewLine()
245 void WriteChar(const char c) { stream_->WriteRaw(&c, sizeof(c)); } in WriteChar()
249 stream_->WriteRaw(s.data(), s.length()); in WriteRawString()
253 io::CodedOutputStream* stream_; variable
/third_party/skia/third_party/externals/swiftshader/third_party/SPIRV-Tools/source/
Ddisassemble.cpp60 stream_(out_.get()), in Disassembler()
126 std::ostream& stream_; // The output std::stream. member in __anon0168c9c60111::Disassembler
144 stream_ << "; SPIR-V\n" in HandleHeader()
150 stream_ << "(" << SPV_GENERATOR_TOOL_PART(generator) << ")"; in HandleHeader()
154 stream_ << "; " << SPV_GENERATOR_MISC_PART(generator) << "\n" in HandleHeader()
168 stream_ << std::endl; in HandleInstruction()
169 stream_ << std::string(indent_, ' '); in HandleInstruction()
170 stream_ << "; Function " << name_mapper_(inst.result_id) << std::endl; in HandleInstruction()
175 stream_ << std::endl; in HandleInstruction()
176 stream_ << std::string(indent_, ' '); in HandleInstruction()
[all …]
/third_party/skia/third_party/externals/spirv-tools/source/
Ddisassemble.cpp60 stream_(out_.get()), in Disassembler()
126 std::ostream& stream_; // The output std::stream. member in __anone289c25a0111::Disassembler
144 stream_ << "; SPIR-V\n" in HandleHeader()
150 stream_ << "(" << SPV_GENERATOR_TOOL_PART(generator) << ")"; in HandleHeader()
154 stream_ << "; " << SPV_GENERATOR_MISC_PART(generator) << "\n" in HandleHeader()
168 stream_ << std::endl; in HandleInstruction()
169 stream_ << std::string(indent_, ' '); in HandleInstruction()
170 stream_ << "; Function " << name_mapper_(inst.result_id) << std::endl; in HandleInstruction()
175 stream_ << std::endl; in HandleInstruction()
176 stream_ << std::string(indent_, ' '); in HandleInstruction()
[all …]
/third_party/boost/boost/convert/
Dstream.hpp73 basic_stream() : stream_(std::ios_base::in | std::ios_base::out) {} in basic_stream()
75 basic_stream(this_type&& other) : stream_(std::move(other.stream_)) {} in basic_stream()
86 this_type& operator() (manipulator m) { return (stream_ << m, *this); } in operator ()()
87 this_type& operator() (manipulator_type m) { return (m(stream_), *this); } in operator ()()
88 this_type& operator() (std::locale const& l) { return (stream_.imbue(l), *this); } in operator ()()
90 …BOOST_CNV_PARAM(locale, std::locale) { return (stream_.imbue(arg[cnv::parameter::locale]), *this);… in BOOST_CNV_PARAM()
91 …BOOST_CNV_PARAM(precision, int) { return (stream_.precision(arg[cnv::parameter::precision]), … in BOOST_CNV_PARAM()
92 …BOOST_CNV_PARAM(width, int) { return (stream_.width(arg[cnv::parameter::width]), *this); } in BOOST_CNV_PARAM()
93 … BOOST_CNV_PARAM(fill, char) { return (stream_.fill(arg[cnv::parameter::fill]), *this); } in BOOST_CNV_PARAM()
97 uppercase ? (void) stream_.setf(std::ios::uppercase) : stream_.unsetf(std::ios::uppercase); in BOOST_CNV_PARAM()
[all …]
/third_party/flutter/skia/third_party/externals/spirv-tools/source/
Ddisassemble.cpp55 stream_(out_.get()), in Disassembler()
120 std::ostream& stream_; // The output std::stream. member in __anonc75e990f0111::Disassembler
136 stream_ << "; SPIR-V\n" in HandleHeader()
142 stream_ << "(" << SPV_GENERATOR_TOOL_PART(generator) << ")"; in HandleHeader()
146 stream_ << "; " << SPV_GENERATOR_MISC_PART(generator) << "\n" in HandleHeader()
163 stream_ << std::setw(std::max(0, indent_ - 3 - int(id_name.size()))); in HandleInstruction()
164 stream_ << "%" << id_name; in HandleInstruction()
166 stream_ << " = "; in HandleInstruction()
168 stream_ << std::string(indent_, ' '); in HandleInstruction()
171 stream_ << "Op" << spvOpcodeString(static_cast<SpvOp>(inst.opcode)); in HandleInstruction()
[all …]
/third_party/flutter/engine/flutter/fml/
Dlogging.cc53 stream_ << "["; in LogMessage()
55 stream_ << GetNameForLogSeverity(severity); in LogMessage()
57 stream_ << "VERBOSE" << -severity; in LogMessage()
58 stream_ << ":" << (severity > LOG_INFO ? StripDots(file_) : StripPath(file_)) in LogMessage()
62 stream_ << "Check failed: " << condition << ". "; in LogMessage()
66 stream_ << std::endl; in ~LogMessage()
83 HiLogPrint(LOG_CORE, priority, 0xD003900, "flutter", "%{public}s", stream_.str().c_str()); in ~LogMessage()
101 __android_log_write(priority, "flutter", stream_.str().c_str()); in ~LogMessage()
103 syslog(LOG_ALERT, "%s", stream_.str().c_str()); in ~LogMessage()
105 std::cerr << stream_.str(); in ~LogMessage()
/third_party/grpc/test/cpp/qps/
Dclient_sync.cc149 stream_(num_threads_), in SynchronousStreamingClient()
159 stream_[thread_idx]->Finish().IgnoreError(); in ~SynchronousStreamingClient()
165 std::vector<std::unique_ptr<StreamType>> stream_; member in grpc::testing::SynchronousStreamingClient
178 Status s = stream_[thread_idx]->Finish(); in FinishStream()
200 if (stream_[i]) { in CleanupAllStreams()
226 [this](size_t thread_idx) { stream_[thread_idx]->WritesDone(); }); in ~SynchronousStreamingPingPongClient()
234 stream_[thread_idx] = stub->StreamingCall(&context_[thread_idx]); in InitThreadFuncImpl()
248 if (stream_[thread_idx]->Write(request_) && in ThreadFuncImpl()
249 stream_[thread_idx]->Read(&responses_[thread_idx])) { in ThreadFuncImpl()
261 stream_[thread_idx]->WritesDone(); in ThreadFuncImpl()
[all …]
Dserver_async.cc317 stream_(srv_ctx_.get()) { in ServerRpcContextStreamingImpl()
318 request_method_(srv_ctx_.get(), &stream_, AsyncQpsServerTest::tag(this)); in ServerRpcContextStreamingImpl()
325 stream_ = grpc::ServerAsyncReaderWriter<ResponseType, RequestType>( in Reset()
330 request_method_(srv_ctx_.get(), &stream_, AsyncQpsServerTest::tag(this)); in Reset()
339 stream_.Read(&req_, AsyncQpsServerTest::tag(this)); in request_done()
350 stream_.Write(response_, AsyncQpsServerTest::tag(this)); in read_done()
354 stream_.Finish(Status::OK, AsyncQpsServerTest::tag(this)); in read_done()
362 stream_.Read(&req_, AsyncQpsServerTest::tag(this)); in write_done()
365 stream_.Finish(Status::OK, AsyncQpsServerTest::tag(this)); in write_done()
380 grpc::ServerAsyncReaderWriter<ResponseType, RequestType> stream_; member in grpc::testing::AsyncQpsServerTest::ServerRpcContextStreamingImpl
[all …]
/third_party/boost/libs/beast/example/http/client/async-ssl/
Dhttp_client_async_ssl.cpp48 beast::ssl_stream<beast::tcp_stream> stream_; member in session
59 , stream_(ex, ctx) in session()
72 if(! SSL_set_tlsext_host_name(stream_.native_handle(), host)) in run()
104 beast::get_lowest_layer(stream_).expires_after(std::chrono::seconds(30)); in on_resolve()
107 beast::get_lowest_layer(stream_).async_connect( in on_resolve()
121 stream_.async_handshake( in on_connect()
135 beast::get_lowest_layer(stream_).expires_after(std::chrono::seconds(30)); in on_handshake()
138 http::async_write(stream_, req_, in on_handshake()
155 http::async_read(stream_, buffer_, res_, in on_write()
175 beast::get_lowest_layer(stream_).expires_after(std::chrono::seconds(30)); in on_read()
[all …]
/third_party/boost/libs/iostreams/src/
Dbzip2.cpp80 : params_(params), stream_(new bz_stream), ready_(false) in bzip2_base()
83 bzip2_base::~bzip2_base() { delete static_cast<bz_stream*>(stream_); } in ~bzip2_base()
88 bz_stream* s = static_cast<bz_stream*>(stream_); in before()
97 bz_stream* s = static_cast<bz_stream*>(stream_); in after()
104 bz_stream* s = static_cast<bz_stream*>(stream_); in check_end()
118 bz_stream* s = static_cast<bz_stream*>(stream_); in end()
131 return BZ2_bzCompress(static_cast<bz_stream*>(stream_), action); in compress()
136 return BZ2_bzDecompress(static_cast<bz_stream*>(stream_)); in decompress()
145 bz_stream* s = static_cast<bz_stream*>(stream_); in do_init()
Dlzma.cpp85 : stream_(new lzma_stream), level_(lzma::default_compression), threads_(1) in lzma_base()
88 lzma_base::~lzma_base() { delete static_cast<lzma_stream*>(stream_); } in ~lzma_base()
93 lzma_stream* s = static_cast<lzma_stream*>(stream_); in before()
102 lzma_stream* s = static_cast<lzma_stream*>(stream_); in after()
109 return lzma_code(static_cast<lzma_stream*>(stream_), static_cast<lzma_action>(action)); in deflate()
114 return lzma_code(static_cast<lzma_stream*>(stream_), static_cast<lzma_action>(action)); in inflate()
119 lzma_stream* s = static_cast<lzma_stream*>(stream_); in reset()
147 lzma_stream* s = static_cast<lzma_stream*>(stream_); in init_stream()
Dzlib.cpp94 : stream_(new z_stream), calculate_crc_(false), crc_(0), crc_imp_(0), in zlib_base()
98 zlib_base::~zlib_base() { delete static_cast<z_stream*>(stream_); } in ~zlib_base()
103 z_stream* s = static_cast<z_stream*>(stream_); in before()
112 z_stream* s = static_cast<z_stream*>(stream_); in after()
134 return ::deflate(static_cast<z_stream*>(stream_), flush); in xdeflate()
139 return ::inflate(static_cast<z_stream*>(stream_), flush); in xinflate()
144 z_stream* s = static_cast<z_stream*>(stream_); in reset()
162 z_stream* s = static_cast<z_stream*>(stream_); in do_init()
/third_party/gn/src/base/
Dlogging.cc150 stream_ << "Check failed: " << condition << ". "; in LogMessage()
156 stream_ << "Check failed: " << *result; in LogMessage()
166 stream_ << "Check failed: " << *result; in LogMessage()
172 stream_ << std::endl; // Newline to separate from log message. in ~LogMessage()
174 stream_ << std::endl; in ~LogMessage()
175 std::string str_newline(stream_.str()); in ~LogMessage()
197 stream_ << '['; in Init()
198 stream_ << std::this_thread::get_id() << ':'; in Init()
202 stream_ << std::setfill('0') << std::setw(2) << local_time.wMonth in Init()
214 stream_ << std::setfill('0') << std::setw(2) << 1 + tm_time->tm_mon in Init()
[all …]
/third_party/boost/libs/beast/example/http/client/async-ssl-system-executor/
Dhttp_client_async_ssl_system_executor.cpp49 beast::ssl_stream<beast::tcp_stream> stream_; member in session
58 , stream_(strand, ctx) in session()
80 if(! SSL_set_tlsext_host_name(stream_.native_handle(), host)) in run()
112 beast::get_lowest_layer(stream_).expires_after(std::chrono::seconds(30)); in on_resolve()
115 beast::get_lowest_layer(stream_).async_connect( in on_resolve()
129 stream_.async_handshake( in on_connect()
143 beast::get_lowest_layer(stream_).expires_after(std::chrono::seconds(30)); in on_handshake()
146 http::async_write(stream_, req_, in on_handshake()
163 http::async_read(stream_, buffer_, res_, in on_write()
183 beast::get_lowest_layer(stream_).expires_after(std::chrono::seconds(30)); in on_read()
[all …]
/third_party/boost/libs/beast/example/http/client/async/
Dhttp_client_async.cpp44 beast::tcp_stream stream_; member in session
55 , stream_(net::make_strand(ioc)) in session()
92 stream_.expires_after(std::chrono::seconds(30)); in on_resolve()
95 stream_.async_connect( in on_resolve()
109 stream_.expires_after(std::chrono::seconds(30)); in on_connect()
112 http::async_write(stream_, req_, in on_connect()
129 http::async_read(stream_, buffer_, res_, in on_write()
149 stream_.socket().shutdown(tcp::socket::shutdown_both, ec); in on_read()
/third_party/boost/libs/beast/example/http/server/flex/
Dhttp_server_flex.cpp374 beast::tcp_stream stream_; member in plain_session
385 , stream_(std::move(socket)) in plain_session()
393 return stream_; in stream()
404 net::dispatch(stream_.get_executor(), in run()
415 stream_.socket().shutdown(tcp::socket::shutdown_send, ec); in do_eof()
426 beast::ssl_stream<beast::tcp_stream> stream_; member in ssl_session
438 , stream_(std::move(socket), ctx) in ssl_session()
446 return stream_; in stream()
456 net::dispatch(stream_.get_executor(), [self]() { in run()
458 beast::get_lowest_layer(self->stream_).expires_after( in run()
[all …]
/third_party/cef/libcef_dll/wrapper/
Dcef_stream_resource_handler.cc19 stream_(stream) { in CefStreamResourceHandler()
33 stream_(stream) { in CefStreamResourceHandler()
60 response_length = stream_ ? -1 : 0; in GetResponseHeaders()
70 DCHECK(stream_); in Read()
78 stream_->Read(static_cast<char*>(data_out) + bytes_read, 1, in Read()
/third_party/boost/boost/asio/impl/
Dread_until.hpp791 : stream_(stream), in read_until_delim_op_v1()
802 : stream_(other.stream_), in read_until_delim_op_v1()
812 : stream_(other.stream_), in read_until_delim_op_v1()
879 stream_.async_read_some(buffers_.prepare(bytes_to_read), in operator ()()
901 AsyncReadStream& stream_; member in boost::asio::detail::read_until_delim_op_v1
985 : stream_(stream) in initiate_async_read_until_delim_v1()
991 return stream_.get_executor(); in get_executor()
1007 stream_, BOOST_ASIO_MOVE_CAST(DynamicBuffer_v1)(buffers), in operator ()()
1012 AsyncReadStream& stream_; member in boost::asio::detail::initiate_async_read_until_delim_v1
1087 : stream_(stream), in read_until_delim_string_op_v1()
[all …]
/third_party/boost/libs/beast/test/doc/
Dcore_4_layers.cpp96 counted_stream& stream_; in operator ()() member
102 , stream_(stream) in operator ()()
105 stream_.next_layer().async_read_some(buffers, std::move(*this)); in operator ()()
111 stream_.bytes_read_ += bytes_transferred; in operator ()()
142 counted_stream& stream_; in operator ()() member
148 , stream_(stream) in operator ()()
151 stream_.next_layer().async_write_some(buffers, std::move(*this)); in operator ()()
157 stream_.bytes_written_ += bytes_transferred; in operator ()()

123456