Implement socket timeouts.

* lib.c (timeout_error_s): New symbol variable.
(obj_init): Intern timeout-error, init new variable.

* lib.h (timeout_error_s): Declared.

* socket.c (sock_timeout, sock_send_timeout,
sock_recv_timeout): New static functions.
(sock_load_init): Register sock-send-timeout and
sock-recv-timeout intrinsics.

* stream.c (stdio_maybe_read_error, stdio_maybe_error):
Convert EAGAIN into timeout_error_s.

* txr.1: Documented.

1 files changed, 8 insertions, 0 deletions

diff --git a/stream.c b/stream.c
index b98d7948..60247af7 100644
--- a/stream.c
+++ b/stream.c
@@ -431,6 +431,10 @@ static val stdio_maybe_read_error(val stream)
   if (ferror(h->f)) {
     val err = num(errno);
     h->err = err;
+#ifdef EAGAIN
+    if (errno == EAGAIN)
+      uw_throwf(timeout_error_s, lit("timed out reading ~a"), stream, nao);
+#endif
     uw_throwf(file_error_s, lit("error reading ~a: ~d/~s"),
               stream, err, errno_to_string(err), nao);
   }
@@ -446,6 +450,10 @@ static val stdio_maybe_error(val stream, val action)
   if (h->f == 0)
     uw_throwf(file_error_s, lit("error ~a ~a: file closed"), stream, action, nao);
   h->err = err;
+#ifdef EAGAIN
+  if (errno == EAGAIN)
+    uw_throwf(timeout_error_s, lit("timed out on ~a"), stream, nao);
+#endif
   uw_throwf(file_error_s, lit("error ~a ~a: ~d/~s"),
             stream, action, err, errno_to_string(err), nao);
 }