amxp_proc_ctrl.c File Reference

#include <stdlib.h>
#include <string.h>
#include <stdio.h>
#include <limits.h>
#include <sys/inotify.h>
#include <unistd.h>
#include <fcntl.h>
#include <errno.h>
#include <amxc/amxc.h>
#include <amxc/amxc_macros.h>
#include <amxp/amxp.h>

Go to the source code of this file.

Macros
#define	_GNU_SOURCE
#define	PROC_CHILDREN   "/proc/%d/task/%d/children"

Functions
static void	amxp_proc_ctrl_free_char (amxc_array_it_t *it)
static void	amxp_proc_ctrl_timer_callback (UNUSED amxp_timer_t *const timer, void *data)
static void	amxp_proc_ctrl_stopped (UNUSED const char *const event_name, UNUSED const amxc_var_t *const event_data, void *const priv)
static int	amxp_proc_ctrl_get_child_pids_proc_children (amxp_proc_ctrl_t *proc)
static int	amxp_proc_ctrl_get_child_pids_scan_proc (amxp_proc_ctrl_t *proc)
int	amxp_proc_ctrl_new (amxp_proc_ctrl_t **proc, amxp_proc_ctrl_cmd_t cmd_build_fn)
	Allocates and initializes an amxp_proc_ctrl_t. More...
void	amxp_proc_ctrl_delete (amxp_proc_ctrl_t **proc)
	Clean-up and frees previously allocated memory. More...
int	amxp_proc_ctrl_start (amxp_proc_ctrl_t *proc, uint32_t minutes, amxc_var_t *settings)
	Launches the child process. More...
int	amxp_proc_ctrl_stop (amxp_proc_ctrl_t *proc)
	Stops the child process. More...
void	amxp_proc_ctrl_set_active_duration (amxp_proc_ctrl_t *proc, uint32_t minutes)
	Sets the active time durations. More...
void	amxp_proc_ctrl_stop_childs (amxp_proc_ctrl_t *proc)
	Stop all child processes of the child process. More...
int	amxp_proc_ctrl_get_child_pids (amxp_proc_ctrl_t *proc)
	Fetches the process ids of the children of the launched child process. More...

Macro Definition Documentation

_GNU_SOURCE

#define _GNU_SOURCE

Definition at line 56 of file amxp_proc_ctrl.c.

PROC_CHILDREN

#define PROC_CHILDREN   "/proc/%d/task/%d/children"

Definition at line 72 of file amxp_proc_ctrl.c.

Function Documentation

amxp_proc_ctrl_free_char()

static void amxp_proc_ctrl_free_char ( amxc_array_it_t *  it )

static

Definition at line 74 of file amxp_proc_ctrl.c.

                                                          {
    char* txt = (char*) amxc_array_it_get_data(it);
    free(txt);
}

amxp_proc_ctrl_get_child_pids_proc_children()

static int amxp_proc_ctrl_get_child_pids_proc_children ( amxp_proc_ctrl_t *  proc )

static

Definition at line 110 of file amxp_proc_ctrl.c.

                                                                               {
    int retval = -1;
    FILE* fp = NULL;
    amxc_string_t file;
    pid_t ppid = 0;
    ssize_t read = 0;
    char* line = NULL;
    size_t len = 0;
 
    amxc_string_init(&file, 0);
 
    ppid = amxp_subproc_get_pid(proc->proc);
    amxc_var_set_type(&proc->child_proc_pids, AMXC_VAR_ID_LIST);
 
    amxc_string_setf(&file, PROC_CHILDREN, ppid, ppid);
    fp = fopen(amxc_string_get(&file, 0), "r");
    if(fp == NULL) {
        goto leave;
    }
 
    read = getline(&line, &len, fp);
    if(read == -1) {
        free(line);
        goto leave;
    }
 
    amxc_var_push(ssv_string_t, &proc->child_proc_pids, line);
    amxc_var_cast(&proc->child_proc_pids, AMXC_VAR_ID_LIST);
 
    retval = 0;
 
leave:
    if(fp != NULL) {
        fclose(fp);
    }
    amxc_string_clean(&file);
    return retval;
}

amxp_proc_ctrl_get_child_pids_scan_proc()

static int amxp_proc_ctrl_get_child_pids_scan_proc ( amxp_proc_ctrl_t *  proc )

static

Definition at line 149 of file amxp_proc_ctrl.c.

                                                                           {
    int retval = -1;
    amxc_llist_t children;
 
    amxc_llist_init(&children);
    retval = amxp_proci_findf(&children,
                              "ppid == %d", amxp_subproc_get_pid(proc->proc));
 
    when_failed(retval, leave);
    amxc_var_set_type(&proc->child_proc_pids, AMXC_VAR_ID_LIST);
 
    amxc_llist_iterate(it, (&children)) {
        amxp_proc_info_t* pi = amxc_container_of(it, amxp_proc_info_t, it);
        amxc_var_add(int32_t, &proc->child_proc_pids, pi->pid);
    }
 
leave:
    amxc_llist_clean(&children, amxp_proci_free_it);
    return retval;
}

amxp_proc_ctrl_stopped()

static void amxp_proc_ctrl_stopped ( UNUSED const char *const  event_name, UNUSED const amxc_var_t *const  event_data, void *const  priv  )

static

Definition at line 91 of file amxp_proc_ctrl.c.

                                                     {
    amxp_proc_ctrl_t* proc = (amxp_proc_ctrl_t*) priv;
    amxc_var_t pid;
    amxc_var_init(&pid);
 
    when_null(proc, leave);
 
    amxc_var_set(uint32_t, &pid, proc->proc->pid);
    amxp_timer_stop(proc->timer);
    amxp_proc_ctrl_stop_childs(proc);
 
    amxp_sigmngr_emit_signal(NULL, "proc:stopped", &pid);
 
leave:
    amxc_var_clean(&pid);
}

amxp_proc_ctrl_timer_callback()

static void amxp_proc_ctrl_timer_callback ( UNUSED amxp_timer_t *const  timer, void *  data  )

static

Definition at line 79 of file amxp_proc_ctrl.c.

                                                      {
    amxp_proc_ctrl_t* proc = (amxp_proc_ctrl_t*) data;
    amxc_var_t pid;
    amxc_var_init(&pid);
    amxc_var_set(uint32_t, &pid, proc->proc->pid);
    amxp_sigmngr_emit_signal(NULL, "proc:disable", &pid);
    amxp_proc_ctrl_stop(proc);
 
    amxc_var_clean(&pid);
}