EvtSocketManager Class Reference

Public Member Functions
	EvtSocketManager (EvtSocketRecv *sock)
int	examine ()
std::vector< int > &	connected_socket_list ()
bool	connected (int fd, bool wreq=false)
bool	remove (int fd)

Private Attributes
int	m_maxfd
std::vector< int >	m_fd
EvtSocketRecv *	m_recv
int	m_sock
fd_set	m_rset
fd_set	m_wset
fd_set	m_allset

Detailed Description

Definition at line 21 of file EvtSocketManager.h.

Constructor & Destructor Documentation

EvtSocketManager()

EvtSocketManager

(

EvtSocketRecv *

sock

)

Definition at line 18 of file EvtSocketManager.cc.

{
  SocketRecv* sock = evtsock->sock();
 
  FD_ZERO(&m_allset);
  FD_SET(sock->sock(), &m_allset);
  m_maxfd = sock->sock();
  m_recv = evtsock;
  m_sock = sock->sock();
}

~EvtSocketManager()

~EvtSocketManager

(

)

Definition at line 29 of file EvtSocketManager.cc.

{
}

Member Function Documentation

connected()

bool connected	(	int	fd,
		bool	wreq = false
	)

Definition at line 74 of file EvtSocketManager.cc.

{
  if (!wreq) {
    if (FD_ISSET(fd, &m_rset))
      return true;
    else
      return false;
  } else {
    if (FD_ISSET(fd, &m_wset))
      return true;
    else
      return false;
  }
}

connected_socket_list()

vector< int > & connected_socket_list

(

)

Definition at line 69 of file EvtSocketManager.cc.

{
  return m_fd;
}

examine()

int examine

(

)

Definition at line 33 of file EvtSocketManager.cc.

{
  memcpy(&m_rset, &m_allset, sizeof(m_rset));
  memcpy(&m_wset, &m_allset, sizeof(m_wset));
  struct timeval timeout;
  timeout.tv_sec = 0; // 1sec
  timeout.tv_usec = 1000; // 1msec (in microsec)
  //  printf ( "EvtSocketManager: maxfd = %d, start select...\n", m_maxfd);
  //  int rc = select(m_maxfd+1, &m_rset, &m_wset, NULL, NULL );
  int rc = select(m_maxfd + 1, &m_rset, &m_wset, NULL, &timeout);
  //  printf ( "EvtSocketManager: select returned with %d\n", rc );
  if (rc < 0)
    perror("select");
  else if (rc == 0)   // timeout
    return -1;
 
  if (FD_ISSET(m_sock, &m_rset)) { // New connection request
    int fd  = (m_recv->sock())->accept();
    m_fd.push_back(fd);
    FD_SET(fd, &m_allset);
    if (fd > m_maxfd) m_maxfd = fd;
    /*
    struct sockaddr_in peername;
    socklen_t lname = sizeof (peername);
    int is = getpeername ( fd[0], (sockaddr*)&peername, &lname );
    struct hostent* dest = gethostbyaddr (
    (char*)&peername.sin_addr.s_addr, sizeof(unsigned int),AF_INET );
    tprintf ( "DQM_server : connected to host = %s (port %d); fd=%d\n",
        dest->h_name, ntohs(peername.sin_port), fd[0] );
    */
    return 0;
  } else { //
    return 1;
  }
}

remove()

bool remove

(

int

fd

)

Definition at line 89 of file EvtSocketManager.cc.

{
  FD_CLR(fd, &m_allset);
  shutdown(fd, SHUT_RDWR);
  close(fd);
  vector<int>::iterator pos = find(m_fd.begin(), m_fd.end(), fd);
  if (pos != m_fd.end()) {
    m_fd.erase(pos);
    return true;
  } else
    return false;
}

Member Data Documentation

m_allset

fd_set m_allset

private

Definition at line 42 of file EvtSocketManager.h.

m_fd

std::vector<int> m_fd

private

Definition at line 36 of file EvtSocketManager.h.

m_maxfd

int m_maxfd

private

Definition at line 35 of file EvtSocketManager.h.

m_recv

EvtSocketRecv* m_recv

private

Definition at line 38 of file EvtSocketManager.h.

m_rset

fd_set m_rset

private

Definition at line 40 of file EvtSocketManager.h.

m_sock

int m_sock

private

Definition at line 39 of file EvtSocketManager.h.

m_wset

fd_set m_wset

private

Definition at line 41 of file EvtSocketManager.h.

---

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

• daq/dataflow/include/EvtSocketManager.h
• daq/dataflow/src/EvtSocketManager.cc