nghttpx: Fix memory leak
This commit is contained in:
parent
7751f4fb3b
commit
ac97c122d4
|
@ -182,27 +182,29 @@ void Worker::replace_downstream_config(
|
||||||
dst_addr.fall = src_addr.fall;
|
dst_addr.fall = src_addr.fall;
|
||||||
dst_addr.rise = src_addr.rise;
|
dst_addr.rise = src_addr.rise;
|
||||||
|
|
||||||
|
auto shared_addr_ptr = shared_addr.get();
|
||||||
|
|
||||||
dst_addr.connect_blocker =
|
dst_addr.connect_blocker =
|
||||||
make_unique<ConnectBlocker>(randgen_, loop_,
|
make_unique<ConnectBlocker>(randgen_, loop_,
|
||||||
[shared_addr, &dst_addr]() {
|
[shared_addr_ptr, &dst_addr]() {
|
||||||
switch (dst_addr.proto) {
|
switch (dst_addr.proto) {
|
||||||
case PROTO_HTTP1:
|
case PROTO_HTTP1:
|
||||||
--shared_addr->http1_pri.weight;
|
--shared_addr_ptr->http1_pri.weight;
|
||||||
break;
|
break;
|
||||||
case PROTO_HTTP2:
|
case PROTO_HTTP2:
|
||||||
--shared_addr->http2_pri.weight;
|
--shared_addr_ptr->http2_pri.weight;
|
||||||
break;
|
break;
|
||||||
default:
|
default:
|
||||||
assert(0);
|
assert(0);
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
[shared_addr, &dst_addr]() {
|
[shared_addr_ptr, &dst_addr]() {
|
||||||
switch (dst_addr.proto) {
|
switch (dst_addr.proto) {
|
||||||
case PROTO_HTTP1:
|
case PROTO_HTTP1:
|
||||||
++shared_addr->http1_pri.weight;
|
++shared_addr_ptr->http1_pri.weight;
|
||||||
break;
|
break;
|
||||||
case PROTO_HTTP2:
|
case PROTO_HTTP2:
|
||||||
++shared_addr->http2_pri.weight;
|
++shared_addr_ptr->http2_pri.weight;
|
||||||
break;
|
break;
|
||||||
default:
|
default:
|
||||||
assert(0);
|
assert(0);
|
||||||
|
|
Loading…
Reference in New Issue