Poll.hpp

Go to the documentation of this file.

// ANNA - Anna is Not Nothingness Anymore                                                         //
//                                                                                                //
// (c) Copyright 2005-2015 Eduardo Ramos Testillano & Francisco Ruiz Rayo                         //
//                                                                                                //
// See project site at http://redmine.teslayout.com/projects/anna-suite                           //
// See accompanying file LICENSE or copy at http://www.teslayout.com/projects/public/anna.LICENSE //


#ifndef anna_comm_internal_Poll_hpp
#define anna_comm_internal_Poll_hpp

#include <unistd.h>
#include <sys/time.h>
#include <limits.h>

#include <anna/config/defines.hpp>
#include <anna/core/util/defines.hpp>
#include <anna/core/RuntimeException.hpp>
#include <anna/core/functions.hpp>

namespace anna {

namespace comm {

class Poll {
public:
  Poll() : a_ptrTimeout(NULL), a_minfd(INT_MAX), a_maxfd(0) {
    FD_ZERO(&a_fdmask);
    FD_ZERO(&a_fdset);
  }

  void setTimeout(const Millisecond &timeout) ;

  void waitMessage() noexcept(false);
  int fetch() ;
  bool isEmpty() const { return a_pollr <= 0; }
  void clear() { a_maxfd = 0; a_minfd = INT_MAX; FD_ZERO(&a_fdmask); FD_ZERO(&a_fdset);}
  void insert(const int fd) ;
  void erase(const int fd) ;

private:
  fd_set a_fdmask;
  fd_set a_fdset;
  timeval* a_ptrTimeout;
  int a_minfd;
  int a_maxfd;
  int a_pollr;
  int a_ifd;
  timeval a_timeout;

  static int select(const int maxfd, fd_set* fdset, timeval* timeout)
  noexcept(false) {
    int result;

    do {
      result = ::select(maxfd + 1, fdset, NULL, NULL, timeout);
    } while(result == -1 && errno == EINTR);

    if(result == -1) {
      int xerrno = errno;
      throw RuntimeException("Error en anna::comm::Poll::select", xerrno, ANNA_FILE_LOCATION);
    }

    return result;
  }

  static int min(const Millisecond &n1, const Millisecond &n2) { return (n1 < n2) ? n1 : n2; }
};

}
}

#endif