XANTRONIX Development
9734c97f35
Implement src/daemon.c to provide a high level method to instantiate a
patty server
Changes:
* Refactor src/server.c, src/route.c, src/if.c methods which accept
callsign arguments to use a patty_ax25_addr pointer instead; this
has significantly reduced the number of redundant calls to
patty_ax25_pton()
* Decouple patty_ax25_addr from patty_ax25_if_info types when
creating new interfaces with patty_ax25_if_new(); instead, take a
separate patty_ax25_addr argument
* Split patty_ax25_server_run() into the following methods:
- patty_ax25_server_start()
- patty_ax25_server_stop()
- patty_ax25_server_event_handle()
This is intended to allow possible integration into other event
loops.
* Implement src/daemon.c to allow quick instantiation of a server,
interfaces, and routes, and to encapsulate the setting of
configuration variables; callsigns and interface names are handled
as character strings
* Rename examples/server.c to examples/daemon.c; reimplement in
terms of the patty_daemon code
*
147 lines
3.3 KiB
C
147 lines
3.3 KiB
C
#include <stdlib.h>
|
|
#include <string.h>
|
|
#include <stdint.h>
|
|
#include <errno.h>
|
|
|
|
#include <patty/hash.h>
|
|
|
|
#include <patty/ax25.h>
|
|
|
|
patty_ax25_route *patty_ax25_route_new(patty_ax25_if *iface,
|
|
patty_ax25_addr *dest,
|
|
patty_ax25_addr *repeaters,
|
|
int hops) {
|
|
patty_ax25_route *route;
|
|
|
|
int i;
|
|
|
|
if (hops >= PATTY_AX25_MAX_HOPS) {
|
|
errno = EOVERFLOW;
|
|
|
|
goto error_max_hops;
|
|
}
|
|
|
|
if ((route = malloc(sizeof(*route))) == NULL) {
|
|
goto error_malloc_route;
|
|
}
|
|
|
|
memset(route, '\0', sizeof(*route));
|
|
|
|
route->iface = iface;
|
|
|
|
if (dest) {
|
|
patty_ax25_addr_copy(&route->dest, dest, 0);
|
|
}
|
|
|
|
for (i=0; i<hops; i++) {
|
|
patty_ax25_addr_copy(&route->repeaters, &repeaters[i], 0);
|
|
}
|
|
|
|
return route;
|
|
|
|
error_malloc_route:
|
|
error_max_hops:
|
|
return NULL;
|
|
}
|
|
|
|
patty_ax25_route *patty_ax25_route_new_default(patty_ax25_if *iface) {
|
|
return patty_ax25_route_new(iface, NULL, NULL, 0);
|
|
}
|
|
|
|
patty_ax25_route_table *patty_ax25_route_table_new() {
|
|
return patty_dict_new();
|
|
}
|
|
|
|
void patty_ax25_route_table_destroy(patty_ax25_route_table *table) {
|
|
patty_dict_destroy(table);
|
|
}
|
|
|
|
patty_ax25_route *patty_ax25_route_table_find(patty_ax25_route_table *table,
|
|
patty_ax25_addr *dest) {
|
|
patty_ax25_route *route;
|
|
uint32_t hash;
|
|
|
|
patty_hash_init(&hash);
|
|
patty_ax25_addr_hash(&hash, dest);
|
|
patty_hash_end(&hash);
|
|
|
|
route = patty_dict_get(table, hash);
|
|
|
|
if (route) {
|
|
return route;
|
|
}
|
|
|
|
return patty_ax25_route_table_default(table);
|
|
}
|
|
|
|
patty_ax25_route *patty_ax25_route_table_default(patty_ax25_route_table *table) {
|
|
patty_ax25_addr empty;
|
|
|
|
uint32_t hash;
|
|
|
|
memset(&empty, '\0', sizeof(empty));
|
|
|
|
patty_hash_init(&hash);
|
|
patty_ax25_addr_hash(&hash, &empty);
|
|
patty_hash_end(&hash);
|
|
|
|
return patty_dict_get(table, hash);
|
|
}
|
|
|
|
struct dict_ctx_wrapper {
|
|
int (*callback)(patty_ax25_route *route, void *);
|
|
void *ctx;
|
|
};
|
|
|
|
static int each_dict_callback(uint32_t key, void *value, void *ctx) {
|
|
struct dict_ctx_wrapper *wrapper = ctx;
|
|
|
|
return wrapper->callback(value, wrapper->ctx);
|
|
}
|
|
|
|
int patty_ax25_route_table_each(patty_ax25_route_table *table,
|
|
int (*callback)(patty_ax25_route *, void *),
|
|
void *ctx) {
|
|
struct dict_ctx_wrapper wrapper = {
|
|
.callback = callback,
|
|
.ctx = ctx
|
|
};
|
|
|
|
return patty_dict_each(table, each_dict_callback, &wrapper);
|
|
}
|
|
|
|
int patty_ax25_route_table_add(patty_ax25_route_table *table,
|
|
patty_ax25_route *route) {
|
|
uint32_t hash;
|
|
|
|
patty_hash_init(&hash);
|
|
patty_ax25_addr_hash(&hash, &route->dest);
|
|
patty_hash_end(&hash);
|
|
|
|
if (patty_ax25_route_table_find(table, &route->dest) != NULL) {
|
|
errno = EEXIST;
|
|
|
|
goto error_exists;
|
|
}
|
|
|
|
if (patty_dict_set(table, hash, route) == NULL) {
|
|
goto error_dict_set;
|
|
}
|
|
|
|
return 0;
|
|
|
|
error_dict_set:
|
|
error_exists:
|
|
return -1;
|
|
}
|
|
|
|
int patty_ax25_route_table_delete(patty_ax25_route_table *route,
|
|
patty_ax25_addr *dest) {
|
|
uint32_t hash;
|
|
|
|
patty_hash_init(&hash);
|
|
patty_ax25_addr_hash(&hash, dest);
|
|
patty_hash_end(&hash);
|
|
|
|
return patty_dict_delete(route, hash);
|
|
}
|