svn commit: r226130 - in projects/diffused_head/sys:
modules/diffuse modules/diffuse/diffuse_feature_iat netinet/ipfw
Lawrence Stewart
lstewart at FreeBSD.org
Sat Oct 8 04:16:20 UTC 2011
Author: lstewart
Date: Sat Oct 8 04:16:19 2011
New Revision: 226130
URL: http://svn.freebsd.org/changeset/base/226130
Log:
A DIFFUSE feature kernel module which calculates per-flow minimum, mean, maximum
and standard deviation interarrival time statistics for use in classification
decisions.
Sponsored by: FreeBSD Foundation
Reviewed by: bz
Added:
projects/diffused_head/sys/modules/diffuse/diffuse_feature_iat/
projects/diffused_head/sys/modules/diffuse/diffuse_feature_iat/Makefile (contents, props changed)
projects/diffused_head/sys/netinet/ipfw/diffuse_feature_iat.c (contents, props changed)
projects/diffused_head/sys/netinet/ipfw/diffuse_feature_iat.h (contents, props changed)
projects/diffused_head/sys/netinet/ipfw/diffuse_feature_iat_common.h (contents, props changed)
Modified:
projects/diffused_head/sys/modules/diffuse/Makefile
Modified: projects/diffused_head/sys/modules/diffuse/Makefile
==============================================================================
--- projects/diffused_head/sys/modules/diffuse/Makefile Sat Oct 8 04:09:23 2011 (r226129)
+++ projects/diffused_head/sys/modules/diffuse/Makefile Sat Oct 8 04:16:19 2011 (r226130)
@@ -1,5 +1,6 @@
# $FreeBSD$
-SUBDIR= diffuse
+SUBDIR= diffuse \
+ diffuse_feature_iat
.include <bsd.subdir.mk>
Added: projects/diffused_head/sys/modules/diffuse/diffuse_feature_iat/Makefile
==============================================================================
--- /dev/null 00:00:00 1970 (empty, because file is newly added)
+++ projects/diffused_head/sys/modules/diffuse/diffuse_feature_iat/Makefile Sat Oct 8 04:16:19 2011 (r226130)
@@ -0,0 +1,8 @@
+# $FreeBSD$
+
+.PATH: ${.CURDIR}/../../../netinet/ipfw
+
+KMOD= diffuse_feature_iat
+SRCS= diffuse_feature_iat.c
+
+.include <bsd.kmod.mk>
Added: projects/diffused_head/sys/netinet/ipfw/diffuse_feature_iat.c
==============================================================================
--- /dev/null 00:00:00 1970 (empty, because file is newly added)
+++ projects/diffused_head/sys/netinet/ipfw/diffuse_feature_iat.c Sat Oct 8 04:16:19 2011 (r226130)
@@ -0,0 +1,468 @@
+/*-
+ * Copyright (c) 2010-2011
+ * Swinburne University of Technology, Melbourne, Australia.
+ * All rights reserved.
+ *
+ * This software was developed at the Centre for Advanced Internet
+ * Architectures, Swinburne University of Technology, by Sebastian Zander, made
+ * possible in part by a gift from The Cisco University Research Program Fund, a
+ * corporate advised fund of Silicon Valley Community Foundation.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions
+ * are met:
+ * 1. Redistributions of source code must retain the above copyright
+ * notice, this list of conditions and the following disclaimer.
+ * 2. Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the distribution.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND
+ * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
+ * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
+ * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE
+ * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
+ * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
+ * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
+ * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
+ * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
+ * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
+ * SUCH DAMAGE.
+ */
+
+/*
+ * DIFFUSE packet inter-arrival time feature.
+ */
+
+#include <sys/cdefs.h>
+__FBSDID("$FreeBSD$");
+
+#ifdef _KERNEL
+#include <sys/param.h>
+#include <sys/kernel.h>
+#include <sys/malloc.h>
+#include <sys/mbuf.h>
+#include <sys/module.h>
+#endif /* _KERNEL */
+#include <sys/socket.h>
+
+#include <net/if.h>
+#include <net/bpf.h>
+
+#include <netinet/in.h>
+#include <netinet/ip_fw.h>
+#include <netinet/ip_diffuse.h>
+#include <netinet/ip_var.h>
+#include <netinet/ip.h>
+#include <netinet/ip6.h>
+#include <netinet/udp.h>
+#include <netinet/tcp.h>
+
+#include <netinet/ipfw/diffuse_common.h>
+#include <netinet/ipfw/diffuse_feature.h>
+#include <netinet/ipfw/diffuse_feature_iat_common.h>
+#include <netinet/ipfw/diffuse_feature_iat.h>
+#ifdef _KERNEL
+#include <netinet/ipfw/diffuse_private.h>
+#include <netinet/ipfw/diffuse_feature_module.h>
+#endif /* _KERNEL */
+
+#ifndef _KERNEL
+#include <stdlib.h>
+#include <string.h>
+#include <errno.h>
+#define KPI_USER_COMPAT
+#include <netinet/ipfw/diffuse_user_compat.h> /* Must come after stdlib.h */
+#endif
+
+/*
+ * Feature inter-arrival time computes minimum, mean, maximum and std deviation
+ * of inter-arrival time (time between two consecutive packets).
+ */
+
+/* If we are linked from userspace, only put the declaration here. */
+#ifdef _KERNEL
+DI_IAT_STAT_NAMES;
+#else
+DI_IAT_STAT_NAMES_DECL;
+#endif
+
+/* State for jump windows. */
+struct di_iat_jump_win_state {
+ uint32_t min;
+ uint32_t max;
+ uint64_t sum;
+ uint64_t sqsum;
+ int jump;
+ int first;
+};
+
+/* Per flow data (ring buffer). */
+struct di_iat_fdata {
+ int full;
+ int changed;
+ int index;
+ struct timeval last_abs_time;
+ /*
+ * We can only store intervals <= 4294 seconds and stats are signed so
+ * can only be <= 2147 seconds, but default flow timeouts are much
+ * smaller.
+ */
+ uint32_t *iats;
+ struct di_iat_jump_win_state *jstate;
+};
+
+static int iat_reset_stats(struct di_cdata *cdata, struct di_fdata *fdata);
+
+static int
+iat_init_instance(struct di_cdata *cdata, struct di_oid *params)
+{
+ struct di_feature_iat_config *conf, *p;
+
+ cdata->conf = malloc(sizeof(struct di_feature_iat_config), M_DIFFUSE,
+ M_NOWAIT | M_ZERO);
+ if (cdata->conf == NULL)
+ return (ENOMEM);
+
+ conf = (struct di_feature_iat_config *)cdata->conf;
+
+ /* Set default configuration. */
+ conf->iat_window = DI_DEFAULT_IAT_WINDOW;
+ conf->iat_partial_window = 0;
+ conf->iat_ts_acc = DI_IAT_TS_ACC_NORMAL;
+ conf->iat_jump_window = 0;
+ conf->iat_prec = 1;
+
+ /* Set configuration. */
+ if (params != NULL) {
+ p = (struct di_feature_iat_config *)params;
+
+ if (p->iat_window != -1)
+ conf->iat_window = p->iat_window;
+
+ if (p->iat_partial_window != -1)
+ conf->iat_partial_window = p->iat_partial_window;
+
+ if (p->iat_ts_acc != -1)
+ conf->iat_ts_acc = p->iat_ts_acc;
+
+ if (p->iat_jump_window != -1)
+ conf->iat_jump_window = p->iat_jump_window;
+
+ if (p->iat_prec != -1)
+ conf->iat_prec = p->iat_prec;
+ }
+
+ return (0);
+}
+
+static int
+iat_destroy_instance(struct di_cdata *cdata)
+{
+
+ free(cdata->conf, M_DIFFUSE);
+
+ return (0);
+}
+
+static int
+iat_get_conf(struct di_cdata *cdata, struct di_oid *cbuf, int size_only)
+{
+
+ if (!size_only)
+ memcpy(cbuf, cdata->conf, sizeof(struct di_feature_iat_config));
+
+ return (sizeof(struct di_feature_iat_config));
+}
+
+static int
+iat_init_stats(struct di_cdata *cdata, struct di_fdata *fdata)
+{
+ struct di_feature_iat_config *conf;
+ struct di_iat_fdata *data;
+
+ conf = (struct di_feature_iat_config *)cdata->conf;
+
+ fdata->data = malloc(sizeof(struct di_iat_fdata), M_DIFFUSE,
+ M_NOWAIT | M_ZERO);
+ if (fdata->data == NULL)
+ return (ENOMEM);
+
+ data = (struct di_iat_fdata *)fdata->data;
+
+ if (!conf->iat_jump_window)
+ data->iats = malloc((conf->iat_window - 1) * sizeof(uint32_t),
+ M_DIFFUSE, M_NOWAIT | M_ZERO);
+ else
+ data->jstate = malloc(sizeof(struct di_iat_jump_win_state),
+ M_DIFFUSE, M_NOWAIT | M_ZERO);
+
+ fdata->stats = malloc(DI_IAT_NO_STATS * sizeof(int32_t), M_DIFFUSE,
+ M_NOWAIT | M_ZERO);
+
+ if (data->iats == NULL || data->jstate == NULL ||
+ fdata->stats == NULL) {
+ free(fdata->stats, M_DIFFUSE);
+ free(data->jstate, M_DIFFUSE);
+ free(data->iats, M_DIFFUSE);
+ free(fdata->data, M_DIFFUSE);
+
+ return (ENOMEM);
+ }
+
+ iat_reset_stats(cdata, fdata);
+
+ return (0);
+}
+
+static int
+iat_destroy_stats(struct di_cdata *cdata, struct di_fdata *fdata)
+{
+ struct di_feature_iat_config *conf;
+ struct di_iat_fdata *data;
+
+ conf = (struct di_feature_iat_config *)cdata->conf;
+ data = (struct di_iat_fdata *)fdata->data;
+
+ if (!conf->iat_jump_window)
+ free(data->iats, M_DIFFUSE);
+ else
+ free(data->jstate, M_DIFFUSE);
+
+ free(fdata->data, M_DIFFUSE);
+ free(fdata->stats, M_DIFFUSE);
+
+ return (0);
+}
+
+static void
+reset_jump_win_state(struct di_iat_jump_win_state *state)
+{
+
+ state->min = 0x7FFFFFFF;
+ state->max = 0;
+ state->sum = 0;
+ state->sqsum = 0;
+ state->jump = 0;
+}
+
+static int
+iat_update_stats(struct di_cdata *cdata, struct di_fdata *fdata,
+ struct mbuf *mbuf, int proto, void *ulp, int dir)
+{
+ struct di_feature_iat_config *conf;
+ struct di_iat_fdata *data;
+ struct timeval t, tv_diff;
+ uint32_t diff;
+
+ conf = (struct di_feature_iat_config *)cdata->conf;
+ data = (struct di_iat_fdata *)fdata->data;
+ t.tv_sec = t.tv_usec = 0;
+
+#if !defined(__linux__) && defined(_KERNEL)
+ /* Get from external source if possible (hardware), see bpf.c. */
+ if (mbuf != NULL) {
+ struct m_tag *tag = m_tag_locate(mbuf, MTAG_BPF,
+ MTAG_BPF_TIMESTAMP, NULL);
+ if (tag != NULL) {
+ struct bintime bt = *(struct bintime *)(tag + 1);
+ bintime2timeval(&bt, &t);
+ }
+ }
+#endif
+
+ if (t.tv_sec == 0 && t.tv_usec == 0) {
+ if (conf->iat_ts_acc == DI_IAT_TS_ACC_ACCURATE)
+ getmicrouptime(&t);
+ else
+ microuptime(&t);
+ }
+
+ if (data->last_abs_time.tv_sec > 0 || data->last_abs_time.tv_usec > 0) {
+ /* Get inter-arrival time. */
+ tv_diff = tv_sub0(&t, &data->last_abs_time);
+ diff = (tv_diff.tv_sec * 1000000 + tv_diff.tv_usec) /
+ conf->iat_prec; /* XXX: round() */
+
+ if (!conf->iat_jump_window) {
+ data->iats[data->index++] = diff;
+ } else {
+ if (diff < data->jstate->min)
+ data->jstate->min = diff;
+
+ if (diff > data->jstate->max)
+ data->jstate->max = diff;
+
+ data->jstate->sum += diff;
+ data->jstate->sqsum += (uint64_t)diff * diff;
+ data->index++;
+
+ if (data->index == (conf->iat_window - 1)) {
+ data->jstate->jump = 1;
+ if (data->jstate->first)
+ data->jstate->first = 0;
+ }
+ }
+
+ if (!data->full && data->index == (conf->iat_window - 1))
+ data->full = 1;
+
+ data->changed = 1;
+ if (data->index == conf->iat_window - 1)
+ data->index = 0;
+ }
+ data->last_abs_time = t;
+
+ return (0);
+}
+
+static int
+iat_reset_stats(struct di_cdata *cdata, struct di_fdata *fdata)
+{
+ struct di_feature_iat_config *conf;
+ struct di_iat_fdata *data;
+ int i;
+
+ conf = (struct di_feature_iat_config *)cdata->conf;
+ data = (struct di_iat_fdata *)fdata->data;
+
+ fdata->stats[0] = 0x7FFFFFFF;
+ for (i = 1; i < DI_IAT_NO_STATS; i++)
+ fdata->stats[i] = 0;
+
+ if (!conf->iat_jump_window) {
+ for (i = 0; i < (conf->iat_window - 1); i++)
+ data->iats[i] = 0;
+ } else {
+ reset_jump_win_state(data->jstate);
+ data->jstate->first = 1;
+ }
+ data->full = 0;
+ data->changed = 0;
+ data->index = 0;
+
+ return (0);
+}
+
+/*
+ * XXX: Potential overflow of square sum for jumping windows otherwise overflow
+ * only possible if flow timeouts would be set much higher than default.
+ */
+static int
+iat_get_stats(struct di_cdata *cdata, struct di_fdata *fdata, int32_t **stats)
+{
+#define DI_IAT_MIN fdata->stats[0]
+#define DI_IAT_MEAN fdata->stats[1]
+#define DI_IAT_MAX fdata->stats[2]
+#define DI_IAT_STDEV fdata->stats[3]
+ struct di_feature_iat_config *conf;
+ struct di_iat_fdata *data;
+ uint64_t sqsum, sum;
+ int i, wsize;
+
+ conf = (struct di_feature_iat_config *)cdata->conf;
+ data = (struct di_iat_fdata *)fdata->data;
+
+ if (!data->full && !(conf->iat_partial_window && data->index > 1))
+ return (0); /* Window is not full yet. */
+
+ /* Compute stats only if we need update. */
+ if ((!conf->iat_jump_window && data->changed) ||
+ (conf->iat_jump_window && (data->jstate->jump ||
+ (conf->iat_partial_window && data->jstate->first)))) {
+ wsize = conf->iat_window - 1;
+ if (!data->full)
+ wsize = data->index;
+
+ if (!conf->iat_jump_window) {
+ sum = 0;
+ sqsum = 0;
+
+ DI_IAT_MIN = 0x7FFFFFFF;
+ DI_IAT_MAX = 0;
+ for (i = 0; i < wsize; i++) {
+ if (data->iats[i] < DI_IAT_MIN)
+ DI_IAT_MIN = data->iats[i];
+
+ if (data->iats[i] > DI_IAT_MAX)
+ DI_IAT_MAX = data->iats[i];
+
+ sum += data->iats[i];
+ }
+
+ DI_IAT_MEAN = sum / wsize;
+ if (wsize > 1) {
+ /* Need a second loop or sqsum may overflow. */
+ for (i = 0; i < wsize; i++) {
+ sqsum +=
+ ((int64_t)data->iats[i] -
+ DI_IAT_MEAN) *
+ ((int64_t)data->iats[i] -
+ DI_IAT_MEAN);
+ }
+ DI_IAT_STDEV = fixp_sqrt(sqsum / wsize);
+ }
+ } else {
+ DI_IAT_MIN = data->jstate->min;
+ DI_IAT_MAX = data->jstate->max;
+ DI_IAT_MEAN = data->jstate->sum / wsize;
+ if (wsize > 1) {
+ DI_IAT_STDEV =
+ fixp_sqrt((data->jstate->sqsum -
+ (data->jstate->sum *
+ data->jstate->sum / wsize)) / (wsize - 1));
+ }
+
+ reset_jump_win_state(data->jstate);
+ }
+ data->changed = 0;
+ }
+ *stats = fdata->stats;
+
+ return (DI_IAT_NO_STATS);
+}
+
+static int
+iat_get_stat(struct di_cdata *cdata, struct di_fdata *fdata, int which,
+ int32_t *stat)
+{
+ int32_t *stats;
+
+ if (which < 0 || which > DI_IAT_NO_STATS)
+ return (-1);
+
+ if (!iat_get_stats(cdata, fdata, &stats))
+ return (0);
+
+ *stat = stats[which];
+
+ return (1);
+}
+
+static int
+iat_get_stat_names(char **names[])
+{
+
+ *names = di_iat_stat_names;
+
+ return (DI_IAT_NO_STATS);
+}
+
+static struct di_feature_alg di_iat_desc = {
+ _FI( .name = ) DI_IAT_NAME,
+ _FI( .type = ) DI_IAT_TYPE,
+ _FI( .ref_count = ) 0,
+
+ _FI( .init_instance = ) iat_init_instance,
+ _FI( .destroy_instance = ) iat_destroy_instance,
+ _FI( .init_stats = ) iat_init_stats,
+ _FI( .destroy_stats = ) iat_destroy_stats,
+ _FI( .update_stats = ) iat_update_stats,
+ _FI( .reset_stats = ) iat_reset_stats,
+ _FI( .get_stats = ) iat_get_stats,
+ _FI( .get_stat = ) iat_get_stat,
+ _FI( .get_stat_names = ) iat_get_stat_names,
+ _FI( .get_conf = ) iat_get_conf,
+};
+
+DECLARE_DIFFUSE_FEATURE_MODULE(iat, &di_iat_desc);
Added: projects/diffused_head/sys/netinet/ipfw/diffuse_feature_iat.h
==============================================================================
--- /dev/null 00:00:00 1970 (empty, because file is newly added)
+++ projects/diffused_head/sys/netinet/ipfw/diffuse_feature_iat.h Sat Oct 8 04:16:19 2011 (r226130)
@@ -0,0 +1,59 @@
+/*-
+ * Copyright (c) 2010-2011
+ * Swinburne University of Technology, Melbourne, Australia.
+ * All rights reserved.
+ *
+ * This software was developed at the Centre for Advanced Internet
+ * Architectures, Swinburne University of Technology, by Sebastian Zander, made
+ * possible in part by a gift from The Cisco University Research Program Fund, a
+ * corporate advised fund of Silicon Valley Community Foundation.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions
+ * are met:
+ * 1. Redistributions of source code must retain the above copyright
+ * notice, this list of conditions and the following disclaimer.
+ * 2. Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the distribution.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND
+ * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
+ * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
+ * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE
+ * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
+ * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
+ * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
+ * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
+ * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
+ * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
+ * SUCH DAMAGE.
+ *
+ * $FreeBSD$
+ */
+
+/*
+ * DIFFUSE packet inter-arrival time feature.
+ */
+
+#ifndef _NETINET_IPFW_DIFFUSE_FEATURE_IAT_H_
+#define _NETINET_IPFW_DIFFUSE_FEATURE_IAT_H_
+
+#define DI_DEFAULT_IAT_WINDOW 15
+
+/* Main properties, used in kernel and userspace. */
+#define DI_IAT_NAME "iat"
+#define DI_IAT_TYPE DI_FEATURE_ALG_UNIDIRECTIONAL
+#define DI_IAT_NO_STATS 4
+#define DI_IAT_STAT_NAMES_DECL char *di_iat_stat_names[DI_IAT_NO_STATS]
+#define DI_IAT_STAT_NAMES DI_IAT_STAT_NAMES_DECL = \
+{ \
+ "min", \
+ "mean", \
+ "max", \
+ "stdev" \
+};
+
+struct di_feature_module *iat_module(void);
+
+#endif /* _NETINET_IPFW_DIFFUSE_FEATURE_IAT_H_ */
Added: projects/diffused_head/sys/netinet/ipfw/diffuse_feature_iat_common.h
==============================================================================
--- /dev/null 00:00:00 1970 (empty, because file is newly added)
+++ projects/diffused_head/sys/netinet/ipfw/diffuse_feature_iat_common.h Sat Oct 8 04:16:19 2011 (r226130)
@@ -0,0 +1,56 @@
+/*-
+ * Copyright (c) 2010-2011
+ * Swinburne University of Technology, Melbourne, Australia.
+ * All rights reserved.
+ *
+ * This software was developed at the Centre for Advanced Internet
+ * Architectures, Swinburne University of Technology, by Sebastian Zander, made
+ * possible in part by a gift from The Cisco University Research Program Fund, a
+ * corporate advised fund of Silicon Valley Community Foundation.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions
+ * are met:
+ * 1. Redistributions of source code must retain the above copyright
+ * notice, this list of conditions and the following disclaimer.
+ * 2. Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the distribution.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND
+ * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
+ * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
+ * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE
+ * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
+ * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
+ * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
+ * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
+ * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
+ * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
+ * SUCH DAMAGE.
+ *
+ * $FreeBSD$
+ */
+
+#ifndef _NETINET_IPFW_DIFFUSE_FEATURE_IAT_COMMON_H_
+#define _NETINET_IPFW_DIFFUSE_FEATURE_IAT_COMMON_H_
+
+#define DI_IAT_TS_ACC_NORMAL 0
+#define DI_IAT_TS_ACC_ACCURATE 1
+
+struct di_feature_iat_config {
+ struct di_oid oid;
+
+ /* Sliding/jumping window as number of packets. */
+ int iat_window;
+ /* Compute stats for partial windows. */
+ int iat_partial_window;
+ /* Accuracy of timestamp. */
+ int iat_ts_acc;
+ /* If = 1 we have jumping windows. */
+ int iat_jump_window;
+ /* Precision in us. */
+ int iat_prec;
+};
+
+#endif /* _NETINET_IPFW_DIFFUSE_FEATURE_IAT_COMMON_H_ */
More information about the svn-src-projects
mailing list