2 * Copyright (c) 1995, the EUROPAGATE consortium (see below).
4 * The EUROPAGATE consortium members are:
6 * University College Dublin
7 * Danmarks Teknologiske Videnscenter
8 * An Chomhairle Leabharlanna
9 * Consejo Superior de Investigaciones Cientificas
11 * Permission to use, copy, modify, distribute, and sell this software and
12 * its documentation, in whole or in part, for any purpose, is hereby granted,
15 * 1. This copyright and permission notice appear in all copies of the
16 * software and its documentation. Notices of copyright or attribution
17 * which appear at the beginning of any file must remain unchanged.
19 * 2. The names of EUROPAGATE or the project partners may not be used to
20 * endorse or promote products derived from this software without specific
21 * prior written permission.
23 * 3. Users of this software (implementors and gateway operators) agree to
24 * inform the EUROPAGATE consortium of their use of the software. This
25 * information will be used to evaluate the EUROPAGATE project and the
26 * software, and to plan further developments. The consortium may use
27 * the information in later publications.
29 * 4. Users of this software agree to make their best efforts, when
30 * documenting their use of the software, to acknowledge the EUROPAGATE
31 * consortium, and the role played by the software in their work.
33 * THIS SOFTWARE IS PROVIDED "AS IS" AND WITHOUT WARRANTY OF ANY KIND,
34 * EXPRESS, IMPLIED, OR OTHERWISE, INCLUDING WITHOUT LIMITATION, ANY
35 * WARRANTY OF MERCHANTABILITY OR FITNESS FOR A PARTICULAR PURPOSE.
36 * IN NO EVENT SHALL THE EUROPAGATE CONSORTIUM OR ITS MEMBERS BE LIABLE
37 * FOR ANY SPECIAL, INCIDENTAL, INDIRECT OR CONSEQUENTIAL DAMAGES OF
38 * ANY KIND, OR ANY DAMAGES WHATSOEVER RESULTING FROM LOSS OF USE, DATA
39 * OR PROFITS, WHETHER OR NOT ADVISED OF THE POSSIBILITY OF DAMAGE, AND
40 * ON ANY THEORY OF LIABILITY, ARISING OUT OF OR IN CONNECTION WITH THE
41 * USE OR PERFORMANCE OF THIS SOFTWARE.
44 /* Gateway kernel - Z39.50 Persistence
48 * Revision 1.10 1995/07/20 08:16:38 adam
49 * Bug fix in persist.c: Double referenced result-sets weren't recovered.
51 * Revision 1.9 1995/05/19 13:26:00 adam
52 * Bug fixes. Better command line options.
54 * Revision 1.8 1995/05/16 09:40:43 adam
55 * LICENSE. Setting of CCL token names (and/or/not/set) in read_kernel_res.
57 * Revision 1.7 1995/05/03 16:34:19 adam
58 * CCL def command, i.e. user definitions - saved as resource files.
60 * Revision 1.6 1995/05/03 07:37:44 adam
61 * CCL commands stop/continue implemented. New functions gw_res_{int,bool}
62 * are used when possible.
64 * Revision 1.5 1995/05/02 15:26:00 adam
65 * Monitor observes death of child (email kernel). The number
66 * of simultanous processes is controlled now. Email requests are
67 * queued if necessary. This scheme should only be forced if no kernels
70 * Revision 1.4 1995/04/20 16:10:46 adam
71 * Modified to work with non-blocking zass-api. Not using non-blocking
74 * Revision 1.3 1995/04/19 13:19:09 adam
75 * New command: account - for authentication.
77 * Revision 1.2 1995/04/19 10:46:19 adam
78 * Persistency works much better now. New command: status - history-like
80 * Revision 1.1 1995/04/19 07:31:10 adam
81 * First work on Z39.50 persistence.
95 static int fgetsx (char *buf, int size, FILE *inf)
99 if (!fgets (buf, size, inf))
101 if ((cp = strchr (buf, '\n')))
106 static int set_change;
108 static int obtain_set (ZASS zass, struct gw_user_set *set)
110 const struct zass_searchent *p;
112 gw_log (GW_LOG_DEBUG, KERNEL_LOG, "Set %s must be obtained", set->name);
113 p = zass_search (zass, set->rpn, set->name, set->database, NULL);
116 if (p->errcode != -1)
118 if (p->num != set->hits)
120 set->present_flag = 1;
122 gw_log (GW_LOG_DEBUG, KERNEL_LOG, "Set %s researched", set->name);
126 static int obtain_sets (ZASS zass, struct ccl_rpn_node *rpn,
127 struct gw_user_set *sets)
129 struct gw_user_set *set;
138 if ((r=obtain_sets (zass, rpn->u.p[0], sets)))
140 return obtain_sets (zass, rpn->u.p[1], sets);
144 set = user_set_search (rpn->u.setname);
147 gw_log (GW_LOG_DEBUG, KERNEL_LOG, "Set %s not there at all",
151 if (set->present_flag)
153 gw_log (GW_LOG_DEBUG, KERNEL_LOG, "Set %s already there",
158 obtain_sets (zass, set->rpn, sets);
159 return obtain_set (zass, set);
162 const struct zass_searchent *zass_p_search (ZASS zass,
163 struct ccl_rpn_node *rpn,
164 const char *result_set,
165 const char *database,
166 struct gw_user_set *sets)
171 r = obtain_sets (zass, rpn, sets);
174 return zass_search (zass, rpn, (char*) result_set, (char*) database, NULL);
177 const struct zass_presentent *zass_p_present (ZASS zass,
178 const char *result_set, int offset, int number)
180 struct gw_user_set *set;
182 set = user_set_search (result_set);
185 if (!set->present_flag)
187 const struct zass_searchent *p;
189 p = zass_p_search (zass, set->rpn, result_set, set->database,
194 return zass_present (zass, (char*) result_set, offset, number, NULL);
197 struct ccl_rpn_node *load_rpn (char *buf, FILE *inf)
199 struct ccl_rpn_node *rpn;
200 struct ccl_rpn_attr **attrp;
201 int type, value, no_read;
204 if (!fgetsx (buf, 1024, inf))
206 rpn = malloc (sizeof (*rpn));
212 rpn->kind = CCL_RPN_AND;
213 rpn->u.p[0] = load_rpn (buf, inf);
214 rpn->u.p[1] = load_rpn (buf, inf);
217 rpn->kind = CCL_RPN_OR;
218 rpn->u.p[0] = load_rpn (buf, inf);
219 rpn->u.p[1] = load_rpn (buf, inf);
222 rpn->kind = CCL_RPN_NOT;
223 rpn->u.p[0] = load_rpn (buf, inf);
224 rpn->u.p[1] = load_rpn (buf, inf);
227 rpn->kind = CCL_RPN_PROX;
228 rpn->u.p[0] = load_rpn (buf, inf);
229 rpn->u.p[1] = load_rpn (buf, inf);
232 rpn->kind = CCL_RPN_TERM;
234 rpn->u.t.term = gw_strdup (buf+2);
235 attrp = &rpn->u.t.attr_list;
236 if (!fgetsx (buf, 1024, inf))
239 while (sscanf (cp, "%d %d%n", &type, &value, &no_read) > 1)
241 *attrp = malloc (sizeof(**attrp));
242 (*attrp)->type = type;
243 (*attrp)->value = value;
244 attrp = &(*attrp)->next;
250 rpn->kind = CCL_RPN_SET;
251 rpn->u.setname = gw_strdup (buf+2);
260 int load_p_state (int userid)
268 struct gw_user_set *set;
270 sprintf (fname, "user.%d.p", userid);
272 inf = fopen (fname, "r");
275 gw_log (GW_LOG_WARN|GW_LOG_ERRNO, KERNEL_LOG,
276 "Couldn't open %s", fname);
279 gw_log (GW_LOG_DEBUG, KERNEL_LOG,
280 "Reading persistence file %s", fname);
282 if (!fgetsx (fline, 1024, inf))
284 if (sscanf (fline, "%s", info.target) != 1)
288 if (!fgetsx (fline, 1024, inf))
290 if (sscanf (fline, "%s", info.account) != 1)
291 *info.account = '\0';
293 if (!fgetsx (fline, 1024, inf))
295 free (info.database);
296 info.database = gw_strdup (fline);
298 if (!fgetsx (fline, 1024, inf))
300 if (sscanf (fline, "%d", &info.setno) != 1)
302 if (!fgetsx (fline, 1024, inf))
304 if (sscanf (fline, "%d", &info.next_position) != 1)
306 gw_log (GW_LOG_DEBUG, KERNEL_LOG,
307 "Reading persistence file %s (2)", fname);
308 while (fgetsx (fline, 1024, inf))
310 gw_log (GW_LOG_DEBUG, KERNEL_LOG,
311 "Reading persistence file %s (3)", fname);
312 if (sscanf (fline, "%s %d %s", resultname, &hits, database) != 3)
314 if (!fgetsx (fline, 1024, inf)) /* search string */
316 gw_log (GW_LOG_DEBUG, KERNEL_LOG,
317 "Adding %s, %d hits, database %s",
318 resultname, hits, database);
319 gw_log (GW_LOG_DEBUG, KERNEL_LOG, "Search string %s", fline);
320 set = user_set_add (resultname, hits, database, NULL, 0, fline);
321 set->rpn = load_rpn (fline, inf);
323 ccl_pr_tree (set->rpn, stderr);
325 fgetsx (fline, 1024, inf);
328 gw_log (GW_LOG_DEBUG, KERNEL_LOG, "Finished reading %s", fname);
332 static void save_rpn (struct ccl_rpn_node *rpn, FILE *of)
334 struct ccl_rpn_attr *attr;
340 save_rpn (rpn->u.p[0], of);
341 save_rpn (rpn->u.p[1], of);
345 save_rpn (rpn->u.p[0], of);
346 save_rpn (rpn->u.p[1], of);
350 save_rpn (rpn->u.p[0], of);
351 save_rpn (rpn->u.p[1], of);
355 save_rpn (rpn->u.p[0], of);
356 save_rpn (rpn->u.p[1], of);
359 fprintf (of, "T %s\n", rpn->u.t.term);
360 for (attr = rpn->u.t.attr_list; attr; attr = attr->next)
361 fprintf (of, "%d %d ", attr->type, attr->value);
365 fprintf (of, "S %s\n", rpn->u.setname);
369 static void save_sets (FILE *of, struct gw_user_set *sp)
373 save_sets (of, sp->prev);
374 fprintf (of, "%s %d %s\n%s\n", sp->name, sp->hits, sp->database,
376 save_rpn (sp->rpn, of);
380 int save_p_state (int userid)
385 sprintf (fname, "user.%d.p", userid);
387 of = fopen (fname, "w");
390 gw_log (GW_LOG_WARN|GW_LOG_ERRNO, KERNEL_LOG,
391 "Couldn't open %s", fname);
394 gw_log (GW_LOG_DEBUG, KERNEL_LOG, "Writing persistence file %s", fname);
395 fprintf (of, "%s\n%s\n%s\n%d\n%d\n", info.target, info.account,
396 info.database, info.setno, info.next_position);
397 save_sets (of, info.sets);
402 void del_p_state (int userid)
406 sprintf (fname, "user.%d.p", userid);