From: Russ Combs <rucombs@cisco.com>
Date: Tue, 15 Jul 2014 21:08:44 +0000 (-0400)
Subject: moved stats / peg counts to module
X-Git-Tag: 3.0.0-233~1444^2~1
X-Git-Url: http://git.ipfire.org/cgi-bin/gitweb.cgi?a=commitdiff_plain;h=fe8e5fdf74a543511ec5be6ed3855f6989be69a6;p=thirdparty%2Fsnort3.git

moved stats / peg counts to module
---

diff --git a/ChangeLog b/ChangeLog
index 2d7b7ba34..b3667a6c1 100644
--- a/ChangeLog
+++ b/ChangeLog
@@ -1,3 +1,8 @@
+102
+-- moved stats (peg counts) to module
+-- removed sum() and stats() from InspectApi
+-- tweaked --help-module
+
 101
 -- tweaked startup output
 -- fixed pattern matcher
diff --git a/configure.ac b/configure.ac
index 6c48b28be..6cbb1bc19 100644
--- a/configure.ac
+++ b/configure.ac
@@ -25,7 +25,7 @@
 # initialization
 #--------------------------------------------------------------------------
 
-AC_INIT([snort], [2.10.101])
+AC_INIT([snort], [2.10.102])
 AC_PREREQ([2.68])
 
 AC_CONFIG_SRCDIR([src/main.h])
diff --git a/doc/style.txt b/doc/style.txt
index c1182e113..947599273 100644
--- a/doc/style.txt
+++ b/doc/style.txt
@@ -49,7 +49,7 @@ yet firm so feedback is welcome to get something we can live with.
   write, easier to read, and overall better code.
 
 * Use consistent spacing and linebreaks.  Always indent 4 spaces from the
-  breaking line.  Try to keep lines less than 80 chars; it greatly helps
+  breaking line.  Keep lines less than 100 chars; it greatly helps
   readability.
 
     No:
diff --git a/src/framework/counts.h b/src/framework/counts.h
index b8d64b107..0626f72b3 100644
--- a/src/framework/counts.h
+++ b/src/framework/counts.h
@@ -31,6 +31,8 @@ struct SimpleStats
     PegCount total_packets;
 };
 
+extern const char* simple_pegs[];
+
 #define array_size(a) (sizeof(a)/sizeof(a[0]))
 
 #endif
diff --git a/src/framework/inspector.h b/src/framework/inspector.h
index 1973d2451..a8043f78e 100644
--- a/src/framework/inspector.h
+++ b/src/framework/inspector.h
@@ -154,8 +154,6 @@ struct InspectApi
     InspectFunc pinit;     // plugin thread local allocation
     InspectFunc pterm;     // plugin thread local cleanup
     InspectSsnFunc ssn;    // purge caches
-    InspectFunc sum;       // accumulate stats
-    InspectFunc stats;     // output stats
     InspectFunc reset;     // clear stats
 };
 
diff --git a/src/framework/module.cc b/src/framework/module.cc
index f08422d76..d3e39dcac 100644
--- a/src/framework/module.cc
+++ b/src/framework/module.cc
@@ -20,6 +20,7 @@
 
 #include "module.h"
 #include "parameter.h"
+#include "utils/stats.h"
 
 static const Parameter null_params[] =
 {
@@ -33,6 +34,7 @@ void Module::init(const char* s)
     list = false;
     cmds = nullptr;
     rules = nullptr;
+    num_counts = -1;
 }
 
 Module::Module(const char* s)
@@ -47,3 +49,49 @@ Module::Module(const char* s, const Parameter* p, bool is_list)
     list = is_list;
 }
 
+void Module::sum_stats()
+{
+    if ( num_counts < 0 )
+        reset_stats();
+
+    PegCount* p = get_counts();
+
+    if ( !p )
+        return;
+
+    for ( int i = 0; i < num_counts; i++ )
+    {
+        counts[i] += p[i];
+        p[i] = 0;
+    }
+}
+
+void Module::show_stats()
+{
+    if ( num_counts > 0 )
+        ::show_stats(get_counts(), get_pegs(), num_counts, get_name());
+}
+
+void Module::reset_stats()
+{
+    num_counts = 0;
+    const char** pegs = get_pegs();
+
+    if ( !pegs )
+        return;
+
+    while ( pegs[num_counts] )
+        ++num_counts;
+
+    counts.resize(num_counts);
+
+    for ( int i = 0; i < num_counts; i++ )
+        counts[i] = 0;
+}
+
+const char* simple_pegs[] =
+{
+    "packets",
+    nullptr
+};
+
diff --git a/src/framework/module.h b/src/framework/module.h
index 796948937..5ada9b2fe 100644
--- a/src/framework/module.h
+++ b/src/framework/module.h
@@ -30,6 +30,7 @@
 #ifndef MODULE_H
 #define MODULE_H
 
+#include <vector>
 #include <lua.hpp>
 
 #include "framework/value.h"
@@ -103,11 +104,11 @@ public:
     virtual const RuleMap* get_rules() const
     { return nullptr; };
 
-    virtual const char* get_pegs() const
+    virtual const char** get_pegs() const
     { return nullptr; };
 
     // counts and profile are thread local
-    virtual const PegCount* get_counts() const
+    virtual PegCount* get_counts() const
     { return nullptr; };
 
     virtual ProfileStats* get_profile() const
@@ -118,6 +119,10 @@ public:
         unsigned /*index*/, const char*& /*name*/, const char*& /*parent*/) const
     { return nullptr; };
 
+    virtual void sum_stats();
+    virtual void show_stats();
+    virtual void reset_stats();
+
 protected:
     Module(const char* s);
     Module(const char* s, const Parameter* p, bool is_list = false);
@@ -131,6 +136,8 @@ private:
     const Parameter* params;
     const Command* cmds;
     const RuleMap* rules;
+    std::vector<PegCount> counts;
+    int num_counts;
 };
 
 #endif
diff --git a/src/main/snort.cc b/src/main/snort.cc
index dbd8afb31..608fc8fc8 100644
--- a/src/main/snort.cc
+++ b/src/main/snort.cc
@@ -1006,6 +1006,7 @@ void snort_thread_init(const char* intf)
 
 void snort_thread_term()
 {
+    ModuleManager::accumulate(snort_conf);
     InspectorManager::thread_term(snort_conf);
     IpsManager::clear_options();
     EventManager::close_outputs();
diff --git a/src/managers/inspector_manager.cc b/src/managers/inspector_manager.cc
index a7ae2d286..1477b8255 100644
--- a/src/managers/inspector_manager.cc
+++ b/src/managers/inspector_manager.cc
@@ -382,33 +382,6 @@ static PHClass* GetClass(const char* keyword, FrameworkConfig* fc)
     return NULL;
 }
 
-void InspectorManager::dump_stats (SnortConfig* sc)
-{
-    for ( auto* p : sc->framework_config->clist )
-        if ( p->api.stats )
-            p->api.stats();
-}
-
-void InspectorManager::accumulate (SnortConfig* sc)
-{
-    static mutex stats_mutex;
-    stats_mutex.lock();
-
-    for ( auto* p : sc->framework_config->clist )
-        if ( p->api.sum )
-            p->api.sum();
-
-    pc_sum();
-    stats_mutex.unlock();
-}
-
-void InspectorManager::reset_stats (SnortConfig* sc)
-{
-    for ( auto* p : sc->framework_config->clist )
-        if ( p->api.reset )
-            p->api.reset();
-}
-
 // this is per thread
 void InspectorManager::thread_init(SnortConfig* sc)
 {
@@ -441,8 +414,6 @@ void InspectorManager::thread_term(SnortConfig* sc)
     for ( auto* p : sc->framework_config->clist )
         if ( p->api.pterm )
             p->api.pterm();
-
-    accumulate(sc);
 }
 
 //-------------------------------------------------------------------------
diff --git a/src/managers/inspector_manager.h b/src/managers/inspector_manager.h
index c554ca944..a70d03091 100644
--- a/src/managers/inspector_manager.h
+++ b/src/managers/inspector_manager.h
@@ -46,10 +46,6 @@ public:
     static void new_config(SnortConfig*);
     static void delete_config(SnortConfig*);
 
-    static void dump_stats(SnortConfig*);
-    static void accumulate(SnortConfig*);
-    static void reset_stats(SnortConfig*);
-
     static void instantiate(const InspectApi*, Module*, SnortConfig*);
     static Inspector* get_inspector(const char* key);
     static void free_inspector(Inspector*);
diff --git a/src/managers/module_manager.cc b/src/managers/module_manager.cc
index 2bae2810c..32181f764 100644
--- a/src/managers/module_manager.cc
+++ b/src/managers/module_manager.cc
@@ -22,6 +22,7 @@
 
 #include <iostream>
 #include <list>
+#include <mutex>
 #include <string>
 #include <sstream>
 #include <lua.hpp>
@@ -492,6 +493,50 @@ void ModuleManager::dump_modules()
             d.dump(p->mod->get_name());
 }
 
+void ModuleManager::show_module(bool markup, const char* name)
+{
+    s_modules.sort(comp_gids);
+    s_markup = markup;
+
+    for ( auto p : s_modules )
+    {
+        const Module* m = p->mod;
+        assert(m);
+
+        if ( strcmp(m->get_name(), name) )
+            continue;
+
+        LogMessage("\nModule: %s\n", name);
+
+        if ( const Parameter* p = m->get_parameters() )
+        {
+            if ( p->type < Parameter::PT_MAX )
+            {
+                LogMessage("\nConfiguration:\n");
+                show_configs(markup, name);
+            }
+        }
+
+        if ( m->get_commands() )
+        {
+            LogMessage("\nCommands:\n");
+            show_commands(markup, name);
+        }
+
+        if ( m->get_rules() )
+        {
+            LogMessage("\nRules:\n");
+            show_rules(markup, name);
+        }
+
+        if ( m->get_pegs() )
+        {
+            LogMessage("\nPeg counts:\n");
+            show_pegs(markup, name);
+        }
+    }
+}
+
 void ModuleManager::show_configs(bool markup, const char* pfx)
 {
     s_modules.sort(comp_mods);
@@ -585,6 +630,37 @@ void ModuleManager::show_gids(bool markup, const char* pfx)
     }    
 }
 
+void ModuleManager::show_pegs(bool markup, const char* pfx)
+{
+    s_modules.sort(comp_gids);
+    s_markup = markup;
+    unsigned len = pfx ? strlen(pfx) : 0;
+
+    for ( auto p : s_modules )
+    {
+        const Module* m = p->mod;
+        assert(m);
+
+        if ( pfx && strncmp(m->get_name(), pfx, len) )
+            continue;
+
+        const char** pegs = m->get_pegs();
+
+        if ( !pegs )
+            continue;
+
+        while ( *pegs )
+        {
+            cout << item();
+            cout << emphasis_on();
+            cout << *pegs;
+            cout << emphasis_off();
+            cout << endl;
+            ++pegs;
+        }
+    }    
+}
+
 void ModuleManager::show_rules(bool markup, const char* pfx)
 {
     s_modules.sort(comp_gids);
@@ -652,3 +728,27 @@ void ModuleManager::load_rules(SnortConfig* sc)
     pop_parse_location();
 }
 
+void ModuleManager::dump_stats (SnortConfig*)
+{
+    for ( auto p : s_modules )
+        p->mod->show_stats();
+}
+
+void ModuleManager::accumulate (SnortConfig*)
+{
+    static mutex stats_mutex;
+    stats_mutex.lock();
+
+    for ( auto p : s_modules )
+        p->mod->sum_stats();
+
+    pc_sum();
+    stats_mutex.unlock();
+}
+
+void ModuleManager::reset_stats (SnortConfig*)
+{
+    for ( auto p : s_modules )
+        p->mod->reset_stats();
+}
+
diff --git a/src/managers/module_manager.h b/src/managers/module_manager.h
index 2661b06a4..7dce1a4ff 100644
--- a/src/managers/module_manager.h
+++ b/src/managers/module_manager.h
@@ -36,14 +36,20 @@ public:
     static Module* get_module(const char*);
 
     static void dump_modules();
+    static void show_module(bool markup, const char*);
     static void show_configs(bool markup, const char* = nullptr);
     static void show_commands(bool markup, const char* = nullptr);
     static void show_gids(bool markup, const char* = nullptr);
+    static void show_pegs(bool markup, const char* = nullptr);
     static void show_rules(bool markup, const char* = nullptr);
     static void load_rules(SnortConfig*);
 
     static void set_config(SnortConfig*);
     static unsigned get_errors();
+
+    static void dump_stats(SnortConfig*);
+    static void accumulate(SnortConfig*);
+    static void reset_stats(SnortConfig*);
 };
 
 #endif
diff --git a/src/network_inspectors/arp_spoof/arp_module.cc b/src/network_inspectors/arp_spoof/arp_module.cc
index 8a7fbc0a5..f7ece3f95 100644
--- a/src/network_inspectors/arp_spoof/arp_module.cc
+++ b/src/network_inspectors/arp_spoof/arp_module.cc
@@ -32,6 +32,8 @@ static const char* mod_name = "arp_spoof";
 #define ARPSPOOF_ARP_CACHE_OVERWRITE_ATTACK_STR \
     "(arp_spoof) Attempted ARP cache overwrite attack"
 
+THREAD_LOCAL SimpleStats asstats;
+
 //-------------------------------------------------------------------------
 // arp_spoof stuff
 //-------------------------------------------------------------------------
@@ -133,3 +135,10 @@ bool ArpSpoofModule::end(const char*, int idx, SnortConfig*)
     return true;
 }
 
+const char** ArpSpoofModule::get_pegs() const
+{ return simple_pegs; }
+
+PegCount* ArpSpoofModule::get_counts() const
+{ return (PegCount*)&asstats; }
+
+
diff --git a/src/network_inspectors/arp_spoof/arp_module.h b/src/network_inspectors/arp_spoof/arp_module.h
index 6f5545175..7390bcef7 100644
--- a/src/network_inspectors/arp_spoof/arp_module.h
+++ b/src/network_inspectors/arp_spoof/arp_module.h
@@ -36,6 +36,7 @@
 #define ARPSPOOF_ETHERFRAME_ARP_MISMATCH_DST  3
 #define ARPSPOOF_ARP_CACHE_OVERWRITE_ATTACK   4
 
+extern THREAD_LOCAL SimpleStats asstats;
 extern THREAD_LOCAL ProfileStats arpPerfStats;
 
 struct IPMacEntry
@@ -71,6 +72,9 @@ public:
         return temp;
     };
 
+    const char** get_pegs() const;
+    PegCount* get_counts() const;
+
     unsigned get_gid() const
     { return GID_ARP_SPOOF; };
 
diff --git a/src/network_inspectors/arp_spoof/arp_spoof.cc b/src/network_inspectors/arp_spoof/arp_spoof.cc
index 947bb619f..9dce8fa84 100644
--- a/src/network_inspectors/arp_spoof/arp_spoof.cc
+++ b/src/network_inspectors/arp_spoof/arp_spoof.cc
@@ -98,9 +98,6 @@ static const uint8_t bcast[6] = {0xff, 0xff, 0xff, 0xff, 0xff, 0xff};
 
 THREAD_LOCAL ProfileStats arpPerfStats;
 
-static THREAD_LOCAL SimpleStats asstats;
-static SimpleStats gasstats;
-
 //-------------------------------------------------------------------------
 // implementation stuff
 //-------------------------------------------------------------------------
@@ -299,15 +296,6 @@ static Inspector* as_ctor(Module* m)
 static void as_dtor(Inspector* p)
 { delete p; }
 
-static void as_sum()
-{ sum_stats(&gasstats, &asstats); }
-
-static void as_stats()
-{ show_stats(&gasstats, MOD_NAME); }
-
-static void as_reset()
-{ memset(&gasstats, 0, sizeof(gasstats)); }
-
 static const InspectApi as_api =
 {
     {
@@ -329,9 +317,7 @@ static const InspectApi as_api =
     nullptr, // pinit
     nullptr, // pterm
     nullptr, // ssn
-    as_sum,
-    as_stats,
-    as_reset
+    nullptr, // reset
 };
 
 #ifdef BUILDING_SO
diff --git a/src/network_inspectors/binder/bind_module.cc b/src/network_inspectors/binder/bind_module.cc
index decd24445..f581db39f 100644
--- a/src/network_inspectors/binder/bind_module.cc
+++ b/src/network_inspectors/binder/bind_module.cc
@@ -29,6 +29,8 @@ using namespace std;
 
 #include "binder.h"
 
+THREAD_LOCAL SimpleStats bstats;
+
 //-------------------------------------------------------------------------
 // binder module
 //-------------------------------------------------------------------------
@@ -178,3 +180,9 @@ vector<Binding*> BinderModule::get_data()
     return bindings;  // move semantics
 }
 
+const char** BinderModule::get_pegs() const
+{ return simple_pegs; }
+
+PegCount* BinderModule::get_counts() const
+{ return (PegCount*)&bstats; }
+
diff --git a/src/network_inspectors/binder/bind_module.h b/src/network_inspectors/binder/bind_module.h
index bed393af9..5425fff4e 100644
--- a/src/network_inspectors/binder/bind_module.h
+++ b/src/network_inspectors/binder/bind_module.h
@@ -27,6 +27,7 @@
 #include "framework/module.h"
 #include "main/thread.h"
 
+extern THREAD_LOCAL SimpleStats bstats;
 extern THREAD_LOCAL ProfileStats bindPerfStats;
 struct Binding;
 
@@ -40,6 +41,8 @@ public:
     bool begin(const char*, int, SnortConfig*);
     bool end(const char*, int, SnortConfig*);
 
+    const char** get_pegs() const;
+    PegCount* get_counts() const;
     ProfileStats* get_profile() const;
 
     std::vector<Binding*> get_data();
diff --git a/src/network_inspectors/binder/binder.cc b/src/network_inspectors/binder/binder.cc
index 6d9e3a782..358ad8a83 100644
--- a/src/network_inspectors/binder/binder.cc
+++ b/src/network_inspectors/binder/binder.cc
@@ -37,8 +37,6 @@ using namespace std;
 static const char* mod_name = "binder";
 
 THREAD_LOCAL ProfileStats bindPerfStats;
-static THREAD_LOCAL SimpleStats tstats;
-static SimpleStats gstats;
 
 //-------------------------------------------------------------------------
 // helpers
@@ -118,7 +116,7 @@ void Binder::eval(Packet* p)
 {
     Flow* flow = p->flow;
     flow->flow_state = check_rules(flow, p);
-    ++tstats.total_packets;
+    ++bstats.total_packets;
 }
 
 // FIXIT implement inspector lookup from policy / bindings
@@ -257,21 +255,6 @@ static void bind_dtor(Inspector* p)
     delete p;
 }
 
-static void bind_sum()
-{
-    sum_stats(&gstats, &tstats);
-}
-
-static void bind_stats()
-{
-    show_stats(&gstats, mod_name);
-}
-
-static void bind_reset()
-{
-    memset(&gstats, 0, sizeof(gstats));
-}
-
 static const InspectApi bind_api =
 {
     {
@@ -293,9 +276,7 @@ static const InspectApi bind_api =
     nullptr, // pinit
     nullptr, // pterm
     nullptr, // ssn
-    bind_sum,
-    bind_stats,
-    bind_reset
+    nullptr  // reset
 };
 
 const BaseApi* nin_binder = &bind_api.base;
diff --git a/src/network_inspectors/normalize/norm.cc b/src/network_inspectors/normalize/norm.cc
index 83970c3a8..52fd8713f 100644
--- a/src/network_inspectors/normalize/norm.cc
+++ b/src/network_inspectors/normalize/norm.cc
@@ -32,6 +32,7 @@
 #include "packet_io/sfdaq.h"
 #include "protocols/ipv4.h"
 #include "protocols/tcp.h"
+#include "stream/stream.h"
 
 typedef enum {
     PC_IP4_TRIM,
@@ -57,25 +58,25 @@ typedef enum {
 } PegCounts;
 
 static const char* pegName[PC_MAX] = {
-    "ip4::trim",
-    "ip4::tos",
-    "ip4::df",
-    "ip4::rf",
-    "ip4::ttl",
-    "ip4::opts",
-    "icmp4::echo",
-    "ip6::ttl",
-    "ip6::opts",
-    "icmp6::echo",
-    "tcp::syn_opt",
-    "tcp::ts_ecr",
-    "tcp::opt",
-    "tcp::pad",
-    "tcp::rsv",
-    "tcp::ecn_pkt",
-    "tcp::ns",
-    "tcp::urg",
-    "tcp::urp"
+    "ip4.trim",
+    "ip4.tos",
+    "ip4.df",
+    "ip4.rf",
+    "ip4.ttl",
+    "ip4.opts",
+    "icmp4.echo",
+    "ip6.ttl",
+    "ip6.opts",
+    "icmp6.echo",
+    "tcp.syn_opt",
+    "tcp.ts_ecr",
+    "tcp.opt",
+    "tcp.pad",
+    "tcp.rsv",
+    "tcp.ecn_pkt",
+    "tcp.ns",
+    "tcp.urg",
+    "tcp.urp"
 };
 
 static THREAD_LOCAL PegCount normStats[PC_MAX];
@@ -516,16 +517,19 @@ static int Norm_TCP (
 void Norm_SumStats (void)
 {
     sum_stats((PegCount*)&gnormStats, (PegCount*)&normStats, array_size(pegName));
+    Stream_SumNormalizationStats();
 }
 
 void Norm_PrintStats (const char* name)
 {
     show_stats((PegCount*)&gnormStats, pegName, array_size(pegName), name);
+    Stream_PrintNormalizationStats();
 }
 
 void Norm_ResetStats (void)
 {
     memset(gnormStats, 0, sizeof(gnormStats));
+    Stream_ResetNormalizationStats();
 }
 
 //-----------------------------------------------------------------------
diff --git a/src/network_inspectors/normalize/norm.h b/src/network_inspectors/normalize/norm.h
index 663a174b4..c17ebb07d 100644
--- a/src/network_inspectors/normalize/norm.h
+++ b/src/network_inspectors/normalize/norm.h
@@ -1,6 +1,6 @@
 /****************************************************************************
  *
-** Copyright (C) 2014 Cisco and/or its affiliates. All rights reserved.
+ * Copyright (C) 2014 Cisco and/or its affiliates. All rights reserved.
  * Copyright (C) 2005-2013 Sourcefire, Inc.
  *
  * This program is free software; you can redistribute it and/or modify
diff --git a/src/network_inspectors/normalize/norm_module.cc b/src/network_inspectors/normalize/norm_module.cc
index 26f4a3fa9..f0ff409fc 100644
--- a/src/network_inspectors/normalize/norm_module.cc
+++ b/src/network_inspectors/normalize/norm_module.cc
@@ -277,3 +277,12 @@ bool NormalizeModule::end(const char*, int, SnortConfig*)
     return true;
 }
 
+void NormalizeModule::sum_stats()
+{ Norm_SumStats(); }
+
+void NormalizeModule::show_stats()
+{ Norm_PrintStats(get_name()); }
+
+void NormalizeModule::reset_stats()
+{ Norm_ResetStats(); }
+
diff --git a/src/network_inspectors/normalize/norm_module.h b/src/network_inspectors/normalize/norm_module.h
index 4927504b6..2d3d766eb 100644
--- a/src/network_inspectors/normalize/norm_module.h
+++ b/src/network_inspectors/normalize/norm_module.h
@@ -45,6 +45,10 @@ public:
     const NormalizerConfig* get_config()
     { return &config; };
 
+    void sum_stats();
+    void show_stats();
+    void reset_stats();
+
 private:
     bool set_ip4(const char*, Value&, SnortConfig*);
     bool set_tcp(const char*, Value&, SnortConfig*);
diff --git a/src/network_inspectors/normalize/normalize.cc b/src/network_inspectors/normalize/normalize.cc
index c19271fb1..2f7cba4ed 100644
--- a/src/network_inspectors/normalize/normalize.cc
+++ b/src/network_inspectors/normalize/normalize.cc
@@ -28,13 +28,14 @@
 #include "profiler.h"
 #include "snort_types.h"
 #include "snort.h"
-#include "stream/stream.h"
 #include "framework/inspector.h"
 
-THREAD_LOCAL ProfileStats norm_perf_stats;
-
 #define PROTO_BITS (PROTO_BIT__IP|PROTO_BIT__ICMP|PROTO_BIT__TCP)
 
+static const char* name = "normalize";
+
+THREAD_LOCAL ProfileStats norm_perf_stats;
+
 //-------------------------------------------------------------------------
 // printing stuff
 //-------------------------------------------------------------------------
@@ -231,26 +232,6 @@ static Module* mod_ctor()
 static void mod_dtor(Module* m)
 { delete m; }
 
-static const char* name = "normalize";
-
-static void no_sum()
-{
-    Norm_SumStats();
-    Stream_SumNormalizationStats();
-}
-
-static void no_stats()
-{
-    Norm_PrintStats(name);
-    Stream_PrintNormalizationStats();
-}
-
-static void no_reset()
-{
-    Norm_ResetStats();
-    Stream_ResetNormalizationStats();
-}
-
 static Inspector* no_ctor(Module* m)
 {
     return new Normalizer((NormalizeModule*)m);
@@ -282,9 +263,7 @@ static const InspectApi no_api =
     nullptr, // pinit
     nullptr, // pterm
     nullptr, // ssn
-    no_sum,
-    no_stats,
-    no_reset
+    nullptr  // reset
 };
 
 const BaseApi* nin_normalize = &no_api.base;
diff --git a/src/network_inspectors/perf_monitor/perf_module.cc b/src/network_inspectors/perf_monitor/perf_module.cc
index 99af51201..8c74601d3 100644
--- a/src/network_inspectors/perf_monitor/perf_module.cc
+++ b/src/network_inspectors/perf_monitor/perf_module.cc
@@ -174,3 +174,9 @@ void PerfMonModule::get_config(SFPERF& cfg)
     memset(&config, 0, sizeof(config));
 }
 
+const char** PerfMonModule::get_pegs() const
+{ return simple_pegs; }
+
+PegCount* PerfMonModule::get_counts() const
+{ return (PegCount*)&pmstats; }
+
diff --git a/src/network_inspectors/perf_monitor/perf_module.h b/src/network_inspectors/perf_monitor/perf_module.h
index b61a9a1b9..4fd2e9644 100644
--- a/src/network_inspectors/perf_monitor/perf_module.h
+++ b/src/network_inspectors/perf_monitor/perf_module.h
@@ -25,6 +25,7 @@
 #include "perf.h"
 #include "framework/module.h"
 
+extern THREAD_LOCAL SimpleStats pmstats;
 extern THREAD_LOCAL ProfileStats perfmonStats;
 
 class PerfMonModule : public Module
@@ -35,6 +36,8 @@ public:
     bool set(const char*, Value&, SnortConfig*);
     bool begin(const char*, int, SnortConfig*);
 
+    const char** get_pegs() const;
+    PegCount* get_counts() const;
     ProfileStats* get_profile() const;
 
     void get_config(SFPERF&);
diff --git a/src/network_inspectors/perf_monitor/perf_monitor.cc b/src/network_inspectors/perf_monitor/perf_monitor.cc
index f5a2372be..26b0bd95b 100644
--- a/src/network_inspectors/perf_monitor/perf_monitor.cc
+++ b/src/network_inspectors/perf_monitor/perf_monitor.cc
@@ -57,11 +57,9 @@ THREAD_LOCAL SFPERF *perfmon_config = NULL;
 
 static const char* mod_name = "perf_monitor";
 
+THREAD_LOCAL SimpleStats pmstats;
 THREAD_LOCAL ProfileStats perfmonStats;
 
-static THREAD_LOCAL SimpleStats pmstats;
-static SimpleStats gpmstats;
-
 /* This function changes the perfmon log files permission if exists.
    It is done in the  PerfMonitorInit() before Snort changed its user & group.
  */
@@ -356,21 +354,6 @@ static Inspector* pm_ctor(Module* m)
     return new PerfMonitor((PerfMonModule*)m);
 }
 
-static void pm_sum()
-{
-    sum_stats(&gpmstats, &pmstats);
-}
-
-static void pm_stats()
-{
-    show_stats(&gpmstats, mod_name);
-}
-
-static void pm_reset()
-{
-    memset(&gpmstats, 0, sizeof(gpmstats));
-}
-
 static void pm_dtor(Inspector* p)
 {
     delete p;
@@ -397,9 +380,7 @@ static const InspectApi pm_api =
     nullptr, // pinit
     nullptr, // pterm
     nullptr, // ssn
-    pm_sum,
-    pm_stats,
-    pm_reset
+    nullptr  // reset
 };
 
 const BaseApi* nin_perf_monitor = &pm_api.base;
diff --git a/src/network_inspectors/port_scan/port_scan.cc b/src/network_inspectors/port_scan/port_scan.cc
index 4709f10d8..438cac2e2 100644
--- a/src/network_inspectors/port_scan/port_scan.cc
+++ b/src/network_inspectors/port_scan/port_scan.cc
@@ -82,11 +82,9 @@
 static THREAD_LOCAL Packet* g_tmp_pkt = NULL;
 static THREAD_LOCAL FILE* g_logfile = NULL;
 
+THREAD_LOCAL SimpleStats spstats;
 THREAD_LOCAL ProfileStats psPerfStats;
 
-static THREAD_LOCAL SimpleStats spstats;
-static SimpleStats gspstats;
-
 /*
 **  NAME
 **    MakeProtoInfo::
@@ -985,20 +983,9 @@ static void sp_dtor(Inspector* p)
     delete p;
 }
 
-static void sp_sum()
-{
-    sum_stats(&gspstats, &spstats);
-}
-
-static void sp_stats()
-{
-    show_stats(&gspstats, PS_MODULE);
-}
-
 static void sp_reset()
 {
     ps_reset();
-    memset(&gspstats, 0, sizeof(gspstats));
 }
 
 static const InspectApi sp_api =
@@ -1022,8 +1009,6 @@ static const InspectApi sp_api =
     nullptr, // pinit
     nullptr, // pterm
     nullptr, // ssn
-    sp_sum,
-    sp_stats,
     sp_reset
 };
 
diff --git a/src/network_inspectors/port_scan/ps_module.cc b/src/network_inspectors/port_scan/ps_module.cc
index 9598139a4..951e9aaed 100644
--- a/src/network_inspectors/port_scan/ps_module.cc
+++ b/src/network_inspectors/port_scan/ps_module.cc
@@ -245,3 +245,9 @@ PsCommon* PortScanGlobalModule::get_data()
     return tmp;
 }
 
+const char** PortScanGlobalModule::get_pegs() const
+{ return simple_pegs; }
+
+PegCount* PortScanGlobalModule::get_counts() const
+{ return (PegCount*)&spstats; }
+
diff --git a/src/network_inspectors/port_scan/ps_module.h b/src/network_inspectors/port_scan/ps_module.h
index 5397bb119..91cc00c7b 100644
--- a/src/network_inspectors/port_scan/ps_module.h
+++ b/src/network_inspectors/port_scan/ps_module.h
@@ -31,6 +31,7 @@
 #define PS_MODULE "port_scan"
 #define PS_GLOBAL "port_scan_global"
 
+extern THREAD_LOCAL SimpleStats spstats;
 extern THREAD_LOCAL ProfileStats psPerfStats;
 
 //-------------------------------------------------------------------------
@@ -44,6 +45,8 @@ public:
     bool set(const char*, Value&, SnortConfig*);
     bool begin(const char*, int, SnortConfig*);
 
+    const char** get_pegs() const;
+    PegCount* get_counts() const;
     ProfileStats* get_profile() const;
     PsCommon* get_data();
 
diff --git a/src/parser/cmd_line.cc b/src/parser/cmd_line.cc
index ea6de8a2e..460c17ff1 100644
--- a/src/parser/cmd_line.cc
+++ b/src/parser/cmd_line.cc
@@ -280,9 +280,7 @@ static void show_help(SnortConfig* sc, const char* val, HelpType ht)
         ModuleManager::show_rules(s_markup, val);
         break;
     case HT_MOD:
-        ModuleManager::show_configs(s_markup, val);
-        ModuleManager::show_commands(s_markup, val);
-        ModuleManager::show_rules(s_markup, val);
+        ModuleManager::show_module(s_markup, val);
         break;
     case HT_BUF:
         InspectorManager::dump_buffers();
@@ -797,7 +795,7 @@ static ConfigFunc basic_opts[] =
       "<module prefix> output matching generators" },
 
     { "help-module", config_help_module,
-      "output config, commands, and builtin rules for given module" },
+      "output description of given module" },
 
     { "help-options", config_help_options,
       "<option prefix> (same as --help)" },
diff --git a/src/service_inspectors/back_orifice/back_orifice.cc b/src/service_inspectors/back_orifice/back_orifice.cc
index ec8509faa..8a2828083 100644
--- a/src/service_inspectors/back_orifice/back_orifice.cc
+++ b/src/service_inspectors/back_orifice/back_orifice.cc
@@ -153,9 +153,7 @@ static uint16_t lookup1[65536][3];
 static uint16_t lookup2[65536];
 
 static THREAD_LOCAL ProfileStats boPerfStats;
-
 static THREAD_LOCAL SimpleStats bostats;
-static SimpleStats gbostats;
 
 //-------------------------------------------------------------------------
 // bo module
@@ -199,9 +197,17 @@ public:
     unsigned get_gid() const
     { return GID_BO; };
 
+    const char** get_pegs() const;
+    PegCount* get_counts() const;
     ProfileStats* get_profile() const;
 };
 
+const char** BoModule::get_pegs() const
+{ return simple_pegs; }
+
+PegCount* BoModule::get_counts() const
+{ return (PegCount*)&bostats; }
+
 ProfileStats* BoModule::get_profile() const
 { return &boPerfStats; }
 
@@ -585,21 +591,6 @@ static void bo_dtor(Inspector* p)
     delete p;
 }
 
-static void bo_sum()
-{
-    sum_stats(&gbostats, &bostats);
-}
-
-static void bo_stats()
-{
-    show_stats(&gbostats, mod_name);
-}
-
-static void bo_reset()
-{
-    memset(&gbostats, 0, sizeof(gbostats));
-}
-
 static const InspectApi bo_api =
 {
     {
@@ -621,9 +612,7 @@ static const InspectApi bo_api =
     nullptr, // pinit
     nullptr, // pterm
     nullptr, // ssn
-    bo_sum,
-    bo_stats,
-    bo_reset
+    nullptr  // reset
 };
 
 #ifdef BUILDING_SO
diff --git a/src/service_inspectors/ftp_telnet/ftp.cc b/src/service_inspectors/ftp_telnet/ftp.cc
index 0fe33b160..555ee535c 100644
--- a/src/service_inspectors/ftp_telnet/ftp.cc
+++ b/src/service_inspectors/ftp_telnet/ftp.cc
@@ -58,9 +58,7 @@ static const char* client_key = "ftp_client";
 static const char* server_key = "ftp_server";
 
 THREAD_LOCAL ProfileStats ftpPerfStats;
-
-static THREAD_LOCAL SimpleStats ftstats;
-static SimpleStats gftstats;
+THREAD_LOCAL SimpleStats ftstats;
 
 static FTP_CLIENT_PROTO_CONF* bind_client = nullptr;
 static FTP_SERVER_PROTO_CONF* bind_server = nullptr;
@@ -502,21 +500,6 @@ static void fs_dtor(Inspector* p)
     delete p;
 }
 
-static void fs_sum()
-{
-    sum_stats(&gftstats, &ftstats);
-}
-
-static void fs_stats()
-{
-    show_stats(&gftstats, server_key);
-}
-
-static void fs_reset()
-{
-    memset(&gftstats, 0, sizeof(gftstats));
-}
-
 static const InspectApi fs_api =
 {
     {
@@ -539,9 +522,7 @@ static const InspectApi fs_api =
     nullptr, // pinit
     nullptr, // pterm
     nullptr, // ssn
-    fs_sum,
-    fs_stats,
-    fs_reset
+    nullptr  // reset
 };
 
 #ifdef BUILDING_SO
diff --git a/src/service_inspectors/ftp_telnet/ftp_data.cc b/src/service_inspectors/ftp_telnet/ftp_data.cc
index d7e6c3d7e..7cbc3a582 100644
--- a/src/service_inspectors/ftp_telnet/ftp_data.cc
+++ b/src/service_inspectors/ftp_telnet/ftp_data.cc
@@ -55,9 +55,7 @@
 static const char* data_key = "ftp_data";
 
 static THREAD_LOCAL ProfileStats ftpdataPerfStats;
-
 static THREAD_LOCAL SimpleStats fdstats;
-static SimpleStats gfdstats;
 
 //-------------------------------------------------------------------------
 // implementation stuff
@@ -222,12 +220,20 @@ class FtpDataModule : public Module
 public:
     FtpDataModule() : Module(data_key, fd_params) { };
 
+    const char** get_pegs() const;
+    PegCount* get_counts() const;
     ProfileStats* get_profile() const;
 
     bool set(const char*, Value&, SnortConfig*)
     { return false; };
 };
 
+const char** FtpDataModule::get_pegs() const
+{ return simple_pegs; }
+
+PegCount* FtpDataModule::get_counts() const
+{ return (PegCount*)&fdstats; }
+
 ProfileStats* FtpDataModule::get_profile() const
 { return &ftpdataPerfStats; }
 
@@ -252,12 +258,12 @@ void FtpData::eval(Packet* p)
 // api stuff
 //-------------------------------------------------------------------------
 
-static void mod_dtor(Module* m)
-{ delete m; }
-
 static Module* mod_ctor()
 { return new FtpDataModule; }
 
+static void mod_dtor(Module* m)
+{ delete m; }
+
 static void fd_init()
 {
     FtpDataFlowData::init();
@@ -273,21 +279,6 @@ static void fd_dtor(Inspector* p)
     delete p;
 }
 
-static void fd_sum()
-{
-    sum_stats(&gfdstats, &fdstats);
-}
-
-static void fd_stats()
-{
-    show_stats(&gfdstats, data_key);
-}
-
-static void fd_reset()
-{
-    memset(&gfdstats, 0, sizeof(gfdstats));
-}
-
 // exported in ftp.cc
 const InspectApi fd_api =
 {
@@ -310,8 +301,6 @@ const InspectApi fd_api =
     nullptr, // pinit
     nullptr, // pterm
     nullptr, // ssn
-    fd_sum,
-    fd_stats,
-    fd_reset
+    nullptr  // reset
 };
 
diff --git a/src/service_inspectors/ftp_telnet/ftp_module.cc b/src/service_inspectors/ftp_telnet/ftp_module.cc
index 13c91fb58..e8757a218 100644
--- a/src/service_inspectors/ftp_telnet/ftp_module.cc
+++ b/src/service_inspectors/ftp_telnet/ftp_module.cc
@@ -490,3 +490,9 @@ bool FtpServerModule::end(const char* fqn, int idx, SnortConfig*)
     return true;
 }
 
+const char** FtpServerModule::get_pegs() const
+{ return simple_pegs; }
+
+PegCount* FtpServerModule::get_counts() const
+{ return (PegCount*)&ftstats; }
+
diff --git a/src/service_inspectors/ftp_telnet/ftp_module.h b/src/service_inspectors/ftp_telnet/ftp_module.h
index ad5887151..4804956c2 100644
--- a/src/service_inspectors/ftp_telnet/ftp_module.h
+++ b/src/service_inspectors/ftp_telnet/ftp_module.h
@@ -43,6 +43,7 @@
 
 struct SnortConfig;
 
+extern THREAD_LOCAL SimpleStats ftstats;
 extern THREAD_LOCAL ProfileStats ftpPerfStats;
 
 //-------------------------------------------------------------------------
@@ -117,6 +118,8 @@ public:
     { return GID_FTP; };
 
     const RuleMap* get_rules() const;
+    const char** get_pegs() const;
+    PegCount* get_counts() const;
     ProfileStats* get_profile() const;
 
     FTP_SERVER_PROTO_CONF* get_data();
diff --git a/src/service_inspectors/ftp_telnet/telnet.cc b/src/service_inspectors/ftp_telnet/telnet.cc
index 3bf5d7e09..c6e3497bf 100644
--- a/src/service_inspectors/ftp_telnet/telnet.cc
+++ b/src/service_inspectors/ftp_telnet/telnet.cc
@@ -49,9 +49,7 @@
 static const char* tn_name = "telnet";
 
 THREAD_LOCAL ProfileStats telnetPerfStats;
-
-static THREAD_LOCAL SimpleStats tnstats;
-static SimpleStats gtnstats;
+THREAD_LOCAL SimpleStats tnstats;
 
 //-------------------------------------------------------------------------
 // implementation
@@ -300,21 +298,6 @@ static void tn_dtor(Inspector* p)
     delete p;
 }
 
-static void tn_sum()
-{
-    sum_stats(&gtnstats, &tnstats);
-}
-
-static void tn_stats()
-{
-    show_stats(&gtnstats, tn_name);
-}
-
-static void tn_reset()
-{
-    memset(&gtnstats, 0, sizeof(gtnstats));
-}
-
 // exported in ftp.cc
 const InspectApi tn_api =
 {
@@ -337,8 +320,6 @@ const InspectApi tn_api =
     nullptr, // pinit
     nullptr, // pterm
     nullptr, // ssn
-    tn_sum,
-    tn_stats,
-    tn_reset,
+    nullptr  // reset
 };
 
diff --git a/src/service_inspectors/ftp_telnet/telnet_module.cc b/src/service_inspectors/ftp_telnet/telnet_module.cc
index 5e570bce9..61a53933c 100644
--- a/src/service_inspectors/ftp_telnet/telnet_module.cc
+++ b/src/service_inspectors/ftp_telnet/telnet_module.cc
@@ -124,3 +124,9 @@ bool TelnetModule::end(const char*, int, SnortConfig*)
     return true;
 }
 
+const char** TelnetModule::get_pegs() const
+{ return simple_pegs; }
+
+PegCount* TelnetModule::get_counts() const
+{ return (PegCount*)&tnstats; }
+
diff --git a/src/service_inspectors/ftp_telnet/telnet_module.h b/src/service_inspectors/ftp_telnet/telnet_module.h
index 0f74e21e3..239788d03 100644
--- a/src/service_inspectors/ftp_telnet/telnet_module.h
+++ b/src/service_inspectors/ftp_telnet/telnet_module.h
@@ -34,6 +34,7 @@
 
 struct SnortConfig;
 
+extern THREAD_LOCAL SimpleStats tnstats;
 extern THREAD_LOCAL ProfileStats telnetPerfStats;
 
 class TelnetModule : public Module
@@ -50,6 +51,8 @@ public:
     { return GID_TELNET; };
 
     const RuleMap* get_rules() const;
+    const char** get_pegs() const;
+    PegCount* get_counts() const;
     ProfileStats* get_profile() const;
 
     TELNET_PROTO_CONF* get_data();
diff --git a/src/service_inspectors/http_inspect/hi_include.h b/src/service_inspectors/http_inspect/hi_include.h
index 2bcd46101..c0ebe5b64 100644
--- a/src/service_inspectors/http_inspect/hi_include.h
+++ b/src/service_inspectors/http_inspect/hi_include.h
@@ -57,6 +57,7 @@ typedef struct _hi_stats {
 } HIStats;
 
 extern THREAD_LOCAL HIStats hi_stats;
+extern const char* peg_names[];
 
 #endif
 
diff --git a/src/service_inspectors/http_inspect/hi_module.cc b/src/service_inspectors/http_inspect/hi_module.cc
index 0bb946eac..a5d58fb5a 100644
--- a/src/service_inspectors/http_inspect/hi_module.cc
+++ b/src/service_inspectors/http_inspect/hi_module.cc
@@ -155,6 +155,12 @@ const RuleMap* HttpInspectModule::get_rules() const
 ProfileStats* HttpInspectModule::get_profile() const
 { return &hiPerfStats; }
 
+const char** HttpInspectModule::get_pegs() const
+{ return peg_names; }
+
+PegCount* HttpInspectModule::get_counts() const
+{ return (PegCount*)&hi_stats; }
+
 HTTPINSPECT_GLOBAL_CONF* HttpInspectModule::get_data()
 {
     HTTPINSPECT_GLOBAL_CONF* tmp = config;
diff --git a/src/service_inspectors/http_inspect/hi_module.h b/src/service_inspectors/http_inspect/hi_module.h
index 951c5b256..82216e0f4 100644
--- a/src/service_inspectors/http_inspect/hi_module.h
+++ b/src/service_inspectors/http_inspect/hi_module.h
@@ -45,6 +45,8 @@ public:
     { return GID_HTTP_CLIENT; };
 
     const RuleMap* get_rules() const;
+    const char** get_pegs() const;
+    PegCount* get_counts() const;
     ProfileStats* get_profile() const;
 
     HTTPINSPECT_GLOBAL_CONF* get_data();
diff --git a/src/service_inspectors/http_inspect/http_inspect.cc b/src/service_inspectors/http_inspect/http_inspect.cc
index 5f9168819..0c7a987a5 100644
--- a/src/service_inspectors/http_inspect/http_inspect.cc
+++ b/src/service_inspectors/http_inspect/http_inspect.cc
@@ -83,9 +83,7 @@ int valid_lookup[256];
 THREAD_LOCAL ProfileStats hiPerfStats;
 THREAD_LOCAL ProfileStats hiDetectPerfStats;
 
-static HIStats ghi_stats;
-
-static const char* peg_names[] =
+const char* peg_names[] =
 {
     "packets",
     "gets",
@@ -424,22 +422,6 @@ static void hs_dtor(Inspector* p)
     delete p;
 }
 
-static void hs_sum()
-{
-    sum_stats((PegCount*)&ghi_stats, (PegCount*)&hi_stats, array_size(peg_names));
-}
-
-static void hs_stats()
-{
-    show_stats((PegCount*)&ghi_stats, peg_names, array_size(peg_names),
-        SERVER_KEYWORD);
-}
-
-static void hs_reset()
-{
-    memset(&ghi_stats, 0, sizeof(ghi_stats));
-}
-
 //-------------------------------------------------------------------------
 
 static const char* buffers[] =
@@ -478,9 +460,7 @@ static const InspectApi hs_api =
     nullptr, // pinit
     nullptr, // pterm
     nullptr, // ssn
-    hs_sum,
-    hs_stats,
-    hs_reset
+    nullptr  // reset
 };
 
 #ifdef BUILDING_SO
diff --git a/src/service_inspectors/nhttp_inspect/nhttp_api.cc b/src/service_inspectors/nhttp_inspect/nhttp_api.cc
index a62a987df..ee63a7e23 100644
--- a/src/service_inspectors/nhttp_inspect/nhttp_api.cc
+++ b/src/service_inspectors/nhttp_inspect/nhttp_api.cc
@@ -85,10 +85,8 @@ const InspectApi NHttpApi::nhttp_api =
     NHttpApi::nhttp_dtor,
     NHttpApi::nhttp_pinit,
     NHttpApi::nhttp_pterm,
-    nullptr,
-    NHttpApi::nhttp_sum,
-    NHttpApi::nhttp_stats,
-    NHttpApi::nhttp_reset
+    nullptr, // ssn
+    nullptr  // reset
 };
 
 #ifdef BUILDING_SO
diff --git a/src/service_inspectors/nhttp_inspect/nhttp_api.h b/src/service_inspectors/nhttp_inspect/nhttp_api.h
index 7a4e82211..3d4df3cd5 100644
--- a/src/service_inspectors/nhttp_inspect/nhttp_api.h
+++ b/src/service_inspectors/nhttp_inspect/nhttp_api.h
@@ -49,9 +49,6 @@ private:
     static void nhttp_dtor(Inspector* p) { delete p; };
     static void nhttp_pinit() {};
     static void nhttp_pterm() {};
-    static void nhttp_sum() {};
-    static void nhttp_stats() {};
-    static void nhttp_reset() {};
 };
 
 #endif
diff --git a/src/service_inspectors/rpc_decode/rpc_decode.cc b/src/service_inspectors/rpc_decode/rpc_decode.cc
index 37add49c2..bbc129e95 100644
--- a/src/service_inspectors/rpc_decode/rpc_decode.cc
+++ b/src/service_inspectors/rpc_decode/rpc_decode.cc
@@ -125,9 +125,7 @@ static THREAD_LOCAL uint32_t rpc_memory = 0;
 static const char* mod_name = "rpc_decode";
 
 THREAD_LOCAL ProfileStats rpcdecodePerfStats;
-
-static THREAD_LOCAL SimpleStats rdstats;
-static SimpleStats grdstats;
+THREAD_LOCAL SimpleStats rdstats;
 
 static int ConvertRPC(RpcDecodeConfig *, RpcSsnData *, Packet *);
 
@@ -1100,21 +1098,6 @@ static void rd_dtor(Inspector* p)
     delete p;
 }
 
-static void rd_sum()
-{
-    sum_stats(&grdstats, &rdstats);
-}
-
-static void rd_stats()
-{
-    show_stats(&grdstats, mod_name);
-}
-
-static void rd_reset()
-{
-    memset(&grdstats, 0, sizeof(grdstats));
-}
-
 static const InspectApi rd_api =
 {
     {
@@ -1136,9 +1119,7 @@ static const InspectApi rd_api =
     nullptr, // pinit
     nullptr, // pterm
     nullptr, // ssn
-    rd_sum,
-    rd_stats,
-    rd_reset
+    nullptr  // reset
 };
 
 #ifdef BUILDING_SO
diff --git a/src/service_inspectors/rpc_decode/rpc_module.cc b/src/service_inspectors/rpc_decode/rpc_module.cc
index 9431a96f2..eb76cb440 100644
--- a/src/service_inspectors/rpc_decode/rpc_module.cc
+++ b/src/service_inspectors/rpc_decode/rpc_module.cc
@@ -59,6 +59,12 @@ RpcModule::RpcModule() : Module("rpc_decode", rpc_params)
 const RuleMap* RpcModule::get_rules() const
 { return rpc_rules; }
 
+const char** RpcModule::get_pegs() const
+{ return simple_pegs; }
+
+PegCount* RpcModule::get_counts() const
+{ return (PegCount*)&rdstats; }
+
 ProfileStats* RpcModule::get_profile() const
 { return &rpcdecodePerfStats; }
 
diff --git a/src/service_inspectors/rpc_decode/rpc_module.h b/src/service_inspectors/rpc_decode/rpc_module.h
index f2ead7748..9b602f562 100644
--- a/src/service_inspectors/rpc_decode/rpc_module.h
+++ b/src/service_inspectors/rpc_decode/rpc_module.h
@@ -34,6 +34,7 @@
 #define RPC_INCOMPLETE_SEGMENT     4
 #define RPC_ZERO_LENGTH_FRAGMENT   5
 
+extern THREAD_LOCAL SimpleStats rdstats;
 extern THREAD_LOCAL ProfileStats rpcdecodePerfStats;
 
 class RpcModule : public Module
@@ -48,6 +49,8 @@ public:
     { return GID_RPC_DECODE; };
 
     const RuleMap* get_rules() const;
+    const char** get_pegs() const;
+    PegCount* get_counts() const;
     ProfileStats* get_profile() const;
 };
 
diff --git a/src/service_inspectors/wizard/wiz_module.cc b/src/service_inspectors/wizard/wiz_module.cc
index d427e881e..8db0d5380 100644
--- a/src/service_inspectors/wizard/wiz_module.cc
+++ b/src/service_inspectors/wizard/wiz_module.cc
@@ -216,3 +216,9 @@ MagicBook* WizardModule::get_book(bool c2s, bool hex)
     return hex ? s2c_hexes : s2c_spells;
 }
 
+const char** WizardModule::get_pegs() const
+{ return wiz_pegs; }
+
+PegCount* WizardModule::get_counts() const
+{ return (PegCount*)&tstats; }
+
diff --git a/src/service_inspectors/wizard/wiz_module.h b/src/service_inspectors/wizard/wiz_module.h
index efe2e077f..ffbe9ffa9 100644
--- a/src/service_inspectors/wizard/wiz_module.h
+++ b/src/service_inspectors/wizard/wiz_module.h
@@ -27,6 +27,8 @@
 #include "framework/module.h"
 #include "main/thread.h"
 
+extern const char* wiz_pegs[];
+extern THREAD_LOCAL struct WizStats tstats;
 extern THREAD_LOCAL ProfileStats wizPerfStats;
 
 class MagicBook;
@@ -41,6 +43,8 @@ public:
     bool begin(const char*, int, SnortConfig*);
     bool end(const char*, int, SnortConfig*);
 
+    const char** get_pegs() const;
+    PegCount* get_counts() const;
     ProfileStats* get_profile() const;
 
     MagicBook* get_book(bool c2s, bool hex);
diff --git a/src/service_inspectors/wizard/wizard.cc b/src/service_inspectors/wizard/wizard.cc
index f25f4d351..d625f6fd4 100644
--- a/src/service_inspectors/wizard/wizard.cc
+++ b/src/service_inspectors/wizard/wizard.cc
@@ -48,16 +48,16 @@ struct WizStats
     PegCount udp_hits;
 };
 
-static const char* wiz_pegs[] =
+const char* wiz_pegs[] =
 {
     "tcp scans",
     "tcp hits",
     "udp scans",
-    "udp hits"
+    "udp hits",
+    nullptr
 };
 
-static THREAD_LOCAL WizStats tstats;
-static WizStats gstats;
+THREAD_LOCAL WizStats tstats;
 
 //-------------------------------------------------------------------------
 // configuration
@@ -237,21 +237,6 @@ static void wiz_dtor(Inspector* p)
     delete p;
 }
 
-static void wiz_sum()
-{
-    sum_stats((PegCount*)&gstats, (PegCount*)&tstats, array_size(wiz_pegs));
-}
-
-static void wiz_stats()
-{
-    show_stats((PegCount*)&gstats, wiz_pegs, array_size(wiz_pegs), mod_name);
-}
-
-static void wiz_reset()
-{
-    memset(&gstats, 0, sizeof(gstats));
-}
-
 static const InspectApi wiz_api =
 {
     {
@@ -273,9 +258,7 @@ static const InspectApi wiz_api =
     nullptr, // pinit
     nullptr, // pterm
     nullptr, // ssn
-    wiz_sum,
-    wiz_stats,
-    wiz_reset
+    nullptr  // reset
 };
 
 #ifdef BUILDING_SO
diff --git a/src/stream/base/stream_base.cc b/src/stream/base/stream_base.cc
index 756c05983..869ca6d6d 100644
--- a/src/stream/base/stream_base.cc
+++ b/src/stream/base/stream_base.cc
@@ -40,7 +40,7 @@
 #include "profiler.h"
 
 //-------------------------------------------------------------------------
-// globals
+// stats
 //-------------------------------------------------------------------------
 
 THREAD_LOCAL ProfileStats s5PerfStats;
@@ -54,7 +54,8 @@ const char* session_pegs[] =
     "created",
     "released",
     "discards",
-    "events"
+    "events",
+    nullptr
 };
 
 const unsigned session_peg_count = array_size(session_pegs);
@@ -78,6 +79,29 @@ static const char* base_pegs[] =
     "ip flows"
 };
 
+void base_sum()
+{   
+    t_stats.tcp = flow_con->get_flow_count(IPPROTO_TCP);
+    t_stats.udp = flow_con->get_flow_count(IPPROTO_UDP);
+    t_stats.icmp = flow_con->get_flow_count(IPPROTO_ICMP);
+    t_stats.ip = flow_con->get_flow_count(IPPROTO_IP);
+
+    sum_stats((PegCount*)&g_stats, (PegCount*)&t_stats,
+        array_size(base_pegs));
+}   
+    
+void base_stats()
+{   
+    show_stats((PegCount*)&g_stats, base_pegs, array_size(base_pegs),
+        MOD_NAME);
+}
+
+void base_reset()
+{
+    flow_con->clear_flow_counts();
+    memset(&t_stats, 0, sizeof(t_stats));
+}
+
 //-------------------------------------------------------------------------
 // runtime support
 //-------------------------------------------------------------------------
@@ -245,29 +269,6 @@ static void base_dtor(Inspector* p)
     delete p;
 }
 
-void base_sum()
-{   
-    t_stats.tcp = flow_con->get_flow_count(IPPROTO_TCP);
-    t_stats.udp = flow_con->get_flow_count(IPPROTO_UDP);
-    t_stats.icmp = flow_con->get_flow_count(IPPROTO_ICMP);
-    t_stats.ip = flow_con->get_flow_count(IPPROTO_IP);
-
-    sum_stats((PegCount*)&g_stats, (PegCount*)&t_stats,
-        array_size(base_pegs));
-}   
-    
-void base_stats()
-{   
-    show_stats((PegCount*)&g_stats, base_pegs, array_size(base_pegs),
-        MOD_NAME);
-}
-
-void base_reset()
-{
-    flow_con->clear_flow_counts();
-    memset(&t_stats, 0, sizeof(t_stats));
-}
-
 static const InspectApi base_api =
 {
     {
@@ -289,9 +290,7 @@ static const InspectApi base_api =
     nullptr, // pinit
     nullptr, // pterm
     nullptr, // ssn
-    base_sum,
-    base_stats,
-    base_reset
+    nullptr  // reset
 };
 
 const BaseApi* nin_stream_base = &base_api.base;
diff --git a/src/stream/base/stream_module.cc b/src/stream/base/stream_module.cc
index f0c8012c5..df89bddc6 100644
--- a/src/stream/base/stream_module.cc
+++ b/src/stream/base/stream_module.cc
@@ -130,3 +130,12 @@ bool StreamModule::begin(const char* fqn, int, SnortConfig*)
     return true;
 }
 
+void StreamModule::sum_stats()
+{ base_sum(); }
+
+void StreamModule::show_stats()
+{ base_stats(); }
+
+void StreamModule::reset_stats()
+{ base_reset(); }
+
diff --git a/src/stream/base/stream_module.h b/src/stream/base/stream_module.h
index da2e34efe..bb60be431 100644
--- a/src/stream/base/stream_module.h
+++ b/src/stream/base/stream_module.h
@@ -54,9 +54,17 @@ public:
     ProfileStats* get_profile() const;
     const StreamConfig* get_data();
 
+    void sum_stats();
+    void show_stats();
+    void reset_stats();
+
 private:
     FlowConfig* proto;
 };
 
+extern void base_sum();
+extern void base_stats();
+extern void base_reset();
+
 #endif
 
diff --git a/src/stream/icmp/icmp_module.cc b/src/stream/icmp/icmp_module.cc
index d8569fe2a..864970143 100644
--- a/src/stream/icmp/icmp_module.cc
+++ b/src/stream/icmp/icmp_module.cc
@@ -79,3 +79,9 @@ bool StreamIcmpModule::end(const char*, int, SnortConfig*)
     return true;
 }
 
+const char** StreamIcmpModule::get_pegs() const
+{ return session_pegs; }
+
+PegCount* StreamIcmpModule::get_counts() const
+{ return (PegCount*)&icmpStats; }
+
diff --git a/src/stream/icmp/icmp_module.h b/src/stream/icmp/icmp_module.h
index d0b03145c..afc894e02 100644
--- a/src/stream/icmp/icmp_module.h
+++ b/src/stream/icmp/icmp_module.h
@@ -25,8 +25,11 @@
 #include "snort_types.h"
 #include "framework/module.h"
 #include "main/thread.h"
+#include "stream/stream.h"
 
+extern THREAD_LOCAL SessionStats icmpStats;
 extern THREAD_LOCAL ProfileStats icmp_perf_stats;
+
 struct SnortConfig;
 
 //-------------------------------------------------------------------------
@@ -46,6 +49,8 @@ public:
     bool end(const char*, int, SnortConfig*);
 
     ProfileStats* get_profile() const;
+    const char** get_pegs() const;
+    PegCount* get_counts() const;
     StreamIcmpConfig* get_data();
 
 private:
diff --git a/src/stream/icmp/icmp_session.cc b/src/stream/icmp/icmp_session.cc
index 33199f680..c36177ee3 100644
--- a/src/stream/icmp/icmp_session.cc
+++ b/src/stream/icmp/icmp_session.cc
@@ -43,9 +43,7 @@
 #include "protocols/layer.h"
 #include "protocols/vlan.h"
 
-static SessionStats gicmpStats;
-static THREAD_LOCAL SessionStats icmpStats;
-
+THREAD_LOCAL SessionStats icmpStats;
 THREAD_LOCAL ProfileStats icmp_perf_stats;
 
 //------------------------------------------------------------------------
@@ -234,20 +232,14 @@ void IcmpSession::update_direction(char dir, snort_ip* ip, uint16_t)
 // api related methods
 //-------------------------------------------------------------------------
 
-void icmp_sum()
-{
-    sum_stats((PegCount*)&gicmpStats, (PegCount*)&icmpStats,
-        session_peg_count);
-}
-
+#if 0
 void icmp_stats()
 {
+    // FIXIT move these to the actual owner
     // FIXIT need to get these before delete flow_con
     //flow_con->get_prunes(IPPROTO_UDP, icmpStats.prunes);
-
-    show_stats((PegCount*)&gicmpStats, session_pegs, session_peg_count,
-        MOD_NAME);
 }
+#endif
 
 void icmp_reset()
 {
diff --git a/src/stream/icmp/icmp_session.h b/src/stream/icmp/icmp_session.h
index 753f527ae..f607ebe2c 100644
--- a/src/stream/icmp/icmp_session.h
+++ b/src/stream/icmp/icmp_session.h
@@ -40,7 +40,6 @@ public:
     struct timeval ssn_time;
 };
 
-void icmp_sum();
 void icmp_stats();
 void icmp_reset();
 
diff --git a/src/stream/icmp/stream_icmp.cc b/src/stream/icmp/stream_icmp.cc
index 40a040f68..b66a681b7 100644
--- a/src/stream/icmp/stream_icmp.cc
+++ b/src/stream/icmp/stream_icmp.cc
@@ -131,8 +131,6 @@ static const InspectApi icmp_api =
     nullptr, // pinit
     nullptr, // pterm
     icmp_ssn,
-    icmp_sum,
-    icmp_stats,
     icmp_reset
 };
 
diff --git a/src/stream/ip/ip_module.cc b/src/stream/ip/ip_module.cc
index b132eb7a0..a9778ab9b 100644
--- a/src/stream/ip/ip_module.cc
+++ b/src/stream/ip/ip_module.cc
@@ -25,6 +25,7 @@
 using namespace std;
 
 #include "stream_ip.h"
+#include "ip_defrag.h"
 #include "main/snort_config.h"
 #include "stream/stream.h"
 
@@ -212,3 +213,18 @@ bool StreamIpModule::end(const char*, int, SnortConfig*)
     return true;
 }
 
+const char** StreamIpModule::get_pegs() const
+{ return session_pegs; }
+
+PegCount* StreamIpModule::get_counts() const
+{ return (PegCount*)&ipStats; }
+
+void StreamIpModule::sum_stats()
+{ Defrag::sum(); }
+
+void StreamIpModule::show_stats()
+{ Defrag::stats(); }
+
+void StreamIpModule::reset_stats()
+{ Defrag::reset(); }
+
diff --git a/src/stream/ip/ip_module.h b/src/stream/ip/ip_module.h
index b0aec0339..4bb4edcfc 100644
--- a/src/stream/ip/ip_module.h
+++ b/src/stream/ip/ip_module.h
@@ -25,6 +25,7 @@
 #include "snort_types.h"
 #include "framework/module.h"
 #include "main/thread.h"
+#include "stream/stream.h"
 
 struct SnortConfig;
 
@@ -54,6 +55,7 @@ struct SnortConfig;
 #define DEFRAG_EXCESSIVE_OVERLAP  12
 #define DEFRAG_TINY_FRAGMENT      13
 
+extern THREAD_LOCAL SessionStats ipStats;
 extern THREAD_LOCAL ProfileStats ip_perf_stats;
 extern THREAD_LOCAL ProfileStats fragPerfStats;
 extern THREAD_LOCAL ProfileStats fragInsertPerfStats;
@@ -79,8 +81,17 @@ public:
 
     const RuleMap* get_rules() const;
     ProfileStats* get_profile(unsigned, const char*&, const char*&) const;
+    const char** get_pegs() const;
+    PegCount* get_counts() const;
     StreamIpConfig* get_data();
 
+    unsigned get_gid() const
+    { return GID_DEFRAG; };
+
+    void sum_stats();
+    void show_stats();
+    void reset_stats();
+
 private:
     StreamIpConfig* config;
 };
diff --git a/src/stream/ip/ip_session.cc b/src/stream/ip/ip_session.cc
index 41bcefd4f..83ecf9612 100644
--- a/src/stream/ip/ip_session.cc
+++ b/src/stream/ip/ip_session.cc
@@ -33,9 +33,7 @@
 #include "perf_monitor/perf.h"
 #include "flow/flow_control.h"
 
-static SessionStats gipStats;
-static THREAD_LOCAL SessionStats ipStats;
-
+THREAD_LOCAL SessionStats ipStats;
 THREAD_LOCAL ProfileStats ip_perf_stats;
 
 //-------------------------------------------------------------------------
@@ -184,29 +182,3 @@ int IpSession::process(Packet* p)
     return 0;
 }
 
-//-------------------------------------------------------------------------
-// api related methods
-//-------------------------------------------------------------------------
-
-void ip_sum()
-{
-    sum_stats((PegCount*)&gipStats, (PegCount*)&ipStats, session_peg_count);
-    Defrag::sum();
-}
-
-void ip_stats()
-{
-    // FIXIT need to get these before delete flow_con
-    //flow_con->get_prunes(IPPROTO_UDP, ipStats.prunes);
-
-    show_stats((PegCount*)&gipStats, session_pegs, session_peg_count, MOD_NAME);
-    Defrag::stats();
-}
-
-void ip_reset()
-{
-    memset(&ipStats, 0, sizeof(ipStats));
-    flow_con->reset_prunes(IPPROTO_IP);
-    Defrag::reset();
-}
-
diff --git a/src/stream/ip/stream_ip.cc b/src/stream/ip/stream_ip.cc
index 279a3e83b..09a667d9b 100644
--- a/src/stream/ip/stream_ip.cc
+++ b/src/stream/ip/stream_ip.cc
@@ -178,9 +178,7 @@ static const InspectApi ip_api =
     nullptr, // pinit
     nullptr, // pterm
     ip_ssn,
-    ip_sum,
-    ip_stats,
-    ip_reset
+    nullptr  // reset
 };
 
 const BaseApi* nin_stream_ip = &ip_api.base;
diff --git a/src/stream/ip/stream_ip.h b/src/stream/ip/stream_ip.h
index 51bc415c6..3b9d624e3 100644
--- a/src/stream/ip/stream_ip.h
+++ b/src/stream/ip/stream_ip.h
@@ -53,10 +53,6 @@ struct StreamIpConfig
     StreamIpConfig();
 };
 
-void ip_sum();
-void ip_stats();
-void ip_reset();
-
 StreamIpConfig* get_ip_cfg(Inspector*);
 class Defrag* get_defrag(Inspector*);
 
diff --git a/src/stream/tcp/stream_tcp.cc b/src/stream/tcp/stream_tcp.cc
index 8320f1f82..79e23fe3f 100644
--- a/src/stream/tcp/stream_tcp.cc
+++ b/src/stream/tcp/stream_tcp.cc
@@ -138,8 +138,6 @@ static const InspectApi tcp_api =
     tcp_pinit,
     tcp_pterm,
     tcp_ssn,
-    tcp_sum,
-    tcp_stats,
     tcp_reset
 };
 
diff --git a/src/stream/tcp/tcp_module.cc b/src/stream/tcp/tcp_module.cc
index e7cb1a3b7..b1d518c87 100644
--- a/src/stream/tcp/tcp_module.cc
+++ b/src/stream/tcp/tcp_module.cc
@@ -434,3 +434,9 @@ bool StreamTcpModule::end(const char*, int, SnortConfig*)
     return true;
 }
 
+const char** StreamTcpModule::get_pegs() const
+{ return tcp_pegs; }
+
+PegCount* StreamTcpModule::get_counts() const
+{ return (PegCount*)&tcpStats; }
+
diff --git a/src/stream/tcp/tcp_module.h b/src/stream/tcp/tcp_module.h
index 047928832..c25e23dcf 100644
--- a/src/stream/tcp/tcp_module.h
+++ b/src/stream/tcp/tcp_module.h
@@ -28,6 +28,7 @@
 #include "snort_types.h"
 #include "framework/module.h"
 #include "main/thread.h"
+#include "stream/stream.h"
 
 #define GID_STREAM_TCP  129
 
@@ -52,6 +53,8 @@
 #define STREAM_TCP_WINDOW_SLAM                    19
 #define STREAM_TCP_NO_3WHS                        20
 
+extern const char* tcp_pegs[];
+extern THREAD_LOCAL struct TcpStats tcpStats;
 extern THREAD_LOCAL ProfileStats s5TcpPerfStats;
 extern THREAD_LOCAL ProfileStats s5TcpNewSessPerfStats;
 extern THREAD_LOCAL ProfileStats s5TcpStatePerfStats;
@@ -102,6 +105,8 @@ public:
     const ServiceReassembly* get_proto(unsigned);
 
     ProfileStats* get_profile(unsigned, const char*&, const char*&) const;
+    const char** get_pegs() const;
+    PegCount* get_counts() const;
 
 private:
     void add_protos(Value&, bool, bool);
diff --git a/src/stream/tcp/tcp_session.cc b/src/stream/tcp/tcp_session.cc
index 42cf219d7..3ffafa8e8 100644
--- a/src/stream/tcp/tcp_session.cc
+++ b/src/stream/tcp/tcp_session.cc
@@ -99,6 +99,13 @@ THREAD_LOCAL ProfileStats streamReassembleRuleOptionPerfStats;
 
 struct TcpStats
 {
+    PegCount sessions;
+    PegCount prunes;
+    PegCount timeouts;
+    PegCount created;
+    PegCount released;
+    PegCount discards;
+    PegCount events;
     PegCount trackers_created;
     PegCount trackers_released;
     PegCount segs_created;
@@ -112,8 +119,15 @@ struct TcpStats
     PegCount s5tcp2;
 };
 
-static const char* tcp_pegs[] =
+const char* tcp_pegs[] =
 {
+    "sessions",
+    "prunes",
+    "timeouts",
+    "created",
+    "released",
+    "discards",
+    "events",
     "trackers created",
     "trackers released",
     "segs created",
@@ -127,12 +141,7 @@ static const char* tcp_pegs[] =
     "server cleanup flushes"
 };
 
-static SessionStats gssnStats;
-static TcpStats gtcpStats;
-
-static THREAD_LOCAL SessionStats ssnStats;
-static THREAD_LOCAL TcpStats tcpStats;
-
+THREAD_LOCAL TcpStats tcpStats;
 THREAD_LOCAL Memcap* tcp_memcap = nullptr;
 
 /*  M A C R O S  **************************************************/
@@ -912,114 +921,114 @@ static void PrintFlushMgr(FlushMgr *fm)
 
 static inline void Discard ()
 {
-    ssnStats.discards++;
+    tcpStats.discards++;
 }
 
 static inline void EventSynOnEst()
 {
     SnortEventqAdd(GID_STREAM_TCP, STREAM_TCP_SYN_ON_EST);
-    ssnStats.events++;
+    tcpStats.events++;
 }
 
 static inline void EventExcessiveOverlap()
 {
     SnortEventqAdd(GID_STREAM_TCP, STREAM_TCP_EXCESSIVE_TCP_OVERLAPS);
-    ssnStats.events++;
+    tcpStats.events++;
 }
 
 static inline void EventBadTimestamp()
 {
     SnortEventqAdd(GID_STREAM_TCP, STREAM_TCP_BAD_TIMESTAMP);
-    ssnStats.events++;
+    tcpStats.events++;
 }
 
 static inline void EventWindowTooLarge()
 {
     SnortEventqAdd(GID_STREAM_TCP, STREAM_TCP_WINDOW_TOO_LARGE);
-    ssnStats.events++;
+    tcpStats.events++;
 }
 
 static inline void EventDataOnSyn()
 {
     SnortEventqAdd(GID_STREAM_TCP, STREAM_TCP_DATA_ON_SYN);
-    ssnStats.events++;
+    tcpStats.events++;
 }
 
 static inline void EventDataOnClosed()
 {
     SnortEventqAdd(GID_STREAM_TCP, STREAM_TCP_DATA_ON_CLOSED);
-    ssnStats.events++;
+    tcpStats.events++;
 }
 
 static inline void EventDataAfterReset()
 {
     SnortEventqAdd(GID_STREAM_TCP, STREAM_TCP_DATA_AFTER_RESET);
-    ssnStats.events++;
+    tcpStats.events++;
 }
 
 static inline void EventBadSegment()
 {
     SnortEventqAdd(GID_STREAM_TCP, STREAM_TCP_BAD_SEGMENT);
-    ssnStats.events++;
+    tcpStats.events++;
 }
 
 static inline void EventSessionHijackedClient()
 {
     SnortEventqAdd(GID_STREAM_TCP, STREAM_TCP_SESSION_HIJACKED_CLIENT);
-    ssnStats.events++;
+    tcpStats.events++;
 }
 static inline void EventSessionHijackedServer()
 {
     SnortEventqAdd(GID_STREAM_TCP, STREAM_TCP_SESSION_HIJACKED_SERVER);
-    ssnStats.events++;
+    tcpStats.events++;
 }
 
 static inline void EventDataWithoutFlags()
 {
     SnortEventqAdd(GID_STREAM_TCP, STREAM_TCP_DATA_WITHOUT_FLAGS);
-    ssnStats.events++;
+    tcpStats.events++;
 }
 
 static inline void EventMaxSmallSegsExceeded()
 {
     SnortEventqAdd(GID_STREAM_TCP, STREAM_TCP_SMALL_SEGMENT);
-    ssnStats.events++;
+    tcpStats.events++;
 }
 
 static inline void Event4whs()
 {
     SnortEventqAdd(GID_STREAM_TCP, STREAM_TCP_4WAY_HANDSHAKE);
-    ssnStats.events++;
+    tcpStats.events++;
 }
 
 static inline void EventNoTimestamp()
 {
     SnortEventqAdd(GID_STREAM_TCP, STREAM_TCP_NO_TIMESTAMP);
-    ssnStats.events++;
+    tcpStats.events++;
 }
 
 static inline void EventBadReset()
 {
     SnortEventqAdd(GID_STREAM_TCP, STREAM_TCP_BAD_RST);
-    ssnStats.events++;
+    tcpStats.events++;
 }
 
 static inline void EventBadFin()
 {
     SnortEventqAdd(GID_STREAM_TCP, STREAM_TCP_BAD_FIN);
-    ssnStats.events++;
+    tcpStats.events++;
 }
 
 static inline void EventBadAck()
 {
     SnortEventqAdd(GID_STREAM_TCP, STREAM_TCP_BAD_ACK);
-    ssnStats.events++;
+    tcpStats.events++;
 }
 
 static inline void EventDataAfterRstRcvd()
 {
     SnortEventqAdd(GID_STREAM_TCP, STREAM_TCP_DATA_AFTER_RST_RCVD);
-    ssnStats.events++;
+    tcpStats.events++;
 }
 
 static inline void EventInternal (uint32_t eventSid)
@@ -1038,13 +1047,13 @@ static inline void EventInternal (uint32_t eventSid)
 static inline void EventWindowSlam ()
 {
     SnortEventqAdd(GID_STREAM_TCP, STREAM_TCP_WINDOW_SLAM);
-    ssnStats.events++;
+    tcpStats.events++;
 }
 
 static inline void EventNo3whs()
 {
     SnortEventqAdd(GID_STREAM_TCP, STREAM_TCP_NO_3WHS);
-    ssnStats.events++;
+    tcpStats.events++;
 }
 
 /*
@@ -7214,7 +7223,7 @@ bool TcpSession::setup (Packet* p)
     stream.set_splitter(flow, true, ins->get_splitter(true));
     stream.set_splitter(flow, false, ins->get_splitter(false));
 
-    ssnStats.sessions++;
+    tcpStats.sessions++;
     return true;
 }
 
@@ -7354,7 +7363,7 @@ int TcpSession::process(Packet *p)
             /* Not reset, simply time'd out.  Clean it up */
             TcpSessionCleanup(flow, 1);
         }
-        ssnStats.timeouts++;
+        tcpStats.timeouts++;
     }
     status = ProcessTcp(flow, p, &tdb, config);
 
@@ -7393,31 +7402,8 @@ void tcp_init()
 #endif
 }
 
-void tcp_sum()
-{
-    sum_stats((PegCount*)&gssnStats, (PegCount*)&ssnStats,
-        session_peg_count);
-
-    sum_stats((PegCount*)&gtcpStats, (PegCount*)&tcpStats,
-        array_size(tcp_pegs));
-}
-
-void tcp_stats()
-{
-    // FIXIT need to get these before delete flow_con
-    //flow_con->get_prunes(IPPROTO_TCP, ssnStats.prunes);
-
-    show_stats((PegCount*)&gssnStats, session_pegs, session_peg_count,
-        MOD_NAME);
-
-    show_stats((PegCount*)&gtcpStats, tcp_pegs, array_size(tcp_pegs));
-}
-
 void tcp_reset()
 {
-    memset(&gssnStats, 0, sizeof(gssnStats));
-    memset(&gtcpStats, 0, sizeof(gtcpStats));
-
     flow_con->reset_prunes(IPPROTO_TCP);
 }
 
diff --git a/src/stream/udp/stream_udp.cc b/src/stream/udp/stream_udp.cc
index d473b0cca..bbc4b96dd 100644
--- a/src/stream/udp/stream_udp.cc
+++ b/src/stream/udp/stream_udp.cc
@@ -146,8 +146,6 @@ static const InspectApi udp_api =
     nullptr, // pinit
     nullptr, // pterm
     udp_ssn,
-    udp_sum,
-    udp_stats,
     udp_reset
 };
 
diff --git a/src/stream/udp/udp_module.cc b/src/stream/udp/udp_module.cc
index 34a85f0fd..bcef49890 100644
--- a/src/stream/udp/udp_module.cc
+++ b/src/stream/udp/udp_module.cc
@@ -87,3 +87,9 @@ bool StreamUdpModule::end(const char*, int, SnortConfig*)
     return true;
 }
 
+const char** StreamUdpModule::get_pegs() const
+{ return session_pegs; }
+
+PegCount* StreamUdpModule::get_counts() const
+{ return (PegCount*)&udpStats; }
+
diff --git a/src/stream/udp/udp_module.h b/src/stream/udp/udp_module.h
index ba02489e0..03a56810c 100644
--- a/src/stream/udp/udp_module.h
+++ b/src/stream/udp/udp_module.h
@@ -28,9 +28,11 @@
 #include "snort_types.h"
 #include "framework/module.h"
 #include "main/thread.h"
-
+#include "stream/stream.h"
+    
 struct SnortConfig;
 
+extern THREAD_LOCAL SessionStats udpStats;
 extern THREAD_LOCAL ProfileStats udp_perf_stats;
 
 //-------------------------------------------------------------------------
@@ -50,6 +52,8 @@ public:
     bool end(const char*, int, SnortConfig*);
 
     ProfileStats* get_profile() const;
+    const char** get_pegs() const;
+    PegCount* get_counts() const;
     StreamUdpConfig* get_data();
 
 private:
diff --git a/src/stream/udp/udp_session.cc b/src/stream/udp/udp_session.cc
index d51951c06..e87808a2e 100644
--- a/src/stream/udp/udp_session.cc
+++ b/src/stream/udp/udp_session.cc
@@ -51,9 +51,7 @@
 #define udp_responder_ip flow->server_ip
 #define udp_responder_port flow->server_port
 
-static SessionStats gudpStats;
-static THREAD_LOCAL SessionStats udpStats;
-
+THREAD_LOCAL SessionStats udpStats;
 THREAD_LOCAL ProfileStats udp_perf_stats;
 
 //-------------------------------------------------------------------------
@@ -235,24 +233,16 @@ int UdpSession::process(Packet *p)
 // api related methods
 //-------------------------------------------------------------------------
 
-void udp_sum()
-{
-    sum_stats((PegCount*)&gudpStats, (PegCount*)&udpStats,
-        session_peg_count);
-}
-
+#if 0
 void udp_stats()
 {
     // FIXIT need to get these before delete flow_con
     //flow_con->get_prunes(IPPROTO_UDP, udpStats.prunes);
-
-    show_stats((PegCount*)&gudpStats, session_pegs, session_peg_count,
-        MOD_NAME);
 }
+#endif
 
 void udp_reset()
 {
-    memset(&udpStats, 0, sizeof(udpStats));
     flow_con->reset_prunes(IPPROTO_UDP);
 }
 
diff --git a/src/stream/udp/udp_session.h b/src/stream/udp/udp_session.h
index 3e9ad6c91..f859b8d5d 100644
--- a/src/stream/udp/udp_session.h
+++ b/src/stream/udp/udp_session.h
@@ -40,7 +40,6 @@ public:
     struct timeval ssn_time;
 };
 
-void udp_sum();
 void udp_stats();
 void udp_reset();
 
diff --git a/src/utils/stats.cc b/src/utils/stats.cc
index 2108cc6dc..00bb909e9 100644
--- a/src/utils/stats.cc
+++ b/src/utils/stats.cc
@@ -32,7 +32,7 @@
 #include "packet_io/active.h"
 #include "packet_io/trough.h"
 #include "target_based/sftarget_reader.h"
-#include "managers/inspector_manager.h"
+#include "managers/module_manager.h"
 #include "managers/packet_manager.h"
 
 #define STATS_SEPARATOR \
@@ -297,7 +297,7 @@ void DropStats()
     PacketManager::dump_stats();
     //mpse_print_qinfo();
 
-    InspectorManager::dump_stats(snort_conf);
+    ModuleManager::dump_stats(snort_conf);
 
     // ensure proper counting of log_limit
     SnortEventqResetCounts();