1 /* $Id: getaddrinfo.c,v 1.7 2007-07-25 11:41:32 adam Exp $
2 Copyright (c) 2006-2007, Index Data.
4 This file is part of Pazpar2.
6 Pazpar2 is free software; you can redistribute it and/or modify it under
7 the terms of the GNU General Public License as published by the Free
8 Software Foundation; either version 2, or (at your option) any later
11 Pazpar2 is distributed in the hope that it will be useful, but WITHOUT ANY
12 WARRANTY; without even the implied warranty of MERCHANTABILITY or
13 FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
16 You should have received a copy of the GNU General Public License
17 along with Pazpar2; see the file LICENSE. If not, write to the
18 Free Software Foundation, 59 Temple Place - Suite 330, Boston, MA
26 #include "sel_thread.h"
32 #include <sys/types.h>
33 #include <sys/socket.h>
35 #include <netinet/in.h>
39 #include <yaz/tcpip.h>
42 #include "connection.h"
46 char *hostport; /* hostport to be resolved in separate thread */
47 char *ipport; /* result or NULL if it could not be resolved */
48 struct host *host; /* host that we're dealing with - mother thread */
51 static int log_level = YLOG_LOG;
53 void perform_getaddrinfo(struct work *w)
58 struct addrinfo *addrinfo, hints;
62 char *hostport = xstrdup(w->hostport);
64 if ((port = strchr(hostport, ':')))
69 yaz_log(YLOG_LOG, "Resolving %s", w->hostport);
73 hints.ai_family = PF_INET;
74 hints.ai_socktype = SOCK_STREAM;
75 hints.ai_protocol = IPPROTO_TCP;
78 hints.ai_canonname = 0;
80 // This is not robust code. It assumes that getaddrinfo always
81 // returns AF_INET address.
82 if ((res = getaddrinfo(hostport, port, &hints, &addrinfo)))
84 yaz_log(YLOG_WARN, "Failed to resolve %s: %s",
85 w->hostport, gai_strerror(res));
90 unsigned char addrbuf[4];
91 assert(addrinfo->ai_family == PF_INET);
93 &((struct sockaddr_in*)addrinfo->ai_addr)->sin_addr.s_addr, 4);
94 sprintf(ipport, "%u.%u.%u.%u:%s",
95 addrbuf[0], addrbuf[1], addrbuf[2], addrbuf[3], port);
96 freeaddrinfo(addrinfo);
97 w->ipport = xstrdup(ipport);
98 yaz_log(log_level, "Resolved %s -> %s", hostport, ipport);
101 hp = gethostbyname(hostport);
104 yaz_log(YLOG_WARN|YLOG_ERRNO, "Failed to resolve %s", hostport);
109 unsigned char addrbuf[4];
111 memcpy(addrbuf, *hp->h_addr_list, 4 * sizeof(unsigned char));
112 sprintf(ipport, "%u.%u.%u.%u:%s",
113 addrbuf[0], addrbuf[1], addrbuf[2], addrbuf[3], port);
114 w->ipport = xstrdup(ipport);
115 yaz_log(log_level, "Resolved %s -> %s", hostport, ipport);
121 static void work_handler(void *vp)
125 int sec = 0; /* >0 for debugging/testing purposes */
128 yaz_log(log_level, "waiting %d seconds", sec);
131 perform_getaddrinfo(w);
134 void iochan_handler(struct iochan *i, int event)
136 sel_thread_t p = iochan_getdata(i);
138 if (event & EVENT_INPUT)
140 struct work *w = sel_thread_result(p);
141 w->host->ipport = w->ipport;
142 connect_resolver_host(w->host);
147 static sel_thread_t resolver_thread = 0;
149 static void getaddrinfo_start(void)
152 sel_thread_t p = resolver_thread =
153 sel_thread_create(work_handler, 0 /* work_destroy */, &fd,
154 3 /* no of resolver threads */);
157 yaz_log(YLOG_FATAL|YLOG_ERRNO, "sel_create_create failed");
162 IOCHAN chan = iochan_create(fd, iochan_handler, EVENT_INPUT);
163 iochan_setdata(chan, p);
164 pazpar2_add_channel(chan);
166 yaz_log(log_level, "resolver start");
170 int host_getaddrinfo(struct host *host)
172 struct work *w = xmalloc(sizeof(*w));
173 int use_thread = 1; /* =0 to disable threading entirely */
175 w->hostport = host->hostport;
180 if (resolver_thread == 0)
182 assert(resolver_thread);
183 sel_thread_add(resolver_thread, w);
187 perform_getaddrinfo(w);
188 host->ipport = w->ipport;
199 * indent-tabs-mode: nil
201 * vim: shiftwidth=4 tabstop=8 expandtab