osg::DgramQueue Class Reference
[Network]

Stream socket connection.

#include <OSGDgramQueue.h>

List of all members.

Public Types
typedef std::list< Dgram * >	QueueT
Public Member Functions
Constructors
	DgramQueue ()
Destructor
virtual	~DgramQueue ()
data put,get
void	put (Dgram *dgram)
Dgram *	get (Lock *lock)
bool	empty (void)
void	wait (Lock *lock)
bool	waiting (void)
Protected Attributes
member
Barrier *	_barrier
QueueT	_queue
bool	_waiting
Private Member Functions
	DgramQueue (const DgramQueue &source)
	prohibit default function (move to 'public' if needed)
void	operator= (const DgramQueue &source)

---

Detailed Description

Definition at line 60 of file OSGDgramQueue.h.

---

Member Typedef Documentation

typedef std::list<Dgram*> osg::DgramQueue::QueueT

Definition at line 65 of file OSGDgramQueue.h.

---

Constructor & Destructor Documentation

DgramQueue::DgramQueue

(

)

Constructor size must be 2^x

Definition at line 67 of file OSGDgramQueue.cpp.

References _barrier, and osg::Barrier::get().

                      :
    _queue(),
    _waiting(false)
{
    char barrierName[256];
    sprintf(barrierName,"DgramQueue%p",this);

    // create barrier
    _barrier = Barrier::get(barrierName);
}

DgramQueue::~DgramQueue

(

)

[virtual]

Destructor

Definition at line 80 of file OSGDgramQueue.cpp.

{
}

osg::DgramQueue::DgramQueue

(

const DgramQueue &

source

)

[private]

---

Member Function Documentation

void DgramQueue::put

(

Dgram *

dgram

)

put a dgram to the queue.

Definition at line 89 of file OSGDgramQueue.cpp.

References _barrier, _queue, _waiting, and osg::Barrier::enter().

Referenced by osg::GroupMCastConnection::GroupMCastConnection(), osg::PointMCastConnection::PointMCastConnection(), osg::PointMCastConnection::read(), osg::PointMCastConnection::readBuffer(), osg::PointMCastConnection::recvQueue(), osg::GroupMCastConnection::sendQueue(), osg::GroupMCastConnection::write(), and osg::GroupMCastConnection::~GroupMCastConnection().

{
    _queue.push_back(dgram);
    if(_waiting)
    {
        _waiting = false;
        _barrier->enter(2);
    }
}

Dgram * DgramQueue::get

(

Lock *

lock

)

get a dgram from the queue. Block if queue is empty

Definition at line 101 of file OSGDgramQueue.cpp.

References _barrier, _queue, _waiting, osg::Lock::aquire(), osg::Barrier::enter(), and osg::Lock::release().

Referenced by osg::PointMCastConnection::read(), osg::PointMCastConnection::readBuffer(), osg::PointMCastConnection::recvQueue(), osg::GroupMCastConnection::sendQueue(), osg::GroupMCastConnection::write(), osg::GroupMCastConnection::~GroupMCastConnection(), and osg::PointMCastConnection::~PointMCastConnection().

{
    Dgram *result;

    if(_queue.empty())
    {
        _waiting = true;
        lock->release();
        _barrier->enter(2);
        lock->aquire();
    }
    result = _queue.front();
    _queue.pop_front();

    return result;
}

bool DgramQueue::empty

(

void

)

put a dgram to the queue.

Definition at line 138 of file OSGDgramQueue.cpp.

References _queue.

Referenced by osg::PointMCastConnection::readBuffer(), osg::PointMCastConnection::selectChannel(), osg::GroupMCastConnection::sendQueue(), osg::GroupMCastConnection::~GroupMCastConnection(), and osg::PointMCastConnection::~PointMCastConnection().

{
    return _queue.empty();
}

void DgramQueue::wait

(

Lock *

lock

)

wait for a dgram but dont read

Definition at line 120 of file OSGDgramQueue.cpp.

References _barrier, _queue, _waiting, osg::Lock::aquire(), osg::Barrier::enter(), and osg::Lock::release().

Referenced by osg::PointMCastConnection::selectChannel().

{
    if(_queue.empty())
    {
        _waiting = true;
        lock->release();
        _barrier->enter(2);
        lock->aquire();
    }
}

bool DgramQueue::waiting

(

void

)

true, if reader is waiting

Definition at line 133 of file OSGDgramQueue.cpp.

References _waiting.

Referenced by osg::GroupMCastConnection::write().

{
    return _waiting;
}

void osg::DgramQueue::operator=

(

const DgramQueue &

source

)

[private]

---

Member Data Documentation

Barrier* osg::DgramQueue::_barrier [protected]

Definition at line 99 of file OSGDgramQueue.h.

Referenced by DgramQueue(), get(), put(), and wait().

QueueT osg::DgramQueue::_queue [protected]

Definition at line 100 of file OSGDgramQueue.h.

Referenced by empty(), get(), put(), and wait().

bool osg::DgramQueue::_waiting [protected]

Definition at line 101 of file OSGDgramQueue.h.

Referenced by get(), put(), wait(), and waiting().

---

The documentation for this class was generated from the following files:

• OSGDgramQueue.h
• OSGDgramQueue.cpp