---

tty_win.H

Go to the documentation of this file.

/*
 * Copyright 1997, Brown University, Providence, RI.
 * 
 *                         All Rights Reserved
 * 
 * Permission to use, copy, modify, and distribute this software and its
 * documentation for any purpose other than its incorporation into a
 * commercial product is hereby granted without fee, provided that the
 * above copyright notice appear in all copies and that both that
 * copyright notice and this permission notice appear in supporting
 * documentation, and that the name of Brown University not be used in
 * advertising or publicity pertaining to distribution of the software
 * without specific, written prior permission.
 * 
 * BROWN UNIVERSITY DISCLAIMS ALL WARRANTIES WITH REGARD TO THIS SOFTWARE,
 * INCLUDING ALL IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR ANY
 * PARTICULAR PURPOSE.  IN NO EVENT SHALL BROWN UNIVERSITY BE LIABLE FOR
 * ANY SPECIAL, INDIRECT OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
 * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
 * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
 * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
 */
#ifndef TTY_WIN_HAS_BEEN_INCLUDED
#define TTY_WIN_HAS_BEEN_INCLUDED

#include "tty/tty.H"
#include <Winsock2.h>

class WIN_MANAGER : public FD_MANAGER {
  public:
      class tty_to_id {
         public :
          FD_EVENT    *_fd;
          tty_to_id() : _fd(0) { }
          tty_to_id(FD_EVENT *fd) : _fd(fd) { }
      int ready() {
             COMSTAT stat;
             DWORD eflags;
             if (ClearCommError((HANDLE)(_fd->fd()), &eflags, &stat)) {
                return (stat.cbInQue > 0);
             } else if (_fd->fd() == fileno(stdin)) {
                return 0;
//                return num_bytes_to_read(fileno(stdin)) > 0;
             } else {
                fd_set fd;
                struct timeval tm;

                FD_ZERO(&fd);
                FD_SET(_fd->fd(), &fd);
                tm.tv_usec = 0;
                tm.tv_sec = 0;
                if (select(_fd->fd()+1, &fd, NULL, NULL, &tm) != SOCKET_ERROR)
                   return FD_ISSET(_fd->fd(), &fd);
             }
             return 0;
      }
          int operator == (const tty_to_id &i)   { return _fd == i._fd; }
      };

  protected :
   ARRAY<tty_to_id> _ids;

  public :
   WIN_MANAGER() { }

   virtual void loop(int infinite=1){ do {
     for (int i=0; i<_ids.num(); i++) {
       if (_ids[i].ready())
     ((FD_EVENT *)_ids[i]._fd)->sample();
     }
     // dfk: adding this.. don't think timeouts are ever getting called on windows??
     for (int j=0; j<_timeouts.num(); j++) {
       _timeouts[j]->timeout();
     }
   } while (infinite);
   }
  
   virtual void add(FD_EVENT *fd)   { _ids += tty_to_id(fd); }
   virtual void rem(FD_EVENT *fd)   { if (_ids.contains(tty_to_id(fd)))
                                        _ids -= tty_to_id(fd); }

   virtual void add(FD_TIMEOUT *fd) { FD_MANAGER::add(fd);}
   virtual void rem(FD_TIMEOUT *fd) { FD_MANAGER::rem(fd);}
  
};

#endif

---