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

infiniband: adapt to new signal code and separate node-type configuration into in/out sections

Browse source
This commit is contained in:
Steffen Vogel 2018-08-20 18:29:12 +02:00
parent a59509294c
commit 8a1947b95f
1 changed files with 2 additions and 15 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
lib/nodes/infiniband.c
View file

@ -826,13 +826,6 @@ int ib_read(struct node *n, struct sample *smps[], unsigned cnt, unsigned *relea
j++;
// Format
sge[i][j].addr = (uint64_t) &smps[i]->format;
sge[i][j].length = sizeof(smps[i]->format);
sge[i][j].lkey = mr->lkey;
j++;
// Timespec origin
sge[i][j].addr = (uint64_t) &smps[i]->ts.origin;
sge[i][j].length = sizeof(smps[i]->ts.origin);
@ -890,7 +883,7 @@ int ib_read(struct node *n, struct sample *smps[], unsigned cnt, unsigned *relea
smps[j]->length = (wc[j].byte_len - correction) / sizeof(double);
smps[j]->ts.received = ts_receive;
smps[j]->flags = (SAMPLE_HAS_ORIGIN | SAMPLE_HAS_RECEIVED | SAMPLE_HAS_SEQUENCE | SAMPLE_HAS_FORMAT);
smps[j]->flags = (SAMPLE_HAS_TS_ORIGIN | SAMPLE_HAS_TS_RECEIVED | SAMPLE_HAS_SEQUENCE);
}
}
return read_values;
@ -928,13 +921,6 @@ int ib_write(struct node *n, struct sample *smps[], unsigned cnt, unsigned *rele
j++;
// Format
sge[sent][j].addr = (uint64_t) &smps[sent]->format;
sge[sent][j].length = sizeof(smps[sent]->format);
sge[sent][j].lkey = mr->lkey;
j++;
// Timespec origin
sge[sent][j].addr = (uint64_t) &smps[sent]->ts.origin;
sge[sent][j].length = sizeof(smps[sent]->ts.origin);
@ -1064,6 +1050,7 @@ static struct plugin p = {
.node = {
.vectorize = 0,
.size = sizeof(struct infiniband),
.pool_size = 8192,
.reverse = ib_reverse,
.parse = ib_parse,
.check = ib_check,