winnet.c

   1 /*
   2  * Windows networking abstraction.
   3  *
   4  * Due to this clean abstraction it was possible
   5  * to easily implement IPv6 support :)
   6  *
   7  * IPv6 patch 1 (27 October 2000) Jeroen Massar <jeroen@unfix.org>
   8  *  - Preliminary hacked IPv6 support.
   9  *    - Connecting to IPv6 address (eg fec0:4242:4242:100:2d0:b7ff:fe8f:5d42) works.
  10  *    - Connecting to IPv6 hostname (eg heaven.ipv6.unfix.org) works.
  11  *  - Compiles as either IPv4 or IPv6.
  12  *
  13  * IPv6 patch 2 (29 October 2000) Jeroen Massar <jeroen@unfix.org>
  14  *  - When compiled as IPv6 it also allows connecting to IPv4 hosts.
  15  *  - Added some more documentation.
  16  *
  17  * IPv6 patch 3 (18 November 2000) Jeroen Massar <jeroen@unfix.org>
  18  *  - It now supports dynamically loading the IPv6 resolver dll's.
  19  *    This way we should be able to distribute one (1) binary
  20  *    which supports both IPv4 and IPv6.
  21  *  - getaddrinfo() and getnameinfo() are loaded dynamicaly if possible.
  22  *  - in6addr_any is defined in this file so we don't need to link to wship6.lib
  23  *  - The patch is now more unified so that we can still
  24  *    remove all IPv6 support by undef'ing IPV6.
  25  *    But where it fallsback to IPv4 it uses the IPv4 code which is already in place...
  26  *  - Canonical name resolving works.
  27  *
  28  * IPv6 patch 4 (07 January 2001) Jeroen Massar <jeroen@unfix.org>
  29  *  - patch against CVS of today, will be submitted to the bugs list
  30  *    as a 'cvs diff -u' on Simon's request...
  31  *
  32  */
  33
  34 /*
  35  * Define IPV6 to have IPv6 on-the-fly-loading support.
  36  * This means that one doesn't have to have an IPv6 stack to use it.
  37  * But if an IPv6 stack is found it is used with a fallback to IPv4.
  38  */
  39 /* #define IPV6 1 */
  40
  41 #ifdef IPV6
  42 #include <winsock2.h>
  43 #include <ws2tcpip.h>
  44 #include <tpipv6.h>
  45 #else
  46 #include <winsock.h>
  47 #endif
  48 #include <windows.h>
  49 #include <stdio.h>
  50 #include <stdlib.h>
  51
  52 #include "putty.h"
  53 #include "network.h"
  54 #include "tree234.h"
  55
  56 #define BUFFER_GRANULE 512
  57
  58 struct Socket_tag {
  59     char *error;
  60     SOCKET s;
  61     sk_receiver_t receiver;
  62     void *private_ptr;
  63     struct buffer *head, *tail;
  64     int writable;
  65     int in_oob, sending_oob;
  66 };
  67
  68 struct SockAddr_tag {
  69     char *error;
  70     /* address family this belongs to, AF_INET for IPv4, AF_INET6 for IPv6. */
  71     int family;
  72     unsigned long address;             /* Address IPv4 style. */
  73 #ifdef IPV6
  74     struct addrinfo *ai;               /* Address IPv6 style. */
  75 #endif
  76     /*
  77      * We need to have this lengthy enough to hold *any* hostname
  78      * (including IPv6 reverse...)
  79      */
  80     char realhost[8192];
  81 };
  82
  83 struct buffer {
  84     struct buffer *next;
  85     int buflen, bufpos;
  86     char buf[BUFFER_GRANULE];
  87 };
  88
  89 static tree234 *sktree;
  90
  91 static int cmpfortree(void *av, void *bv) {
  92     Socket a = (Socket)av, b = (Socket)bv;
  93     unsigned long as = (unsigned long)a->s, bs = (unsigned long)b->s;
  94     if (as < bs) return -1;
  95     if (as > bs) return +1;
  96     return 0;
  97 }
  98
  99 static int cmpforsearch(void *av, void *bv) {
 100     Socket b = (Socket)bv;
 101     unsigned long as = (unsigned long)av, bs = (unsigned long)b->s;
 102     if (as < bs) return -1;
 103     if (as > bs) return +1;
 104     return 0;
 105 }
 106
 107 void sk_init(void) {
 108     sktree = newtree234(cmpfortree);
 109 }
 110
 111 char *winsock_error_string(int error) {
 112     switch (error) {
 113       case WSAEACCES: return "Network error: Permission denied";
 114       case WSAEADDRINUSE: return "Network error: Address already in use";
 115       case WSAEADDRNOTAVAIL: return "Network error: Cannot assign requested address";
 116       case WSAEAFNOSUPPORT: return "Network error: Address family not supported by protocol family";
 117       case WSAEALREADY: return "Network error: Operation already in progress";
 118       case WSAECONNABORTED: return "Network error: Software caused connection abort";
 119       case WSAECONNREFUSED: return "Network error: Connection refused";
 120       case WSAECONNRESET: return "Network error: Connection reset by peer";
 121       case WSAEDESTADDRREQ: return "Network error: Destination address required";
 122       case WSAEFAULT: return "Network error: Bad address";
 123       case WSAEHOSTDOWN: return "Network error: Host is down";
 124       case WSAEHOSTUNREACH: return "Network error: No route to host";
 125       case WSAEINPROGRESS: return "Network error: Operation now in progress";
 126       case WSAEINTR: return "Network error: Interrupted function call";
 127       case WSAEINVAL: return "Network error: Invalid argument";
 128       case WSAEISCONN: return "Network error: Socket is already connected";
 129       case WSAEMFILE: return "Network error: Too many open files";
 130       case WSAEMSGSIZE: return "Network error: Message too long";
 131       case WSAENETDOWN: return "Network error: Network is down";
 132       case WSAENETRESET: return "Network error: Network dropped connection on reset";
 133       case WSAENETUNREACH: return "Network error: Network is unreachable";
 134       case WSAENOBUFS: return "Network error: No buffer space available";
 135       case WSAENOPROTOOPT: return "Network error: Bad protocol option";
 136       case WSAENOTCONN: return "Network error: Socket is not connected";
 137       case WSAENOTSOCK: return "Network error: Socket operation on non-socket";
 138       case WSAEOPNOTSUPP: return "Network error: Operation not supported";
 139       case WSAEPFNOSUPPORT: return "Network error: Protocol family not supported";
 140       case WSAEPROCLIM: return "Network error: Too many processes";
 141       case WSAEPROTONOSUPPORT: return "Network error: Protocol not supported";
 142       case WSAEPROTOTYPE: return "Network error: Protocol wrong type for socket";
 143       case WSAESHUTDOWN: return "Network error: Cannot send after socket shutdown";
 144       case WSAESOCKTNOSUPPORT: return "Network error: Socket type not supported";
 145       case WSAETIMEDOUT: return "Network error: Connection timed out";
 146       case WSAEWOULDBLOCK: return "Network error: Resource temporarily unavailable";
 147       case WSAEDISCON: return "Network error: Graceful shutdown in progress";
 148       default: return "Unknown network error";
 149     }
 150 }
 151
 152 SockAddr sk_namelookup(char *host, char **canonicalname)
 153 {
 154     SockAddr ret = smalloc(sizeof(struct SockAddr_tag));
 155     unsigned long a;
 156     struct hostent *h = NULL;
 157
 158     /* Clear the structure and default to IPv4. */
 159     memset(ret, 0, sizeof(struct SockAddr_tag));
 160     ret->family = 0;                   /* We set this one when we have resolved the host. */
 161     *canonicalname = ret->realhost;    /* This makes sure we always have a hostname to return. */
 162
 163     if ( (a = inet_addr(host)) == (unsigned long) INADDR_NONE)
 164     {
 165 #ifdef IPV6
 166
 167         /* Try to get the getaddrinfo() function from wship6.dll */
 168         /* This way one doesn't need to have IPv6 dll's to use PuTTY and
 169          * it will fallback to IPv4. */
 170         typedef int (CALLBACK* FGETADDRINFO)(const char *nodename,
 171                                              const char *servname,
 172                                              const struct addrinfo *hints,
 173                                              struct addrinfo **res);
 174         FGETADDRINFO fGetAddrInfo = NULL;
 175
 176         HINSTANCE dllWSHIP6 = LoadLibrary("wship6.dll");
 177         if (dllWSHIP6)
 178             fGetAddrInfo = (FGETADDRINFO)GetProcAddress(dllWSHIP6,
 179                                                         "getaddrinfo");
 180
 181         /*
 182          * Use fGetAddrInfo when it's available (which usually also
 183          * means IPv6 is installed...)
 184          */
 185         if (fGetAddrInfo)
 186         {
 187             /*debug(("Resolving \"%s\" with getaddrinfo()  (IPv4+IPv6 capable)...\n", host)); */
 188             if (fGetAddrInfo(host, NULL, NULL, &ret->ai) == 0)
 189                 ret->family = ret->ai->ai_family;
 190         }
 191         else
 192 #endif
 193             /*
 194              * Otherwise use the IPv4-only gethostbyname...
 195              * (NOTE: we don't use gethostbyname as a
 196              * fallback!)
 197              */
 198             if (ret->family == 0)
 199         {
 200             /*debug(("Resolving \"%s\" with gethostbyname() (IPv4 only)...\n", host)); */
 201             if (h = gethostbyname(host)) ret->family = AF_INET;
 202         }
 203         /*debug(("Done resolving...(family is %d) AF_INET = %d, AF_INET6 = %d\n", ret->family, AF_INET, AF_INET6)); */
 204
 205         if (ret->family == 0)
 206         {
 207             DWORD err = WSAGetLastError();
 208             ret->error = (err == WSAENETDOWN ? "Network is down" :
 209                           err == WSAHOST_NOT_FOUND ? "Host does not exist" :
 210                           err == WSATRY_AGAIN ? "Host not found" :
 211 #ifdef IPV6
 212                           fGetAddrInfo ? "getaddrinfo: unknown error" :
 213 #endif
 214                           "gethostbyname: unknown error");
 215 #ifdef DEBUG
 216             {
 217                 LPVOID lpMsgBuf;
 218                 FormatMessage(FORMAT_MESSAGE_ALLOCATE_BUFFER | FORMAT_MESSAGE_FROM_SYSTEM | FORMAT_MESSAGE_IGNORE_INSERTS, NULL, err, MAKELANGID(LANG_NEUTRAL, SUBLANG_DEFAULT), (LPTSTR)&lpMsgBuf,     0,      NULL);
 219                 /*debug(("Error %ld: %s (h=%lx)\n", err, lpMsgBuf, h));*/
 220                 /* Free the buffer. */
 221                 LocalFree(lpMsgBuf);
 222             }
 223 #endif
 224         }
 225         else
 226         {
 227             ret->error = NULL;
 228
 229 #ifdef IPV6
 230             /* If we got an address info use that... */
 231             if (ret->ai)
 232             {
 233                 typedef int (CALLBACK* FGETNAMEINFO)
 234                     (const struct sockaddr FAR *sa, socklen_t salen,
 235                      char FAR * host, size_t hostlen, char FAR * serv,
 236                      size_t servlen, int flags);
 237                 FGETNAMEINFO fGetNameInfo = NULL;
 238
 239                 /* Are we in IPv4 fallback mode? */
 240                 /* We put the IPv4 address into the a variable so we can further-on use the IPv4 code... */
 241                 if (ret->family == AF_INET)
 242                     memcpy(&a, (char *)&((SOCKADDR_IN *)ret->ai->ai_addr)->sin_addr, sizeof(a));
 243
 244                 /* Now let's find that canonicalname... */
 245                 if ((dllWSHIP6) && (fGetNameInfo = (FGETNAMEINFO)GetProcAddress(dllWSHIP6, "getnameinfo")))
 246                 {
 247                     if (fGetNameInfo((struct sockaddr *)ret->ai->ai_addr,
 248                                      ret->family == AF_INET ?
 249                                      sizeof(SOCKADDR_IN) :
 250                                      sizeof(SOCKADDR_IN6), ret->realhost,
 251                                      sizeof(ret->realhost), NULL,
 252                                      0, 0) != 0)
 253                     {
 254                         strncpy(ret->realhost, host,
 255                                 sizeof(ret->realhost));
 256                     }
 257                 }
 258             }
 259             /* We used the IPv4-only gethostbyname()... */
 260             else
 261             {
 262 #endif
 263                 memcpy(&a, h->h_addr, sizeof(a));
 264                 /* This way we are always sure the h->h_name is valid :) */
 265                 strncpy(ret->realhost, h->h_name, sizeof(ret->realhost));
 266 #ifdef IPV6
 267             }
 268 #endif
 269         }
 270 #ifdef IPV6
 271         FreeLibrary(dllWSHIP6);
 272 #endif
 273     }
 274     else
 275     {
 276         /*
 277          * Hack inserted to deal with problems with numeric IPs.
 278          * FIXME: how will this work in IPv6?
 279          */
 280         ret->family = AF_INET;
 281         *canonicalname = host;
 282     }
 283     ret->address = ntohl(a);
 284     return ret;
 285 }
 286
 287 void sk_addr_free(SockAddr addr) {
 288     sfree(addr);
 289 }
 290
 291 Socket sk_new(SockAddr addr, int port, int privport, sk_receiver_t receiver) {
 292     SOCKET s;
 293 #ifdef IPV6
 294     SOCKADDR_IN6 a6;
 295 #endif
 296     SOCKADDR_IN a;
 297     DWORD err;
 298     char *errstr;
 299     Socket ret;
 300     extern char *do_select(SOCKET skt, int startup);
 301     short localport;
 302
 303     /*
 304      * Create Socket structure.
 305      */
 306     ret = smalloc(sizeof(struct Socket_tag));
 307     ret->error = NULL;
 308     ret->receiver = receiver;
 309     ret->head = ret->tail = NULL;
 310     ret->writable = 1;                 /* to start with */
 311     ret->in_oob = FALSE;
 312     ret->sending_oob = 0;
 313
 314     /*
 315      * Open socket.
 316      */
 317     s = socket(addr->family, SOCK_STREAM, 0);
 318     ret->s = s;
 319
 320     if (s == INVALID_SOCKET) {
 321         err = WSAGetLastError();
 322         ret->error = winsock_error_string(err);
 323         return ret;
 324     }
 325
 326     /*
 327      * Bind to local address.
 328      */
 329     if (privport)
 330         localport = 1023;              /* count from 1023 downwards */
 331     else
 332         localport = 0;                 /* just use port 0 (ie winsock picks) */
 333
 334     /* Loop round trying to bind */
 335     while (1) {
 336         int retcode;
 337
 338 #ifdef IPV6
 339         if (addr->family == AF_INET6)
 340         {
 341             memset(&a6,0,sizeof(a6));
 342             a6.sin6_family      = AF_INET6;
 343             /*a6.sin6_addr      = in6addr_any;*/  /* == 0 */
 344             a6.sin6_port        = htons(localport);
 345         }
 346         else
 347         {
 348 #endif
 349             a.sin_family = AF_INET;
 350             a.sin_addr.s_addr = htonl(INADDR_ANY);
 351             a.sin_port = htons(localport);
 352 #ifdef IPV6
 353         }
 354         retcode = bind (s, (addr->family == AF_INET6 ?
 355                             (struct sockaddr *)&a6 :
 356                             (struct sockaddr *)&a),
 357                         (addr->family == AF_INET6 ? sizeof(a6) : sizeof(a)));
 358 #else
 359         retcode = bind (s, (struct sockaddr *)&a, sizeof(a));
 360 #endif
 361         if (retcode != SOCKET_ERROR) {
 362             err = 0;
 363             break;                     /* done */
 364         } else {
 365             err = WSAGetLastError();
 366             if (err != WSAEADDRINUSE)  /* failed, for a bad reason */
 367                 break;
 368         }
 369
 370         if (localport == 0)
 371             break;                     /* we're only looping once */
 372         localport--;
 373         if (localport == 0)
 374             break;                     /* we might have got to the end */
 375     }
 376
 377     if (err)
 378     {
 379         ret->error = winsock_error_string(err);
 380         return ret;
 381     }
 382
 383     /*
 384      * Connect to remote address.
 385      */
 386 #ifdef IPV6
 387     if (addr->family == AF_INET6)
 388     {
 389         memset(&a,0,sizeof(a));
 390         a6.sin6_family = AF_INET6;
 391         a6.sin6_port = htons((short)port);
 392         a6.sin6_addr = ((struct sockaddr_in6 *)addr->ai->ai_addr)->sin6_addr;
 393     }
 394     else
 395     {
 396 #endif
 397         a.sin_family = AF_INET;
 398         a.sin_addr.s_addr = htonl(addr->address);
 399         a.sin_port = htons((short)port);
 400 #ifdef IPV6
 401     }
 402     if (connect (s, (addr->family == AF_INET6) ? (struct sockaddr *)&a6 : (struct sockaddr *)&a, (addr->family == AF_INET6) ? sizeof(a6) : sizeof(a)) == SOCKET_ERROR)
 403 #else
 404         if (connect (s, (struct sockaddr *)&a, sizeof(a)) == SOCKET_ERROR)
 405 #endif
 406     {
 407         err = WSAGetLastError();
 408         ret->error = winsock_error_string(err);
 409         return ret;
 410     }
 411
 412     /* Set up a select mechanism. This could be an AsyncSelect on a
 413      * window, or an EventSelect on an event object. */
 414     errstr = do_select(s, 1);
 415     if (errstr) {
 416         ret->error = errstr;
 417         return ret;
 418     }
 419
 420     add234(sktree, ret);
 421
 422     return ret;
 423 }
 424
 425 void sk_close(Socket s) {
 426     del234(sktree, s);
 427     do_select(s->s, 0);
 428     closesocket(s->s);
 429     sfree(s);
 430 }
 431
 432 /*
 433  * The function which tries to send on a socket once it's deemed
 434  * writable.
 435  */
 436 void try_send(Socket s) {
 437     while (s->head) {
 438         int nsent;
 439         DWORD err;
 440         int len, urgentflag;
 441
 442         if (s->sending_oob) {
 443             urgentflag = MSG_OOB;
 444             len = s->sending_oob;
 445         } else {
 446             urgentflag = 0;
 447             len = s->head->buflen - s->head->bufpos;
 448         }
 449
 450         nsent = send(s->s, s->head->buf + s->head->bufpos, len, urgentflag);
 451         noise_ultralight(nsent);
 452         if (nsent <= 0) {
 453             err = (nsent < 0 ? WSAGetLastError() : 0);
 454             if (err == WSAEWOULDBLOCK) {
 455                 /* Perfectly normal: we've sent all we can for the moment. */
 456                 s->writable = FALSE;
 457                 return;
 458             } else if (nsent == 0 ||
 459                        err == WSAECONNABORTED ||
 460                        err == WSAECONNRESET) {
 461                 /*
 462                  * FIXME. This will have to be done better when we
 463                  * start managing multiple sockets (e.g. SSH port
 464                  * forwarding), because if we get CONNRESET while
 465                  * trying to write a particular forwarded socket
 466                  * then it isn't necessarily the end of the world.
 467                  * Ideally I'd like to pass the error code back to
 468                  * somewhere the next select_result() will see it,
 469                  * but that might be hard. Perhaps I should pass it
 470                  * back to be queued in the Windows front end bit.
 471                  */
 472                 fatalbox(winsock_error_string(err));
 473             } else {
 474                 fatalbox(winsock_error_string(err));
 475             }
 476         } else {
 477             s->head->bufpos += nsent;
 478             if (s->sending_oob)
 479                 s->sending_oob -= nsent;
 480             if (s->head->bufpos >= s->head->buflen) {
 481                 struct buffer *tmp = s->head;
 482                 s->head = tmp->next;
 483                 sfree(tmp);
 484                 if (!s->head)
 485                     s->tail = NULL;
 486             }
 487         }
 488     }
 489 }
 490
 491 void sk_write(Socket s, char *buf, int len) {
 492     /*
 493      * Add the data to the buffer list on the socket.
 494      */
 495     if (s->tail && s->tail->buflen < BUFFER_GRANULE) {
 496         int copylen = min(len, BUFFER_GRANULE - s->tail->buflen);
 497         memcpy(s->tail->buf + s->tail->buflen, buf, copylen);
 498         buf += copylen;
 499         len -= copylen;
 500         s->tail->buflen += copylen;
 501     }
 502     while (len > 0) {
 503         int grainlen = min(len, BUFFER_GRANULE);
 504         struct buffer *newbuf;
 505         newbuf = smalloc(sizeof(struct buffer));
 506         newbuf->bufpos = 0;
 507         newbuf->buflen = grainlen;
 508         memcpy(newbuf->buf, buf, grainlen);
 509         buf += grainlen;
 510         len -= grainlen;
 511         if (s->tail)
 512             s->tail->next = newbuf;
 513         else
 514             s->head = s->tail = newbuf;
 515         newbuf->next = NULL;
 516         s->tail = newbuf;
 517     }
 518
 519     /*
 520      * Now try sending from the start of the buffer list.
 521      */
 522     if (s->writable)
 523         try_send(s);
 524 }
 525
 526 void sk_write_oob(Socket s, char *buf, int len) {
 527     /*
 528      * Replace the buffer list on the socket with the data.
 529      */
 530     if (!s->head) {
 531         s->head = smalloc(sizeof(struct buffer));
 532     } else {
 533         struct buffer *walk = s->head->next;
 534         while (walk) {
 535             struct buffer *tmp = walk;
 536             walk = tmp->next;
 537             sfree(tmp);
 538         }
 539     }
 540     s->head->next = NULL;
 541     s->tail = s->head;
 542     s->head->buflen = len;
 543     memcpy(s->head->buf, buf, len);
 544
 545     /*
 546      * Set the Urgent marker.
 547      */
 548     s->sending_oob = len;
 549
 550     /*
 551      * Now try sending from the start of the buffer list.
 552      */
 553     if (s->writable)
 554         try_send(s);
 555 }
 556
 557 int select_result(WPARAM wParam, LPARAM lParam) {
 558     int ret;
 559     DWORD err;
 560     char buf[BUFFER_GRANULE];
 561     Socket s;
 562     u_long atmark;
 563
 564     /* wParam is the socket itself */
 565     s = find234(sktree, (void *)wParam, cmpforsearch);
 566     if (!s)
 567         return 1;                      /* boggle */
 568
 569     if ((err = WSAGETSELECTERROR(lParam)) != 0) {
 570         fatalbox(winsock_error_string(err));
 571     }
 572
 573     noise_ultralight(lParam);
 574
 575     switch (WSAGETSELECTEVENT(lParam)) {
 576       case FD_READ:
 577         ret = recv(s->s, buf, sizeof(buf), 0);
 578         if (ret < 0) {
 579             err = WSAGetLastError();
 580             if (err == WSAEWOULDBLOCK) {
 581                 break;
 582             }
 583         }
 584         if (ret < 0) {
 585             fatalbox(winsock_error_string(err));
 586         } else {
 587             int type = s->in_oob ? 2 : 0;
 588             s->in_oob = FALSE;
 589             return s->receiver(s, type, buf, ret);
 590         }
 591         break;
 592       case FD_OOB:
 593         /*
 594          * Read all data up to the OOB marker, and send it to the
 595          * receiver with urgent==1 (OOB pending).
 596          */
 597         atmark = 1;
 598         s->in_oob = TRUE;
 599         /* Some WinSock wrappers don't support this call, so we
 600          * deliberately don't check the return value. If the call
 601          * fails and does nothing, we will get back atmark==1,
 602          * which is good enough to keep going at least. */
 603         ioctlsocket(s->s, SIOCATMARK, &atmark);
 604         ret = recv(s->s, buf, sizeof(buf), MSG_OOB);
 605         noise_ultralight(ret);
 606         if (ret <= 0) {
 607             fatalbox(ret == 0 ? "Internal networking trouble" :
 608                      winsock_error_string(WSAGetLastError()));
 609         } else {
 610             return s->receiver(s, atmark ? 2 : 1, buf, ret);
 611         }
 612         break;
 613       case FD_WRITE:
 614         s->writable = 1;
 615         try_send(s);
 616         break;
 617       case FD_CLOSE:
 618         /* Signal a close on the socket. */
 619         return s->receiver(s, 0, NULL, 0);
 620         break;
 621     }
 622
 623     return 1;
 624 }
 625
 626 /*
 627  * Each socket abstraction contains a `void *' private field in
 628  * which the client can keep state.
 629  */
 630 void sk_set_private_ptr(Socket s, void *ptr) {
 631     s->private_ptr = ptr;
 632 }
 633 void *sk_get_private_ptr(Socket s) {
 634     return s->private_ptr;
 635 }
 636
 637 /*
 638  * Special error values are returned from sk_namelookup and sk_new
 639  * if there's a problem. These functions extract an error message,
 640  * or return NULL if there's no problem.
 641  */
 642 char *sk_addr_error(SockAddr addr) {
 643     return addr->error;
 644 }
 645 char *sk_socket_error(Socket s) {
 646     return s->error;
 647 }
 648
 649 /*
 650  * For Plink: enumerate all sockets currently active.
 651  */
 652 SOCKET first_socket(enum234 *e) {
 653     Socket s = first234(sktree, e);
 654     return s ? s->s : INVALID_SOCKET;
 655 }
 656 SOCKET next_socket(enum234 *e) {
 657     Socket s = next234(e);
 658     return s ? s->s : INVALID_SOCKET;
 659 }