mirror of
https://git.rwth-aachen.de/acs/public/villas/node/
synced 2025-03-23 00:00:01 +01:00
Steffen Vogel
c2516799ee
git-svn-id: https://zerberus.eonerc.rwth-aachen.de:8443/svn/s2ss/trunk@155 8ec27952-4edc-4aab-86aa-e87bb2611832
61 lines
1.3 KiB
C
61 lines
1.3 KiB
C
/** Nodes.
|
|
*
|
|
* @author Steffen Vogel <stvogel@eonerc.rwth-aachen.de>
|
|
* @copyright 2014, Institute for Automation of Complex Power Systems, EONERC
|
|
*/
|
|
|
|
#include <stdlib.h>
|
|
#include <string.h>
|
|
#include <unistd.h>
|
|
|
|
#include "config.h"
|
|
#include "cfg.h"
|
|
#include "utils.h"
|
|
#include "msg.h"
|
|
#include "node.h"
|
|
#include "if.h"
|
|
|
|
int node_connect(struct node *n)
|
|
{
|
|
/* Create socket */
|
|
n->sd = socket(AF_INET, SOCK_DGRAM, 0);
|
|
if (n->sd < 0)
|
|
perror("Failed to create socket");
|
|
|
|
/* Set socket options */
|
|
int prio = SOCKET_PRIO;
|
|
if (setsockopt(n->sd, SOL_SOCKET, SO_PRIORITY, &prio, sizeof(prio)))
|
|
perror("Failed to set socket priority");
|
|
else
|
|
debug(4, "Set socket priority of node '%s' to %u", n->name, prio);
|
|
|
|
/* Set mark for outgoing packets */
|
|
if (setsockopt(n->sd, SOL_SOCKET, SO_MARK, &n->mark, sizeof(n->mark)))
|
|
perror("Failed to set mark for outgoing packets");
|
|
else
|
|
debug(4, "Set mark of outgoing packets of node '%s' to %u", n->name, n->mark);
|
|
|
|
/* Bind socket for receiving */
|
|
if (bind(n->sd, (struct sockaddr *) &n->local, sizeof(struct sockaddr_in)))
|
|
perror("Failed to bind to socket");
|
|
|
|
return 0;
|
|
}
|
|
|
|
int node_disconnect(struct node *n)
|
|
{
|
|
close(n->sd);
|
|
|
|
return 0;
|
|
}
|
|
|
|
struct node* node_lookup_name(const char *str, struct node *nodes)
|
|
{
|
|
for (struct node *n = nodes; n; n = n->next) {
|
|
if (!strcmp(str, n->name)) {
|
|
return n;
|
|
}
|
|
}
|
|
|
|
return NULL;
|
|
}
|