zoom/zoomtst7.c

   1 /*
   2  * $Id: zoomtst7.c,v 1.9 2002-02-20 14:40:42 adam Exp $
   3  *
   4  * API test..
   5  */
   6
   7 #include <stdio.h>
   8 #include <stdlib.h>
   9 #include <assert.h>
  10
  11 #include <yaz/xmalloc.h>
  12 #include <yaz/nmem.h>
  13
  14 #include <yaz/zoom.h>
  15
  16 int main(int argc, char **argv)
  17 {
  18     int i, j, block;
  19     ZOOM_connection z;
  20     ZOOM_resultset r[10];  /* and result sets .. */
  21     ZOOM_options o;
  22
  23     nmem_init ();
  24     o = ZOOM_options_create ();
  25
  26     z = ZOOM_connection_new ("localhost", 9999);
  27     if (ZOOM_connection_error (z, 0, 0))
  28     {
  29         printf ("error - couldn't connect?\n");
  30         exit (1);
  31     }
  32
  33     ZOOM_connection_destroy (z);
  34
  35     for (block = 0; block < 3; block++)
  36     {
  37         switch (block)
  38         {
  39         case 0:
  40             printf ("blocking - not calling ZOOM_events\n");
  41             break;
  42         case 1:
  43             printf ("blocking - calling ZOOM_events\n");
  44             break;
  45         case 2:
  46             printf ("non-blocking - calling ZOOM_events\n");
  47             break;
  48         }
  49         if (block > 1)
  50             ZOOM_options_set (o, "async", "1");
  51         for (i = 0; i<10; i++)
  52         {
  53             char host[40];
  54
  55             printf ("session %2d", i);
  56             sprintf (host, "localhost:9999/%d", i);
  57             z = ZOOM_connection_create (o);
  58             ZOOM_connection_connect (z, host, 0);
  59
  60             for (j = 0; j < 10; j++)
  61             {
  62                 ZOOM_record recs[2];
  63                 char query[40];
  64                 ZOOM_query s = ZOOM_query_create ();
  65
  66                 sprintf (query, "i%dr%d", i, j);
  67
  68                 if (ZOOM_query_prefix (s, query))
  69                 {
  70                     printf ("bad PQF: %s\n", query);
  71                     exit (2);
  72                 }
  73                 ZOOM_options_set (o, "start", "0");
  74                 ZOOM_options_set (o, "count", "0");
  75
  76                 r[j] = ZOOM_connection_search (z, s); /* non-piggy */
  77
  78                 ZOOM_resultset_records (r[j], recs, 0, 2);  /* first two */
  79
  80                 ZOOM_resultset_records (r[j], recs, 1, 2);  /* third */
  81
  82                 ZOOM_resultset_records (r[j], recs, 0, 0);  /* ignored */
  83
  84                 if (ZOOM_resultset_size (r[j]) > 2)
  85                 {
  86                     if (!recs[0])
  87                     {
  88                         fprintf (stderr, "\nrecord missing\n");
  89                         exit (1);
  90                     }
  91                 }
  92
  93                 ZOOM_query_destroy (s);
  94
  95                 printf (".");
  96                 if (block > 0)
  97                     while (ZOOM_event (1, &z))
  98                         ;
  99             }
 100             for (j = 0; j<i; j++)
 101                 ZOOM_resultset_destroy (r[j]);
 102             ZOOM_connection_destroy (z);
 103             for (; j < 10; j++)
 104                 ZOOM_resultset_destroy (r[j]);
 105             printf ("10 searches, 20 presents done\n");
 106
 107         }
 108
 109         for (i = 0; i<1; i++)
 110         {
 111             ZOOM_query q = ZOOM_query_create ();
 112             char host[40];
 113
 114             printf ("session %2d", i+10);
 115             sprintf (host, "localhost:9999/%d", i);
 116             z = ZOOM_connection_create (o);
 117             ZOOM_connection_connect (z, host, 0);
 118
 119             for (j = 0; j < 10; j++)
 120             {
 121                 char query[40];
 122
 123                 sprintf (query, "i%dr%d", i, j);
 124
 125                 ZOOM_options_set (o, "count", "0");
 126
 127                 r[j] = ZOOM_connection_search_pqf (z, query);
 128
 129                 printf (".");
 130                 if (block > 0)
 131                     while (ZOOM_event (1, &z))
 132                         ;
 133             }
 134
 135             ZOOM_connection_destroy (z);
 136
 137             for (j = 0; j < 10; j++)
 138             {
 139                 ZOOM_resultset_records (r[j], 0, 0, 1);
 140                 if (block > 0)
 141                     while (ZOOM_event (1, &z))
 142                         ;
 143             }
 144             for (j = 0; j < 10; j++)
 145                 ZOOM_resultset_destroy (r[j]);
 146             ZOOM_query_destroy (q);
 147             printf ("10 searches, 10 ignored presents done\n");
 148         }
 149
 150
 151         for (i = 0; i<1; i++)
 152         {
 153             char host[40];
 154             ZOOM_scanset scan = 0;
 155
 156             printf ("session %2d", i);
 157             sprintf (host, "localhost:9999/%d", i);
 158             z = ZOOM_connection_create (o);
 159             ZOOM_connection_connect (z, host, 0);
 160
 161             scan = ZOOM_connection_scan (z, "@attr 1=4 a");
 162             if (block > 0)
 163                 while (ZOOM_event (1, &z))
 164                     ;
 165             printf (" scan size = %d\n", ZOOM_scanset_size(scan));
 166             for (j = 0; j<ZOOM_scanset_size (scan); j++)
 167             {
 168                 int occur, len;
 169                 const char *term;
 170                 term = ZOOM_scanset_term (scan, j, &occur, &len);
 171                 if (term)
 172                     printf ("%d %.*s %d\n", j, len, term, occur);
 173
 174             }
 175             ZOOM_scanset_destroy (scan);
 176             ZOOM_connection_destroy (z);
 177         }
 178
 179     }
 180     ZOOM_options_destroy (o);
 181     xmalloc_trav("");
 182     nmem_exit();
 183     xmalloc_trav("");
 184     exit (0);
 185 }
 186