Lines Matching refs:soflow_db_so
410 db->soflow_db_so = so; in soflow_db_init()
428 …struct socket *so = (hash_entry && hash_entry->soflow_db) ? hash_entry->soflow_db->soflow_db_so : … in soflow_entry_free()
450 …SOFLOW_LOG(LOG_INFO, db->soflow_db_so, hash_entry->soflow_debug, "<Close nstat> - context %lX", (u… in soflow_db_remove_entry()
465 soflow_feat_detach_entry_func_ptr(db->soflow_db_so, hash_entry); in soflow_db_remove_entry()
493 …SOFLOW_LOG(LOG_INFO, db->soflow_db_so, db->soflow_db_debug, "<db %p> freeing db (count == %d)", db… in soflow_db_free()
498 SOFLOW_ENTRY_LOG(LOG_INFO, db->soflow_db_so, entry, entry->soflow_debug, "Remove entry"); in soflow_db_free()
504 soflow_feat_detach_db_func_ptr(db->soflow_db_so, db); in soflow_db_free()
562 struct inpcb *inp = sotoinpcb(db->soflow_db_so); in soflow_db_lookup_entry_internal()
582 matchentry.soflow_debug = SOFLOW_ENABLE_DEBUG(db->soflow_db_so, (&matchentry)); in soflow_db_lookup_entry_internal()
583 SOFLOW_ENTRY_LOG(LOG_DEBUG, db->soflow_db_so, &matchentry, true, "Looking for entry"); in soflow_db_lookup_entry_internal()
603 …SOFLOW_ENTRY_LOG(LOG_DEBUG, db->soflow_db_so, nextentry, nextentry->soflow_debug, "Found entry v6"… in soflow_db_lookup_entry_internal()
608 …SOFLOW_ENTRY_LOG(LOG_DEBUG, db->soflow_db_so, nextentry, nextentry->soflow_debug, "Found entry v4"… in soflow_db_lookup_entry_internal()
615 …SOFLOW_ENTRY_LOG(LOG_DEBUG, db->soflow_db_so, &matchentry, matchentry.soflow_debug, "Entry not fou… in soflow_db_lookup_entry_internal()
641 …SOFLOW_ENTRY_LOG(LOG_DEBUG, db->soflow_db_so, nextentry, nextentry->soflow_debug, "Looking at entr… in soflow_db_lookup_by_feature_context_id()
644 …SOFLOW_ENTRY_LOG(LOG_DEBUG, db->soflow_db_so, nextentry, nextentry->soflow_debug, "Found entry by … in soflow_db_lookup_by_feature_context_id()
650 …SOFLOW_LOG(LOG_DEBUG, db->soflow_db_so, db->soflow_db_debug, "No entry found for featureID %llu <c… in soflow_db_lookup_by_feature_context_id()
662 if (db == NULL || db->soflow_db_so == NULL || feature_context_id == 0) { in soflow_db_get_feature_context()
666 socket_lock_assert_owned(db->soflow_db_so); in soflow_db_get_feature_context()
678 …SOFLOW_ENTRY_LOG(LOG_DEBUG, db->soflow_db_so, db->soflow_db_only_entry, db->soflow_db_only_entry->… in soflow_db_get_feature_context()
681 …SOFLOW_LOG(LOG_DEBUG, db->soflow_db_so, db->soflow_db_debug, "MISMATCHED only entry for featureID … in soflow_db_get_feature_context()
702 if (db == NULL || db->soflow_db_so == NULL) { in soflow_db_get_feature_context_id()
706 socket_lock_assert_owned(db->soflow_db_so); in soflow_db_get_feature_context_id()
732 struct inpcb *inp = db ? sotoinpcb(db->soflow_db_so) : NULL; in soflow_db_add_entry()
756 entry->soflow_debug = SOFLOW_ENABLE_DEBUG(db->soflow_db_so, entry); in soflow_db_add_entry()
770 socket_lock_assert_owned(db->soflow_db_so); in soflow_db_add_entry()
783 SOFLOW_LOG(LOG_INFO, db->soflow_db_so, db->soflow_db_debug, "total count %d", db->soflow_db_count); in soflow_db_add_entry()
862 struct inpcb *inp = sotoinpcb(db->soflow_db_so); in soflow_entry_update_local()
871 SOFLOW_ENTRY_LOG(LOG_INFO, db->soflow_db_so, entry, entry->soflow_debug, "Updated outifp"); in soflow_entry_update_local()
913 SOFLOW_ENTRY_LOG(LOG_INFO, db->soflow_db_so, entry, entry->soflow_debug, "Updated address"); in soflow_entry_update_local()
917 if (soflow_entry_local_port_needs_update(db->soflow_db_so, entry)) { in soflow_entry_update_local()
920 SOFLOW_ENTRY_LOG(LOG_INFO, db->soflow_db_so, entry, entry->soflow_debug, "Updated port"); in soflow_entry_update_local()
956 …struct socket *so = (hash_entry && hash_entry->soflow_db) ? hash_entry->soflow_db->soflow_db_so : … in soflow_nstat_provider_request_vals()
1089 …struct socket *so = (hash_entry && hash_entry->soflow_db) ? hash_entry->soflow_db->soflow_db_so : … in soflow_nstat_provider_request_extensions()
1142 …struct socket *so = (hash_entry && hash_entry->soflow_db) ? hash_entry->soflow_db->soflow_db_so : … in soflow_update_flow_stats()
1386 …struct socket *so = (hash_entry && hash_entry->soflow_db) ? hash_entry->soflow_db->soflow_db_so : … in soflow_gc_idle_timed_out()
1474 so = hash_entry->soflow_db ? hash_entry->soflow_db->soflow_db_so : NULL; in soflow_gc_expire()
1544 if (db == NULL || db->soflow_db_so == NULL || entry_apply_fn == NULL) { in soflow_db_apply()
1548 socket_lock_assert_owned(db->soflow_db_so); in soflow_db_apply()
1559 if (entry_apply_fn(db->soflow_db_so, entry, context) == false) { in soflow_db_apply()