Implementation of an IOChannel, over a Socket. More...

#include <Socket.h>

Inheritance diagram for nidas::core::Socket:

[legend]

Classes
class	ConnectionThread

Public Member Functions
	Socket ()
	Constructor.

	Socket (nidas::util::Socket *sock)
	Constructor from a connected nidas::util::Socket.

	~Socket ()

Socket *	clone () const
	Derived classes must provide clone.

void	requestConnection (IOChannelRequester *service)

IOChannel *	connect ()

virtual bool	isNewInput () const
	Some IOChannels, namely FileSet, which opens successive files, need to indicate when a read is from the start of a new file.

void	setRequestType (enum McSocketRequest val)

enum McSocketRequest	getRequestType () const

void	setKeepAliveIdleSecs (int val)
	Do setKeepAliveIdleSecs(int secs) on underlying socket.

int	getKeepAliveIdleSecs () const
	Return getKeepAliveIdleSecs() on underlying socket.

std::list< nidas::util::Inet4NetworkInterface >	getInterfaces () const

void	setNonBlocking (bool val)
	Do setNonBlocking(val) on underlying socket.

bool	isNonBlocking () const
	Return isNonBlocking() of underlying socket.

size_t	getBufferSize () const throw ()
	Return suggested buffer length.

size_t	read (void *buf, size_t len)
	Do the actual hardware read.

size_t	write (const void *buf, size_t len)
	Do the actual hardware write.

size_t	write (const struct iovec *iov, int iovcnt)
	Do the actual hardware write.

void	close ()

int	getFd () const

const std::string &	getName () const

void	setName (const std::string &val)

nidas::util::Inet4Address	getRemoteInet4Address ()

void	setRemoteHostPort (const std::string &host, unsigned short port)
	Set the hostname and port of the remote connection.

const std::string &	getRemoteHost () const
	Get the name of the remote host.

unsigned short	getRemotePort () const

const std::string &	getRemoteUnixPath () const
	Get the name of the remote host.

void	setRemoteUnixPath (const std::string &unixPath)
	Set the pathname for the unix socket connection.

void	setRemoteSocketAddress (const nidas::util::SocketAddress &val)

const nidas::util::SocketAddress &	getRemoteSocketAddress ()
	This method does a DNS lookup of the value of getRemoteHost(), and so it can throw an UnknownHostException.

void	fromDOMElement (const xercesc::DOMElement *)

virtual int	getReconnectDelaySecs () const

virtual const ConnectionInfo &	getConnectionInfo () const
	What is the IP address of the host at the other end of the connection.

virtual void	setConnectionInfo (const ConnectionInfo &val)

virtual void	flush ()
	Default flush implementation does nothing.

virtual dsm_time_t	createFile (dsm_time_t t, bool exact)
	Request that an IOChannel open a new file, with a name based on a time.

virtual bool	writeNidasHeader () const
	Should the NIDAS header be written to this IOChannel? NIDAS headers are not written to DatagramSockets, because there is no guarantee they will get there.

virtual void	setDSMConfig (const DSMConfig *val)
	What DSM is this IOChannel connected to?

virtual const DSMConfig *	getDSMConfig () const
	What DSM is this IOChannel connected to? May be NULL.

virtual void	addSampleTag (const nidas::core::SampleTag *)
	The special NetcdfRPCChannel subclass needs a way to add a SampleTag to the IOChannel through a virtual base class.

virtual xercesc::DOMElement *	toDOMParent (xercesc::DOMElement *parent, bool complete) const
	Create a DOMElement and append it to the parent.

virtual xercesc::DOMElement *	toDOMElement (xercesc::DOMElement *node, bool complete) const
	Add my content into a DOMElement.

Static Public Member Functions
static IOChannel *	createSocket (const xercesc::DOMElement *)
	Create either a Socket or a McSocket from a DOMElement.

static IOChannel *	createIOChannel (const xercesc::DOMElement *node)

static const XMLCh *	getNamespaceURI ()

Protected Member Functions
	Socket (const Socket &x)
	Copy constructor.

Private Member Functions
Socket &	operator= (const Socket &)
	No assignment.

Private Attributes
nidas::util::auto_ptr< nidas::util::SocketAddress >	_remoteSockAddr

std::string	_remoteHost

unsigned short	_remotePort

std::string	_unixPath

nidas::util::Socket *	_nusocket

std::string	_name

IOChannelRequester *	_iochanRequester

ConnectionThread *	_connectionThread

bool	_firstRead

bool	_newInput

int	_keepAliveIdleSecs

bool	_nonBlocking

nidas::util::Mutex	_connectionMutex

enum McSocketRequest	_requestType

const DSMConfig *	_dsm

ConnectionInfo	_conInfo

Static Private Attributes
static XMLCh *	namespaceURI = 0

Detailed Description

Implementation of an IOChannel, over a Socket.

Constructor & Destructor Documentation

◆ Socket() [1/3]

Socket::Socket ( )

Constructor.

References setName().

Referenced by clone(), and createSocket().

◆ Socket() [2/3]

Socket::Socket ( nidas::util::Socket * sock )

Constructor from a connected nidas::util::Socket.

Parameters

sock	Pointer to the connected nidas::util::Socket. Socket will own the pointer and will delete it it its destructor.

References _keepAliveIdleSecs, _nonBlocking, _nusocket, _remoteHost, _remoteSockAddr, _unixPath, nidas::util::Socket::getKeepAliveIdleSecs(), nidas::core::getSample(), nidas::util::Socket::isNonBlocking(), setRemoteHostPort(), and setRemoteUnixPath().

◆ ~Socket()

Socket::~Socket ( )

References _connectionMutex, _connectionThread, _nusocket, close(), nidas::core::getSample(), nidas::core::Socket::ConnectionThread::interrupt(), and WLOG.

◆ Socket() [3/3]

Socket::Socket ( const Socket & x )

protected

Copy constructor.

References nidas::core::getSample().

Member Function Documentation

◆ addSampleTag()

void IOChannel::addSampleTag ( const nidas::core::SampleTag * )

virtualinherited

The special NetcdfRPCChannel subclass needs a way to add a SampleTag to the IOChannel through a virtual base class.

This method does nothing and serves no purpose except for that class.

◆ clone()

Socket * Socket::clone ( ) const

virtual

Derived classes must provide clone.

Implements nidas::core::IOChannel.

References Socket().

◆ close()

void Socket::close ( )

virtual

Exceptions

nidas::util::IOException

Implements nidas::core::IOChannel.

References _nusocket, and nidas::util::Socket::close().

Referenced by WriterThread::run(), and ~Socket().

◆ connect()

◆ createFile()

virtual dsm_time_t nidas::core::IOChannel::createFile	(	dsm_time_t	t,
		bool	exact )

inlinevirtualinherited

Request that an IOChannel open a new file, with a name based on a time.

This should be implemented by derived classes which write to disk files. Other derived classes (e.g. sockets) can just use this default implementation - basically ignoring the request.

Parameters

t	Time to use when creating file name.
exact	Use exact time when creating file name, else the time is adjusted to an even time interval.

Exceptions

nidas::util::IOException

Reimplemented in nidas::core::FileSet.

References nidas::core::getSample().

Referenced by nidas::core::IOStream::createFile(), and nidas::core::SampleOutputBase::createNextFile().

◆ createIOChannel()

IOChannel * IOChannel::createIOChannel ( const xercesc::DOMElement * node )

staticinherited

Exceptions

nidas::util::InvalidParameterException

References nidas::core::DOMObjectFactory::createObject(), createSocket(), and nidas::core::getSample().

Referenced by nidas::core::DSMService::fromDOMElement(), nidas::core::SampleOutputBase::fromDOMElement(), and nidas::dynld::SampleInputStream::fromDOMElement().

◆ createSocket()

IOChannel * Socket::createSocket ( const xercesc::DOMElement * node )

static

Create either a Socket or a McSocket from a DOMElement.

Exceptions

nidas::util::InvalidParameterException

References nidas::core::getSample(), and Socket().

Referenced by nidas::core::IOChannel::createIOChannel().

◆ flush()

virtual void nidas::core::IOChannel::flush ( )

inlinevirtualinherited

Default flush implementation does nothing.

Exceptions

nidas::util::IOException

Referenced by nidas::core::IOStream::flush().

◆ fromDOMElement()

void Socket::fromDOMElement ( const xercesc::DOMElement * node )

virtual

Exceptions

nidas::util::InvalidParameterException

Implements nidas::core::DOMable.

References getName(), nidas::core::getSample(), port, setKeepAliveIdleSecs(), setNonBlocking(), setRemoteHostPort(), setRemoteUnixPath(), and WLOG.

◆ getBufferSize()

size_t Socket::getBufferSize	(		)	const
throw	(	)

virtual

Return suggested buffer length.

Reimplemented from nidas::core::IOChannel.

References _nusocket, nidas::util::Socket::getReceiveBufferSize(), and nidas::core::getSample().

◆ getConnectionInfo()

virtual const ConnectionInfo & nidas::core::IOChannel::getConnectionInfo ( ) const

inlinevirtualinherited

What is the IP address of the host at the other end of the connection.

If this IOChannel is not a socket then return INADDR_ANY, using the default constructor of an Inet4Address. Socket subclasses should override this.

References nidas::core::IOChannel::_conInfo.

Referenced by nidas::dynld::SampleInputStream::setIOChannel().

◆ getDSMConfig()

virtual const DSMConfig * nidas::core::IOChannel::getDSMConfig ( ) const

inlinevirtualinherited

What DSM is this IOChannel connected to? May be NULL.

References nidas::core::IOChannel::_dsm.

Referenced by nidas::core::FileSet::setDir(), and nidas::core::FileSet::setFileName().

◆ getFd()

int nidas::core::Socket::getFd ( ) const

inlinevirtual

Implements nidas::core::IOChannel.

References _nusocket, and nidas::util::Socket::getFd().

◆ getInterfaces()

std::list< nidas::util::Inet4NetworkInterface > nidas::core::Socket::getInterfaces ( ) const

inline

Exceptions

nidas::util::IOException

References _nusocket, and nidas::util::Socket::getInterfaces().

◆ getKeepAliveIdleSecs()

int nidas::core::Socket::getKeepAliveIdleSecs ( ) const

inline

Return getKeepAliveIdleSecs() on underlying socket.

Exceptions

nidas::util::IOException

References _keepAliveIdleSecs, _nusocket, and nidas::util::Socket::getKeepAliveIdleSecs().

◆ getName()

const std::string & nidas::core::Socket::getName ( ) const

inlinevirtual

Implements nidas::core::IOChannel.

References _name.

Referenced by fromDOMElement(), nidas::core::ServerSocket::fromDOMElement(), requestConnection(), and nidas::core::Socket::ConnectionThread::run().

◆ getNamespaceURI()

static const XMLCh * nidas::core::DOMable::getNamespaceURI ( )

inlinestaticinherited

References nidas::core::DOMable::namespaceURI.

◆ getReconnectDelaySecs()

virtual int nidas::core::IOChannel::getReconnectDelaySecs ( ) const

inlinevirtualinherited

Reimplemented in nidas::core::FileSet.

Referenced by nidas::core::SampleOutputBase::getReconnectDelaySecs().

◆ getRemoteHost()

const std::string & nidas::core::Socket::getRemoteHost ( ) const

inline

Get the name of the remote host.

References _remoteHost.

◆ getRemoteInet4Address()

n_u::Inet4Address Socket::getRemoteInet4Address ( )

References getRemoteSocketAddress(), and LOG_WARNING.

◆ getRemotePort()

unsigned short nidas::core::Socket::getRemotePort ( ) const

inline

References _remotePort.

◆ getRemoteSocketAddress()

const n_u::SocketAddress & Socket::getRemoteSocketAddress ( )

This method does a DNS lookup of the value of getRemoteHost(), and so it can throw an UnknownHostException.

This is different behaviour from the the nidas::util::Socket::getRemoteSocketAddress() method, which does not throw an exception.

Exceptions

nidas::util::UnknownHostException

References _remoteHost, _remotePort, _remoteSockAddr, getRemoteUnixPath(), nidas::core::getSample(), setName(), and setRemoteSocketAddress().

Referenced by connect(), getRemoteInet4Address(), and WriterThread::run().

◆ getRemoteUnixPath()

const std::string & nidas::core::Socket::getRemoteUnixPath ( ) const

inline

Get the name of the remote host.

References _unixPath.

Referenced by getRemoteSocketAddress().

◆ getRequestType()

enum McSocketRequest nidas::core::Socket::getRequestType ( ) const

inlinevirtual

Reimplemented from nidas::core::IOChannel.

References _requestType.

◆ isNewInput()

virtual bool nidas::core::Socket::isNewInput ( ) const

inlinevirtual

Some IOChannels, namely FileSet, which opens successive files, need to indicate when a read is from the start of a new file.

This method is used by code which may need to do special things at the beginning of a file, like read a SampleInputHeader.

Reimplemented from nidas::core::IOChannel.

References _newInput.

◆ isNonBlocking()

bool nidas::core::Socket::isNonBlocking ( ) const

inlinevirtual

Return isNonBlocking() of underlying socket.

Exceptions

nidas::util::IOException

Implements nidas::core::IOChannel.

References _nonBlocking, _nusocket, and nidas::util::Socket::isNonBlocking().

◆ operator=()

Socket & nidas::core::Socket::operator= ( const Socket & )

private

No assignment.

◆ read()

size_t nidas::core::Socket::read	(	void *	buf,
		size_t	len )

inlinevirtual

Do the actual hardware read.

Exceptions

nidas::util::IOException

Implements nidas::core::IOChannel.

References _firstRead, _newInput, _nusocket, len, and nidas::util::Socket::recv().

◆ requestConnection()

void Socket::requestConnection ( IOChannelRequester * service )

virtual

Exceptions

nidas::util::IOException

Implements nidas::core::IOChannel.

References _connectionMutex, _connectionThread, _iochanRequester, getName(), nidas::core::getSample(), and nidas::util::Thread::start().

◆ setConnectionInfo()

virtual void nidas::core::IOChannel::setConnectionInfo ( const ConnectionInfo & val )

inlinevirtualinherited

References nidas::core::IOChannel::_conInfo, and nidas::core::getSample().

Referenced by connect().

◆ setDSMConfig()

virtual void nidas::core::IOChannel::setDSMConfig ( const DSMConfig * val )

inlinevirtualinherited

What DSM is this IOChannel connected to?

References nidas::core::IOChannel::_dsm, and nidas::core::getSample().

Referenced by nidas::core::SampleOutputBase::SampleOutputBase(), and nidas::core::SampleOutputBase::setIOChannel().

◆ setKeepAliveIdleSecs()

void nidas::core::Socket::setKeepAliveIdleSecs ( int val )

inline

Do setKeepAliveIdleSecs(int secs) on underlying socket.

Exceptions

nidas::util::IOException

References _keepAliveIdleSecs, _nusocket, nidas::core::getSample(), and nidas::util::Socket::setKeepAliveIdleSecs().

Referenced by fromDOMElement(), and nidas::core::ServerSocket::fromDOMElement().

◆ setName()

void nidas::core::Socket::setName ( const std::string & val )

inlinevirtual

Implements nidas::core::IOChannel.

References _name, and nidas::core::getSample().

Referenced by connect(), nidas::core::ServerSocket::fromDOMElement(), getRemoteSocketAddress(), and Socket().

◆ setNonBlocking()

void nidas::core::Socket::setNonBlocking ( bool val )

inlinevirtual

Do setNonBlocking(val) on underlying socket.

Exceptions

nidas::util::IOException

Implements nidas::core::IOChannel.

References _nonBlocking, _nusocket, nidas::core::getSample(), and nidas::util::Socket::setNonBlocking().

Referenced by fromDOMElement(), nidas::core::ServerSocket::fromDOMElement(), and WriterThread::run().

◆ setRemoteHostPort()

void Socket::setRemoteHostPort	(	const std::string &	host,
		unsigned short	port )

Set the hostname and port of the remote connection.

This method does not try to do a DNS host lookup. The DNS lookup will be done at connect time.

References _remoteHost, _remotePort, nidas::core::getSample(), and port.

Referenced by fromDOMElement(), and Socket().

◆ setRemoteSocketAddress()

void Socket::setRemoteSocketAddress ( const nidas::util::SocketAddress & val )

References _remoteSockAddr.

Referenced by getRemoteSocketAddress().

◆ setRemoteUnixPath()

void Socket::setRemoteUnixPath ( const std::string & unixPath )

Set the pathname for the unix socket connection.

References _unixPath, and nidas::core::getSample().

Referenced by fromDOMElement(), and Socket().

◆ setRequestType()

void nidas::core::Socket::setRequestType ( enum McSocketRequest val )

inlinevirtual

Reimplemented from nidas::core::IOChannel.

References _requestType, and nidas::core::getSample().

◆ toDOMElement()

xercesc::DOMElement * DOMable::toDOMElement	(	xercesc::DOMElement *	node,
		bool	complete ) const

virtualinherited

Add my content into a DOMElement.

Exceptions

xercesc::DOMException

Reimplemented in nidas::core::DSMConfig, nidas::core::DSMSensor, nidas::core::Project, nidas::core::SampleTag, nidas::core::Site, nidas::core::ServerSocket, and nidas::core::Variable.

Referenced by nidas::core::ServerSocket::toDOMParent().

◆ toDOMParent()

xercesc::DOMElement * DOMable::toDOMParent	(	xercesc::DOMElement *	parent,
		bool	complete ) const

virtualinherited

Create a DOMElement and append it to the parent.

Exceptions

xercesc::DOMException

Reimplemented in nidas::core::DSMConfig, nidas::core::DSMSensor, nidas::core::Project, nidas::core::SampleTag, nidas::core::Site, nidas::core::ServerSocket, and nidas::core::Variable.

◆ write() [1/2]

size_t nidas::core::Socket::write	(	const struct iovec *	iov,
		int	iovcnt )

inlinevirtual

Do the actual hardware write.

Exceptions

nidas::util::IOException

Implements nidas::core::IOChannel.

References _nusocket, nidas::core::getSample(), and nidas::util::Socket::send().

◆ write() [2/2]

size_t nidas::core::Socket::write	(	const void *	buf,
		size_t	len )

inlinevirtual

Do the actual hardware write.

Exceptions

nidas::util::IOException

Implements nidas::core::IOChannel.

References _nusocket, nidas::util::UTime::format(), len, and nidas::util::Socket::send().

◆ writeNidasHeader()

virtual bool nidas::core::IOChannel::writeNidasHeader ( ) const

inlinevirtualinherited

Should the NIDAS header be written to this IOChannel? NIDAS headers are not written to DatagramSockets, because there is no guarantee they will get there.

Reimplemented in nidas::core::DatagramSocket.

Referenced by nidas::dynld::SampleInputStream::setIOChannel().

Member Data Documentation

◆ _conInfo

ConnectionInfo nidas::core::IOChannel::_conInfo

privateinherited

Referenced by nidas::core::IOChannel::getConnectionInfo(), and nidas::core::IOChannel::setConnectionInfo().

◆ _connectionMutex

nidas::util::Mutex nidas::core::Socket::_connectionMutex

private

Referenced by requestConnection(), and ~Socket().

◆ _connectionThread

ConnectionThread* nidas::core::Socket::_connectionThread

private

Referenced by requestConnection(), and ~Socket().

◆ _dsm

const DSMConfig* nidas::core::IOChannel::_dsm

privateinherited

Referenced by nidas::core::IOChannel::getDSMConfig(), nidas::core::IOChannel::operator=(), and nidas::core::IOChannel::setDSMConfig().

◆ _firstRead

bool nidas::core::Socket::_firstRead

private

Referenced by connect(), and read().

◆ _iochanRequester

IOChannelRequester* nidas::core::Socket::_iochanRequester

private

Referenced by requestConnection().

◆ _keepAliveIdleSecs

int nidas::core::Socket::_keepAliveIdleSecs

private

Referenced by connect(), getKeepAliveIdleSecs(), setKeepAliveIdleSecs(), and Socket().

◆ _name

std::string nidas::core::Socket::_name

private

Referenced by getName(), and setName().

◆ _newInput

bool nidas::core::Socket::_newInput

private

Referenced by connect(), isNewInput(), and read().

◆ _nonBlocking

bool nidas::core::Socket::_nonBlocking

private

Referenced by connect(), isNonBlocking(), setNonBlocking(), and Socket().

◆ _nusocket

nidas::util::Socket* nidas::core::Socket::_nusocket

private

Referenced by close(), connect(), getBufferSize(), getFd(), getInterfaces(), getKeepAliveIdleSecs(), isNonBlocking(), read(), setKeepAliveIdleSecs(), setNonBlocking(), Socket(), write(), write(), and ~Socket().

◆ _remoteHost

std::string nidas::core::Socket::_remoteHost

private

Referenced by getRemoteHost(), getRemoteSocketAddress(), setRemoteHostPort(), and Socket().

◆ _remotePort

unsigned short nidas::core::Socket::_remotePort

private

Referenced by getRemotePort(), getRemoteSocketAddress(), and setRemoteHostPort().

◆ _remoteSockAddr

nidas::util::auto_ptr<nidas::util::SocketAddress> nidas::core::Socket::_remoteSockAddr

private

Referenced by getRemoteSocketAddress(), setRemoteSocketAddress(), and Socket().

◆ _requestType

enum McSocketRequest nidas::core::Socket::_requestType

private

Referenced by getRequestType(), and setRequestType().

◆ _unixPath

std::string nidas::core::Socket::_unixPath

private

Referenced by getRemoteUnixPath(), setRemoteUnixPath(), and Socket().

◆ namespaceURI

XMLCh * DOMable::namespaceURI = 0

staticprivateinherited

Referenced by nidas::core::DOMable::getNamespaceURI().

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

nidas/core/Socket.h
nidas/core/Socket.cc

Classes

Public Member Functions

Static Public Member Functions

Protected Member Functions

Private Member Functions

Private Attributes

Static Private Attributes

Detailed Description

Constructor & Destructor Documentation

◆ Socket() [1/3]

◆ Socket() [2/3]

◆ ~Socket()

◆ Socket() [3/3]

Member Function Documentation

◆ addSampleTag()

◆ clone()

◆ close()

◆ connect()

◆ createFile()

◆ createIOChannel()

◆ createSocket()

◆ flush()

◆ fromDOMElement()

◆ getBufferSize()

◆ getConnectionInfo()

◆ getDSMConfig()

◆ getFd()

◆ getInterfaces()

◆ getKeepAliveIdleSecs()

◆ getName()

◆ getNamespaceURI()

◆ getReconnectDelaySecs()

◆ getRemoteHost()

◆ getRemoteInet4Address()

◆ getRemotePort()

◆ getRemoteSocketAddress()

◆ getRemoteUnixPath()

◆ getRequestType()

◆ isNewInput()

◆ isNonBlocking()

◆ operator=()

◆ read()

◆ requestConnection()

◆ setConnectionInfo()

◆ setDSMConfig()

◆ setKeepAliveIdleSecs()

◆ setName()

◆ setNonBlocking()

◆ setRemoteHostPort()

◆ setRemoteSocketAddress()

◆ setRemoteUnixPath()

◆ setRequestType()

◆ toDOMElement()

◆ toDOMParent()

◆ write() [1/2]

◆ write() [2/2]

◆ writeNidasHeader()

Member Data Documentation

◆ _conInfo

◆ _connectionMutex

◆ _connectionThread

◆ _dsm

◆ _firstRead

◆ _iochanRequester

◆ _keepAliveIdleSecs

◆ _name

◆ _newInput

◆ _nonBlocking

◆ _nusocket

◆ _remoteHost

◆ _remotePort

◆ _remoteSockAddr

◆ _requestType

◆ _unixPath

◆ namespaceURI