Changeset 243bfd1

Timestamp:

03/04/19 13:57:16 (2 years ago)

Author:

Shane Alcock <salcock@…>

Branches:

develop

Parents:

450d198

git-author:

Shane Alcock <salcock@…> (03/04/19 13:42:54)

git-committer:

Shane Alcock <salcock@…> (03/04/19 13:57:16)

Message:

Improve parallel performance by skipping needless sanity checks

Normally, the sanity checking that we do here would be a good idea,
just in case something has corrupted one of our packets.

BUT, these checks happen every single time we attempt to read a
batch of packets (even for members of the packet array that are
not filled in by the read operation) and even though the checks
themselves are pretty simple, the CPU cycles used to perform them
really start to add up at high packet rates.

Instead, we're going to trust that a) we don't invalidate the
packets ourselves with some broken internal code and b) the user
doesn't go around touching raw packet structure contents
because we have an API for all necessary interactions. Sanity
checks can also be added at the point where the packet array element
is about to be updated by the read, if necessary. At least at that
point, we're sanity-checking something that we're about to use
instead of the current case where we waste time checking something
that we may or may not use.

File:

• lib/trace_parallel.c (modified) (3 diffs)

lib/trace_parallel.c

@@ -1412 +1412 @@
         if (libtrace->format->pread_packets) {
                 int ret;
+#if 0
                 for (i = 0; i < (int) nb_packets; ++i) {
                         if (!i[packets]) {
@@ -1424 +1425 @@
                                 return -1;
                         }
-                        packets[i]->which_trace_start = libtrace->startcount;
-                }
+                }
+#endif
                 do {
                         ret=libtrace->format->pread_packets(libtrace, t,
@@ -1451 +1452 @@
                                         trace_set_capture_length(packets[i],
                                                         libtrace->snaplen);
+                                packets[i]->which_trace_start = libtrace->startcount;
                         }
                 } while(ret == 0);