diff --git a/source/extensions/common/wasm/context.cc b/source/extensions/common/wasm/context.cc index bba0d9bafe9c..4d393ae91692 100644 --- a/source/extensions/common/wasm/context.cc +++ b/source/extensions/common/wasm/context.cc @@ -724,11 +724,7 @@ BufferInterface* Context::getBuffer(WasmBufferType type) { void Context::onDownstreamConnectionClose(CloseType close_type) { ContextBase::onDownstreamConnectionClose(close_type); downstream_closed_ = true; - // Call close on TCP connection, if upstream connection closed or there was a failure seen in this - // connection. - if (upstream_closed_ || getRequestStreamInfo()->hasAnyResponseFlag()) { - onCloseTCP(); - } + onCloseTCP(); } void Context::onUpstreamConnectionClose(CloseType close_type) { diff --git a/test/integration/BUILD b/test/integration/BUILD index f2f2fa9df554..ee0328b514b4 100644 --- a/test/integration/BUILD +++ b/test/integration/BUILD @@ -965,6 +965,9 @@ envoy_cc_test( "tcp_proxy_integration_test.cc", "tcp_proxy_integration_test.h", ], + tags = [ + "no_tsan", + ], data = [ "//test/config/integration/certs", ],