TCPServerSocket Class Reference

Inheritance diagram for TCPServerSocket:

Public Member Functions
	TCPServerSocket (const std::string &ip, unsigned short port)
void	setIP (const std::string &ip)
void	setPort (unsigned short port)
const std::string &	getIP () const
unsigned short	getPort () const
int	open (int nqueue=5)
int	open (const std::string &ip, unsigned short port, int nqueue=5)
TCPSocket	accept ()
int	get_fd () const
bool	select (int sec=-1, int usec=-1)
bool	select2 (int sec=-1, int usec=-1)
bool	close ()

Protected Attributes
int	m_fd

Private Attributes
std::string	m_ip
unsigned short	m_port

Detailed Description

Definition at line 20 of file TCPServerSocket.h.

Constructor & Destructor Documentation

TCPServerSocket() [1/2]

TCPServerSocket ( )

inline

Definition at line 23 of file TCPServerSocket.h.

      : m_ip(""), m_port(0) {}

TCPServerSocket() [2/2]

TCPServerSocket ( const std::string &  ip, unsigned short  port  )

inline

Definition at line 25 of file TCPServerSocket.h.

      : m_ip(ip), m_port(port) {}

~TCPServerSocket()

virtual ~TCPServerSocket ( )

inlinevirtual

Definition at line 27 of file TCPServerSocket.h.

{}

Member Function Documentation

accept()

TCPSocket accept

(

)

Definition at line 78 of file TCPServerSocket.cc.

{
  socklen_t len = sizeof(sockaddr_in);
  sockaddr_in addr;
  memset(&addr, 0, sizeof(sockaddr_in));
  addr.sin_family = AF_INET;
  addr.sin_addr.s_addr = INADDR_ANY;
  addr.sin_port = htons(m_port);
  int fd;
  errno = 0;
  while (true) {
    if ((fd = ::accept(m_fd, (sockaddr*) & (addr), &len)) == -1) {
      switch (errno) {
        case EINTR: continue;
        case EAGAIN: continue;
        default:
          perror("accept");
          throw (IOException("Fail to accept."));
      }
    }
    break;
  }
  TCPSocket s(fd);
  s.m_ip = inet_ntoa(addr.sin_addr);
  s.m_port = ntohs(addr.sin_port);
  return s;
}

close()

bool close ( )

inherited

Definition at line 90 of file FileDescriptor.cc.

{
  if (m_fd > 0) {
    if (::close(m_fd) != 0) {
      return false;
    }
  }
  m_fd = -1;
  return true;
}

get_fd()

int get_fd ( ) const

inherited

Definition at line 33 of file FileDescriptor.cc.

{
  return m_fd;
}

getIP()

const std::string & getIP ( ) const

inline

Definition at line 32 of file TCPServerSocket.h.

{ return m_ip; }

getPort()

unsigned short getPort ( ) const

inline

Definition at line 33 of file TCPServerSocket.h.

{ return m_port; }

open() [1/2]

int open	(	const std::string &	ip,
		unsigned short	port,
		int	nqueue = 5
	)

Definition at line 24 of file TCPServerSocket.cc.

{
  m_ip = ip;
  m_port = port;
  return open(nqueue);
}

open() [2/2]

int open

(

int

nqueue = 5

)

Definition at line 32 of file TCPServerSocket.cc.

{
  if (m_fd > 0) {
    throw (IOException("Socket is working already."));
  }
  sockaddr_in addr;
  memset(&addr, 0, sizeof(sockaddr_in));
  addr.sin_family = AF_INET;
  addr.sin_addr.s_addr = INADDR_ANY;
  addr.sin_port = htons(m_port);
 
  m_fd = socket(PF_INET, SOCK_STREAM, 0);
  if (m_fd == -1) {
    m_fd = 0;
    throw (IOException("Fail to create a server socket."));
  }
  int enable = 1;
  if (setsockopt(m_fd, SOL_SOCKET, SO_REUSEADDR, &enable, sizeof(enable)) == -1) {
    m_fd = 0;
    throw (IOException("Fail to set resue address for the socket."));
  }
  struct hostent* host = NULL;
  host = gethostbyname(m_ip.c_str());
  if (host == NULL) {
    unsigned long ip_address = inet_addr(m_ip.c_str());
    if ((signed long) ip_address < 0) {
      throw (std::exception());
      // throw (IOException("Wrong host name or ip")); // TODO which throw is the correct one?
    } else {
      host = gethostbyaddr((char*)&ip_address, sizeof(ip_address), AF_INET);
    }
  }
  if (host == NULL) {
    throw (IOException("Fail to get host ip: %s", m_ip.c_str()));
  }
  addr.sin_addr.s_addr = (*(unsigned long*)host->h_addr_list[0]);
 
  if (bind(m_fd, (const sockaddr*) & (addr), sizeof(sockaddr_in)) != 0) {
    throw (IOException("Fail to bind the socket. %s:%d", m_ip.c_str(), m_port));
  }
  if (listen(m_fd, nqueue) != 0) {
    throw (IOException("Fail to listen to the socket."));
  }
  return m_fd;
}

select()

bool select ( int  sec = -1, int  usec = -1  )

inherited

Definition at line 38 of file FileDescriptor.cc.

{
  if (m_fd <= 0) {
    return false;
  }
  fd_set fds;
  FD_ZERO(&fds);
  FD_SET(m_fd, &fds);
  int ret;
  if (sec >= 0 && usec >= 0) {
    timeval t = {sec, usec};
    ret = ::select(FD_SETSIZE, &fds, NULL, NULL, &t);
  } else {
    ret = ::select(FD_SETSIZE, &fds, NULL, NULL, NULL);
  }
  if (ret < 0) {
    perror("select");
    throw (IOException("Failed to select"));
  }
  if (FD_ISSET(m_fd, &fds)) {
    return true;
  } else {
    return false;
  }
}

select2()

bool select2 ( int  sec = -1, int  usec = -1  )

inherited

Definition at line 64 of file FileDescriptor.cc.

{
  if (m_fd <= 0) {
    return false;
  }
  fd_set fds;
  FD_ZERO(&fds);
  FD_SET(m_fd, &fds);
  int ret;
  if (sec >= 0 && usec >= 0) {
    timeval t = {sec, usec};
    ret = ::select(FD_SETSIZE, NULL, &fds, NULL, &t);
  } else {
    ret = ::select(FD_SETSIZE, NULL, &fds, NULL, NULL);
  }
  if (ret < 0) {
    perror("select");
    throw (IOException("Failed to select"));
  }
  if (FD_ISSET(m_fd, &fds)) {
    return true;
  } else {
    return false;
  }
}

setIP()

void setIP ( const std::string &  ip )

inline

Definition at line 30 of file TCPServerSocket.h.

{ m_ip = ip; }

setPort()

void setPort ( unsigned short  port )

inline

Definition at line 31 of file TCPServerSocket.h.

{ m_port = port; }

Member Data Documentation

m_fd

int m_fd

protectedinherited

Definition at line 31 of file FileDescriptor.h.

m_ip

std::string m_ip

private

Definition at line 39 of file TCPServerSocket.h.

m_port

unsigned short m_port

private

Definition at line 40 of file TCPServerSocket.h.

---

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

• daq/slc/system/include/TCPServerSocket.h
• daq/slc/system/src/TCPServerSocket.cc