57c6eb6836b8056a1083df977c9eda87f730eee7
[pazpar2-moved-to-github.git] / src / host.c
1 /* This file is part of Pazpar2.
2    Copyright (C) 2006-2011 Index Data
3
4 Pazpar2 is free software; you can redistribute it and/or modify it under
5 the terms of the GNU General Public License as published by the Free
6 Software Foundation; either version 2, or (at your option) any later
7 version.
8
9 Pazpar2 is distributed in the hope that it will be useful, but WITHOUT ANY
10 WARRANTY; without even the implied warranty of MERCHANTABILITY or
11 FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
12 for more details.
13
14 You should have received a copy of the GNU General Public License
15 along with this program; if not, write to the Free Software
16 Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
17
18 */
19
20 #if HAVE_CONFIG_H
21 #include <config.h>
22 #endif
23
24 #include <assert.h>
25 #include <sys/types.h>
26 #include <sys/stat.h>
27 #include <yaz/log.h>
28 #include <yaz/nmem.h>
29
30 #include "ppmutex.h"
31 #include "session.h"
32 #include "host.h"
33
34 #include <sys/types.h>
35
36 struct database_hosts {
37     struct host *hosts;
38     YAZ_MUTEX mutex;
39 };
40
41 // Create a new host structure for hostport
42 static struct host *create_host(const char *url, const char *proxy,
43                                 int default_port,
44                                 iochan_man_t iochan_man)
45 {
46     struct host *host;
47     char *db_comment;
48
49     host = xmalloc(sizeof(struct host));
50     host->url = xstrdup(url);
51     host->proxy = 0;
52     host->tproxy = 0;
53     if (proxy && *proxy)
54         host->proxy = xstrdup(proxy);
55     else
56     {
57         char *cp;
58         
59         host->tproxy = xmalloc (strlen(url) + 10); /* so we can add :port */
60         strcpy(host->tproxy, url);
61         for (cp = host->tproxy; *cp; cp++)
62             if (strchr("/?#~", *cp))
63             {
64                 *cp = '\0';
65                 break;
66             }
67         if (!strchr(host->tproxy, ':'))
68             sprintf(cp, ":%d", default_port); /* no port given, add it */
69     }
70
71     db_comment = strchr(host->url, '#');
72     if (db_comment)
73         *db_comment = '\0';
74     host->connections = 0;
75     host->ipport = 0;
76     host->mutex = 0;
77
78     if (host_getaddrinfo(host, iochan_man))
79     {
80         xfree(host->ipport);
81         xfree(host->tproxy);
82         xfree(host->proxy);
83         xfree(host->url);
84         xfree(host);
85         return 0;
86     }
87     pazpar2_mutex_create(&host->mutex, "host");
88
89     yaz_cond_create(&host->cond_ready);
90
91     return host;
92 }
93
94 struct host *find_host(database_hosts_t hosts, const char *url,
95                        const char *proxy, int port,
96                        iochan_man_t iochan_man)
97 {
98     struct host *p;
99     yaz_mutex_enter(hosts->mutex);
100     for (p = hosts->hosts; p; p = p->next)
101         if (!strcmp(p->url, url))
102             break;
103     if (!p)
104     {
105         p = create_host(url, proxy, port, iochan_man);
106         if (p)
107         {
108             p->next = hosts->hosts;
109             hosts->hosts = p;
110         }
111     }
112     yaz_mutex_leave(hosts->mutex);
113     return p;
114 }
115
116 database_hosts_t database_hosts_create(void)
117 {
118     database_hosts_t p = xmalloc(sizeof(*p));
119     p->hosts = 0;
120     p->mutex = 0;
121     pazpar2_mutex_create(&p->mutex, "database");
122     return p;
123 }
124
125 void database_hosts_destroy(database_hosts_t *pp)
126 {
127     if (*pp)
128     {
129         struct host *p = (*pp)->hosts;
130         while (p)
131         {
132             struct host *p_next = p->next;
133             yaz_mutex_destroy(&p->mutex);
134             yaz_cond_destroy(&p->cond_ready);
135             xfree(p->url);
136             xfree(p->ipport);
137             xfree(p);
138             p = p_next;
139         }
140         yaz_mutex_destroy(&(*pp)->mutex);
141         xfree(*pp);
142     }
143 }
144
145 /*
146  * Local variables:
147  * c-basic-offset: 4
148  * c-file-style: "Stroustrup"
149  * indent-tabs-mode: nil
150  * End:
151  * vim: shiftwidth=4 tabstop=8 expandtab
152  */
153