diff options
author | Fritz Elfert <felfert@to.com> | 1999-06-28 08:56:01 +0000 |
---|---|---|
committer | Fritz Elfert <felfert@to.com> | 1999-06-28 08:56:01 +0000 |
commit | 34b70b0b46e34a73308a4034cc9b1c70209b9eb4 (patch) | |
tree | 7abe8be40fde08828d3606e13c41435b2fc9a26c /lib/iowatch.cc | |
parent | 3d3be141551bb4622da1cb610e4f6f798dd1715e (diff) | |
download | plptools-34b70b0b46e34a73308a4034cc9b1c70209b9eb4.tar.gz plptools-34b70b0b46e34a73308a4034cc9b1c70209b9eb4.tar.bz2 plptools-34b70b0b46e34a73308a4034cc9b1c70209b9eb4.zip |
First import.
Diffstat (limited to 'lib/iowatch.cc')
-rw-r--r-- | lib/iowatch.cc | 77 |
1 files changed, 77 insertions, 0 deletions
diff --git a/lib/iowatch.cc b/lib/iowatch.cc new file mode 100644 index 0000000..15e8ecf --- /dev/null +++ b/lib/iowatch.cc @@ -0,0 +1,77 @@ +// +// PLP - An implementation of the PSION link protocol +// +// Copyright (C) 1999 Philip Proudman +// +// This program is free software; you can redistribute it and/or modify +// it under the terms of the GNU General Public License as published by +// the Free Software Foundation; either version 2 of the License, or +// (at your option) any later version. +// +// This program is distributed in the hope that it will be useful, +// but WITHOUT ANY WARRANTY; without even the implied warranty of +// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the +// GNU General Public License for more details. +// +// You should have received a copy of the GNU General Public License +// along with this program; if not, write to the Free Software +// Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA +// +// e-mail philip.proudman@btinternet.com + +#include <unistd.h> +#include <stdio.h> +#include <sys/time.h> +#include <sys/types.h> +#include <stream.h> +#include <memory.h> + +#include "bool.h" +#include "iowatch.h" + +IOWatch::IOWatch() { + num = 0; + io = new int [MAX_IO]; +} + +IOWatch::~IOWatch() { + delete [] io; +} + +void IOWatch::addIO(int a) { + int pos; + for (pos = 0; pos < num && a < io[pos]; pos++); + for (int i = num; i > pos; i--) io[i] = io[i-1]; + io[pos] = a; + num++; +} + +void IOWatch::remIO(int a) { + int pos; + for (pos = 0; pos < num && a != io[pos]; pos++); + if (pos != num) { + num--; + for (int i = pos; i <num; i++) io[i] = io[i+1]; + } +} + +bool IOWatch::watch(long secs, long usecs) { + if (num > 0) { + fd_set iop; + FD_ZERO(&iop); + for (int i=0; i<num; i++) { + FD_SET(io[i], &iop); + } + struct timeval t; + t.tv_usec = usecs; + t.tv_sec = secs; + return select(io[0]+1, &iop, NULL, NULL, &t); + } + else { + sleep(secs); + usleep(usecs); + } + return false; +} + + |