Changeset 92a2bf6 for lib


Ignore:
Timestamp:
10/07/15 11:59:32 (5 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:
1 edited

Legend:

Unmodified
Added
Removed
  • lib/trace.c

    rd8b05b7 r92a2bf6  
    720720                // This has all of our packets
    721721                libtrace_ocache_destroy(&libtrace->packet_freelist);
     722                for (i = 0; i < libtrace->perpkt_thread_count; ++i) {
     723                        libtrace_message_queue_destroy(&libtrace->perpkt_threads[i].messages);
     724                }
     725                libtrace_message_queue_destroy(&libtrace->hasher_thread.messages);
     726                libtrace_message_queue_destroy(&libtrace->keepalive_thread.messages);
     727                libtrace_message_queue_destroy(&libtrace->reporter_thread.messages);
     728
     729
    722730                if (libtrace->combiner.destroy && libtrace->reporter_cbs)
    723731                        libtrace->combiner.destroy(libtrace, &libtrace->combiner);
Note: See TracChangeset for help on using the changeset viewer.