Home
last modified time | relevance | path

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

/dports/net/sems/sems-f89581a/core/
H A DAmEventDispatcher.cpp62 queues_mut[queue_bucket].lock(); in addEventQueue()
64 if (queues[queue_bucket].find(local_tag) != queues[queue_bucket].end()) { in addEventQueue()
70 queues_mut[queue_bucket].unlock(); in addEventQueue()
90 queues_mut[queue_bucket].lock(); in addEventQueue()
92 if (queues[queue_bucket].find(local_tag) != queues[queue_bucket].end()) { in addEventQueue()
117 queues_mut[queue_bucket].unlock(); in addEventQueue()
127 queues_mut[queue_bucket].lock(); in delEventQueue()
133 queues[queue_bucket].erase(qi); in delEventQueue()
149 queues_mut[queue_bucket].unlock(); in delEventQueue()
160 queues_mut[queue_bucket].lock(); in post()
[all …]