/Users/mourrain/Devel/mmx/basix/include/basix/posix_port.hpp

Go to the documentation of this file.

/******************************************************************************
* MODULE     : posix_port.hpp
* DESCRIPTION: Ports from file descriptors
* COPYRIGHT  : (C) 2010  Joris van der Hoeven
*******************************************************************************
* This software falls under the GNU general public license and comes WITHOUT
* ANY WARRANTY WHATSOEVER. See the file $TEXMACS_PATH/LICENSE for more details.
* If you don't have this file, write to the Free Software Foundation, Inc.,
* 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
******************************************************************************/

#ifndef __POSIX_PORT_HPP
#define __POSIX_PORT_HPP
#include <basix/port.hpp>
#include <basix/table.hpp>


namespace mmx {

/******************************************************************************
* The posix_port class
******************************************************************************/

class posix_port_rep: public port_rep {
protected:
  int    kind;
  int    fd;
  string buffer;
  nat    pos;
  bool   alive;

public:
  virtual void send (const char* s, nat n);
  virtual void feed ();
  virtual bool wait (int msecs);

  virtual inline bool is_output_port () { return (kind & 1) != 0; }
  virtual inline bool is_input_port () { return (kind & 2) != 0; }
  virtual inline bool busy () { feed (); return alive || pos < N(buffer); }
  virtual inline nat  can_write () { return alive? (nat) (-1): 0; }
  virtual inline nat  can_read () { feed (); return N(buffer) - pos; }
  virtual inline void write (const char* s, nat n) { send (s, n); }
  virtual inline void read (char* s, nat n) {
    while (pos + n > N(buffer)) feed ();
    mem_copy (s, inside (buffer, pos), n);
    pos += n; }

public:
  posix_port_rep (int kind2, int fd2);
  ~posix_port_rep ();
};

} // namespace mmx
#endif // __POSIX_PORT_HPP