summaryrefslogtreecommitdiff
path: root/src/openvpn/mbuf.c
diff options
context:
space:
mode:
authorAlberto Gonzalez Iniesta <agi@inittab.org>2012-11-05 16:28:10 +0100
committerAlberto Gonzalez Iniesta <agi@inittab.org>2012-11-05 16:28:10 +0100
commitd213c4e5576e2fd601679e0d7b2fb1262b807111 (patch)
tree5f0cc82bd0f11fb13b385417604d04c751245a92 /src/openvpn/mbuf.c
parent79c8d3ef7a938f86472e549ef64e1fb820dc80c4 (diff)
parent8dd0350e1607aa30f7a043c8d5ec7a7eeb874115 (diff)
Merge tag 'upstream/2.3_rc1'
Upstream version 2.3_rc1
Diffstat (limited to 'src/openvpn/mbuf.c')
-rw-r--r--src/openvpn/mbuf.c175
1 files changed, 175 insertions, 0 deletions
diff --git a/src/openvpn/mbuf.c b/src/openvpn/mbuf.c
new file mode 100644
index 0000000..82f2388
--- /dev/null
+++ b/src/openvpn/mbuf.c
@@ -0,0 +1,175 @@
+/*
+ * OpenVPN -- An application to securely tunnel IP networks
+ * over a single TCP/UDP port, with support for SSL/TLS-based
+ * session authentication and key exchange,
+ * packet encryption, packet authentication, and
+ * packet compression.
+ *
+ * Copyright (C) 2002-2010 OpenVPN Technologies, Inc. <sales@openvpn.net>
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License version 2
+ * as published by the Free Software Foundation.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program (see the file COPYING included with this
+ * distribution); if not, write to the Free Software Foundation, Inc.,
+ * 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
+ */
+
+#ifdef HAVE_CONFIG_H
+#include "config.h"
+#elif defined(_MSC_VER)
+#include "config-msvc.h"
+#endif
+
+#include "syshead.h"
+
+#if P2MP
+
+#include "buffer.h"
+#include "error.h"
+#include "misc.h"
+#include "mbuf.h"
+
+#include "memdbg.h"
+
+struct mbuf_set *
+mbuf_init (unsigned int size)
+{
+ struct mbuf_set *ret;
+ ALLOC_OBJ_CLEAR (ret, struct mbuf_set);
+ ret->capacity = adjust_power_of_2 (size);
+ ALLOC_ARRAY (ret->array, struct mbuf_item, ret->capacity);
+ return ret;
+}
+
+void
+mbuf_free (struct mbuf_set *ms)
+{
+ if (ms)
+ {
+ int i;
+ for (i = 0; i < (int) ms->len; ++i)
+ {
+ struct mbuf_item *item = &ms->array[MBUF_INDEX(ms->head, i, ms->capacity)];
+ mbuf_free_buf (item->buffer);
+ }
+ free (ms->array);
+ free (ms);
+ }
+}
+
+struct mbuf_buffer *
+mbuf_alloc_buf (const struct buffer *buf)
+{
+ struct mbuf_buffer *ret;
+ ALLOC_OBJ (ret, struct mbuf_buffer);
+ ret->buf = clone_buf (buf);
+ ret->refcount = 1;
+ ret->flags = 0;
+ return ret;
+}
+
+void
+mbuf_free_buf (struct mbuf_buffer *mb)
+{
+ if (mb)
+ {
+ if (--mb->refcount <= 0)
+ {
+ free_buf (&mb->buf);
+ free (mb);
+ }
+ }
+}
+
+void
+mbuf_add_item (struct mbuf_set *ms, const struct mbuf_item *item)
+{
+ ASSERT (ms);
+ if (ms->len == ms->capacity)
+ {
+ struct mbuf_item rm;
+ ASSERT (mbuf_extract_item (ms, &rm));
+ mbuf_free_buf (rm.buffer);
+ msg (D_MULTI_DROPPED, "MBUF: mbuf packet dropped");
+ }
+
+ ASSERT (ms->len < ms->capacity);
+
+ ms->array[MBUF_INDEX(ms->head, ms->len, ms->capacity)] = *item;
+ if (++ms->len > ms->max_queued)
+ ms->max_queued = ms->len;
+ ++item->buffer->refcount;
+}
+
+bool
+mbuf_extract_item (struct mbuf_set *ms, struct mbuf_item *item)
+{
+ bool ret = false;
+ if (ms)
+ {
+ while (ms->len)
+ {
+ *item = ms->array[ms->head];
+ ms->head = MBUF_INDEX(ms->head, 1, ms->capacity);
+ --ms->len;
+ if (item->instance) /* ignore dereferenced instances */
+ {
+ ret = true;
+ break;
+ }
+ }
+ }
+ return ret;
+}
+
+struct multi_instance *
+mbuf_peek_dowork (struct mbuf_set *ms)
+{
+ struct multi_instance *ret = NULL;
+ if (ms)
+ {
+ int i;
+ for (i = 0; i < (int) ms->len; ++i)
+ {
+ struct mbuf_item *item = &ms->array[MBUF_INDEX(ms->head, i, ms->capacity)];
+ if (item->instance)
+ {
+ ret = item->instance;
+ break;
+ }
+ }
+ }
+ return ret;
+}
+
+void
+mbuf_dereference_instance (struct mbuf_set *ms, struct multi_instance *mi)
+{
+ if (ms)
+ {
+ int i;
+ for (i = 0; i < (int) ms->len; ++i)
+ {
+ struct mbuf_item *item = &ms->array[MBUF_INDEX(ms->head, i, ms->capacity)];
+ if (item->instance == mi)
+ {
+ mbuf_free_buf (item->buffer);
+ item->buffer = NULL;
+ item->instance = NULL;
+ msg (D_MBUF, "MBUF: dereferenced queued packet");
+ }
+ }
+ }
+}
+
+#else
+static void dummy(void) {}
+#endif /* P2MP */