| /kernel/linux/linux-5.10/block/ |
| D | blk-exec.c | 1 // SPDX-License-Identifier: GPL-2.0
3 * Functions related to setting various queue properties from drivers
9 #include <linux/blk-mq.h>
13 #include "blk-mq-sched.h"
16 * blk_end_sync_rq - executes a completion event on a request
22 struct completion *waiting = rq->end_io_data; in blk_end_sync_rq()
24 rq->end_io_data = (void *)(uintptr_t)error; in blk_end_sync_rq()
34 * blk_execute_rq_nowait - insert a request into queue for execution
35 * @q: queue to insert the request in
38 * @at_head: insert request at head or tail of queue
[all …]
|
| /kernel/linux/linux-6.6/tools/testing/selftests/netfilter/ |
| D | nft_queue.sh | 7 # Kselftest framework requirement - SKIP code is 4.
11 sfx=$(mktemp -u "XXXXXXXX")
12 ns1="ns1-$sfx"
13 ns2="ns2-$sfx"
14 nsrouter="nsrouter-$sfx"
26 rm -f "$TMPFILE0"
27 rm -f "$TMPFILE1"
28 rm -f "$TMPFILE2" "$TMPFILE3"
31 nft --version > /dev/null 2>&1
32 if [ $? -ne 0 ];then
[all …]
|
| /kernel/linux/linux-6.6/drivers/infiniband/hw/hfi1/ |
| D | iowait.h | 1 /* SPDX-License-Identifier: GPL-2.0 or BSD-3-Clause */
3 * Copyright(c) 2015 - 2018 Intel Corporation.
11 #include <linux/wait.h>
17 * typedef (*restart_t)() - restart callback
57 * @list: used to add/insert into QP/PQ wait lists
63 * @lock: lock protected head of wait queue
65 * @wait_dma: wait for sdma_busy == 0
66 * @wait_pio: wait for pio_busy == 0
71 * @flags: wait flags (one per QP)
72 * @wait: SE array for multiple legs
[all …]
|
| /kernel/linux/linux-6.6/drivers/net/wwan/iosm/ |
| D | iosm_ipc_task_queue.h | 1 /* SPDX-License-Identifier: GPL-2.0-only
3 * Copyright (C) 2020-21 Intel Corporation.
9 /* Number of available element for the input message queue of the IPC
15 * struct ipc_task_queue_args - Struct for Task queue elements
18 * @completion: OS object used to wait for the tasklet function to finish for
40 * struct ipc_task_queue - Struct for Task queue
41 * @q_lock: Protect the message queue of the ipc ipc_task
42 * @args: Message queue of the IPC ipc_task
43 * @q_rpos: First queue element to process.
44 * @q_wpos: First free element of the input queue.
[all …]
|
| D | iosm_ipc_task_queue.c | 1 // SPDX-License-Identifier: GPL-2.0-only
3 * Copyright (C) 2020-21 Intel Corporation.
10 * Calls event handler involves callback for each element in the message queue
15 unsigned int q_rpos = ipc_task->q_rpos; in ipc_task_queue_handler()
17 /* Loop over the input queue contents. */ in ipc_task_queue_handler()
18 while (q_rpos != ipc_task->q_wpos) { in ipc_task_queue_handler()
19 /* Get the current first queue element. */ in ipc_task_queue_handler()
20 struct ipc_task_queue_args *args = &ipc_task->args[q_rpos]; in ipc_task_queue_handler()
23 if (args->func) in ipc_task_queue_handler()
24 args->response = args->func(args->ipc_imem, args->arg, in ipc_task_queue_handler()
[all …]
|
| /kernel/linux/linux-5.10/kernel/sched/ |
| D | wait.c | 1 // SPDX-License-Identifier: GPL-2.0-only
11 spin_lock_init(&wq_head->lock); in __init_waitqueue_head()
12 lockdep_set_class_and_name(&wq_head->lock, key, name); in __init_waitqueue_head()
13 INIT_LIST_HEAD(&wq_head->head); in __init_waitqueue_head()
22 wq_entry->flags &= ~WQ_FLAG_EXCLUSIVE; in add_wait_queue()
23 spin_lock_irqsave(&wq_head->lock, flags); in add_wait_queue()
25 spin_unlock_irqrestore(&wq_head->lock, flags); in add_wait_queue()
33 wq_entry->flags |= WQ_FLAG_EXCLUSIVE; in add_wait_queue_exclusive()
34 spin_lock_irqsave(&wq_head->lock, flags); in add_wait_queue_exclusive()
36 spin_unlock_irqrestore(&wq_head->lock, flags); in add_wait_queue_exclusive()
[all …]
|
| /kernel/linux/linux-6.6/kernel/sched/ |
| D | wait.c | 1 // SPDX-License-Identifier: GPL-2.0-only
10 spin_lock_init(&wq_head->lock); in __init_waitqueue_head()
11 lockdep_set_class_and_name(&wq_head->lock, key, name); in __init_waitqueue_head()
12 INIT_LIST_HEAD(&wq_head->head); in __init_waitqueue_head()
21 wq_entry->flags &= ~WQ_FLAG_EXCLUSIVE; in add_wait_queue()
22 spin_lock_irqsave(&wq_head->lock, flags); in add_wait_queue()
24 spin_unlock_irqrestore(&wq_head->lock, flags); in add_wait_queue()
32 wq_entry->flags |= WQ_FLAG_EXCLUSIVE; in add_wait_queue_exclusive()
33 spin_lock_irqsave(&wq_head->lock, flags); in add_wait_queue_exclusive()
35 spin_unlock_irqrestore(&wq_head->lock, flags); in add_wait_queue_exclusive()
[all …]
|
| /kernel/linux/linux-5.10/drivers/infiniband/hw/hfi1/ |
| D | iowait.h | 4 * Copyright(c) 2015 - 2018 Intel Corporation.
26 * - Redistributions of source code must retain the above copyright
28 * - Redistributions in binary form must reproduce the above copyright
32 * - Neither the name of Intel Corporation nor the names of its
52 #include <linux/wait.h>
58 * typedef (*restart_t)() - restart callback
98 * @list: used to add/insert into QP/PQ wait lists
104 * @lock: lock protected head of wait queue
106 * @wait_dma: wait for sdma_busy == 0
107 * @wait_pio: wait for pio_busy == 0
[all …]
|
| /kernel/linux/linux-5.10/include/linux/ |
| D | sbitmap.h | 1 /* SPDX-License-Identifier: GPL-2.0-only */
6 * Copyright (C) 2013-2014 Jens Axboe
18 * struct sbitmap_word - Word in a &struct sbitmap.
37 * @swap_lock: Held while swapping word <-> cleared
43 * struct sbitmap - Scalable bitmap.
45 * A &struct sbitmap is spread over multiple cachelines to avoid ping-pong. This
74 * struct sbq_wait_state - Wait queue in a &struct sbitmap_queue.
83 * @wait: Wait queue.
85 wait_queue_head_t wait; member
89 * struct sbitmap_queue - Scalable bitmap with the added ability to wait on free
[all …]
|
| D | uacce.h | 1 /* SPDX-License-Identifier: GPL-2.0-or-later */
16 * struct uacce_qfile_region - structure of queue file region
24 * struct uacce_ops - uacce device operations
26 * @get_queue: get a queue from the device
27 * @put_queue: free a queue to the device
28 * @start_queue: make the queue start work after get_queue
29 * @stop_queue: make the queue stop work before put_queue
31 * @mmap: mmap addresses of queue to user space
32 * @ioctl: ioctl for user space users of the queue
49 * struct uacce_interface - interface required for uacce_register()
[all …]
|
| /kernel/linux/linux-6.6/include/linux/ |
| D | sbitmap.h | 1 /* SPDX-License-Identifier: GPL-2.0-only */
6 * Copyright (C) 2013-2014 Jens Axboe
22 #include <linux/wait.h>
27 * struct sbitmap_word - Word in a &struct sbitmap.
41 * @swap_lock: serializes simultaneous updates of ->word and ->cleared
47 * struct sbitmap - Scalable bitmap.
49 * A &struct sbitmap is spread over multiple cachelines to avoid ping-pong. This
69 * @round_robin: Allocate bits in strict round-robin order.
81 * This is per-cpu, which allows multiple users to stick to different
91 * struct sbq_wait_state - Wait queue in a &struct sbitmap_queue.
[all …]
|
| D | uacce.h | 1 /* SPDX-License-Identifier: GPL-2.0-or-later */
17 * struct uacce_qfile_region - structure of queue file region
25 * struct uacce_ops - uacce device operations
27 * @get_queue: get a queue from the device
28 * @put_queue: free a queue to the device
29 * @start_queue: make the queue start work after get_queue
30 * @stop_queue: make the queue stop work before put_queue
32 * @mmap: mmap addresses of queue to user space
33 * @ioctl: ioctl for user space users of the queue
56 * struct uacce_interface - interface required for uacce_register()
[all …]
|
| D | wait.h | 1 /* SPDX-License-Identifier: GPL-2.0 */
5 * Linux wait queue related types and methods
12 #include <uapi/linux/wait.h>
28 * A single wait-queue entry structure:
84 wq_entry->flags = 0; in init_waitqueue_entry()
85 wq_entry->private = p; in init_waitqueue_entry()
86 wq_entry->func = default_wake_function; in init_waitqueue_entry()
92 wq_entry->flags = 0; in init_waitqueue_func_entry()
93 wq_entry->private = NULL; in init_waitqueue_func_entry()
94 wq_entry->func = func; in init_waitqueue_func_entry()
[all …]
|
| /kernel/linux/linux-5.10/drivers/block/rnbd/ |
| D | rnbd-clt.c | 1 // SPDX-License-Identifier: GPL-2.0-or-later
5 * Copyright (c) 2014 - 2018 ProfitBricks GmbH. All rights reserved.
6 * Copyright (c) 2018 - 2019 1&1 IONOS Cloud GmbH. All rights reserved.
7 * Copyright (c) 2019 - 2020 1&1 IONOS SE. All rights reserved.
19 #include "rnbd-clt.h"
38 return refcount_inc_not_zero(&sess->refcount); in rnbd_clt_get_sess()
47 if (refcount_dec_and_test(&sess->refcount)) in rnbd_clt_put_sess()
55 if (!refcount_dec_and_test(&dev->refcount)) in rnbd_clt_put_dev()
59 ida_simple_remove(&index_ida, dev->clt_device_id); in rnbd_clt_put_dev()
61 kfree(dev->hw_queues); in rnbd_clt_put_dev()
[all …]
|
| /kernel/linux/linux-5.10/tools/testing/selftests/netfilter/ |
| D | nft_queue.sh | 7 # Kselftest framework requirement - SKIP code is 4.
11 sfx=$(mktemp -u "XXXXXXXX")
12 ns1="ns1-$sfx"
13 ns2="ns2-$sfx"
14 nsrouter="nsrouter-$sfx"
22 rm -f "$TMPFILE0"
23 rm -f "$TMPFILE1"
24 rm -f "$TMPFILE2" "$TMPFILE3"
27 nft --version > /dev/null 2>&1
28 if [ $? -ne 0 ];then
[all …]
|
| /kernel/linux/linux-5.10/drivers/net/ethernet/intel/ice/ |
| D | ice_base.c | 1 // SPDX-License-Identifier: GPL-2.0
10 * __ice_vsi_get_qs_contig - Assign a contiguous chunk of queues to VSI
11 * @qs_cfg: gathered variables needed for PF->VSI queues assignment
13 * Return 0 on success and -ENOMEM in case of no left space in PF queue bitmap
19 mutex_lock(qs_cfg->qs_mutex); in __ice_vsi_get_qs_contig()
20 offset = bitmap_find_next_zero_area(qs_cfg->pf_map, qs_cfg->pf_map_size, in __ice_vsi_get_qs_contig()
21 0, qs_cfg->q_count, 0); in __ice_vsi_get_qs_contig()
22 if (offset >= qs_cfg->pf_map_size) { in __ice_vsi_get_qs_contig()
23 mutex_unlock(qs_cfg->qs_mutex); in __ice_vsi_get_qs_contig()
24 return -ENOMEM; in __ice_vsi_get_qs_contig()
[all …]
|
| /kernel/linux/linux-5.10/drivers/usb/gadget/function/ |
| D | uvc_queue.c | 1 // SPDX-License-Identifier: GPL-2.0+
3 * uvc_queue.c -- USB Video Class driver - Buffers management
5 * Copyright (C) 2005-2010
17 #include <linux/wait.h>
19 #include <media/v4l2-common.h>
20 #include <media/videobuf2-vmalloc.h>
24 /* ------------------------------------------------------------------------
25 * Video buffers queue management.
31 * the videobuf2 queue operations by serializing calls to videobuf2 and a
32 * spinlock to protect the IRQ queue that holds the buffers to be processed by
[all …]
|
| /kernel/linux/linux-6.6/net/core/ |
| D | stream.c | 1 // SPDX-License-Identifier: GPL-2.0
6 * protocols. Even IP. Tonight 8-).
13 * Alan Cox <alan@lxorguk.ukuu.org.uk> (Borrowed comments 8-))
21 #include <linux/wait.h>
25 * sk_stream_write_space - stream socket write_space callback.
32 struct socket *sock = sk->sk_socket; in sk_stream_write_space()
36 clear_bit(SOCK_NOSPACE, &sock->flags); in sk_stream_write_space()
39 wq = rcu_dereference(sk->sk_wq); in sk_stream_write_space()
41 wake_up_interruptible_poll(&wq->wait, EPOLLOUT | in sk_stream_write_space()
43 if (wq && wq->fasync_list && !(sk->sk_shutdown & SEND_SHUTDOWN)) in sk_stream_write_space()
[all …]
|
| /kernel/linux/linux-5.10/net/core/ |
| D | stream.c | 1 // SPDX-License-Identifier: GPL-2.0
6 * protocols. Even IP. Tonight 8-).
13 * Alan Cox <alan@lxorguk.ukuu.org.uk> (Borrowed comments 8-))
21 #include <linux/wait.h>
25 * sk_stream_write_space - stream socket write_space callback.
32 struct socket *sock = sk->sk_socket; in sk_stream_write_space()
36 clear_bit(SOCK_NOSPACE, &sock->flags); in sk_stream_write_space()
39 wq = rcu_dereference(sk->sk_wq); in sk_stream_write_space()
41 wake_up_interruptible_poll(&wq->wait, EPOLLOUT | in sk_stream_write_space()
43 if (wq && wq->fasync_list && !(sk->sk_shutdown & SEND_SHUTDOWN)) in sk_stream_write_space()
[all …]
|
| /kernel/linux/linux-6.6/net/sunrpc/ |
| D | sched.c | 1 // SPDX-License-Identifier: GPL-2.0-only
54 * rpciod-related stuff
62 if (current->flags & PF_WQ_WORKER) in rpc_task_gfp_mask()
70 if (cmpxchg(&task->tk_rpc_status, 0, rpc_status) == 0) in rpc_task_set_rpc_status()
78 unsigned long timeout = READ_ONCE(task->tk_timeout); in rpc_task_timeout()
83 return timeout - now; in rpc_task_timeout()
91 * queue->lock and bh_disabled in order to avoid races within
95 __rpc_disable_timer(struct rpc_wait_queue *queue, struct rpc_task *task) in __rpc_disable_timer() argument
97 if (list_empty(&task->u.tk_wait.timer_list)) in __rpc_disable_timer()
99 task->tk_timeout = 0; in __rpc_disable_timer()
[all …]
|
| /kernel/linux/linux-5.10/net/sunrpc/ |
| D | sched.c | 1 // SPDX-License-Identifier: GPL-2.0-only
54 * rpciod-related stuff
63 unsigned long timeout = READ_ONCE(task->tk_timeout); in rpc_task_timeout()
68 return timeout - now; in rpc_task_timeout()
76 * queue->lock and bh_disabled in order to avoid races within
80 __rpc_disable_timer(struct rpc_wait_queue *queue, struct rpc_task *task) in __rpc_disable_timer() argument
82 if (list_empty(&task->u.tk_wait.timer_list)) in __rpc_disable_timer()
84 task->tk_timeout = 0; in __rpc_disable_timer()
85 list_del(&task->u.tk_wait.timer_list); in __rpc_disable_timer()
86 if (list_empty(&queue->timer_list.list)) in __rpc_disable_timer()
[all …]
|
| /kernel/linux/linux-6.6/drivers/gpu/drm/nouveau/nvkm/engine/gr/fuc/ |
| D | com.fuc | 27 // queue_put - add request to queue
29 // In : $r13 queue pointer
44 // store cmd/data on queue
59 // queue_get - fetch request from queue
61 // In : $r13 queue pointer
89 // nv_rd32 - read 32-bit value from nv register
107 // nv_wr32 - write 32-bit value to nv register
124 // wait_donez - wait on FUC_DONE bit to become clear
126 // In : $r10 bit to wait on
138 // wait_doneo - wait on FUC_DONE bit to become set
[all …]
|
| /kernel/linux/linux-5.10/drivers/gpu/drm/nouveau/nvkm/engine/gr/fuc/ |
| D | com.fuc | 27 // queue_put - add request to queue
29 // In : $r13 queue pointer
44 // store cmd/data on queue
59 // queue_get - fetch request from queue
61 // In : $r13 queue pointer
89 // nv_rd32 - read 32-bit value from nv register
107 // nv_wr32 - write 32-bit value to nv register
124 // wait_donez - wait on FUC_DONE bit to become clear
126 // In : $r10 bit to wait on
138 // wait_doneo - wait on FUC_DONE bit to become set
[all …]
|
| /kernel/linux/linux-6.6/fs/autofs/ |
| D | waitq.c | 1 // SPDX-License-Identifier: GPL-2.0-or-later
3 * Copyright 1997-1998 Transmeta Corporation -- All Rights Reserved
4 * Copyright 2001-2006 Ian Kent <raven@themaw.net>
19 mutex_lock(&sbi->wq_mutex); in autofs_catatonic_mode()
20 if (sbi->flags & AUTOFS_SBI_CATATONIC) { in autofs_catatonic_mode()
21 mutex_unlock(&sbi->wq_mutex); in autofs_catatonic_mode()
27 sbi->flags |= AUTOFS_SBI_CATATONIC; in autofs_catatonic_mode()
28 wq = sbi->queues; in autofs_catatonic_mode()
29 sbi->queues = NULL; /* Erase all wait queues */ in autofs_catatonic_mode()
31 nwq = wq->next; in autofs_catatonic_mode()
[all …]
|
| /kernel/linux/linux-6.6/drivers/usb/gadget/function/ |
| D | uvc_queue.c | 1 // SPDX-License-Identifier: GPL-2.0+
3 * uvc_queue.c -- USB Video Class driver - Buffers management
5 * Copyright (C) 2005-2010
17 #include <linux/wait.h>
19 #include <media/v4l2-common.h>
20 #include <media/videobuf2-dma-sg.h>
21 #include <media/videobuf2-vmalloc.h>
25 /* ------------------------------------------------------------------------
26 * Video buffers queue management.
32 * the videobuf2 queue operations by serializing calls to videobuf2 and a
[all …]
|