Mercurial > hg > freeDiameter
changeset 655:98a322c319db
Added T flag and some debug information for test_netemul
| author | Sebastien Decugis <sdecugis@nict.go.jp> |
|---|---|
| date | Tue, 11 Jan 2011 13:02:07 +0900 |
| parents | 0b547aa70ff5 |
| children | 5b05d85682f1 |
| files | extensions/test_netemul/test_netemul.c extensions/test_netemul/tne_process.c |
| diffstat | 2 files changed, 7 insertions(+), 0 deletions(-) [+] |
line wrap: on
line diff
--- a/extensions/test_netemul/test_netemul.c Tue Jan 11 12:29:29 2011 +0900 +++ b/extensions/test_netemul/test_netemul.c Tue Jan 11 13:02:07 2011 +0900 @@ -56,6 +56,7 @@ m = *msg; *msg = NULL; + TRACE_DEBUG(FULL, "[tne] Processing message %p", m); CHECK_FCT( tne_process_message(m) ); return 0;
--- a/extensions/test_netemul/tne_process.c Tue Jan 11 12:29:29 2011 +0900 +++ b/extensions/test_netemul/tne_process.c Tue Jan 11 13:02:07 2011 +0900 @@ -97,6 +97,7 @@ /* create the duplicate */ struct process_item * npi; struct msg * nm; + struct msg_hdr * nh; unsigned char * buf; size_t len; @@ -104,6 +105,9 @@ CHECK_FCT( fd_msg_bufferize(m, &buf, &len) ); 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 */ CHECK_MALLOC( npi = malloc(sizeof(struct process_item)) ); @@ -178,6 +182,7 @@ /* If there is a latency to add */ 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; pi->ts.tv_nsec += l * 1000000; @@ -222,6 +227,7 @@ m = pi->chain.o; free(pi); + TRACE_DEBUG(FULL, "[tne] Sending now %p", m); CHECK_FCT( fd_msg_send(&m, NULL, NULL) ); }