test/api/t15.c

   1 /* $Id: t15.c,v 1.10 2006-11-23 21:35:02 adam Exp $
   2    Copyright (C) 2004-2006
   3    Index Data ApS
   4
   5 This file is part of the Zebra server.
   6
   7 Zebra is free software; you can redistribute it and/or modify it under
   8 the terms of the GNU General Public License as published by the Free
   9 Software Foundation; either version 2, or (at your option) any later
  10 version.
  11
  12 Zebra is distributed in the hope that it will be useful, but WITHOUT ANY
  13 WARRANTY; without even the implied warranty of MERCHANTABILITY or
  14 FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
  15 for more details.
  16
  17 You should have received a copy of the GNU General Public License
  18 along with this program; if not, write to the Free Software
  19 Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
  20
  21 */
  22
  23 #if HAVE_SYS_STAT_H
  24 #include <sys/stat.h>
  25 #endif
  26 #if HAVE_SYS_TYPES_H
  27 #include <sys/types.h>
  28 #endif
  29 #if HAVE_UNISTD_H
  30 #include <unistd.h>
  31 #endif
  32 #if HAVE_SYS_WAIT_H
  33 #include <sys/wait.h>
  34 #endif
  35
  36 #include <string.h>
  37 #include <sys/utsname.h>
  38
  39 #include "testlib.h"
  40
  41 static void update_process(ZebraService zs, int iter)
  42 {
  43     int i;
  44     for (i = 0; i<iter; i++)
  45     {
  46         const char *rec = "<gils><title>some</title></gils>";
  47         ZebraHandle zh = zebra_open(zs, 0);
  48         zebra_add_record(zh, rec, strlen(rec));
  49         if ((i % 30) == 0 || i == iter-1)
  50             zebra_commit(zh);
  51         zebra_close(zh);
  52     }
  53 }
  54
  55 static void search_process(ZebraService zs, int iter)
  56 {
  57     zint hits_max = 0;
  58     int i;
  59     for (i = 0; i<iter; i++)
  60     {
  61         ZebraHandle zh = zebra_open(zs, 0);
  62         zint hits;
  63         ZEBRA_RES res = zebra_search_PQF(zh, "@attr 1=4 some", "default",
  64                                          &hits);
  65         YAZ_CHECK(res == ZEBRA_OK);
  66
  67         YAZ_CHECK(hits >= hits_max);
  68         if (hits < hits_max)
  69             printf("i=%d hits=%lld hits_max=%lld\n", i, hits, hits_max);
  70         hits_max = hits;
  71         zebra_close(zh);
  72     }
  73 }
  74
  75 static pid_t fork_service(ZebraService zs, int iter,
  76                            void (*f)(ZebraService zs, int iter))
  77 {
  78     pid_t pid = fork();
  79
  80     YAZ_CHECK(pid != -1);
  81     if (pid)
  82         return pid;
  83
  84     (*f)(zs, iter);
  85     YAZ_CHECK_TERM;
  86 }
  87
  88 static void tst(int argc, char **argv)
  89 {
  90     ZebraService zs;
  91     ZebraHandle zh;
  92
  93     mkdir("register", 0775);
  94     mkdir("shadow", 0775);
  95
  96     zs = tl_start_up("zebra15.cfg", argc, argv);
  97     YAZ_CHECK(zs);
  98
  99     zh = zebra_open(zs, 0);
 100     YAZ_CHECK(zh);
 101
 102     YAZ_CHECK(zebra_select_database(zh, "Default") == ZEBRA_OK);
 103
 104     zebra_init(zh);
 105
 106     YAZ_CHECK(zebra_create_database (zh, "Default") == ZEBRA_OK);
 107     YAZ_CHECK(zebra_select_database(zh, "Default") == ZEBRA_OK);
 108     zebra_close(zh);
 109
 110     update_process(zs, 1);
 111
 112 #if HAVE_SYS_WAIT_H
 113 #if HAVE_UNISTD_H
 114
 115     if (1)
 116     {
 117         int tst_with_fork = 1;
 118         int status[3];
 119         pid_t pids[3];
 120         struct utsname s;
 121         uname(&s);
 122         if (!strcmp(s.sysname, "FreeBSD"))
 123             tst_with_fork = 0;
 124
 125         yaz_log(YLOG_LOG, "s.sysname=%s tst_with_fork=%d", s.sysname,
 126             tst_with_fork);
 127         if (tst_with_fork)
 128         {
 129             pids[0] = fork_service(zs, 200, search_process);
 130             pids[1] = fork_service(zs, 20, update_process);
 131             pids[2] = fork_service(zs, 20, update_process);
 132             waitpid(pids[0], &status[0], 0);
 133             YAZ_CHECK(status[0] == 0);
 134             waitpid(pids[1], &status[1], 0);
 135             YAZ_CHECK(status[1] == 0);
 136             waitpid(pids[2], &status[2], 0);
 137             YAZ_CHECK(status[2] == 0);
 138         }
 139     }
 140 #endif
 141 #endif
 142     YAZ_CHECK(tl_close_down(0, zs));
 143 }
 144
 145 TL_MAIN
 146 /*
 147  * Local variables:
 148  * c-basic-offset: 4
 149  * indent-tabs-mode: nil
 150  * End:
 151  * vim: shiftwidth=4 tabstop=8 expandtab
 152  */
 153