diff options
Diffstat (limited to '')
| -rw-r--r-- | src/output/HttpdClient.cxx | 19 |
1 files changed, 14 insertions, 5 deletions
diff --git a/src/output/HttpdClient.cxx b/src/output/HttpdClient.cxx index 121f36e41..d16f78942 100644 --- a/src/output/HttpdClient.cxx +++ b/src/output/HttpdClient.cxx @@ -212,10 +212,19 @@ HttpdClient::ClearQueue() { assert(state == RESPONSE); - for (auto page : pages) + while (!pages.empty()) { + Page *page = pages.front(); + pages.pop(); + +#ifndef NDEBUG + assert(queue_size >= page->size); + queue_size -= page->size; +#endif + page->Unref(); - pages.clear(); - queue_size = 0; + } + + assert(queue_size == 0); } void @@ -273,7 +282,7 @@ HttpdClient::TryWrite() } current_page = pages.front(); - pages.pop_front(); + pages.pop(); current_position = 0; assert(queue_size >= current_page->size); @@ -379,7 +388,7 @@ HttpdClient::PushPage(Page *page) return; page->Ref(); - pages.push_back(page); + pages.push(page); queue_size += page->size; ScheduleWrite(); |