Extensive changes that _should_ fix the socket buffering problems,
[u/mdw/putty] / winnet.c
index 621c3ca..ee2fc3a 100644 (file)
--- a/winnet.c
+++ b/winnet.c
 #include <windows.h>
 #include <stdio.h>
 #include <stdlib.h>
+#include <assert.h>
 
 #define DEFINE_PLUG_METHOD_MACROS
 #include "putty.h"
 #include "network.h"
 #include "tree234.h"
 
-#define BUFFER_GRANULE  512
-
 struct Socket_tag {
     struct socket_function_table *fn;
     /* the above variable absolutely *must* be the first in this structure */
@@ -63,8 +62,12 @@ struct Socket_tag {
     SOCKET s;
     Plug plug;
     void *private_ptr;
-    struct buffer *head, *tail;
+    bufchain output_data;
     int writable;
+    int frozen; /* this causes readability notifications to be ignored */
+    int frozen_readable; /* this means we missed at least one readability
+                         * notification while we were frozen */
+    char oobdata[1];
     int sending_oob;
     int oobinline;
 };
@@ -89,12 +92,6 @@ struct SockAddr_tag {
 #endif
 };
 
-struct buffer {
-    struct buffer *next;
-    int buflen, bufpos;
-    char buf[BUFFER_GRANULE];
-};
-
 static tree234 *sktree;
 
 static int cmpfortree(void *av, void *bv)
@@ -364,10 +361,63 @@ static void sk_tcp_flush(Socket s)
 }
 
 static void sk_tcp_close(Socket s);
-static void sk_tcp_write(Socket s, char *data, int len);
-static void sk_tcp_write_oob(Socket s, char *data, int len);
+static int sk_tcp_write(Socket s, char *data, int len);
+static int sk_tcp_write_oob(Socket s, char *data, int len);
 static char *sk_tcp_socket_error(Socket s);
 
+extern char *do_select(SOCKET skt, int startup);
+
+Socket sk_register(void *sock, Plug plug)
+{
+    static struct socket_function_table fn_table = {
+       sk_tcp_plug,
+       sk_tcp_close,
+       sk_tcp_write,
+       sk_tcp_write_oob,
+       sk_tcp_flush,
+       sk_tcp_socket_error
+    };
+
+    DWORD err;
+    char *errstr;
+    Actual_Socket ret;
+
+    /*
+     * Create Socket structure.
+     */
+    ret = smalloc(sizeof(struct Socket_tag));
+    ret->fn = &fn_table;
+    ret->error = NULL;
+    ret->plug = plug;
+    bufchain_init(&ret->output_data);
+    ret->writable = 1;                /* to start with */
+    ret->sending_oob = 0;
+    ret->frozen = 1;
+    ret->frozen_readable = 0;
+
+    ret->s = (SOCKET)sock;
+
+    if (ret->s == INVALID_SOCKET) {
+       err = WSAGetLastError();
+       ret->error = winsock_error_string(err);
+       return (Socket) ret;
+    }
+
+    ret->oobinline = 0;
+
+    /* Set up a select mechanism. This could be an AsyncSelect on a
+     * window, or an EventSelect on an event object. */
+    errstr = do_select(ret->s, 1);
+    if (errstr) {
+       ret->error = errstr;
+       return (Socket) ret;
+    }
+
+    add234(sktree, ret);
+
+    return (Socket) ret;
+}
+
 Socket sk_new(SockAddr addr, int port, int privport, int oobinline,
              Plug plug)
 {
@@ -388,7 +438,6 @@ Socket sk_new(SockAddr addr, int port, int privport, int oobinline,
     DWORD err;
     char *errstr;
     Actual_Socket ret;
-    extern char *do_select(SOCKET skt, int startup);
     short localport;
 
     /*
@@ -398,9 +447,11 @@ Socket sk_new(SockAddr addr, int port, int privport, int oobinline,
     ret->fn = &fn_table;
     ret->error = NULL;
     ret->plug = plug;
-    ret->head = ret->tail = NULL;
+    bufchain_init(&ret->output_data);
     ret->writable = 1;                /* to start with */
     ret->sending_oob = 0;
+    ret->frozen = 0;
+    ret->frozen_readable = 0;
 
     /*
      * Open socket.
@@ -519,6 +570,112 @@ Socket sk_new(SockAddr addr, int port, int privport, int oobinline,
     return (Socket) ret;
 }
 
+Socket sk_newlistenner(int port, Plug plug)
+{
+    static struct socket_function_table fn_table = {
+       sk_tcp_plug,
+       sk_tcp_close,
+       sk_tcp_write,
+       sk_tcp_write_oob,
+       sk_tcp_flush,
+       sk_tcp_socket_error
+    };
+
+    SOCKET s;
+#ifdef IPV6
+    SOCKADDR_IN6 a6;
+#endif
+    SOCKADDR_IN a;
+    DWORD err;
+    char *errstr;
+    Actual_Socket ret;
+    int retcode;
+    int on = 1;
+
+    /*
+     * Create Socket structure.
+     */
+    ret = smalloc(sizeof(struct Socket_tag));
+    ret->fn = &fn_table;
+    ret->error = NULL;
+    ret->plug = plug;
+    bufchain_init(&ret->output_data);
+    ret->writable = 0;                /* to start with */
+    ret->sending_oob = 0;
+    ret->frozen = 0;
+    ret->frozen_readable = 0;
+
+    /*
+     * Open socket.
+     */
+    s = socket(AF_INET, SOCK_STREAM, 0);
+    ret->s = s;
+
+    if (s == INVALID_SOCKET) {
+       err = WSAGetLastError();
+       ret->error = winsock_error_string(err);
+       return (Socket) ret;
+    }
+
+    ret->oobinline = 0;
+
+
+    setsockopt(s, SOL_SOCKET, SO_REUSEADDR, (const char *)&on, sizeof(on));
+
+
+#ifdef IPV6
+       if (addr->family == AF_INET6) {
+           memset(&a6, 0, sizeof(a6));
+           a6.sin6_family = AF_INET6;
+/*a6.sin6_addr      = in6addr_any; *//* == 0 */
+           a6.sin6_port = htons(port);
+       } else
+#endif
+       {
+           a.sin_family = AF_INET;
+           a.sin_addr.s_addr = htonl(INADDR_ANY);
+           a.sin_port = htons((short)port);
+       }
+#ifdef IPV6
+       retcode = bind(s, (addr->family == AF_INET6 ?
+                          (struct sockaddr *) &a6 :
+                          (struct sockaddr *) &a),
+                      (addr->family ==
+                       AF_INET6 ? sizeof(a6) : sizeof(a)));
+#else
+       retcode = bind(s, (struct sockaddr *) &a, sizeof(a));
+#endif
+       if (retcode != SOCKET_ERROR) {
+           err = 0;
+       } else {
+           err = WSAGetLastError();
+       }
+
+    if (err) {
+       ret->error = winsock_error_string(err);
+       return (Socket) ret;
+    }
+
+
+    if (listen(s, SOMAXCONN) == SOCKET_ERROR) {
+        closesocket(s);
+       ret->error = winsock_error_string(err);
+       return (Socket) ret;
+    }
+
+    /* Set up a select mechanism. This could be an AsyncSelect on a
+     * window, or an EventSelect on an event object. */
+    errstr = do_select(s, 1);
+    if (errstr) {
+       ret->error = errstr;
+       return (Socket) ret;
+    }
+
+    add234(sktree, ret);
+
+    return (Socket) ret;
+}
+
 static void sk_tcp_close(Socket sock)
 {
     extern char *do_select(SOCKET skt, int startup);
@@ -536,21 +693,22 @@ static void sk_tcp_close(Socket sock)
  */
 void try_send(Actual_Socket s)
 {
-    while (s->head) {
+    while (s->sending_oob || bufchain_size(&s->output_data) > 0) {
        int nsent;
        DWORD err;
+       void *data;
        int len, urgentflag;
 
        if (s->sending_oob) {
            urgentflag = MSG_OOB;
            len = s->sending_oob;
+           data = &s->oobdata;
        } else {
            urgentflag = 0;
-           len = s->head->buflen - s->head->bufpos;
+           bufchain_prefix(&s->output_data, &data, &len);
        }
 
-       nsent =
-           send(s->s, s->head->buf + s->head->bufpos, len, urgentflag);
+       nsent = send(s->s, data, len, urgentflag);
        noise_ultralight(nsent);
        if (nsent <= 0) {
            err = (nsent < 0 ? WSAGetLastError() : 0);
@@ -583,83 +741,48 @@ void try_send(Actual_Socket s)
                fatalbox(winsock_error_string(err));
            }
        } else {
-           s->head->bufpos += nsent;
-           if (s->sending_oob)
-               s->sending_oob -= nsent;
-           if (s->head->bufpos >= s->head->buflen) {
-               struct buffer *tmp = s->head;
-               s->head = tmp->next;
-               sfree(tmp);
-               if (!s->head)
-                   s->tail = NULL;
+           if (s->sending_oob) {
+               if (nsent < len) {
+                   memmove(s->oobdata, s->oobdata+nsent, len-nsent);
+                   s->sending_oob = len - nsent;
+               } else {
+                   s->sending_oob = 0;
+               }
+           } else {
+               bufchain_consume(&s->output_data, nsent);
            }
        }
     }
 }
 
-static void sk_tcp_write(Socket sock, char *buf, int len)
+static int sk_tcp_write(Socket sock, char *buf, int len)
 {
     Actual_Socket s = (Actual_Socket) sock;
 
     /*
      * Add the data to the buffer list on the socket.
      */
-    if (s->tail && s->tail->buflen < BUFFER_GRANULE) {
-       int copylen = min(len, BUFFER_GRANULE - s->tail->buflen);
-       memcpy(s->tail->buf + s->tail->buflen, buf, copylen);
-       buf += copylen;
-       len -= copylen;
-       s->tail->buflen += copylen;
-    }
-    while (len > 0) {
-       int grainlen = min(len, BUFFER_GRANULE);
-       struct buffer *newbuf;
-       newbuf = smalloc(sizeof(struct buffer));
-       newbuf->bufpos = 0;
-       newbuf->buflen = grainlen;
-       memcpy(newbuf->buf, buf, grainlen);
-       buf += grainlen;
-       len -= grainlen;
-       if (s->tail)
-           s->tail->next = newbuf;
-       else
-           s->head = s->tail = newbuf;
-       newbuf->next = NULL;
-       s->tail = newbuf;
-    }
+    bufchain_add(&s->output_data, buf, len);
 
     /*
      * Now try sending from the start of the buffer list.
      */
     if (s->writable)
        try_send(s);
+
+    return bufchain_size(&s->output_data);
 }
 
-static void sk_tcp_write_oob(Socket sock, char *buf, int len)
+static int sk_tcp_write_oob(Socket sock, char *buf, int len)
 {
     Actual_Socket s = (Actual_Socket) sock;
 
     /*
      * Replace the buffer list on the socket with the data.
      */
-    if (!s->head) {
-       s->head = smalloc(sizeof(struct buffer));
-    } else {
-       struct buffer *walk = s->head->next;
-       while (walk) {
-           struct buffer *tmp = walk;
-           walk = tmp->next;
-           sfree(tmp);
-       }
-    }
-    s->head->next = NULL;
-    s->tail = s->head;
-    s->head->buflen = len;
-    memcpy(s->head->buf, buf, len);
-
-    /*
-     * Set the Urgent marker.
-     */
+    bufchain_clear(&s->output_data);
+    assert(len <= sizeof(s->oobdata));
+    memcpy(s->oobdata, buf, len);
     s->sending_oob = len;
 
     /*
@@ -667,6 +790,8 @@ static void sk_tcp_write_oob(Socket sock, char *buf, int len)
      */
     if (s->writable)
        try_send(s);
+
+    return s->sending_oob;
 }
 
 int select_result(WPARAM wParam, LPARAM lParam)
@@ -694,6 +819,12 @@ int select_result(WPARAM wParam, LPARAM lParam)
 
     switch (WSAGETSELECTEVENT(lParam)) {
       case FD_READ:
+       /* In the case the socket is still frozen, we don't even bother */
+       if (s->frozen) {
+           s->frozen_readable = 1;
+           break;
+       }
+
        /*
         * We have received data on the socket. For an oobinline
         * socket, this might be data _before_ an urgent pointer,
@@ -747,8 +878,15 @@ int select_result(WPARAM wParam, LPARAM lParam)
        }
        break;
       case FD_WRITE:
-       s->writable = 1;
-       try_send(s);
+       {
+           int bufsize_before, bufsize_after;
+           s->writable = 1;
+           bufsize_before = s->sending_oob + bufchain_size(&s->output_data);
+           try_send(s);
+           bufsize_after = s->sending_oob + bufchain_size(&s->output_data);
+           if (bufsize_after < bufsize_before)
+               plug_sent(s->plug, bufsize_after);
+       }
        break;
       case FD_CLOSE:
        /* Signal a close on the socket. First read any outstanding data. */
@@ -769,6 +907,26 @@ int select_result(WPARAM wParam, LPARAM lParam)
            }
        } while (ret > 0);
        return open;
+       case FD_ACCEPT:
+       {
+               struct sockaddr isa;
+               int addrlen = sizeof(struct sockaddr);
+               SOCKET t;  /* socket of connection */
+
+               memset(&isa, 0, sizeof(struct sockaddr));
+               err = 0;
+               t = accept(s->s,&isa,&addrlen);
+               if (t == INVALID_SOCKET)
+                               {
+                                       err = WSAGetLastError();
+                                       if (err == WSATRY_AGAIN)
+                                               break;
+                               }
+
+               if (plug_accepting(s->plug, &isa, (void*)t)) {
+                       closesocket(t); // denied or error
+               }
+       }
     }
 
     return 1;
@@ -805,6 +963,19 @@ static char *sk_tcp_socket_error(Socket sock)
     return s->error;
 }
 
+void sk_set_frozen(Socket sock, int is_frozen)
+{
+    Actual_Socket s = (Actual_Socket) sock;
+    if (s->frozen == is_frozen)
+       return;
+    s->frozen = is_frozen;
+    if (!is_frozen && s->frozen_readable) {
+       char c;
+       recv(s->s, &c, 1, MSG_PEEK);
+    }
+    s->frozen_readable = 0;
+}
+
 /*
  * For Plink: enumerate all sockets currently active.
  */