X-Git-Url: http://git.indexdata.com/?a=blobdiff_plain;f=index%2Fzebraapi.c;h=58b99beb0ba1b2b490a65729840e8039d9c97134;hb=3e72747f4b28856e5f684dbe8984f8fb28680e62;hp=13b913ed6e66aff97c5c480633b70c567c07d550;hpb=98e21f950e6d0babe88a6a1ccb03b90f0b3a6b1a;p=idzebra-moved-to-github.git diff --git a/index/zebraapi.c b/index/zebraapi.c index 13b913e..58b99be 100644 --- a/index/zebraapi.c +++ b/index/zebraapi.c @@ -2,7 +2,7 @@ * Copyright (C) 1995-2002, Index Data * All rights reserved. * - * $Id: zebraapi.c,v 1.52 2002-04-04 20:50:37 adam Exp $ + * $Id: zebraapi.c,v 1.59 2002-04-26 08:44:47 adam Exp $ */ #include @@ -50,9 +50,6 @@ static struct zebra_register *zebra_register_open (ZebraService zs, const char *reg_path); static void zebra_register_close (ZebraService zs, struct zebra_register *reg); -static int zebra_begin_read (ZebraHandle zh); -static void zebra_end_read (ZebraHandle zh); - ZebraHandle zebra_open (ZebraService zs) { ZebraHandle zh; @@ -83,6 +80,8 @@ ZebraHandle zebra_open (ZebraService zs) zh->admin_databaseName = 0; + zh->shadow_enable = 1; + zebra_mutex_cond_lock (&zs->session_lock); zh->next = zs->sessions; @@ -182,11 +181,10 @@ struct zebra_register *zebra_register_open (ZebraService zs, const char *name, reg->sortIdx = 0; reg->isams = 0; reg->matchDict = 0; -#if ZMBOL reg->isam = 0; reg->isamc = 0; reg->isamd = 0; -#endif + reg->isamb = 0; reg->zei = 0; reg->matchDict = 0; @@ -227,8 +225,7 @@ struct zebra_register *zebra_register_open (ZebraService zs, const char *name, return 0; } } -#if ZMBOL - else if (res_get_match (res, "isam", "i", ISAM_DEFAULT)) + if (res_get_match (res, "isam", "i", ISAM_DEFAULT)) { if (!(reg->isam = is_open (reg->bfs, FNAME_ISAM, key_compare, rw, sizeof (struct it_key), res))) @@ -237,7 +234,7 @@ struct zebra_register *zebra_register_open (ZebraService zs, const char *name, return 0; } } - else if (res_get_match (res, "isam", "c", ISAM_DEFAULT)) + if (res_get_match (res, "isam", "c", ISAM_DEFAULT)) { struct ISAMC_M_s isamc_m; if (!(reg->isamc = isc_open (reg->bfs, FNAME_ISAMC, @@ -247,7 +244,7 @@ struct zebra_register *zebra_register_open (ZebraService zs, const char *name, return 0; } } - else if (res_get_match (res, "isam", "d", ISAM_DEFAULT)) + if (res_get_match (res, "isam", "d", ISAM_DEFAULT)) { struct ISAMD_M_s isamd_m; @@ -258,7 +255,17 @@ struct zebra_register *zebra_register_open (ZebraService zs, const char *name, return 0; } } -#endif + if (res_get_match (res, "isam", "b", ISAM_DEFAULT)) + { + struct ISAMC_M_s isamc_m; + + if (!(reg->isamb = isamb_open (reg->bfs, "isamb", + rw, key_isamc_m(res, &isamc_m)))) + { + logf (LOG_WARN, "isamb_open"); + return 0; + } + } reg->zei = zebraExplain_open (reg->records, reg->dh, res, rw, reg, explain_extract); @@ -301,14 +308,14 @@ static void zebra_register_close (ZebraService zs, struct zebra_register *reg) sortIdx_close (reg->sortIdx); if (reg->isams) isams_close (reg->isams); -#if ZMBOL if (reg->isam) is_close (reg->isam); if (reg->isamc) isc_close (reg->isamc); if (reg->isamd) isamd_close (reg->isamd); -#endif + if (reg->isamb) + isamb_close (reg->isamb); rec_close (®->records); } @@ -388,7 +395,7 @@ void zebra_close (ZebraHandle zh) zebra_mutex_cond_unlock (&zs->session_lock); xfree (zh->reg_name); xfree (zh); - yaz_log (LOG_LOG, "zebra_close zh=%p end", zh);} +} struct map_baseinfo { ZebraHandle zh; @@ -562,7 +569,7 @@ int zebra_select_databases (ZebraHandle zh, int num_bases, { int i; const char *cp; - size_t len = 0; + int len = 0; char *new_reg = 0; if (num_bases < 1) @@ -601,7 +608,7 @@ int zebra_select_databases (ZebraHandle zh, int num_bases, zh->errCode = 23; return -1; } - if (len != cp - basenames[i] || + if (len != cp1 - basenames[i] || memcmp (basenames[i], new_reg, len)) { zh->errCode = 23; @@ -912,7 +919,7 @@ void zebra_get_state (ZebraHandle zh, char *val, int *seqno) xfree (fname); } -static int zebra_begin_read (ZebraHandle zh) +int zebra_begin_read (ZebraHandle zh) { int dirty = 0; char val; @@ -927,6 +934,9 @@ static int zebra_begin_read (ZebraHandle zh) zebra_flush_reg (zh); return 0; } +#if HAVE_SYS_TIMES_H + times (&zh->tms1); +#endif if (!zh->res) { (zh->trans_no)--; @@ -975,13 +985,21 @@ static int zebra_begin_read (ZebraHandle zh) return 0; } -static void zebra_end_read (ZebraHandle zh) +void zebra_end_read (ZebraHandle zh) { (zh->trans_no)--; if (zh->trans_no != 0) return; +#if HAVE_SYS_TIMES_H + times (&zh->tms2); + logf (LOG_LOG, "user/system: %ld/%ld", + (long) (zh->tms2.tms_utime - zh->tms1.tms_utime), + (long) (zh->tms2.tms_stime - zh->tms1.tms_stime)); + +#endif + zebra_unlock (zh->lock_normal); zebra_unlock (zh->lock_shadow); } @@ -991,7 +1009,7 @@ void zebra_begin_trans (ZebraHandle zh) int pass; int seqno = 0; char val = '?'; - const char *rval; + const char *rval = 0; assert (zh->res); @@ -1002,12 +1020,19 @@ void zebra_begin_trans (ZebraHandle zh) } yaz_log (LOG_LOG, "zebra_begin_trans"); + + zh->records_inserted = 0; + zh->records_updated = 0; + zh->records_deleted = 0; + zh->records_processed = 0; + #if HAVE_SYS_TIMES_H times (&zh->tms1); #endif /* lock */ - rval = res_get (zh->res, "shadow"); + if (zh->shadow_enable) + rval = res_get (zh->res, "shadow"); for (pass = 0; pass < 2; pass++) { @@ -1081,6 +1106,11 @@ void zebra_end_trans (ZebraHandle zh) zebra_register_close (zh->service, zh->reg); zh->reg = 0; + + yaz_log (LOG_LOG, "Records: %7d i/u/d %d/%d/%d", + zh->records_processed, zh->records_inserted, + zh->records_updated, zh->records_deleted); + zebra_get_state (zh, &val, &seqno); if (val != 'd') { @@ -1158,7 +1188,9 @@ int zebra_commit (ZebraHandle zh) zebra_set_state (zh, 'c', seqno); logf (LOG_LOG, "commit start"); +#ifndef WIN32 sleep (2); +#endif bf_commitExec (bfs); #ifndef WIN32 sync (); @@ -1244,3 +1276,8 @@ void zebra_result (ZebraHandle zh, int *code, char **addinfo) *addinfo = zh->errString; } +void zebra_shadow_enable (ZebraHandle zh, int value) +{ + zh->shadow_enable = value; +} +