X-Git-Url: http://winboard.nl/cgi-bin?a=blobdiff_plain;f=io.c;h=6e9dde76808518e4abd6c1adcc3134ccb9b529c9;hb=de010509fa0e57ba955da6512c714fbff8606af3;hp=92d15181cdc77bdaaf99c36ef6bf3cd44252984e;hpb=a0f731f21d6aa26dbf7246039a1c66c2ade0533f;p=polyglot.git

diff --git a/io.c b/io.c
index 92d1518..6e9dde7 100644
--- a/io.c
+++ b/io.c
@@ -11,6 +11,7 @@
 #include <string.h>
 
 #include <sys/types.h>
+#include <sys/select.h>
 #include <unistd.h>
 
 #include "io.h"
@@ -63,6 +64,27 @@ void io_init(io_t * io) {
    ASSERT(io_is_ok(io));
 }
 
+// io_peek()
+
+bool io_peek(io_t * io){
+    fd_set set[1];
+    int fd_max;
+    int ret;
+    struct timeval tv;
+    tv.tv_sec=0;
+    tv.tv_usec=0;
+  
+    FD_ZERO(set);
+    FD_SET(io->in_fd,set);
+    fd_max=io->in_fd;
+    ret=select(fd_max+1,set,NULL,NULL,&tv);
+    if(ret>0){
+	return TRUE;
+    }else{
+	return FALSE;
+    }
+}
+
 // io_close()
 
 void io_close(io_t * io) {
@@ -71,7 +93,7 @@ void io_close(io_t * io) {
 
    ASSERT(io->out_fd>=0);
 
-   my_log("Adapter>%s: EOF\n",io->name);
+   my_log("Adapter->%s: EOF\n",io->name);
 
    if (close(io->out_fd) == -1) {
       my_fatal("io_close(): close(): %s\n",strerror(errno));