Lines Matching refs:pipeline
46 HttpPipelinedConnection* pipeline = factory_->CreateNewPipeline(
50 pipelines_.insert(std::make_pair(pipeline, info));
51 return pipeline->CreateNewStream();
84 void HttpPipelinedHostImpl::OnPipelineEmpty(HttpPipelinedConnection* pipeline) {
85 CHECK(ContainsKey(pipelines_, pipeline));
86 pipelines_.erase(pipeline);
87 delete pipeline;
95 HttpPipelinedConnection* pipeline) {
96 CHECK(ContainsKey(pipelines_, pipeline));
97 if (CanPipelineAcceptRequests(pipeline)) {
100 if (!pipeline->depth()) {
101 OnPipelineEmpty(pipeline);
107 HttpPipelinedConnection* pipeline,
109 CHECK(ContainsKey(pipelines_, pipeline));
112 ++pipelines_[pipeline].num_successes;
117 pipelines_[pipeline].num_successes >=
127 if (pipelines_[pipeline].num_successes > 0 || pipeline->depth() > 1) {
130 // otherwise able to pipeline just fine. Consider being more persistent
164 CHECK(false) << "Unkown pipeline capability: " << capability_;
170 HttpPipelinedConnection* pipeline) const {
172 pipeline->usable() &&
173 pipeline->active() &&
174 pipeline->depth() < GetPipelineCapacity();
