X-Git-Url: http://jsfdemo.indexdata.com/?a=blobdiff_plain;f=index%2Flockidx.c;h=286bd4144578c9a4770f8b9c1df822a894bc9438;hb=5a4211916c8b14d4b0ec9cc717e613b88394affb;hp=dad7181121fa3471d99ba14702458dff21a0b56d;hpb=4ec5e11d0e4db05000b47db4c681d570431c1818;p=idzebra-moved-to-github.git diff --git a/index/lockidx.c b/index/lockidx.c index dad7181..286bd41 100644 --- a/index/lockidx.c +++ b/index/lockidx.c @@ -4,7 +4,18 @@ * Sebastian Hammer, Adam Dickmeiss * * $Log: lockidx.c,v $ - * Revision 1.5 1995-12-13 08:46:09 adam + * Revision 1.8 1997-02-12 20:39:46 adam + * Implemented options -f that limits the log to the first + * records. + * Changed some log messages also. + * + * Revision 1.7 1996/10/29 14:08:13 adam + * Uses resource lockDir instead of lockPath. + * + * Revision 1.6 1996/03/26 16:01:13 adam + * New setting lockPath: directory of various lock files. + * + * Revision 1.5 1995/12/13 08:46:09 adam * Locking uses F_WRLCK and F_RDLCK again! * * Revision 1.4 1995/12/12 16:00:57 adam @@ -33,7 +44,6 @@ #include #include -#include #include "index.h" static int lock_fd = -1; @@ -50,7 +60,7 @@ int zebraIndexWait (int commitPhase) if (server_lock_cmt == -1) { - sprintf (path, "%s%s", FNAME_COMMIT_LOCK, pathPrefix); + sprintf (path, "%s%s", pathPrefix, FNAME_COMMIT_LOCK); if ((server_lock_cmt = open (path, O_CREAT|O_RDWR|O_SYNC, 0666)) == -1) { @@ -62,7 +72,7 @@ int zebraIndexWait (int commitPhase) zebraUnlock (server_lock_cmt); if (server_lock_org == -1) { - sprintf (path, "%s%s", FNAME_ORG_LOCK, pathPrefix); + sprintf (path, "%s%s", pathPrefix, FNAME_ORG_LOCK); if ((server_lock_org = open (path, O_CREAT|O_RDWR|O_SYNC, 0666)) == -1) { @@ -153,12 +163,11 @@ void zebraIndexLock (int commitNow) logf (LOG_FATAL|LOG_ERRNO, "open %s", path); exit (1); } - logf (LOG_LOG, "zebraLockNB"); if (zebraLockNB (lock_fd, 1) == -1) { if (errno == EWOULDBLOCK) { - logf (LOG_LOG, "Waiting for other index process"); + logf (LOG_LOG, "waiting for other index process"); zebraLock (lock_fd, 1); zebraUnlock (lock_fd); close (lock_fd); @@ -172,11 +181,11 @@ void zebraIndexLock (int commitNow) } else { - logf (LOG_WARN, "Unlocked %s", path); + logf (LOG_WARN, "unlocked %s", path); r = read (lock_fd, buf, 256); if (r == 0) { - logf (LOG_WARN, "Zero length %s", path); + logf (LOG_WARN, "zero length %s", path); close (lock_fd); unlink (path); continue; @@ -188,7 +197,7 @@ void zebraIndexLock (int commitNow) } if (*buf == 'r') { - logf (LOG_WARN, "Previous transaction didn't" + logf (LOG_WARN, "previous transaction didn't" " reach commit"); close (lock_fd); bf_commitClean (); @@ -197,7 +206,7 @@ void zebraIndexLock (int commitNow) } else if (*buf == 'd') { - logf (LOG_WARN, "Commit file wan't deleted after commit"); + logf (LOG_WARN, "commit file wan't deleted after commit"); close (lock_fd); bf_commitClean (); unlink (path); @@ -205,7 +214,7 @@ void zebraIndexLock (int commitNow) } else if (*buf == 'w') { - logf (LOG_WARN, "Your index may be inconsistent"); + logf (LOG_WARN, "your index may be inconsistent"); exit (1); } else if (*buf == 'c') @@ -216,13 +225,13 @@ void zebraIndexLock (int commitNow) close (lock_fd); continue; } - logf (LOG_FATAL, "Previous transaction didn't" + logf (LOG_FATAL, "previous transaction didn't" " finish commit. Commit now!"); exit (1); } else { - logf (LOG_FATAL, "Unknown id 0x%02x in %s", *buf, + logf (LOG_FATAL, "unknown id 0x%02x in %s", *buf, path); exit (1); }