X-Git-Url: http://git.indexdata.com/?p=yaz-moved-to-github.git;a=blobdiff_plain;f=src%2Ftcpip.c;h=e712c0ef7bbf107e76e8a6ca33b862ff3c0bc65e;hp=41c07256d2bca33eb3196d9c2e5f2bcacdf6c423;hb=d7971954990c423d60a52030f5dfa78d32003486;hpb=2ad51254bcafb41daf04f708f9d37ef37d16fb49 diff --git a/src/tcpip.c b/src/tcpip.c index 41c0725..e712c0e 100644 --- a/src/tcpip.c +++ b/src/tcpip.c @@ -238,7 +238,7 @@ COMSTACK tcpip_type(int s, int flags, int protocol, void *vp) sp->connect_response_len = 0; p->timeout = COMSTACK_DEFAULT_TIMEOUT; - TRC(fprintf(stderr, "Created new TCPIP comstack\n")); + TRC(fprintf(stderr, "Created new TCPIP comstack h=%p\n", p)); return p; } @@ -367,7 +367,7 @@ struct addrinfo *tcpip_getaddrinfo(const char *str, const char *port, if (!strcmp("@", host)) { hints.ai_flags = AI_PASSIVE; - hints.ai_family = AF_INET6; + hints.ai_family = AF_UNSPEC; error = getaddrinfo(0, port, &hints, &res); *ipv6_only = 0; } @@ -388,6 +388,7 @@ struct addrinfo *tcpip_getaddrinfo(const char *str, const char *port, else { error = getaddrinfo(host, port, &hints, &res); + *ipv6_only = -1; } if (error) return 0; @@ -462,15 +463,27 @@ void *tcpip_straddr(COMSTACK h, const char *str) int s = -1; for (ai = sp->ai; ai; ai = ai->ai_next) { - s = socket(ai->ai_family, ai->ai_socktype, ai->ai_protocol); - if (s != -1) - break; + if (ai->ai_family == AF_INET6) + { + s = socket(ai->ai_family, ai->ai_socktype, ai->ai_protocol); + if (s != -1) + break; + } + } + if (s == -1) + { + for (ai = sp->ai; ai; ai = ai->ai_next) + { + s = socket(ai->ai_family, ai->ai_socktype, ai->ai_protocol); + if (s != -1) + break; + } } if (s == -1) return 0; assert(ai); h->iofile = s; - if (ipv6_only >= 0 && + if (ai->ai_family == AF_INET6 && ipv6_only >= 0 && setsockopt(h->iofile, IPPROTO_IPV6, IPV6_V6ONLY, &ipv6_only, sizeof(ipv6_only))) @@ -533,7 +546,7 @@ int tcpip_connect(COMSTACK h, void *address) struct sockaddr_in *add = (struct sockaddr_in *) address; #endif int r; - TRC(fprintf(stderr, "tcpip_connect\n")); + TRC(fprintf(stderr, "tcpip_connect h=%p\n", h)); h->io_pending = 0; if (h->state != CS_ST_UNBND) { @@ -1024,7 +1037,7 @@ int tcpip_get(COMSTACK h, char **buf, int *bufsize) int tmpi, berlen, rest, req, tomove; int hasread = 0, res; - TRC(fprintf(stderr, "tcpip_get: bufsize=%d\n", *bufsize)); + TRC(fprintf(stderr, "tcpip_get: h=%p bufsize=%d\n", h, *bufsize)); if (sp->altlen) /* switch buffers */ { TRC(fprintf(stderr, " %d bytes in altbuf (%p)\n", sp->altlen, @@ -1242,7 +1255,7 @@ int tcpip_put(COMSTACK h, char *buf, int size) int res; struct tcpip_state *state = (struct tcpip_state *)h->cprivate; - TRC(fprintf(stderr, "tcpip_put: size=%d\n", size)); + TRC(fprintf(stderr, "tcpip_put: h=%p size=%d\n", h, size)); h->io_pending = 0; h->event = CS_DATA; if (state->towrite < 0) @@ -1360,12 +1373,12 @@ void tcpip_close(COMSTACK h) { tcpip_state *sp = (struct tcpip_state *)h->cprivate; - TRC(fprintf(stderr, "tcpip_close h=%p pid=%d\n", h, getpid())); + TRC(fprintf(stderr, "tcpip_close: h=%p pid=%d\n", h, getpid())); if (h->iofile != -1) { #if HAVE_GNUTLS_H if (sp->session) - gnutls_bye(sp->session, GNUTLS_SHUT_RDWR); + gnutls_bye(sp->session, GNUTLS_SHUT_WR); #elif HAVE_OPENSSL_SSL_H if (sp->ssl) {