Remove HttpConnectionState::response_queue_mutex
This commit is contained in:
@@ -68,8 +68,6 @@ void HttpHandler::on_preprocess_writes(
|
|||||||
|
|
||||||
// Process incoming responses and add to reorder queue
|
// Process incoming responses and add to reorder queue
|
||||||
{
|
{
|
||||||
std::lock_guard lock(state->response_queue_mutex);
|
|
||||||
|
|
||||||
for (auto &pending : pending_responses) {
|
for (auto &pending : pending_responses) {
|
||||||
auto *ctx = static_cast<HttpResponseContext *>(pending.protocol_context);
|
auto *ctx = static_cast<HttpResponseContext *>(pending.protocol_context);
|
||||||
|
|
||||||
|
|||||||
@@ -92,7 +92,6 @@ struct HttpConnectionState {
|
|||||||
std::deque<HttpRequestState> queue;
|
std::deque<HttpRequestState> queue;
|
||||||
|
|
||||||
// Response ordering for HTTP pipelining
|
// Response ordering for HTTP pipelining
|
||||||
std::mutex response_queue_mutex;
|
|
||||||
std::map<int64_t, ResponseData>
|
std::map<int64_t, ResponseData>
|
||||||
ready_responses; // sequence_id -> response data
|
ready_responses; // sequence_id -> response data
|
||||||
int64_t next_sequence_to_send = 0;
|
int64_t next_sequence_to_send = 0;
|
||||||
|
|||||||
Reference in New Issue
Block a user