Mirrors/VILLASnode
1
0
Fork 0
mirror of https://git.rwth-aachen.de/acs/public/villas/node/ synced 2025-03-09 00:00:00 +01:00
Code Issues Releases Wiki Activity

iec61850-9-2: a little progress

Browse source
This commit is contained in:
Steffen Vogel 2017-06-13 03:18:16 +02:00
parent 2c74761ee1
commit 2be839eae0
2 changed files with 68 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

42
include/villas/nodes/iec61850_sv.h
View file

@ -31,11 +31,53 @@
#include <stdint.h>
#include <libiec61850/sv_publisher.h>
#include "node.h"
#include "list.h"
enum {
IEC61850_TYPE_BOOLEAN,
IEC61850_TYPE_INT8,
IEC61850_TYPE_INT16,
IEC61850_TYPE_INT32,
IEC61850_TYPE_INT64,
IEC61850_TYPE_INT8U,
IEC61850_TYPE_INT16U,
IEC61850_TYPE_INT24U,
IEC61850_TYPE_INT32U,
IEC61850_TYPE_FLOAT32,
IEC61850_TYPE_FLOAT64,
IEC61850_TYPE_ENUMERATED,
IEC61850_TYPE_CODED_ENUM,
IEC61850_TYPE_OCTET_STRING,
IEC61850_TYPE_VISIBLE_STRING,
IEC61850_TYPE_TIMESTAMP,
IEC61850_TYPE_ENTRYTIME,
IEC61850_TYPE_BITSTRING
} type;
struct iec61850_sv_mapping {
SV_ASDU *asdu;
int offset;
enum iec61850_type type;
};
struct iec61850_sv {
char *interface;
struct {
SVReceiver receiver
SVSubscriber subscriber;
} in;
struct {
SampledValuesPublisher publisher;
struct list mapping;
struct list asdus;
} out;
};
/** @} */

38
lib/nodes/iec61850_sv.c
View file

@ -22,10 +22,8 @@
#include <string.h>
#include "plugin.h"
#include "nodes/iec61850_sv.h"
#include "utils.h"
#include "msg.h"
#include "plugin.h"
int iec61850_sv_reverse(struct node *n)
{
@ -52,19 +50,24 @@ char * iec61850_sv_print(struct node *n)
int iec61850_sv_start(struct node *n)
{
struct iec61850_sv *i __attribute__((unused)) = n->_vd;
SampledValuesPublisher svPublisher = SampledValuesPublisher_create(interface);
SV_ASDU asdu1 = SampledValuesPublisher_addASDU(svPublisher, "svpub1", NULL, 1);
int float1 = SV_ASDU_addFLOAT(asdu1);
int float2 = SV_ASDU_addFLOAT(asdu1);
SampledValuesPublisher_setupComplete(i->publisher);
return 0;
}
int iec61850_sv_stop(struct node *n)
{
struct iec61850_sv *i __attribute__((unused)) = n->_vd;
return 0;
}
int iec61850_sv_deinit()
{
struct iec61850_sv *i = n->_vd;
SampledValuesPublisher_destroy(i->publisher.handle);
return 0;
}
@ -78,7 +81,19 @@ int iec61850_sv_read(struct node *n, struct sample *smps[], unsigned cnt)
int iec61850_sv_write(struct node *n, struct sample *smps[], unsigned cnt)
{
struct iec61850_sv *i __attribute__((unused)) = n->_vd;
struct iec61850_sv *i = n->_vd;
for (int i = 0; i < cnt; i++) {
SV_ASDU_setFLOAT(asdu1, float1, fVal1);
}
for (int j = 0; j < cnt; j++) {
SV_ASDU *asdu = (SV_ASDU *) list_at(i->publisher.asdus, j);
SV_ASDU_increaseSmpCnt(asdu);
}
SampledValuesPublisher_publish(i->publisher.handle);
return 0;
}
@ -95,7 +110,6 @@ static struct plugin p = {
.print = iec61850_sv_print,
.start = iec61850_sv_start,
.stop = iec61850_sv_stop,
.deinit = iec61850_sv_deinit,
.read = iec61850_sv_read,
.write = iec61850_sv_write,
.instances = LIST_INIT()