| /drivers/staging/lustre/lustre/ptlrpc/ |
| D | sec_gc.c | 150 struct l_wait_info lwi; in sec_gc_main() local
187 lwi = LWI_TIMEOUT(SEC_GC_INTERVAL * HZ, NULL, NULL); in sec_gc_main()
191 &lwi); in sec_gc_main()
204 struct l_wait_info lwi = { 0 }; in sptlrpc_gc_init() local
222 thread_is_running(&sec_gc_thread), &lwi); in sptlrpc_gc_init()
228 struct l_wait_info lwi = { 0 }; in sptlrpc_gc_fini() local
234 thread_is_stopped(&sec_gc_thread), &lwi); in sptlrpc_gc_fini()
|
| D | pinger.c | 233 struct l_wait_info lwi; in ptlrpc_pinger_main() local
270 lwi = LWI_TIMEOUT(max_t(long, time_to_next_wake, in ptlrpc_pinger_main()
276 &lwi); in ptlrpc_pinger_main()
295 struct l_wait_info lwi = { 0 }; in ptlrpc_start_pinger() local
313 thread_is_running(&pinger_thread), &lwi); in ptlrpc_start_pinger()
322 struct l_wait_info lwi = { 0 }; in ptlrpc_stop_pinger() local
334 thread_is_stopped(&pinger_thread), &lwi); in ptlrpc_stop_pinger()
|
| D | import.c | 270 struct l_wait_info lwi; in ptlrpc_invalidate_import() local
308 lwi = LWI_TIMEOUT_INTERVAL( in ptlrpc_invalidate_import()
314 &lwi); in ptlrpc_invalidate_import()
431 struct l_wait_info lwi; in ptlrpc_reconnect_import() local
440 lwi = LWI_TIMEOUT(secs, NULL, NULL); in ptlrpc_reconnect_import()
442 !ptlrpc_import_in_recovery(imp), &lwi); in ptlrpc_reconnect_import()
455 struct l_wait_info lwi = LWI_INTR(LWI_ON_SIGNAL_NOOP, NULL); in ptlrpc_reconnect_import()
459 &lwi); in ptlrpc_reconnect_import()
1442 struct l_wait_info lwi; in ptlrpc_disconnect_import() local
1457 lwi = LWI_TIMEOUT_INTR(cfs_timeout_cap(timeout), in ptlrpc_disconnect_import()
[all …]
|
| D | recover.c | 348 struct l_wait_info lwi; in ptlrpc_recover_import() local
354 lwi = LWI_TIMEOUT(secs, NULL, NULL); in ptlrpc_recover_import()
356 !ptlrpc_import_in_recovery(imp), &lwi); in ptlrpc_recover_import()
|
| D | ptlrpcd.c | 238 struct l_wait_info lwi = LWI_TIMEOUT(cfs_time_seconds(5), in ptlrpcd_add_req() local
243 l_wait_event(req->rq_set_waitq, (req->rq_set == NULL), &lwi); in ptlrpcd_add_req()
432 struct l_wait_info lwi; in ptlrpcd() local
436 lwi = LWI_TIMEOUT(cfs_time_seconds(timeout ? timeout : 1), in ptlrpcd()
441 ptlrpcd_check(&env, pc), &lwi); in ptlrpcd()
|
| D | events.c | 490 struct l_wait_info lwi; in ptlrpc_ni_fini() local
515 lwi = LWI_TIMEOUT(cfs_time_seconds(2), NULL, NULL); in ptlrpc_ni_fini()
516 l_wait_event(waitq, 0, &lwi); in ptlrpc_ni_fini()
|
| D | service.c | 1943 struct l_wait_info lwi = LWI_TIMEOUT(svcpt->scp_rqbd_timeout, in ptlrpc_wait_event() local
1957 ptlrpc_at_check(svcpt), &lwi); in ptlrpc_wait_event()
2277 struct l_wait_info lwi = { 0 }; in ptlrpc_svcpt_stop_threads() local
2307 thread_is_stopped(thread), &lwi); in ptlrpc_svcpt_stop_threads()
2369 struct l_wait_info lwi = { 0 }; in ptlrpc_start_thread() local
2466 &lwi); in ptlrpc_start_thread()
2555 struct l_wait_info lwi = LWI_TIMEOUT(cfs_time_seconds(10), in ptlrpc_wait_replies() local
2559 atomic_read(&svcpt->scp_nreps_difficult) == 0, &lwi); in ptlrpc_wait_replies()
2585 struct l_wait_info lwi; in ptlrpc_service_unlink_rqbd() local
2621 lwi = LWI_TIMEOUT_INTERVAL( in ptlrpc_service_unlink_rqbd()
[all …]
|
| D | niobuf.c | 245 struct l_wait_info lwi; in ptlrpc_unregister_bulk() local
284 lwi = LWI_TIMEOUT_INTERVAL(cfs_time_seconds(LONG_UNLINK), in ptlrpc_unregister_bulk()
286 rc = l_wait_event(*wq, !ptlrpc_client_bulk_active(req), &lwi); in ptlrpc_unregister_bulk()
|
| D | client.c | 2076 struct l_wait_info lwi; in ptlrpc_set_wait() local
2109 lwi = LWI_TIMEOUT_INTR_ALL(cfs_time_seconds(1), in ptlrpc_set_wait()
2118 lwi = LWI_TIMEOUT(cfs_time_seconds(timeout ? timeout : 1), in ptlrpc_set_wait()
2121 rc = l_wait_event(set->set_waitq, ptlrpc_check_set(NULL, set), &lwi); in ptlrpc_set_wait()
2128 if (rc == -ETIMEDOUT && !lwi.lwi_allow_intr && in ptlrpc_set_wait()
2322 struct l_wait_info lwi; in ptlrpc_unregister_reply() local
2364 lwi = LWI_TIMEOUT_INTERVAL(cfs_time_seconds(LONG_UNLINK), in ptlrpc_unregister_reply()
2367 &lwi); in ptlrpc_unregister_reply()
|
| /drivers/staging/lustre/lustre/include/ |
| D | lustre_lib.h | 636 struct l_wait_info lwi = { 0 }; \
637 l_wait_event(wq, condition, &lwi); \
642 struct l_wait_info lwi = { 0 }; \
643 l_wait_event_exclusive(wq, condition, &lwi); \
648 struct l_wait_info lwi = { 0 }; \
649 l_wait_event_exclusive_head(wq, condition, &lwi); \
|
| /drivers/staging/lustre/lustre/llite/ |
| D | statahead.c | 957 struct l_wait_info lwi = { 0 }; in ll_agl_thread() local
978 &lwi); in ll_agl_thread()
1018 struct l_wait_info lwi = { 0 }; in ll_start_agl() local
1036 &lwi); in ll_start_agl()
1054 struct l_wait_info lwi = { 0 }; in ll_statahead_thread() local
1142 &lwi); in ll_statahead_thread()
1200 &lwi); in ll_statahead_thread()
1256 &lwi); in ll_statahead_thread()
1303 struct l_wait_info lwi = { 0 }; in ll_stop_statahead() local
1315 &lwi); in ll_stop_statahead()
[all …]
|
| D | llite_close.c | 335 struct l_wait_info lwi = { 0 }; in ll_close_thread() local
341 &lwi); in ll_close_thread()
|
| /drivers/staging/lustre/lustre/ldlm/ |
| D | ldlm_pool.c | 1021 struct l_wait_info lwi; in ldlm_pools_thread_main() local
1032 lwi = LWI_TIMEOUT(cfs_time_seconds(c_time), in ldlm_pools_thread_main()
1037 &lwi); in ldlm_pools_thread_main()
1055 struct l_wait_info lwi = { 0 }; in ldlm_pools_thread_start() local
1077 thread_is_running(ldlm_pools_thread), &lwi); in ldlm_pools_thread_start()
|
| D | ldlm_flock.c | 451 struct l_wait_info lwi; in ldlm_flock_completion_ast() local
500 lwi = LWI_TIMEOUT_INTR(0, NULL, ldlm_flock_interrupted_wait, &fwd); in ldlm_flock_completion_ast()
503 rc = l_wait_event(lock->l_waitq, is_granted_or_cancelled(lock), &lwi); in ldlm_flock_completion_ast()
|
| D | ldlm_request.c | 220 struct l_wait_info lwi; in ldlm_completion_ast() local
254 lwi = LWI_INTR(interrupted_completion_wait, &lwd); in ldlm_completion_ast()
256 lwi = LWI_TIMEOUT_INTR(cfs_time_seconds(timeout), in ldlm_completion_ast()
274 is_granted_or_cancelled(lock), &lwi); in ldlm_completion_ast()
|
| D | ldlm_resource.c | 862 struct l_wait_info lwi = LWI_INTR(LWI_ON_SIGNAL_NOOP, NULL); in __ldlm_namespace_free() local
870 lwi = LWI_TIMEOUT(obd_timeout * HZ / 4, NULL, NULL); in __ldlm_namespace_free()
873 atomic_read(&ns->ns_bref) == 0, &lwi); in __ldlm_namespace_free()
|
| /drivers/staging/lustre/lustre/obdclass/ |
| D | llog_obd.c | 109 struct l_wait_info lwi = LWI_INTR(LWI_ON_SIGNAL_NOOP, NULL); in llog_cleanup() local
138 llog_group_ctxt_null(olg, idx), &lwi); in llog_cleanup()
|
| D | genops.c | 1251 struct l_wait_info lwi = { 0 }; in obd_zombie_barrier() local
1256 l_wait_event(obd_zombie_waitq, obd_zombie_is_idle(), &lwi); in obd_zombie_barrier()
1271 struct l_wait_info lwi = { 0 }; in obd_zombie_impexp_thread() local
1274 !obd_zombie_impexp_check(NULL), &lwi); in obd_zombie_impexp_thread()
|
| D | cl_io.c | 1548 struct l_wait_info lwi = LWI_TIMEOUT_INTR(cfs_time_seconds(timeout), in cl_sync_io_wait() local
1556 &lwi); in cl_sync_io_wait()
1563 lwi = (struct l_wait_info) { 0 }; in cl_sync_io_wait()
1566 &lwi); in cl_sync_io_wait()
|
| /drivers/staging/lustre/lustre/fld/ |
| D | fld_request.c | 75 struct l_wait_info lwi = { 0 }; in fld_enter_request() local
82 l_wait_event(mcw.mcw_waitq, fld_req_avail(cli, &mcw), &lwi); in fld_enter_request()
|
| /drivers/staging/lustre/lustre/mgc/ |
| D | mgc_request.c | 516 struct l_wait_info lwi; in mgc_requeue_thread() local
536 lwi = LWI_TIMEOUT(to, NULL, NULL); in mgc_requeue_thread()
538 &lwi); in mgc_requeue_thread()
585 lwi = (struct l_wait_info) { 0 }; in mgc_requeue_thread()
587 &lwi); in mgc_requeue_thread()
|
| /drivers/staging/lustre/lustre/lov/ |
| D | lov_request.c | 150 struct l_wait_info lwi; in lov_check_and_wait_active() local
176 lwi = LWI_TIMEOUT_INTERVAL(cfs_time_seconds(obd_timeout), in lov_check_and_wait_active()
179 rc = l_wait_event(waitq, lov_check_set(lov, ost_idx), &lwi); in lov_check_and_wait_active()
|
| /drivers/staging/lustre/lustre/mdc/ |
| D | mdc_lib.c | 503 struct l_wait_info lwi = LWI_INTR(LWI_ON_SIGNAL_NOOP, NULL); in mdc_enter_request() local
511 &lwi); in mdc_enter_request()
|
| /drivers/staging/lustre/lustre/osc/ |
| D | osc_cache.c | 905 struct l_wait_info lwi = LWI_TIMEOUT_INTR(cfs_time_seconds(600), NULL, in osc_extent_wait() local
928 rc = l_wait_event(ext->oe_waitq, extent_wait_cb(ext, state), &lwi); in osc_extent_wait()
934 lwi = LWI_INTR(LWI_ON_SIGNAL_NOOP, NULL); in osc_extent_wait()
936 &lwi); in osc_extent_wait()
1534 struct l_wait_info lwi = LWI_INTR(LWI_ON_SIGNAL_NOOP, NULL); in osc_enter_cache() local
1575 rc = l_wait_event(ocw.ocw_waitq, ocw_granted(cli, &ocw), &lwi); in osc_enter_cache()
|
| D | osc_page.c | 874 struct l_wait_info lwi = LWI_INTR(LWI_ON_SIGNAL_NOOP, NULL); in osc_lru_reserve() local
903 &lwi); in osc_lru_reserve()
|