View difference between Paste ID: KNB7HP4j and xP0kHvXH

 #!/usr/bin/perl -w
 use strict;
 use warnings;
 use FindBin;
 use lib $FindBin::Bin;
 use Lib;
 use const ':constants';
 
 my $daemon = Proc::Daemon->new;
 Proc::Daemon::Init(
     {   work_dir     => WORK_DIR,
         child_STDOUT => "+>>".DEBUG_FILE."",
         child_STDERR => "+>>".ERROR_LOG_FILE."",
         pid_file     => "".LOG_DIR."/remote_imap.pid"
     }
 );
 if (my $pid = Proc::PID::File->running({dir=>LOG_DIR, verify=>1})) {
   &debug(1, $pid, "Already running!\n");
   exit 0;
 }
 
 $SIG{'INT'} = \&cleanupAndShutdown;
 $SIG{'TERM'} = \&cleanupAndShutdown;
 $SIG{'HUP'} = \&restartChildren;
 my ($dbname,$dbuser,$dbpass, $dbhost, $dbport) = (DB_NAME, DB_LOGIN, DB_PASSWORD, DB_HOST, DB_PORT);
 my $dbh = DBI->connect("dbi:Pg:dbname=$dbname;host=$dbhost;port=$dbport", $dbuser, $dbpass,
 			{ RaiseError => 0,
 			AutoCommit => 1,
 			PrintError => 0,})
     or print $DBI::errstr;
 my $p_pid = $$;
 my @kids = (0 .. DAEMON_MAX_CHILD_PROCESSES-1);
 my (@childs, $kid_pid, $status);
 foreach $kid_pid (@kids) {
 	$kid_pid = $daemon->Init(
 			{   work_dir     => WORK_DIR,
 			    exec_command => "perl remote_imapd.pl $p_pid",
 			});
 		 push @childs, $kid_pid;
 }
 $| = 1;
 while(1) {
 	foreach $kid_pid (@kids) {
 		$status = $daemon->Status($kid_pid);
 		if (!$status){
 			my $index = 0;
 			$index++ until $childs[$index] eq $kid_pid;
 			splice(@childs, $index, 1);
 			$kid_pid = $daemon->Init(
 			{   work_dir     => WORK_DIR,
 			    exec_command => "perl remote_imapd.pl $p_pid",
 			});
 		 push @childs, $kid_pid;
 		}
 	}
 	usleep(DAEMON_DELAY);
 	if ($dbh->ping() != 1) {
 		 $dbh = DBI->connect("dbi:Pg:dbname=$dbname;host=$dbhost;port=$dbport", $dbuser, $dbpass,
 			{ RaiseError => 0,
 			AutoCommit => 1,
 			PrintError => 0,})
 		or print $DBI::errstr;
 	}
 	&processing_out_users_remote($dbh, $kid_pid, @childs);
 }
 
 sub processing_out_users_remote {
 	my ($dbh, $pid, @childs) = @_;
-	my $now = &now;
+	## Work with DB
-	my @params;
+
-	my @workers = @childs;
+
-	$params[1] = $pid;
+
-	$params[2] = DB_USERS_REMOTE_STATUS_NEW;
+
-	$params[3] = REMOTE_MAIL_COUNT;
+
-	$params[4] = DB_USERS_REMOTE_STATUS_PROCESSING;
+
-	$params[5] = REMOTE_MAX_ERROR_COUNT;
+
-	my $q = "(select id, status, process_id, error_count from ".DB_USERS_REMOTE." where status=? and is_active in (?,?) and login_type=? and remote_type=?)
+
-		  union all
+
-		 (select id, status, process_id, error_count from ".DB_USERS_REMOTE." where status=? and is_active in (?,?) and login_type=? and remote_type=? and date_get < ? order by date_get asc limit ?)";
+
-	my $sth = $dbh->prepare($q);
+
-	my $rv = $sth->execute($params[4], 1, 2, 2, 2, $params[2], 1, 2, 2, 2, $now, $params[3]) or print $DBI::errstr;
+
-	while (my ($id, $status, $process_id, $error_count) = $sth->fetchrow_array) {
+
-		if ($status == 2) {
+
-			if (grep(/^$process_id$/, @workers)) {
+