osg::GroupSockConnection Class Reference
[Network]

#include <OSGGroupSockConnection.h>

Inheritance diagram for osg::GroupSockConnection:

List of all members.

Public Types
public types
typedef Int32	Channel
Public Member Functions
Constructors
	GroupSockConnection (void)
virtual	~GroupSockConnection (void)
type info
virtual const ConnectionType *	getType (void)
connection
virtual Channel	connectPoint (const std::string &address, Time timeout=-1)
virtual void	disconnect (Channel channel)
virtual Channel	acceptPoint (Time timeout=-1)
virtual std::string	bind (const std::string &interf)
params
virtual void	setParams (const std::string &params)
channel handling
virtual Channel	selectChannel (Time timeout=-1) throw (ReadError)
channel handling
UInt32	getChannelCount (void)
void	addSelection (Channel channel)
void	subSelection (Channel channel)
void	clearSelection (void)
void	resetSelection (void)
UInt32	getSelectionCount (void)
group address
void	setDestination (const std::string &destination)
std::string	getDestination (void)
interface
const std::string &	getInterface (void)
void	setInterface (const std::string &interf)
Put
void	put (void const *src, UInt32 size)
void	putAndFree (MemoryHandle src, UInt32 size)
void	putValue (const bool &value)
void	putValue (const UInt8 &value)
void	putValue (const UInt16 &value)
void	putValue (const UInt32 &value)
void	putValue (const UInt64 &value)
void	putValue (const Int8 &value)
void	putValue (const Int16 &value)
void	putValue (const Int32 &value)
void	putValue (const Int64 &value)
void	putValue (const Real16 &value)
void	putValue (const Real32 &value)
void	putValue (const Real64 &value)
void	putValue (const Real128 &value)
void	putValue (const std::string &value)
void	putValues (const bool *value, UInt32 size)
void	putValues (const UInt8 *value, UInt32 size)
void	putValues (const UInt16 *value, UInt32 size)
void	putValues (const UInt32 *value, UInt32 size)
void	putValues (const UInt64 *value, UInt32 size)
void	putValues (const Int8 *value, UInt32 size)
void	putValues (const Int16 *value, UInt32 size)
void	putValues (const Int32 *value, UInt32 size)
void	putValues (const Int64 *value, UInt32 size)
void	putValues (const Real16 *value, UInt32 size)
void	putValues (const Real32 *value, UInt32 size)
void	putValues (const Real64 *value, UInt32 size)
void	putValues (const Real128 *value, UInt32 size)
void	putValues (const std::string *value, UInt32 size)
Get
void	get (void *dst, UInt32 size)
void	getAndAlloc (MemoryHandle &src, UInt32 size)
void	getValue (bool &value)
void	getValue (UInt8 &value)
void	getValue (UInt16 &value)
void	getValue (UInt32 &value)
void	getValue (UInt64 &value)
void	getValue (Int8 &value)
void	getValue (Int16 &value)
void	getValue (Int32 &value)
void	getValue (Int64 &value)
void	getValue (Real16 &value)
void	getValue (Real32 &value)
void	getValue (Real64 &value)
void	getValue (Real128 &value)
void	getValue (std::string &value)
void	getValues (bool *value, UInt32 size)
void	getValues (UInt8 *value, UInt32 size)
void	getValues (UInt16 *value, UInt32 size)
void	getValues (UInt32 *value, UInt32 size)
void	getValues (UInt64 *value, UInt32 size)
void	getValues (Int8 *value, UInt32 size)
void	getValues (Int16 *value, UInt32 size)
void	getValues (Int32 *value, UInt32 size)
void	getValues (Int64 *value, UInt32 size)
void	getValues (Real16 *value, UInt32 size)
void	getValues (Real32 *value, UInt32 size)
void	getValues (Real64 *value, UInt32 size)
void	getValues (Real128 *value, UInt32 size)
void	getValues (std::string *value, UInt32 size)
Helper
virtual void	forceCopy (void)
virtual void	forceDirectIO (void)
void	flush (void)
	write data not yet written
void	setNetworkOrder (bool value)
bool	getNetworkOrder (void)
Static Public Member Functions
create
static GroupConnection *	create (void)
	create conneciton
Protected Types
typedef std::vector< MemoryBlock >	BuffersT
typedef std::list< MemoryHandle >	FreeMemT
protected types
typedef Int32	ChannelIndex
Protected Member Functions
IO Implementation
virtual void	read (MemoryHandle mem, UInt32 size)
virtual void	readBuffer (void)
virtual void	write (MemoryHandle mem, UInt32 size)
virtual void	writeBuffer (void)
synchronisation
virtual bool	wait (Time timeout) throw (ReadError)
virtual void	signal (void) throw (WriteError)
internal channel handling
Channel	newChannelIndex (ChannelIndex index)
void	delChannelIndex (ChannelIndex index)
channel index mapping
ChannelIndex	channelToIndex (Channel channel) const
Channel	indexToChannel (ChannelIndex index) const
Read
BuffersT::iterator	readBufBegin (void)
BuffersT::iterator	readBufEnd (void)
void	readBufAdd (MemoryHandle mem, UInt32 size, UInt32 dataSize=0)
void	readBufClear (void)
Write
BuffersT::iterator	writeBufBegin (void)
BuffersT::iterator	writeBufEnd (void)
void	writeBufAdd (MemoryHandle mem, UInt32 size, UInt32 dataSize=0)
void	writeBufClear (void)
Helper
bool	isReadBufferEmpty (void)
Protected Attributes
members
StreamSocket	_acceptSocket
std::vector< StreamSocket >	_sockets
std::vector< SocketAddress >	_remoteAddresses
ChannelIndex	_readIndex
std::vector< UInt8 >	_socketReadBuffer
std::vector< UInt8 >	_socketWriteBuffer
protected fields
std::vector< UInt8 >	_selection
std::string	_destination
std::set< Channel >	_disconnectedChannel
protected members
std::string	_interface
Member
BuffersT	_readBuffers
BuffersT	_writeBuffers
BuffersT	_zeroCopyBuffers
UInt32	_zeroCopyThreshold
FreeMemT	_freeMem
BuffersT::iterator	_currentReadBuffer
UInt32	_currentReadBufferPos
BuffersT::iterator	_currentWriteBuffer
UInt32	_currentWriteBufferPos
bool	_networkOrder
Private Types
typedef GroupConnection	Inherited
Private Member Functions
	GroupSockConnection (const GroupSockConnection &source)
GroupSockConnection &	operator= (const GroupSockConnection &source)
Static Private Member Functions
internal methods
static bool	connectSocket (StreamSocket &socket, std::string address, SocketAddress &destination, Time timeout)
static bool	acceptSocket (StreamSocket &accept, StreamSocket &from, SocketAddress &destination, Time timeout)
Static Private Attributes
static type
static ConnectionType	_type
Friends
class	PointSockConnection
Classes
struct	SocketBufferHeader

---

Detailed Description

Definition at line 61 of file OSGGroupSockConnection.h.

---

Member Typedef Documentation

typedef GroupConnection osg::GroupSockConnection::Inherited [private]

Reimplemented from osg::GroupConnection.

Reimplemented in osg::GroupMCastConnection, and osg::GroupSockPipeline.

Definition at line 184 of file OSGGroupSockConnection.h.

typedef Int32 osg::GroupConnection::ChannelIndex [protected, inherited]

Definition at line 122 of file OSGGroupConnection.h.

typedef Int32 osg::Connection::Channel [inherited]

Definition at line 69 of file OSGConnection.h.

typedef std::vector<MemoryBlock> osg::BinaryDataHandler::BuffersT [protected, inherited]

Definition at line 213 of file OSGBinaryDataHandler.h.

typedef std::list<MemoryHandle> osg::BinaryDataHandler::FreeMemT [protected, inherited]

Definition at line 214 of file OSGBinaryDataHandler.h.

---

Constructor & Destructor Documentation

GroupSockConnection::GroupSockConnection

(

void

)

Constructor

Definition at line 68 of file OSGGroupSockConnection.cpp.

References _acceptSocket, _socketReadBuffer, _socketWriteBuffer, osg::StreamSocket::open(), osg::BinaryDataHandler::readBufAdd(), osg::Socket::setReusePort(), and osg::BinaryDataHandler::writeBufAdd().

Referenced by create().

                                        :
    GroupConnection(0)
{
    _acceptSocket.open();
    _acceptSocket.setReusePort(true);

    _socketReadBuffer.resize(131071);
    _socketWriteBuffer.resize( _socketReadBuffer.size() );
    // reserve first bytes for buffer size
    readBufAdd (&_socketReadBuffer [sizeof(SocketBufferHeader)],
                _socketReadBuffer.size() -sizeof(SocketBufferHeader));
    writeBufAdd(&_socketWriteBuffer[sizeof(SocketBufferHeader)],
                _socketWriteBuffer.size()-sizeof(SocketBufferHeader));
}

GroupSockConnection::~GroupSockConnection

(

void

)

[virtual]

Destructor

Definition at line 85 of file OSGGroupSockConnection.cpp.

References _acceptSocket, _sockets, and osg::StreamSocket::close().

{
    // close and remove sockets
    while(_sockets.size())
    {
        try
        {
            _sockets.begin()->close();
            _sockets.erase(_sockets.begin());
        }
        catch(...)
        {
        }
    }
    _acceptSocket.close();
}

osg::GroupSockConnection::GroupSockConnection

(

const GroupSockConnection &

source

)

[private]

---

Member Function Documentation

const ConnectionType * GroupSockConnection::getType

(

void

)

[virtual]

get connection type

Implements osg::GroupConnection.

Reimplemented in osg::GroupMCastConnection, and osg::GroupSockPipeline.

Definition at line 104 of file OSGGroupSockConnection.cpp.

References _type.

{
    return &_type;
}

GroupConnection::Channel GroupSockConnection::connectPoint	(	const std::string &	address,
		Time	timeout = -1
	)			[virtual]

connect to the given point. If timeout is reached, -1 is returned

Implements osg::Connection.

Reimplemented in osg::GroupMCastConnection, and osg::GroupSockPipeline.

Definition at line 115 of file OSGGroupSockConnection.cpp.

References _readIndex, _remoteAddresses, _sockets, connectSocket(), and osg::GroupConnection::newChannelIndex().

Referenced by osg::GroupSockPipeline::connectPoint(), and osg::GroupMCastConnection::connectPoint().

{
    Channel channel = -1;
    StreamSocket socket;
    SocketAddress destination;
    if(connectSocket(socket,address,destination,timeout))
    {
        channel = newChannelIndex(_sockets.size());
        _sockets.push_back(socket);
        _remoteAddresses.push_back(destination);
        _readIndex = 0;
    }
    return channel;
}

void GroupSockConnection::disconnect

(

Channel

channel

)

[virtual]

disconnect the given channel

Implements osg::GroupConnection.

Reimplemented in osg::GroupMCastConnection, and osg::GroupSockPipeline.

Definition at line 134 of file OSGGroupSockConnection.cpp.

References _readIndex, _sockets, osg::GroupConnection::channelToIndex(), and osg::GroupConnection::delChannelIndex().

Referenced by osg::GroupSockPipeline::disconnect(), and osg::GroupMCastConnection::disconnect().

{
    ChannelIndex index = channelToIndex(channel);
    try
    {
        _sockets[index].close();
    }
    catch(...)
    {
    }
    _sockets.erase(_sockets.begin() + index);
    delChannelIndex(index);
    _readIndex = 0;
}

GroupConnection::Channel GroupSockConnection::acceptPoint

(

Time

timeout = -1

)

[virtual]

accept an icomming point connection. If timeout is reached, -1 is returned. If timeout is -1 then wait without timeout

Implements osg::Connection.

Reimplemented in osg::GroupMCastConnection, and osg::GroupSockPipeline.

Definition at line 152 of file OSGGroupSockConnection.cpp.

References _acceptSocket, _readIndex, _remoteAddresses, _sockets, acceptSocket(), and osg::GroupConnection::newChannelIndex().

Referenced by osg::GroupSockPipeline::acceptPoint(), and osg::GroupMCastConnection::acceptPoint().

{
    StreamSocket from;
    SocketAddress destination;
    if(GroupSockConnection::acceptSocket(_acceptSocket,from,destination,timeout))
    {
        Channel channel = newChannelIndex(_sockets.size());
        _sockets.push_back(from);
        _remoteAddresses.push_back(destination);
        _readIndex = 0;
        return channel;
    }
    else
    {
        return -1;
    }
}

std::string GroupSockConnection::bind

(

const std::string &

address

)

[virtual]

bind the connection to an network interface. The address is returned, on wich the port could be connected. The interface is determined by the connection interface filed and the address parameter. Address can be empty, wich means to use a free port or address can contain a port number.

Implements osg::Connection.

Definition at line 176 of file OSGGroupSockConnection.cpp.

References _acceptSocket, osg::Socket::bind(), osg::Socket::getAddress(), osg::SocketAddress::getHost(), osg::Connection::getInterface(), osg::SocketAddress::getPort(), osg::Socket::listen(), osg::osgGetHostname(), osg::Socket::setReusePort(), and SINFO.

{
    int         port=0;
    char        localhost[256];
    char        host[256];
    char        portStr[256];
    std::string interf;
    std::string boundedAddress;

    // get local host name
    osgGetHostname(localhost,255);

    if(!getInterface().empty())
        interf = getInterface();
    else
        interf = localhost;
    // parse address
    if(!address.empty())
        if(sscanf(address.c_str(),"%*[^:]:%d",&port) != 1)
            if(sscanf(address.c_str(),":%d",&port) != 1)
                port = 0;
    // bind port
    _acceptSocket.setReusePort(true);
    _acceptSocket.bind(SocketAddress(interf.c_str(),port));
    SINFO << "Connection bound to "
          << _acceptSocket.getAddress().getHost() << ":"
          << _acceptSocket.getAddress().getPort() << std::endl;
    _acceptSocket.listen();
    // create address
    sprintf(portStr,"%d",_acceptSocket.getAddress().getPort());
    return interf + ":" + portStr;
}

void GroupSockConnection::setParams

(

const std::string &

params

)

[virtual]

parse the params string.

Reimplemented from osg::Connection.

Reimplemented in osg::GroupMCastConnection.

Definition at line 211 of file OSGGroupSockConnection.cpp.

References _socketReadBuffer, _socketWriteBuffer, FINFO, osg::BinaryDataHandler::readBufAdd(), osg::BinaryDataHandler::readBufClear(), osg::BinaryDataHandler::writeBufAdd(), and osg::BinaryDataHandler::writeBufClear().

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

{
    if(params.empty())
        return;

    std::string option = "bufferSize=";
    std::string::size_type i = 0;
    if((i=params.find(option)) != std::string::npos)
    {
        std::string str = params.substr(i + option.size());

        std::stringstream ss;
        std::string::size_type j = 0;
        while(j < str.length() && str[j] != ',' && isdigit(str[j]))
        {
            ss << str[j++];
        }
        UInt32 bufferSize;
        ss >> bufferSize;

        // clear old buffer.
        readBufClear();
        writeBufClear();

        _socketReadBuffer.resize(bufferSize);
        _socketWriteBuffer.resize(_socketReadBuffer.size());
        
        // reserve first bytes for buffer size
        readBufAdd (&_socketReadBuffer [sizeof(SocketBufferHeader)],
                    _socketReadBuffer.size() -sizeof(SocketBufferHeader));
        writeBufAdd(&_socketWriteBuffer[sizeof(SocketBufferHeader)],
                    _socketWriteBuffer.size()-sizeof(SocketBufferHeader));

        FINFO(("GroupSockConnection::setParams : setting buffer size to %u.\n", bufferSize));
    }
}

Connection::Channel GroupSockConnection::selectChannel

(

Time

timeout = -1

)

throw (ReadError) [virtual]

select the next channel for reading. If timeout is not -1 then -1 is returned if timeout is reached

Implements osg::Connection.

Definition at line 254 of file OSGGroupSockConnection.cpp.

References osg::BinaryDataHandler::_currentReadBuffer, _readIndex, osg::GroupConnection::_selection, _sockets, osg::BinaryDataHandler::_zeroCopyThreshold, FFATAL, osg::GroupConnection::indexToChannel(), osg::SocketSelection::isSetRead(), osg::BinaryDataHandler::readBufEnd(), osg::SocketSelection::select(), osg::SocketSelection::setRead(), and osg::Exception::what().

{
    Int32 maxnread=0,nread;
    ChannelIndex index;
    SocketSelection selection,result;

    // if there is data in the read buffer, return current channel
    if(_zeroCopyThreshold != 1 &&
       _currentReadBuffer != readBufEnd())
    {
        FFATAL(("Channel change ignores data in current buffer"))
        return indexToChannel(_readIndex);
    }    

    if(_selection[_readIndex] &&
       _sockets[_readIndex].getAvailable())
    {
        return indexToChannel(_readIndex);;
    }

    // wait for first socket to deliver data
    for(index = 0 ; index < _sockets.size() ; ++index)
    {
        if(_selection[index])
            selection.setRead(_sockets[index]);
    }
    
    try 
    {
        // select ok ?
        if(!selection.select(timeout,result))
            return -1;

        // use socket with most data
        for(index = 0 ; index < _sockets.size() ; ++index)
        {
            if(result.isSetRead(_sockets[index]))
            {
                nread=_sockets[index].getAvailable();
                if(maxnread < nread)
                {
                    maxnread = nread;
                    _readIndex=index;
                }
            }
        }
    }
    catch(SocketException &e)
    {
        throw ReadError(e.what());
    }

    // return channel id
    return indexToChannel(_readIndex);
}

ConnectionType GroupSockConnection::_type & GroupSockConnection::create

(

void

)

[static]

Reimplemented in osg::GroupMCastConnection, and osg::GroupSockPipeline.

Definition at line 382 of file OSGGroupSockConnection.cpp.

References GroupSockConnection().

{
    return new GroupSockConnection();
}

void GroupSockConnection::read	(	MemoryHandle	mem,
		UInt32	size
	)			[protected, virtual]

Read data into given memory

Read data form the current read socket. The read socket is that socket, that was selectet in selectChannel.

Reimplemented from osg::BinaryDataHandler.

Definition at line 397 of file OSGGroupSockConnection.cpp.

References _readIndex, and _sockets.

{
    int len;

    // read data
    len=_sockets[_readIndex].recv(mem,size);
    if(len==0)
    {
//        throw ChannelClosed(indexToChannel(_readIndex));
        throw ReadError("Channel closed");
    }
} 

void GroupSockConnection::readBuffer

(

void

)

[protected, virtual]

Read next data block

The stream connection uses only BinaryDataHandler buffer. If more then one buffer is present, then this methode must be changed!

Reimplemented from osg::BinaryDataHandler.

Definition at line 417 of file OSGGroupSockConnection.cpp.

References _readIndex, _socketReadBuffer, _sockets, osg::osgntohl(), and osg::BinaryDataHandler::readBufBegin().

{
    int size;
    int len;

    // read buffer header
    len=_sockets[_readIndex].recv(&_socketReadBuffer[0],sizeof(SocketBufferHeader));
    if(len==0)
        throw ReadError("Channel closed");
    // read remaining data
    size=osgntohl(((SocketBufferHeader*)&_socketReadBuffer[0])->size);
    len=_sockets[_readIndex].recv(&_socketReadBuffer[sizeof(SocketBufferHeader)],
                         size);
    if(len==0)
        throw ReadError("Channel closed");
    readBufBegin()->setDataSize(size);
}    

void GroupSockConnection::write	(	MemoryHandle	mem,
		UInt32	size
	)			[protected, virtual]

Write data to all destinations

Parameters:

	mem	Pointer to data buffer
	size	Size of bytes to write

Reimplemented from osg::BinaryDataHandler.

Reimplemented in osg::GroupMCastConnection, and osg::GroupSockPipeline.

Definition at line 442 of file OSGGroupSockConnection.cpp.

References _sockets, and osg::Exception::what().

{
    Int32 index;

    try
    {
        // write to all connected sockets
        for(index = 0 ; index < _sockets.size() ; ++index)
            _sockets[index].send(mem,size);
    }
    catch(SocketException &e)
    {
        throw WriteError(e.what());
    }
}

void GroupSockConnection::writeBuffer

(

void

)

[protected, virtual]

Write buffer

Write blocksize and data.

Reimplemented from osg::BinaryDataHandler.

Reimplemented in osg::GroupMCastConnection, and osg::GroupSockPipeline.

Definition at line 463 of file OSGGroupSockConnection.cpp.

References _sockets, _socketWriteBuffer, osg::osghtonl(), and osg::BinaryDataHandler::writeBufBegin().

{
    Int32 index;
    UInt32 size = writeBufBegin()->getDataSize();
    // write size to header
    ((SocketBufferHeader*)&_socketWriteBuffer[0])->size=osghtonl(size);
    if(size)
    {
        // write data to all sockets
        for(index = 0 ; index < _sockets.size() ; ++index)
        {
            // write whole block
            _sockets[index].send(&_socketWriteBuffer[0],
                                 size+sizeof(SocketBufferHeader));
        }
    }
}

bool GroupSockConnection::wait

(

Time

timeout

)

throw (ReadError) [protected, virtual]

wait for signal

Implements osg::Connection.

Reimplemented in osg::GroupMCastConnection.

Definition at line 316 of file OSGGroupSockConnection.cpp.

References _sockets, osg::SocketSelection::clearRead(), FFATAL, osg::SocketSelection::isSetRead(), osg::osgntohl(), osg::SocketSelection::select(), osg::SocketSelection::setRead(), and osg::Exception::what().

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

{
    UInt32 len;
    UInt32 index;
    UInt32 tag=314156;
    UInt32 missing = _sockets.size();
    SocketSelection selection,result;

    for(index = 0 ; index < _sockets.size() ; ++index)
        selection.setRead(_sockets[index]);

    try
    {
        while(missing)
        {
            if(!selection.select(timeout,result))
                return false;
            for(index = 0 ; index < _sockets.size() ; ++index)
            {
                if(result.isSetRead(_sockets[index]))
                {
                    len = _sockets[index].recv(&tag,sizeof(tag));
                    tag = osgntohl(tag);
                    if(len == 0)
                        throw ReadError("Channel closed");
                    selection.clearRead(_sockets[index]);
                    missing--;
                    if(tag != 314156)
                    {
                        FFATAL(("Stream out of sync in SockConnection\n"));
                        throw ReadError("Stream out of sync");
                    }
                }
            }
        }
    }
    catch(SocketException &e)
    {
        throw ReadError(e.what());
    }
    return true;
}

void GroupSockConnection::signal

(

void

)

throw (WriteError) [protected, virtual]

send signal

Implements osg::Connection.

Reimplemented in osg::GroupMCastConnection.

Definition at line 361 of file OSGGroupSockConnection.cpp.

References _sockets, osg::osghtonl(), and osg::Exception::what().

{
    UInt32 tag=osghtonl(314156);
    UInt32 index;

    try
    {
        for(index = 0 ; index<_sockets.size() ; ++index)
            _sockets[index].send(&tag,sizeof(tag));
    }
    catch(SocketError &e)
    {
        throw WriteError(e.what());
    }
}

bool GroupSockConnection::connectSocket	(	StreamSocket &	socket,
		std::string	address,
		SocketAddress &	destination,
		Time	timeout
	)			[static, private]

connect two sockets until success or timeout

Definition at line 486 of file OSGGroupSockConnection.cpp.

References osg::Socket::connect(), osg::getSystemTime(), osg::StreamSocket::open(), osg::StreamSocket::setDelay(), osg::Socket::setReadBufferSize(), osg::Socket::setWriteBufferSize(), and startTime.

Referenced by osg::PointSockConnection::connectGroup(), osg::PointSockConnection::connectPoint(), and connectPoint().

{
    std::string  host="unknown";
    int          port=0;
    Time         startTime = getSystemTime();
    bool         connected=false;
    
    int pos = address.find(':');
    if(pos>=0)
    {
        host = std::string(address,0,pos);
        port = atoi(std::string(address,pos+1,std::string::npos).c_str());
    }
    else
    {
        host = address;
    }
    
    socket.open();
    socket.setDelay(false);
    socket.setReadBufferSize(1048576);
    socket.setWriteBufferSize(1048576);
    destination = SocketAddress(host.c_str(),port);
    while(!connected && 
          (timeout == -1 || (getSystemTime()-startTime) < timeout))
    {
        try
        {
            socket.connect(destination);
            connected = true;
        }
        catch(...)
        {
        }
    }
    if(connected)
        return true;
    else
        return false;
}

bool GroupSockConnection::acceptSocket	(	StreamSocket &	accept,
		StreamSocket &	from,
		SocketAddress &	destination,
		Time	timeout
	)			[static, private]

accept socket untile success or timeout

Definition at line 532 of file OSGGroupSockConnection.cpp.

References osg::StreamSocket::acceptFrom(), osg::StreamSocket::setDelay(), osg::Socket::setReadBufferSize(), osg::Socket::setWriteBufferSize(), and osg::Socket::waitReadable().

Referenced by osg::PointSockConnection::acceptGroup(), osg::PointSockConnection::acceptPoint(), and acceptPoint().

{
    if(!accept.waitReadable(timeout))
        return false;
    from=accept.acceptFrom(destination);
    from.setDelay(false);
    from.setReadBufferSize(1048576);
    from.setWriteBufferSize(1048576);
    return true;
}

GroupSockConnection& osg::GroupSockConnection::operator=

(

const GroupSockConnection &

source

)

[private]

UInt32 GroupConnection::getChannelCount

(

void

)

[inherited]

number of connected channels

Definition at line 78 of file OSGGroupConnection.cpp.

References osg::GroupConnection::_selection.

Referenced by osg::SortFirstWindow::clientInit(), osg::ClusterNetwork::connectAllGroupToPoint(), osg::ClusterNetwork::connectAllPointToPoint(), osg::ClusterViewBuffer::recv(), and osg::GroupSockPipeline::write().

{
    return _selection.size();
}

void GroupConnection::addSelection

(

Channel

channel

)

[inherited]

mark the given channel as selectable

Definition at line 85 of file OSGGroupConnection.cpp.

References osg::GroupConnection::_channelToIndex, and osg::GroupConnection::_selection.

{
    ChannelIndex index = _channelToIndex[channel];
    _selection[index] = true;
}

void GroupConnection::subSelection

(

Channel

channel

)

[inherited]

mark the given channel as not selectable

Definition at line 93 of file OSGGroupConnection.cpp.

References osg::GroupConnection::_channelToIndex, and osg::GroupConnection::_selection.

Referenced by osg::SortFirstWindow::clientInit(), osg::ClusterNetwork::connectAllGroupToPoint(), osg::ClusterNetwork::connectAllPointToPoint(), osg::ClusterWindow::init(), and osg::ClusterViewBuffer::recv().

{
    ChannelIndex index = _channelToIndex[channel];
    _selection[index] = false;
}

void GroupConnection::clearSelection

(

void

)

[inherited]

mark all channels as selectable

Definition at line 101 of file OSGGroupConnection.cpp.

References osg::GroupConnection::_selection.

{
    std::fill(_selection.begin(),_selection.end(),false);
}

void GroupConnection::resetSelection

(

void

)

[inherited]

mark all channels as not selectable

Definition at line 108 of file OSGGroupConnection.cpp.

References osg::GroupConnection::_selection.

Referenced by osg::SortFirstWindow::clientInit(), osg::ClusterNetwork::connectAllGroupToPoint(), osg::ClusterNetwork::connectAllPointToPoint(), osg::ClusterWindow::init(), and osg::ClusterViewBuffer::recv().

{
    std::fill(_selection.begin(),_selection.end(),true);
}

UInt32 GroupConnection::getSelectionCount

(

void

)

[inherited]

get number of sockets in the selection

Definition at line 115 of file OSGGroupConnection.cpp.

References osg::GroupConnection::_selection.

{
    UInt32 selectionCount=0;
    std::vector<UInt8>::iterator i;
    for(i=_selection.begin() ; i!=_selection.end() ; ++i)
        if(*i)
            selectionCount++;
    return selectionCount;
}

void GroupConnection::setDestination

(

const std::string &

destination

)

[inherited]

set destination address used to broadcast or multicast to all connected points. On Multicast connections this could be 224.22.22.1 or something like that.

Definition at line 132 of file OSGGroupConnection.cpp.

References osg::GroupConnection::_destination.

Referenced by osg::ClusterWindow::init().

{
    _destination = destination;
}

std::string GroupConnection::getDestination

(

void

)

[inherited]

get destination address

Definition at line 139 of file OSGGroupConnection.cpp.

References osg::GroupConnection::_destination.

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

{
    return _destination;
}

Connection::Channel GroupConnection::newChannelIndex

(

ChannelIndex

index

)

[protected, inherited]

create a new channel

Definition at line 149 of file OSGGroupConnection.cpp.

References osg::GroupConnection::_channelToIndex, osg::GroupConnection::_indexToChannel, osg::GroupConnection::_reuseChannel, and osg::GroupConnection::_selection.

Referenced by acceptPoint(), and connectPoint().

{
    Channel channel;
    if(_reuseChannel.begin() != _reuseChannel.end())
    {
        channel = *(_reuseChannel.begin());
        _reuseChannel.pop_front();
    }
    else
    {
        channel = _channelToIndex.size();
        _channelToIndex.resize(channel+1);
    }
    if(index >= _indexToChannel.size())
        _indexToChannel.resize(index+1);
    if(index >= _selection.size())
        _selection.resize(index+1);
    // enable selection
    _selection[index] = true;
    // set index to channel mapping
    _indexToChannel[index] = channel;
    // set channel to index mapping
    _channelToIndex[channel] = index;
    return channel;
}

void GroupConnection::delChannelIndex

(

ChannelIndex

index

)

[protected, inherited]

remove a channel.

Definition at line 177 of file OSGGroupConnection.cpp.

References osg::GroupConnection::_indexToChannel, osg::GroupConnection::_reuseChannel, and osg::GroupConnection::_selection.

Referenced by disconnect().

{
    Channel channel = _indexToChannel[index];
    // erase from indexed arrays
    _selection     .erase(_selection.begin()      + index);
    _indexToChannel.erase(_indexToChannel.begin() + index);
    // move to reuse
    _reuseChannel.push_back(channel);
}

GroupConnection::ChannelIndex GroupConnection::channelToIndex

(

Channel

channel

)

const [protected, inherited]

Definition at line 190 of file OSGGroupConnection.cpp.

References osg::GroupConnection::_channelToIndex.

Referenced by disconnect(), and osg::GroupMCastConnection::disconnect().

{
    return _channelToIndex[channel];
}

Connection::Channel GroupConnection::indexToChannel

(

ChannelIndex

index

)

const [protected, inherited]

Definition at line 195 of file OSGGroupConnection.cpp.

References osg::GroupConnection::_indexToChannel.

Referenced by selectChannel().

{
    return _indexToChannel[index];
}

const std::string & Connection::getInterface

(

void

)

[inherited]

get network interface

Definition at line 98 of file OSGConnection.cpp.

References osg::Connection::_interface.

Referenced by osg::PointSockConnection::bind(), bind(), osg::PointSockPipeline::initialize(), osg::PointMCastConnection::initialize(), and osg::GroupMCastConnection::initialize().

{
    return _interface;
}

void Connection::setInterface

(

const std::string &

interf

)

[inherited]

set network interface

Definition at line 105 of file OSGConnection.cpp.

References osg::Connection::_interface.

Referenced by osg::ClusterServer::acceptClient(), and osg::ClusterWindow::init().

{
    _interface = interf;
}

void BinaryDataHandler::put	(	void const *	src,
		UInt32	size
	)			[inherited]

Definition at line 83 of file OSGBinaryDataHandler.cpp.

References osg::BinaryDataHandler::_currentWriteBuffer, osg::BinaryDataHandler::_currentWriteBufferPos, osg::BinaryDataHandler::_zeroCopyBuffers, osg::BinaryDataHandler::_zeroCopyThreshold, osg::osgMin(), osg::BinaryDataHandler::pushBuffer(), osg::BinaryDataHandler::write(), and osg::BinaryDataHandler::writeBufEnd().

Referenced by osg::BinaryDataHandler::putAndFree(), osg::BinaryDataHandler::putValue(), osg::BinaryDataHandler::putValues(), and osg::ClusterViewBuffer::send().

{
    UInt8 const *data = static_cast<UInt8 const *>(src);

    if(_zeroCopyThreshold && size >= _zeroCopyThreshold)
    {
        if(_zeroCopyThreshold == 1)
        {
            write(const_cast<MemoryHandle>(data), size);
        }
        else
        {
            UInt8 tag = 1;

            // we have to write a tag, to indicate the membership
            // of this zero copy block to the current data block
            put(&tag, sizeof(tag));

            _zeroCopyBuffers.push_back(
                MemoryBlock(const_cast<MemoryHandle>(data), size, size));
        }
    }
    else
    {
        UInt32 copySize;

        while(size != 0)
        {
            if(_currentWriteBuffer == writeBufEnd())
            {
                pushBuffer();
            }

            copySize = osgMin((_currentWriteBuffer->getSize() -
                               _currentWriteBufferPos),
                              size);

            memcpy(_currentWriteBuffer->getMem() + _currentWriteBufferPos,
                    data,
                    copySize);

             size                  -= copySize;
            _currentWriteBufferPos += copySize;
             data                  += copySize;

            // skip to next buffer if current buffer is full
            if(_currentWriteBufferPos == _currentWriteBuffer->getSize())
            {
                _currentWriteBuffer->setDataSize(_currentWriteBufferPos);
                _currentWriteBuffer++;
                _currentWriteBufferPos = 0;
            }
        }
    }
}

void BinaryDataHandler::putAndFree	(	MemoryHandle	src,
		UInt32	size
	)			[inherited]

Put data from dynamic allocated block The caller doesn't know, when the block will be written. So we are responsible for freeing this block.

Definition at line 144 of file OSGBinaryDataHandler.cpp.

References osg::BinaryDataHandler::_freeMem, osg::BinaryDataHandler::_zeroCopyThreshold, and osg::BinaryDataHandler::put().

{
    put(src, size);

    if(_zeroCopyThreshold && size > _zeroCopyThreshold)
    {
        _freeMem.push_back(src);
    }
    else
    {
        delete [] src;
    }
}

void osg::BinaryDataHandler::putValue

(

const bool &

value

)

[inline, inherited]

Definition at line 60 of file OSGBinaryDataHandler.inl.

References osg::BinaryDataHandler::put().

Referenced by osg::SortFirstWindow::clientInit(), osg::ClusterNetwork::connectAllGroupToPoint(), osg::ClusterNetwork::connectAllPointToPoint(), osg::osg::FieldDataTraits2< bool >::copyToBin(), osg::RenderNode::copyToBin(), osg::ParticleBSPTree::copyToBin(), osg::MField< FieldTypeT, fieldNameSpace >::copyToBin(), osg::FieldTraitsIntegralRecurseMapper< uint64_t >::copyToBin(), osg::FieldTraitsRecurseBase1< GLXContext >::copyToBin(), osg::FieldTraitsRecurseBase< osg::NodePtr >::copyToBin(), osg::osg::FieldTraitsRecurseMapper< FieldContainerPtr, false >::copyToBin(), osg::osg::FieldDataTraits< Plane >::copyToBin(), osg::osg::FieldDataTraits1< GLenum >::copyToBin(), osg::osg::FieldDataTraits1< BitVector >::copyToBin(), osg::osg::FieldDataTraits< DynamicVolume >::copyToBin(), osg::osg::FieldDataTraits1< Time >::copyToBin(), osg::osg::FieldDataTraits< std::string >::copyToBin(), osg::osg::FieldTraitsRecurseMapper< AttachmentMap, false >::copyToBin(), osg::BINWriter::doWriteIndexedFC(), osg::RemoteAspect::handleFCMapping(), osg::ClusterWindow::init(), osg::BinaryDataHandler::putValue(), osg::BinaryDataHandler::putValues(), osg::ClusterViewBuffer::send(), osg::RemoteAspect::sendSync(), osg::SortFirstWindow::serverInit(), osg::GroupMCastConnection::signal(), osg::ClusterServer::start(), and osg::BINWriter::writeFileHeader().

{
    // on Mac OS X a bool is four bytes long on all other
    // platfroms it is one byte long. So we write now always
    // one byte out.
    // put(&value, sizeof(bool));
    UInt8 temp = (UInt8) value;
    put(&temp, sizeof(UInt8));
}

void osg::BinaryDataHandler::putValue

(

const UInt8 &

value

)

[inline, inherited]

Definition at line 71 of file OSGBinaryDataHandler.inl.

References osg::BinaryDataHandler::put().

{
    put(&value, sizeof(UInt8));
}

void osg::BinaryDataHandler::putValue

(

const UInt16 &

value

)

[inline, inherited]

Definition at line 77 of file OSGBinaryDataHandler.inl.

References osg::osghtons(), and osg::BinaryDataHandler::put().

{
    UInt16 z = osghtons(value);

    put(&z, sizeof(UInt16));
}

void osg::BinaryDataHandler::putValue

(

const UInt32 &

value

)

[inline, inherited]

Definition at line 85 of file OSGBinaryDataHandler.inl.

References osg::osghtonl(), and osg::BinaryDataHandler::put().

{
    UInt32 z = osghtonl(value);

    put(&z, sizeof(UInt32));
}

void osg::BinaryDataHandler::putValue

(

const UInt64 &

value

)

[inline, inherited]

Definition at line 93 of file OSGBinaryDataHandler.inl.

References osg::osghtonll(), and osg::BinaryDataHandler::put().

{
    UInt64 z = osghtonll(value);

    put(&z, sizeof(UInt64));
}

void osg::BinaryDataHandler::putValue

(

const Int8 &

value

)

[inline, inherited]

Definition at line 101 of file OSGBinaryDataHandler.inl.

References osg::BinaryDataHandler::put().

{
    put(&value, sizeof(Int8));
}

void osg::BinaryDataHandler::putValue

(

const Int16 &

value

)

[inline, inherited]

Definition at line 107 of file OSGBinaryDataHandler.inl.

References osg::osghtons(), and osg::BinaryDataHandler::put().

{
    Int16 z = osghtons(value);

    put(&z, sizeof(Int16));
}

void osg::BinaryDataHandler::putValue

(

const Int32 &

value

)

[inline, inherited]

Definition at line 115 of file OSGBinaryDataHandler.inl.

References osg::osghtonl(), and osg::BinaryDataHandler::put().

{
    Int32 z = osghtonl(value);

    put(&z, sizeof(Int32));
}

void osg::BinaryDataHandler::putValue

(

const Int64 &

value

)

[inline, inherited]

Definition at line 123 of file OSGBinaryDataHandler.inl.

References osg::osghtonll(), and osg::BinaryDataHandler::put().

{
    Int64 z = osghtonll(value);
    put(&z, sizeof(Int64));

}

void osg::BinaryDataHandler::putValue

(

const Real16 &

value

)

[inline, inherited]

Definition at line 131 of file OSGBinaryDataHandler.inl.

References osg::Real16::bits(), osg::osghtons(), and osg::BinaryDataHandler::put().

{
    UInt16 v = osghtons(value.bits());

    put(&v, sizeof(Real16));
}

void osg::BinaryDataHandler::putValue

(

const Real32 &

value

)

[inline, inherited]

Definition at line 139 of file OSGBinaryDataHandler.inl.

References osg::osghtonl(), and osg::BinaryDataHandler::put().

{
    UInt32 v = osghtonl( *((const UInt32 *)(&value)) );

    put(&v, sizeof(Real32));
}

void osg::BinaryDataHandler::putValue

(

const Real64 &

value

)

[inline, inherited]

Definition at line 147 of file OSGBinaryDataHandler.inl.

References osg::osghtonll(), and osg::BinaryDataHandler::put().

{
    UInt64 v = osghtonll( *((const UInt64 *)(&value)) );

    put(&v, sizeof(Real64));
}

void osg::BinaryDataHandler::putValue

(

const Real128 &

value

)

[inline, inherited]

Definition at line 155 of file OSGBinaryDataHandler.inl.

References osg::osghtonll(), and osg::BinaryDataHandler::put().

{
    UInt64 v = osghtonll( *( (const UInt64 *)(&value)) );
    UInt64 w = osghtonll( *(((const UInt64 *)(&value)) + 1) );

#if BYTE_ORDER == LITTLE_ENDIAN
    put(&w, sizeof(UInt64));
    put(&v, sizeof(UInt64));
#else
    put(&v, sizeof(UInt64));
    put(&w, sizeof(UInt64));
#endif
}

void osg::BinaryDataHandler::putValue

(

const std::string &

value

)

[inline, inherited]

Definition at line 170 of file OSGBinaryDataHandler.inl.

References osg::BinaryDataHandler::put(), osg::BinaryDataHandler::putValue(), and osg::stringlen().

{
    UInt32 len = stringlen(value.c_str()) + 1;

    putValue(len);

    if(len != 0)
    {
        put(value.c_str(), len);
    }
}

void osg::BinaryDataHandler::putValues	(	const bool *	value,
		UInt32	size
	)			[inline, inherited]

Definition at line 184 of file OSGBinaryDataHandler.inl.

References osg::BinaryDataHandler::putValue().

Referenced by osg::FieldTraitsRecurseVecStoreBase< osg::Pnt2s >::copyToBin(), osg::osg::FieldDataTraits< Quaternion >::copyToBin(), osg::osg::FieldDataTraits< Matrix4d >::copyToBin(), osg::osg::FieldDataTraits< Matrix >::copyToBin(), osg::FieldTraitsIntegralRecurseMapper< uint64_t >::copyToBin(), osg::osg::FieldDataTraits< Plane >::copyToBin(), osg::osg::FieldDataTraits< DynamicVolume >::copyToBin(), osg::osg::FieldDataTraits1< Time >::copyToBin(), osg::osg::FieldDataTraits< Color4ub >::copyToBin(), osg::osg::FieldDataTraits< Color3ub >::copyToBin(), osg::osg::FieldDataTraits< Color4f >::copyToBin(), and osg::osg::FieldDataTraits< Color3f >::copyToBin().

{
    for(UInt32 i = 0; i < size; ++i)
        putValue(value[i]);
}

void osg::BinaryDataHandler::putValues	(	const UInt8 *	value,
		UInt32	size
	)			[inline, inherited]

Definition at line 191 of file OSGBinaryDataHandler.inl.

References osg::BinaryDataHandler::put().

{
    put(value, size * sizeof(UInt8));
}

void osg::BinaryDataHandler::putValues	(	const UInt16 *	value,
		UInt32	size
	)			[inline, inherited]

Definition at line 197 of file OSGBinaryDataHandler.inl.

References osg::BinaryDataHandler::_networkOrder, osg::BinaryDataHandler::put(), and osg::BinaryDataHandler::putValue().

{
#if BYTE_ORDER == LITTLE_ENDIAN

    if(_networkOrder == true)
    {
        for(UInt32 i = 0; i < size; ++i)
        {
            putValue(value[i]);
        }
    }
    else
#endif
    {
        put(value, size * sizeof(UInt16));
    }
}

void osg::BinaryDataHandler::putValues	(	const UInt32 *	value,
		UInt32	size
	)			[inline, inherited]

Definition at line 216 of file OSGBinaryDataHandler.inl.

References osg::BinaryDataHandler::_networkOrder, osg::BinaryDataHandler::put(), and osg::BinaryDataHandler::putValue().

{
#if BYTE_ORDER == LITTLE_ENDIAN
    if(_networkOrder == true)
    {
        for(UInt32 i = 0; i < size; ++i)
        {
            putValue(value[i]);
        }
    }
    else
#endif
    {
        put(value, size * sizeof(UInt32));
    }
}

void osg::BinaryDataHandler::putValues	(	const UInt64 *	value,
		UInt32	size
	)			[inline, inherited]

Definition at line 234 of file OSGBinaryDataHandler.inl.

References osg::BinaryDataHandler::_networkOrder, osg::BinaryDataHandler::put(), and osg::BinaryDataHandler::putValue().

{
#if BYTE_ORDER == LITTLE_ENDIAN
    if(_networkOrder == true)
    {
        for(UInt32 i = 0; i < size; ++i)
        {
            putValue(value[i]);
        }
    }
    else
#endif
    {
        put(value, size * sizeof(UInt64));
    }
}

void osg::BinaryDataHandler::putValues	(	const Int8 *	value,
		UInt32	size
	)			[inline, inherited]

Definition at line 252 of file OSGBinaryDataHandler.inl.

References osg::BinaryDataHandler::_networkOrder, osg::BinaryDataHandler::put(), and osg::BinaryDataHandler::putValue().

{
#if BYTE_ORDER == LITTLE_ENDIAN
    if(_networkOrder == true)
    {
        for(UInt32 i = 0; i < size; ++i)
        {
            putValue(value[i]);
        }
    }
    else
#endif
    {
        put(value, size * sizeof(Int8));
    }
}

void osg::BinaryDataHandler::putValues	(	const Int16 *	value,
		UInt32	size
	)			[inline, inherited]

Definition at line 270 of file OSGBinaryDataHandler.inl.

References osg::BinaryDataHandler::_networkOrder, osg::BinaryDataHandler::put(), and osg::BinaryDataHandler::putValue().

{
#if BYTE_ORDER == LITTLE_ENDIAN
    if(_networkOrder == true)
    {
        for(UInt32 i = 0; i < size; ++i)
        {
            putValue(value[i]);
        }
    }
    else
#endif
    {
        put(value, size * sizeof(Int16));
    }
}

void osg::BinaryDataHandler::putValues	(	const Int32 *	value,
		UInt32	size
	)			[inline, inherited]

Definition at line 288 of file OSGBinaryDataHandler.inl.

References osg::BinaryDataHandler::_networkOrder, osg::BinaryDataHandler::put(), and osg::BinaryDataHandler::putValue().

{
#if BYTE_ORDER == LITTLE_ENDIAN
    if(_networkOrder == true)
    {
        for(UInt32 i = 0; i < size; ++i)
        {
            putValue(value[i]);
        }
    }
    else
#endif
    {
        put(value, size * sizeof(Int32));
    }
}

void osg::BinaryDataHandler::putValues	(	const Int64 *	value,
		UInt32	size
	)			[inline, inherited]

Definition at line 306 of file OSGBinaryDataHandler.inl.

References osg::BinaryDataHandler::_networkOrder, osg::BinaryDataHandler::put(), and osg::BinaryDataHandler::putValue().

{
#if BYTE_ORDER == LITTLE_ENDIAN
    if(_networkOrder == true)
    {
        for(UInt32 i = 0; i < size; ++i)
        {
            putValue(value[i]);
        }
    }
    else
#endif
    {
        put(value, size * sizeof(Int64));
    }
}

void osg::BinaryDataHandler::putValues	(	const Real16 *	value,
		UInt32	size
	)			[inline, inherited]

Definition at line 324 of file OSGBinaryDataHandler.inl.

References osg::BinaryDataHandler::_networkOrder, osg::BinaryDataHandler::put(), and osg::BinaryDataHandler::putValue().

{
#if BYTE_ORDER == LITTLE_ENDIAN
    if(_networkOrder == true)
    {
        for(UInt32 i = 0; i < size; ++i)
        {
            putValue(value[i]);
        }
    }
    else
#endif
    {
        put(value, size * sizeof(Real16));
    }
}

void osg::BinaryDataHandler::putValues	(	const Real32 *	value,
		UInt32	size
	)			[inline, inherited]

Definition at line 342 of file OSGBinaryDataHandler.inl.

References osg::BinaryDataHandler::_networkOrder, osg::BinaryDataHandler::put(), and osg::BinaryDataHandler::putValue().

{
#if BYTE_ORDER == LITTLE_ENDIAN
    if(_networkOrder == true)
    {
        for(UInt32 i = 0; i < size; ++i)
        {
            putValue(value[i]);
        }
    }
    else
#endif
    {
        put(value, size * sizeof(Real32));
    }
}

void osg::BinaryDataHandler::putValues	(	const Real64 *	value,
		UInt32	size
	)			[inline, inherited]

Definition at line 360 of file OSGBinaryDataHandler.inl.

References osg::BinaryDataHandler::_networkOrder, osg::BinaryDataHandler::put(), and osg::BinaryDataHandler::putValue().

{
#if BYTE_ORDER == LITTLE_ENDIAN
    if(_networkOrder == true)
    {
        for(UInt32 i = 0; i < size; ++i)
        {
            putValue(value[i]);
        }
    }
    else
#endif
    {
        put(value, size * sizeof(Real64));
    }
}

void osg::BinaryDataHandler::putValues	(	const Real128 *	value,
		UInt32	size
	)			[inline, inherited]

Definition at line 378 of file OSGBinaryDataHandler.inl.

References osg::BinaryDataHandler::_networkOrder, osg::BinaryDataHandler::put(), and osg::BinaryDataHandler::putValue().

{
#if BYTE_ORDER == LITTLE_ENDIAN
    if(_networkOrder == true)
    {
        for(UInt32 i = 0; i < size; ++i)
        {
            putValue(value[i]);
        }
    }
    else
#endif
    {
        put(value, size * sizeof(Real128));
    }
}

void osg::BinaryDataHandler::putValues	(	const std::string *	value,
		UInt32	size
	)			[inline, inherited]

Definition at line 396 of file OSGBinaryDataHandler.inl.

References osg::BinaryDataHandler::putValue().

{
    for(UInt32 i = 0; i<size; ++i)
    {
        putValue(value[i]);    
    }
}

void BinaryDataHandler::get	(	void *	dst,
		UInt32	size
	)			[inherited]

Definition at line 161 of file OSGBinaryDataHandler.cpp.

References osg::BinaryDataHandler::_currentReadBuffer, osg::BinaryDataHandler::_currentReadBufferPos, osg::BinaryDataHandler::_zeroCopyThreshold, osg::osgMin(), osg::BinaryDataHandler::pullBuffer(), osg::BinaryDataHandler::read(), and osg::BinaryDataHandler::readBufEnd().

Referenced by osg::RemoteAspect::receiveSync(), and osg::ClusterViewBuffer::recv().

{
    MemoryHandle data = static_cast<MemoryHandle>(dst);

    if(_zeroCopyThreshold && size >= _zeroCopyThreshold)
    {
        if(_zeroCopyThreshold > 1)
        {
            UInt8 tag;

            // we have to read the tag, to force reading of data blocks
            // if the first data field was zero copied
            get(&tag, sizeof(tag));
        }

        // read direct into destination
        read(data, size);
    }
    else
    {
        UInt32 copySize;

        while(size != 0)
        {
            // read new data if nothing left
            if(_currentReadBuffer == readBufEnd())
            {
                pullBuffer();
            }

            // num bytes to copy
            copySize = osgMin((_currentReadBuffer->getDataSize() -
                               _currentReadBufferPos),
                              size);

            // no data in buffer ?
            if(copySize != 0)
            {
                memcpy( data,
                       _currentReadBuffer->getMem() + _currentReadBufferPos,
                        copySize);

                 size                 -= copySize;
                _currentReadBufferPos += copySize;
                 data                 += copySize;
            }

            // skip to next buffer if current buffer is full
            if(_currentReadBufferPos == _currentReadBuffer->getDataSize())
            {
                _currentReadBuffer++;
                _currentReadBufferPos = 0;
            }
        }
    }
}

void BinaryDataHandler::getAndAlloc	(	MemoryHandle &	src,
		UInt32	size
	)			[inherited]

read data in a dynamic allocated block

If data was compressed or converted then it is not possible to write it into the destination memory. BinaryDataHandler doesn't store data in continous memory areas. If the caller needs a continuous memory then we provide a dynamic allocated block. The caller is responsible to free this block.

Definition at line 227 of file OSGBinaryDataHandler.cpp.

{
    src = new UInt8[size];

    get(src, size);
}

void osg::BinaryDataHandler::getValue

(

bool &

value

)

[inline, inherited]

Definition at line 405 of file OSGBinaryDataHandler.inl.

Referenced by osg::BINLoader::chargeFieldContainers(), osg::SortFirstWindow::clientInit(), osg::ClusterNetwork::connectAllGroupToPoint(), osg::ClusterNetwork::connectAllPointToPoint(), osg::osg::FieldDataTraits2< bool >::copyFromBin(), osg::RenderNode::copyFromBin(), osg::ParticleBSPTree::copyFromBin(), osg::MField< FieldTypeT, fieldNameSpace >::copyFromBin(), osg::FieldTraitsIntegralRecurseMapper< uint64_t >::copyFromBin(), osg::FieldTraitsRecurseBase1< GLXContext >::copyFromBin(), osg::FieldTraitsRecurseBase< osg::NodePtr >::copyFromBin(), osg::osg::FieldTraitsRecurseMapper< FieldContainerPtr, false >::copyFromBin(), osg::osg::FieldDataTraits< Plane >::copyFromBin(), osg::osg::FieldDataTraits1< GLenum >::copyFromBin(), osg::osg::FieldDataTraits1< BitVector >::copyFromBin(), osg::osg::FieldDataTraits< DynamicVolume >::copyFromBin(), osg::osg::FieldDataTraits1< Time >::copyFromBin(), osg::osg::FieldDataTraits< std::string >::copyFromBin(), osg::osg::FieldTraitsRecurseMapper< AttachmentMap, false >::copyFromBin(), osg::BINLoader::createFieldContainers(), osg::BinaryDataHandler::getValue(), osg::BinaryDataHandler::getValues(), osg::ClusterWindow::init(), osg::RemoteAspect::receiveSync(), osg::ClusterViewBuffer::recv(), osg::SortFirstWindow::serverInit(), osg::ClusterServer::start(), and osg::PointMCastConnection::wait().

{
    //get(&value, sizeof(bool));
    UInt8 temp;
    get(&temp, sizeof(UInt8));
    value = (temp!=0);
}

void osg::BinaryDataHandler::getValue

(

UInt8 &

value

)

[inline, inherited]

Definition at line 414 of file OSGBinaryDataHandler.inl.

{
    get(&value, sizeof(UInt8));
}

void osg::BinaryDataHandler::getValue

(

UInt16 &

value

)

[inline, inherited]

Definition at line 420 of file OSGBinaryDataHandler.inl.

References osg::osgntohs().

{
    get(&value, sizeof(UInt16));

    value = osgntohs(value);
}

void osg::BinaryDataHandler::getValue

(

UInt32 &

value

)

[inline, inherited]

Definition at line 428 of file OSGBinaryDataHandler.inl.

References osg::osgntohl().

{
    get(&value, sizeof(UInt32));

    value = osgntohl(value);
}

void osg::BinaryDataHandler::getValue

(

UInt64 &

value

)

[inline, inherited]

Definition at line 436 of file OSGBinaryDataHandler.inl.

References osg::osgntohll().

{
    get(&value, sizeof(UInt64));

    value = osgntohll(value);
}

void osg::BinaryDataHandler::getValue

(

Int8 &

value

)

[inline, inherited]

Definition at line 444 of file OSGBinaryDataHandler.inl.

{
    get(&value, sizeof(Int8));
}

void osg::BinaryDataHandler::getValue

(

Int16 &

value

)

[inline, inherited]

Definition at line 450 of file OSGBinaryDataHandler.inl.

References osg::osgntohs().

{
    get(&value, sizeof(Int16));

    value = osgntohs(value);
}

void osg::BinaryDataHandler::getValue

(

Int32 &

value

)

[inline, inherited]

Definition at line 458 of file OSGBinaryDataHandler.inl.

References osg::osgntohl().

{
    get(&value, sizeof(Int32));

    value = osgntohl(value);
}

void osg::BinaryDataHandler::getValue

(

Int64 &

value

)

[inline, inherited]

Definition at line 466 of file OSGBinaryDataHandler.inl.

References osg::osgntohll().

{
    get(&value, sizeof(Int64));

    value = osgntohll(value);
}

void osg::BinaryDataHandler::getValue

(

Real16 &

value

)

[inline, inherited]

Definition at line 474 of file OSGBinaryDataHandler.inl.

References osg::osgntohs(), and osg::Real16::setBits().

{
    UInt16 v;

    get(&v, sizeof(Real16));

    v     = osgntohs(v);
    value.setBits(v);
}

void osg::BinaryDataHandler::getValue

(

Real32 &

value

)

[inline, inherited]

Definition at line 485 of file OSGBinaryDataHandler.inl.

References osg::osgntohf(), and osg::osgntohl().

{
    get(&value, sizeof(Real32));

    value = osgntohf(value);

#if 0
    // doesn't work on my 64 bit linux ...
    UInt32 v;

    get(&v, sizeof(Real32));

    v     = osgntohl(v);
    value = *(reinterpret_cast<Real32 *>(&v));
#endif
}

void osg::BinaryDataHandler::getValue

(

Real64 &

value

)

[inline, inherited]

Definition at line 503 of file OSGBinaryDataHandler.inl.

References osg::osgntohd(), and osg::osgntohll().

{
    get(&value, sizeof(Real64));

    value = osgntohd(value);

#if 0
    UInt64 v;

    get(&v, sizeof(Real64));

    v     = osgntohll(v);
    value = *(reinterpret_cast<Real64 *>(&v));
#endif
}

void osg::BinaryDataHandler::getValue

(

Real128 &

value

)

[inline, inherited]

Definition at line 520 of file OSGBinaryDataHandler.inl.

References osg::osgntohdd(), and osg::osgntohll().

{
    get(&value, sizeof(Real128));

    value = osgntohdd(value);

#if 0
    UInt64 v[2];

#if BYTE_ORDER == LITTLE_ENDIAN
    get(&v[1], sizeof(UInt64));
    get(&v[0], sizeof(UInt64));
#else
    get(&v[0], sizeof(UInt64));
    get(&v[1], sizeof(UInt64));
#endif

    v[0]     = osgntohll(v[0]);
    v[1]     = osgntohll(v[1]);
    value = *(reinterpret_cast<Real128 *>(&v));
#endif
}

void osg::BinaryDataHandler::getValue

(

std::string &

value

)

[inline, inherited]

Definition at line 544 of file OSGBinaryDataHandler.inl.

References osg::BinaryDataHandler::getValue().

{
    UInt32  len;
    Char8  *str = NULL;

    getValue(len);

    if(len != 0)
    {
        str = new Char8[len];
        
        get(str, len);

        value = str;
        
        delete [] str;
    }
    else
    {
        value.erase();
    }
}

void osg::BinaryDataHandler::getValues	(	bool *	value,
		UInt32	size
	)			[inline, inherited]

Definition at line 568 of file OSGBinaryDataHandler.inl.

References osg::BinaryDataHandler::getValue().

Referenced by osg::FieldTraitsRecurseVecStoreBase< osg::Pnt2s >::copyFromBin(), osg::osg::FieldDataTraits< Quaternion >::copyFromBin(), osg::osg::FieldDataTraits< Matrix4d >::copyFromBin(), osg::osg::FieldDataTraits< Matrix >::copyFromBin(), osg::FieldTraitsIntegralRecurseMapper< uint64_t >::copyFromBin(), osg::osg::FieldDataTraits< Plane >::copyFromBin(), osg::osg::FieldDataTraits< DynamicVolume >::copyFromBin(), osg::osg::FieldDataTraits1< Time >::copyFromBin(), osg::osg::FieldDataTraits< Color4ub >::copyFromBin(), osg::osg::FieldDataTraits< Color3ub >::copyFromBin(), osg::osg::FieldDataTraits< Color4f >::copyFromBin(), and osg::osg::FieldDataTraits< Color3f >::copyFromBin().

{
    for(UInt32 i = 0; i < size; ++i)
        getValue(value[i]);
}

void osg::BinaryDataHandler::getValues	(	UInt8 *	value,
		UInt32	size
	)			[inline, inherited]

Definition at line 575 of file OSGBinaryDataHandler.inl.

{
    get(value, size * sizeof(UInt8));
}

void osg::BinaryDataHandler::getValues	(	UInt16 *	value,
		UInt32	size
	)			[inline, inherited]

Definition at line 581 of file OSGBinaryDataHandler.inl.

References osg::BinaryDataHandler::_networkOrder, and osg::osgntohs().

{
    get(value, size * sizeof(UInt16));

#if BYTE_ORDER == LITTLE_ENDIAN
    if(_networkOrder == true)
    {
        for(UInt32 i = 0; i < size; ++i)
        {
            value[i] = osgntohs(value[i]);
        }
    }
#endif
}

void osg::BinaryDataHandler::getValues	(	UInt32 *	value,
		UInt32	size
	)			[inline, inherited]

Definition at line 597 of file OSGBinaryDataHandler.inl.

References osg::BinaryDataHandler::_networkOrder, and osg::osgntohl().

{
    get(value, size * sizeof(UInt32));

#if BYTE_ORDER == LITTLE_ENDIAN
    if(_networkOrder == true)
    {
        for(UInt32 i = 0; i < size; ++i)
        {
            value[i] = osgntohl(value[i]);
        }
    }
#endif
}

void osg::BinaryDataHandler::getValues	(	UInt64 *	value,
		UInt32	size
	)			[inline, inherited]

Definition at line 613 of file OSGBinaryDataHandler.inl.

References osg::BinaryDataHandler::_networkOrder, and osg::osgntohll().

{
    get(value, size * sizeof(UInt64));

#if BYTE_ORDER == LITTLE_ENDIAN
    if(_networkOrder == true)
    {
        for(UInt32 i = 0; i < size; ++i)
        {
            value[i] = osgntohll(value[i]);
        }
    }
#endif
}

void osg::BinaryDataHandler::getValues	(	Int8 *	value,
		UInt32	size
	)			[inline, inherited]

Definition at line 629 of file OSGBinaryDataHandler.inl.

{
    get(value, size * sizeof(Int8));
}

void osg::BinaryDataHandler::getValues	(	Int16 *	value,
		UInt32	size
	)			[inline, inherited]

Definition at line 635 of file OSGBinaryDataHandler.inl.

References osg::BinaryDataHandler::_networkOrder, and osg::osgntohs().

{
    get(value, size * sizeof(Int16));

#if BYTE_ORDER == LITTLE_ENDIAN
    if(_networkOrder == true)
    {
        for(UInt32 i = 0; i < size; ++i)
        {
            value[i] = osgntohs(value[i]);
        }
    }
#endif
}

void osg::BinaryDataHandler::getValues	(	Int32 *	value,
		UInt32	size
	)			[inline, inherited]

Definition at line 651 of file OSGBinaryDataHandler.inl.

References osg::BinaryDataHandler::_networkOrder, and osg::osgntohl().

{
    get(value, size * sizeof(Int32));

#if BYTE_ORDER == LITTLE_ENDIAN
    if(_networkOrder == true)
    {
        for(UInt32 i = 0; i < size; ++i)
        {
            value[i] = osgntohl(value[i]);
        }
    }
#endif
}

void osg::BinaryDataHandler::getValues	(	Int64 *	value,
		UInt32	size
	)			[inline, inherited]

Definition at line 667 of file OSGBinaryDataHandler.inl.

References osg::BinaryDataHandler::_networkOrder, and osg::osgntohll().

{
    get(value, size * sizeof(Int64));

#if BYTE_ORDER == LITTLE_ENDIAN
    if(_networkOrder == true)
    {
        for(UInt32 i = 0; i < size; ++i)
        {
            value[i] = osgntohll(value[i]);
        }
    }
#endif
}

void osg::BinaryDataHandler::getValues	(	Real16 *	value,
		UInt32	size
	)			[inline, inherited]

Definition at line 683 of file OSGBinaryDataHandler.inl.

References osg::BinaryDataHandler::_networkOrder, osg::osgntohs(), and osg::Real16::setBits().

{
    get(value, size * sizeof(Real16));

#if BYTE_ORDER == LITTLE_ENDIAN
    if(_networkOrder == true)
    {
        UInt16 *intValue = reinterpret_cast<UInt16 *>(value);

        for(UInt32 i = 0; i < size; ++i)
        {
            value[i].setBits(osgntohs(intValue[i]));
        }
    }
#endif
}

void osg::BinaryDataHandler::getValues	(	Real32 *	value,
		UInt32	size
	)			[inline, inherited]

Definition at line 701 of file OSGBinaryDataHandler.inl.

References osg::BinaryDataHandler::_networkOrder, and osg::osgntohl().

{
    get(value, size * sizeof(Real32));

#if BYTE_ORDER == LITTLE_ENDIAN
    if(_networkOrder == true)
    {
        UInt32 *intValue = reinterpret_cast<UInt32 *>(value);

        for(UInt32 i = 0; i < size; ++i)
        {
            intValue[i] = osgntohl(intValue[i]);
        }
    }
#endif
}

void osg::BinaryDataHandler::getValues	(	Real64 *	value,
		UInt32	size
	)			[inline, inherited]

Definition at line 719 of file OSGBinaryDataHandler.inl.

References osg::BinaryDataHandler::_networkOrder, and osg::osgntohll().

{
    get(value, size * sizeof(Real64));

#if BYTE_ORDER == LITTLE_ENDIAN
    if(_networkOrder == true)
    {
        UInt64 *longValue = reinterpret_cast<UInt64 *>(value);

        for(UInt32 i = 0; i < size; ++i)
        {
            longValue[i] = osgntohll(longValue[i]);
        }
    }
#endif
}

void osg::BinaryDataHandler::getValues	(	Real128 *	value,
		UInt32	size
	)			[inline, inherited]

Definition at line 737 of file OSGBinaryDataHandler.inl.

References osg::BinaryDataHandler::_networkOrder, and osg::osgntohll().

{
    get(value, size * sizeof(UInt64) * 2);

#if BYTE_ORDER == LITTLE_ENDIAN
    if(_networkOrder == true)
    {
        UInt64 *longValue = reinterpret_cast<UInt64 *>(value);

        for(UInt32 i = 0; i < size; i += 2)
        {
            UInt64 l = longValue[i];
            longValue[i]     = osgntohll(longValue[i + 1]);
            longValue[i + 1] = osgntohll(longValue[l    ]);
        }
    }
#endif
}

void osg::BinaryDataHandler::getValues	(	std::string *	value,
		UInt32	size
	)			[inline, inherited]

Definition at line 757 of file OSGBinaryDataHandler.inl.

References osg::BinaryDataHandler::getValue().

{
    for(UInt32 i = 0; i < size; ++i)
    {
        getValue(value[i]);
    }
}

void BinaryDataHandler::forceCopy

(

void

)

[virtual, inherited]

always copy memory blocks befor write forceCopy must be called for all endpoints of this connection

Definition at line 260 of file OSGBinaryDataHandler.cpp.

References osg::BinaryDataHandler::_zeroCopyThreshold.

{
    _zeroCopyThreshold = 0;
}

void BinaryDataHandler::forceDirectIO

(

void

)

[virtual, inherited]

always read or write directly into or from memory blocks forceDirectIO must be called for all endpoints of this connection

Definition at line 268 of file OSGBinaryDataHandler.cpp.

References osg::BinaryDataHandler::_zeroCopyThreshold.

{
    _zeroCopyThreshold = 1;
}

void BinaryDataHandler::flush

(

void

)

[inherited]

Definition at line 239 of file OSGBinaryDataHandler.cpp.

References osg::BinaryDataHandler::_currentWriteBuffer, osg::BinaryDataHandler::_currentWriteBufferPos, osg::BinaryDataHandler::pushBuffer(), and osg::BinaryDataHandler::writeBufEnd().

Referenced by osg::SortFirstWindow::clientInit(), osg::ClusterNetwork::connectAllGroupToPoint(), osg::ClusterNetwork::connectAllPointToPoint(), osg::ClusterWindow::init(), osg::ClusterViewBuffer::send(), osg::RemoteAspect::sendSync(), osg::SortFirstWindow::serverInit(), osg::GroupMCastConnection::signal(), osg::ClusterServer::start(), and osg::BINWriter::write().

{
    if(_currentWriteBuffer != writeBufEnd())
    {
        // mark rest of buffer as empty
        _currentWriteBuffer->setDataSize(_currentWriteBufferPos);
        _currentWriteBuffer++;

        while(_currentWriteBuffer != writeBufEnd())
        {
            _currentWriteBuffer->setDataSize(0);
            _currentWriteBuffer++;
        }
    }

    pushBuffer();
}

void BinaryDataHandler::setNetworkOrder

(

bool

value

)

[inherited]

always copy memory blocks befor write forceCopy must be called for all endpoints of this connection

Definition at line 277 of file OSGBinaryDataHandler.cpp.

References osg::BinaryDataHandler::_networkOrder.

Referenced by osg::ClusterWindow::init(), and osg::ClusterServer::start().

{
    _networkOrder = value;    
}

bool BinaryDataHandler::getNetworkOrder

(

void

)

[inherited]

always copy memory blocks befor write forceCopy must be called for all endpoints of this connection

Definition at line 282 of file OSGBinaryDataHandler.cpp.

References osg::BinaryDataHandler::_networkOrder.

{
    return _networkOrder;
}

BinaryDataHandler::BuffersT::iterator osg::BinaryDataHandler::readBufBegin

(

void

)

[inline, protected, inherited]

Definition at line 812 of file OSGBinaryDataHandler.inl.

References osg::BinaryDataHandler::_readBuffers.

Referenced by osg::BinaryDataHandler::pullBuffer(), osg::PointSockPipeline::readBuffer(), osg::PointSockConnection::readBuffer(), osg::PointMCastConnection::readBuffer(), readBuffer(), and osg::BinaryDataHandler::readBuffer().

{
    return _readBuffers.begin();
}

BinaryDataHandler::BuffersT::iterator osg::BinaryDataHandler::readBufEnd

(

void

)

[inline, protected, inherited]

Definition at line 818 of file OSGBinaryDataHandler.inl.

References osg::BinaryDataHandler::_readBuffers.

Referenced by osg::BinaryDataHandler::get(), osg::BinaryDataHandler::isReadBufferEmpty(), osg::BinaryDataHandler::readBufAdd(), osg::BinaryDataHandler::readBufClear(), osg::BinaryDataHandler::readBuffer(), and selectChannel().

{
    return _readBuffers.end();
}

void BinaryDataHandler::readBufAdd	(	MemoryHandle	mem,
		UInt32	size,
		UInt32	dataSize = 0
	)			[protected, inherited]

Definition at line 290 of file OSGBinaryDataHandler.cpp.

References osg::BinaryDataHandler::_currentReadBuffer, osg::BinaryDataHandler::_readBuffers, and osg::BinaryDataHandler::readBufEnd().

Referenced by osg::BINLoader::BinaryFileHandler::BinaryFileHandler(), GroupSockConnection(), osg::PointSockConnection::PointSockConnection(), and setParams().

{
    MemoryBlock memBlock(mem, size, dataSize);

    _readBuffers.push_back(memBlock);

    _currentReadBuffer = readBufEnd();
}

void BinaryDataHandler::readBufClear

(

void

)

[protected, inherited]

Definition at line 301 of file OSGBinaryDataHandler.cpp.

References osg::BinaryDataHandler::_currentReadBuffer, osg::BinaryDataHandler::_readBuffers, and osg::BinaryDataHandler::readBufEnd().

Referenced by setParams().

{
    _readBuffers.clear();

    _currentReadBuffer=readBufEnd();
}

BinaryDataHandler::BuffersT::iterator osg::BinaryDataHandler::writeBufBegin

(

void

)

[inline, protected, inherited]

Definition at line 824 of file OSGBinaryDataHandler.inl.

References osg::BinaryDataHandler::_writeBuffers.

Referenced by osg::BinaryDataHandler::pushBuffer(), osg::BinaryDataHandler::writeBufAdd(), osg::PointSockConnection::writeBuffer(), osg::GroupSockPipeline::writeBuffer(), writeBuffer(), osg::GroupMCastConnection::writeBuffer(), and osg::BinaryDataHandler::writeBuffer().

{
    return _writeBuffers.begin();
}

BinaryDataHandler::BuffersT::iterator osg::BinaryDataHandler::writeBufEnd

(

void

)

[inline, protected, inherited]

Definition at line 830 of file OSGBinaryDataHandler.inl.

References osg::BinaryDataHandler::_writeBuffers.

Referenced by osg::BinaryDataHandler::flush(), osg::BinaryDataHandler::put(), osg::BinaryDataHandler::writeBufClear(), and osg::BinaryDataHandler::writeBuffer().

{
    return _writeBuffers.end();
}

void BinaryDataHandler::writeBufAdd	(	MemoryHandle	mem,
		UInt32	size,
		UInt32	dataSize = 0
	)			[protected, inherited]

Definition at line 311 of file OSGBinaryDataHandler.cpp.

References osg::BinaryDataHandler::_currentWriteBuffer, osg::BinaryDataHandler::_currentWriteBufferPos, osg::BinaryDataHandler::_writeBuffers, and osg::BinaryDataHandler::writeBufBegin().

Referenced by osg::BINWriter::BinaryFileHandler::BinaryFileHandler(), GroupSockConnection(), osg::PointSockConnection::PointSockConnection(), and setParams().

{
    MemoryBlock memBlock(mem, size, dataSize);

    _writeBuffers.push_back(memBlock);

    _currentWriteBuffer    = writeBufBegin();
    _currentWriteBufferPos = 0;
}

void BinaryDataHandler::writeBufClear

(

void

)

[protected, inherited]

Definition at line 323 of file OSGBinaryDataHandler.cpp.

References osg::BinaryDataHandler::_currentWriteBuffer, osg::BinaryDataHandler::_writeBuffers, and osg::BinaryDataHandler::writeBufEnd().

Referenced by setParams().

{
    _writeBuffers.clear();

    _currentWriteBuffer = writeBufEnd();
}

bool BinaryDataHandler::isReadBufferEmpty

(

void

)

[protected, inherited]

check for data in read buffer

Definition at line 431 of file OSGBinaryDataHandler.cpp.

References osg::BinaryDataHandler::_currentReadBuffer, osg::BinaryDataHandler::_zeroCopyThreshold, and osg::BinaryDataHandler::readBufEnd().

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

{
    if(_zeroCopyThreshold == 1)
        return true;
    if(_currentReadBuffer == readBufEnd())
        return true;
    return false;
}

---

Friends And Related Function Documentation

friend class PointSockConnection [friend]

Definition at line 160 of file OSGGroupSockConnection.h.

---

Member Data Documentation

StreamSocket osg::GroupSockConnection::_acceptSocket [protected]

Definition at line 140 of file OSGGroupSockConnection.h.

Referenced by acceptPoint(), bind(), GroupSockConnection(), and ~GroupSockConnection().

std::vector<StreamSocket> osg::GroupSockConnection::_sockets [protected]

Definition at line 141 of file OSGGroupSockConnection.h.

Referenced by acceptPoint(), osg::GroupMCastConnection::checkChannels(), connectPoint(), disconnect(), osg::GroupSockPipeline::initialize(), osg::GroupMCastConnection::initialize(), read(), readBuffer(), selectChannel(), signal(), wait(), write(), writeBuffer(), and ~GroupSockConnection().

std::vector<SocketAddress> osg::GroupSockConnection::_remoteAddresses [protected]

Definition at line 142 of file OSGGroupSockConnection.h.

Referenced by acceptPoint(), connectPoint(), and osg::GroupMCastConnection::initialize().

ChannelIndex osg::GroupSockConnection::_readIndex [protected]

Definition at line 143 of file OSGGroupSockConnection.h.

Referenced by acceptPoint(), connectPoint(), disconnect(), read(), readBuffer(), and selectChannel().

std::vector<UInt8> osg::GroupSockConnection::_socketReadBuffer [protected]

Definition at line 144 of file OSGGroupSockConnection.h.

Referenced by GroupSockConnection(), readBuffer(), and setParams().

std::vector<UInt8> osg::GroupSockConnection::_socketWriteBuffer [protected]

Definition at line 145 of file OSGGroupSockConnection.h.

Referenced by GroupSockConnection(), setParams(), osg::GroupSockPipeline::writeBuffer(), and writeBuffer().

ConnectionType osg::GroupSockConnection::_type [static, private]

Reimplemented in osg::GroupMCastConnection, and osg::GroupSockPipeline.

Definition at line 166 of file OSGGroupSockConnection.h.

Referenced by getType().

std::vector<UInt8> osg::GroupConnection::_selection [protected, inherited]

Definition at line 113 of file OSGGroupConnection.h.

Referenced by osg::GroupConnection::addSelection(), osg::GroupConnection::clearSelection(), osg::GroupConnection::delChannelIndex(), osg::GroupConnection::getChannelCount(), osg::GroupConnection::getSelectionCount(), osg::GroupConnection::newChannelIndex(), osg::GroupConnection::resetSelection(), selectChannel(), and osg::GroupConnection::subSelection().

std::string osg::GroupConnection::_destination [protected, inherited]

Definition at line 114 of file OSGGroupConnection.h.

Referenced by osg::GroupMCastConnection::disconnect(), osg::GroupConnection::getDestination(), osg::GroupMCastConnection::initialize(), and osg::GroupConnection::setDestination().

std::set<Channel> osg::GroupConnection::_disconnectedChannel [protected, inherited]

Definition at line 115 of file OSGGroupConnection.h.

std::string osg::Connection::_interface [protected, inherited]

Definition at line 139 of file OSGConnection.h.

Referenced by osg::Connection::getInterface(), and osg::Connection::setInterface().

BuffersT osg::BinaryDataHandler::_readBuffers [protected, inherited]

Definition at line 220 of file OSGBinaryDataHandler.h.

Referenced by osg::BinaryDataHandler::readBufAdd(), osg::BinaryDataHandler::readBufBegin(), osg::BinaryDataHandler::readBufClear(), and osg::BinaryDataHandler::readBufEnd().

BuffersT osg::BinaryDataHandler::_writeBuffers [protected, inherited]

Definition at line 221 of file OSGBinaryDataHandler.h.

Referenced by osg::BinaryDataHandler::writeBufAdd(), osg::BinaryDataHandler::writeBufBegin(), osg::BinaryDataHandler::writeBufClear(), and osg::BinaryDataHandler::writeBufEnd().

BuffersT osg::BinaryDataHandler::_zeroCopyBuffers [protected, inherited]

Definition at line 222 of file OSGBinaryDataHandler.h.

Referenced by osg::BinaryDataHandler::pushBuffer(), and osg::BinaryDataHandler::put().

UInt32 osg::BinaryDataHandler::_zeroCopyThreshold [protected, inherited]

Definition at line 223 of file OSGBinaryDataHandler.h.

Referenced by osg::BinaryDataHandler::forceCopy(), osg::BinaryDataHandler::forceDirectIO(), osg::BinaryDataHandler::get(), osg::BinaryDataHandler::isReadBufferEmpty(), osg::BinaryDataHandler::put(), osg::BinaryDataHandler::putAndFree(), and selectChannel().

FreeMemT osg::BinaryDataHandler::_freeMem [protected, inherited]

Definition at line 225 of file OSGBinaryDataHandler.h.

Referenced by osg::BinaryDataHandler::freeMem(), and osg::BinaryDataHandler::putAndFree().

BuffersT::iterator osg::BinaryDataHandler::_currentReadBuffer [protected, inherited]

Definition at line 226 of file OSGBinaryDataHandler.h.

Referenced by osg::BinaryDataHandler::get(), osg::BinaryDataHandler::isReadBufferEmpty(), osg::BinaryDataHandler::pullBuffer(), osg::BinaryDataHandler::readBufAdd(), osg::BinaryDataHandler::readBufClear(), and selectChannel().

UInt32 osg::BinaryDataHandler::_currentReadBufferPos [protected, inherited]

Definition at line 227 of file OSGBinaryDataHandler.h.

Referenced by osg::BinaryDataHandler::get(), and osg::BinaryDataHandler::pullBuffer().

BuffersT::iterator osg::BinaryDataHandler::_currentWriteBuffer [protected, inherited]

Definition at line 228 of file OSGBinaryDataHandler.h.

Referenced by osg::BinaryDataHandler::flush(), osg::BinaryDataHandler::pushBuffer(), osg::BinaryDataHandler::put(), osg::BinaryDataHandler::writeBufAdd(), and osg::BinaryDataHandler::writeBufClear().

UInt32 osg::BinaryDataHandler::_currentWriteBufferPos [protected, inherited]

Definition at line 229 of file OSGBinaryDataHandler.h.

Referenced by osg::BinaryDataHandler::flush(), osg::BinaryDataHandler::pushBuffer(), osg::BinaryDataHandler::put(), and osg::BinaryDataHandler::writeBufAdd().

bool osg::BinaryDataHandler::_networkOrder [protected, inherited]

Definition at line 231 of file OSGBinaryDataHandler.h.

Referenced by osg::BinaryDataHandler::getNetworkOrder(), osg::BinaryDataHandler::getValues(), osg::BinaryDataHandler::putValues(), and osg::BinaryDataHandler::setNetworkOrder().

---

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

• OSGGroupSockConnection.h
• OSGGroupSockConnection.cpp