jyapayne/Simple-Web-Server
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Minor cleanup in send_from_queue

Browse source
This commit is contained in:
eidheim 2019-06-03 12:12:33 +02:00
commit 3fcf628657
1 changed files with 23 additions and 21 deletions
Download patch file Download diff file Expand all files Collapse all files

44
server_http.hpp
View file

@ -77,30 +77,32 @@ namespace SimpleWeb {
auto lock = self->session->connection->handler_runner->continue_lock(); auto lock = self->session->connection->handler_runner->continue_lock();
if(!lock) if(!lock)
return; return;
std::unique_lock<std::mutex> send_queue_lock(self->send_queue_mutex); {
if(!ec) { std::unique_lock<std::mutex> lock(self->send_queue_mutex);
auto it = self->send_queue.begin(); if(!ec) {
auto callback = std::move(it->second); auto it = self->send_queue.begin();
self->send_queue.erase(it); auto callback = std::move(it->second);
if(self->send_queue.size() > 0) self->send_queue.erase(it);
self->send_from_queue(); if(self->send_queue.size() > 0)
self->send_from_queue();
send_queue_lock.unlock(); lock.unlock();
if(callback) if(callback)
callback(ec); callback(ec);
}
else {
// All handlers in the queue is called with ec:
std::vector<std::function<void(const error_code &)>> callbacks;
for(auto &pair : self->send_queue) {
if(pair.second)
callbacks.emplace_back(std::move(pair.second));
} }
self->send_queue.clear(); else {
// All handlers in the queue is called with ec:
std::vector<std::function<void(const error_code &)>> callbacks;
for(auto &pair : self->send_queue) {
if(pair.second)
callbacks.emplace_back(std::move(pair.second));
}
self->send_queue.clear();
send_queue_lock.unlock(); lock.unlock();
for(auto &callback : callbacks) for(auto &callback : callbacks)
callback(ec); callback(ec);
}
} }
}); });
} }