From 258c69b7628f5a4b90488e147c244a582222b5c8 Mon Sep 17 00:00:00 2001 From: tim <245304590@qq.com> Date: Thu, 16 Jul 2020 07:31:09 +0800 Subject: [PATCH] slice: fix throttle not work --- plugins/experimental/slice/client.cc | 4 ++-- plugins/experimental/slice/server.cc | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/plugins/experimental/slice/client.cc b/plugins/experimental/slice/client.cc index 1ad1b74f2f1..2179ba8a6cf 100644 --- a/plugins/experimental/slice/client.cc +++ b/plugins/experimental/slice/client.cc @@ -156,9 +156,9 @@ handle_client_resp(TSCont contp, TSEvent event, Data *const data) int64_t const output_sent = data->m_bytessent; int64_t const threshout = data->m_config->m_blockbytes; - if (threshout < (output_done - output_sent)) { + if (threshout < (output_sent - output_done)) { start_next_block = false; - DEBUG_LOG("%p handle_client_resp: throttling %" PRId64, data, (output_done - output_sent)); + DEBUG_LOG("%p handle_client_resp: throttling %" PRId64, data, (output_sent - output_done)); } if (start_next_block) { diff --git a/plugins/experimental/slice/server.cc b/plugins/experimental/slice/server.cc index 238a587fe48..272ab7e0e7c 100644 --- a/plugins/experimental/slice/server.cc +++ b/plugins/experimental/slice/server.cc @@ -668,9 +668,9 @@ handle_server_resp(TSCont contp, TSEvent event, Data *const data) int64_t const output_sent = data->m_bytessent; int64_t const threshout = data->m_config->m_blockbytes; - if (threshout < (output_done - output_sent)) { + if (threshout < (output_sent - output_done)) { start_next_block = false; - DEBUG_LOG("%p handle_server_resp: throttling %" PRId64, data, (output_done - output_sent)); + DEBUG_LOG("%p handle_server_resp: throttling %" PRId64, data, (output_sent - output_done)); } }