Changeset eea65f4 in mainline for uspace/srv/net/tl/tcp/rqueue.c

Timestamp:

2011-11-21T21:16:23Z (13 years ago)

Author:

Jiri Svoboda <jiri@…>

Branches:

lfn, master, serial, ticket/834-toolchain-update, topic/msim-upgrade, topic/simplify-dev-export

Children:

6896409c

Parents:

004a5fe

Message:

PDU encoding and decoding.

File:

• uspace/srv/net/tl/tcp/rqueue.c (modified) (2 diffs)

uspace/srv/net/tl/tcp/rqueue.c

@@ -41 +41 @@
 #include <thread.h>
 #include "conn.h"
+#include "header.h"
 #include "rqueue.h"
+#include "segment.h"
 #include "state.h"
 #include "tcp_type.h"
+
+/** Transcode bounced segments.
+ *
+ * If defined, segments bounced via the internal debugging loopback will
+ * be encoded to a PDU and the decoded. Otherwise they will be bounced back
+ * directly without passing the encoder-decoder.
+ */
+#define BOUNCE_TRANSCODE
 
 static prodcons_t rqueue;
@@ -66 +76 @@
         log_msg(LVL_DEBUG, "tcp_rqueue_bounce_seg()");
 
+#ifdef BOUNCE_TRANSCODE
+        tcp_pdu_t *pdu;
+        tcp_segment_t *dseg;
+
+        if (tcp_pdu_encode(sp, seg, &pdu) != EOK) {
+                log_msg(LVL_WARN, "Not enough memory. Segment dropped.");
+                return;
+        }
+
+        if (tcp_pdu_decode(pdu, &rident, &dseg) != EOK) {
+                log_msg(LVL_WARN, "Not enough memory. Segment dropped.");
+                return;
+        }
+
+        tcp_pdu_delete(pdu);
+
+        /** Insert decoded segment into rqueue */
+        tcp_rqueue_insert_seg(&rident, dseg);
+        tcp_segment_delete(seg);
+#else
         /* Reverse the identification */
         tcp_sockpair_flipped(sp, &rident);
 
+        /* Insert segment back into rqueue */
         tcp_rqueue_insert_seg(&rident, seg);
+#endif
 }