Home
last modified time | relevance | path

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

123

/external/chromium/net/spdy/
Dspdy_http_stream.cc29 stream_(NULL), in SpdyHttpStream()
41 stream_ = spdy_stream; in InitializeWithExistingStream()
42 stream_->SetDelegate(this); in InitializeWithExistingStream()
47 if (stream_) in ~SpdyHttpStream()
48 stream_->DetachDelegate(); in ~SpdyHttpStream()
54 DCHECK(!stream_.get()); in InitializeStream()
60 int error = spdy_session_->GetPushStream(request_info_->url, &stream_, in InitializeStream()
66 if (stream_.get()) in InitializeStream()
70 request_info_->priority, &stream_, in InitializeStream()
87 CHECK(!stream_->cancelled()); in ReadResponseHeaders()
[all …]
/external/antlr/antlr-3.4/tool/src/main/resources/org/antlr/codegen/templates/C/
DAST.stg80 :{it | pANTLR3_REWRITE_RULE_<rewriteElementType>_STREAM stream_<it>;}; separator="\n">
82 :{it | pANTLR3_REWRITE_RULE_SUBTREE_STREAM stream_<it>;}; separator="\n">
97 :{it | stream_<it> = NULL;
98 #define CREATE_stream_<it> if (stream_<it> == NULL) {stream_<it> = antlr3RewriteRule<rewriteElemen…
100 :{it | stream_<it> = NULL;
101 #define CREATE_stream_<it> if (stream_<it> == NULL) {stream_<it> = antlr3RewriteRuleSubtreeStreamN…
143 …s.(actionScope).synpredgate> ) { <endif>CREATE_stream_<token>; stream_<token>->add(stream_<token>,…
157 …ns.(actionScope).synpredgate> ) {<endif>CREATE_stream_<token>; stream_<token>->add(stream_<token>,…
167 …ionScope).synpredgate> ) { <endif>CREATE_stream_<rule.name>; stream_<rule.name>->add(stream_<rule.…
179 …ionScope).synpredgate> ) { <endif>CREATE_stream_<rule.name>; stream_<rule.name>->add(stream_<rule.…
[all …]
/external/antlr/antlr-3.4/tool/src/main/resources/org/antlr/codegen/templates/Ruby/
DAST.stg26 …:{int |stream_<it> = ANTLR3::AST::RewriteRule<rewriteElementType>Stream.new( @adaptor, "token <it>…
28 …:{int |stream_<it> = ANTLR3::AST::RewriteRuleSubtreeStream.new( @adaptor, "rule <it>" )}; separato…
41 <gatedAction({stream_<token>.add( <label; format="label"> )})>
51 <gatedAction({stream_<token>.add( <label; format="label"> )})>
61 <gatedAction({stream_<rule.name>.add( <label; format="label">.tree )})>
70 <gatedAction({stream_<rule.name>.add( <label; format="label">.tree )})>
130 {it | stream_<it> = <rewriteElementType; format="snakecase">_stream( "token <it>", <it; format="lab…
133 {it | stream_<it> = <rewriteElementType; format="snakecase">_stream( "token <it>", list_of_<it; for…
136 {it | stream_<it> = subtree_stream( "wildcard <it>", <it; format="label"> )};
139 {it | stream_<it> = subtree_stream( "wildcard <it>", list_of_<it; format="label"> )};
[all …]
/external/chromium/net/http/
Dhttp_network_transaction.cc120 if (stream_.get()) { in ~HttpNetworkTransaction()
127 stream_->CanFindEndOfResponse() && in ~HttpNetworkTransaction()
130 stream_->Close(true /* not reusable */); in ~HttpNetworkTransaction()
132 if (stream_->IsResponseBodyComplete()) { in ~HttpNetworkTransaction()
134 stream_->Close(false /* reusable */); in ~HttpNetworkTransaction()
135 } else if (stream_->IsSpdyHttpStream()) { in ~HttpNetworkTransaction()
137 stream_->Close(true /* not reusable */); in ~HttpNetworkTransaction()
146 new HttpResponseBodyDrainer(stream_.release()); in ~HttpNetworkTransaction()
174 DCHECK(!stream_.get()); in RestartIgnoringLastError()
192 DCHECK(!stream_.get()); in RestartWithCertificate()
[all …]
Dhttp_response_body_drainer.cc17 : stream_(stream), in HttpResponseBodyDrainer()
72 return stream_->ReadResponseBody( in DoDrainResponseBody()
87 if (stream_->IsResponseBodyComplete()) in DoDrainResponseBodyComplete()
117 stream_->Close(true /* no keep-alive */); in Finish()
120 stream_->Close(false /* keep-alive */); in Finish()
/external/chromium/third_party/libjingle/source/talk/base/
Dsocketpool.cc166 : factory_(factory), stream_(NULL), checked_out_(false) { in ReuseSocketPool()
171 delete stream_; in ~ReuseSocketPool()
178 if (!stream_) { in RequestConnectedStream()
187 stream_ = new SocketStream(socket); in RequestConnectedStream()
189 if ((stream_->GetState() == SS_OPEN) && (remote == remote_)) { in RequestConnectedStream()
193 stream_->Close(); in RequestConnectedStream()
194 if ((stream_->GetSocket()->Connect(remote_) != 0) in RequestConnectedStream()
195 && !stream_->GetSocket()->IsBlocking()) { in RequestConnectedStream()
197 *err = stream_->GetSocket()->GetError(); in RequestConnectedStream()
203 stream_->SignalEvent.disconnect(this); in RequestConnectedStream()
[all …]
Dstream.h250 return stream_->GetState(); in GetState()
254 return stream_->Read(buffer, buffer_len, read, error); in Read()
258 return stream_->Write(data, data_len, written, error); in Write()
261 stream_->Close(); in Close()
292 return stream_->SetPosition(position); in SetPosition()
295 return stream_->GetPosition(position); in GetPosition()
298 return stream_->GetSize(size); in GetSize()
301 return stream_->GetAvailable(size); in GetAvailable()
304 return stream_->GetWriteRemaining(size); in GetWriteRemaining()
307 return stream_->ReserveSize(size); in ReserveSize()
[all …]
/external/chromium/googleurl/base/
Dlogging.cc236 stream_ << "Check failed: " << (*result.str_); in LogMessage()
256 stream_ << '['; in Init()
258 stream_ << GetCurrentProcessId() << ':'; in Init()
260 stream_ << GetCurrentThreadId() << ':'; in Init()
265 stream_ << std::setfill('0') in Init()
275 stream_ << GetTickCount() << ':'; in Init()
276 stream_ << log_severity_names[severity_] << ":" << file << "(" << line << ")] "; in Init()
278 message_start_ = stream_.pcount(); in Init()
285 std::string str_newline(stream_.str(), stream_.pcount()); in ~LogMessage()
340 log_assert_handler(std::string(stream_.str(), stream_.pcount())); in ~LogMessage()
[all …]
/external/marisa-trie/lib/marisa/
Dreader.cc15 : file_(NULL), fd_(-1), stream_(NULL), needs_fclose_(false) {} in Reader()
18 : file_(file), fd_(-1), stream_(NULL), needs_fclose_(false) {} in Reader()
21 : file_(NULL), fd_(fd), stream_(NULL), needs_fclose_(false) {} in Reader()
24 : file_(NULL), fd_(-1), stream_(stream), needs_fclose_(false) {} in Reader()
60 Swap(&stream_, &rhs->stream_); in swap()
82 } else if (stream_ != NULL) { in read_data()
83 if (!stream_->read(static_cast<char *>(buf), size)) { in read_data()
Dwriter.cc15 : file_(NULL), fd_(-1), stream_(NULL), needs_fclose_(false) {} in Writer()
18 : file_(file), fd_(-1), stream_(NULL), needs_fclose_(false) {} in Writer()
21 : file_(NULL), fd_(fd), stream_(NULL), needs_fclose_(false) {} in Writer()
24 : file_(NULL), fd_(-1), stream_(stream), needs_fclose_(false) {} in Writer()
72 Swap(&stream_, &rhs->stream_); in swap()
94 } else if (stream_ != NULL) { in write_data()
95 if (!stream_->write(static_cast<const char *>(data), size)) { in write_data()
/external/marisa-trie/v0_1_5/lib/marisa_alpha/
Dreader.cc15 : file_(NULL), fd_(-1), stream_(NULL), needs_fclose_(false) {} in Reader()
18 : file_(file), fd_(-1), stream_(NULL), needs_fclose_(false) {} in Reader()
21 : file_(NULL), fd_(fd), stream_(NULL), needs_fclose_(false) {} in Reader()
24 : file_(NULL), fd_(-1), stream_(stream), needs_fclose_(false) {} in Reader()
60 Swap(&stream_, &rhs->stream_); in swap()
82 } else if (stream_ != NULL) { in read_data()
84 if (!stream_->read(static_cast<char *>(buf), size)) { in read_data()
Dwriter.cc15 : file_(NULL), fd_(-1), stream_(NULL), needs_fclose_(false) {} in Writer()
18 : file_(file), fd_(-1), stream_(NULL), needs_fclose_(false) {} in Writer()
21 : file_(NULL), fd_(fd), stream_(NULL), needs_fclose_(false) {} in Writer()
24 : file_(NULL), fd_(-1), stream_(stream), needs_fclose_(false) {} in Writer()
72 Swap(&stream_, &rhs->stream_); in swap()
94 } else if (stream_ != NULL) { in write_data()
96 if (!stream_->write(static_cast<const char *>(data), size)) { in write_data()
/external/antlr/antlr-3.4/tool/src/main/resources/org/antlr/codegen/templates/Java/
DAST.stg70 …:{it | RewriteRule<rewriteElementType>Stream stream_<it>=new RewriteRule<rewriteElementType>Stream…
72 …:{it | RewriteRuleSubtreeStream stream_<it>=new RewriteRuleSubtreeStream(adaptor,"rule <it>");}; s…
95 <if(backtracking)>if ( <actions.(actionScope).synpredgate> ) <endif>stream_<token>.add(<label>);<\n>
109 <if(backtracking)>if ( <actions.(actionScope).synpredgate> ) <endif>stream_<token>.add(<label>);<\n>
121 <if(backtracking)>if ( <actions.(actionScope).synpredgate> ) <endif>stream_<rule.name>.add(<label>.…
133 <if(backtracking)>if ( <actions.(actionScope).synpredgate> ) <endif>stream_<rule>.add(<label>.getTr…
195 …:{it | RewriteRule<rewriteElementType>Stream stream_<it>=new RewriteRule<rewriteElementType>Stream…
199 …:{it | RewriteRule<rewriteElementType>Stream stream_<it>=new RewriteRule<rewriteElementType>Stream…
203 …:{it | RewriteRuleSubtreeStream stream_<it>=new RewriteRuleSubtreeStream(adaptor,"wildcard <it>",<…
207 …:{it | RewriteRuleSubtreeStream stream_<it>=new RewriteRuleSubtreeStream(adaptor,"wildcard <it>",l…
[all …]
/external/antlr/antlr-3.4/tool/src/main/resources/org/antlr/codegen/templates/ActionScript/
DAST.stg71 …:{var stream_<it>:RewriteRule<rewriteElementType>Stream=new RewriteRule<rewriteElementType>Stream(…
73 …:{var stream_<it>:RewriteRuleSubtreeStream=new RewriteRuleSubtreeStream(adaptor,"rule <it>");}; se…
96 <if(backtracking)>if ( <actions.(actionScope).synpredgate> ) <endif>stream_<token>.add(<label>);<\n>
110 <if(backtracking)>if ( <actions.(actionScope).synpredgate> ) <endif>stream_<token>.add(<label>);<\n>
122 <if(backtracking)>if ( <actions.(actionScope).synpredgate> ) <endif>stream_<rule.name>.add(<label>.…
134 <if(backtracking)>if ( <actions.(actionScope).synpredgate> ) <endif>stream_<rule>.add(<label>.tree);
195 …:{var stream_<it>:RewriteRule<rewriteElementType>Stream=new RewriteRule<rewriteElementType>Stream(…
199 …:{var stream_<it>:RewriteRule<rewriteElementType>Stream=new RewriteRule<rewriteElementType>Stream(…
203 …:{var stream_<it>:RewriteRuleSubtreeStream=new RewriteRuleSubtreeStream(adaptor,"wildcard <it>",<…
207 …:{var stream_<it>:RewriteRuleSubtreeStream=new RewriteRuleSubtreeStream(adaptor,"wildcard <it>",li…
[all …]
/external/antlr/antlr-3.4/tool/src/main/resources/org/antlr/codegen/templates/JavaScript/
DAST.stg66 …:{var stream_<it>=new org.antlr.runtime.tree.RewriteRuleTokenStream(this.adaptor,"token <it>");}; …
68 …:{var stream_<it>=new org.antlr.runtime.tree.RewriteRuleSubtreeStream(this.adaptor,"rule <it>");};…
91 <if(backtracking)>if ( <actions.(actionScope).synpredgate> ) <endif>stream_<token>.add(<label>);<\n>
105 <if(backtracking)>if ( <actions.(actionScope).synpredgate> ) <endif>stream_<token>.add(<label>);<\n>
121 <if(backtracking)>if ( <actions.(actionScope).synpredgate> ) <endif>stream_<rule.name>.add(<label>.…
133 <if(backtracking)>if ( <actions.(actionScope).synpredgate> ) <endif>stream_<rule>.add(<label>.getTr…
194 …:{var stream_<it>=new org.antlr.runtime.tree.RewriteRule<rewriteElementType>Stream(this.adaptor,"t…
198 …:{var stream_<it>=new org.antlr.runtime.tree.RewriteRule<rewriteElementType>Stream(this.adaptor,"t…
202 …:{var stream_<it>=new org.antlr.runtime.tree.RewriteRuleSubtreeStream(this.adaptor,"wildcard <it>"…
206 …:{var stream_<it>=new org.antlr.runtime.tree.RewriteRuleSubtreeStream(this.adaptor,"wildcard <it>"…
[all …]
/external/antlr/antlr-3.4/tool/src/main/resources/org/antlr/codegen/templates/Python/
DAST.stg86 …:{it | stream_<it> = RewriteRule<rewriteElementType>Stream(self._adaptor, "token <it>")}; separato…
88 :{it | stream_<it> = RewriteRuleSubtreeStream(self._adaptor, "rule <it>")}; separator="\n">
112 <finishedBacktracking({stream_<token>.add(<label>)})>
126 <finishedBacktracking({stream_<token>.add(<label>)})>
138 <finishedBacktracking({stream_<rule.name>.add(<label>.tree)})>
150 <finishedBacktracking({stream_<rule.name>.add(<label>.tree)})>
213 :{it | stream_<it> = RewriteRule<rewriteElementType>Stream(self._adaptor, "token <it>", <it>)};
217 …:{it | stream_<it> = RewriteRule<rewriteElementType>Stream(self._adaptor, "token <it>", list_<it>)…
221 :{it | stream_<it> = RewriteRuleSubtreeStream(self._adaptor, "wildcard <it>", <it>)};
225 :{it | stream_<it> = RewriteRuleSubtreeStream(self._adaptor, "wildcard <it>", list_<it>)};
[all …]
/external/antlr/antlr-3.4/tool/src/main/resources/org/antlr/codegen/templates/CSharp2/
DAST.stg97 …:{it|RewriteRule<rewriteElementType>Stream stream_<it>=new RewriteRule<rewriteElementType>Stream(a…
99 …:{it|RewriteRuleSubtreeStream stream_<it>=new RewriteRuleSubtreeStream(adaptor,"rule <it>");}; sep…
122 <if(backtracking)>if (<actions.(actionScope).synpredgate>) <endif>stream_<token>.Add(<label>);<\n>
136 <if(backtracking)>if (<actions.(actionScope).synpredgate>) <endif>stream_<token>.Add(<label>);
148 <if(backtracking)>if (<actions.(actionScope).synpredgate>) <endif>stream_<rule.name>.Add(<label>.Tr…
160 <if(backtracking)>if (<actions.(actionScope).synpredgate>) <endif>stream_<rule>.Add(<label>.Tree);
217 …:{it|RewriteRule<rewriteElementType>Stream stream_<it>=new RewriteRule<rewriteElementType>Stream(a…
221 …:{it|RewriteRule<rewriteElementType>Stream stream_<it>=new RewriteRule<rewriteElementType>Stream(a…
225 …:{it|RewriteRuleSubtreeStream stream_<it>=new RewriteRuleSubtreeStream(adaptor,"wildcard <it>",<it…
229 …:{it|RewriteRuleSubtreeStream stream_<it>=new RewriteRuleSubtreeStream(adaptor,"wildcard <it>",lis…
[all …]
/external/antlr/antlr-3.4/tool/src/main/resources/org/antlr/codegen/templates/CSharp3/
DAST.stg98 …:{it|<\n>RewriteRule<rewriteElementType>Stream stream_<it>=new RewriteRule<rewriteElementType>Stre…
100 :{it|<\n>RewriteRuleSubtreeStream stream_<it>=new RewriteRuleSubtreeStream(adaptor,"rule <it>");}>
120 <if(backtracking)>if (<actions.(actionScope).synpredgate>) <endif>stream_<token>.Add(<label>);<\n>
134 <if(backtracking)>if (<actions.(actionScope).synpredgate>) <endif>stream_<token>.Add(<label>);
146 <if(backtracking)>if (<actions.(actionScope).synpredgate>) <endif>stream_<rule.name>.Add(<label>.Tr…
158 <if(backtracking)>if (<actions.(actionScope).synpredgate>) <endif>stream_<rule>.Add(<label>.Tree);
215 …:{it|RewriteRule<rewriteElementType>Stream stream_<it>=new RewriteRule<rewriteElementType>Stream(a…
219 …:{it|RewriteRule<rewriteElementType>Stream stream_<it>=new RewriteRule<rewriteElementType>Stream(a…
223 …:{it|RewriteRuleSubtreeStream stream_<it>=new RewriteRuleSubtreeStream(adaptor,"wildcard <it>",<it…
227 …:{it|RewriteRuleSubtreeStream stream_<it>=new RewriteRuleSubtreeStream(adaptor,"wildcard <it>",lis…
[all …]
/external/chromium/third_party/libjingle/source/talk/session/tunnel/
Dpseudotcpchannel.cc105 session_(session), channel_(NULL), tcp_(NULL), stream_(NULL), in PseudoTcpChannel()
117 ASSERT(stream_ == NULL); in ~PseudoTcpChannel()
161 if (!stream_) in GetStream()
162 stream_ = new PseudoTcpChannel::InternalStream(this); in GetStream()
164 return stream_; in GetStream()
179 if ((stream_ != NULL) in OnChannelDestroyed()
198 if (stream_ != NULL) in OnSessionTerminate()
228 ASSERT(stream_ != NULL && stream_thread_->IsCurrent()); in GetState()
249 ASSERT(stream_ != NULL && stream_thread_->IsCurrent()); in Read()
280 ASSERT(stream_ != NULL && stream_thread_->IsCurrent()); in Write()
[all …]
/external/chromium/third_party/libjingle/source/talk/examples/login/
Dxmppsocket.cc66 stream_ = new talk_base::SocketStream(cricket_socket_); in XmppSocket()
69 stream_ = talk_base::SSLStreamAdapter::Create(stream_); in XmppSocket()
71 stream_->SignalEvent.connect(this, &XmppSocket::OnEvent); in XmppSocket()
82 delete stream_; in ~XmppSocket()
147 result = stream_->Write(buffer_.Data(), buffer_.Length(), in OnEvent()
192 talk_base::StreamResult result = stream_->Read(data, len, len_read, NULL); in Read()
204 OnEvent(stream_, talk_base::SE_WRITE, 0); in Write()
221 stream_->Close(); in Close()
239 static_cast<talk_base::SSLStreamAdapter *>(stream_); in StartTls()
/external/antlr/antlr-3.4/tool/src/main/resources/org/antlr/codegen/templates/ObjC/
DAST.stg177 <ruleDescriptor.allTokenRefsInAltsWithRewrites:{it | ANTLRRewriteRuleTokenStream *stream_<it> =
180 <ruleDescriptor.allRuleRefsInAltsWithRewrites:{it | ANTLRRewriteRuleSubtreeStream *stream_<it> =
188 …sInAltsWithRewrites,ruleDescriptor.allRuleRefsInAltsWithRewrites]:{it | [stream_<it> release];}; s…
206 <referencedTokenLabels:{it | [stream_<it> release];}; separator="\n">
207 <referencedTokenListLabels:{it | [stream_<it> release];}; separator="\n">
208 <referencedRuleLabels:{it | [stream_<it> release];}; separator="\n">
209 <referencedRuleListLabels:{it | [stream_<it> release];}; separator="\n">
235 [stream_<token> addElement:<label>];<\n>
252 [stream_<token> addElement:<label>];<\n>
265 [stream_<rule.name> addElement:[<label> getTree]];
[all …]
/external/openfst/src/include/fst/extensions/far/
Dstlist.h61 : stream_( in STListWriter()
65 WriteType(*stream_, kSTListMagicNumber); in STListWriter()
66 WriteType(*stream_, kSTListFileVersion); in STListWriter()
67 if (!stream_) { in STListWriter()
88 WriteType(*stream_, key); in Add()
89 entry_writer_(*stream_, t); in Add()
95 WriteType(*stream_, string()); in ~STListWriter()
96 if (stream_ != &cout) in ~STListWriter()
97 delete stream_; in ~STListWriter() local
102 ostream *stream_; // Output stream variable
/external/chromium/base/
Dlogging.cc545 stream_ << "Check failed: " << *result; in LogMessage()
553 stream_ << "Check failed: " << *result; in LogMessage()
562 stream_ << std::endl; // Newline to separate from log message. in ~LogMessage()
563 trace.OutputToStream(&stream_); in ~LogMessage()
566 stream_ << std::endl; in ~LogMessage()
567 std::string str_newline(stream_.str()); in ~LogMessage()
626 log_assert_handler(std::string(stream_.str())); in ~LogMessage()
634 DisplayDebugMessageInDialog(stream_.str()); in ~LogMessage()
643 log_report_handler(std::string(stream_.str())); in ~LogMessage()
645 DisplayDebugMessageInDialog(stream_.str()); in ~LogMessage()
[all …]
/external/chromium/third_party/libjingle/source/talk/session/phone/
Drtpdump.cc108 res = stream_->ReadAll(header, sizeof(header), NULL, NULL); in ReadPacket()
122 return stream_->ReadAll(&packet->data[0], packet->data.size(), NULL, NULL); in ReadPacket()
128 talk_base::StreamResult res = stream_->ReadLine(&first_line); in ReadFileHeader()
138 res = stream_->ReadAll(header, sizeof(header), NULL, NULL); in ReadFileHeader()
285 : stream_(stream), in RtpDumpWriter()
296 if (!stream_ || !data || 0 == data_len) return talk_base::SR_ERROR; in WritePacket()
313 res = stream_->WriteAll(buf.Data(), buf.Length(), NULL, NULL); in WritePacket()
319 return stream_->WriteAll(data, data_len, NULL, NULL); in WritePacket()
323 talk_base::StreamResult res = stream_->WriteAll( in WriteFileHeader()
333 return stream_->WriteAll(buf.Data(), buf.Length(), NULL, NULL); in WriteFileHeader()
Drtpdump.h90 : stream_(stream), in RtpDumpReader()
102 return stream_->SetPosition(first_line_and_file_header_len_); in RewindToFirstDumpPacket()
109 talk_base::StreamInterface* stream_; variable
185 return stream_ && size && stream_->GetPosition(size); in GetDumpSize()
195 talk_base::StreamInterface* stream_; variable

123