amxrt.c File Reference

#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include <errno.h>
#include <unistd.h>
#include <sys/time.h>
#include <sys/resource.h>
#include <sys/stat.h>
#include <syslog.h>
#include <cap-ng.h>
#include <amxrt/amxrt.h>
#include "amxrt_priv.h"

Go to the source code of this file.

Macros
#define	_GNU_SOURCE

Functions
static bool	amxrt_file_exists (const char *filename)
static int	amxrt_parse_odl_string (amxo_parser_t *parser, amxd_object_t *root)
static int	amxrt_parse_odl_extensions (amxo_parser_t *parser, amxd_object_t *root)
static int	amxrt_try_default_odl (amxo_parser_t *parser, amxd_object_t *root)
static int	amxrt_parse_odl_files (amxo_parser_t *parser, int argc, char *argv[], int index, amxd_object_t *root)
static int	amxrt_create_pid_file (pid_t pid, const char *name)
static void	amxrt_remove_pid_file (const char *name)
static int	amxrt_apply_process_settings (amxo_parser_t *parser)
static int	amxrt_register (amxo_parser_t *parser, amxd_dm_t *dm)
static void	amxrt_handle_events (amxd_dm_t *dm, amxo_parser_t *parser)
static void	amxrt_wait_done (UNUSED const char *const s, UNUSED const amxc_var_t *const d, UNUSED void *const p)
amxrt_t *	amxrt_get (void)
amxc_var_t *	amxrt_get_config (void)
	Gets the htable variant containing the configuration options. More...
amxo_parser_t *	amxrt_get_parser (void)
	Gets runtime odl parser. More...
amxd_dm_t *	amxrt_get_dm (void)
	Gets the runtime data model storage. More...
void	amxrt_new (void)
	Create the ambiorix runtime. More...
int	amxrt (int argc, char *argv[], amxrt_arg_fn_t fn)
	This function can create full ambiorix application (data model provider or client). More...
int	amxrt_init (int argc, char *argv[], amxrt_arg_fn_t fn)
	Initializes the ambiorix runtime. More...
void	amxrt_delete (void)
	Clean-up ambiorix runtime. More...
int	amxrt_register_or_wait (void)
	Register the data model or wait for required data model objects. More...
int	amxrt_run (void)
	Starts the event loop. More...
void	amxrt_stop (void)
	Stops the runtime. More...
int	amxrt_load_odl_files (int argc, char *argv[], int index)
	Load odls files mentioned on the command line or the default odl file. More...
int	amxrt_connect (void)
	Connects to all bus sockets. More...
void	amxrt_enable_syssigs (amxc_var_t *syssigs)
	Enables system signals that should be monitored by the eventloop. More...

Variables
static amxrt_t	rt

Macro Definition Documentation

_GNU_SOURCE

#define _GNU_SOURCE

Definition at line 56 of file amxrt.c.

Function Documentation

amxrt_apply_process_settings()

static int amxrt_apply_process_settings ( amxo_parser_t *  parser )

static

Definition at line 209 of file amxrt.c.

                                                               {
    int retval = 0;
    int pid = -1;
    bool pidfile = amxc_var_dyncast(bool, GET_ARG(&parser->config, AMXRT_COPT_PID_FILE));
    char* name = amxc_var_dyncast(cstring_t, GET_ARG(&parser->config, AMXRT_COPT_NAME));
 
    int priority = amxc_var_dyncast(uint32_t, GET_ARG(&parser->config, AMXRT_COPT_PRIORITY));
 
    pid = getpid();
    retval = setpriority(PRIO_PROCESS, pid, priority);
    when_failed(retval, leave);
 
    if(pidfile && (name != NULL)) {
        amxrt_create_pid_file(pid, name);
    }
 
    if(GET_BOOL(&parser->config, AMXRT_COPT_LOG) &&
       ( GET_CHAR(&parser->config, AMXRT_COPT_NAME) != NULL)) {
        openlog(GET_CHAR(&parser->config, AMXRT_COPT_NAME), LOG_CONS | LOG_PID, LOG_USER);
        syslog(LOG_USER | LOG_INFO, "** MARK **");
    }
 
    retval = amxrt_caps_apply();
 
leave:
    free(name);
    return retval;
}

amxrt_create_pid_file()

static int amxrt_create_pid_file ( pid_t  pid, const char *  name  )

static

Definition at line 164 of file amxrt.c.

                                                              {
    amxc_string_t pidfile;
    int retval = -1;
    FILE* pf = NULL;
 
    amxc_string_init(&pidfile, 64);
 
    // create pidfile
    amxc_string_appendf(&pidfile, "/var/run/%s.pid", name);
    pf = fopen(amxc_string_get(&pidfile, 0), "w");
    if((pf == NULL) && (errno == EACCES)) {
        amxc_string_reset(&pidfile);
        amxc_string_appendf(&pidfile, "/var/run/%s/%s.pid", name, name);
        pf = fopen(amxc_string_get(&pidfile, 0), "w");
    }
    if(pf != NULL) {
        fprintf(pf, "%d", pid);
        fflush(pf);
        fclose(pf);
        retval = 0;
    } else {
        amxrt_print_error("Failed to create pidfile");
    }
 
    amxc_string_clean(&pidfile);
    return retval;
}

amxrt_file_exists()

static bool amxrt_file_exists ( const char *  filename )

static

Definition at line 76 of file amxrt.c.

                                                    {
    struct stat buffer;
 
    return (stat(filename, &buffer) == 0);
}

amxrt_get()

amxrt_t* amxrt_get

(

void

)

Definition at line 297 of file amxrt.c.

                         {
    return &rt;
}

amxrt_handle_events()

static void amxrt_handle_events ( amxd_dm_t *  dm, amxo_parser_t *  parser  )

static

Definition at line 264 of file amxrt.c.

                                                                      {
    bool handle_events = GET_BOOL(&parser->config, AMXRT_COPT_HANDLE_EVENTS);
 
    if(handle_events) {
        while(amxp_signal_read() == 0) {
        }
    }
    amxp_sigmngr_trigger_signal(&dm->sigmngr, "app:start", NULL);
}

amxrt_parse_odl_extensions()

static int amxrt_parse_odl_extensions ( amxo_parser_t *  parser, amxd_object_t *  root  )

static

Definition at line 98 of file amxrt.c.

                                                                                  {
    int retval = 0;
 
    const char* ext_dir = GET_CHAR(&parser->config, AMXRT_COPT_EXT_DIR);
    amxc_string_t opt_include;
 
    amxc_string_init(&opt_include, 0);
    when_str_empty(ext_dir, exit);
 
    amxc_string_setf(&opt_include, "#include '%s';", ext_dir);
 
    retval = amxo_parser_parse_string(parser, amxc_string_get(&opt_include, 0), root);
 
exit:
    amxc_string_clean(&opt_include);
    return retval;
}

amxrt_parse_odl_files()

static int amxrt_parse_odl_files ( amxo_parser_t *  parser, int  argc, char *  argv[], int  index, amxd_object_t *  root  )

static

Definition at line 142 of file amxrt.c.

                                                      {
    int retval = 0;
 
    if(index >= argc) {
        retval = amxrt_try_default_odl(parser, root);
    } else {
        while(index < argc) {
            retval = amxo_parser_parse_file(parser, argv[index++], root);
            if(retval != 0) {
                amxrt_print_failure(parser, argv[index - 1]);
                break;
            }
        }
    }
 
    return retval;
}

amxrt_parse_odl_string()

static int amxrt_parse_odl_string ( amxo_parser_t *  parser, amxd_object_t *  root  )

static

Definition at line 82 of file amxrt.c.

                                                       {
    const char* odl_str = NULL;
    int retval = 0;
 
    odl_str = amxc_var_constcast(cstring_t, GET_ARG(&parser->config, AMXRT_COPT_ODL));
    if(odl_str != NULL) {
        retval = amxo_parser_parse_string(parser, odl_str, root);
        if(retval != 0) {
            amxrt_print_failure(parser, odl_str);
        }
    }
 
    return retval;
}

amxrt_register()

static int amxrt_register ( amxo_parser_t *  parser, amxd_dm_t *  dm  )

static

Definition at line 238 of file amxrt.c.

                                                                {
    int retval = 0;
 
    retval = amxrt_connection_register_dm(parser, dm);
    when_failed(retval, leave);
    amxc_var_set(bool, GET_ARG(&parser->config, AMXRT_COPT_EVENT), true);
    if(parser->post_includes != NULL) {
        retval = amxo_parser_invoke_entry_points(parser, dm, AMXO_START);
        when_failed(retval, leave);
        retval = amxo_parser_invoke_entry_points(parser, dm, AMXO_ODL_LOADED);
        when_failed(retval, leave);
    } else {
        retval = amxo_parser_invoke_entry_points(parser, dm, AMXO_START);
        when_failed(retval, leave);
    }
 
    retval = amxo_parser_start_synchronize(parser);
    if(retval != 0) {
        amxrt_print_error("Runtime - synchronizations failed to start (nr failed = %d)\n", retval);
        amxrt_print_message("Runtime - Are all required objects available?");
    }
 
leave:
    return retval;
}

amxrt_remove_pid_file()

static void amxrt_remove_pid_file ( const char *  name )

static

Definition at line 192 of file amxrt.c.

                                                    {
    amxc_string_t pidfile;
    amxc_string_init(&pidfile, 64);
 
    amxc_string_appendf(&pidfile, "/var/run/%s.pid", name);
    if(!amxrt_file_exists(amxc_string_get(&pidfile, 0))) {
        amxc_string_reset(&pidfile);
        amxc_string_appendf(&pidfile, "/var/run/%s/%s.pid", name, name);
    }
 
    if(amxrt_file_exists(amxc_string_get(&pidfile, 0))) {
        unlink(amxc_string_get(&pidfile, 0));
    }
 
    amxc_string_clean(&pidfile);
}

amxrt_try_default_odl()

static int amxrt_try_default_odl ( amxo_parser_t *  parser, amxd_object_t *  root  )

static

Definition at line 116 of file amxrt.c.

                                                                             {
    char* name = amxc_var_dyncast(cstring_t, GET_ARG(&parser->config, AMXRT_COPT_NAME));
    char* prefix = amxc_var_dyncast(cstring_t, GET_ARG(&parser->config, AMXRT_COPT_PREFIX_PATH));
    char* cfg_dir = amxc_var_dyncast(cstring_t, GET_ARG(&parser->config, AMXRT_COPT_CFG_DIR));
    struct stat sb;
    int retval = 0;
 
    amxc_string_t include;
    amxc_string_init(&include, 32);
    amxc_string_appendf(&include, "%s/%s/%s/%s.odl", prefix, cfg_dir, name, name);
 
    if(stat(amxc_string_get(&include, 0), &sb) == 0) {
        retval = amxo_parser_parse_file(parser, amxc_string_get(&include, 0), root);
        if(retval != 0) {
            amxrt_print_failure(parser, amxc_string_get(&include, 0));
        }
    }
    amxc_string_clean(&include);
 
    free(cfg_dir);
    free(prefix);
    free(name);
 
    return retval;
}

amxrt_wait_done()

static void amxrt_wait_done ( UNUSED const char *const  s, UNUSED const amxc_var_t *const  d, UNUSED void *const  p  )

static

Definition at line 274 of file amxrt.c.

                                                  {
    amxo_parser_t* parser = amxrt_get_parser();
    amxd_dm_t* dm = amxrt_get_dm();
    amxc_var_t* req = GET_ARG(&parser->config, AMXRT_COPT_REQUIRES);
 
    amxc_var_clean(req);
    amxc_var_set_type(req, AMXC_VAR_ID_LIST);
 
    amxrt_print_message("RunTime - All required objects available - continue");
 
    amxp_sigmngr_resume(&dm->sigmngr);
 
    if(amxrt_register(parser, dm) != 0) {
        amxrt_print_error("Failed to register data model");
        amxrt_el_stop();
    } else {
        amxrt_handle_events(dm, parser);
        amxp_slot_disconnect(NULL, "wait:done", amxrt_wait_done);
    }
}

Variable Documentation

rt

amxrt_t rt

static

Definition at line 74 of file amxrt.c.