[mh] Process_item_queue <partly solved>

=head1 B<Process_Item_queue>

=head2 SYNOPSIS

  
=head2 DESCRIPTION

use this object to add process items to a queue. 
This version has a single queue called @process_item_queue, the next item on the queue is forked when the previous one finishes

=head2 INHERITS

<>

=head2 METHODS

add_process_item_to_queue add a process item to the queue, passed the  Process_item 
check_process_item_queue This is called regularly to see if it has any items to process on the queue

=over

=cut

#-----------------------------------------------------------------------
# tests
#-----------------------------------------------------------------------
# noloop=start
$my_test1   = new Voice_Cmd 'Run test [1,2,3,4]';
$p_longproc = new Process_Item;
set $p_longproc $config_parms{"code_dir"} . "/procs/longproc.sh";
$p_longproc->set_output( $config_parms{data_dir} . "/logs/longproc.txt" );
set_timeout $p_longproc 5;

# noloop=stop

if ( $state = said $my_test1) {
	if ( $state == 1 ) {
		set $p_longproc $config_parms{"code_dir"} . "/procs/longproc.sh 2";
		set_timeout $p_longproc 5;
		add_process_item_to_queue($p_longproc);
	}
	elsif ( $state == 2 ) {
		print_log( "Longproc run 1 3sec", "INFORMATIONAL", "p_longproc" );
		set $p_longproc $config_parms{"code_dir"} . "/procs/longproc.sh 3";
		set_timeout $p_longproc 5;		
		add_process_item_to_queue($p_longproc);
		print_log( "Longproc run 2 6sec", "INFORMATIONAL", "p_longproc" );
		set $p_longproc $config_parms{"code_dir"} . "/procs/longproc.sh 6";
		set_timeout $p_longproc 5;	
		add_process_item_to_queue($p_longproc);
		print_log( "Longproc run  3 2sec", "INFORMATIONAL", "p_longproc" );
		set $p_longproc $config_parms{"code_dir"} . "/procs/longproc.sh 2";
		set_timeout $p_longproc 5;		
		add_process_item_to_queue($p_longproc);

	}

	elsif ( $state == 3 ) {
		purge_process_item_queue();
	}
	elsif ( $state == 4 ) {

	}
}

if ( done_now $p_longproc) {
	print_log( "Longproc done", "INFORMATIONAL", "p_longproc" );
	if ( timed_out $p_longproc) {
		print_log( 'longproc - timed out', "ERROR", "p_longproc" );
	}
	print_process_log( "longproc.txt", "p_longproc" );
}

#-----------------------------------------------------------------------
# every  seconds check the queue
#-----------------------------------------------------------------------

if ($New_Second) {
	check_process_item_queue();
}

#-----------------------------------------------------------------------
# globals
#-----------------------------------------------------------------------

#-----------------------------------------------------------------------
# Add a process item to the queue
#-----------------------------------------------------------------------

sub add_process_item_to_queue {
	my $this_process_object = $_[0];
	print_log(
		"Adding "
		  . substr( $this_process_object->{object_name}, 1 ) 
		  . " cmds"
		  . $this_process_object->{cmds}[0]
		  . " timeout"
		  . $this_process_object->{timeout}
		  . " to the queue",
		"INFORMATIONAL", "add_process_item_to_queue"
	);
	my $counter = scalar @process_item_queue;
	$process_item_queue[$counter][0] = substr( $this_process_object->{object_name}, 1 );
	$process_item_queue[$counter][1] = $this_process_object->{cmds}[0];
	$process_item_queue[$counter][2] = $this_process_object->{timeout};
	
	if ( scalar @process_item_queue == 1 ) {
		start_process_object($process_item_queue[0][0], $process_item_queue[0][1], $process_item_queue[0][2]);		    
	}
	

}

#-----------------------------------------------------------------------
# check the process_item_queue
# if the previous one is done, delete it and action the next
#-----------------------------------------------------------------------
sub check_process_item_queue {

	my ( $this_queued_process_name, $this_queued_process, $this_process_object, $next_process_object );
	my $count_items_in_queue = scalar @process_item_queue;
	if ( $count_items_in_queue > 0 ) {
		print_log(
			"there are  " . $count_items_in_queue . " items in the queue",
			"INFORMATIONAL", "check_process_item_queue" );
		$this_queued_process_name = $process_item_queue[0][0];
		$this_process_object = get_object_by_name( $this_queued_process_name );
		if ( !defined( $this_process_object->{done} ) )
		{    # this process is still running
			return;
		}
		else {
			print_log(
				$this_queued_process_name
				  . " has finished",
				"INFORMATIONAL", "check_process_item_queue"
			);
			if ( $count_items_in_queue == 1 ) {
				@process_item_queue = ();
			}
			else {
				my $first = shift @process_item_queue; # delete the firstitem
				print_log(
					"Starting new first  process item "
					  . $process_item_queue[0][0] . " cmds"
					  . $process_item_queue[0][1],
					"INFORMATIONAL", "check_process_item_queue"
				);
				start_process_object($process_item_queue[0][0], $process_item_queue[0][1], $process_item_queue[0][2]);
			    
			}
		}
		return;
	}
	else {
		return;
	}

}

#-----------------------------------------------------------------------
# start a process item given its name, cmds and timeout
#-----------------------------------------------------------------------
sub start_process_object {
	my ($this_process_name,$this_process_cmds,$this_process_timeout) = @_;
	my $command;
	$command = "set \$" . $this_process_name . " \"" . $this_process_cmds . "\";";
	print_log( "running " . $command, "INFORMATIONAL", "start_process_name" );
	eval $command;
	$command = "set_timeout \$" . $this_process_name . " " . $this_process_timeout . ";";
	print_log( "running " . $command, "INFORMATIONAL", "start_process_object" );
	eval $command;
	$command = "start \$" . $this_process_name . ";";
	print_log( "running " . $command, "INFORMATIONAL", "start_process_object" );
	eval $command;
	return;
}

#-----------------------------------------------------------------------
# purge process item queue
#-----------------------------------------------------------------------
sub purge_process_item_queue {
	print_log( "Purging process item queue ",
		"INFORMATIONAL", "purge_process_item_queue" );
	@process_item_queue = ();
	return;
}
########################################################################
# History:
# 19-02-2021 new code
# 20-02-2021 fixed for changes on each queue entry

20/02/2021 14:43:19 Ran telnet command: run test 2
20/02/2021 14:43:19 [p_longproc] INFO Longproc run 1 3sec
20/02/2021 14:43:19 [add_process_item_to_queue] INFO Adding p_longproc cmds/home/pi/mh/GGBcode/procs/longproc.sh 3 timeout5 to the queue
20/02/2021 14:43:19 [start_process_object] INFO running start $p_longproc;
20/02/2021 14:43:19 [p_longproc] INFO Longproc run 2 6sec
20/02/2021 14:43:19 [add_process_item_to_queue] INFO Adding p_longproc cmds/home/pi/mh/GGBcode/procs/longproc.sh 6 timeout5 to the queue
20/02/2021 14:43:19 [p_longproc] INFO Longproc run  3 2sec
20/02/2021 14:43:19 [add_process_item_to_queue] INFO Adding p_longproc cmds/home/pi/mh/GGBcode/procs/longproc.sh 2 timeout5 to the queue
20/02/2021 14:43:20 [check_process_item_queue] INFO there are  3 items in the queue
20/02/2021 14:43:22 [p_longproc] INFO Longproc done
20/02/2021 14:43:22 [p_longproc] 14:43:19 longproc start 3 second sleep pid= 9401
20/02/2021 14:43:22 [p_longproc] 14:43:22 longproc end
20/02/2021 14:43:23 [check_process_item_queue] INFO there are  3 items in the queue
20/02/2021 14:43:23 [check_process_item_queue] INFO p_longproc has finished
20/02/2021 14:43:23 [check_process_item_queue] INFO Starting new first  process item p_longproc cmds/home/pi/mh/GGBcode/procs/longproc.sh 6
20/02/2021 14:43:23 [start_process_object] INFO running start $p_longproc;
20/02/2021 14:43:24 [check_process_item_queue] INFO there are  2 items in the queue
20/02/2021 14:43:29 [p_longproc] INFO Longproc done
20/02/2021 14:43:29 [p_longproc] ERROR longproc - timed out
20/02/2021 14:43:29 [p_longproc] 14:43:23 longproc start 6 second sleep pid= 9407
20/02/2021 14:43:29 [check_process_item_queue] INFO there are  2 items in the queue
20/02/2021 14:43:29 [check_process_item_queue] INFO p_longproc has finished
20/02/2021 14:43:29 [check_process_item_queue] INFO Starting new first  process item p_longproc cmds/home/pi/mh/GGBcode/procs/longproc.sh 2
20/02/2021 14:43:29 [start_process_object] INFO running start $p_longproc;
20/02/2021 14:43:30 [check_process_item_queue] INFO there are  1 items in the queue
20/02/2021 14:43:31 [p_longproc] INFO Longproc done
20/02/2021 14:43:31 [p_longproc] 14:43:29 longproc start 2 second sleep pid= 9414
20/02/2021 14:43:31 [p_longproc] 14:43:31 longproc end
20/02/2021 14:43:32 [check_process_item_queue] INFO there are  1 items in the queue
20/02/2021 14:43:32 [check_process_item_queue] INFO p_longproc has finished
20/02