test_proc_ctrl.c File Reference

#include <stdlib.h>
#include <stdio.h>
#include <setjmp.h>
#include <stdarg.h>
#include <cmocka.h>
#include <string.h>
#include <amxc/amxc.h>
#include <amxp/amxp.h>
#include "test_proc_ctrl.h"
#include <amxc/amxc_macros.h>

Go to the source code of this file.

Macros
#define	_GNU_SOURCE

Functions
int	__wrap_kill (pid_t pid, int sig)
FILE *	__wrap_fopen (const char *pathname, const char *mode)
FILE *	__real_fopen (const char *pathname, const char *mode)
ssize_t	__wrap_getline (char **lineptr, size_t *n, FILE *stream)
ssize_t	__real_getline (char **lineptr, size_t *n, FILE *stream)
int	__wrap_amxc_var_init (amxc_var_t *const var)
int	__real_amxc_var_init (amxc_var_t *const var)
static void	read_sigalrm (void)
static void	handle_events (void)
static int	test_cmd_builder (amxc_array_t *cmd, UNUSED amxc_var_t *settings)
int	__wrap_kill (UNUSED pid_t pid, UNUSED int sig)
void	test_proc_ctrl_new_delete (UNUSED void **state)
void	test_proc_ctrl_start_stop (UNUSED void **state)
void	test_proc_is_stopped_when_timer_expires (UNUSED void **state)
void	test_proc_is_stopped_when_timer_is_set_after_start (UNUSED void **state)
void	test_proc_can_stop_timer (UNUSED void **state)
void	test_proc_can_stop_children (UNUSED void **state)

Variables
static amxc_string_t	path

Macro Definition Documentation

_GNU_SOURCE

#define _GNU_SOURCE

Definition at line 56 of file test_proc_ctrl.c.

Function Documentation

__real_amxc_var_init()

int __real_amxc_var_init

(

amxc_var_t *const

var

)

__real_fopen()

FILE* __real_fopen	(	const char *	pathname,
		const char *	mode
	)

__real_getline()

ssize_t __real_getline	(	char **	lineptr,
		size_t *	n,
		FILE *	stream
	)

__wrap_amxc_var_init()

int __wrap_amxc_var_init

(

amxc_var_t *const

var

)

Definition at line 142 of file test_proc_ctrl.c.

                                                {
    int rv = mock();
 
    if(rv == 0) {
        rv = __real_amxc_var_init(var);
    }
 
    return rv;
}

__wrap_fopen()

FILE * __wrap_fopen	(	const char *	pathname,
		const char *	mode
	)

Definition at line 129 of file test_proc_ctrl.c.

                                                           {
    const char* f = amxc_string_get(&path, 0);
    if(f != NULL) {
        if(strcmp(pathname, f) == 0) {
            return __real_fopen("./test_child_pids.txt", mode);
        } else {
            return __real_fopen(pathname, mode);
        }
    } else {
        return __real_fopen(pathname, mode);
    }
}

__wrap_getline()

ssize_t __wrap_getline	(	char **	lineptr,
		size_t *	n,
		FILE *	stream
	)

Definition at line 152 of file test_proc_ctrl.c.

                                                                {
    ssize_t rv = mock();
 
    if(rv == 0) {
        return __real_getline(lineptr, n, stream);
    }
 
    return rv;
}

__wrap_kill() [1/2]

int __wrap_kill	(	pid_t	pid,
		int	sig
	)

__wrap_kill() [2/2]

int __wrap_kill	(	UNUSED pid_t	pid,
		UNUSED int	sig
	)

Definition at line 125 of file test_proc_ctrl.c.

                                                  {
    return 0;
}

handle_events()

static void handle_events ( void  )

static

Definition at line 106 of file test_proc_ctrl.c.

                                {
    printf("Handling events ");
    while(amxp_signal_read() == 0) {
        printf(".");
    }
    printf("\n");
}

read_sigalrm()

static void read_sigalrm ( void  )

static

Definition at line 85 of file test_proc_ctrl.c.

                               {
    sigset_t mask;
    int sfd;
    struct signalfd_siginfo fdsi;
    ssize_t s;
 
    sigemptyset(&mask);
    sigaddset(&mask, SIGALRM);
 
    sigprocmask(SIG_BLOCK, &mask, NULL);
 
    sfd = signalfd(-1, &mask, 0);
    s = read(sfd, &fdsi, sizeof(struct signalfd_siginfo));
    assert_int_equal(s, sizeof(struct signalfd_siginfo));
    if(fdsi.ssi_signo == SIGALRM) {
        printf("Got SIGALRM\n");
    } else {
        printf("Read unexpected signal\n");
    }
}

test_cmd_builder()

static int test_cmd_builder ( amxc_array_t *  cmd, UNUSED amxc_var_t *  settings  )

static

Definition at line 114 of file test_proc_ctrl.c.

                                                                            {
    int rv = mock();
 
    if(rv == 0) {
        amxc_array_append_data(cmd, strdup("sleep "));
        amxc_array_append_data(cmd, strdup("10m"));
    }
 
    return rv;
}

test_proc_can_stop_children()

void test_proc_can_stop_children

(

UNUSED void **

state

)

Definition at line 302 of file test_proc_ctrl.c.

                                                      {
    amxc_var_t settings;
    amxp_proc_ctrl_t* ctrl = NULL;
 
    amxc_string_init(&path, 0);
    will_return_always(__wrap_amxc_var_init, 0);
    will_return_always(__wrap_getline, 0);
    will_return_always(test_cmd_builder, 0);
 
    amxc_var_init(&settings);
 
    assert_int_equal(amxp_proc_ctrl_new(&ctrl, test_cmd_builder), 0);
    assert_int_equal(amxp_proc_ctrl_start(ctrl, 0, &settings), 0);
 
    amxc_string_setf(&path, "/proc/%d/task/%d/children", ctrl->proc->pid, ctrl->proc->pid);
    assert_int_equal(amxp_proc_ctrl_get_child_pids(ctrl), 3);
    amxp_proc_ctrl_stop_childs(ctrl);
 
    amxp_proc_ctrl_delete(&ctrl);
    amxc_string_clean(&path);
    amxc_var_clean(&settings);
}

test_proc_can_stop_timer()

void test_proc_can_stop_timer

(

UNUSED void **

state

)

Definition at line 276 of file test_proc_ctrl.c.

                                                   {
    amxc_var_t settings;
    amxp_proc_ctrl_t* ctrl = NULL;
 
    will_return_always(__wrap_amxc_var_init, 0);
    will_return_always(__wrap_getline, 0);
 
    amxc_var_init(&settings);
 
    assert_int_equal(amxp_proc_ctrl_new(&ctrl, test_cmd_builder), 0);
 
    will_return(test_cmd_builder, 0);
    assert_int_equal(amxp_proc_ctrl_start(ctrl, 1, &settings), 0);
    assert_true(ctrl->proc->is_running);
    assert_int_equal(amxp_timer_get_state(ctrl->timer), amxp_timer_running);
    amxp_timers_calculate();
    amxp_timers_check();
    assert_int_equal(amxp_timer_get_state(ctrl->timer), amxp_timer_running);
 
    amxp_proc_ctrl_set_active_duration(ctrl, 0);
    assert_int_equal(amxp_timer_get_state(ctrl->timer), amxp_timer_off);
 
    amxp_proc_ctrl_delete(&ctrl);
    amxc_var_clean(&settings);
}

test_proc_ctrl_new_delete()

void test_proc_ctrl_new_delete

(

UNUSED void **

state

)

Definition at line 162 of file test_proc_ctrl.c.

                                                    {
    amxp_proc_ctrl_t* ctrl = NULL;
 
    will_return(__wrap_amxc_var_init, 0);
    assert_int_equal(amxp_proc_ctrl_new(&ctrl, test_cmd_builder), 0);
    assert_non_null(ctrl);
    assert_non_null(ctrl->proc);
    assert_non_null(ctrl->timer);
    assert_int_equal(amxc_var_type_of(&ctrl->child_proc_pids), AMXC_VAR_ID_NULL);
 
    amxp_proc_ctrl_delete(&ctrl);
    assert_null(ctrl);
 
    will_return(__wrap_amxc_var_init, -1);
    assert_int_not_equal(amxp_proc_ctrl_new(&ctrl, test_cmd_builder), 0);
    assert_null(ctrl);
 
    assert_int_not_equal(amxp_proc_ctrl_new(NULL, test_cmd_builder), 0);
    assert_int_not_equal(amxp_proc_ctrl_new(&ctrl, NULL), 0);
    assert_null(ctrl);
    amxp_proc_ctrl_delete(NULL);
}

test_proc_ctrl_start_stop()

void test_proc_ctrl_start_stop

(

UNUSED void **

state

)

Definition at line 185 of file test_proc_ctrl.c.

                                                    {
    amxc_var_t settings;
    amxp_proc_ctrl_t* ctrl = NULL;
 
    will_return_always(__wrap_amxc_var_init, 0);
    will_return_always(__wrap_getline, 0);
 
    amxc_var_init(&settings);
 
    assert_int_equal(amxp_proc_ctrl_new(&ctrl, test_cmd_builder), 0);
 
    will_return(test_cmd_builder, 0);
    assert_int_equal(amxp_proc_ctrl_start(ctrl, 0, &settings), 0);
    assert_true(ctrl->proc->is_running);
 
    assert_int_equal(amxp_proc_ctrl_stop(ctrl), 0);
    assert_false(ctrl->proc->is_running);
 
    will_return(test_cmd_builder, -1);
    assert_int_not_equal(amxp_proc_ctrl_start(ctrl, 0, &settings), 0);
 
    will_return(test_cmd_builder, 0);
    assert_int_equal(amxp_proc_ctrl_start(ctrl, 0, NULL), 0);
    assert_true(ctrl->proc->is_running);
 
    assert_int_equal(amxp_proc_ctrl_stop(ctrl), 0);
    handle_events();
    assert_false(ctrl->proc->is_running);
 
    amxp_proc_ctrl_delete(&ctrl);
 
    assert_int_not_equal(amxp_proc_ctrl_start(NULL, 0, &settings), 0);
    assert_int_not_equal(amxp_proc_ctrl_stop(NULL), 0);
 
    amxc_var_clean(&settings);
}

test_proc_is_stopped_when_timer_expires()

void test_proc_is_stopped_when_timer_expires

(

UNUSED void **

state

)

Definition at line 222 of file test_proc_ctrl.c.

                                                                  {
    amxc_var_t settings;
    amxp_proc_ctrl_t* ctrl = NULL;
 
    will_return_always(__wrap_amxc_var_init, 0);
    will_return_always(__wrap_getline, 0);
 
    amxc_var_init(&settings);
 
    assert_int_equal(amxp_proc_ctrl_new(&ctrl, test_cmd_builder), 0);
 
    will_return(test_cmd_builder, 0);
    assert_int_equal(amxp_proc_ctrl_start(ctrl, 1, &settings), 0);
    assert_true(ctrl->proc->is_running);
 
    read_sigalrm();
    amxp_timers_calculate();
    amxp_timers_check();
    handle_events();
 
    assert_false(amxp_subproc_is_running(ctrl->proc));
 
    amxp_proc_ctrl_delete(&ctrl);
    amxc_var_clean(&settings);
}

test_proc_is_stopped_when_timer_is_set_after_start()

void test_proc_is_stopped_when_timer_is_set_after_start

(

UNUSED void **

state

)

Definition at line 248 of file test_proc_ctrl.c.

                                                                             {
    amxc_var_t settings;
    amxp_proc_ctrl_t* ctrl = NULL;
 
    will_return_always(__wrap_amxc_var_init, 0);
    will_return_always(__wrap_getline, 0);
 
    amxc_var_init(&settings);
 
    assert_int_equal(amxp_proc_ctrl_new(&ctrl, test_cmd_builder), 0);
 
    will_return(test_cmd_builder, 0);
    assert_int_equal(amxp_proc_ctrl_start(ctrl, 0, &settings), 0);
    assert_true(ctrl->proc->is_running);
 
    amxp_proc_ctrl_set_active_duration(ctrl, 1);
 
    read_sigalrm();
    amxp_timers_calculate();
    amxp_timers_check();
    handle_events();
 
    assert_false(amxp_subproc_is_running(ctrl->proc));
 
    amxp_proc_ctrl_delete(&ctrl);
    amxc_var_clean(&settings);
}

Variable Documentation

path

amxc_string_t path

static

Definition at line 71 of file test_proc_ctrl.c.