From 8ca43646a6c87d00d5b2cb74cebf65a8d0ea5e8e Mon Sep 17 00:00:00 2001
From: "Suren A. Chilingaryan" <csa@dside.dyndns.org>
Date: Sat, 14 Apr 2007 22:20:10 +0000
Subject: DB4 & Postponed processing     - New DB4 database type     -
 Postponed processing in external module 	+ User may allow external
 module to finish required processing before 	termination. This could be
 useful for translation services while using 	console applications (if
 network connection is slow, the external will 	never finish translation
 before program termination)     - SKIP_PARRENT options are renamed to
 SKIP_PARENT

---
 src/rcclock.c | 108 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 108 insertions(+)
 create mode 100644 src/rcclock.c

(limited to 'src/rcclock.c')

diff --git a/src/rcclock.c b/src/rcclock.c
new file mode 100644
index 0000000..b8f0e8f
--- /dev/null
+++ b/src/rcclock.c
@@ -0,0 +1,108 @@
+#include <stdio.h>
+#include <string.h>
+#include <stdlib.h>
+#include <time.h>
+#include <errno.h>
+
+#include "../config.h"
+
+#ifdef HAVE_SYS_FILE_H
+# include <sys/file.h>
+#endif /* HAVE_SYS_FILE_H */
+
+#ifdef HAVE_UNISTD_H
+# include <unistd.h>
+#endif /* HAVE_UNISTD_H */
+
+#ifdef HAVE_SYS_TYPES_H
+# include <sys/types.h>
+#endif /* HAVE_SYS_TYPES_H */
+#ifdef HAVE_SYS_STAT_H
+# include <sys/stat.h>
+#endif /* HAVE_SYS_STAT_H */
+
+#include "rcchome.h"
+#include "rcclock.h"
+
+static int lockfd = -1;
+
+int rccLock() {
+# ifdef HAVE_SYS_FILE_H
+    int err, i;
+    int size;
+    char *stmp;
+    struct timespec wait = { 0, 10000000 };
+    
+    if (lockfd>=0) return -1;    
+    
+    size = strlen(rcc_home_dir) + 32;
+    stmp = (char*)malloc(size*sizeof(char));
+    if (!stmp) return -1;
+
+    sprintf(stmp,"%s/.rcc/", rcc_home_dir);
+    mkdir(stmp, 00755);
+    
+    sprintf(stmp,"%s/.rcc/locks/", rcc_home_dir);
+    mkdir(stmp, 00700);
+
+    sprintf(stmp,"%s/.rcc/locks/rcc.lock", rcc_home_dir);
+
+    lockfd = open(stmp, O_RDWR|O_CREAT, 0644);
+    if (lockfd >= 0) {
+	for (err = -1, i = 0; i < (LIBRCC_LOCK_WAIT/10); i++) {
+	    err = flock(lockfd, LOCK_EX|LOCK_NB);
+	    if ((err)&&(errno == EWOULDBLOCK)) nanosleep(&wait, NULL);
+	    else break;
+	}
+
+	if (err) {
+	    close(lockfd);
+
+		// Removing invalid lock
+	    if (i == (LIBRCC_LOCK_WAIT/10)) {
+		remove(stmp);
+
+		lockfd = open(stmp, O_RDWR|O_CREAT, 0644);
+		if (lockfd >= 0) {
+		    for (err = -1, i = 0; i < (LIBRCC_LOCK_WAIT/10); i++) {
+			err = flock(lockfd, LOCK_EX|LOCK_NB);
+			if ((err)&&(errno == EWOULDBLOCK)) nanosleep(&wait, NULL);
+			else break;
+		    }
+		    
+		    if (err) close(lockfd);
+		    else return 0;
+		} 
+	    }
+	    
+	    lockfd = -1;
+	    return -1;
+	} 
+
+	return 0;
+    }
+    
+    return -1;
+# else  /* HAVE_SYS_FILE_H */
+    return 0;
+# endif /* HAVE_SYS_FILE_H */
+}
+
+void rccUnLock() {
+#ifdef HAVE_SYS_FILE_H
+    int size;
+    char *stmp;
+
+    if (lockfd<0) return;
+    
+    size = strlen(rcc_home_dir) + 32;
+    stmp = (char*)malloc(size*sizeof(char));
+    if (!stmp) return;
+
+    sprintf(stmp,"%s/.rcc/locks/rcc.lock", rcc_home_dir);
+
+    flock(lockfd, LOCK_UN);
+    close(lockfd);
+    lockfd = -1;
+#endif /* HAVE_SYS_FILE_H */
+}
-- 
cgit v1.2.3