Merge pull request #34 from isaac129/deliver

Add a function to push flow state to open
Active-Telemetry · Feb 18, 2018 · 3d24ad2 · 3d24ad2
2 parents acf1af9 + 74dad30
commit 3d24ad2
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 0 deletions.
diff --git a/ginetflow.c b/ginetflow.c
@@ -1059,3 +1059,11 @@ GInetFlow *g_inet_flow_lookup(GInetFlowTable * table, GInetTuple * tuple)
     packet.hash = 0;
     return (GInetFlow *) g_hash_table_lookup(table->table, &packet);
 }
+
+void g_inet_flow_establish(GInetFlowTable * table, GInetFlow * flow)
+{
+    remove_flow_by_expiry(table, flow, flow->lifetime);
+    flow->state = FLOW_OPEN;
+    flow->lifetime = G_INET_FLOW_DEFAULT_OPEN_TIMEOUT;
+    insert_flow_by_expiry(table, flow, flow->lifetime);
+}
diff --git a/ginetflow.h b/ginetflow.h
@@ -54,6 +54,7 @@ GInetFlow *g_inet_flow_get_full(GInetFlowTable * table, const guint8 * frame,
                                 const uint8_t ** iphr);
 GInetFlow *g_inet_flow_create(GInetFlowTable * table, GInetTuple * tuple);
 GInetFlow *g_inet_flow_expire(GInetFlowTable * table, guint64 ts);
+void g_inet_flow_establish(GInetFlowTable * table, GInetFlow * flow);
 
 /* g_inet_flow_parse will populate result if result is not null, otherwise it will malloc a structure
  * to return. */