1 files changed, 115 insertions, 0 deletions
diff --git a/mit-pthreads/tests/test_select.c b/mit-pthreads/tests/test_select.c
new file mode 100644
index 00000000000..0401d77a666
--- /dev/null
+++ b/mit-pthreads/tests/test_select.c
@@ -0,0 +1,115 @@
+#include <pthread.h>
+#include <stdio.h>
+#ifndef ultrix
+#include <sys/fcntl.h>
+#else /* ultrix */
+#include <fcntl.h>
+#endif /* !ultrix */
+#include <sys/types.h>
+#include <sys/time.h>
+#ifdef hpux
+#include <sys/file.h>
+#endif /* hpux */
+#include <errno.h>
+#define NLOOPS 1000
+
+int ntouts = 0;
+
+void *
+bg_routine(void *arg)
+{
+  write(1,"bg routine running\n",19);
+  /*pthread_dump_state();*/
+  while (1) {
+    int n;
+    char dot;
+
+    dot = '.';
+    pthread_yield();
+    write(1,&dot,1);
+    pthread_yield();
+    n = NLOOPS;
+    while (n-- > 0)
+      pthread_yield();
+  }
+}
+
+void *
+fg_routine(void *arg)
+{
+  int flags, stat, nonblock_flag;
+  static struct timeval tout = { 0, 500000 };
+
+#if 0
+#if defined(hpux) || defined(__alpha)
+  nonblock_flag = O_NONBLOCK;
+#else
+  nonblock_flag = FNDELAY;
+#endif
+  printf("fg_routine running\n");
+  flags = fcntl(0, F_GETFL, 0);
+  printf("stdin flags b4 anything = %x\n", flags);
+  stat = fcntl(0, F_SETFL, flags | nonblock_flag);
+  if (stat < 0) {
+    printf("fcntl(%x) => %d\n", nonblock_flag, errno);
+    printf("could not set nonblocking i/o on stdin [oldf %x, stat %d]\n",
+	   flags, stat);
+    exit(1);
+  }
+  printf("stdin flags = 0x%x after turning on %x\n", flags, nonblock_flag);
+#endif
+  while (1) {
+    int n;
+    fd_set r;
+
+    FD_ZERO(&r);
+    FD_SET(0,&r);
+    printf("select>");
+    n = select(1, &r, (fd_set*)0, (fd_set*)0, (struct timeval *)0);
+    if (n < 0) {
+      perror ("select");
+      exit(1);
+    } else if (n > 0) {
+      int nb;
+      char buf[128];
+
+      printf("=> select returned: %d\n", n);
+      while ((nb = read(0, buf, sizeof(buf)-1)) >= 0) {
+	buf[nb] = '\0';
+	printf("read %d: |%s|\n", nb, buf);
+      }
+      printf("=> out of read loop: %d / %d\n", nb, errno);
+      if (nb < 0) {
+	if (errno != EWOULDBLOCK && errno != EAGAIN) {
+	  perror ("read");
+	  exit(1);
+	}
+      }
+    } else
+      ntouts++;
+  }
+}
+
+main(int argc, char **argv)
+{
+  pthread_t bg_thread, fg_thread;
+  int junk;
+
+  pthread_init();
+  setbuf(stdout,NULL);
+  setbuf(stderr,NULL);
+  if (argc > 1) {
+    if (pthread_create(&bg_thread, NULL, bg_routine, 0) < 0) {
+      printf("error: could not create bg thread\n");
+      exit(1);
+    }
+  }
+  if (pthread_create(&fg_thread, NULL, fg_routine, 0) < 0) {
+    printf("error: could not create fg thread\n");
+    exit(1);
+  }
+  printf("threads forked: bg=%lx fg=%lx\n", bg_thread, fg_thread);
+  /*pthread_dump_state();*/
+  printf("initial thread %lx joining fg...\n", pthread_self());
+  pthread_join(fg_thread, (void **)&junk);
+}