From 63d51b566ea270b45b5b34b1feab37b8faa28232 Mon Sep 17 00:00:00 2001
From: Lennart Poettering <lennart@poettering.net>
Date: Sun, 9 May 2004 23:20:43 +0000
Subject: main fieryfilter work

git-svn-id: file:///home/lennart/svn/public/fieryfilter/fieryfilter@31 79e6afc9-17da-0310-ae3c-b873bff394f4
---
 daemon/packet.c | 101 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 101 insertions(+)
 create mode 100644 daemon/packet.c

(limited to 'daemon/packet.c')

diff --git a/daemon/packet.c b/daemon/packet.c
new file mode 100644
index 0000000..c8722f8
--- /dev/null
+++ b/daemon/packet.c
@@ -0,0 +1,101 @@
+#include <time.h>
+
+#include "packet.h"
+
+#define PACKET_TIMEOUT 30
+
+typedef struct packet_wrapper {
+    time_t timestamp;
+    ipq_packet_msg_t m;
+} packet_wrapper_t;
+
+static GSList *packets = NULL;
+static guint n_packets = 0;
+static guint total_packets = 0;
+
+guint get_queued_packets() {
+    return n_packets;
+}
+
+guint get_total_packets() {
+    return total_packets;
+}
+
+void packet_new(ipq_packet_msg_t *m) {
+    packet_wrapper_t *w = (packet_wrapper_t*) g_malloc(sizeof(packet_wrapper_t)+ m->data_len);
+    memcpy(&w->m, m, sizeof(ipq_packet_msg_t)+ m->data_len);
+    time(&w->timestamp);
+
+    packets = g_slist_prepend(packets, w);
+    n_packets++;
+    total_packets++;
+}
+
+static packet_wrapper_t* _find(unsigned long id) {
+    GSList *l;
+    
+    for (l = packets; l; l = l->next) {
+        packet_wrapper_t *w = (packet_wrapper_t*) l->data;
+        if (w->m.packet_id == id)
+            return w;
+    }
+
+    return NULL;
+}
+
+ipq_packet_msg_t* packet_find(unsigned long id) {
+    packet_wrapper_t* w;
+
+    if ((w = _find(id)))
+        return &w->m;
+    
+    return NULL;
+}
+
+void packet_release(unsigned long id) {
+    packet_wrapper_t *w;
+
+    w = _find(id);
+    g_assert(w);
+    
+    packets = g_slist_remove(packets, w);
+    g_free(w);
+    n_packets--;
+}
+
+
+void packet_foreach(gboolean age, gboolean (*func)(ipq_packet_msg_t*)) {
+    GSList *l, *p;
+
+    for (l = packets, p = NULL; l;) {
+        gboolean remove = FALSE;
+        packet_wrapper_t *w = (packet_wrapper_t*) l->data;
+        
+        if (!age || w->timestamp + PACKET_TIMEOUT < time(NULL))
+            if (!func(&w->m))
+                remove = TRUE;
+
+        
+        
+        if (remove) {
+            if (p)
+                p->next = l->next;
+            else
+                packets = l->next;
+            
+            g_slist_free_1(l);
+
+            l = p;
+        } else
+            l = l->next;
+    }
+}
+
+void packets_free() {
+    while (packets) {
+        packet_wrapper_t *w;
+        w = (packet_wrapper_t*) packets->data;
+        packets = g_slist_remove(packets, w);
+        g_free(w);
+    }
+}
-- 
cgit