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

Remove sequence num ordering in case of gtnet-skt without GTNET_SKT_HEADER enabled

Browse source
This commit is contained in:
Steffen Vogel 2016-10-12 16:57:14 +02:00
parent deba073407
commit 5aa4fec093
4 changed files with 8 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
config.h
View file

@ -25,7 +25,7 @@
#define DEFAULT_QUEUELEN 1024
/** Whether or not to send / receive timestamp & sequence number as first values of payload */
#define GTNET_SKT_HEADER 1
#define GTNET_SKT_HEADER 0
/** Width of log output in characters */
#define LOG_WIDTH 132

4
etc/gtnet_test4.conf
View file

@ -32,8 +32,8 @@ nodes = {
node1 = {
type = "socket",
layer = "udp",
local = "192.168.88.128:12002", # Local ip:port, use '*' for random port
remote = "192.168.88.129:12001",
local = "134.130.169.31:12002", # Local ip:port, use '*' for random port
remote = "134.130.169.98:12001",
header = "gtnet-skt", # 'gtnet-skt' or 'villas'. If not provided, 'villas' header will be used
vectorize = 1, # Number of samples to fetch per iteration from the socket
netem = {

1
include/villas/hooks.h
View file

@ -22,6 +22,7 @@
#define _HOOKS_H_
#include <time.h>
#include <string.h>
#include "queue.h"
#include "list.h"

4
lib/hooks/hooks-internal.c
View file

@ -67,6 +67,10 @@ int hook_drop(struct path *p, struct hook *h, int when, struct sample *smps[], s
{
int i, ok, dist;
/** Don't check the sequence number order in case of gtnet-skt without header */
if(!strcmp(p->in->_vt->name, "socket") && !GTNET_SKT_HEADER)
return cnt;
for (i = 0, ok = 0; i < cnt; i++) {
h->last = smps[i];