mirror of
https://git.rwth-aachen.de/acs/public/villas/node/
synced 2025-03-16 00:00:02 +01:00
133 lines
2.5 KiB
C
133 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
|
|
list_foreach(const struct node_type *vt, &node_types) {
|
|
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 */
|
|
list_foreach(const struct node_type *vt, &node_types) {
|
|
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 node_open(n);
|
|
}
|
|
}
|
|
|
|
int node_stop(struct node *n)
|
|
{ INDENT
|
|
int ret;
|
|
info("Stopping node '%s'", n->name);
|
|
|
|
{ INDENT
|
|
ret = node_close(n);
|
|
}
|
|
|
|
return ret;
|
|
}
|
|
|
|
void node_reverse(struct node *n)
|
|
{
|
|
switch (node_type(n)) {
|
|
#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 (node_type(n)) {
|
|
#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);
|
|
}
|