#include "recvqueue.h"

RecvQueue::~RecvQueue()
{
	while (!pktList.isEmpty())
		delete pktList.get();
}

void RecvQueue::addPkt(NetPkt* pkt)
{
	if (pkt != NULL) {
		pktList.add(pkt);
		pktCount.post();
	}
}

NetPkt* RecvQueue::getPkt()
{
	pktCount.wait();
	return pktList.get();
}