X-Git-Url: http://git.indexdata.com/?a=blobdiff_plain;ds=sidebyside;f=index%2Flocksrv.c;h=0140718b1685c03d11c34dc6860380ff291db3f1;hb=47eeb5384a8fae8bcac8afb8a84782ca094683f9;hp=7591349f3e10ae5bbb07c8715641f796a6d691d6;hpb=3c5f6226f97612c0d6ac40591f600587c5ffa858;p=idzebra-moved-to-github.git diff --git a/index/locksrv.c b/index/locksrv.c index 7591349..0140718 100644 --- a/index/locksrv.c +++ b/index/locksrv.c @@ -1,57 +1,32 @@ -/* - * Copyright (C) 1994-1999, Index Data - * All rights reserved. - * Sebastian Hammer, Adam Dickmeiss - * - * $Log: locksrv.c,v $ - * Revision 1.12 1999-02-02 14:50:58 adam - * Updated WIN32 code specific sections. Changed header. - * - * Revision 1.11 1998/03/05 08:45:12 adam - * New result set model and modular ranking system. Moved towards - * descent server API. System information stored as "SGML" records. - * - * Revision 1.10 1997/09/29 09:08:36 adam - * Revised locking system to be thread safe for the server. - * - * Revision 1.9 1997/09/25 14:54:43 adam - * WIN32 files lock support. - * - * Revision 1.8 1997/09/17 12:19:15 adam - * Zebra version corresponds to YAZ version 1.4. - * Changed Zebra server so that it doesn't depend on global common_resource. - * - * Revision 1.7 1997/09/04 13:58:04 adam - * Added O_BINARY for open calls. - * - * Revision 1.6 1996/10/29 14:06:52 adam - * Include zebrautl.h instead of alexutil.h. - * - * Revision 1.5 1996/05/15 11:58:18 adam - * Changed some log messages. - * - * Revision 1.4 1996/04/10 16:01:27 quinn - * Fixed order of path/filename. - * - * Revision 1.3 1995/12/11 11:43:29 adam - * Locking based on fcntl instead of flock. - * Setting commitEnable removed. Command line option -n can be used to - * prevent commit if commit setting is defined in the configuration file. - * - * Revision 1.2 1995/12/08 16:22:55 adam - * Work on update while servers are running. Three lock files introduced. - * The servers reload their registers when necessary, but they don't - * reestablish result sets yet. - * - * Revision 1.1 1995/12/07 17:38:47 adam - * Work locking mechanisms for concurrent updates/commit. - * - */ +/* $Id: locksrv.c,v 1.20 2005-06-14 20:28:54 adam Exp $ + Copyright (C) 1995-2005 + Index Data ApS + +This file is part of the Zebra server. + +Zebra is free software; you can redistribute it and/or modify it under +the terms of the GNU General Public License as published by the Free +Software Foundation; either version 2, or (at your option) any later +version. + +Zebra is distributed in the hope that it will be useful, but WITHOUT ANY +WARRANTY; without even the implied warranty of MERCHANTABILITY or +FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License +for more details. + +You should have received a copy of the GNU General Public License +along with Zebra; see the file LICENSE.zebra. If not, write to the +Free Software Foundation, 59 Temple Place - Suite 330, Boston, MA +02111-1307, USA. +*/ + + #include #include #ifdef WIN32 #include -#else +#endif +#if HAVE_UNISTD_H #include #endif #include @@ -61,32 +36,31 @@ #include "zserver.h" -int zebra_server_lock_init (ZebraHandle zi) +int zebra_server_lock_init (ZebraService zi) { char path_prefix[1024]; - assert (zi->res); zi->server_lock_cmt = NULL; zi->server_lock_org = NULL; zebra_lock_prefix (zi->res, path_prefix); - zi->server_path_prefix = xmalloc (strlen(path_prefix)+1); + zi->server_path_prefix = (char *) xmalloc (strlen(path_prefix)+1); strcpy (zi->server_path_prefix, path_prefix); - logf (LOG_DEBUG, "Locking system initialized"); + yaz_log (YLOG_DEBUG, "Locking system initialized"); return 0; } -int zebra_server_lock_destroy (ZebraHandle zi) +int zebra_server_lock_destroy (ZebraService zi) { xfree (zi->server_path_prefix); zebra_lock_destroy (zi->server_lock_cmt); zebra_lock_destroy (zi->server_lock_org); - logf (LOG_DEBUG, "Locking system destroyed"); + yaz_log (YLOG_DEBUG, "Locking system destroyed"); return 0; } -int zebra_server_lock (ZebraHandle zi, int commitPhase) +int zebra_server_lock (ZebraService zi, int commitPhase) { if (!zi->server_lock_cmt) { @@ -96,7 +70,7 @@ int zebra_server_lock (ZebraHandle zi, int commitPhase) strcat (path, FNAME_COMMIT_LOCK); if (!(zi->server_lock_cmt = zebra_lock_create (path, 0))) { - logf (LOG_FATAL|LOG_ERRNO, "create %s", path); + yaz_log (YLOG_FATAL|YLOG_ERRNO, "create %s", path); return -1; } assert (zi->server_lock_org == NULL); @@ -105,40 +79,34 @@ int zebra_server_lock (ZebraHandle zi, int commitPhase) strcat (path, FNAME_ORG_LOCK); if (!(zi->server_lock_org = zebra_lock_create (path, 0))) { - logf (LOG_FATAL|LOG_ERRNO, "create %s", path); + yaz_log (YLOG_FATAL|YLOG_ERRNO, "create %s", path); return -1; } } if (commitPhase) { - logf (LOG_DEBUG, "Server locks org"); + yaz_log (YLOG_DEBUG, "Server locks org"); zebra_lock (zi->server_lock_org); } else { - logf (LOG_DEBUG, "Server locks cmt"); + yaz_log (YLOG_DEBUG, "Server locks cmt"); zebra_lock (zi->server_lock_cmt); } return 0; } -void zebra_server_unlock (ZebraHandle zi, int commitPhase) +void zebra_server_unlock (ZebraService zi, int commitPhase) { if (zi->server_lock_org == NULL) return; - if (commitPhase) - { - logf (LOG_DEBUG, "Server unlocks org"); - zebra_unlock (zi->server_lock_org); - } - else - { - logf (LOG_DEBUG, "Server unlocks cmt"); - zebra_unlock (zi->server_lock_cmt); - } + yaz_log (YLOG_DEBUG, "Server unlocks org"); + zebra_unlock (zi->server_lock_org); + yaz_log (YLOG_DEBUG, "Server unlocks cmt"); + zebra_unlock (zi->server_lock_cmt); } -int zebra_server_lock_get_state (ZebraHandle zi, time_t *timep) +int zebra_server_lock_get_state (ZebraService zi, time_t *timep) { char path[1024]; char buf[256]; @@ -150,7 +118,7 @@ int zebra_server_lock_get_state (ZebraHandle zi, time_t *timep) if (stat (path, &xstat) == -1) *timep = 1; else - *timep = xstat.st_ctime; + *timep = xstat.st_mtime; strcpy (path, zi->server_path_prefix); strcat (path, FNAME_MAIN_LOCK);