osg::PointSockPipeline Class Reference
[Network]

#include <OSGPointSockPipeline.h>

Inheritance diagram for osg::PointSockPipeline:

List of all members.

Public Types
public types
typedef Int32	Channel
Public Member Functions
Constructors
	PointSockPipeline (void)
virtual	~PointSockPipeline (void)
type info
virtual const ConnectionType *	getType (void)
connection
virtual Channel	connectGroup (const std::string &address, Time timeout=-1)
virtual void	disconnect (void)
virtual Channel	acceptGroup (Time timeout=-1)
channel handling
virtual Channel	selectChannel (Time timeout=-1) throw (ReadError)
connection
virtual Channel	connectPoint (const std::string &address, Time timeout=-1)
virtual Channel	acceptPoint (Time timeout=-1)
virtual std::string	bind (const std::string &interf)
synchronisation
virtual bool	wait (Time timeout) throw (ReadError )
virtual void	signal (void) throw (WriteError)
params
virtual void	setParams (const std::string &params)
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 PointConnection *	create (void)
	create conneciton
Protected Types
typedef std::vector< MemoryBlock >	BuffersT
typedef std::list< MemoryHandle >	FreeMemT
Protected Member Functions
IO Implementation
virtual void	read (MemoryHandle mem, UInt32 size)
virtual void	readBuffer (void)
IO Implementation
virtual void	write (MemoryHandle mem, UInt32 size)
virtual void	writeBuffer (void)
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	_next
StreamSocket	_prev
bool	_last
bool	_initialized
members
StreamSocket	_acceptSocket
StreamSocket	_socket
SocketAddress	_remoteAddress
std::vector< UInt8 >	_socketReadBuffer
std::vector< UInt8 >	_socketWriteBuffer
members
bool	_pointToPoint
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 PointSockConnection	Inherited
Private Member Functions
	PointSockPipeline (const PointSockPipeline &source)
PointSockPipeline &	operator= (const PointSockPipeline &source)
private helpers
void	initialize (void)
Static Private Attributes
static type
static ConnectionType	_type

---

Detailed Description

Definition at line 62 of file OSGPointSockPipeline.h.

---

Member Typedef Documentation

typedef PointSockConnection osg::PointSockPipeline::Inherited [private]

Reimplemented from osg::PointSockConnection.

Definition at line 147 of file OSGPointSockPipeline.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

PointSockPipeline::PointSockPipeline

(

void

)

Constructor

Definition at line 69 of file OSGPointSockPipeline.cpp.

References _next, _prev, and osg::StreamSocket::open().

Referenced by create().

                                    :
    Inherited(),
    _initialized(false)
{
    _prev.open();
    _next.open();
}

PointSockPipeline::~PointSockPipeline

(

void

)

[virtual]

Destructor

Definition at line 79 of file OSGPointSockPipeline.cpp.

References _next, _prev, and osg::StreamSocket::close().

{
    _prev.close();
    _next.close();
}

osg::PointSockPipeline::PointSockPipeline

(

const PointSockPipeline &

source

)

[private]

---

Member Function Documentation

const ConnectionType * PointSockPipeline::getType

(

void

)

[virtual]

get connection type

Reimplemented from osg::PointSockConnection.

Definition at line 87 of file OSGPointSockPipeline.cpp.

References _type.

{
    return &_type;
}

Connection::Channel PointSockPipeline::connectGroup	(	const std::string &	address,
		Time	timeout = -1
	)			[virtual]

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

Reimplemented from osg::PointSockConnection.

Definition at line 98 of file OSGPointSockPipeline.cpp.

References osg::PointSockConnection::connectGroup().

{
    Channel channel = Inherited::connectGroup(address,timeout);
    return channel;
}

void PointSockPipeline::disconnect

(

void

)

[virtual]

disconnect the given channel

Reimplemented from osg::PointSockConnection.

Definition at line 108 of file OSGPointSockPipeline.cpp.

References osg::PointSockConnection::_socket, and osg::StreamSocket::close().

{
    _socket.close();
}

Connection::Channel PointSockPipeline::acceptGroup

(

Time

timeout = -1

)

[virtual]

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

Reimplemented from osg::PointSockConnection.

Definition at line 116 of file OSGPointSockPipeline.cpp.

References osg::PointSockConnection::acceptGroup().

{
    Channel channel = Inherited::acceptGroup(timeout);
    return channel;
}

Connection::Channel PointSockPipeline::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

Reimplemented from osg::PointSockConnection.

Definition at line 128 of file OSGPointSockPipeline.cpp.

References _initialized, _prev, initialize(), osg::Socket::waitReadable(), and osg::Exception::what().

{
    if(!_initialized)
        initialize();
    try
    {
        if(_prev.waitReadable(timeout))
            return 0;
    }
    catch(SocketError &e)
    {
        throw ReadError(e.what());
    }
    return -1;
}

ConnectionType PointSockPipeline::_type & PointSockPipeline::create

(

void

)

[static]

Reimplemented from osg::PointSockConnection.

Definition at line 150 of file OSGPointSockPipeline.cpp.

References PointSockPipeline().

{
    return new PointSockPipeline();
}

void PointSockPipeline::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::PointSockConnection.

Definition at line 165 of file OSGPointSockPipeline.cpp.

References _initialized, _last, _next, _prev, initialize(), osg::Socket::recv(), and osg::Socket::send().

{
    int len;

    if(!_initialized)
        initialize();
    // read data
    len=_prev.recv(mem,size);
    if(len==0)
    {
        throw ReadError("read got 0 bytes!");
    }
    // send to next in chain
    if(!_last)
        _next.send(mem,size);
}

void PointSockPipeline::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::PointSockConnection.

Definition at line 189 of file OSGPointSockPipeline.cpp.

References _initialized, _last, _next, _prev, osg::PointSockConnection::_socketReadBuffer, initialize(), osg::osgntohl(), osg::BinaryDataHandler::readBufBegin(), osg::Socket::recv(), and osg::Socket::send().

{
    int size;
    int len;

    if(!_initialized)
        initialize();

    // read buffer header
    len=_prev.recv(&_socketReadBuffer[0],sizeof(SocketBufferHeader));
    if(len==0)
        throw ReadError("peek got 0 bytes!");
    // read remaining data
    size=osgntohl(((SocketBufferHeader*)&_socketReadBuffer[0])->size);
    len=_prev.recv(&_socketReadBuffer[sizeof(SocketBufferHeader)],
                   size);
    if(len==0)
        throw ReadError("read got 0 bytes!");
    readBufBegin()->setDataSize(size);
    // send to next in chain
    if(!_last)
        _next.send(&_socketReadBuffer[0],
                   sizeof(SocketBufferHeader)+size);
}    

void PointSockPipeline::initialize

(

void

)

[private]

initialize pipeline

Definition at line 219 of file OSGPointSockPipeline.cpp.

References _initialized, _last, _next, _prev, osg::PointSockConnection::_socket, osg::StreamSocket::accept(), osg::Socket::bind(), osg::StreamSocket::close(), osg::Socket::connect(), osg::Socket::getAddress(), osg::Connection::getInterface(), osg::SocketAddress::getPort(), osg::BinaryMessage::getString(), osg::BinaryMessage::getUInt32(), osg::Socket::listen(), osg::StreamSocket::open(), osg::osgGetHostname(), osg::BinaryMessage::putString(), osg::BinaryMessage::putUInt32(), osg::Socket::recv(), and osg::Socket::send().

Referenced by read(), readBuffer(), and selectChannel().

{
    BinaryMessage message;
    StreamSocket  sock;
    UInt32        nextPort;
    std::string   nextHost;
    UInt32        len;
    char          localhost[256];
    std::string   interf;

    // get local host name
    osgGetHostname(localhost,255);
    if(!getInterface().empty())
        interf = getInterface();
    else
        interf = localhost;

    sock.open();
    sock.bind(SocketAddress(interf.c_str(),0));
    sock.listen();

    // send my own address
    message.putString(interf);
    message.putUInt32(sock.getAddress().getPort());
    _socket.send(message);
    // accept prev
    _prev = sock.accept();
    sock.close();

    len = _socket.recv(message);
    if(len == 0)
        throw ReadError("Channel closed\n");
    _last = message.getUInt32();
    if(!_last)
    {
        nextHost = message.getString();
        nextPort = message.getUInt32();
        for(;;)
        {
            try
            {
                _next.connect(SocketAddress(nextHost.c_str(),
                                            nextPort));
                break;
            }
            catch(...)
            {
            }
        }
    }

    _initialized = true;
}

PointSockPipeline& osg::PointSockPipeline::operator=

(

const PointSockPipeline &

source

)

[private]

Connection::Channel PointSockConnection::connectPoint	(	const std::string &	address,
		Time	timeout = -1
	)			[virtual, inherited]

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

Implements osg::Connection.

Definition at line 101 of file OSGPointSockConnection.cpp.

References osg::PointConnection::_pointToPoint, osg::PointSockConnection::_remoteAddress, osg::PointSockConnection::_socket, and osg::GroupSockConnection::connectSocket().

{
    StreamSocket socket;
    if(GroupSockConnection::connectSocket(socket,address,_remoteAddress,timeout))
    {
        _socket = socket;
        _pointToPoint = true;
        return true;
    }
    else
    {
        return false;
    }
}

Connection::Channel PointSockConnection::acceptPoint

(

Time

timeout = -1

)

[virtual, inherited]

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

Implements osg::Connection.

Definition at line 148 of file OSGPointSockConnection.cpp.

References osg::PointSockConnection::_acceptSocket, osg::PointConnection::_pointToPoint, osg::PointSockConnection::_remoteAddress, osg::PointSockConnection::_socket, and osg::GroupSockConnection::acceptSocket().

{
    if(GroupSockConnection::acceptSocket(_acceptSocket,_socket,_remoteAddress,timeout))
    {
        _pointToPoint = true;
        return 0;
    }
    else
    {
        return -1;
    }
}

std::string PointSockConnection::bind

(

const std::string &

address

)

[virtual, inherited]

bind the connection to a 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 183 of file OSGPointSockConnection.cpp.

References osg::PointSockConnection::_acceptSocket, osg::SocketAddress::ANY, 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;

    // 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);
    if(!getInterface().empty())
        _acceptSocket.bind(SocketAddress(getInterface().c_str(),port));
    else
        _acceptSocket.bind(SocketAddress(SocketAddress::ANY,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;
}

bool PointSockConnection::wait

(

Time

timeout

)

throw (ReadError ) [virtual, inherited]

wait for signal

Implements osg::PointConnection.

Reimplemented in osg::PointMCastConnection.

Definition at line 245 of file OSGPointSockConnection.cpp.

References osg::PointSockConnection::_socket, FFATAL, osg::osgntohl(), osg::Socket::recv(), osg::Socket::waitReadable(), and osg::Exception::what().

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

{
    UInt32 tag;
    try
    {
        if(!_socket.waitReadable(timeout))
            return false;
        if(!_socket.recv(&tag,sizeof(tag)))
            throw ReadError("Channel closed");
        tag = osgntohl(tag);
        if(tag != 314156)
        {
            FFATAL(("Stream out of sync in SockConnection\n"));
            throw ReadError("Stream out of sync");
        }
    }
    catch(SocketError &e)
    {
        throw ReadError(e.what());
    }
    return true;
}

void PointSockConnection::signal

(

void

)

throw (WriteError) [virtual, inherited]

send signal

Implements osg::PointConnection.

Definition at line 270 of file OSGPointSockConnection.cpp.

References osg::PointSockConnection::_socket, osg::osghtonl(), osg::Socket::send(), and osg::Exception::what().

{
    UInt32 tag=osghtonl(314156);
    try
    {
        _socket.send(&tag,sizeof(tag));
    }
    catch(SocketError &e)
    {
        throw ReadError(e.what());
    }
}

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

Write data to destinations

Parameters:

	mem	Pointer to data buffer
	size	Size of bytes to write

Reimplemented from osg::BinaryDataHandler.

Definition at line 347 of file OSGPointSockConnection.cpp.

References osg::PointSockConnection::_socket, and osg::Socket::send().

{
    _socket.send(mem,size);
}

void PointSockConnection::writeBuffer

(

void

)

[protected, virtual, inherited]

Write buffer

Write blocksize and data.

Reimplemented from osg::BinaryDataHandler.

Definition at line 357 of file OSGPointSockConnection.cpp.

References osg::PointSockConnection::_socket, osg::PointSockConnection::_socketWriteBuffer, osg::osghtonl(), osg::Socket::send(), and osg::BinaryDataHandler::writeBufBegin().

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

void Connection::setParams

(

const std::string &

params

)

[virtual, inherited]

set connections parameters, a comma separated list e.g. "TTL=255"

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

Definition at line 91 of file OSGConnection.cpp.

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

{
    // do nothing this is implemented in the derived classes e.g. OSGGroupMCastConnection.cpp
}

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(), osg::GroupSockConnection::bind(), 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::RenderNode::copyToBin(), osg::MField< FieldTypeT, fieldNameSpace >::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().

{
    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::RenderNode::copyFromBin(), osg::MField< FieldTypeT, fieldNameSpace >::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().

{
    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(), readBuffer(), osg::PointSockConnection::readBuffer(), osg::PointMCastConnection::readBuffer(), osg::GroupSockConnection::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 osg::GroupSockConnection::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(), osg::GroupSockConnection::GroupSockConnection(), osg::PointSockConnection::PointSockConnection(), and osg::GroupSockConnection::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 osg::GroupSockConnection::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(), osg::GroupSockConnection::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(), osg::GroupSockConnection::GroupSockConnection(), osg::PointSockConnection::PointSockConnection(), and osg::GroupSockConnection::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 osg::GroupSockConnection::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;
}

---

Member Data Documentation

StreamSocket osg::PointSockPipeline::_next [protected]

Definition at line 122 of file OSGPointSockPipeline.h.

Referenced by initialize(), PointSockPipeline(), read(), readBuffer(), and ~PointSockPipeline().

StreamSocket osg::PointSockPipeline::_prev [protected]

Definition at line 123 of file OSGPointSockPipeline.h.

Referenced by initialize(), PointSockPipeline(), read(), readBuffer(), selectChannel(), and ~PointSockPipeline().

bool osg::PointSockPipeline::_last [protected]

Definition at line 124 of file OSGPointSockPipeline.h.

Referenced by initialize(), read(), and readBuffer().

bool osg::PointSockPipeline::_initialized [protected]

Definition at line 125 of file OSGPointSockPipeline.h.

Referenced by initialize(), read(), readBuffer(), and selectChannel().

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

Reimplemented from osg::PointSockConnection.

Definition at line 143 of file OSGPointSockPipeline.h.

Referenced by getType().

StreamSocket osg::PointSockConnection::_acceptSocket [protected, inherited]

Definition at line 142 of file OSGPointSockConnection.h.

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

StreamSocket osg::PointSockConnection::_socket [protected, inherited]

Definition at line 143 of file OSGPointSockConnection.h.

Referenced by osg::PointSockConnection::acceptGroup(), osg::PointSockConnection::acceptPoint(), osg::PointSockConnection::connectGroup(), osg::PointSockConnection::connectPoint(), disconnect(), osg::PointSockConnection::disconnect(), osg::PointMCastConnection::disconnect(), initialize(), osg::PointMCastConnection::initialize(), osg::PointSockConnection::read(), osg::PointSockConnection::readBuffer(), osg::PointMCastConnection::recvQueue(), osg::PointSockConnection::selectChannel(), osg::PointSockConnection::signal(), osg::PointSockConnection::wait(), osg::PointSockConnection::write(), and osg::PointSockConnection::writeBuffer().

SocketAddress osg::PointSockConnection::_remoteAddress [protected, inherited]

Definition at line 144 of file OSGPointSockConnection.h.

Referenced by osg::PointSockConnection::acceptGroup(), osg::PointSockConnection::acceptPoint(), osg::PointSockConnection::connectGroup(), osg::PointSockConnection::connectPoint(), and osg::PointMCastConnection::initialize().

std::vector<UInt8> osg::PointSockConnection::_socketReadBuffer [protected, inherited]

Definition at line 145 of file OSGPointSockConnection.h.

Referenced by osg::PointSockConnection::PointSockConnection(), readBuffer(), and osg::PointSockConnection::readBuffer().

std::vector<UInt8> osg::PointSockConnection::_socketWriteBuffer [protected, inherited]

Definition at line 146 of file OSGPointSockConnection.h.

Referenced by osg::PointSockConnection::PointSockConnection(), and osg::PointSockConnection::writeBuffer().

bool osg::PointConnection::_pointToPoint [protected, inherited]

Definition at line 103 of file OSGPointConnection.h.

Referenced by osg::PointSockConnection::acceptGroup(), osg::PointSockConnection::acceptPoint(), osg::PointSockConnection::connectGroup(), osg::PointSockConnection::connectPoint(), osg::PointMCastConnection::read(), osg::PointMCastConnection::readBuffer(), osg::PointMCastConnection::selectChannel(), and osg::PointMCastConnection::wait().

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 osg::GroupSockConnection::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 osg::GroupSockConnection::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:

• OSGPointSockPipeline.h
• OSGPointSockPipeline.cpp