27 #ifndef NIDAS_CORE_DATAGRAMSOCKET_H
28 #define NIDAS_CORE_DATAGRAMSOCKET_H
38 namespace nidas {
namespace core {
76 throw(nidas::util::IOException)
79 return std::list<nidas::util::Inet4NetworkInterface>();
105 size_t read(
void* buf,
size_t len) throw (nidas::util::IOException)
126 void close() throw (nidas::util::IOException)
165 throw(nidas::util::UnknownHostException);
177 void setPort(
unsigned short port);
193 throw(nidas::util::InvalidParameterException);
197 nidas::util::auto_ptr<nidas::util::SocketAddress>
_sockAddr;
std::string _host
Definition: DatagramSocket.h:199
const std::string & getUnixPath() const
Get the unix path name.
Definition: DatagramSocket.h:145
size_t write(const void *buf, size_t len)
Do the actual hardware write.
Definition: DatagramSocket.h:113
size_t recv(void *buf, size_t len, int flags=0)
Definition: Socket.h:1063
void send(const DatagramPacketBase &packet, int flags=0)
Definition: Socket.h:1058
bool isNonBlocking() const
Definition: Socket.h:1121
void close()
Definition: DatagramSocket.h:126
void setHostPort(const std::string &host, unsigned short port)
Set the hostname and port of the remote connection.
Definition: DatagramSocket.cc:125
int getFd() const
Definition: Socket.h:1031
An interface for a socket address.
Definition: SocketAddress.h:36
void setName(const std::string &val)
Definition: DatagramSocket.h:140
void setNonBlocking(bool val)
Do setNonBlocking(val) on underlying socket.
Definition: DatagramSocket.h:85
A socket for sending or receiving datagrams, either unicast, broadcast or multicast.
Definition: Socket.h:912
std::list< nidas::util::Inet4NetworkInterface > getInterfaces() const
Definition: DatagramSocket.h:75
int getFd() const
Definition: DatagramSocket.h:132
void requestConnection(IOChannelRequester *service)
After the IOChannel is configured, a user of IOChannel calls requestConnection to get things started...
Definition: DatagramSocket.cc:194
std::list< Inet4NetworkInterface > getInterfaces() const
Definition: Socket.h:1145
const nidas::util::SocketAddress & getSocketAddress()
Definition: DatagramSocket.cc:137
nidas::util::DatagramSocket * _nusocket
Definition: DatagramSocket.h:205
void close()
Definition: Socket.h:958
void setSocketAddress(const nidas::util::SocketAddress &val)
Set address for this socket.
Definition: DatagramSocket.cc:119
DatagramSocket & operator=(const DatagramSocket &rhs)
Definition: DatagramSocket.cc:63
const std::string & getHost() const
Get the name of the remote host.
Definition: DatagramSocket.h:182
A channel for Input or Output of data.
Definition: IOChannel.h:64
size_t getBufferSize() const
Return suggested buffer length.
Definition: DatagramSocket.cc:104
void fromDOMElement(const xercesc::DOMElement *)
Initialize myself from a xercesc::DOMElement.
Definition: DatagramSocket.cc:202
bool isNonBlocking() const
Return isNonBlocking() of underlying socket.
Definition: DatagramSocket.h:94
unsigned short getPort() const
Definition: DatagramSocket.h:187
Implementation of an IOChannel, over a DatagramSocket.
Definition: DatagramSocket.h:44
std::string _unixPath
Definition: DatagramSocket.h:203
std::string _name
Definition: DatagramSocket.h:207
bool isNewInput() const
Some IOChannels, namely FileSet, which opens successive files, need to indicate when a read is from t...
Definition: DatagramSocket.h:71
DatagramSocket * clone() const
Derived classes must provide clone.
Definition: DatagramSocket.cc:99
bool _nonBlocking
Definition: DatagramSocket.h:211
unsigned short _port
Definition: DatagramSocket.h:201
const std::string & getName() const
Definition: DatagramSocket.h:138
size_t read(void *buf, size_t len)
Do the actual hardware read.
Definition: DatagramSocket.h:105
int len
Definition: sing.cc:934
size_t write(const struct iovec *iov, int iovcnt)
Do the actual hardware write.
Definition: DatagramSocket.h:121
void setUnixPath(const std::string &unixPath)
Set the pathname for the unix socket connection.
Definition: DatagramSocket.cc:132
IOChannel * connect()
Establish a connection.
Definition: DatagramSocket.cc:161
Definition: IOException.h:37
static n_u::SerialPort port
Definition: sing.cc:68
~DatagramSocket()
Definition: DatagramSocket.cc:88
nidas::util::auto_ptr< nidas::util::SocketAddress > _sockAddr
Definition: DatagramSocket.h:197
DatagramSocket()
Constructor.
Definition: DatagramSocket.cc:37
bool writeNidasHeader() const
Should the NIDAS header be written to this IOChannel? NIDAS headers are not written to DatagramSocket...
Definition: DatagramSocket.h:73
void setNonBlocking(bool val)
Do fcntl system call to set O_NONBLOCK file descriptor flag on the socket.
Definition: Socket.h:1116
Interface for an object that requests connections to Inputs or Outputs.
Definition: IOChannel.h:54
void setPort(unsigned short port)
Set the the local port number.
IOChannelRequester * _iochanRequester
Definition: DatagramSocket.h:209