X-Git-Url: http://the.earth.li/gitweb/?a=blobdiff_plain;f=onak-mail.pl;h=e5c0d046c188e1eeb8dcb2a592dcd9ac1f3ba975;hb=7f1c2d9ec737a90d4d216f59ccb8b93f9054c472;hp=1c3647c9720f6493393cda7f1f031abf40b8d181;hpb=e3ac2630467e42937478a8e03dec83693912f9c4;p=onak.git

diff --git a/onak-mail.pl b/onak-mail.pl
index 1c3647c..e5c0d04 100755
--- a/onak-mail.pl
+++ b/onak-mail.pl
@@ -6,10 +6,11 @@
 # Copyright 2002 Project Purple
 # Released under the GPL.
 #
-# $Id: onak-mail.pl,v 1.8 2003/10/11 22:17:17 noodles Exp $
+# $Id: onak-mail.pl,v 1.9 2004/01/04 18:48:37 noodles Exp $
 #
 
 use strict;
+use Fcntl ':flock';
 use IPC::Open3;
 
 my %config;
@@ -38,6 +39,8 @@ sub readconfig {
 			$config{'mta'} = $1;
 		} elsif (/^pks_bin_dir (.*)/) {
 			$config{'pks_bin_dir'} = $1;
+		} elsif (/^db_dir (.*)/) {
+			$config{'db_dir'} = $1;
 		} elsif (/^syncsite (.*)/) {
 			push @{$config{'syncsites'}}, $1;
 		}
@@ -59,6 +62,10 @@ sub submitupdate {
 	my @data = @_;
 	my (@errors, @mergedata);
 
+	open(LOCKFILE, '>'.$config{'db_dir'}.'/onak-mail.lck');
+	flock(LOCKFILE, LOCK_EX);
+	print LOCKFILE "$$";
+
 	open3(\*MERGEIN, \*MERGEOUT, \*MERGEERR,
 		$config{'pks_bin_dir'}."/onak", "-u", "add");
 
@@ -69,6 +76,9 @@ sub submitupdate {
 	@errors = <MERGEERR>;
 	close MERGEERR;
 
+	flock(LOCKFILE, LOCK_UN);
+	close(LOCKFILE);
+
 	return @mergedata;
 }