Revert "remove already_associated variable (#82)"

This reverts commit 2e0e4c6.
althea-net · Jan 4, 2024 · 002425a · 002425a
1 parent 2e0e4c6
commit 002425a
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 2 deletions.
diff --git a/lib/pfcp/context.h b/lib/pfcp/context.h
@@ -112,6 +112,8 @@ typedef struct ogs_pfcp_node_s {
 
     ogs_pfcp_up_function_features_t up_function_features;
     int up_function_features_len;
+
+    bool already_associated;
 } ogs_pfcp_node_t;
 
 typedef enum {

diff --git a/src/sgwc/pfcp-sm.c b/src/sgwc/pfcp-sm.c
@@ -175,7 +175,10 @@ void sgwc_pfcp_state_associated(ogs_fsm_t *s, sgwc_event_t *e)
         ogs_timer_start(node->t_no_heartbeat,
                 ogs_app()->time.message.pfcp.no_heartbeat_duration);
 
-        sgwc_pfcp_resend_established_sessions(node);
+        if (node->already_associated) {
+            sgwc_pfcp_resend_established_sessions(node);
+        }
+        node->already_associated = true;
 
         stats_update_sgwc_pfcp_nodes();
 

diff --git a/src/smf/pfcp-sm.c b/src/smf/pfcp-sm.c
@@ -177,7 +177,10 @@ void smf_pfcp_state_associated(ogs_fsm_t *s, smf_event_t *e)
         ogs_timer_start(node->t_no_heartbeat,
                 ogs_app()->time.message.pfcp.no_heartbeat_duration);
 
-        smf_epc_pfcp_resend_established_sessions(node);
+        if (node->already_associated) {
+            smf_epc_pfcp_resend_established_sessions(node);
+        }
+        node->already_associated = true;
 
         stats_update_smf_pfcp_nodes();