amxb_ba_connect.c File Reference

#include <errno.h>
#include <fcntl.h>
#include <uriparser/Uri.h>
#include <amxc/amxc.h>
#include <amxp/amxp.h>
#include <amxd/amxd_dm.h>
#include <amxb/amxb_be_intf.h>
#include <amxb/amxb.h>
#include "amxb_priv.h"

Go to the source code of this file.

Functions
static int	amxb_uri_part_to_string (amxc_string_t *buffer, UriTextRangeA *tr)
static int	amxb_uri_path_to_string (amxc_string_t *buffer, UriPathSegmentA *ps)
static int	amxb_uri_parse (const char *uri, char **scheme, char **host, char **port, char **path)
static int	amxb_bus_ctx_init (amxb_bus_ctx_t **ctx, amxb_be_funcs_t *fns)
static int	amxb_bus_ctx_create (amxb_bus_ctx_t **ctx, amxb_be_funcs_t **fns, const char *uri, char **scheme, char **host, char **port, char **path)
static int	amxb_bus_ctx_be_init (amxb_bus_ctx_t *ctx, amxb_be_funcs_t *fns, amxb_be_connect_fn_t fn, const char *uri, const char *host, const char *port, const char *path)
static void	amxb_free_request (amxc_llist_it_t *it)
int	amxb_connect_intf (amxb_bus_ctx_t **ctx, const char *uri, const char *intf)
	Create a bus connection. More...
int	amxb_connect (amxb_bus_ctx_t **ctx, const char *uri)
	Create a bus connection. More...
int	amxb_listen (amxb_bus_ctx_t **ctx, const char *uri)
	Create a listen socket. More...
int	amxb_accept (amxb_bus_ctx_t *listen_ctx, amxb_bus_ctx_t **accepted_ctx)
	Accepts an incomming connection request. More...
int	amxb_disconnect (amxb_bus_ctx_t *ctx)
	Disconnects a bus connection. More...
void	amxb_free (amxb_bus_ctx_t **ctx)
	Frees allocated memory. More...
amxb_bus_ctx_t *	amxb_find_uri (const char *uri)
	Find the bus context for a given uri. More...
amxc_array_t *	amxb_list_uris (void)
	List all open connections by their uri. More...
int	amxb_get_fd (const amxb_bus_ctx_t *const ctx)
	Get the connection file descriptor. More...
int	amxb_read (const amxb_bus_ctx_t *const ctx)
	Reads data from the file descriptor. More...
int	amxb_read_raw (const amxb_bus_ctx_t *const ctx, void *buf, size_t count)
	Attempts to read up to count bytes from the file descriptor into the buffer starting at buf. More...
static CONSTRUCTOR void	amxb_initialize_connections (void)
static DESTRUCTOR void	amxb_cleanup_connections (void)

Variables
static amxc_htable_t	uri_bus_ctxs

Function Documentation

amxb_bus_ctx_be_init()

static int amxb_bus_ctx_be_init ( amxb_bus_ctx_t *  ctx, amxb_be_funcs_t *  fns, amxb_be_connect_fn_t  fn, const char *  uri, const char *  host, const char *  port, const char *  path  )

static

Definition at line 169 of file amxb_ba_connect.c.

                                                  {
    int retval = -1;
 
    ctx->bus_ctx = fn(host, port, path, &ctx->sigmngr);
    if(ctx->bus_ctx == NULL) {
        retval = AMXB_ERROR_BACKEND_FAILED;
    } else {
        amxc_llist_append(&fns->connections, &ctx->it);
        amxc_htable_insert(&uri_bus_ctxs, uri, &ctx->hit);
        retval = 0;
    }
 
    return retval;
}

amxb_bus_ctx_create()

static int amxb_bus_ctx_create ( amxb_bus_ctx_t **  ctx, amxb_be_funcs_t **  fns, const char *  uri, char **  scheme, char **  host, char **  port, char **  path  )

static

Definition at line 141 of file amxb_ba_connect.c.

                                            {
    int retval = -1;
 
    when_null(ctx, exit);
    when_not_null(*ctx, exit);
    if(amxb_uri_parse(uri, scheme, host, port, path) != 0) {
        retval = AMXB_ERROR_INVALID_URI;
        goto exit;
    }
 
    *fns = amxb_be_find(*scheme);
    if(*fns == NULL) {
        retval = AMXB_ERROR_NOT_SUPPORTED_SCHEME;
        goto exit;
    }
 
    retval = amxb_bus_ctx_init(ctx, *fns);
 
exit:
    return retval;
}

amxb_bus_ctx_init()

static int amxb_bus_ctx_init ( amxb_bus_ctx_t **  ctx, amxb_be_funcs_t *  fns  )

static

Definition at line 123 of file amxb_ba_connect.c.

                                                                         {
    int retval = -1;
 
    *ctx = (amxb_bus_ctx_t*) calloc(1, sizeof(amxb_bus_ctx_t));
    when_null(*ctx, exit);
 
    (*ctx)->bus_fn = fns;
    amxp_sigmngr_init(&(*ctx)->sigmngr);
    amxc_htable_init(&(*ctx)->subscriptions, 5);
    amxc_llist_init(&(*ctx)->client_subs);
    (*ctx)->access = AMXB_PROTECTED;
    (*ctx)->socket_type = AMXB_DATA_SOCK;
 
    retval = 0;
exit:
    return retval;
}

amxb_cleanup_connections()

static DESTRUCTOR void amxb_cleanup_connections ( void  )

static

Definition at line 430 of file amxb_ba_connect.c.

                                                      {
    amxc_htable_clean(&uri_bus_ctxs, NULL);
}

amxb_free_request()

static void amxb_free_request ( amxc_llist_it_t *  it )

static

Definition at line 190 of file amxb_ba_connect.c.

                                                   {
    amxb_req_t* req = amxc_container_of(it, amxb_req_t, it);
    if(req->closed && !req->in_flight) {
        free(req);
    }
}

amxb_initialize_connections()

static CONSTRUCTOR void amxb_initialize_connections ( void  )

static

Definition at line 426 of file amxb_ba_connect.c.

                                                          {
    amxc_htable_init(&uri_bus_ctxs, 10);
}

amxb_uri_parse()

static int amxb_uri_parse ( const char *  uri, char **  scheme, char **  host, char **  port, char **  path  )

static

Definition at line 92 of file amxb_ba_connect.c.

                                       {
    int retval = -1;
    UriUriA parsed_uri;
    amxc_string_t uri_part;
    amxc_string_init(&uri_part, 0);
 
    when_failed(uriParseSingleUriA(&parsed_uri, uri, NULL), exit);
    amxb_uri_part_to_string(&uri_part, &parsed_uri.scheme);
    *scheme = amxc_string_take_buffer(&uri_part);
    when_null(*scheme, exit_clean);
    amxb_uri_part_to_string(&uri_part, &parsed_uri.hostText);
    *host = amxc_string_take_buffer(&uri_part);
    amxb_uri_part_to_string(&uri_part, &parsed_uri.portText);
    *port = amxc_string_take_buffer(&uri_part);
    amxb_uri_path_to_string(&uri_part, parsed_uri.pathHead);
    *path = amxc_string_take_buffer(&uri_part);
 
    retval = 0;
 
exit_clean:
    uriFreeUriMembersA(&parsed_uri);
 
exit:
    amxc_string_clean(&uri_part);
    return retval;
}

amxb_uri_part_to_string()

static int amxb_uri_part_to_string ( amxc_string_t *  buffer, UriTextRangeA *  tr  )

static

Definition at line 72 of file amxb_ba_connect.c.

                                                      {
 
    return amxc_string_append(buffer, tr->first, tr->afterLast - tr->first);
}

amxb_uri_path_to_string()

static int amxb_uri_path_to_string ( amxc_string_t *  buffer, UriPathSegmentA *  ps  )

static

Definition at line 78 of file amxb_ba_connect.c.

                                                        {
 
    const char* sep = "/";
    while(ps) {
        amxc_string_append(buffer, sep, strlen(sep));
        amxb_uri_part_to_string(buffer, &ps->text);
        sep = "/";
        ps = ps->next;
    }
 
    return 0;
}

Variable Documentation

uri_bus_ctxs

amxc_htable_t uri_bus_ctxs

static

Definition at line 70 of file amxb_ba_connect.c.