bahman/scylla
1
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

transport: respond with overloaded exception during shedding

Browse Source 
This commit makes shedding always respond - with overloaded exception,
instead of ignoring the request.

Fixes #9442

Closes #9443
This commit is contained in:
Piotr Sarna
2021-10-06 16:44:44 +02:00
committed by Avi Kivity
parent d1505762df
commit 59bd25d1ea
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
transport/server.cc
View File

@@ -581,7 +581,11 @@ future<> cql_server::connection::process_request() {
const bool allow_shedding = _client_state.get_workload_type() == service::client_state::workload_type::interactive;
if (allow_shedding && _shed_incoming_requests) {
++_server._stats.requests_shed;
return _read_buf.skip(f.length);
return _read_buf.skip(f.length).then([this, stream = f.stream] {
write_response(make_error(stream, exceptions::exception_code::OVERLOADED,
"request shed due to coordinator overload", tracing::trace_state_ptr()));
return make_ready_future<>();
});
}
tracing_request_type tracing_requested = tracing_request_type::not_requested;