diff options
author | Shauren <shauren.trinity@gmail.com> | 2016-02-22 20:02:26 +0100 |
---|---|---|
committer | Shauren <shauren.trinity@gmail.com> | 2016-03-12 23:49:39 +0100 |
commit | 9fc5c4bc41b2738836ce99eb42ddbb88fb398884 (patch) | |
tree | 06fe8a150475127098250f0ec3f9a3518f069c1c /src/common/Threading/LockedQueue.h | |
parent | 67aa8cabce360e42fa1cd4a4d425ed4f655d0d34 (diff) |
Core/PacketIO: Requeue packets handled with STATUS_LOGGEDIN received before player is fully loaded in one step after packet processing loop - reduces used locks from 3 per packet to 1 per packet
(cherry picked from commit 8086a39210659c44d52fb463f5a39f047aa45685)
Diffstat (limited to 'src/common/Threading/LockedQueue.h')
-rw-r--r-- | src/common/Threading/LockedQueue.h | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/src/common/Threading/LockedQueue.h b/src/common/Threading/LockedQueue.h index c6faaaf81ca..21a29d7e53b 100644 --- a/src/common/Threading/LockedQueue.h +++ b/src/common/Threading/LockedQueue.h @@ -57,6 +57,14 @@ public: unlock(); } + //! Adds items back to front of the queue + template<class Iterator> + void readd(Iterator begin, Iterator end) + { + std::lock_guard<std::mutex> lock(_lock); + _queue.insert(_queue.begin(), begin, end); + } + //! Gets the next result in the queue, if any. bool next(T& result) { |