CoolVLViewer/indra/llmessage/llcorehttpretryqueue.h

/**
 * @file llcorehttpretryqueue.h
 * @brief Internal declaration for the operation retry queue
 *
 * $LicenseInfo:firstyear=2012&license=viewerlgpl$
 * Second Life Viewer Source Code
 * Copyright (C) 2012, Linden Research, Inc.
 *
 * This library is free software; you can redistribute it and/or
 * modify it under the terms of the GNU Lesser General Public
 * License as published by the Free Software Foundation;
 * version 2.1 of the License only.
 *
 * This library is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 * Lesser General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public
 * License along with this library; if not, write to the Free Software
 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301  USA
 *
 * Linden Research, Inc., 945 Battery Street, San Francisco, CA  94111  USA
 * $/LicenseInfo$
 */

#ifndef	_LLCORE_HTTP_RETRY_QUEUE_H_
#define	_LLCORE_HTTP_RETRY_QUEUE_H_

#include <queue>

#include "llcorehttpoprequest.h"

namespace LLCore
{

// HttpRetryQueue provides a simple priority queue for HttpOpRequest objects.
//
// This uses the priority_queue adaptor class to provide the queue as well as
// the ordering scheme while allowing us access to the raw container if we
// follow a few simple rules. One of the more important of those rules is that
// any iterator becomes invalid on element erasure. So pay attention.
//
// Threading: not thread-safe. Expected to be used entirely by a single thread,
// typically a worker thread of some sort.

struct HttpOpRetryCompare
{
	LL_INLINE bool operator()(const HttpOpRequest::ptr_t& lhs,
							  const HttpOpRequest::ptr_t& rhs)
	{
		return lhs->mPolicyRetryAt < rhs->mPolicyRetryAt;
	}
};

typedef std::priority_queue<HttpOpRequest::ptr_t,
							std::deque<HttpOpRequest::ptr_t>,
							LLCore::HttpOpRetryCompare> HttpRetryQueueBase;

class HttpRetryQueue final : public HttpRetryQueueBase
{
public:
	HttpRetryQueue() = default;
	HttpRetryQueue(const HttpRetryQueue&) = delete;
	void operator=(const HttpRetryQueue&) = delete;

	LL_INLINE const container_type& get_container() const	{ return c; }
	LL_INLINE container_type& get_container()				{ return c; }
};

}  // End namespace LLCore

#endif	// _LLCORE_HTTP_RETRY_QUEUE_H_