src/host.c

   1 /* This file is part of Pazpar2.
   2    Copyright (C) 2006-2013 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 #include <yaz/matchstr.h>
  30
  31 #include "ppmutex.h"
  32 #include "session.h"
  33 #include "host.h"
  34
  35 #include <sys/types.h>
  36
  37 struct database_hosts {
  38     struct host *hosts;
  39     YAZ_MUTEX mutex;
  40 };
  41
  42 // Create a new host structure for hostport
  43 static struct host *create_host(const char *proxy,
  44                                 const char *tproxy,
  45                                 iochan_man_t iochan_man)
  46 {
  47     struct host *host;
  48
  49     host = xmalloc(sizeof(struct host));
  50     host->proxy = 0;
  51     host->tproxy = 0;
  52     if (proxy && *proxy)
  53         host->proxy = xstrdup(proxy);
  54     else
  55     {
  56         assert(tproxy);
  57         host->tproxy = xstrdup(tproxy);
  58     }
  59     host->connections = 0;
  60     host->ipport = 0;
  61     host->mutex = 0;
  62
  63     if (host_getaddrinfo(host, iochan_man))
  64     {
  65         xfree(host->ipport);
  66         xfree(host->tproxy);
  67         xfree(host->proxy);
  68         xfree(host);
  69         return 0;
  70     }
  71     pazpar2_mutex_create(&host->mutex, "host");
  72
  73     yaz_cond_create(&host->cond_ready);
  74
  75     return host;
  76 }
  77
  78 struct host *find_host(database_hosts_t hosts, const char *url,
  79                        const char *proxy, int port,
  80                        iochan_man_t iochan_man)
  81 {
  82     struct host *p;
  83     char *tproxy = 0;
  84
  85     if (!proxy || !*proxy)
  86     {
  87         char *cp;
  88
  89         tproxy = xmalloc (strlen(url) + 10); /* so we can add :port */
  90         strcpy(tproxy, url);
  91         for (cp = tproxy; *cp; cp++)
  92             if (strchr("/?#~", *cp))
  93             {
  94                 *cp = '\0';
  95                 break;
  96             }
  97         if (!strchr(tproxy, ':'))
  98             sprintf(cp, ":%d", port); /* no port given, add it */
  99     }
 100     yaz_mutex_enter(hosts->mutex);
 101     for (p = hosts->hosts; p; p = p->next)
 102     {
 103         if (!yaz_strcmp_null(p->tproxy, tproxy) &&
 104             !yaz_strcmp_null(p->proxy, proxy))
 105         {
 106             break;
 107         }
 108     }
 109     if (!p)
 110     {
 111         p = create_host(proxy, tproxy, iochan_man);
 112         if (p)
 113         {
 114             p->next = hosts->hosts;
 115             hosts->hosts = p;
 116         }
 117     }
 118     yaz_mutex_leave(hosts->mutex);
 119     xfree(tproxy);
 120     return p;
 121 }
 122
 123 database_hosts_t database_hosts_create(void)
 124 {
 125     database_hosts_t p = xmalloc(sizeof(*p));
 126     p->hosts = 0;
 127     p->mutex = 0;
 128     pazpar2_mutex_create(&p->mutex, "database");
 129     return p;
 130 }
 131
 132 void database_hosts_destroy(database_hosts_t *pp)
 133 {
 134     if (*pp)
 135     {
 136         struct host *p = (*pp)->hosts;
 137         while (p)
 138         {
 139             struct host *p_next = p->next;
 140             yaz_mutex_destroy(&p->mutex);
 141             yaz_cond_destroy(&p->cond_ready);
 142             xfree(p->ipport);
 143             xfree(p);
 144             p = p_next;
 145         }
 146         yaz_mutex_destroy(&(*pp)->mutex);
 147         xfree(*pp);
 148     }
 149 }
 150
 151 /*
 152  * Local variables:
 153  * c-basic-offset: 4
 154  * c-file-style: "Stroustrup"
 155  * indent-tabs-mode: nil
 156  * End:
 157  * vim: shiftwidth=4 tabstop=8 expandtab
 158  */
 159