core/sm_queue.h
author Kyle Sanderson <kyle.leet@gmail.com>
Mon Aug 12 00:44:22 2013 +0100 (2013-08-12)
changeset 3995 e94dfd569130
parent 2471 194be299b700
permissions -rw-r--r--
Fixed various memory issues. (bug 5766, r=asherkin)
dvander@1098
     1
/**
dvander@1098
     2
 * vim: set ts=4 :
ds@1330
     3
 * =============================================================================
dvander@1231
     4
 * SourceMod
ds@1947
     5
 * Copyright (C) 2004-2008 AlliedModders LLC.  All rights reserved.
ds@1330
     6
 * =============================================================================
dvander@1098
     7
 *
ds@1330
     8
 * This program is free software; you can redistribute it and/or modify it under
ds@1330
     9
 * the terms of the GNU General Public License, version 3.0, as published by the
ds@1330
    10
 * Free Software Foundation.
dvander@1231
    11
 * 
ds@1330
    12
 * This program is distributed in the hope that it will be useful, but WITHOUT
ds@1330
    13
 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
ds@1330
    14
 * FOR A PARTICULAR PURPOSE.  See the GNU General Public License for more
ds@1330
    15
 * details.
dvander@1231
    16
 *
ds@1330
    17
 * You should have received a copy of the GNU General Public License along with
ds@1330
    18
 * this program.  If not, see <http://www.gnu.org/licenses/>.
dvander@1231
    19
 *
ds@1330
    20
 * As a special exception, AlliedModders LLC gives you permission to link the
ds@1330
    21
 * code of this program (as well as its derivative works) to "Half-Life 2," the
ds@1330
    22
 * "Source Engine," the "SourcePawn JIT," and any Game MODs that run on software
ds@1330
    23
 * by the Valve Corporation.  You must obey the GNU General Public License in
ds@1330
    24
 * all respects for all other code used.  Additionally, AlliedModders LLC grants
ds@1330
    25
 * this exception to all derivative works.  AlliedModders LLC defines further
ds@1330
    26
 * exceptions, found in LICENSE.txt (as of this writing, version JULY-31-2007),
ds@1330
    27
 * or <http://www.sourcemod.net/license.php>.
dvander@1098
    28
 *
dvander@1098
    29
 * Version: $Id$
dvander@1098
    30
 */
dvander@1098
    31
dvander@1098
    32
#ifndef _INCLUDE_SM_QUEUE_H
dvander@1098
    33
#define _INCLUDE_SM_QUEUE_H
dvander@1098
    34
dvander@1098
    35
#include <new>
dvander@2471
    36
#include <stdlib.h>
dvander@1098
    37
#include <sh_stack.h>
dvander@1098
    38
dvander@1098
    39
using namespace SourceHook;
dvander@1098
    40
dvander@1098
    41
/*
dvander@1098
    42
	A circular, doubly-linked List with one sentinel node
dvander@1098
    43
dvander@1098
    44
	Empty:
dvander@1098
    45
	m_Head = sentinel
dvander@1098
    46
	m_Head->next = m_Head;
dvander@1098
    47
	m_Head->prev = m_Head;
dvander@1098
    48
	One element:
dvander@1098
    49
	m_Head = sentinel
dvander@1098
    50
	m_Head->next = node1
dvander@1098
    51
	m_Head->prev = node1
dvander@1098
    52
	node1->next = m_Head
dvander@1098
    53
	node1->prev = m_Head
dvander@1098
    54
	Two elements:
dvander@1098
    55
	m_Head = sentinel
dvander@1098
    56
	m_Head->next = node1
dvander@1098
    57
	m_Head->prev = node2
dvander@1098
    58
	node1->next = node2
dvander@1098
    59
	node1->prev = m_Head
dvander@1098
    60
	node2->next = m_Head
dvander@1098
    61
	node2->prev = node1
dvander@1098
    62
*/
dvander@1098
    63
template <class T>
dvander@1098
    64
class Queue
dvander@1098
    65
{
dvander@1098
    66
public:
dvander@1098
    67
	class iterator;
dvander@1098
    68
	friend class iterator;
dvander@1098
    69
	class QueueNode
dvander@1098
    70
	{
dvander@1098
    71
	public:
dvander@1098
    72
		T obj;
dvander@1098
    73
		QueueNode *next;
dvander@1098
    74
		QueueNode *prev;
dvander@1098
    75
	};
dvander@1098
    76
private:
dvander@1098
    77
	// Initializes the sentinel node.
dvander@1098
    78
	QueueNode *_Initialize()
dvander@1098
    79
	{
dvander@1098
    80
		QueueNode *n = (QueueNode *)malloc(sizeof(QueueNode));
dvander@1098
    81
		n->next = n;
dvander@1098
    82
		n->prev = n;
dvander@1098
    83
		return n;
dvander@1098
    84
	}
dvander@1098
    85
public:
dvander@1098
    86
	Queue() : m_Head(_Initialize()), m_Size(0)
dvander@1098
    87
	{
dvander@1098
    88
	}
dvander@1098
    89
dvander@1098
    90
	Queue(const Queue &src) : m_Head(_Initialize()), m_Size(0)
dvander@1098
    91
	{
dvander@1098
    92
		iterator iter;
dvander@1098
    93
		for (iter=src.begin(); iter!=src.end(); iter++)
dvander@1098
    94
		{
dvander@1098
    95
			push_back( (*iter) );
dvander@1098
    96
		}
dvander@1098
    97
	}
dvander@1098
    98
dvander@1098
    99
	~Queue()
dvander@1098
   100
	{
dvander@1098
   101
		clear();
dvander@1098
   102
dvander@1098
   103
		// Don't forget to free the sentinel
dvander@1098
   104
		if (m_Head)
dvander@1098
   105
		{
dvander@1098
   106
			free(m_Head);
dvander@1098
   107
			m_Head = NULL;
dvander@1098
   108
		}
dvander@1098
   109
dvander@1098
   110
		while (!m_FreeNodes.empty())
dvander@1098
   111
		{
dvander@1098
   112
			free(m_FreeNodes.front());
dvander@1098
   113
			m_FreeNodes.pop();
dvander@1098
   114
		}
dvander@1098
   115
	}
dvander@1098
   116
dvander@1098
   117
	void push(const T &obj)
dvander@1098
   118
	{
dvander@1098
   119
		QueueNode *node;
dvander@1098
   120
		
dvander@1098
   121
		if (m_FreeNodes.empty())
dvander@1098
   122
		{
dvander@1098
   123
			node = (QueueNode *)malloc(sizeof(QueueNode));
dvander@1098
   124
		} else {
dvander@1098
   125
			node = m_FreeNodes.front();
dvander@1098
   126
			m_FreeNodes.pop();
dvander@1098
   127
		}
dvander@1098
   128
dvander@1098
   129
		/* Copy the object */
dvander@1098
   130
		new (&node->obj) T(obj);
dvander@1098
   131
dvander@1098
   132
		/* Install into the Queue */
dvander@1098
   133
		node->prev = m_Head->prev;
dvander@1098
   134
		node->next = m_Head;
dvander@1098
   135
		m_Head->prev->next = node;
dvander@1098
   136
		m_Head->prev = node;
dvander@1098
   137
dvander@1098
   138
		m_Size++;
dvander@1098
   139
	}
dvander@1098
   140
dvander@1098
   141
	size_t size() const
dvander@1098
   142
	{
dvander@1098
   143
		return m_Size;
dvander@1098
   144
	}
dvander@1098
   145
dvander@1098
   146
	void clear()
dvander@1098
   147
	{
dvander@1098
   148
		QueueNode *node = m_Head->next;
dvander@1098
   149
		QueueNode *temp;
dvander@1098
   150
		m_Head->next = m_Head;
dvander@1098
   151
		m_Head->prev = m_Head;
dvander@1098
   152
dvander@1098
   153
		// Iterate through the nodes until we find g_Head (the sentinel) again
dvander@1098
   154
		while (node != m_Head)
dvander@1098
   155
		{
dvander@1098
   156
			temp = node->next;
dvander@1098
   157
			node->obj.~T();
dvander@1098
   158
			m_FreeNodes.push(node);
dvander@1098
   159
			node = temp;
dvander@1098
   160
		}
dvander@1098
   161
		m_Size = 0;
dvander@1098
   162
	}
dvander@1098
   163
dvander@1098
   164
	bool empty() const
dvander@1098
   165
	{
dvander@1098
   166
		return (m_Size == 0);
dvander@1098
   167
	}
dvander@1098
   168
dvander@1098
   169
private:
dvander@1098
   170
	QueueNode *m_Head;
dvander@1098
   171
	size_t m_Size;
dvander@1098
   172
	CStack<QueueNode *> m_FreeNodes;
dvander@1098
   173
public:
dvander@1098
   174
	class iterator
dvander@1098
   175
	{
dvander@1098
   176
		friend class Queue;
dvander@1098
   177
	public:
dvander@1098
   178
		iterator()
dvander@1098
   179
		{
dvander@1098
   180
			m_This = NULL;
dvander@1098
   181
		}
dvander@1098
   182
		iterator(const Queue &src)
dvander@1098
   183
		{
dvander@1098
   184
			m_This = src.m_Head;
dvander@1098
   185
		}
dvander@1098
   186
		iterator(QueueNode *n) : m_This(n)
dvander@1098
   187
		{
dvander@1098
   188
		}
dvander@1098
   189
		iterator(const iterator &where)
dvander@1098
   190
		{
dvander@1098
   191
			m_This = where.m_This;
dvander@1098
   192
		}
dvander@1098
   193
		//pre decrement
dvander@1098
   194
		iterator & operator--()
dvander@1098
   195
		{
dvander@1098
   196
			if (m_This)
dvander@1098
   197
				m_This = m_This->prev;
dvander@1098
   198
			return *this;
dvander@1098
   199
		}
dvander@1098
   200
		//post decrement
dvander@1098
   201
		iterator operator--(int)
dvander@1098
   202
		{
dvander@1098
   203
			iterator old(*this);
dvander@1098
   204
			if (m_This)
dvander@1098
   205
				m_This = m_This->prev;
dvander@1098
   206
			return old;
dvander@1098
   207
		}	
dvander@1098
   208
dvander@1098
   209
		//pre increment
dvander@1098
   210
		iterator & operator++()
dvander@1098
   211
		{
dvander@1098
   212
			if (m_This)
dvander@1098
   213
				m_This = m_This->next;
dvander@1098
   214
			return *this;
dvander@1098
   215
		}
dvander@1098
   216
		//post increment
dvander@1098
   217
		iterator operator++(int)
dvander@1098
   218
		{
dvander@1098
   219
			iterator old(*this);
dvander@1098
   220
			if (m_This)
dvander@1098
   221
				m_This = m_This->next;
dvander@1098
   222
			return old;
dvander@1098
   223
		}
dvander@1098
   224
dvander@1098
   225
		const T & operator * () const
dvander@1098
   226
		{
dvander@1098
   227
			return m_This->obj;
dvander@1098
   228
		}
dvander@1098
   229
		T & operator * ()
dvander@1098
   230
		{
dvander@1098
   231
			return m_This->obj;
dvander@1098
   232
		}
dvander@1098
   233
dvander@1098
   234
		T * operator -> ()
dvander@1098
   235
		{
dvander@1098
   236
			return &(m_This->obj);
dvander@1098
   237
		}
dvander@1098
   238
		const T * operator -> () const
dvander@1098
   239
		{
dvander@1098
   240
			return &(m_This->obj);
dvander@1098
   241
		}
dvander@1098
   242
dvander@1098
   243
		bool operator != (const iterator &where) const
dvander@1098
   244
		{
dvander@1098
   245
			return (m_This != where.m_This);
dvander@1098
   246
		}
dvander@1098
   247
		bool operator ==(const iterator &where) const
dvander@1098
   248
		{
dvander@1098
   249
			return (m_This == where.m_This);
dvander@1098
   250
		}
dvander@1098
   251
	private:
dvander@1098
   252
		QueueNode *m_This;
dvander@1098
   253
	};
dvander@1098
   254
public:
dvander@1098
   255
	iterator begin() const
dvander@1098
   256
	{
dvander@1098
   257
		return iterator(m_Head->next);
dvander@1098
   258
	}
dvander@1098
   259
dvander@1098
   260
	iterator end() const
dvander@1098
   261
	{
dvander@1098
   262
		return iterator(m_Head);
dvander@1098
   263
	}
dvander@1098
   264
dvander@1098
   265
	iterator erase(iterator &where)
dvander@1098
   266
	{
dvander@1098
   267
		QueueNode *pNode = where.m_This;
dvander@1098
   268
		iterator iter(where);
dvander@1098
   269
		iter++;
dvander@1098
   270
dvander@1098
   271
dvander@1098
   272
		// Works for all cases: empty Queue, erasing first element, erasing tail, erasing in the middle...
dvander@1098
   273
		pNode->prev->next = pNode->next;
dvander@1098
   274
		pNode->next->prev = pNode->prev;
dvander@1098
   275
dvander@1098
   276
		pNode->obj.~T();
dvander@1098
   277
		m_FreeNodes.push(pNode);
dvander@1098
   278
		m_Size--;
dvander@1098
   279
dvander@1098
   280
		return iter;
dvander@1098
   281
	}
dvander@1098
   282
public:
dvander@1098
   283
	void remove(const T & obj)
dvander@1098
   284
	{
dvander@1098
   285
		iterator b;
dvander@1098
   286
		for (b=begin(); b!=end(); b++)
dvander@1098
   287
		{
dvander@1098
   288
			if ( (*b) == obj )
dvander@1098
   289
			{
dvander@1098
   290
				erase( b );
dvander@1098
   291
				break;
dvander@1098
   292
			}
dvander@1098
   293
		}
dvander@1098
   294
	}
dvander@1098
   295
	template <typename U>
dvander@1098
   296
	iterator find(const U & equ) const
dvander@1098
   297
	{
dvander@1098
   298
		iterator iter;
dvander@1098
   299
		for (iter=begin(); iter!=end(); iter++)
dvander@1098
   300
		{
dvander@1098
   301
			if ( (*iter) == equ )
dvander@1098
   302
			{
dvander@1098
   303
				return iter;
dvander@1098
   304
			}
dvander@1098
   305
		}
dvander@1098
   306
		return end();
dvander@1098
   307
	}
dvander@1098
   308
	Queue & operator =(const Queue &src)
dvander@1098
   309
	{
dvander@1098
   310
		clear();
dvander@1098
   311
		iterator iter;
dvander@1098
   312
		for (iter=src.begin(); iter!=src.end(); iter++)
dvander@1098
   313
		{
dvander@1098
   314
			push_back( (*iter) );
dvander@1098
   315
		}
dvander@1098
   316
		return *this;
dvander@1098
   317
	}
dvander@1098
   318
public:
dvander@1098
   319
	T & first() const
dvander@1098
   320
	{
dvander@1098
   321
		iterator i = begin();
dvander@1098
   322
dvander@1098
   323
		return (*i);
dvander@1098
   324
	}
dvander@1098
   325
dvander@1098
   326
	void pop()
dvander@1098
   327
	{
dvander@1099
   328
		iterator iter = begin();
dvander@1099
   329
		erase(iter);
dvander@1098
   330
	}
dvander@1098
   331
};
dvander@1098
   332
dvander@1098
   333
#endif //_INCLUDE_SM_QUEUE_H