File Coverage

blib/lib/NL/File/Lock.pm

Criterion	Covered	Total	%
statement	47	125	37.6
branch	18	74	24.3
condition	5	30	16.6
subroutine	9	17	52.9
pod	0	10	0.0
total	79	256	30.8

#!/usr/bin/perl
# NL::File::Lock - mostNeeded Libs :: File locking (based on lockfiles)
# (C) 2007-2008 Nickolay Kovalev, http://resume.nickola.ru
# E-mail: [e-mail]

package NL::File::Lock;
use strict;

our $VERSION = '0.3';
sub LOCK_SH() {1} # multi-lock
sub LOCK_EX() {2} # mono-lock
sub LOCK_NB() {4} # don't wait lock result
sub LOCK_UN() {8} # unlock

# OS SETTING
$NL::File::Lock::OS_SETTINGS = {
	'IS_SOLARIS' => 0,
	'USE_FCNTL' => 0,
	'FCNTL_ERROR' => ''
};
if ($^O =~ /^(solaris|sunos)$/i) {
	$NL::File::Lock::OS_SETTINGS->{'IS_SOLARIS'} = 1;
	$NL::File::Lock::OS_SETTINGS->{'USE_FCNTL'} = 1;
	eval { require Fcntl; }; # If we can - we will use 'Fcntl'
	if ($@) {
		$NL::File::Lock::OS_SETTINGS->{'USE_FCNTL'} = 0;
		$NL::File::Lock::OS_SETTINGS->{'FCNTL_ERROR'} = $@;
	}
	else { Fcntl->import(); }
}

# Internal DATA
$NL::File::Lock::DATA = {
	'SETTINGS' => {
		'SECONDS_TO_REMOVE_OLD_LOCKS' => 3600*5, # 3600 = 1 hour
		'LOCK_FILE_POSTFIX' => '.lck',
		'dir_for_locks' => '',
		'dir_splitter' => '/',
		'dir_splitters_extra' => []
	},
	'LOCKED_FILES' => {}
};
# Path processing
sub _path_get_file {
	my ($str) = @_;

	foreach my $spl ($NL::File::Lock::DATA->{'SETTINGS'}->{'dir_splitter'}, @{ $NL::File::Lock::DATA->{'SETTINGS'}->{'dir_splitters_extra'} }) {
		my $splitter = quotemeta($spl);
		$str =~ s/^.*$splitter([^$splitter]{0,})$/$1/;
	}
	return $str;
}
sub _path_dir_chomp {
	my ($ref_str) = @_;

	foreach my $spl ($NL::File::Lock::DATA->{'SETTINGS'}->{'dir_splitter'}, @{ $NL::File::Lock::DATA->{'SETTINGS'}->{'dir_splitters_extra'} }) {
		my $splitter = quotemeta($spl);
		${ $ref_str } =~ s/[$splitter]{1,}$//;
	}
}
sub _make_lock_file_name {
	my ($file_name) = @_;

	if ($NL::File::Lock::DATA->{'SETTINGS'}->{'dir_for_locks'} ne '') {
		my $fn = &_path_get_file($file_name);
		if ($fn ne '') {
			return $NL::File::Lock::DATA->{'SETTINGS'}->{'dir_for_locks'}.$NL::File::Lock::DATA->{'SETTINGS'}->{'dir_splitter'}.$fn.$NL::File::Lock::DATA->{'SETTINGS'}->{'LOCK_FILE_POSTFIX'};
		}
	}
	return $file_name.$NL::File::Lock::DATA->{'SETTINGS'}->{'LOCK_FILE_POSTFIX'};
}
# Initialization
sub init {
	my ($dir_for_locks, $in_SETTINGS) = @_;
	$in_SETTINGS = {} if (!$in_SETTINGS);

	if ($^O eq 'MacOS') { $NL::File::Lock::DATA->{'SETTINGS'}->{'dir_splitter'} = ':'; }
	elsif ($^O eq 'MSWin32') {
		$NL::File::Lock::DATA->{'SETTINGS'}->{'dir_splitter'} = '/';
		$NL::File::Lock::DATA->{'SETTINGS'}->{'dir_splitters_extra'} = ['\\'];
	}
	if (defined $dir_for_locks && $dir_for_locks ne '') {
		&_path_dir_chomp(\$dir_for_locks);
		if ($dir_for_locks ne '' && -d $dir_for_locks) {
			$NL::File::Lock::DATA->{'SETTINGS'}->{'dir_for_locks'} = $dir_for_locks;
			# Removing old LOCKS
			if (defined $in_SETTINGS->{'REMOVE_OLD'} && $in_SETTINGS->{'REMOVE_OLD'}) {
				# Getting listing
				my @arr_listing;
				if (opendir(DIR, $NL::File::Lock::DATA->{'SETTINGS'}->{'dir_for_locks'})) {
					my $pf_QM = quotemeta($NL::File::Lock::DATA->{'SETTINGS'}->{'LOCK_FILE_POSTFIX'});
					@arr_listing = grep( /${pf_QM}$/, grep(!/^\.{1,2}$/, readdir (DIR)) );
					closedir (DIR);
				}
				my $splitter = $NL::File::Lock::DATA->{'SETTINGS'}->{'dir_splitter'};
				my $dir = ($NL::File::Lock::DATA->{'SETTINGS'}->{'dir_for_locks'} =~ /$splitter$/) ? $NL::File::Lock::DATA->{'SETTINGS'}->{'dir_for_locks'} : $NL::File::Lock::DATA->{'SETTINGS'}->{'dir_for_locks'}.$splitter;
				my $time = time();
				foreach (@arr_listing) {
					my $file = $dir.$_;
					if (-f $file) {
						my @arr_stat = stat($file);
						if (defined $arr_stat[9]) {
							unlink $file if ($time - $arr_stat[9] >= $NL::File::Lock::DATA->{'SETTINGS'}->{'SECONDS_TO_REMOVE_OLD_LOCKS'});
						}
					}
				}
			}
			return 1;
		}
	}
	return 0;

}
# Locking
sub lock_read  { my ($file_name, $in_ref_hash_EXT) = @_; return &lf_lock($file_name, &LOCK_SH(), defined $in_ref_hash_EXT ? $in_ref_hash_EXT : {}); }
sub lock_write { my ($file_name, $in_ref_hash_EXT) = @_; return &lf_lock($file_name, &LOCK_EX(), defined $in_ref_hash_EXT ? $in_ref_hash_EXT : {}); }
sub lf_lock {
	my ($file_name, $lock_type, $in_ref_hash_EXT) = @_;
	$lock_type = &LOCK_EX() if (!defined $lock_type || $lock_type <= 0);
	$in_ref_hash_EXT = {} if (!defined $in_ref_hash_EXT || ref $in_ref_hash_EXT ne 'HASH');

	my $lock_file_name = '';
	my ($time_stop, $time_sleep) = (0, 0);
	if (defined $in_ref_hash_EXT->{'timeout'}) {
		$time_sleep = (defined $in_ref_hash_EXT->{'time_sleep'} && $in_ref_hash_EXT->{'time_sleep'} > 0) ? $in_ref_hash_EXT->{'time_sleep'} : 0;
		$time_stop = time() + $in_ref_hash_EXT->{'timeout'};
	}
	if (defined $NL::File::Lock::DATA->{'LOCKED_FILES'}->{$file_name}) {
		if ($NL::File::Lock::DATA->{'LOCKED_FILES'}->{$file_name}->{'IS_LOCKED'}) { return 2; } # already locked
		else {
			if (&_lf_lock_MAKE_LOCK($NL::File::Lock::DATA->{'LOCKED_FILES'}->{$file_name}->{'lock_handle'}, $lock_type, $time_stop, $time_sleep)) {
				# Locked
				$NL::File::Lock::DATA->{'LOCKED_FILES'}->{$file_name}->{'IS_LOCKED'} = 1;
				return 1;
			}
			else { return 0; }
		}
	}
	else { $lock_file_name = &_make_lock_file_name($file_name); }

	my $is_locked = 0;
	do {
		my $FILE_OPENED;
		if ($NL::File::Lock::OS_SETTINGS->{'USE_FCNTL'}) {
			# eval '$FILE_OPENED = sysopen(LFH, $lock_file_name, O_WRONLY|O_CREAT)';
			eval '$FILE_OPENED = sysopen(LFH, $lock_file_name, O_RDWR|O_CREAT)';
		}
		else { $FILE_OPENED = open(LFH, ">>$lock_file_name"); }

		if ($FILE_OPENED) {
			if (&_lf_lock_MAKE_LOCK(\*LFH, $lock_type, $time_stop, $time_sleep)) {
				# Locked
				$NL::File::Lock::DATA->{'LOCKED_FILES'}->{$file_name} = { 'IS_LOCKED' => 1, 'lock_file' => $lock_file_name, 'lock_handle' => \*LFH };
				return 1;
			}
			else {
				close(LFH);
				return 0;
			}
		}
		else {
			# Sleeping
			# sleep($time_sleep) if ($time_sleep > 0);
			if ($time_sleep > 0) { select(undef, undef, undef, $time_sleep); }
		}
	} while (!$is_locked && time() < $time_stop);
	return 0;
}
sub _lf_lock_MAKE_LOCK {
	my ($lock_file_handle, $lock_type, $time_stop, $time_sleep) = @_;

	# Solaris workaround
	$lock_type = &LOCK_EX() if ($NL::File::Lock::OS_SETTINGS->{'IS_SOLARIS'} && !$NL::File::Lock::OS_SETTINGS->{'USE_FCNTL'} && $lock_type == &LOCK_SH());
	do {
		if (flock($lock_file_handle, $lock_type | &LOCK_NB())) { return 1; }
		else {
			# Sleeping
			# sleep($time_sleep) if ($time_sleep > 0);
			if ($time_sleep > 0) { select(undef, undef, undef, $time_sleep); }
		}
	} while (time() < $time_stop);
	return 0;
}
# Ulocking
sub unlock {
	my ($file_name, $not_unlink) = @_;
	$not_unlink = 0 if (!defined $not_unlink);

	if (defined $NL::File::Lock::DATA->{'LOCKED_FILES'}->{$file_name})
	{
		if ($NL::File::Lock::DATA->{'LOCKED_FILES'}->{$file_name}->{'IS_LOCKED'}) {
			flock($NL::File::Lock::DATA->{'LOCKED_FILES'}->{$file_name}->{'lock_handle'}, &LOCK_UN());
		}
		close $NL::File::Lock::DATA->{'LOCKED_FILES'}->{$file_name}->{'lock_handle'};
		unlink $NL::File::Lock::DATA->{'LOCKED_FILES'}->{$file_name}->{'lock_file'} if (!$not_unlink); # If file is opened it will not be removed on some OS
		delete $NL::File::Lock::DATA->{'LOCKED_FILES'}->{$file_name};
		return 1;
	}
	return 0;
}
sub unlock_not_unlink {
	my ($file_name) = @_;
	return &unlock($file_name, 1);
}
# DO NOT USE 'unlock_not_close' - USE 'unlock_not_unlink'
# 'unlock_not_close' is not good because, proccess A can make 'unlock_not_close' and proccess B
# can remove lock file on some OS then, when proccess A will make lock again via FILE_HANDLE - can be error
sub unlock_not_close {
	my ($file_name) = @_;

	if (defined $NL::File::Lock::DATA->{'LOCKED_FILES'}->{$file_name})
	{
		if ($NL::File::Lock::DATA->{'LOCKED_FILES'}->{$file_name}->{'IS_LOCKED'}) {
			if ($] < 5.004) {
				# Fix for old Perl
				my $old_fh = select($NL::File::Lock::DATA->{'LOCKED_FILES'}->{$file_name}->{'lock_handle'});
				local $|=1;               # Enable commands bufferization
				local $\ = '';            # Make empty splitter of output records
				print '';                 # Call buffer cleaning
				select($old_fh);          # Restore old HANDLER
			}
			flock($NL::File::Lock::DATA->{'LOCKED_FILES'}->{$file_name}->{'lock_handle'}, &LOCK_UN()); # LOCK_UN = 8
			$NL::File::Lock::DATA->{'LOCKED_FILES'}->{$file_name}->{'status'} = 'unlocked';
			return 1;
		}
	}
	return 0;
}
# Removing all LOCKS
sub END
{
	foreach (keys %{ $NL::File::Lock::DATA->{'LOCKED_FILES'} }) { &unlock($_); }
}
# Simple 'flock' based locks
sub flock_read { return &_flock($_[0], &LOCK_SH()); }
sub flock_write { return &_flock($_[0], &LOCK_EX()); }
sub _flock {
	my ($file_handle, $lock_type) = @_;
	$lock_type = &LOCK_EX() if (!defined $lock_type || $lock_type <= 0);
	return flock($file_handle, $lock_type);
}
sub unflock { return flock($_[0], &LOCK_UN()); }
1;
__END__