| /dports/net-im/libsignal-client/libsignal-client-0.9.6/cargo-crates/neon-0.9.1/src/ |
| H A D | lifecycle.rs | 34 drop_queue: Arc<ThreadsafeFunction<NapiRef>>, field
65 let drop_queue = unsafe { in get() localVariable
79 drop_queue: Arc::new(drop_queue), in get()
88 pub(crate) fn drop_queue<'a, C: Context<'a>>(cx: &mut C) -> Arc<ThreadsafeFunction<NapiRef>> { in drop_queue() method
89 Arc::clone(&InstanceData::get(cx).drop_queue) in drop_queue()
|
| /dports/net-im/libsignal-client/libsignal-client-0.9.6/cargo-crates/neon-0.9.1/src/handle/ |
| H A D | root.rs | 39 drop_queue: Arc<ThreadsafeFunction<NapiRef>>, field
72 drop_queue: InstanceData::drop_queue(cx), in new()
100 drop_queue: Arc::clone(&self.drop_queue), in clone()
193 let _ = self.drop_queue.call(internal.clone(), None); in drop()
|
| /dports/multimedia/libv4l/linux-5.13-rc2/net/core/ |
| H A D | drop_monitor.c | 83 struct sk_buff_head drop_queue; member
515 spin_lock_irqsave(&data->drop_queue.lock, flags); in net_dm_packet_trace_kfree_skb_hit()
517 __skb_queue_tail(&data->drop_queue, nskb); in net_dm_packet_trace_kfree_skb_hit()
705 spin_lock_irqsave(&data->drop_queue.lock, flags); in net_dm_packet_work()
924 spin_lock_irqsave(&hw_data->drop_queue.lock, flags); in net_dm_hw_packet_work()
962 spin_lock_irqsave(&hw_data->drop_queue.lock, flags); in net_dm_hw_trap_packet_probe()
964 __skb_queue_tail(&hw_data->drop_queue, nskb); in net_dm_hw_trap_packet_probe()
1157 while ((skb = __skb_dequeue(&data->drop_queue))) in net_dm_trace_on_set()
1186 while ((skb = __skb_dequeue(&data->drop_queue))) in net_dm_trace_off_set()
1664 skb_queue_head_init(&data->drop_queue); in __net_dm_cpu_data_init()
[all …]
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/net/core/ |
| H A D | drop_monitor.c | 83 struct sk_buff_head drop_queue; member
515 spin_lock_irqsave(&data->drop_queue.lock, flags); in net_dm_packet_trace_kfree_skb_hit()
517 __skb_queue_tail(&data->drop_queue, nskb); in net_dm_packet_trace_kfree_skb_hit()
705 spin_lock_irqsave(&data->drop_queue.lock, flags); in net_dm_packet_work()
924 spin_lock_irqsave(&hw_data->drop_queue.lock, flags); in net_dm_hw_packet_work()
962 spin_lock_irqsave(&hw_data->drop_queue.lock, flags); in net_dm_hw_trap_packet_probe()
964 __skb_queue_tail(&hw_data->drop_queue, nskb); in net_dm_hw_trap_packet_probe()
1157 while ((skb = __skb_dequeue(&data->drop_queue))) in net_dm_trace_on_set()
1186 while ((skb = __skb_dequeue(&data->drop_queue))) in net_dm_trace_off_set()
1664 skb_queue_head_init(&data->drop_queue); in __net_dm_cpu_data_init()
[all …]
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/net/core/ |
| H A D | drop_monitor.c | 83 struct sk_buff_head drop_queue; member
515 spin_lock_irqsave(&data->drop_queue.lock, flags); in net_dm_packet_trace_kfree_skb_hit()
517 __skb_queue_tail(&data->drop_queue, nskb); in net_dm_packet_trace_kfree_skb_hit()
705 spin_lock_irqsave(&data->drop_queue.lock, flags); in net_dm_packet_work()
924 spin_lock_irqsave(&hw_data->drop_queue.lock, flags); in net_dm_hw_packet_work()
962 spin_lock_irqsave(&hw_data->drop_queue.lock, flags); in net_dm_hw_trap_packet_probe()
964 __skb_queue_tail(&hw_data->drop_queue, nskb); in net_dm_hw_trap_packet_probe()
1157 while ((skb = __skb_dequeue(&data->drop_queue))) in net_dm_trace_on_set()
1186 while ((skb = __skb_dequeue(&data->drop_queue))) in net_dm_trace_off_set()
1664 skb_queue_head_init(&data->drop_queue); in __net_dm_cpu_data_init()
[all …]
|
| /dports/misc/rump/buildrump.sh-b914579/src/sys/altq/ |
| H A D | altq_wfq.c | 294 wfq *drop_queue = wfq_maxqueue(wfqp); in wfq_ifenqueue() local
297 mp = drop_queue->head; in wfq_ifenqueue()
298 if ((drop_queue->head = mp->m_nextpkt) == NULL) in wfq_ifenqueue()
299 drop_queue->tail = NULL; in wfq_ifenqueue()
302 drop_queue->bytes -= byte; in wfq_ifenqueue()
303 PKTCNTR_ADD(&drop_queue->drop_cnt, byte); in wfq_ifenqueue()
307 if(drop_queue == queue) in wfq_ifenqueue()
|
| /dports/devel/erlang-sbroker/sbroker-1.0.0/src/ |
| H A D | sbroker_timeout_queue.erl | 332 drop_queue(Time, Q),
338 drop_queue(Time, Q),
346 drop_queue(Time, DropQ),
392 _ = drop_queue(Time, DropQ),
396 _ = drop_queue(Time, DropQ),
402 drop_queue(Time, Q) -> function
|
| H A D | sbroker_drop_queue.erl | 241 drop_queue(Time, DropQ),
246 drop_queue(Time, DropQ),
253 drop_queue(Time, Q) -> function
|
| H A D | sbroker_codel_queue.erl | 505 drop_queue(Time, Q) -> function
526 drop_queue(Time, DropQ),
530 drop_queue(Time, DropQ),
|
| /dports/devel/erlang-sbroker/sbroker-1.0.0/test/ |
| H A D | sbroker_fq_queue.erl | 88 drop_queue(Time, DropQ),
144 drop_queue(Time, Q) -> function
|
| H A D | sbroker_statem_queue.erl | 140 drop_queue(Time, DropQ),
143 drop_queue(Time, Q) -> function
|
| /dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/src/app/netschedule/test/ |
| H A D | test_netschedule_smoke.py | 25 self.drop_queue()
|
| H A D | ns.py | 99 def drop_queue(self): member in Connection
|