X-Git-Url: https://gerrit.fd.io/r/gitweb?a=blobdiff_plain;f=src%2Fplugins%2Fnat%2Fnat44%2Finlines.h;h=541770ad102e18204cd651738734ba094932d6a1;hb=1a0a89770688a37e500f634b68805b1984eccac0;hp=631c4cd4104f04f59f145e20e7c33a1150c563d7;hpb=8daeea9a5dc2c68c8e54fe7bdae98cec7072a9cd;p=vpp.git

diff --git a/src/plugins/nat/nat44/inlines.h b/src/plugins/nat/nat44/inlines.h
index 631c4cd4104..541770ad102 100644
--- a/src/plugins/nat/nat44/inlines.h
+++ b/src/plugins/nat/nat44/inlines.h
@@ -31,19 +31,6 @@ nat44_maximum_sessions_exceeded (snat_main_t * sm, u32 thread_index)
   return 0;
 }
 
-static_always_inline f64
-nat44_minimal_timeout (snat_main_t * sm)
-{
-  f64 min_timeout;
-
-  min_timeout = clib_min (sm->udp_timeout, sm->icmp_timeout);
-  min_timeout = clib_min (min_timeout, sm->icmp_timeout);
-  min_timeout = clib_min (min_timeout, sm->tcp_transitory_timeout);
-  min_timeout = clib_min (min_timeout, sm->tcp_established_timeout);
-
-  return min_timeout;
-}
-
 static_always_inline snat_session_t *
 nat44_session_reuse_old (snat_main_t * sm, snat_user_t * u,
 			 snat_session_t * s, u32 thread_index, f64 now)
@@ -66,7 +53,6 @@ nat44_session_reuse_old (snat_main_t * sm, snat_user_t * u,
   return s;
 }
 
-
 static_always_inline snat_session_t *
 nat44_session_alloc_new (snat_main_per_thread_data_t * tsm, snat_user_t * u,
 			 f64 now)
@@ -122,7 +108,6 @@ nat44_user_del_sessions (snat_user_t * u, u32 thread_index)
       elt = pool_elt_at_index (tsm->list_pool, elt->next);
 
       nat44_free_session_data (sm, s, thread_index, 0);
-      // TODO: needs refactoring as in nat44_user_session_cleanup
       nat44_delete_session (sm, s, thread_index);
     }
 }
@@ -172,161 +157,6 @@ nat44_user_del (ip4_address_t * addr, u32 fib_index)
   return rv;
 }
 
-static_always_inline u32
-nat44_user_session_cleanup (snat_user_t * u, u32 thread_index, f64 now)
-{
-  u32 cleared = 0;
-  dlist_elt_t *elt;
-  snat_session_t *s;
-  u64 sess_timeout_time;
-
-  snat_main_t *sm = &snat_main;
-  snat_main_per_thread_data_t *tsm = &sm->per_thread_data[thread_index];
-
-  if (now < u->min_session_timeout)
-    goto done;
-  u->min_session_timeout = now + sm->min_timeout;
-
-  // get head
-  elt = pool_elt_at_index (tsm->list_pool,
-			   u->sessions_per_user_list_head_index);
-  // get first element
-  elt = pool_elt_at_index (tsm->list_pool, elt->next);
-
-  while (elt->value != ~0)
-    {
-      s = pool_elt_at_index (tsm->sessions, elt->value);
-      elt = pool_elt_at_index (tsm->list_pool, elt->next);
-
-      sess_timeout_time = s->last_heard +
-	(f64) nat44_session_get_timeout (sm, s);
-
-      if (s->tcp_close_timestamp)
-	{
-	  sess_timeout_time =
-	    clib_min (sess_timeout_time, s->tcp_close_timestamp);
-	}
-
-      if (now < sess_timeout_time)
-	continue;
-
-      // do cleanup of this call (refactor for ED NAT44 only)
-      nat44_free_session_data (sm, s, thread_index, 0);
-
-      clib_dlist_remove (tsm->list_pool, s->per_user_index);
-      pool_put_index (tsm->list_pool, s->per_user_index);
-      clib_dlist_remove (tsm->global_lru_pool, s->global_lru_index);
-      pool_put_index (tsm->global_lru_pool, s->global_lru_index);
-      pool_put (tsm->sessions, s);
-      vlib_set_simple_counter (&sm->total_sessions, thread_index, 0,
-			       pool_elts (tsm->sessions));
-
-      if (snat_is_session_static (s))
-	u->nstaticsessions--;
-      else
-	u->nsessions--;
-
-      cleared++;
-    }
-done:
-  return cleared;
-}
-
-static_always_inline u32
-nat44_users_cleanup (u32 thread_index, f64 now)
-{
-  snat_main_t *sm = &snat_main;
-  snat_main_per_thread_data_t *tsm;
-
-  u32 cleared = 0;
-
-  snat_user_key_t u_key;
-  clib_bihash_kv_8_8_t kv;
-
-  snat_user_t *u = 0;
-  u32 pool_index;
-
-  tsm = vec_elt_at_index (sm->per_thread_data, thread_index);
-
-  if (now < tsm->min_session_timeout)
-    goto done;
-  tsm->min_session_timeout = now + sm->min_timeout;
-  // consider
-  tsm->cleanup_timeout = tsm->min_session_timeout;
-
-  pool_index = ~0;
-  do
-    {
-      pool_index = pool_next_index (tsm->users, pool_index);
-      if (pool_index == ~0)
-	break;
-      u = pool_elt_at_index (tsm->users, pool_index);
-
-      cleared += nat44_user_session_cleanup (u, thread_index, now);
-
-      if (u->nstaticsessions == 0 && u->nsessions == 0)
-	{
-	  u_key.addr.as_u32 = u->addr.as_u32;
-	  u_key.fib_index = u->fib_index;
-	  kv.key = u_key.as_u64;
-
-	  // delete user
-	  pool_put_index (tsm->list_pool,
-			  u->sessions_per_user_list_head_index);
-	  pool_put (tsm->users, u);
-	  clib_bihash_add_del_8_8 (&tsm->user_hash, &kv, 0);
-
-	  // update total users counter
-	  vlib_set_simple_counter (&sm->total_users, thread_index, 0,
-				   pool_elts (tsm->users));
-	}
-    }
-  while (1);
-  tsm->cleared += cleared;
-  tsm->cleanup_runs++;
-done:
-  return cleared;
-}
-
-static_always_inline u32
-nat44_out_of_ports_cleanup (u32 thread_index, f64 now)
-{
-  return nat44_users_cleanup (thread_index, now);
-}
-
-static_always_inline u32
-nat44_max_translations_per_user_cleanup (snat_user_t * u, u32 thread_index,
-					 f64 now)
-{
-  return nat44_user_session_cleanup (u, thread_index, now);
-}
-
-static_always_inline u32
-nat44_force_users_cleanup (void)
-{
-  snat_main_t *sm = &snat_main;
-  snat_main_per_thread_data_t *tsm;
-
-  f64 now = vlib_time_now (vlib_get_main ());
-  u32 cleared = 0;
-
-  if (sm->num_workers > 1)
-    {
-      /* *INDENT-OFF* */
-      vec_foreach (tsm, sm->per_thread_data)
-        {
-          cleared += nat44_users_cleanup (tsm->thread_index, now);
-        }
-      /* *INDENT-ON* */
-    }
-  else
-    {
-      tsm = vec_elt_at_index (sm->per_thread_data, sm->num_workers);
-      cleared += nat44_users_cleanup (tsm->thread_index, now);
-    }
-  return cleared;
-}
-
 #endif /* included_nat44_inlines_h__ */
 
 /*