Changeset 894:43fb27a9037f in freeDiameter for libfdcore/sctp.c

Timestamp:

Nov 30, 2012, 6:51:49 AM (11 years ago)

Author:

Sebastien Decugis <sdecugis@freediameter.net>

Branch:

default

Phase:

public

Message:

Intrumented socket reception to store the timestamp along the received buffer

File:

• libfdcore/sctp.c (modified) (3 diffs)

libfdcore/sctp.c

@@ -1068 +1068 @@
         size_t                   mempagesz = sysconf(_SC_PAGESIZE); /* We alloc buffer by memory pages for efficiency */
         int                      timedout = 0;
+        struct timespec          recv_on;
         
         TRACE_ENTRY("%p %p %p %p %p", conn, strid, buf, len, event);
@@ -1086 +1087 @@
         /* We will loop while all data is not received. */
 incomplete:
-        if (datasize == bufsz) {
+        if (datasize == bufsz - sizeof(struct timespec)) {
                 /* The buffer is full, enlarge it */
                 bufsz += mempagesz;
-                CHECK_MALLOC( data = realloc(data, bufsz) );
+                CHECK_MALLOC( data = realloc(data, bufsz ) );
         }
         /* the new data will be received following the preceding */
         memset(&iov,  0, sizeof(iov));
         iov.iov_base = data + datasize ;
-        iov.iov_len  = bufsz - datasize;
+        iov.iov_len  = bufsz - sizeof(struct timespec) - datasize;
 
         /* Receive data from the socket */
@@ -1188 +1189 @@
         }
         
+        /* Piggy-tail the timestamp of reception */
+        CHECK_SYS_DO( clock_gettime(CLOCK_REALTIME, &recv_on), /* continue */ );
+        memcpy(data + datasize, &recv_on, sizeof(struct timespec));
+                
         /* From this point, we have received a message */
         *event = FDEVP_CNX_MSG_RECV;