Add CTT support

Makefile.am

@@ -78,6 +78,8 @@ ipfixprobe_storage_src=\
 		storage/cttController.cpp \
 		storage/cacheRowSpan.hpp \
 		storage/cacheRowSpan.cpp \
+		storage/cttController.hpp \
+		storage/cttController.cpp \
 		storage/xxhash.c \
 		storage/xxhash.h
 

include/ipfixprobe/flowifc.hpp

@@ -267,9 +267,9 @@ struct Flow : public Record {
 
     #ifdef WITH_CTT
       uint64_t flow_hash_ctt;     /**< Flow hash for CTT. */
-      bool record_in_ctt;         /**< CTT - offload or not. */
-      bool is_delayed;            /**< Delayed export flag. */
-      time_t delay_time;          /**< Time until export of the flow is delayed. */
+      //bool record_in_ctt;         /**< CTT - offload or not. */
+      //bool is_delayed;            /**< Delayed export flag. */
+      //timeval delay_time;          /**< Time until export of the flow is delayed. */
     #endif
 
     PluginsStatus plugins_status; /**< Statuses of the process plugins for this flow, used to check

include/ipfixprobe/packet.hpp

@@ -47,7 +47,7 @@ namespace ipxp {
  * \brief Structure for storing parsed packet fields
  */
 struct Packet : public Record {
-   struct timeval ts;
+   timeval ts;
 
    uint8_t     dst_mac[6];
    uint8_t     src_mac[6];

include/ipfixprobe/storage.hpp

@@ -93,6 +93,7 @@ class StoragePlugin : public Plugin
    virtual void export_expired(time_t ts)
    {
    }
+
    virtual void finish()
    {
    }
@@ -189,12 +190,6 @@ class StoragePlugin : public Plugin
      */
     int plugins_post_create(Flow& rec, const Packet& pkt)
     {
-        // if metadata are valid, add flow hash ctt to the flow record
-#ifdef WITH_CTT
-        if (pkt.cttmeta_valid) {
-            rec.flow_hash_ctt = pkt.cttmeta.flow_hash;
-        }
-#endif /* WITH_CTT */
         PluginStatusConverter plugin_status_converter(m_plugins_status);
         int ret = 0;
         for (unsigned int i = 0; i < m_plugin_cnt; i++) {