X-Git-Url: http://git.indexdata.com/?a=blobdiff_plain;f=src%2Fdatabase.c;h=da26ed05f02f9b0fbdf4951c9bb852422565159a;hb=cca105c35464171daf2945161bf4f6a0a52a4d52;hp=8ffbee2328a71984fc8b93ab95f67a7c65d65296;hpb=ca9817524ebe069581ad72f6bca0e9775d61e30c;p=pazpar2-moved-to-github.git diff --git a/src/database.c b/src/database.c index 8ffbee2..da26ed0 100644 --- a/src/database.c +++ b/src/database.c @@ -29,6 +29,7 @@ Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA #include #include +#include "ppmutex.h" #include "session.h" #include "host.h" #include "pazpar2_config.h" @@ -109,7 +110,9 @@ static struct host *create_host(const char *hostport, iochan_man_t iochan_man) xfree(host); return 0; } - yaz_mutex_create(&host->mutex); + pazpar2_mutex_create(&host->mutex, "host"); + + yaz_cond_create(&host->cond_ready); return host; } @@ -184,7 +187,7 @@ struct database *new_database(const char *id, NMEM nmem) db->errors = 0; db->explain = 0; - db->num_settings = PZ_NEGOTIATION_CHARSET+1; + db->num_settings = PZ_MAX_EOF; db->settings = nmem_malloc(nmem, sizeof(struct settings*) * db->num_settings); memset(db->settings, 0, sizeof(struct settings*) * db->num_settings); @@ -410,10 +413,30 @@ database_hosts_t database_hosts_create(void) database_hosts_t p = xmalloc(sizeof(*p)); p->hosts = 0; p->mutex = 0; - yaz_mutex_create(&p->mutex); + pazpar2_mutex_create(&p->mutex, "database"); return p; } +void database_hosts_destroy(database_hosts_t *pp) +{ + if (*pp) + { + struct host *p = (*pp)->hosts; + while (p) + { + struct host *p_next = p->next; + yaz_mutex_destroy(&p->mutex); + yaz_cond_destroy(&p->cond_ready); + xfree(p->ipport); + xfree(p->hostport); + xfree(p); + p = p_next; + } + yaz_mutex_destroy(&(*pp)->mutex); + xfree(*pp); + } +} + /* * Local variables: * c-basic-offset: 4