apps.rss.metadata: add timestamp

src/apps/rss/metadata.lua

@@ -192,6 +192,8 @@ local magic_number = 0x5ABB
 pkt_meta_data_t = ffi.typeof([[
    struct {
       uint16_t magic;
+      /* Unix timestamp in nanoseconds */
+      uint64_t timestamp;
       /* Actual ethertype for single-tagged frames */
       uint16_t ethertype;
       /* vlan == 0 if untagged frame */
@@ -272,6 +274,7 @@ function add (pkt, rm_ext_headers, vlan_override)
 
    local md = md_ptr(pkt)
    md.magic = magic_number
+   md.timestamp = ffi.C.get_unix_time_ns()
    md.ref = 0
    md.ethertype = ethertype
    md.vlan = vlan_override or vlan

src/core/lib.c

@@ -6,7 +6,7 @@
 #include <sys/time.h>
 #include <unistd.h>
 
-/* Return the current wall-clock time in nanoseconds. */
+/* Return the monotonic time in nanoseconds. */
 uint64_t get_time_ns()
 {
     /* XXX Consider using RDTSC. */
@@ -15,6 +15,14 @@ uint64_t get_time_ns()
     return ts.tv_sec * 1000000000LL + ts.tv_nsec;
 }
 
+/* Return the current wall-clock time in nanoseconds. */
+uint64_t get_unix_time_ns()
+{
+    struct timespec ts;
+    clock_gettime(CLOCK_REALTIME, &ts);
+    return ts.tv_sec * 1000000000LL + ts.tv_nsec;
+}
+
 static double get_time(int clock)
 {
   struct timespec ts;

src/core/lib.h

@@ -3,6 +3,7 @@
 uint64_t get_time_ns();
 double get_monotonic_time();
 double get_unix_time();
+uint64_t get_unix_time_ns();
 void sleep_ns(int nanoseconds);
 void full_memory_barrier();
 void prefetch_for_read(const void *address);