Changeset 655:98a322c319db in freeDiameter

Timestamp:

Jan 11, 2011 1:02:07 PM (2 years ago)

Author:

Sebastien Decugis <sdecugis@nict.go.jp>

Branch:

default

Message:

Added T flag and some debug information for test_netemul

Location:

extensions/test_netemul

Files:

• test_netemul.c (modified) (1 diff)
• tne_process.c (modified) (4 diffs)

extensions/test_netemul/test_netemul.c

@@ -57 +57 @@
         *msg = NULL;
         
+        TRACE_DEBUG(FULL, "[tne] Processing message %p", m);
         CHECK_FCT( tne_process_message(m) );
         

extensions/test_netemul/tne_process.c

@@ -98 +98 @@
                                 struct process_item * npi;
                                 struct msg * nm;
+                                struct msg_hdr * nh;
                                 unsigned char * buf;
                                 size_t len;
@@ -105 +106 @@
                                 CHECK_FCT( fd_msg_parse_buffer(&buf, len, &nm) );
                                 CHECK_FCT( fd_msg_source_set(nm, src, 0, NULL) );
+                                CHECK_FCT( fd_msg_hdr(nm, &nh) );
+                                nh->msg_flags |= CMD_FLAG_RETRANSMIT; /* Add the 'T' flag */
+                                TRACE_DEBUG(FULL, "[tne] Duplicated message %p as %p", m, nm);
                                 
                                 /* Duplicate the pi */
@@ -179 +183 @@
                 if (tne_conf.lat_avg) {
                         unsigned long l = get_latency();
+                        TRACE_DEBUG(FULL, "[tne] Set %lu ms latency for %p", l, pi->chain.o);
                         pi->ts.tv_sec += l / 1000;
                         l %= 1000;
@@ -223 +228 @@
                 free(pi);
                 
+                TRACE_DEBUG(FULL, "[tne] Sending now %p", m);
                 CHECK_FCT( fd_msg_send(&m, NULL, NULL) );
         }