Skip to content
Browse files

an item is open as soon as the pop begins

  • Loading branch information...
1 parent eb4041b commit 06e3e1d89ba04eab851e5fde74712b8c195bc545 @erikfrey erikfrey committed
Showing with 2 additions and 2 deletions.
  1. +2 −2 src/queue/queue.cpp
View
4 src/queue/queue.cpp
@@ -150,6 +150,8 @@ bool queue::pop_begin(id_type& result)
else
return false;
+ ++items_open_;
+
return true;
}
@@ -170,8 +172,6 @@ void queue::pop_read(std::string& result_item, header_type& result_header, id_ty
throw system::system_error(system::errc::io_error,
boost::asio::error::get_system_category()); // anything else is bad data
}
-
- ++items_open_;
}
void queue::pop_end(bool erase, id_type id, const header_type& header)

0 comments on commit 06e3e1d

Please sign in to comment.
Something went wrong with that request. Please try again.