File util/watch_ctrl.c

Included Files

• #include <stdio.h>

• #include <string.h>

• #include <stdlib.h>

• #include <memory.h>

• #include <time.h>

• #include <sys/types.h>

• #include <sys/stat.h>

• #include <sys/ipc.h>

• #include <sys/mman.h>

• #include <signal.h>

• #include <unistd.h>

• #include <mplib1/cfg_file.h>

• #include <mplib1/fprintfile.h>
  • #include <mplib1/timestamp.h>

• #include <mplib1/fgetline.h>

• #include <mplib1/match_tok.h>

• #include <mplib1/pid_check.h>

• #include <mplib1/bpo_queue.h>
  • #include <mplib1/mplib1_config.h>
  • #include <mplib1/bpo_lock.h>
  • #include <mplib1/bpo_list.h>
  • #include <mplib1/bpo_init.h>
  • #include <mplib1/bpo_alloc.h>
  • #include <mplib1/bpo_proc.h>

• #include <mplib1/daemon.h>

• #include "util/watchdog.h"
  • #include <mplib1/dl_list.h>

Type enum comm_actions

• enum comm_actions
  
  • {
    
  • CA_SHUTDOWN;
    
  • CA_INCLUDE;
    
  • CA_EXCLUDE;
    
  • CA_CREATE;
    
  • CA_UPDATE;
    
  • CA_FORGET;
    
  • CA_DELETE;
    
  • CA_KILL;
    
  • CA_LIST;
    
  • CA_TICKLE;
    
  • CA_WAIT;
    
  • CA_DUMP;
    
  • CA_LOAD;
    
  • CA_SAVE;
    
  • CA_SLEEP;
    
  • CA_SIGNAL;
    
  • CA_RESTART;
    
  • CA_RUN;
    
  • CA_BOUNCE;
    
  • CA_CLEANUP;
    
  • CA_DEBUG;
    
  • }
    

Type enum wait_actions

• enum wait_actions
  
  • {
    
  • WA_KILL;
    
  • WA_START;
    
  • WA_TILL;
    
  • WA_BATCH;
    
  • }
    

Type struct wait_job

• struct wait_job
  
  • {
    
  • Node wj_Node;
    
  • int wait_for;
    
  • time_t wait_till;
    
  • struct watchdog_ctrl_msg* cmp;
    
  • struct program_hdr* pptr;
    
  • }
    

Local Variables

Used in:

• create_watch_queues()
• watch_ctrl()

ctrl_comms
static struct match_token ctrl_comms[]

Used in:

• watch_ctrl()

wait_comms
static struct match_token wait_comms[]

Used in:

• watch_ctrl()

signal_comms
static struct match_token signal_comms[]

Used in:

• signal_name()
• watch_ctrl()

watch_ctrl_debug
static int watch_ctrl_debug

Used in:

• exclude_named_level()
• forget_level()
• forget_program()
• level_bounce()
• level_excl()
• level_incl()
• program_bounce()
• program_excl()
• program_incl()
• watch_ctrl()

watch_wait_debug
static int watch_wait_debug

Used in:

• check_all_wait_jobs()
• check_wait_job()

the_signal
static int the_signal

Used in:

• signal_pptr()
• signal_things()

wait_list
static List wait_list

Used in:

• add_wait_job()
• check_all_wait_jobs()
• create_watch_queues()
• delete_watch_queues()

dt_tm_iso8601
static const char dt_tm_iso8601[]

Used in:

• pid_details()
• print_prg_debug()

Global Function create_watch_queues()

Prototyped in:

• util/watchdog.h

Calls:

• Init_List(), fprintfile(), mpCreateQ()

Called by:

• main() : util/watchdog.c

References Variables:

• ctrl_q_name : util/watch_ctrl.c
• wait_list : util/watch_ctrl.c

Global Function delete_watch_queues()

Prototyped in:

• util/watchdog.h

Calls:

• Walk_List()

Called by:

• main() : util/watchdog.c

References Functions:

• free_wait_job() : util/watch_ctrl.c

References Variables:

• wait_list : util/watch_ctrl.c

Global Function dump_db_to_file()

Prototyped in:

• util/watchdog.h

Calls:

• walk_all_levels() : util/watch_file.c
• walk_all_programs() : util/watch_file.c
• fclose(), fopen(), fprintf(), make_timestamp_str()

Called by:

• watch_ctrl() : util/watch_ctrl.c

References Functions:

• print_lvl_hdr() : util/watch_file.c
• print_prg_hdr() : util/watch_file.c

Global Function exclude_named_level()

Prototyped in:

• util/watchdog.h

Calls:

• set_lvl_state() : util/watch_ctrl.c
• fprintfile()

Called by:

• main() : util/watchdog.c

References Variables:

• watch_ctrl_debug : util/watch_ctrl.c

Global Function read_file_into_db()

Prototyped in:

• util/watchdog.h

Calls:

• parse_watch_line() : util/watch_parse.c
• fclose(), fgetline2(), fopen()

Called by:

• main() : util/watchdog.c
• watch_ctrl() : util/watch_ctrl.c

Global Function watch_ctrl()

Prototyped in:

• util/watchdog.h

Calls:

• add_wait_job() : util/watch_ctrl.c
• check_all_wait_jobs() : util/watch_ctrl.c
• do_cleanup() : util/watch_clean.c
• dump_db_to_file() : util/watch_ctrl.c
• parse_this_line() : util/watch_parse.c
• parse_watch_line() : util/watch_parse.c
• process_line() : util/watch_ctrl.c
• read_file_into_db() : util/watch_ctrl.c
• reply_control_msg() : util/watch_ctrl.c
• run_this_batch() : util/watch_ctrl.c
• signal_name() : util/watch_ctrl.c
• signal_things() : util/watch_ctrl.c
• try_killing() : util/watch_ctrl.c
• watchdog_debug() : util/watch_ctrl.c
• fprintfile(), free(), get_private_flag(), match_a_string(), mpGetMsg(), restart_files(), sprintf(), strdup()

Called by:

• watch_check() : util/watch_loop.c

References Functions:

• forget_level() : util/watch_ctrl.c
• forget_program() : util/watch_ctrl.c
• level_bounce() : util/watch_ctrl.c
• level_excl() : util/watch_ctrl.c
• level_incl() : util/watch_ctrl.c
• level_signal() : util/watch_ctrl.c
• program_bounce() : util/watch_ctrl.c
• program_excl() : util/watch_ctrl.c
• program_incl() : util/watch_ctrl.c
• program_signal() : util/watch_ctrl.c

References Variables:

• ctrl_comms : util/watch_ctrl.c
• ctrl_q_name : util/watch_ctrl.c
• signal_comms : util/watch_ctrl.c
• wait_comms : util/watch_ctrl.c
• watch_ctrl_debug : util/watch_ctrl.c

Local Function add_wait_job()

Calls:

• check_wait_job() : util/watch_ctrl.c
• find_program_hdr() : util/watch_file.c
• Add_Tail(), Init_Node(), atoi(), malloc(), time()

Called by:

• watch_ctrl() : util/watch_ctrl.c

References Variables:

• wait_list : util/watch_ctrl.c

Local Function check_all_wait_jobs()

Calls:

• Walk_List(), get_private_flag()

Called by:

• watch_ctrl() : util/watch_ctrl.c

References Functions:

• check_wait_job() : util/watch_ctrl.c

References Variables:

• wait_list : util/watch_ctrl.c
• watch_wait_debug : util/watch_ctrl.c

Local Function check_wait_job()

Calls:

• check_kills() : util/watch_kill.c
• count_all_starting() : util/watch_track.c
• free_wait_job() : util/watch_ctrl.c
• send_back_control_msg() : util/watch_ctrl.c
• Any_In_List(), fprintfile(), sprintf(), time()

Called by:

• add_wait_job() : util/watch_ctrl.c

Used in:

• check_all_wait_jobs() : util/watch_ctrl.c

References Variables:

• watch_wait_debug : util/watch_ctrl.c

Local Function forget_level()

Calls:

• delete_lvl_hdr() : util/watch_file.c
• find_level_hdr() : util/watch_file.c
• free_level() : util/watch_file.c
• fprintfile()

Used in:

• watch_ctrl() : util/watch_ctrl.c

References Variables:

• watch_ctrl_debug : util/watch_ctrl.c

Local Function forget_program()

Calls:

• delete_prg_hdr() : util/watch_file.c
• find_program_hdr() : util/watch_file.c
• free_program() : util/watch_file.c
• fprintfile()

Used in:

• watch_ctrl() : util/watch_ctrl.c

References Variables:

• watch_ctrl_debug : util/watch_ctrl.c

Local Function free_ctrl_msg()

Calls:

• bpo_Remove_Node(), shfree()

Called by:

• free_wait_job() : util/watch_ctrl.c
• reply_control_msg() : util/watch_ctrl.c

Local Function free_wait_job()

Calls:

• free_ctrl_msg() : util/watch_ctrl.c
• Remove_Node(), free()

Called by:

• check_wait_job() : util/watch_ctrl.c

Used in:

• delete_watch_queues() : util/watch_ctrl.c

Local Function level_bounce()

Calls:

• find_level_hdr() : util/watch_file.c
• walk_all_programs_in_level() : util/watch_file.c
• fprintfile()

Used in:

• watch_ctrl() : util/watch_ctrl.c

References Functions:

• kill_current_instances() : util/watch_track.c

References Variables:

• watch_ctrl_debug : util/watch_ctrl.c

Local Function level_excl()

Calls:

• set_lvl_state() : util/watch_ctrl.c
• fprintfile()

Used in:

• watch_ctrl() : util/watch_ctrl.c

References Variables:

• watch_ctrl_debug : util/watch_ctrl.c

Local Function level_incl()

Calls:

• set_lvl_state() : util/watch_ctrl.c
• fprintfile()

Used in:

• watch_ctrl() : util/watch_ctrl.c

References Variables:

• watch_ctrl_debug : util/watch_ctrl.c

Local Function level_signal()

Calls:

• find_level_hdr() : util/watch_file.c
• walk_all_programs_in_level() : util/watch_file.c

Used in:

• signal_things() : util/watch_ctrl.c
• watch_ctrl() : util/watch_ctrl.c

References Functions:

• signal_pptr() : util/watch_ctrl.c

Local Function pid_details()

Calls:

• fprintf(), gen_pid_str(), gmtime(), strftime()

Used in:

• print_prg_debug() : util/watch_ctrl.c

References Variables:

• dt_tm_iso8601 : util/watch_ctrl.c

Local Function print_prg_debug()

Calls:

• Walk_List(), fprintf(), gmtime(), strftime()

Used in:

• watchdog_debug() : util/watch_ctrl.c

References Functions:

• pid_details() : util/watch_ctrl.c

References Variables:

• dt_tm_iso8601 : util/watch_ctrl.c

Local Function process_line()

Calls:

• parse_this_line() : util/watch_parse.c
• sprintf()

Called by:

• watch_ctrl() : util/watch_ctrl.c

Local Function program_bounce()

Calls:

• find_program_hdr() : util/watch_file.c
• kill_current_instances() : util/watch_track.c
• fprintfile()

Used in:

• watch_ctrl() : util/watch_ctrl.c

References Variables:

• watch_ctrl_debug : util/watch_ctrl.c

Local Function program_excl()

Calls:

• set_prg_state() : util/watch_ctrl.c
• fprintfile()

Used in:

• watch_ctrl() : util/watch_ctrl.c

References Variables:

• watch_ctrl_debug : util/watch_ctrl.c

Local Function program_incl()

Calls:

• set_prg_state() : util/watch_ctrl.c
• fprintfile()

Used in:

• watch_ctrl() : util/watch_ctrl.c

References Variables:

• watch_ctrl_debug : util/watch_ctrl.c

Local Function program_signal()

Calls:

• find_program_hdr() : util/watch_file.c
• signal_pptr() : util/watch_ctrl.c

Used in:

• signal_things() : util/watch_ctrl.c
• watch_ctrl() : util/watch_ctrl.c

Local Function reply_control_msg()

Calls:

• free_ctrl_msg() : util/watch_ctrl.c
• send_back_control_msg() : util/watch_ctrl.c

Called by:

• watch_ctrl() : util/watch_ctrl.c

Local Function run_this_batch()

Calls:

• find_program_hdr() : util/watch_file.c
• start_some_program() : util/watch_run.c

Called by:

• watch_ctrl() : util/watch_ctrl.c

Local Function send_back_control_msg()

Calls:

• fprintfile(), mpReplyMsg(), strlen()

Called by:

• check_wait_job() : util/watch_ctrl.c
• reply_control_msg() : util/watch_ctrl.c

Local Function set_lvl_state()

Calls:

• find_level_hdr() : util/watch_file.c
• save_lvl_hdr() : util/watch_file.c
• set_all_program_levels() : util/watch_file.c

Called by:

• exclude_named_level() : util/watch_ctrl.c
• level_excl() : util/watch_ctrl.c
• level_incl() : util/watch_ctrl.c

Local Function set_prg_state()

Calls:

• find_program_hdr() : util/watch_file.c
• save_prg_hdr() : util/watch_file.c

Called by:

• program_excl() : util/watch_ctrl.c
• program_incl() : util/watch_ctrl.c

Local Function signal_name()

Called by:

• signal_this() : util/watch_ctrl.c
• watch_ctrl() : util/watch_ctrl.c

References Variables:

• signal_comms : util/watch_ctrl.c

Local Function signal_pptr()

Calls:

• Walk_List()

Called by:

• program_signal() : util/watch_ctrl.c

Used in:

• level_signal() : util/watch_ctrl.c

References Functions:

• signal_this() : util/watch_ctrl.c

References Variables:

• the_signal : util/watch_ctrl.c

Local Function signal_things()

Calls:

• parse_this_line() : util/watch_parse.c

Called by:

• watch_ctrl() : util/watch_ctrl.c

References Functions:

• level_signal() : util/watch_ctrl.c
• program_signal() : util/watch_ctrl.c

References Variables:

• the_signal : util/watch_ctrl.c

Local Function signal_this()

Calls:

• signal_name() : util/watch_ctrl.c
• fprintfile(), kill()

Used in:

• signal_pptr() : util/watch_ctrl.c

Local Function try_killing()

Calls:

• kill_pid() : util/watch_kill.c
• getpid(), strtol()

Called by:

• watch_ctrl() : util/watch_ctrl.c

Local Function watchdog_debug()

Calls:

• walk_all_programs() : util/watch_file.c
• strcpy()

Called by:

• watch_ctrl() : util/watch_ctrl.c

References Functions:

• print_prg_debug() : util/watch_ctrl.c