1 /* $Id: getaddrinfo.c,v 1.5 2007-04-23 21:05:23 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)
57 struct addrinfo *addrinfo, hints;
58 char *hostport = xstrdup(w->hostport);
60 if ((port = strchr(hostport, ':')))
66 hints.ai_family = PF_INET;
67 hints.ai_socktype = SOCK_STREAM;
68 hints.ai_protocol = IPPROTO_TCP;
71 hints.ai_canonname = 0;
73 // This is not robust code. It assumes that getaddrinfo always
74 // returns AF_INET address.
75 if ((res = getaddrinfo(hostport, port, &hints, &addrinfo)))
77 yaz_log(YLOG_WARN, "Failed to resolve %s: %s",
78 w->hostport, gai_strerror(res));
83 unsigned char addrbuf[4];
84 assert(addrinfo->ai_family == PF_INET);
86 &((struct sockaddr_in*)addrinfo->ai_addr)->sin_addr.s_addr, 4);
87 sprintf(ipport, "%u.%u.%u.%u:%s",
88 addrbuf[0], addrbuf[1], addrbuf[2], addrbuf[3], port);
89 freeaddrinfo(addrinfo);
90 w->ipport = xstrdup(ipport);
91 yaz_log(log_level, "Resolved %s -> %s", hostport, ipport);
96 static void work_handler(void *vp)
100 int sec = 0; /* >0 for debugging/testing purposes */
103 yaz_log(log_level, "waiting %d seconds", sec);
106 perform_getaddrinfo(w);
109 void iochan_handler(struct iochan *i, int event)
111 sel_thread_t p = iochan_getdata(i);
113 if (event & EVENT_INPUT)
115 struct work *w = sel_thread_result(p);
116 w->host->ipport = w->ipport;
117 connect_resolver_host(w->host);
122 static sel_thread_t resolver_thread = 0;
124 static void getaddrinfo_start(void)
127 sel_thread_t p = resolver_thread =
128 sel_thread_create(work_handler, 0 /* work_destroy */, &fd,
129 3 /* no of resolver threads */);
132 yaz_log(YLOG_FATAL|YLOG_ERRNO, "sel_create_create failed");
137 IOCHAN chan = iochan_create(fd, iochan_handler, EVENT_INPUT);
138 iochan_setdata(chan, p);
139 pazpar2_add_channel(chan);
141 yaz_log(log_level, "resolver start");
145 int host_getaddrinfo(struct host *host)
147 struct work *w = xmalloc(sizeof(*w));
148 int use_thread = 1; /* =0 to disable threading entirely */
150 w->hostport = host->hostport;
155 if (resolver_thread == 0)
157 assert(resolver_thread);
158 sel_thread_add(resolver_thread, w);
162 perform_getaddrinfo(w);
163 host->ipport = w->ipport;
174 * indent-tabs-mode: nil
176 * vim: shiftwidth=4 tabstop=8 expandtab