| /linux/drivers/infiniband/hw/hfi1/ |
| H A D | iowait.c | 12 void iowait_set_flag(struct iowait *wait, u32 flag) in iowait_set_flag() argument
14 trace_hfi1_iowait_set(wait, flag); in iowait_set_flag()
15 set_bit(flag, &wait->flags); in iowait_set_flag()
18 bool iowait_flag_set(struct iowait *wait, u32 flag) in iowait_flag_set() argument
20 return test_bit(flag, &wait->flags); in iowait_flag_set()
23 inline void iowait_clear_flag(struct iowait *wait, u32 flag) in iowait_clear_flag() argument
25 trace_hfi1_iowait_clear(wait, flag); in iowait_clear_flag()
26 clear_bit(flag, &wait->flags); in iowait_clear_flag()
41 void iowait_init(struct iowait *wait, u32 tx_limit, in iowait_init() argument
45 struct iowait_work *wait, in iowait_init() argument
[all …]
|
| H A D | trace_iowait.h | 17 TP_PROTO(struct iowait *wait, u32 flag),
18 TP_ARGS(wait, flag),
26 __entry->addr = (unsigned long)wait;
27 __entry->flags = wait->flags;
29 __entry->qpn = iowait_to_qp(wait)->ibqp.qp_num;
41 TP_PROTO(struct iowait *wait, u32 flag),
42 TP_ARGS(wait, flag));
45 TP_PROTO(struct iowait *wait, u32 flag),
46 TP_ARGS(wait, flag));
|
| H A D | vnic_sdma.c | 155 ret = sdma_send_txreq(sde, iowait_get_ib_work(&vnic_sdma->wait), in hfi1_vnic_send_dma()
163 iowait_starve_clear(vnic_sdma->pkts_sent, &vnic_sdma->wait); in hfi1_vnic_send_dma()
187 struct iowait_work *wait, in hfi1_vnic_sdma_sleep() argument
193 container_of(wait->iow, struct hfi1_vnic_sdma, wait); in hfi1_vnic_sdma_sleep()
202 if (list_empty(&vnic_sdma->wait.list)) { in hfi1_vnic_sdma_sleep()
203 iowait_get_priority(wait->iow); in hfi1_vnic_sdma_sleep()
204 iowait_queue(pkts_sent, wait->iow, &sde->dmawait); in hfi1_vnic_sdma_sleep()
217 static void hfi1_vnic_sdma_wakeup(struct iowait *wait, int reason) in hfi1_vnic_sdma_wakeup() argument
220 container_of(wait, struct hfi1_vnic_sdma, wait); in hfi1_vnic_sdma_wakeup()
243 iowait_init(&vnic_sdma->wait, 0, NULL, NULL, in hfi1_vnic_sdma_init()
[all …]
|
| /linux/drivers/gpu/drm/nouveau/nvif/ |
| H A D | timer.c | 26 nvif_timer_wait_test(struct nvif_timer_wait *wait) in nvif_timer_wait_test() argument
28 u64 time = nvif_device_time(wait->device); in nvif_timer_wait_test()
30 if (wait->reads == 0) { in nvif_timer_wait_test()
31 wait->time0 = time; in nvif_timer_wait_test()
32 wait->time1 = time; in nvif_timer_wait_test()
35 if (wait->time1 == time) { in nvif_timer_wait_test()
36 if (WARN_ON(wait->reads++ == 16)) in nvif_timer_wait_test()
39 wait->time1 = time; in nvif_timer_wait_test()
40 wait->reads = 1; in nvif_timer_wait_test()
43 if (wait->time1 - wait->time0 > wait->limit) in nvif_timer_wait_test()
[all …]
|
| /linux/drivers/net/ethernet/cisco/enic/ |
| H A D | vnic_dev.c | 213 int wait) in _vnic_dev_cmd() argument
242 for (delay = 0; delay < wait; delay++) { in _vnic_dev_cmd()
281 int wait) in _vnic_dev_cmd2() argument
332 for (delay = 0; delay < wait; delay++) { in _vnic_dev_cmd2()
440 u64 *a0, u64 *a1, int wait) in vnic_dev_cmd_proxy() argument
452 err = vdev->devcmd_rtn(vdev, proxy_cmd, wait); in vnic_dev_cmd_proxy()
473 enum vnic_devcmd_cmd cmd, u64 *a0, u64 *a1, int wait) in vnic_dev_cmd_no_proxy() argument
480 err = vdev->devcmd_rtn(vdev, cmd, wait); in vnic_dev_cmd_no_proxy()
501 u64 *a0, u64 *a1, int wait) in vnic_dev_cmd() argument
508 a0, a1, wait); in vnic_dev_cmd()
[all …]
|
| H A D | enic_res.c | 119 int wait = 1000; in enic_add_vlan() local
122 err = vnic_dev_cmd(enic->vdev, CMD_VLAN_ADD, &a0, &a1, wait); in enic_add_vlan()
132 int wait = 1000; in enic_del_vlan() local
135 err = vnic_dev_cmd(enic->vdev, CMD_VLAN_DEL, &a0, &a1, wait); in enic_del_vlan()
149 int wait = 1000; in enic_set_nic_cfg() local
162 return vnic_dev_cmd(enic->vdev, cmd, &a0, &a1, wait); in enic_set_nic_cfg()
168 int wait = 1000; in enic_set_rss_key() local
170 return vnic_dev_cmd(enic->vdev, CMD_RSS_KEY, &a0, &a1, wait); in enic_set_rss_key()
176 int wait = 1000; in enic_set_rss_cpu() local
178 return vnic_dev_cmd(enic->vdev, CMD_RSS_CPU, &a0, &a1, wait); in enic_set_rss_cpu()
[all …]
|
| /linux/drivers/gpu/drm/nouveau/nvkm/subdev/timer/ |
| H A D | base.c | 27 nvkm_timer_wait_test(struct nvkm_timer_wait *wait) in nvkm_timer_wait_test() argument
29 struct nvkm_subdev *subdev = &wait->tmr->subdev; in nvkm_timer_wait_test()
30 u64 time = nvkm_timer_read(wait->tmr); in nvkm_timer_wait_test()
32 if (wait->reads == 0) { in nvkm_timer_wait_test()
33 wait->time0 = time; in nvkm_timer_wait_test()
34 wait->time1 = time; in nvkm_timer_wait_test()
37 if (wait->time1 == time) { in nvkm_timer_wait_test()
38 if (wait->reads++ == 16) { in nvkm_timer_wait_test()
43 wait->time1 = time; in nvkm_timer_wait_test()
44 wait->reads = 1; in nvkm_timer_wait_test()
[all …]
|
| /linux/fs/ |
| H A D | fs_pin.c | 16 spin_lock_irq(&pin->wait.lock); in pin_remove()
18 wake_up_locked(&pin->wait); in pin_remove()
19 spin_unlock_irq(&pin->wait.lock); in pin_remove()
32 wait_queue_entry_t wait; in pin_kill() local
38 init_wait(&wait); in pin_kill()
39 spin_lock_irq(&p->wait.lock); in pin_kill()
42 spin_unlock_irq(&p->wait.lock); in pin_kill()
48 spin_unlock_irq(&p->wait.lock); in pin_kill()
52 __add_wait_queue(&p->wait, &wait); in pin_kill()
55 spin_unlock_irq(&p->wait.lock); in pin_kill()
[all …]
|
| /linux/kernel/sched/ |
| H A D | completion.c | 25 raw_spin_lock_irqsave(&x->wait.lock, flags); in complete_with_flags()
29 swake_up_locked(&x->wait, wake_flags); in complete_with_flags()
30 raw_spin_unlock_irqrestore(&x->wait.lock, flags); in complete_with_flags()
78 raw_spin_lock_irqsave(&x->wait.lock, flags); in complete_all()
80 swake_up_all_locked(&x->wait); in complete_all()
81 raw_spin_unlock_irqrestore(&x->wait.lock, flags); in complete_all()
90 DECLARE_SWAITQUEUE(wait); in do_wait_for_common()
97 __prepare_to_swait(&x->wait, &wait); in do_wait_for_common()
99 raw_spin_unlock_irq(&x->wait.lock); in do_wait_for_common()
101 raw_spin_lock_irq(&x->wait.lock); in do_wait_for_common()
[all …]
|
| H A D | swait.c | 85 void __prepare_to_swait(struct swait_queue_head *q, struct swait_queue *wait) in __prepare_to_swait() argument
87 wait->task = current; in __prepare_to_swait()
88 if (list_empty(&wait->task_list)) in __prepare_to_swait()
89 list_add_tail(&wait->task_list, &q->task_list); in __prepare_to_swait()
92 void prepare_to_swait_exclusive(struct swait_queue_head *q, struct swait_queue *wait, int state) in prepare_to_swait_exclusive() argument
97 __prepare_to_swait(q, wait); in prepare_to_swait_exclusive()
103 long prepare_to_swait_event(struct swait_queue_head *q, struct swait_queue *wait, int state) in prepare_to_swait_event() argument
114 list_del_init(&wait->task_list); in prepare_to_swait_event()
117 __prepare_to_swait(q, wait); in prepare_to_swait_event()
126 void __finish_swait(struct swait_queue_head *q, struct swait_queue *wait) in __finish_swait() argument
[all …]
|
| /linux/include/linux/ |
| H A D | smp.h | 51 int wait);
54 void *info, bool wait, const struct cpumask *mask);
69 static inline void on_each_cpu(smp_call_func_t func, void *info, int wait) in on_each_cpu() argument
71 on_each_cpu_cond_mask(NULL, func, info, wait, cpu_online_mask); in on_each_cpu()
80 * @wait: If true, wait (atomically) until function has completed
83 * If @wait is true, then returns once @func has returned.
91 smp_call_func_t func, void *info, bool wait) in on_each_cpu_mask() argument
93 on_each_cpu_cond_mask(NULL, func, info, wait, mask); in on_each_cpu_mask()
103 smp_call_func_t func, void *info, bool wait) in on_each_cpu_cond() argument
202 smp_call_function(func,info,wait) global() argument
206 smp_call_function_many(mask,func,info,wait) global() argument
212 smp_call_function_any(const struct cpumask * mask,smp_call_func_t func,void * info,int wait) smp_call_function_any() argument
[all...] |
| /linux/drivers/scsi/fnic/ |
| H A D | vnic_dev.c | 62 int wait);
249 static int vnic_dev_cmd1(struct vnic_dev *vdev, enum vnic_devcmd_cmd cmd, int wait) in vnic_dev_cmd1() argument
283 for (delay = 0; delay < wait; delay++) { in vnic_dev_cmd1()
312 int wait) in vnic_dev_cmd2() argument
379 for (delay = 0; delay < wait; delay++) { in vnic_dev_cmd2()
501 enum vnic_devcmd_cmd cmd, u64 *a0, u64 *a1, int wait) in vnic_dev_cmd_no_proxy() argument
508 err = (*vdev->devcmd_rtn)(vdev, cmd, wait); in vnic_dev_cmd_no_proxy()
518 u64 *a0, u64 *a1, int wait) in vnic_dev_cmd() argument
525 return vnic_dev_cmd_no_proxy(vdev, cmd, a0, a1, wait); in vnic_dev_cmd()
534 int wait = 1000; in vnic_dev_fw_info() local
[all …]
|
| /linux/net/core/ |
| H A D | stream.c | 45 wake_up_interruptible_poll(&wq->wait, EPOLLOUT | in sk_stream_write_space()
62 DEFINE_WAIT_FUNC(wait, woken_wake_function); in sk_stream_wait_connect()
77 add_wait_queue(sk_sleep(sk), &wait); in sk_stream_wait_connect()
82 ~(TCPF_ESTABLISHED | TCPF_CLOSE_WAIT)), &wait); in sk_stream_wait_connect()
83 remove_wait_queue(sk_sleep(sk), &wait); in sk_stream_wait_connect()
103 DEFINE_WAIT_FUNC(wait, woken_wake_function); in sk_stream_wait_close()
105 add_wait_queue(sk_sleep(sk), &wait); in sk_stream_wait_close()
108 if (sk_wait_event(sk, &timeout, !sk_stream_closing(sk), &wait)) in sk_stream_wait_close()
112 remove_wait_queue(sk_sleep(sk), &wait); in sk_stream_wait_close()
127 DEFINE_WAIT_FUNC(wait, woken_wake_function); in sk_stream_wait_memory()
[all …]
|
| /linux/fs/f2fs/ |
| H A D | gc.h | 146 unsigned int *wait) in increase_sleep_time() argument
151 if (*wait == gc_th->no_gc_sleep_time) in increase_sleep_time()
154 if ((long long)*wait + (long long)min_time > (long long)max_time) in increase_sleep_time()
155 *wait = max_time; in increase_sleep_time()
157 *wait += min_time; in increase_sleep_time()
161 unsigned int *wait) in decrease_sleep_time() argument
165 if (*wait == gc_th->no_gc_sleep_time) in decrease_sleep_time()
166 *wait = gc_th->max_sleep_time; in decrease_sleep_time()
168 if ((long long)*wait - (long long)min_time < (long long)min_time) in decrease_sleep_time()
169 *wait = min_time; in decrease_sleep_time()
[all …]
|
| /linux/drivers/scsi/snic/ |
| H A D | vnic_dev.c | 55 int wait);
248 int wait) in _svnic_dev_cmd2() argument
315 for (delay = 0; delay < wait; delay++) { in _svnic_dev_cmd2()
434 u64 *a0, u64 *a1, int wait) in svnic_dev_cmd() argument
442 err = (*vdev->devcmd_rtn)(vdev, cmd, wait); in svnic_dev_cmd()
454 int wait = VNIC_DVCMD_TMO; in svnic_dev_fw_info() local
467 err = svnic_dev_cmd(vdev, CMD_MCPU_FW_INFO, &a0, &a1, wait); in svnic_dev_fw_info()
479 int wait = VNIC_DVCMD_TMO; in svnic_dev_spec() local
485 err = svnic_dev_cmd(vdev, CMD_DEV_SPEC, &a0, &a1, wait); in svnic_dev_spec()
511 int wait = VNIC_DVCMD_TMO; in svnic_dev_stats_clear() local
[all …]
|
| /linux/net/atm/ |
| H A D | svc.c | 13 #include <linux/wait.h>
53 DEFINE_WAIT(wait); in svc_disconnect()
61 prepare_to_wait(sk_sleep(sk), &wait, TASK_UNINTERRUPTIBLE); in svc_disconnect()
66 finish_wait(sk_sleep(sk), &wait); in svc_disconnect()
103 DEFINE_WAIT(wait); in svc_bind()
137 prepare_to_wait(sk_sleep(sk), &wait, TASK_UNINTERRUPTIBLE); in svc_bind()
142 finish_wait(sk_sleep(sk), &wait); in svc_bind()
159 DEFINE_WAIT(wait); in svc_connect()
219 prepare_to_wait(sk_sleep(sk), &wait, TASK_INTERRUPTIBLE); in svc_connect()
223 prepare_to_wait(sk_sleep(sk), &wait, in svc_connect()
[all...] |
| /linux/drivers/gpu/drm/nouveau/nvkm/core/ |
| H A D | event.c | 98 nvkm_event_ntfy_block_(struct nvkm_event_ntfy *ntfy, bool wait) in nvkm_event_ntfy_block_() argument
102 nvkm_trace(subdev, "event: ntfy block %08x on %d wait:%d\n", ntfy->bits, ntfy->id, wait); in nvkm_event_ntfy_block_()
106 if (wait) in nvkm_event_ntfy_block_()
115 nvkm_event_ntfy_block_(ntfy, ntfy->wait); in nvkm_event_ntfy_block()
125 if (ntfy->wait) in nvkm_event_ntfy_allow()
146 nvkm_event_ntfy_add(struct nvkm_event *event, int id, u32 bits, bool wait, nvkm_event_func func, in nvkm_event_ntfy_add() argument
149 nvkm_trace(event->subdev, "event: ntfy add %08x on %d wait:%d\n", id, bits, wait); in nvkm_event_ntfy_add()
154 ntfy->wait = wait; in nvkm_event_ntfy_add()
159 if (!ntfy->wait) in nvkm_event_ntfy_add()
|
| /linux/fs/squashfs/ |
| H A D | decompressor_multi.c | 42 wait_queue_head_t wait; member
58 wake_up(&stream->wait); in put_decomp_stream()
75 init_waitqueue_head(&stream->wait); in squashfs_decompressor_create()
148 goto wait; in get_decomp_stream()
153 goto wait; in get_decomp_stream()
159 goto wait; in get_decomp_stream()
167 wait: in get_decomp_stream()
174 wait_event(stream->wait, in get_decomp_stream()
|
| /linux/include/trace/events/ |
| H A D | module.h | 109 TP_PROTO(char *name, bool wait, unsigned long ip),
111 TP_ARGS(name, wait, ip),
115 __field( bool, wait )
121 __entry->wait = wait;
125 TP_printk("%s wait=%d call_site=%ps",
126 __get_str(name), (int)__entry->wait, (void *)__entry->ip)
|
| /linux/drivers/hid/ |
| H A D | hid-roccat.c | 44 wait_queue_head_t wait; member
80 DECLARE_WAITQUEUE(wait, current); in roccat_read()
86 add_wait_queue(&device->wait, &wait); in roccat_read()
111 remove_wait_queue(&device->wait, &wait); in roccat_read()
137 static __poll_t roccat_poll(struct file *file, poll_table *wait) in roccat_poll() argument
140 poll_wait(file, &reader->device->wait, wait); in roccat_poll()
283 wake_up_interruptible(&device->wait); in roccat_report_event()
338 init_waitqueue_head(&device->wait); in roccat_connect()
373 wake_up_interruptible(&device->wait); in roccat_disconnect()
|
| /linux/drivers/gpu/drm/msm/disp/ |
| H A D | mdp_kms.c | 81 struct mdp_irq_wait *wait = in wait_irq() local
83 wait->count--; in wait_irq()
89 struct mdp_irq_wait wait = { in mdp_irq_wait() local
96 mdp_irq_register(mdp_kms, &wait.irq); in mdp_irq_wait()
97 wait_event_timeout(wait_event, (wait.count <= 0), in mdp_irq_wait()
99 mdp_irq_unregister(mdp_kms, &wait.irq); in mdp_irq_wait()
|
| /linux/drivers/crypto/xilinx/ |
| H A D | xilinx-trng.c | 107 static size_t xtrng_readblock32(void __iomem *rng_base, __be32 *buf, int blocks32, bool wait) in xtrng_readblock32() argument
114 if (wait) in xtrng_readblock32()
121 TRNG_STATUS_QCNT_16_BYTES, !!wait, timeout); in xtrng_readblock32()
134 int no_of_random_bytes, bool wait) in xtrng_collect_random_data() argument
145 ret = xtrng_readblock32(rng->rng_base, (__be32 *)rand_gen_buf, blocks, wait); in xtrng_collect_random_data()
152 ret = xtrng_readblock32(rng->rng_base, (__be32 *)randbuf, 1, wait); in xtrng_collect_random_data()
230 u32 rand_buf_size, int wait) in xtrng_random_bytes_generate() argument
238 nbytes = xtrng_collect_random_data(rng, rand_buf_ptr, rand_buf_size, wait); in xtrng_random_bytes_generate()
290 static int xtrng_hwrng_trng_read(struct hwrng *hwrng, void *data, size_t max, bool wait) in xtrng_hwrng_trng_read() argument
298 if (!mutex_trylock(&rng->lock) && !wait) in xtrng_hwrng_trng_read()
[all …]
|
| /linux/drivers/crypto/caam/ |
| H A D | caamrng.c | 147 static int caam_read(struct hwrng *rng, void *dst, size_t max, bool wait) in caam_read() argument
152 if (wait) { in caam_read()
176 static inline void test_len(struct hwrng *rng, size_t len, bool wait) in test_len() argument
188 read_len = rng->read(rng, buf, len, wait); in test_len()
190 if (read_len < 0 || (read_len == 0 && wait)) { in test_len()
207 static inline void test_mode_once(struct hwrng *rng, bool wait) in test_mode_once() argument
209 test_len(rng, 32, wait); in test_mode_once()
210 test_len(rng, 64, wait); in test_mode_once()
211 test_len(rng, 128, wait); in test_mode_once()
|
| /linux/drivers/isdn/mISDN/ |
| H A D | timerdev.c | 31 wait_queue_head_t wait; member
58 init_waitqueue_head(&dev->wait); in mISDN_open()
112 wait_event_interruptible(dev->wait, (dev->work || in mISDN_read()
136 mISDN_poll(struct file *filep, poll_table *wait) in mISDN_poll() argument
142 printk(KERN_DEBUG "%s(%p, %p)\n", __func__, filep, wait); in mISDN_poll()
144 poll_wait(filep, &dev->wait, wait); in mISDN_poll()
164 wake_up_interruptible(&timer->dev->wait); in dev_expire_timer()
176 wake_up_interruptible(&dev->wait); in misdn_add_timer()
|
| /linux/drivers/net/ethernet/chelsio/cxgb3/ |
| H A D | aq100x.c | 65 static int aq100x_reset(struct cphy *phy, int wait) in aq100x_reset() argument
269 unsigned int v, v2, gpio, wait; in t3_aq100x_phy_prep() local
290 wait = 500; /* in 10ms increments */ in t3_aq100x_phy_prep()
305 } while (v && --wait); in t3_aq100x_phy_prep()
314 wait = (500 - wait) * 10 + 1000; in t3_aq100x_phy_prep()
315 if (wait > 3000) in t3_aq100x_phy_prep()
316 CH_WARN(adapter, "PHY%d: reset took %ums\n", phy_addr, wait); in t3_aq100x_phy_prep()
|