1/*
2 * Copyright (c) 2004-2007 Marcus Overhagen <marcus@overhagen.de>
3 *
4 * Permission is hereby granted, free of charge, to any person
5 * obtaining a copy of this software and associated documentation
6 * files (the "Software"), to deal in the Software without restriction,
7 * including without limitation the rights to use, copy, modify,
8 * merge, publish, distribute, sublicense, and/or sell copies of
9 * the Software, and to permit persons to whom the Software is
10 * furnished to do so, subject to the following conditions:
11 *
12 * The above copyright notice and this permission notice shall be
13 * included in all copies or substantial portions of the Software.
14 *
15 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
16 * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES
17 * OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
18 * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT
19 * HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY,
20 * WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
21 * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR
22 * OTHER DEALINGS IN THE SOFTWARE.
23 */
24
25#ifndef __PACKET_QUEUE_H
26#define __PACKET_QUEUE_H
27
28#include <OS.h>
29
30class Packet;
31
32class PacketQueue
33{
34public:
35					PacketQueue(int max_packets = 5);
36					~PacketQueue();
37
38	status_t		Insert(Packet *packet);
39	status_t		Remove(Packet **packet);
40
41	// peeks into queue and delivers a copy
42	status_t		Peek(Packet **packet);
43
44	void			Flush(bigtime_t timeout);
45
46	void			Terminate();
47	void			Restart();
48
49private:
50	void			Empty();
51
52					// not implemented
53					PacketQueue(const PacketQueue & clone);
54					PacketQueue & operator=(PacketQueue & clone);
55
56private:
57
58	Packet			**fQueue;
59	sem_id			fSem;
60	volatile bool	fTerminate;
61
62	int				fWriteIndex;
63	int				fReadIndex;
64	int				fMaxPackets;
65	int32			fPacketCount;
66};
67
68
69#endif
70