amxo_parser_main.c File Reference

#include "amxo_parser_priv.h"
#include "amxo_parser_hooks_priv.h"
#include "amxo_parser.tab.h"

Go to the source code of this file.

Macros
#define	_GNU_SOURCE

Functions
static ssize_t	amxo_parser_string_reader (amxo_parser_t *parser, char *buf, size_t max_size)
static int	amxo_parser_parse_fd_internal (amxo_parser_t *parser, int fd, amxd_object_t *object)
static void	amxo_parser_entry_point_free (amxc_llist_it_t *it)
ssize_t	amxo_parser_fd_reader (amxo_parser_t *parser, char *buf, size_t max_size)
static void	amxo_parser_pop_event (event_t *e, amxd_dm_t *dm)
static void	amxo_parser_send_events (amxo_parser_t *parser, amxd_dm_t *dm)
int	amxo_parser_parse_file_impl (amxo_parser_t *parser, const char *file_path, amxd_object_t *object)
void	amxo_parser_child_init (amxo_parser_t *parser)
int	amxo_parser_init (amxo_parser_t *parser)
	Initializes a new odl parser instance. More...
void	amxo_parser_clean (amxo_parser_t *parser)
	Cleans up the odl parser instance. More...
int	amxo_parser_new (amxo_parser_t **parser)
	Allocates memory for a new parser instance on the heap and initializes the odl parser. More...
void	amxo_parser_delete (amxo_parser_t **parser)
	Cleans the odl parser content and frees the allocated memory. More...
int	amxo_parser_parse_fd (amxo_parser_t *parser, int fd, amxd_object_t *object)
	Parses an odl file. More...
int	amxo_parser_parse_file (amxo_parser_t *parser, const char *file_path, amxd_object_t *object)
	Parses an odl file. More...
int	amxo_parser_parse_string (amxo_parser_t *parser, const char *text, amxd_object_t *object)
	Parses a string containing a valid ODL part. More...
amxc_var_t *	amxo_parser_claim_config (amxo_parser_t *parser, const char *path)
	Gets or creates a configuration option. More...
amxc_var_t *	amxo_parser_get_config (amxo_parser_t *parser, const char *path)
	Gets a configuration option. More...
int	amxo_parser_set_config (amxo_parser_t *parser, const char *path, amxc_var_t *value)
	Sets a configuration option. More...
int	amxo_parser_add_entry_point (amxo_parser_t *parser, amxo_entry_point_t fn)
	Adds an entry point function. More...
int	amxo_parser_invoke_entry_points (amxo_parser_t *parser, amxd_dm_t *dm, int reason)
	Invokes all registered entry points. More...
int	amxo_parser_rinvoke_entry_points (amxo_parser_t *parser, amxd_dm_t *dm, int reason)
	Invokes all registered entry points in reversed order. More...
int	amxo_parser_start_synchronize (amxo_parser_t *parser)
	Start all object and parameter synchronizations that were declared in the loaded odl files. More...
void	amxo_parser_stop_synchronize (amxo_parser_t *parser)
	Stop all object and parameter synchronizations that were declared in odl files. More...
amxs_sync_ctx_t *	amxo_parser_new_sync_ctx (const char *sync_template, const char *object_a, const char *object_b)
	Create a new synchronization context from a synchronization template. More...

Macro Definition Documentation

_GNU_SOURCE

#define _GNU_SOURCE

Definition at line 56 of file amxo_parser_main.c.

Function Documentation

amxo_parser_child_init()

void amxo_parser_child_init

(

amxo_parser_t *

parser

)

Definition at line 181 of file amxo_parser_main.c.

                                                   {
    when_null(parser, exit);
 
    parser->fd = -1;
    parser->object = NULL;
    parser->param = NULL;
    parser->func = NULL;
    parser->status = amxd_status_ok;
    parser->resolved_fn = NULL;
    parser->resolvers = NULL;
    parser->include_stack = NULL;
    parser->hooks = NULL;
    parser->entry_points = NULL;
    parser->_unused_1 = NULL;
    parser->_unused_2 = NULL;
    parser->post_includes = NULL;
    parser->parent = NULL;
    parser->resolved_fn_name = NULL;
    parser->buffer_len = 0;
    parser->data = NULL;
    parser->sync_contexts = NULL;
 
    memset(parser->buffer, 0, 128);
    amxc_rbuffer_init(&parser->rbuffer, 0);
    amxc_string_init(&parser->msg, 0);
    amxc_astack_init(&parser->object_stack);
    amxc_llist_init(&parser->event_list);
    amxc_var_init(&parser->config);
    amxc_llist_init(&parser->global_config);
    amxc_htable_init(&parser->mibs, 5);
    amxc_llist_init(&parser->function_names);
 
    parser->file = "<unknown>";
 
exit:
    return;
}

amxo_parser_entry_point_free()

static void amxo_parser_entry_point_free ( amxc_llist_it_t *  it )

static

Definition at line 99 of file amxo_parser_main.c.

                                                              {
    amxo_entry_t* entry = amxc_llist_it_get_data(it, amxo_entry_t, it);
    free(entry);
}

amxo_parser_fd_reader()

ssize_t amxo_parser_fd_reader	(	amxo_parser_t *	parser,
		char *	buf,
		size_t	max_size
	)

Definition at line 104 of file amxo_parser_main.c.

                                                                                 {
    ssize_t result = 0;
    off_t offset = 0;
 
    errno = 0;
    result = read(parser->fd, buf, max_size - 1);
    if((result == -1) && (errno != EAGAIN)) {
        printf("Read failed %d\n", errno);
        goto exit;
    }
    errno = 0;
 
    buf[result] = 0;
    while(result - offset > 0 && buf[result - offset - 1] != '\n') {
        offset++;
    }
    if(result - offset > 0) {
        lseek(parser->fd, -offset, SEEK_CUR);
        result -= offset;
    }
 
exit:
    return result;
}

amxo_parser_parse_fd_internal()

static int amxo_parser_parse_fd_internal ( amxo_parser_t *  parser, int  fd, amxd_object_t *  object  )

static

Definition at line 73 of file amxo_parser_main.c.

                                                                {
    int retval = -1;
 
    parser->fd = fd;
    parser->object = object;
    parser->reader = amxo_parser_fd_reader;
    parser->status = amxd_status_ok;
 
    amxc_string_reset(&parser->msg);
    amxo_parser_create_lex(parser);
    retval = yyparse(parser->scanner);
    amxo_parser_destroy_lex(parser);
 
    amxo_parser_sync_remove_invalid(parser);
 
    parser->fd = -1;
 
    if(retval == 0) {
        amxc_string_clean(&parser->msg);
    }
 
    return retval;
}

amxo_parser_parse_file_impl()

int amxo_parser_parse_file_impl	(	amxo_parser_t *	parser,
		const char *	file_path,
		amxd_object_t *	object
	)

Definition at line 156 of file amxo_parser_main.c.

                                                       {
    int retval = -1;
    int fd = -1;
 
    fd = open(file_path, O_RDONLY);
    if(fd == -1) {
        retval = errno;
        if(errno == ENOENT) {
            amxo_parser_msg(parser, "File not found %s", file_path);
        } else {
            amxo_parser_msg(parser, "File open error 0x%8.8X", errno);
        }
        goto exit;
    }
    parser->file = file_path;
    retval = amxo_parser_parse_fd_internal(parser, fd, object);
    parser->file = NULL;
    close(fd);
 
exit:
    return retval;
}

amxo_parser_pop_event()

static void amxo_parser_pop_event ( event_t *  e, amxd_dm_t *  dm  )

static

Definition at line 129 of file amxo_parser_main.c.

                                                             {
    amxd_object_t* object = amxd_dm_findf(dm, "%s", e->path);
 
    when_null(object, exit);
 
    if(dm->sigmngr.enabled) {
        if(e->id == event_instance_add) {
            amxd_object_send_add_inst(object, false);
        } else if(e->id == event_object_change) {
            amxd_object_send_changed(object, &e->data, false);
        }
    }
 
exit:
    amxc_llist_it_take(&e->it);
    amxc_var_clean(&e->data);
    free(e->path);
    free(e);
}

amxo_parser_send_events()

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

static

Definition at line 149 of file amxo_parser_main.c.

                                                                          {
    amxc_llist_for_each(it, &parser->event_list) {
        event_t* e = amxc_container_of(it, event_t, it);
        amxo_parser_pop_event(e, dm);
    }
}

amxo_parser_string_reader()

static ssize_t amxo_parser_string_reader ( amxo_parser_t *  parser, char *  buf, size_t  max_size  )

static

Definition at line 63 of file amxo_parser_main.c.

                                                          {
    ssize_t result = 0;
    result = amxc_rbuffer_read(&parser->rbuffer, (char*) buf, max_size);
    errno = 0;
 
    return result;
}