Home
last modified time | relevance | path

Searched refs:sess (Results 1 - 25 of 196) sorted by relevance

12345678

/kernel/linux/linux-6.6/fs/smb/server/mgmt/
H A Duser_session.c30 static void free_channel_list(struct ksmbd_session *sess) in free_channel_list() argument
35 xa_for_each(&sess->ksmbd_chann_list, index, chann) { in free_channel_list()
36 xa_erase(&sess->ksmbd_chann_list, index); in free_channel_list()
40 xa_destroy(&sess->ksmbd_chann_list); in free_channel_list()
43 static void __session_rpc_close(struct ksmbd_session *sess, in __session_rpc_close() argument
48 resp = ksmbd_rpc_close(sess, entry->id); in __session_rpc_close()
57 static void ksmbd_session_rpc_clear_list(struct ksmbd_session *sess) in ksmbd_session_rpc_clear_list() argument
62 xa_for_each(&sess->rpc_handle_list, index, entry) { in ksmbd_session_rpc_clear_list()
63 xa_erase(&sess->rpc_handle_list, index); in ksmbd_session_rpc_clear_list()
64 __session_rpc_close(sess, entr in ksmbd_session_rpc_clear_list()
91 ksmbd_session_rpc_open(struct ksmbd_session *sess, char *rpc_name) ksmbd_session_rpc_open() argument
125 ksmbd_session_rpc_close(struct ksmbd_session *sess, int id) ksmbd_session_rpc_close() argument
134 ksmbd_session_rpc_method(struct ksmbd_session *sess, int id) ksmbd_session_rpc_method() argument
142 ksmbd_session_destroy(struct ksmbd_session *sess) ksmbd_session_destroy() argument
161 struct ksmbd_session *sess; __session_lookup() local
175 struct ksmbd_session *sess; ksmbd_expire_session() local
191 ksmbd_session_register(struct ksmbd_conn *conn, struct ksmbd_session *sess) ksmbd_session_register() argument
200 ksmbd_chann_del(struct ksmbd_conn *conn, struct ksmbd_session *sess) ksmbd_chann_del() argument
214 struct ksmbd_session *sess; ksmbd_sessions_deregister() local
255 struct ksmbd_session *sess; ksmbd_session_lookup() local
267 struct ksmbd_session *sess; ksmbd_session_lookup_slowpath() local
281 struct ksmbd_session *sess; ksmbd_session_lookup_all() local
294 struct preauth_session *sess; ksmbd_preauth_session_alloc() local
308 ksmbd_preauth_session_id_match(struct preauth_session *sess, unsigned long long id) ksmbd_preauth_session_id_match() argument
317 struct preauth_session *sess = NULL; ksmbd_preauth_session_lookup() local
326 __init_smb2_session(struct ksmbd_session *sess) __init_smb2_session() argument
338 struct ksmbd_session *sess; __session_create() local
382 ksmbd_acquire_tree_conn_id(struct ksmbd_session *sess) ksmbd_acquire_tree_conn_id() argument
392 ksmbd_release_tree_conn_id(struct ksmbd_session *sess, int id) ksmbd_release_tree_conn_id() argument
[all...]
H A Dtree_connect.c19 ksmbd_tree_conn_connect(struct ksmbd_conn *conn, struct ksmbd_session *sess, in ksmbd_tree_conn_connect() argument
39 tree_conn->id = ksmbd_acquire_tree_conn_id(sess); in ksmbd_tree_conn_connect()
46 resp = ksmbd_ipc_tree_connect_request(sess, in ksmbd_tree_conn_connect()
74 tree_conn->user = sess->user; in ksmbd_tree_conn_connect()
81 ret = xa_err(xa_store(&sess->tree_conns, tree_conn->id, tree_conn, in ksmbd_tree_conn_connect()
92 ksmbd_release_tree_conn_id(sess, tree_conn->id); in ksmbd_tree_conn_connect()
111 int ksmbd_tree_conn_disconnect(struct ksmbd_session *sess, in ksmbd_tree_conn_disconnect() argument
116 write_lock(&sess->tree_conns_lock); in ksmbd_tree_conn_disconnect()
117 xa_erase(&sess->tree_conns, tree_conn->id); in ksmbd_tree_conn_disconnect()
118 write_unlock(&sess in ksmbd_tree_conn_disconnect()
131 ksmbd_tree_conn_lookup(struct ksmbd_session *sess, unsigned int id) ksmbd_tree_conn_lookup() argument
149 ksmbd_tree_conn_session_logoff(struct ksmbd_session *sess) ksmbd_tree_conn_session_logoff() argument
[all...]
/kernel/linux/linux-5.10/drivers/staging/media/meson/vdec/
H A Dvdec.c40 u32 amvdec_get_output_size(struct amvdec_session *sess) in amvdec_get_output_size() argument
42 return get_output_size(sess->width, sess->height); in amvdec_get_output_size()
46 static int vdec_codec_needs_recycle(struct amvdec_session *sess) in vdec_codec_needs_recycle() argument
48 struct amvdec_codec_ops *codec_ops = sess->fmt_out->codec_ops; in vdec_codec_needs_recycle()
55 struct amvdec_session *sess = data; in vdec_recycle_thread() local
56 struct amvdec_core *core = sess->core; in vdec_recycle_thread()
57 struct amvdec_codec_ops *codec_ops = sess->fmt_out->codec_ops; in vdec_recycle_thread()
61 mutex_lock(&sess->bufs_recycle_lock); in vdec_recycle_thread()
62 list_for_each_entry_safe(tmp, n, &sess in vdec_recycle_thread()
78 vdec_poweron(struct amvdec_session *sess) vdec_poweron() argument
107 vdec_wait_inactive(struct amvdec_session *sess) vdec_wait_inactive() argument
115 vdec_poweroff(struct amvdec_session *sess) vdec_poweroff() argument
131 vdec_queue_recycle(struct amvdec_session *sess, struct vb2_buffer *vb) vdec_queue_recycle() argument
147 struct amvdec_session *sess = priv; vdec_m2m_device_run() local
154 struct amvdec_session *sess = priv; vdec_m2m_job_abort() local
164 process_num_buffers(struct vb2_queue *q, struct amvdec_session *sess, unsigned int *num_buffers, bool is_reqbufs) process_num_buffers() argument
193 struct amvdec_session *sess = vb2_get_drv_priv(q); vdec_queue_setup() local
264 struct amvdec_session *sess = vb2_get_drv_priv(vb->vb2_queue); vdec_vb2_buf_queue() local
282 struct amvdec_session *sess = vb2_get_drv_priv(q); vdec_start_streaming() local
365 vdec_free_canvas(struct amvdec_session *sess) vdec_free_canvas() argument
375 vdec_reset_timestamps(struct amvdec_session *sess) vdec_reset_timestamps() argument
385 vdec_reset_bufs_recycle(struct amvdec_session *sess) vdec_reset_bufs_recycle() argument
397 struct amvdec_session *sess = vb2_get_drv_priv(q); vdec_stop_streaming() local
492 vdec_try_fmt_common(struct amvdec_session *sess, u32 size, struct v4l2_format *f) vdec_try_fmt_common() argument
562 struct amvdec_session *sess = vdec_try_fmt() local
572 struct amvdec_session *sess = vdec_g_fmt() local
600 struct amvdec_session *sess = vdec_s_fmt() local
662 struct amvdec_session *sess = vdec_enum_fmt() local
692 struct amvdec_session *sess = vdec_enum_framesizes() local
717 struct amvdec_session *sess = vdec_decoder_cmd() local
777 struct amvdec_session *sess = vdec_g_pixelaspect() local
817 struct amvdec_session *sess = priv; m2m_queue_init() local
847 vdec_init_ctrls(struct amvdec_session *sess) vdec_init_ctrls() argument
875 struct amvdec_session *sess; vdec_open() local
934 struct amvdec_session *sess = vdec_close() local
962 struct amvdec_session *sess = core->cur_sess; vdec_isr() local
972 struct amvdec_session *sess = core->cur_sess; vdec_threaded_isr() local
[all...]
H A Dvdec_helpers.c80 static int canvas_alloc(struct amvdec_session *sess, u8 *canvas_id) in canvas_alloc() argument
84 if (sess->canvas_num >= MAX_CANVAS) { in canvas_alloc()
85 dev_err(sess->core->dev, "Reached max number of canvas\n"); in canvas_alloc()
89 ret = meson_canvas_alloc(sess->core->canvas, canvas_id); in canvas_alloc()
93 sess->canvas_alloc[sess->canvas_num++] = *canvas_id; in canvas_alloc()
97 static int set_canvas_yuv420m(struct amvdec_session *sess, in set_canvas_yuv420m() argument
101 struct amvdec_core *core = sess->core; in set_canvas_yuv420m()
107 ret = canvas_alloc(sess, &canvas_id[i]); in set_canvas_yuv420m()
141 static int set_canvas_nv12m(struct amvdec_session *sess, in set_canvas_nv12m() argument
179 amvdec_set_canvases(struct amvdec_session *sess, u32 reg_base[], u32 reg_num[]) amvdec_set_canvases() argument
230 amvdec_add_ts(struct amvdec_session *sess, u64 ts, struct v4l2_timecode tc, u32 offset, u32 vbuf_flags) amvdec_add_ts() argument
252 amvdec_remove_ts(struct amvdec_session *sess, u64 ts) amvdec_remove_ts() argument
273 dst_buf_done(struct amvdec_session *sess, struct vb2_v4l2_buffer *vbuf, u32 field, u64 timestamp, struct v4l2_timecode timecode, u32 flags) dst_buf_done() argument
323 amvdec_dst_buf_done(struct amvdec_session *sess, struct vb2_v4l2_buffer *vbuf, u32 field) amvdec_dst_buf_done() argument
357 amvdec_dst_buf_done_offset(struct amvdec_session *sess, struct vb2_v4l2_buffer *vbuf, u32 offset, u32 field, bool allow_drop) amvdec_dst_buf_done_offset() argument
406 amvdec_dst_buf_done_idx(struct amvdec_session *sess, u32 buf_idx, u32 offset, u32 field) amvdec_dst_buf_done_idx() argument
429 amvdec_set_par_from_dar(struct amvdec_session *sess, u32 dar_num, u32 dar_den) amvdec_set_par_from_dar() argument
442 amvdec_src_change(struct amvdec_session *sess, u32 width, u32 height, u32 dpb_size) amvdec_src_change() argument
474 amvdec_abort(struct amvdec_session *sess) amvdec_abort() argument
[all...]
H A Dcodec_hevc_common.c30 void codec_hevc_setup_decode_head(struct amvdec_session *sess, int is_10bit) in codec_hevc_setup_decode_head() argument
32 struct amvdec_core *core = sess->core; in codec_hevc_setup_decode_head()
33 u32 body_size = amvdec_am21c_body_size(sess->width, sess->height); in codec_hevc_setup_decode_head()
34 u32 head_size = amvdec_am21c_head_size(sess->width, sess->height); in codec_hevc_setup_decode_head()
36 if (!codec_hevc_use_fbc(sess->pixfmt_cap, is_10bit)) { in codec_hevc_setup_decode_head()
43 sess->pixfmt_cap, is_10bit)) in codec_hevc_setup_decode_head()
56 static void codec_hevc_setup_buffers_gxbb(struct amvdec_session *sess, in codec_hevc_setup_buffers_gxbb() argument
60 struct amvdec_core *core = sess in codec_hevc_setup_buffers_gxbb()
111 codec_hevc_setup_buffers_gxl(struct amvdec_session *sess, struct codec_hevc_common *comm, int is_10bit) codec_hevc_setup_buffers_gxl() argument
153 codec_hevc_free_fbc_buffers(struct amvdec_session *sess, struct codec_hevc_common *comm) codec_hevc_free_fbc_buffers() argument
171 codec_hevc_alloc_fbc_buffers(struct amvdec_session *sess, struct codec_hevc_common *comm) codec_hevc_alloc_fbc_buffers() argument
195 codec_hevc_free_mmu_headers(struct amvdec_session *sess, struct codec_hevc_common *comm) codec_hevc_free_mmu_headers() argument
219 codec_hevc_alloc_mmu_headers(struct amvdec_session *sess, struct codec_hevc_common *comm) codec_hevc_alloc_mmu_headers() argument
248 codec_hevc_setup_buffers(struct amvdec_session *sess, struct codec_hevc_common *comm, int is_10bit) codec_hevc_setup_buffers() argument
279 codec_hevc_fill_mmu_map(struct amvdec_session *sess, struct codec_hevc_common *comm, struct vb2_buffer *vb) codec_hevc_fill_mmu_map() argument
[all...]
H A Dvdec_1.c26 vdec_1_load_firmware(struct amvdec_session *sess, const char *fwname) in vdec_1_load_firmware() argument
29 struct amvdec_core *core = sess->core; in vdec_1_load_firmware()
31 struct amvdec_codec_ops *codec_ops = sess->fmt_out->codec_ops; in vdec_1_load_firmware()
75 ret = codec_ops->load_extended_firmware(sess, in vdec_1_load_firmware()
86 static int vdec_1_stbuf_power_up(struct amvdec_session *sess) in vdec_1_stbuf_power_up() argument
88 struct amvdec_core *core = sess->core; in vdec_1_stbuf_power_up()
94 amvdec_write_dos(core, VLD_MEM_VIFIFO_START_PTR, sess->vififo_paddr); in vdec_1_stbuf_power_up()
95 amvdec_write_dos(core, VLD_MEM_VIFIFO_CURR_PTR, sess->vififo_paddr); in vdec_1_stbuf_power_up()
97 sess->vififo_paddr + sess in vdec_1_stbuf_power_up()
115 vdec_1_conf_esparser(struct amvdec_session *sess) vdec_1_conf_esparser() argument
125 vdec_1_vififo_level(struct amvdec_session *sess) vdec_1_vififo_level() argument
132 vdec_1_stop(struct amvdec_session *sess) vdec_1_stop() argument
169 vdec_1_start(struct amvdec_session *sess) vdec_1_start() argument
[all...]
H A Desparser.c236 static u32 esparser_vififo_get_free_space(struct amvdec_session *sess) in esparser_vififo_get_free_space() argument
239 struct amvdec_ops *vdec_ops = sess->fmt_out->vdec_ops; in esparser_vififo_get_free_space()
240 struct amvdec_core *core = sess->core; in esparser_vififo_get_free_space()
242 vififo_usage = vdec_ops->vififo_level(sess); in esparser_vififo_get_free_space()
246 if (vififo_usage > sess->vififo_size) { in esparser_vififo_get_free_space()
247 dev_warn(sess->core->dev, in esparser_vififo_get_free_space()
249 vififo_usage, sess->vififo_size); in esparser_vififo_get_free_space()
253 return sess->vififo_size - vififo_usage; in esparser_vififo_get_free_space()
276 static u32 esparser_get_offset(struct amvdec_session *sess) in esparser_get_offset() argument
278 struct amvdec_core *core = sess in esparser_get_offset()
292 esparser_queue(struct amvdec_session *sess, struct vb2_v4l2_buffer *vbuf) esparser_queue() argument
377 struct amvdec_session *sess = esparser_queue_all_src() local
391 esparser_power_up(struct amvdec_session *sess) esparser_power_up() argument
[all...]
/kernel/linux/linux-6.6/drivers/staging/media/meson/vdec/
H A Dvdec.c40 u32 amvdec_get_output_size(struct amvdec_session *sess) in amvdec_get_output_size() argument
42 return get_output_size(sess->width, sess->height); in amvdec_get_output_size()
46 static int vdec_codec_needs_recycle(struct amvdec_session *sess) in vdec_codec_needs_recycle() argument
48 struct amvdec_codec_ops *codec_ops = sess->fmt_out->codec_ops; in vdec_codec_needs_recycle()
55 struct amvdec_session *sess = data; in vdec_recycle_thread() local
56 struct amvdec_core *core = sess->core; in vdec_recycle_thread()
57 struct amvdec_codec_ops *codec_ops = sess->fmt_out->codec_ops; in vdec_recycle_thread()
61 mutex_lock(&sess->bufs_recycle_lock); in vdec_recycle_thread()
62 list_for_each_entry_safe(tmp, n, &sess in vdec_recycle_thread()
78 vdec_poweron(struct amvdec_session *sess) vdec_poweron() argument
107 vdec_wait_inactive(struct amvdec_session *sess) vdec_wait_inactive() argument
115 vdec_poweroff(struct amvdec_session *sess) vdec_poweroff() argument
131 vdec_queue_recycle(struct amvdec_session *sess, struct vb2_buffer *vb) vdec_queue_recycle() argument
147 struct amvdec_session *sess = priv; vdec_m2m_device_run() local
154 struct amvdec_session *sess = priv; vdec_m2m_job_abort() local
164 process_num_buffers(struct vb2_queue *q, struct amvdec_session *sess, unsigned int *num_buffers, bool is_reqbufs) process_num_buffers() argument
193 struct amvdec_session *sess = vb2_get_drv_priv(q); vdec_queue_setup() local
264 struct amvdec_session *sess = vb2_get_drv_priv(vb->vb2_queue); vdec_vb2_buf_queue() local
282 struct amvdec_session *sess = vb2_get_drv_priv(q); vdec_start_streaming() local
365 vdec_free_canvas(struct amvdec_session *sess) vdec_free_canvas() argument
375 vdec_reset_timestamps(struct amvdec_session *sess) vdec_reset_timestamps() argument
385 vdec_reset_bufs_recycle(struct amvdec_session *sess) vdec_reset_bufs_recycle() argument
397 struct amvdec_session *sess = vb2_get_drv_priv(q); vdec_stop_streaming() local
492 vdec_try_fmt_common(struct amvdec_session *sess, u32 size, struct v4l2_format *f) vdec_try_fmt_common() argument
562 struct amvdec_session *sess = vdec_try_fmt() local
572 struct amvdec_session *sess = vdec_g_fmt() local
600 struct amvdec_session *sess = vdec_s_fmt() local
662 struct amvdec_session *sess = vdec_enum_fmt() local
692 struct amvdec_session *sess = vdec_enum_framesizes() local
717 struct amvdec_session *sess = vdec_decoder_cmd() local
777 struct amvdec_session *sess = vdec_g_pixelaspect() local
817 struct amvdec_session *sess = priv; m2m_queue_init() local
847 vdec_init_ctrls(struct amvdec_session *sess) vdec_init_ctrls() argument
875 struct amvdec_session *sess; vdec_open() local
934 struct amvdec_session *sess = vdec_close() local
962 struct amvdec_session *sess = core->cur_sess; vdec_isr() local
972 struct amvdec_session *sess = core->cur_sess; vdec_threaded_isr() local
[all...]
H A Dvdec_helpers.c80 static int canvas_alloc(struct amvdec_session *sess, u8 *canvas_id) in canvas_alloc() argument
84 if (sess->canvas_num >= MAX_CANVAS) { in canvas_alloc()
85 dev_err(sess->core->dev, "Reached max number of canvas\n"); in canvas_alloc()
89 ret = meson_canvas_alloc(sess->core->canvas, canvas_id); in canvas_alloc()
93 sess->canvas_alloc[sess->canvas_num++] = *canvas_id; in canvas_alloc()
97 static int set_canvas_yuv420m(struct amvdec_session *sess, in set_canvas_yuv420m() argument
101 struct amvdec_core *core = sess->core; in set_canvas_yuv420m()
107 ret = canvas_alloc(sess, &canvas_id[i]); in set_canvas_yuv420m()
141 static int set_canvas_nv12m(struct amvdec_session *sess, in set_canvas_nv12m() argument
179 amvdec_set_canvases(struct amvdec_session *sess, u32 reg_base[], u32 reg_num[]) amvdec_set_canvases() argument
230 amvdec_add_ts(struct amvdec_session *sess, u64 ts, struct v4l2_timecode tc, u32 offset, u32 vbuf_flags) amvdec_add_ts() argument
252 amvdec_remove_ts(struct amvdec_session *sess, u64 ts) amvdec_remove_ts() argument
273 dst_buf_done(struct amvdec_session *sess, struct vb2_v4l2_buffer *vbuf, u32 field, u64 timestamp, struct v4l2_timecode timecode, u32 flags) dst_buf_done() argument
323 amvdec_dst_buf_done(struct amvdec_session *sess, struct vb2_v4l2_buffer *vbuf, u32 field) amvdec_dst_buf_done() argument
357 amvdec_dst_buf_done_offset(struct amvdec_session *sess, struct vb2_v4l2_buffer *vbuf, u32 offset, u32 field, bool allow_drop) amvdec_dst_buf_done_offset() argument
406 amvdec_dst_buf_done_idx(struct amvdec_session *sess, u32 buf_idx, u32 offset, u32 field) amvdec_dst_buf_done_idx() argument
429 amvdec_set_par_from_dar(struct amvdec_session *sess, u32 dar_num, u32 dar_den) amvdec_set_par_from_dar() argument
442 amvdec_src_change(struct amvdec_session *sess, u32 width, u32 height, u32 dpb_size) amvdec_src_change() argument
474 amvdec_abort(struct amvdec_session *sess) amvdec_abort() argument
[all...]
H A Dcodec_hevc_common.c30 void codec_hevc_setup_decode_head(struct amvdec_session *sess, int is_10bit) in codec_hevc_setup_decode_head() argument
32 struct amvdec_core *core = sess->core; in codec_hevc_setup_decode_head()
33 u32 body_size = amvdec_am21c_body_size(sess->width, sess->height); in codec_hevc_setup_decode_head()
34 u32 head_size = amvdec_am21c_head_size(sess->width, sess->height); in codec_hevc_setup_decode_head()
36 if (!codec_hevc_use_fbc(sess->pixfmt_cap, is_10bit)) { in codec_hevc_setup_decode_head()
43 sess->pixfmt_cap, is_10bit)) in codec_hevc_setup_decode_head()
56 static void codec_hevc_setup_buffers_gxbb(struct amvdec_session *sess, in codec_hevc_setup_buffers_gxbb() argument
60 struct amvdec_core *core = sess in codec_hevc_setup_buffers_gxbb()
111 codec_hevc_setup_buffers_gxl(struct amvdec_session *sess, struct codec_hevc_common *comm, int is_10bit) codec_hevc_setup_buffers_gxl() argument
153 codec_hevc_free_fbc_buffers(struct amvdec_session *sess, struct codec_hevc_common *comm) codec_hevc_free_fbc_buffers() argument
171 codec_hevc_alloc_fbc_buffers(struct amvdec_session *sess, struct codec_hevc_common *comm) codec_hevc_alloc_fbc_buffers() argument
195 codec_hevc_free_mmu_headers(struct amvdec_session *sess, struct codec_hevc_common *comm) codec_hevc_free_mmu_headers() argument
219 codec_hevc_alloc_mmu_headers(struct amvdec_session *sess, struct codec_hevc_common *comm) codec_hevc_alloc_mmu_headers() argument
248 codec_hevc_setup_buffers(struct amvdec_session *sess, struct codec_hevc_common *comm, int is_10bit) codec_hevc_setup_buffers() argument
279 codec_hevc_fill_mmu_map(struct amvdec_session *sess, struct codec_hevc_common *comm, struct vb2_buffer *vb) codec_hevc_fill_mmu_map() argument
[all...]
H A Dvdec_1.c26 vdec_1_load_firmware(struct amvdec_session *sess, const char *fwname) in vdec_1_load_firmware() argument
29 struct amvdec_core *core = sess->core; in vdec_1_load_firmware()
31 struct amvdec_codec_ops *codec_ops = sess->fmt_out->codec_ops; in vdec_1_load_firmware()
75 ret = codec_ops->load_extended_firmware(sess, in vdec_1_load_firmware()
86 static int vdec_1_stbuf_power_up(struct amvdec_session *sess) in vdec_1_stbuf_power_up() argument
88 struct amvdec_core *core = sess->core; in vdec_1_stbuf_power_up()
94 amvdec_write_dos(core, VLD_MEM_VIFIFO_START_PTR, sess->vififo_paddr); in vdec_1_stbuf_power_up()
95 amvdec_write_dos(core, VLD_MEM_VIFIFO_CURR_PTR, sess->vififo_paddr); in vdec_1_stbuf_power_up()
97 sess->vififo_paddr + sess in vdec_1_stbuf_power_up()
115 vdec_1_conf_esparser(struct amvdec_session *sess) vdec_1_conf_esparser() argument
125 vdec_1_vififo_level(struct amvdec_session *sess) vdec_1_vififo_level() argument
132 vdec_1_stop(struct amvdec_session *sess) vdec_1_stop() argument
169 vdec_1_start(struct amvdec_session *sess) vdec_1_start() argument
[all...]
/kernel/linux/linux-5.10/drivers/infiniband/ulp/rtrs/
H A Drtrs-clt.c49 struct rtrs_clt_sess *sess; in rtrs_clt_is_connected() local
53 list_for_each_entry_rcu(sess, &clt->paths_list, s.entry) in rtrs_clt_is_connected()
54 connected |= READ_ONCE(sess->state) == RTRS_CLT_CONNECTED; in rtrs_clt_is_connected()
170 * @sess: client session pointer
177 struct rtrs_clt_con *rtrs_permit_to_clt_con(struct rtrs_clt_sess *sess, in rtrs_permit_to_clt_con() argument
183 id = (permit->cpu_id % (sess->s.con_num - 1)) + 1; in rtrs_permit_to_clt_con()
185 return to_clt_con(sess->s.con[id]); in rtrs_permit_to_clt_con()
192 * @sess: client session to change the state of.
200 static bool __rtrs_clt_change_state(struct rtrs_clt_sess *sess, in __rtrs_clt_change_state() argument
206 lockdep_assert_held(&sess in __rtrs_clt_change_state()
289 rtrs_clt_change_state_from_to(struct rtrs_clt_sess *sess, enum rtrs_clt_state old_state, enum rtrs_clt_state new_state) rtrs_clt_change_state_from_to() argument
305 struct rtrs_clt_sess *sess = to_clt_sess(con->c.sess); rtrs_rdma_error_recovery() local
387 struct rtrs_clt_sess *sess; complete_rdma_req() local
455 struct rtrs_clt_sess *sess = to_clt_sess(con->c.sess); rtrs_post_send_rdma() local
485 process_io_rsp(struct rtrs_clt_sess *sess, u32 msg_id, s16 errno, bool w_inval) process_io_rsp() argument
503 struct rtrs_clt_sess *sess = to_clt_sess(con->c.sess); rtrs_clt_recv_done() local
517 struct rtrs_clt_sess *sess = to_clt_sess(con->c.sess); rtrs_clt_rkey_rsp_done() local
596 struct rtrs_clt_sess *sess = to_clt_sess(con->c.sess); rtrs_clt_rdma_done() local
687 struct rtrs_clt_sess *sess = to_clt_sess(con->c.sess); post_recv_io() local
704 post_recv_sess(struct rtrs_clt_sess *sess) post_recv_sess() argument
809 struct rtrs_clt_sess *sess; get_next_path_min_inflight() local
880 rtrs_clt_init_req(struct rtrs_clt_io_req *req, struct rtrs_clt_sess *sess, void (*conf)(void *priv, int errno), struct rtrs_permit *permit, void *priv, const struct kvec *vec, size_t usr_len, struct scatterlist *sg, size_t sg_cnt, size_t data_len, int dir) rtrs_clt_init_req() argument
913 rtrs_clt_get_req(struct rtrs_clt_sess *sess, void (*conf)(void *priv, int errno), struct rtrs_permit *permit, void *priv, const struct kvec *vec, size_t usr_len, struct scatterlist *sg, size_t sg_cnt, size_t data_len, int dir) rtrs_clt_get_req() argument
951 struct rtrs_clt_sess *sess = to_clt_sess(con->c.sess); rtrs_post_rdma_write_sg() local
988 struct rtrs_clt_sess *sess = to_clt_sess(s); rtrs_clt_write_req() local
1062 struct rtrs_clt_sess *sess = to_clt_sess(s); rtrs_clt_read_req() local
1204 fail_all_outstanding_reqs(struct rtrs_clt_sess *sess) fail_all_outstanding_reqs() argument
1231 free_sess_reqs(struct rtrs_clt_sess *sess) free_sess_reqs() argument
1249 alloc_sess_reqs(struct rtrs_clt_sess *sess) alloc_sess_reqs() argument
1343 query_fast_reg_mode(struct rtrs_clt_sess *sess) query_fast_reg_mode() argument
1365 rtrs_clt_change_state_get_old(struct rtrs_clt_sess *sess, enum rtrs_clt_state new_state, enum rtrs_clt_state *old_state) rtrs_clt_change_state_get_old() argument
1379 rtrs_clt_change_state(struct rtrs_clt_sess *sess, enum rtrs_clt_state new_state) rtrs_clt_change_state() argument
1394 rtrs_clt_init_hb(struct rtrs_clt_sess *sess) rtrs_clt_init_hb() argument
1403 rtrs_clt_start_hb(struct rtrs_clt_sess *sess) rtrs_clt_start_hb() argument
1408 rtrs_clt_stop_hb(struct rtrs_clt_sess *sess) rtrs_clt_stop_hb() argument
1421 struct rtrs_clt_sess *sess; alloc_sess() local
1489 free_sess(struct rtrs_clt_sess *sess) free_sess() argument
1498 create_con(struct rtrs_clt_sess *sess, unsigned int cid) create_con() argument
1519 struct rtrs_clt_sess *sess = to_clt_sess(con->c.sess); destroy_con() local
1527 struct rtrs_clt_sess *sess = to_clt_sess(con->c.sess); create_con_cq_qp() local
1613 struct rtrs_clt_sess *sess = to_clt_sess(con->c.sess); destroy_con_cq_qp() local
1664 struct rtrs_clt_sess *sess = to_clt_sess(con->c.sess); rtrs_rdma_route_resolved() local
1699 struct rtrs_clt_sess *sess = to_clt_sess(con->c.sess); rtrs_rdma_conn_established() local
1786 struct rtrs_clt_sess *sess = to_clt_sess(con->c.sess); flag_success_on_conn() local
1823 rtrs_clt_close_conns(struct rtrs_clt_sess *sess, bool wait) rtrs_clt_close_conns() argument
1834 struct rtrs_clt_sess *sess; flag_error_on_conn() local
1849 struct rtrs_clt_sess *sess = to_clt_sess(s); rtrs_clt_rdma_cm_handler() local
1915 struct rtrs_clt_sess *sess = to_clt_sess(s); create_cm() local
1980 rtrs_clt_sess_up(struct rtrs_clt_sess *sess) rtrs_clt_sess_up() argument
2011 rtrs_clt_sess_down(struct rtrs_clt_sess *sess) rtrs_clt_sess_down() argument
2026 rtrs_clt_stop_and_destroy_conns(struct rtrs_clt_sess *sess) rtrs_clt_stop_and_destroy_conns() argument
2086 xchg_sessions(struct rtrs_clt_sess __rcu **rcu_ppcpu_path, struct rtrs_clt_sess *sess, struct rtrs_clt_sess *next) xchg_sessions() argument
2097 rtrs_clt_remove_path_from_arr(struct rtrs_clt_sess *sess) rtrs_clt_remove_path_from_arr() argument
2187 rtrs_clt_add_path_to_arr(struct rtrs_clt_sess *sess, struct rtrs_addr *addr) rtrs_clt_add_path_to_arr() argument
2201 struct rtrs_clt_sess *sess; rtrs_clt_close_work() local
2210 init_conns(struct rtrs_clt_sess *sess) init_conns() argument
2264 struct rtrs_clt_sess *sess = to_clt_sess(con->c.sess); rtrs_clt_info_req_done() local
2280 process_info_rsp(struct rtrs_clt_sess *sess, const struct rtrs_msg_info_rsp *msg) process_info_rsp() argument
2347 struct rtrs_clt_sess *sess = to_clt_sess(con->c.sess); rtrs_clt_info_rsp_done() local
2401 rtrs_send_sess_info(struct rtrs_clt_sess *sess) rtrs_send_sess_info() argument
2475 init_sess(struct rtrs_clt_sess *sess) init_sess() argument
2499 struct rtrs_clt_sess *sess; rtrs_clt_reconnect_work() local
2672 struct rtrs_clt_sess *sess, *tmp; rtrs_clt_open() local
2685 struct rtrs_clt_sess *sess; rtrs_clt_open() local
2744 struct rtrs_clt_sess *sess, *tmp; rtrs_clt_close() local
2761 rtrs_clt_reconnect_from_sysfs(struct rtrs_clt_sess *sess) rtrs_clt_reconnect_from_sysfs() argument
2787 rtrs_clt_disconnect_from_sysfs(struct rtrs_clt_sess *sess) rtrs_clt_disconnect_from_sysfs() argument
2794 rtrs_clt_remove_path_from_sysfs(struct rtrs_clt_sess *sess, const struct attribute *sysfs_self) rtrs_clt_remove_path_from_sysfs() argument
2865 struct rtrs_clt_sess *sess; rtrs_clt_request() local
2945 struct rtrs_clt_sess *sess; rtrs_clt_create_path_from_sysfs() local
[all...]
H A Drtrs-srv.c70 static bool __rtrs_srv_change_state(struct rtrs_srv_sess *sess, in __rtrs_srv_change_state() argument
76 lockdep_assert_held(&sess->state_lock); in __rtrs_srv_change_state()
77 old_state = sess->state; in __rtrs_srv_change_state()
111 sess->state = new_state; in __rtrs_srv_change_state()
116 static bool rtrs_srv_change_state_get_old(struct rtrs_srv_sess *sess, in rtrs_srv_change_state_get_old() argument
122 spin_lock_irq(&sess->state_lock); in rtrs_srv_change_state_get_old()
123 *old_state = sess->state; in rtrs_srv_change_state_get_old()
124 changed = __rtrs_srv_change_state(sess, new_state); in rtrs_srv_change_state_get_old()
125 spin_unlock_irq(&sess->state_lock); in rtrs_srv_change_state_get_old()
130 static bool rtrs_srv_change_state(struct rtrs_srv_sess *sess, in rtrs_srv_change_state() argument
145 rtrs_srv_free_ops_ids(struct rtrs_srv_sess *sess) rtrs_srv_free_ops_ids() argument
165 rtrs_srv_alloc_ops_ids(struct rtrs_srv_sess *sess) rtrs_srv_alloc_ops_ids() argument
193 rtrs_srv_get_ops_ids(struct rtrs_srv_sess *sess) rtrs_srv_get_ops_ids() argument
198 rtrs_srv_put_ops_ids(struct rtrs_srv_sess *sess) rtrs_srv_put_ops_ids() argument
204 rtrs_srv_wait_ops_ids(struct rtrs_srv_sess *sess) rtrs_srv_wait_ops_ids() argument
214 struct rtrs_srv_sess *sess = to_srv_sess(s); rtrs_srv_reg_mr_done() local
231 struct rtrs_srv_sess *sess = to_srv_sess(s); rdma_write_sg() local
376 struct rtrs_srv_sess *sess = to_srv_sess(s); send_io_resp_imm() local
479 close_sess(struct rtrs_srv_sess *sess) close_sess() argument
518 struct rtrs_srv_sess *sess; rtrs_srv_resp_rdma() local
579 unmap_cont_bufs(struct rtrs_srv_sess *sess) unmap_cont_bufs() argument
596 map_cont_bufs(struct rtrs_srv_sess *sess) map_cont_bufs() argument
715 rtrs_srv_init_hb(struct rtrs_srv_sess *sess) rtrs_srv_init_hb() argument
724 rtrs_srv_start_hb(struct rtrs_srv_sess *sess) rtrs_srv_start_hb() argument
729 rtrs_srv_stop_hb(struct rtrs_srv_sess *sess) rtrs_srv_stop_hb() argument
738 struct rtrs_srv_sess *sess = to_srv_sess(s); rtrs_srv_info_rsp_done() local
753 rtrs_srv_sess_up(struct rtrs_srv_sess *sess) rtrs_srv_sess_up() argument
769 rtrs_srv_sess_down(struct rtrs_srv_sess *sess) rtrs_srv_sess_down() argument
791 struct rtrs_srv_sess *sess = to_srv_sess(s); process_info_req() local
880 struct rtrs_srv_sess *sess = to_srv_sess(s); rtrs_srv_info_req_done() local
923 struct rtrs_srv_sess *sess = to_srv_sess(s); post_recv_info_req() local
956 post_recv_sess(struct rtrs_srv_sess *sess) post_recv_sess() argument
984 struct rtrs_srv_sess *sess = to_srv_sess(s); process_read() local
1042 struct rtrs_srv_sess *sess = to_srv_sess(s); process_write() local
1093 struct rtrs_srv_sess *sess = to_srv_sess(s); process_io_req() local
1128 struct rtrs_srv_sess *sess = to_srv_sess(s); rtrs_srv_inv_rkey_done() local
1185 struct rtrs_srv_sess *sess = to_srv_sess(s); rtrs_srv_rdma_done() local
1281 struct rtrs_srv_sess *sess; rtrs_srv_get_sess_name() local
1309 find_next_bit_ring(struct rtrs_srv_sess *sess) find_next_bit_ring() argument
1320 rtrs_srv_get_next_cq_vector(struct rtrs_srv_sess *sess) rtrs_srv_get_next_cq_vector() argument
1426 __add_path_to_srv(struct rtrs_srv *srv, struct rtrs_srv_sess *sess) __add_path_to_srv() argument
1434 del_path_from_srv(struct rtrs_srv_sess *sess) del_path_from_srv() argument
1475 struct rtrs_srv_sess *sess; __is_path_w_addr_exists() local
1487 free_sess(struct rtrs_srv_sess *sess) free_sess() argument
1500 struct rtrs_srv_sess *sess; rtrs_srv_close_work() local
1545 rtrs_rdma_do_accept(struct rtrs_srv_sess *sess, struct rdma_cm_id *cm_id) rtrs_rdma_do_accept() argument
1599 struct rtrs_srv_sess *sess; __find_sess() local
1609 create_con(struct rtrs_srv_sess *sess, struct rdma_cm_id *cm_id, unsigned int cid) create_con() argument
1710 struct rtrs_srv_sess *sess; __alloc_sess() local
1791 struct rtrs_srv_sess *sess; rtrs_rdma_connect() local
1911 struct rtrs_srv_sess *sess = NULL; rtrs_srv_rdma_cm_handler() local
2155 struct rtrs_srv_sess *sess; close_sessions() local
[all...]
H A Drtrs-srv-sysfs.c18 struct rtrs_srv_sess *sess; in rtrs_srv_release() local
20 sess = container_of(kobj, struct rtrs_srv_sess, kobj); in rtrs_srv_release()
21 kfree(sess); in rtrs_srv_release()
41 struct rtrs_srv_sess *sess; in rtrs_srv_disconnect_store() local
45 sess = container_of(kobj, struct rtrs_srv_sess, kobj); in rtrs_srv_disconnect_store()
46 s = &sess->s; in rtrs_srv_disconnect_store()
53 sockaddr_to_str((struct sockaddr *)&sess->s.dst_addr, str, sizeof(str)); in rtrs_srv_disconnect_store()
57 sysfs_remove_file_self(&sess->kobj, &attr->attr); in rtrs_srv_disconnect_store()
58 close_sess(sess); in rtrs_srv_disconnect_store()
71 struct rtrs_srv_sess *sess; in rtrs_srv_hca_port_show() local
88 struct rtrs_srv_sess *sess; rtrs_srv_hca_name_show() local
103 struct rtrs_srv_sess *sess; rtrs_srv_src_addr_show() local
119 struct rtrs_srv_sess *sess; rtrs_srv_dst_addr_show() local
157 rtrs_srv_create_once_sysfs_root_folders(struct rtrs_srv_sess *sess) rtrs_srv_create_once_sysfs_root_folders() argument
205 rtrs_srv_destroy_once_sysfs_root_folders(struct rtrs_srv_sess *sess) rtrs_srv_destroy_once_sysfs_root_folders() argument
236 rtrs_srv_create_stats_files(struct rtrs_srv_sess *sess) rtrs_srv_create_stats_files() argument
264 rtrs_srv_create_sess_files(struct rtrs_srv_sess *sess) rtrs_srv_create_sess_files() argument
309 rtrs_srv_destroy_sess_files(struct rtrs_srv_sess *sess) rtrs_srv_destroy_sess_files() argument
[all...]
H A Drtrs-clt-sysfs.c21 struct rtrs_clt_sess *sess; in rtrs_clt_sess_release() local
23 sess = container_of(kobj, struct rtrs_clt_sess, kobj); in rtrs_clt_sess_release()
25 free_sess(sess); in rtrs_clt_sess_release()
183 struct rtrs_clt_sess *sess; in rtrs_clt_state_show() local
185 sess = container_of(kobj, struct rtrs_clt_sess, kobj); in rtrs_clt_state_show()
186 if (sess->state == RTRS_CLT_CONNECTED) in rtrs_clt_state_show()
207 struct rtrs_clt_sess *sess; in rtrs_clt_reconnect_store() local
210 sess = container_of(kobj, struct rtrs_clt_sess, kobj); in rtrs_clt_reconnect_store()
212 rtrs_err(sess->clt, "%s: unknown value: '%s'\n", in rtrs_clt_reconnect_store()
216 ret = rtrs_clt_reconnect_from_sysfs(sess); in rtrs_clt_reconnect_store()
239 struct rtrs_clt_sess *sess; rtrs_clt_disconnect_store() local
271 struct rtrs_clt_sess *sess; rtrs_clt_remove_path_store() local
323 struct rtrs_clt_sess *sess; rtrs_clt_hca_port_show() local
337 struct rtrs_clt_sess *sess; rtrs_clt_hca_name_show() local
351 struct rtrs_clt_sess *sess; rtrs_clt_src_addr_show() local
367 struct rtrs_clt_sess *sess; rtrs_clt_dst_addr_show() local
395 rtrs_clt_create_sess_files(struct rtrs_clt_sess *sess) rtrs_clt_create_sess_files() argument
448 rtrs_clt_destroy_sess_files(struct rtrs_clt_sess *sess, const struct attribute *sysfs_self) rtrs_clt_destroy_sess_files() argument
[all...]
/kernel/linux/linux-5.10/drivers/target/tcm_fc/
H A Dtfc_sess.c162 struct ft_sess *sess; in ft_sess_get() local
173 hlist_for_each_entry_rcu(sess, head, hash) { in ft_sess_get()
174 if (sess->port_id == port_id) { in ft_sess_get()
175 kref_get(&sess->kref); in ft_sess_get()
178 port_id, sess); in ft_sess_get()
179 return sess; in ft_sess_get()
192 struct ft_sess *sess = p; in ft_sess_alloc_cb() local
193 struct ft_tport *tport = sess->tport; in ft_sess_alloc_cb()
194 struct hlist_head *head = &tport->hash[ft_sess_hash(sess->port_id)]; in ft_sess_alloc_cb()
196 TFC_SESS_DBG(tport->lport, "port_id %x sess in ft_sess_alloc_cb()
211 struct ft_sess *sess; ft_sess_create() local
246 ft_sess_unhash(struct ft_sess *sess) ft_sess_unhash() argument
264 struct ft_sess *sess; ft_sess_delete() local
276 ft_close_sess(struct ft_sess *sess) ft_close_sess() argument
290 struct ft_sess *sess; ft_sess_delete_all() local
311 struct ft_sess *sess = se_sess->fabric_sess_ptr; ft_sess_close() local
330 struct ft_sess *sess = se_sess->fabric_sess_ptr; ft_sess_get_index() local
338 struct ft_sess *sess = se_sess->fabric_sess_ptr; ft_sess_get_port_name() local
351 struct ft_sess *sess; ft_prli_locked() local
436 struct ft_sess *sess = container_of(kref, struct ft_sess, kref); ft_sess_free() local
442 ft_sess_put(struct ft_sess *sess) ft_sess_put() argument
452 struct ft_sess *sess; ft_prlo() local
480 struct ft_sess *sess; ft_recv() local
[all...]
/kernel/linux/linux-6.6/drivers/target/tcm_fc/
H A Dtfc_sess.c162 struct ft_sess *sess; in ft_sess_get() local
173 hlist_for_each_entry_rcu(sess, head, hash) { in ft_sess_get()
174 if (sess->port_id == port_id) { in ft_sess_get()
175 kref_get(&sess->kref); in ft_sess_get()
178 port_id, sess); in ft_sess_get()
179 return sess; in ft_sess_get()
192 struct ft_sess *sess = p; in ft_sess_alloc_cb() local
193 struct ft_tport *tport = sess->tport; in ft_sess_alloc_cb()
194 struct hlist_head *head = &tport->hash[ft_sess_hash(sess->port_id)]; in ft_sess_alloc_cb()
196 TFC_SESS_DBG(tport->lport, "port_id %x sess in ft_sess_alloc_cb()
211 struct ft_sess *sess; ft_sess_create() local
246 ft_sess_unhash(struct ft_sess *sess) ft_sess_unhash() argument
264 struct ft_sess *sess; ft_sess_delete() local
276 ft_close_sess(struct ft_sess *sess) ft_close_sess() argument
290 struct ft_sess *sess; ft_sess_delete_all() local
311 struct ft_sess *sess = se_sess->fabric_sess_ptr; ft_sess_close() local
330 struct ft_sess *sess = se_sess->fabric_sess_ptr; ft_sess_get_index() local
338 struct ft_sess *sess = se_sess->fabric_sess_ptr; ft_sess_get_port_name() local
351 struct ft_sess *sess; ft_prli_locked() local
436 struct ft_sess *sess = container_of(kref, struct ft_sess, kref); ft_sess_free() local
442 ft_sess_put(struct ft_sess *sess) ft_sess_put() argument
452 struct ft_sess *sess; ft_prlo() local
480 struct ft_sess *sess; ft_recv() local
[all...]
/kernel/linux/linux-6.6/drivers/block/rnbd/
H A Drnbd-clt.c36 static inline bool rnbd_clt_get_sess(struct rnbd_clt_session *sess) in rnbd_clt_get_sess() argument
38 return refcount_inc_not_zero(&sess->refcount); in rnbd_clt_get_sess()
41 static void free_sess(struct rnbd_clt_session *sess);
43 static void rnbd_clt_put_sess(struct rnbd_clt_session *sess) in rnbd_clt_put_sess() argument
47 if (refcount_dec_and_test(&sess->refcount)) in rnbd_clt_put_sess()
48 free_sess(sess); in rnbd_clt_put_sess()
61 rnbd_clt_put_sess(dev->sess); in rnbd_clt_put_dev()
152 * @sess: Session to find a queue for
161 rnbd_get_cpu_qlist(struct rnbd_clt_session *sess, int cpu) in rnbd_get_cpu_qlist() argument
166 bit = find_next_bit(sess in rnbd_get_cpu_qlist()
199 rnbd_rerun_if_needed(struct rnbd_clt_session *sess) rnbd_rerun_if_needed() argument
279 rnbd_rerun_all_if_idle(struct rnbd_clt_session *sess) rnbd_rerun_all_if_idle() argument
288 rnbd_get_permit(struct rnbd_clt_session *sess, enum rtrs_clt_con_type con_type, enum wait_type wait) rnbd_get_permit() argument
306 rnbd_put_permit(struct rnbd_clt_session *sess, struct rtrs_permit *permit) rnbd_put_permit() argument
318 rnbd_get_iu(struct rnbd_clt_session *sess, enum rtrs_clt_con_type con_type, enum wait_type wait) rnbd_get_iu() argument
357 rnbd_put_iu(struct rnbd_clt_session *sess, struct rnbd_iu *iu) rnbd_put_iu() argument
369 struct rnbd_clt_session *sess = dev->sess; rnbd_softirq_done_fn() local
447 struct rnbd_clt_session *sess = dev->sess; send_msg_close() local
519 struct rnbd_clt_session *sess = iu->sess; msg_sess_info_conf() local
532 struct rnbd_clt_session *sess = dev->sess; send_msg_open() local
577 send_msg_sess_info(struct rnbd_clt_session *sess, enum wait_type wait) send_msg_sess_info() argument
630 set_dev_states_to_disconnected(struct rnbd_clt_session *sess) set_dev_states_to_disconnected() argument
650 remap_devs(struct rnbd_clt_session *sess) remap_devs() argument
706 struct rnbd_clt_session *sess = priv; rnbd_clt_link_ev() local
735 destroy_mq_tags(struct rnbd_clt_session *sess) destroy_mq_tags() argument
741 wake_up_rtrs_waiters(struct rnbd_clt_session *sess) wake_up_rtrs_waiters() argument
747 close_rtrs(struct rnbd_clt_session *sess) close_rtrs() argument
758 free_sess(struct rnbd_clt_session *sess) free_sess() argument
779 struct rnbd_clt_session *sess; alloc_sess() local
822 wait_for_rtrs_connection(struct rnbd_clt_session *sess) wait_for_rtrs_connection() argument
857 struct rnbd_clt_session *sess, *sn; global() variable
878 rnbd_clt_put_sess(sess); global() variable
891 wait_for_rtrs_disconnection(sess); global() variable
906 struct rnbd_clt_session *sess = NULL; find_or_create_sess() local
1054 struct rnbd_clt_session *sess = dev->sess; rnbd_clt_dev_add_to_requeue() local
1168 struct rnbd_clt_session *sess = set->driver_data; rnbd_rdma_map_queues() local
1204 setup_mq_tags(struct rnbd_clt_session *sess) setup_mq_tags() argument
1233 struct rnbd_clt_session *sess; find_and_get_or_create_sess() local
1419 init_dev(struct rnbd_clt_session *sess, enum rnbd_access_mode access_mode, const char *pathname, u32 nr_poll_queues) init_dev() argument
1482 struct rnbd_clt_session *sess; __exists_dev() local
1520 struct rnbd_clt_session *sess = dev->sess; insert_dev_if_not_exists_devpath() local
1536 struct rnbd_clt_session *sess = dev->sess; delete_dev() local
1550 struct rnbd_clt_session *sess; rnbd_clt_map_device() local
1685 struct rnbd_clt_session *sess = dev->sess; rnbd_clt_unmap_device() local
1763 struct rnbd_clt_session *sess, *sn; rnbd_destroy_sessions() local
[all...]
/kernel/linux/linux-5.10/drivers/block/rnbd/
H A Drnbd-clt.c36 static inline bool rnbd_clt_get_sess(struct rnbd_clt_session *sess) in rnbd_clt_get_sess() argument
38 return refcount_inc_not_zero(&sess->refcount); in rnbd_clt_get_sess()
41 static void free_sess(struct rnbd_clt_session *sess);
43 static void rnbd_clt_put_sess(struct rnbd_clt_session *sess) in rnbd_clt_put_sess() argument
47 if (refcount_dec_and_test(&sess->refcount)) in rnbd_clt_put_sess()
48 free_sess(sess); in rnbd_clt_put_sess()
63 rnbd_clt_put_sess(dev->sess); in rnbd_clt_put_dev()
76 struct rnbd_clt_session *sess = dev->sess; in rnbd_clt_set_dev_attr() local
92 dev->max_hw_sectors = sess in rnbd_clt_set_dev_attr()
185 rnbd_get_cpu_qlist(struct rnbd_clt_session *sess, int cpu) rnbd_get_cpu_qlist() argument
223 rnbd_rerun_if_needed(struct rnbd_clt_session *sess) rnbd_rerun_if_needed() argument
303 rnbd_rerun_all_if_idle(struct rnbd_clt_session *sess) rnbd_rerun_all_if_idle() argument
312 rnbd_get_permit(struct rnbd_clt_session *sess, enum rtrs_clt_con_type con_type, int wait) rnbd_get_permit() argument
332 rnbd_put_permit(struct rnbd_clt_session *sess, struct rtrs_permit *permit) rnbd_put_permit() argument
344 rnbd_get_iu(struct rnbd_clt_session *sess, enum rtrs_clt_con_type con_type, int wait) rnbd_get_iu() argument
373 rnbd_put_iu(struct rnbd_clt_session *sess, struct rnbd_iu *iu) rnbd_put_iu() argument
382 struct rnbd_clt_session *sess = dev->sess; rnbd_softirq_done_fn() local
463 struct rnbd_clt_session *sess = dev->sess; send_msg_close() local
530 struct rnbd_clt_session *sess = iu->sess; msg_sess_info_conf() local
543 struct rnbd_clt_session *sess = dev->sess; send_msg_open() local
588 send_msg_sess_info(struct rnbd_clt_session *sess, bool wait) send_msg_sess_info() argument
643 set_dev_states_to_disconnected(struct rnbd_clt_session *sess) set_dev_states_to_disconnected() argument
659 remap_devs(struct rnbd_clt_session *sess) remap_devs() argument
715 struct rnbd_clt_session *sess = priv; rnbd_clt_link_ev() local
744 destroy_mq_tags(struct rnbd_clt_session *sess) destroy_mq_tags() argument
750 wake_up_rtrs_waiters(struct rnbd_clt_session *sess) wake_up_rtrs_waiters() argument
756 close_rtrs(struct rnbd_clt_session *sess) close_rtrs() argument
767 free_sess(struct rnbd_clt_session *sess) free_sess() argument
788 struct rnbd_clt_session *sess; alloc_sess() local
831 wait_for_rtrs_connection(struct rnbd_clt_session *sess) wait_for_rtrs_connection() argument
866 struct rnbd_clt_session *sess, *sn; global() variable
887 rnbd_clt_put_sess(sess); global() variable
900 wait_for_rtrs_disconnection(sess); global() variable
914 struct rnbd_clt_session *sess = NULL; find_or_create_sess() local
1064 struct rnbd_clt_session *sess = dev->sess; rnbd_clt_dev_add_to_requeue() local
1168 setup_mq_tags(struct rnbd_clt_session *sess) setup_mq_tags() argument
1189 struct rnbd_clt_session *sess; find_and_get_or_create_sess() local
1342 rnbd_client_setup_device(struct rnbd_clt_session *sess, struct rnbd_clt_dev *dev, int idx) rnbd_client_setup_device() argument
1366 init_dev(struct rnbd_clt_session *sess, enum rnbd_access_mode access_mode, const char *pathname) init_dev() argument
1424 struct rnbd_clt_session *sess; __exists_dev() local
1456 insert_dev_if_not_exists_devpath(const char *pathname, struct rnbd_clt_session *sess, struct rnbd_clt_dev *dev) insert_dev_if_not_exists_devpath() argument
1476 struct rnbd_clt_session *sess = dev->sess; delete_dev() local
1489 struct rnbd_clt_session *sess; rnbd_clt_map_device() local
1581 struct rnbd_clt_session *sess = dev->sess; rnbd_clt_unmap_device() local
1659 struct rnbd_clt_session *sess, *sn; rnbd_destroy_sessions() local
[all...]
/kernel/linux/linux-5.10/drivers/target/iscsi/
H A Discsi_target_erl2.c41 conn->sess->sess_ops->MaxBurstLength) { in iscsit_create_conn_recovery_datain_values()
48 (conn->sess->sess_ops->MaxBurstLength - in iscsit_create_conn_recovery_datain_values()
66 if ((write_data_done + conn->sess->sess_ops->MaxBurstLength) <= in iscsit_create_conn_recovery_dataout_values()
68 write_data_done += conn->sess->sess_ops->MaxBurstLength; in iscsit_create_conn_recovery_dataout_values()
77 struct iscsi_session *sess, in iscsit_attach_active_connection_recovery_entry()
80 spin_lock(&sess->cr_a_lock); in iscsit_attach_active_connection_recovery_entry()
81 list_add_tail(&cr->cr_list, &sess->cr_active_list); in iscsit_attach_active_connection_recovery_entry()
82 spin_unlock(&sess->cr_a_lock); in iscsit_attach_active_connection_recovery_entry()
88 struct iscsi_session *sess, in iscsit_attach_inactive_connection_recovery_entry()
91 spin_lock(&sess in iscsit_attach_inactive_connection_recovery_entry()
76 iscsit_attach_active_connection_recovery_entry( struct iscsi_session *sess, struct iscsi_conn_recovery *cr) iscsit_attach_active_connection_recovery_entry() argument
87 iscsit_attach_inactive_connection_recovery_entry( struct iscsi_session *sess, struct iscsi_conn_recovery *cr) iscsit_attach_inactive_connection_recovery_entry() argument
102 iscsit_get_inactive_connection_recovery_entry( struct iscsi_session *sess, u16 cid) iscsit_get_inactive_connection_recovery_entry() argument
120 iscsit_free_connection_recovery_entries(struct iscsi_session *sess) iscsit_free_connection_recovery_entries() argument
170 iscsit_remove_active_connection_recovery_entry( struct iscsi_conn_recovery *cr, struct iscsi_session *sess) iscsit_remove_active_connection_recovery_entry() argument
187 iscsit_remove_inactive_connection_recovery_entry( struct iscsi_conn_recovery *cr, struct iscsi_session *sess) iscsit_remove_inactive_connection_recovery_entry() argument
199 iscsit_remove_cmd_from_connection_recovery( struct iscsi_cmd *cmd, struct iscsi_session *sess) iscsit_remove_cmd_from_connection_recovery() argument
222 struct iscsi_session *sess = cr->sess; iscsit_discard_cr_cmds_by_expstatsn() local
271 struct iscsi_session *sess = conn->sess; iscsit_discard_unacknowledged_ooo_cmdsns_for_conn() local
[all...]
H A Discsi_target_login.c136 struct iscsi_session *sess = NULL, *sess_p = NULL; in iscsi_check_for_session_reinstatement() local
165 if (!memcmp(sess_p->isid, conn->sess->isid, 6) && in iscsi_check_for_session_reinstatement()
175 sess = sess_p; in iscsi_check_for_session_reinstatement()
184 if (!sess) in iscsi_check_for_session_reinstatement()
189 "Discovery" : "Normal", sess->sid, in iscsi_check_for_session_reinstatement()
190 sess->sess_ops->InitiatorName); in iscsi_check_for_session_reinstatement()
192 spin_lock_bh(&sess->conn_lock); in iscsi_check_for_session_reinstatement()
193 if (sess->session_state == TARG_SESS_STATE_FAILED) { in iscsi_check_for_session_reinstatement()
194 spin_unlock_bh(&sess->conn_lock); in iscsi_check_for_session_reinstatement()
195 iscsit_dec_session_usage_count(sess); in iscsi_check_for_session_reinstatement()
206 iscsi_login_set_conn_values( struct iscsi_session *sess, struct iscsi_conn *conn, __be16 cid) iscsi_login_set_conn_values() argument
259 struct iscsi_session *sess = NULL; iscsi_login_zero_tsih_s1() local
343 struct iscsi_session *sess = conn->sess; iscsi_login_zero_tsih_s2() local
477 struct iscsi_session *sess = NULL, *sess_p = NULL; iscsi_login_non_zero_tsih_s2() local
555 struct iscsi_session *sess = conn->sess; iscsi_login_post_auth_non_zero_tsih() local
617 struct iscsi_session *sess = conn->sess; iscsi_post_login_start_timers() local
680 struct iscsi_session *sess = conn->sess; iscsi_post_login_handler() local
[all...]
/kernel/linux/linux-6.6/drivers/target/iscsi/
H A Discsi_target_erl2.c41 conn->sess->sess_ops->MaxBurstLength) { in iscsit_create_conn_recovery_datain_values()
48 (conn->sess->sess_ops->MaxBurstLength - in iscsit_create_conn_recovery_datain_values()
66 if ((write_data_done + conn->sess->sess_ops->MaxBurstLength) <= in iscsit_create_conn_recovery_dataout_values()
68 write_data_done += conn->sess->sess_ops->MaxBurstLength; in iscsit_create_conn_recovery_dataout_values()
77 struct iscsit_session *sess, in iscsit_attach_active_connection_recovery_entry()
80 spin_lock(&sess->cr_a_lock); in iscsit_attach_active_connection_recovery_entry()
81 list_add_tail(&cr->cr_list, &sess->cr_active_list); in iscsit_attach_active_connection_recovery_entry()
82 spin_unlock(&sess->cr_a_lock); in iscsit_attach_active_connection_recovery_entry()
88 struct iscsit_session *sess, in iscsit_attach_inactive_connection_recovery_entry()
91 spin_lock(&sess in iscsit_attach_inactive_connection_recovery_entry()
76 iscsit_attach_active_connection_recovery_entry( struct iscsit_session *sess, struct iscsi_conn_recovery *cr) iscsit_attach_active_connection_recovery_entry() argument
87 iscsit_attach_inactive_connection_recovery_entry( struct iscsit_session *sess, struct iscsi_conn_recovery *cr) iscsit_attach_inactive_connection_recovery_entry() argument
102 iscsit_get_inactive_connection_recovery_entry( struct iscsit_session *sess, u16 cid) iscsit_get_inactive_connection_recovery_entry() argument
120 iscsit_free_connection_recovery_entries(struct iscsit_session *sess) iscsit_free_connection_recovery_entries() argument
170 iscsit_remove_active_connection_recovery_entry( struct iscsi_conn_recovery *cr, struct iscsit_session *sess) iscsit_remove_active_connection_recovery_entry() argument
187 iscsit_remove_inactive_connection_recovery_entry( struct iscsi_conn_recovery *cr, struct iscsit_session *sess) iscsit_remove_inactive_connection_recovery_entry() argument
199 iscsit_remove_cmd_from_connection_recovery( struct iscsit_cmd *cmd, struct iscsit_session *sess) iscsit_remove_cmd_from_connection_recovery() argument
222 struct iscsit_session *sess = cr->sess; iscsit_discard_cr_cmds_by_expstatsn() local
271 struct iscsit_session *sess = conn->sess; iscsit_discard_unacknowledged_ooo_cmdsns_for_conn() local
[all...]
H A Discsi_target_login.c136 struct iscsit_session *sess = NULL, *sess_p = NULL; in iscsi_check_for_session_reinstatement() local
165 if (!memcmp(sess_p->isid, conn->sess->isid, 6) && in iscsi_check_for_session_reinstatement()
175 sess = sess_p; in iscsi_check_for_session_reinstatement()
184 if (!sess) in iscsi_check_for_session_reinstatement()
189 "Discovery" : "Normal", sess->sid, in iscsi_check_for_session_reinstatement()
190 sess->sess_ops->InitiatorName); in iscsi_check_for_session_reinstatement()
192 spin_lock_bh(&sess->conn_lock); in iscsi_check_for_session_reinstatement()
193 if (sess->session_state == TARG_SESS_STATE_FAILED) { in iscsi_check_for_session_reinstatement()
194 spin_unlock_bh(&sess->conn_lock); in iscsi_check_for_session_reinstatement()
195 iscsit_dec_session_usage_count(sess); in iscsi_check_for_session_reinstatement()
206 iscsi_login_set_conn_values( struct iscsit_session *sess, struct iscsit_conn *conn, __be16 cid) iscsi_login_set_conn_values() argument
259 struct iscsit_session *sess = NULL; iscsi_login_zero_tsih_s1() local
343 struct iscsit_session *sess = conn->sess; iscsi_login_zero_tsih_s2() local
490 struct iscsit_session *sess = NULL, *sess_p = NULL; iscsi_login_non_zero_tsih_s2() local
568 struct iscsit_session *sess = conn->sess; iscsi_login_post_auth_non_zero_tsih() local
630 struct iscsit_session *sess = conn->sess; iscsi_post_login_start_timers() local
693 struct iscsit_session *sess = conn->sess; iscsi_post_login_handler() local
[all...]
/kernel/linux/linux-5.10/drivers/tee/amdtee/
H A Dcore.c51 static void release_session(struct amdtee_session *sess) in release_session() argument
58 if (!test_bit(i, sess->sess_mask)) in release_session()
61 handle_close_session(sess->ta_handle, sess->session_info[i]); in release_session()
62 handle_unload_ta(sess->ta_handle); in release_session()
65 kfree(sess); in release_session()
76 struct amdtee_session *sess; in amdtee_release() local
78 sess = list_first_entry_or_null(&ctxdata->sess_list, in amdtee_release()
82 if (!sess) in amdtee_release()
85 list_del(&sess in amdtee_release()
112 struct amdtee_session *sess; alloc_session() local
140 struct amdtee_session *sess; find_session() local
223 struct amdtee_session *sess = container_of(ref, struct amdtee_session, destroy_session() local
236 struct amdtee_session *sess = NULL; amdtee_open_session() local
309 struct amdtee_session *sess; amdtee_close_session() local
412 struct amdtee_session *sess; amdtee_invoke_func() local
[all...]
/kernel/linux/linux-6.6/drivers/tee/amdtee/
H A Dcore.c51 static void release_session(struct amdtee_session *sess) in release_session() argument
58 if (!test_bit(i, sess->sess_mask)) in release_session()
61 handle_close_session(sess->ta_handle, sess->session_info[i]); in release_session()
62 handle_unload_ta(sess->ta_handle); in release_session()
65 kfree(sess); in release_session()
76 struct amdtee_session *sess; in amdtee_release() local
78 sess = list_first_entry_or_null(&ctxdata->sess_list, in amdtee_release()
82 if (!sess) in amdtee_release()
85 list_del(&sess in amdtee_release()
112 struct amdtee_session *sess; alloc_session() local
140 struct amdtee_session *sess; find_session() local
223 struct amdtee_session *sess = container_of(ref, struct amdtee_session, destroy_session() local
236 struct amdtee_session *sess = NULL; amdtee_open_session() local
309 struct amdtee_session *sess; amdtee_close_session() local
412 struct amdtee_session *sess; amdtee_invoke_func() local
[all...]

Completed in 18 milliseconds

12345678