mirror of
https://git.rwth-aachen.de/acs/public/villas/node/
synced 2025-03-16 00:00:02 +01:00
Steffen Vogel
bfb0221ccf
The new versions of those string concatenating functions are using realloc() to dynamically resize the string buffer if needed. We don't use the stack anymore.
134 lines
2.5 KiB
C
134 lines
2.5 KiB
C
/** Nodes.
|
|
*
|
|
* @author Steffen Vogel <stvogel@eonerc.rwth-aachen.de>
|
|
* @copyright 2014-2015, Institute for Automation of Complex Power Systems, EONERC
|
|
* This file is part of S2SS. All Rights Reserved. Proprietary and confidential.
|
|
* Unauthorized copying of this file, via any medium is strictly prohibited.
|
|
*********************************************************************************/
|
|
|
|
#include <string.h>
|
|
|
|
#include "node.h"
|
|
#include "cfg.h"
|
|
#include "utils.h"
|
|
|
|
/* Node types */
|
|
#include "file.h"
|
|
#ifdef ENABLE_GTFPGA
|
|
#include "gtfpga.h"
|
|
#endif
|
|
#ifdef ENABLE_OPAL_ASYNC
|
|
#include "opal.h"
|
|
#endif
|
|
#ifdef ENABLE_SOCKET
|
|
#include "socket.h"
|
|
#include <netlink/route/qdisc.h>
|
|
#include <netlink/route/classifier.h>
|
|
#endif
|
|
#ifdef ENABLE_NGSI
|
|
#include "ngsi.h"
|
|
#include <jansson.h>
|
|
#endif
|
|
|
|
/** Vtable for virtual node sub types */
|
|
struct list node_types = LIST_INIT(NULL);
|
|
|
|
int node_init(int argc, char *argv[], struct settings *set)
|
|
{ INDENT
|
|
FOREACH(&node_types, it) {
|
|
const struct node_type *vt = it->type;
|
|
if (vt->refcnt) {
|
|
info("Initializing '%s' node type", vt->name);
|
|
vt->init(argc, argv, set);
|
|
}
|
|
}
|
|
|
|
return 0;
|
|
}
|
|
|
|
int node_deinit()
|
|
{ INDENT
|
|
/* De-initialize node types */
|
|
FOREACH(&node_types, it) {
|
|
struct node_type *vt = it->type;
|
|
if (vt->refcnt) {
|
|
info("De-initializing '%s' node type", vt->name);
|
|
vt->deinit();
|
|
}
|
|
}
|
|
return 0;
|
|
}
|
|
|
|
int node_start(struct node *n)
|
|
{ INDENT
|
|
if (!n->refcnt) {
|
|
warn("Node '%s' is unused. Skipping...", n->name);
|
|
return -1;
|
|
}
|
|
|
|
char *buf = node_print(n);
|
|
debug(1, "Starting node '%s' of type '%s' (%s)", n->name, n->vt->name, buf);
|
|
free(buf);
|
|
|
|
{ INDENT
|
|
return n->vt->open(n);
|
|
}
|
|
}
|
|
|
|
int node_stop(struct node *n)
|
|
{ INDENT
|
|
int ret;
|
|
info("Stopping node '%s'", n->name);
|
|
|
|
{ INDENT
|
|
ret = n->vt->close(n);
|
|
}
|
|
|
|
return ret;
|
|
}
|
|
|
|
void node_reverse(struct node *n)
|
|
{
|
|
switch (n->vt->type) {
|
|
#ifdef ENABLE_SOCKET
|
|
case BSD_SOCKET:
|
|
SWAP(n->socket->remote, n->socket->local);
|
|
break;
|
|
#endif
|
|
case LOG_FILE:
|
|
SWAP(n->file->path_in, n->file->path_out);
|
|
break;
|
|
default: { }
|
|
}
|
|
}
|
|
|
|
struct node * node_create()
|
|
{
|
|
return alloc(sizeof(struct node));
|
|
}
|
|
|
|
void node_destroy(struct node *n)
|
|
{
|
|
switch (n->vt->type) {
|
|
#ifdef ENABLE_NGSI
|
|
case NGSI:
|
|
json_decref(n->ngsi->context);
|
|
free(n->ngsi->context_map);
|
|
break;
|
|
#endif
|
|
#ifdef ENABLE_SOCKET
|
|
case BSD_SOCKET:
|
|
rtnl_qdisc_put(n->socket->tc_qdisc);
|
|
rtnl_cls_put(n->socket->tc_classifier);
|
|
break;
|
|
#endif
|
|
case LOG_FILE:
|
|
free(n->file->path_in);
|
|
free(n->file->path_out);
|
|
break;
|
|
default: { }
|
|
}
|
|
|
|
free(n->socket);
|
|
free(n);
|
|
}
|