Changeset 92a2bf6 for lib

Timestamp:

10/07/15 11:59:32 (6 years ago)

Author:

Shane Alcock <salcock@…>

Branches:

4.0.1-hotfixes, cachetimestamps, develop, dpdk-ndag, etsilive, libtrace4, master, ndag_format, pfring, rc-4.0.1, rc-4.0.2, rc-4.0.3, rc-4.0.4, ringdecrementfix, ringperformance, ringtimestampfixes

Children:

44f9892

Parents:

2e91590

Message:

Make sure we destroy the message queue for each thread.

Otherwise, we will run out of fds when processing large numbers
of traces.

File:

• lib/trace.c (modified) (1 diff)

lib/trace.c

@@ -720 +720 @@
                 // This has all of our packets
                 libtrace_ocache_destroy(&libtrace->packet_freelist);
+                for (i = 0; i < libtrace->perpkt_thread_count; ++i) {
+                        libtrace_message_queue_destroy(&libtrace->perpkt_threads[i].messages);
+                }
+                libtrace_message_queue_destroy(&libtrace->hasher_thread.messages);
+                libtrace_message_queue_destroy(&libtrace->keepalive_thread.messages);
+                libtrace_message_queue_destroy(&libtrace->reporter_thread.messages);
+
+
                 if (libtrace->combiner.destroy && libtrace->reporter_cbs)
                         libtrace->combiner.destroy(libtrace, &libtrace->combiner);