Home
last modified time | relevance | path

Searched refs:fob (Results 1 – 6 of 6) sorted by relevance

/xnu-8792.41.9/bsd/skywalk/nexus/flowswitch/flow/
H A Dflow_owner.c48 struct flow_owner_bucket *fob; in flow_owner_buckets_alloc() local
53 *fob_sz = P2ROUNDUP(sizeof(*fob), cache_sz); in flow_owner_buckets_alloc()
74 fob = (struct flow_owner_bucket *) in flow_owner_buckets_alloc()
76 fob_pbuf = (void **)((intptr_t)fob - sizeof(void *)); in flow_owner_buckets_alloc()
78 ASSERT(((intptr_t)fob + (fob_cnt * (*fob_sz))) <= in flow_owner_buckets_alloc()
83 "(total %zu bytes, fob_buf 0x%llx) ALLOC", SK_KVA(fob), fob_cnt, in flow_owner_buckets_alloc()
86 return fob; in flow_owner_buckets_alloc()
90 flow_owner_buckets_free(struct flow_owner_bucket *fob, size_t tot_sz) in flow_owner_buckets_free() argument
95 fob_pbuf = (void **)((intptr_t)fob - sizeof(void *)); in flow_owner_buckets_free()
97 SK_DF(SK_VERB_MEM, "fob 0x%llx (fob_buf 0x%llx) FREE", SK_KVA(fob), in flow_owner_buckets_free()
[all …]
H A Dflow_manager.c211 struct flow_owner_bucket *fob = flow_mgr_get_fob_at_idx(fm, i); in flow_mgr_create() local
212 flow_owner_bucket_init(fob); in flow_mgr_create()
214 *(size_t *)(uintptr_t)&fob->fob_idx = i; in flow_mgr_create()
274 struct flow_owner_bucket *fob = in flow_mgr_destroy() local
276 ASSERT(fob->fob_idx == i); in flow_mgr_destroy()
277 flow_owner_bucket_destroy(fob); in flow_mgr_destroy()
342 struct flow_owner_bucket *fob = in flow_mgr_terminate() local
344 FOB_LOCK(fob); in flow_mgr_terminate()
345 fob->fob_busy_flags |= FOBF_DEAD; in flow_mgr_terminate()
348 struct flow_owner_bucket *fob = in flow_mgr_terminate() local
[all …]
H A Dflow_entry.c158 flow_owner_find_by_pid(struct flow_owner_bucket *fob, pid_t pid, void *context, in flow_owner_find_by_pid() argument
165 FOB_LOCK_ASSERT_HELD(fob); in flow_owner_find_by_pid()
166 return RB_FIND(flow_owner_tree, &fob->fob_owner_head, &find); in flow_owner_find_by_pid()
/xnu-8792.41.9/bsd/skywalk/nexus/flowswitch/
H A Dfsw_flow.c43 struct flow_owner_bucket *fob; in fsw_flow_add() local
101 fob = flow_mgr_get_fob_by_pid(fm, pid); in fsw_flow_add()
102 FOB_LOCK_SPIN(fob); in fsw_flow_add()
103 while (fob->fob_busy_flags & (FOBF_OPEN_BUSY | FOBF_CLOSE_BUSY)) { in fsw_flow_add()
104 if (++(fob->fob_open_waiters) == 0) { /* wraparound */ in fsw_flow_add()
105 fob->fob_open_waiters++; in fsw_flow_add()
107 if ((*error = msleep(&fob->fob_open_waiters, &fob->fob_lock, in fsw_flow_add()
112 ASSERT(fob->fob_open_waiters > 0); in fsw_flow_add()
113 fob->fob_open_waiters--; in fsw_flow_add()
114 FOB_UNLOCK(fob); in fsw_flow_add()
[all …]
H A Dfsw.c1802 struct flow_owner_bucket *fob = flow_mgr_get_fob_at_idx(fm, i); in fsw_mib_get_flow_owner() local
1803 FOB_LOCK(fob); in fsw_mib_get_flow_owner()
1804 RB_FOREACH(fo, flow_owner_tree, &fob->fob_owner_head) { in fsw_mib_get_flow_owner()
1813 FOB_UNLOCK(fob); in fsw_mib_get_flow_owner()
H A Dfsw_dp.c3784 struct flow_owner_bucket *fob = flow_mgr_get_fob_at_idx(fm, i); in fsw_process_deferred() local
3791 if (!FOB_TRY_LOCK(fob)) { in fsw_process_deferred()
3795 FOB_LOCK(fob); in fsw_process_deferred()
3798 FOB_LOCK_ASSERT_HELD(fob); in fsw_process_deferred()
3799 RB_FOREACH(fo, flow_owner_tree, &fob->fob_owner_head) { in fsw_process_deferred()
3838 FOB_UNLOCK(fob); in fsw_process_deferred()