walkero
/
nghttp2
1
0
Fork 0
Code Issues Pull Requests Projects Releases 1 Wiki Activity

nghttpx: Better distribute load to backend h2 servers

This commit is contained in:
Tatsuhiro Tsujikawa 2016-04-02 00:02:48 +09:00
parent c17b3b8517
commit 344541dd89
1 changed files with 8 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/shrpx_client_handler.cc
View File

@ -737,6 +737,8 @@ ClientHandler::get_downstream_connection(Downstream *downstream) {
if (shared_addr->proto == PROTO_HTTP2) { if (shared_addr->proto == PROTO_HTTP2) {
auto &http2_freelist = shared_addr->http2_freelist; auto &http2_freelist = shared_addr->http2_freelist;
Http2Session *http2session;
if (http2_freelist.empty() || if (http2_freelist.empty() ||
http2_freelist.size() < shared_addr->addrs.size()) { http2_freelist.size() < shared_addr->addrs.size()) {
if (LOG_ENABLED(INFO)) { if (LOG_ENABLED(INFO)) {
@ -749,21 +751,22 @@ ClientHandler::get_downstream_connection(Downstream *downstream) {
<< shared_addr->addrs.size(); << shared_addr->addrs.size();
} }
} }
auto session = make_unique<Http2Session>( http2session = new Http2Session(
conn_.loop, shared_addr->tls ? worker_->get_cl_ssl_ctx() : nullptr, conn_.loop, shared_addr->tls ? worker_->get_cl_ssl_ctx() : nullptr,
worker_, &group); worker_, &group);
http2_freelist.append(session.release()); } else {
http2session = http2_freelist.head;
http2_freelist.remove(http2session);
} }
auto http2session = http2_freelist.head;
if (http2session->max_concurrency_reached(1)) { if (http2session->max_concurrency_reached(1)) {
if (LOG_ENABLED(INFO)) { if (LOG_ENABLED(INFO)) {
CLOG(INFO, this) << "Maximum streams are reached for Http2Session(" CLOG(INFO, this) << "Maximum streams are reached for Http2Session("
<< http2session << http2session
<< "). Remove Http2Session from http2_freelist"; << "). Remove Http2Session from http2_freelist";
} }
http2_freelist.remove(http2session); } else {
http2_freelist.append(http2session);
} }
dconn = make_unique<Http2DownstreamConnection>(http2session); dconn = make_unique<Http2DownstreamConnection>(http2session);