Home
last modified time | relevance | path

Searched refs:sqd (Results 1 - 9 of 9) sorted by relevance

/kernel/linux/linux-6.6/io_uring/
H A Dsqpoll.c27 void io_sq_thread_unpark(struct io_sq_data *sqd)
28 __releases(&sqd->lock)
30 WARN_ON_ONCE(sqd->thread == current);
36 clear_bit(IO_SQ_THREAD_SHOULD_PARK, &sqd->state);
37 if (atomic_dec_return(&sqd->park_pending))
38 set_bit(IO_SQ_THREAD_SHOULD_PARK, &sqd->state);
39 mutex_unlock(&sqd->lock);
42 void io_sq_thread_park(struct io_sq_data *sqd)
43 __acquires(&sqd->lock)
45 WARN_ON_ONCE(sqd
54 io_sq_thread_stop(struct io_sq_data *sqd) io_sq_thread_stop() argument
67 io_put_sq_data(struct io_sq_data *sqd) io_put_sq_data() argument
77 io_sqd_update_thread_idle(struct io_sq_data *sqd) io_sqd_update_thread_idle() argument
89 struct io_sq_data *sqd = ctx->sq_data; io_sq_thread_finish() local
105 struct io_sq_data *sqd; io_attach_sq_data() local
135 struct io_sq_data *sqd; io_get_sq_data() local
162 io_sqd_events_pending(struct io_sq_data *sqd) io_sqd_events_pending() argument
205 io_sqd_handle_event(struct io_sq_data *sqd) io_sqd_handle_event() argument
224 struct io_sq_data *sqd = data; io_sq_thread() local
364 struct io_sq_data *sqd; io_sq_offload_create() local
436 struct io_sq_data *sqd = ctx->sq_data; io_sqpoll_wq_cpu_affinity() local
[all...]
H A Dsqpoll.h8 /* ctx's that are using this sqd */
25 void io_sq_thread_stop(struct io_sq_data *sqd);
26 void io_sq_thread_park(struct io_sq_data *sqd);
27 void io_sq_thread_unpark(struct io_sq_data *sqd);
28 void io_put_sq_data(struct io_sq_data *sqd);
H A Dio_uring.c3089 struct io_sq_data *sqd = ctx->sq_data; in io_ring_exit_work() local
3092 io_sq_thread_park(sqd); in io_ring_exit_work()
3093 tsk = sqd->thread; in io_ring_exit_work()
3097 io_sq_thread_unpark(sqd); in io_ring_exit_work()
3323 * requests. @sqd should be not-null IFF it's an SQPOLL thread cancellation.
3325 __cold void io_uring_cancel_generic(bool cancel_all, struct io_sq_data *sqd) in io_uring_cancel_generic() argument
3334 WARN_ON_ONCE(sqd && sqd->thread != current); in io_uring_cancel_generic()
3351 if (!sqd) { in io_uring_cancel_generic()
3360 list_for_each_entry(ctx, &sqd in io_uring_cancel_generic()
4287 struct io_sq_data *sqd = NULL; global() variable
4333 io_put_sq_data(sqd); global() variable
4359 io_put_sq_data(sqd); global() variable
[all...]
H A Dio_uring.h71 __cold void io_uring_cancel_generic(bool cancel_all, struct io_sq_data *sqd);
/kernel/linux/linux-5.10/io_uring/
H A Dio_uring.c283 /* ctx's that are using this sqd */
1084 static void io_uring_cancel_generic(bool cancel_all, struct io_sq_data *sqd);
7426 static inline bool io_sqd_events_pending(struct io_sq_data *sqd) in io_sqd_events_pending() argument
7428 return READ_ONCE(sqd->state); in io_sqd_events_pending()
7487 static void io_sqd_update_thread_idle(struct io_sq_data *sqd) in io_sqd_update_thread_idle() argument
7492 list_for_each_entry(ctx, &sqd->ctx_list, sqd_list) in io_sqd_update_thread_idle()
7494 sqd->sq_thread_idle = sq_thread_idle; in io_sqd_update_thread_idle()
7497 static bool io_sqd_handle_event(struct io_sq_data *sqd) in io_sqd_handle_event() argument
7502 if (test_bit(IO_SQ_THREAD_SHOULD_PARK, &sqd->state) || in io_sqd_handle_event()
7504 mutex_unlock(&sqd in io_sqd_handle_event()
7515 struct io_sq_data *sqd = data; io_sq_thread() local
8063 io_sq_thread_stop(struct io_sq_data *sqd) io_sq_thread_stop() argument
8076 io_put_sq_data(struct io_sq_data *sqd) io_put_sq_data() argument
8088 struct io_sq_data *sqd = ctx->sq_data; io_sq_thread_finish() local
8104 struct io_sq_data *sqd; io_attach_sq_data() local
8134 struct io_sq_data *sqd; io_get_sq_data() local
8736 struct io_sq_data *sqd; io_sq_offload_create() local
9517 struct io_sq_data *sqd = ctx->sq_data; io_ring_exit_work() local
9868 io_uring_cancel_generic(bool cancel_all, struct io_sq_data *sqd) io_uring_cancel_generic() argument
10798 struct io_sq_data *sqd = NULL; global() variable
10845 io_put_sq_data(sqd); global() variable
10871 io_put_sq_data(sqd); global() variable
[all...]
/kernel/linux/linux-5.10/drivers/staging/rtl8712/
H A Drtl8712_recv.c866 struct smooth_rssi_data *sqd = &padapter->recvpriv.signal_qual_data; in process_link_qual() local
875 if (sqd->total_num++ >= PHY_LINKQUALITY_SLID_WIN_MAX) { in process_link_qual()
876 sqd->total_num = PHY_LINKQUALITY_SLID_WIN_MAX; in process_link_qual()
877 last_evm = sqd->elements[sqd->index]; in process_link_qual()
878 sqd->total_val -= last_evm; in process_link_qual()
880 sqd->total_val += pattrib->signal_qual; in process_link_qual()
881 sqd->elements[sqd->index++] = pattrib->signal_qual; in process_link_qual()
882 if (sqd in process_link_qual()
[all...]
H A Drtl871x_mlme.c286 struct smooth_rssi_data *sqd = &padapter->recvpriv.signal_qual_data; in update_network() local
294 last_evm = sqd->elements[sqd->index]; in update_network()
300 sqd->elements[sqd->index++] = src->Rssi; in update_network()
/kernel/linux/linux-6.6/drivers/staging/rtl8712/
H A Drtl8712_recv.c867 struct smooth_rssi_data *sqd = &padapter->recvpriv.signal_qual_data; in process_link_qual() local
876 if (sqd->total_num++ >= PHY_LINKQUALITY_SLID_WIN_MAX) { in process_link_qual()
877 sqd->total_num = PHY_LINKQUALITY_SLID_WIN_MAX; in process_link_qual()
878 last_evm = sqd->elements[sqd->index]; in process_link_qual()
879 sqd->total_val -= last_evm; in process_link_qual()
881 sqd->total_val += pattrib->signal_qual; in process_link_qual()
882 sqd->elements[sqd->index++] = pattrib->signal_qual; in process_link_qual()
883 if (sqd in process_link_qual()
[all...]
H A Drtl871x_mlme.c285 struct smooth_rssi_data *sqd = &padapter->recvpriv.signal_qual_data; in update_network() local
293 last_evm = sqd->elements[sqd->index]; in update_network()
299 sqd->elements[sqd->index++] = src->Rssi; in update_network()

Completed in 45 milliseconds