| /Linux-v5.4/net/can/j1939/ |
| D | transport.c | 246 void j1939_session_get(struct j1939_session *session) in j1939_session_get() argument
248 kref_get(&session->kref); in j1939_session_get()
252 static void __j1939_session_drop(struct j1939_session *session) in __j1939_session_drop() argument
254 if (!session->transmission) in __j1939_session_drop()
257 j1939_sock_pending_del(session->sk); in __j1939_session_drop()
258 sock_put(session->sk); in __j1939_session_drop()
261 static void j1939_session_destroy(struct j1939_session *session) in j1939_session_destroy() argument
263 if (session->err) in j1939_session_destroy()
264 j1939_sk_errqueue(session, J1939_ERRQUEUE_ABORT); in j1939_session_destroy()
266 j1939_sk_errqueue(session, J1939_ERRQUEUE_ACK); in j1939_session_destroy()
[all …]
|
| D | socket.c | 97 static bool j1939_sk_queue_session(struct j1939_session *session) in j1939_sk_queue_session() argument
99 struct j1939_sock *jsk = j1939_sk(session->sk); in j1939_sk_queue_session()
104 j1939_session_get(session); in j1939_sk_queue_session()
105 list_add_tail(&session->sk_session_queue_entry, &jsk->sk_session_queue); in j1939_sk_queue_session()
115 struct j1939_session *session = NULL; in j1939_sk_get_incomplete_session() local
119 session = list_last_entry(&jsk->sk_session_queue, in j1939_sk_get_incomplete_session()
122 if (session->total_queued_size == session->total_message_size) in j1939_sk_get_incomplete_session()
123 session = NULL; in j1939_sk_get_incomplete_session()
125 j1939_session_get(session); in j1939_sk_get_incomplete_session()
129 return session; in j1939_sk_get_incomplete_session()
[all …]
|
| /Linux-v5.4/net/bluetooth/hidp/ |
| D | core.c | 72 static void hidp_copy_session(struct hidp_session *session, struct hidp_conninfo *ci) in hidp_copy_session() argument
76 bacpy(&ci->bdaddr, &session->bdaddr); in hidp_copy_session()
78 ci->flags = session->flags & valid_flags; in hidp_copy_session()
81 if (session->input) { in hidp_copy_session()
82 ci->vendor = session->input->id.vendor; in hidp_copy_session()
83 ci->product = session->input->id.product; in hidp_copy_session()
84 ci->version = session->input->id.version; in hidp_copy_session()
85 if (session->input->name) in hidp_copy_session()
86 strlcpy(ci->name, session->input->name, 128); in hidp_copy_session()
89 } else if (session->hid) { in hidp_copy_session()
[all …]
|
| /Linux-v5.4/net/bluetooth/cmtp/ |
| D | core.c | 55 struct cmtp_session *session; in __cmtp_get_session() local
59 list_for_each_entry(session, &cmtp_session_list, list) in __cmtp_get_session()
60 if (!bacmp(bdaddr, &session->bdaddr)) in __cmtp_get_session()
61 return session; in __cmtp_get_session()
66 static void __cmtp_link_session(struct cmtp_session *session) in __cmtp_link_session() argument
68 list_add(&session->list, &cmtp_session_list); in __cmtp_link_session()
71 static void __cmtp_unlink_session(struct cmtp_session *session) in __cmtp_unlink_session() argument
73 list_del(&session->list); in __cmtp_unlink_session()
76 static void __cmtp_copy_session(struct cmtp_session *session, struct cmtp_conninfo *ci) in __cmtp_copy_session() argument
80 bacpy(&ci->bdaddr, &session->bdaddr); in __cmtp_copy_session()
[all …]
|
| D | capi.c | 73 static struct cmtp_application *cmtp_application_add(struct cmtp_session *session, __u16 appl) in cmtp_application_add() argument
77 BT_DBG("session %p application %p appl %d", session, app, appl); in cmtp_application_add()
85 list_add_tail(&app->list, &session->applications); in cmtp_application_add()
90 static void cmtp_application_del(struct cmtp_session *session, struct cmtp_application *app) in cmtp_application_del() argument
92 BT_DBG("session %p application %p", session, app); in cmtp_application_del()
100 static struct cmtp_application *cmtp_application_get(struct cmtp_session *session, int pattern, __u… in cmtp_application_get() argument
104 list_for_each_entry(app, &session->applications, list) { in cmtp_application_get()
124 static int cmtp_msgnum_get(struct cmtp_session *session) in cmtp_msgnum_get() argument
126 session->msgnum++; in cmtp_msgnum_get()
128 if ((session->msgnum & 0xff) > 200) in cmtp_msgnum_get()
[all …]
|
| /Linux-v5.4/net/l2tp/ |
| D | l2tp_core.c | 206 struct l2tp_session *session; in l2tp_tunnel_get_session() local
211 hlist_for_each_entry(session, session_list, hlist) in l2tp_tunnel_get_session()
212 if (session->session_id == session_id) { in l2tp_tunnel_get_session()
213 l2tp_session_inc_refcount(session); in l2tp_tunnel_get_session()
216 return session; in l2tp_tunnel_get_session()
227 struct l2tp_session *session; in l2tp_session_get() local
232 hlist_for_each_entry_rcu(session, session_list, global_hlist) in l2tp_session_get()
233 if (session->session_id == session_id) { in l2tp_session_get()
234 l2tp_session_inc_refcount(session); in l2tp_session_get()
237 return session; in l2tp_session_get()
[all …]
|
| D | l2tp_debugfs.c | 40 struct l2tp_session *session; /* NULL means get next tunnel */ member
56 if (pd->session) in l2tp_dfs_next_session()
57 l2tp_session_dec_refcount(pd->session); in l2tp_dfs_next_session()
59 pd->session = l2tp_session_get_nth(pd->tunnel, pd->session_idx); in l2tp_dfs_next_session()
62 if (pd->session == NULL) { in l2tp_dfs_next_session()
86 if ((pd->tunnel == NULL) && (pd->session == NULL)) in l2tp_dfs_seq_start()
110 if (pd->session) { in l2tp_dfs_seq_stop()
111 l2tp_session_dec_refcount(pd->session); in l2tp_dfs_seq_stop()
112 pd->session = NULL; in l2tp_dfs_seq_stop()
131 struct l2tp_session *session; in l2tp_dfs_seq_tunnel_show() local
[all …]
|
| D | l2tp_ppp.c | 138 static struct sock *pppol2tp_session_get_sock(struct l2tp_session *session) in pppol2tp_session_get_sock() argument
140 struct pppol2tp_session *ps = l2tp_session_priv(session); in pppol2tp_session_get_sock()
156 struct l2tp_session *session; in pppol2tp_sock_to_session() local
162 session = (struct l2tp_session *)(sk->sk_user_data); in pppol2tp_sock_to_session()
163 if (session == NULL) { in pppol2tp_sock_to_session()
168 BUG_ON(session->magic != L2TP_SESSION_MAGIC); in pppol2tp_sock_to_session()
171 return session; in pppol2tp_sock_to_session()
211 static void pppol2tp_recv(struct l2tp_session *session, struct sk_buff *skb, int data_len) in pppol2tp_recv() argument
213 struct pppol2tp_session *ps = l2tp_session_priv(session); in pppol2tp_recv()
238 l2tp_dbg(session, L2TP_MSG_DATA, in pppol2tp_recv()
[all …]
|
| D | l2tp_eth.c | 40 struct l2tp_session *session; member
68 spriv = l2tp_session_priv(priv->session); in l2tp_eth_dev_uninit()
78 struct l2tp_session *session = priv->session; in l2tp_eth_dev_xmit() local
80 int ret = l2tp_xmit_skb(session, skb, session->hdr_len); in l2tp_eth_dev_xmit()
127 static void l2tp_eth_dev_recv(struct l2tp_session *session, struct sk_buff *skb, int data_len) in l2tp_eth_dev_recv() argument
129 struct l2tp_eth_sess *spriv = l2tp_session_priv(session); in l2tp_eth_dev_recv()
133 if (session->debug & L2TP_MSG_DATA) { in l2tp_eth_dev_recv()
140 pr_debug("%s: eth recv\n", session->name); in l2tp_eth_dev_recv()
177 static void l2tp_eth_delete(struct l2tp_session *session) in l2tp_eth_delete() argument
182 if (session) { in l2tp_eth_delete()
[all …]
|
| D | l2tp_core.h | 115 int (*build_header)(struct l2tp_session *session, void *buf);
116 void (*recv_skb)(struct l2tp_session *session, struct sk_buff *skb, int data_len);
117 void (*session_close)(struct l2tp_session *session);
184 int (*session_delete)(struct l2tp_session *session);
187 static inline void *l2tp_session_priv(struct l2tp_session *session) in l2tp_session_priv() argument
189 return &session->priv[0]; in l2tp_session_priv()
215 int l2tp_session_register(struct l2tp_session *session,
218 void __l2tp_session_unhash(struct l2tp_session *session);
219 int l2tp_session_delete(struct l2tp_session *session);
220 void l2tp_session_free(struct l2tp_session *session);
[all …]
|
| D | l2tp_netlink.c | 42 int flags, struct l2tp_session *session,
54 struct l2tp_session *session = NULL; in l2tp_nl_session_get() local
59 session = l2tp_session_get_by_ifname(net, ifname); in l2tp_nl_session_get()
66 session = l2tp_tunnel_get_session(tunnel, session_id); in l2tp_nl_session_get()
71 return session; in l2tp_nl_session_get()
134 struct l2tp_session *session, in l2tp_session_notify() argument
145 NLM_F_ACK, session, cmd); in l2tp_session_notify()
515 struct l2tp_session *session; in l2tp_nl_cmd_session_create() local
627 session = l2tp_tunnel_get_session(tunnel, session_id); in l2tp_nl_cmd_session_create()
628 if (session) { in l2tp_nl_cmd_session_create()
[all …]
|
| /Linux-v5.4/drivers/s390/char/ |
| D | vmcp.c | 60 static void vmcp_response_alloc(struct vmcp_session *session) in vmcp_response_alloc() argument
65 order = get_order(session->bufsize); in vmcp_response_alloc()
66 nr_pages = ALIGN(session->bufsize, PAGE_SIZE) >> PAGE_SHIFT; in vmcp_response_alloc()
75 session->response = (char *)page_to_phys(page); in vmcp_response_alloc()
76 session->cma_alloc = 1; in vmcp_response_alloc()
79 session->response = (char *)__get_free_pages(GFP_KERNEL | __GFP_RETRY_MAYFAIL, order); in vmcp_response_alloc()
82 static void vmcp_response_free(struct vmcp_session *session) in vmcp_response_free() argument
87 if (!session->response) in vmcp_response_free()
89 order = get_order(session->bufsize); in vmcp_response_free()
90 nr_pages = ALIGN(session->bufsize, PAGE_SIZE) >> PAGE_SHIFT; in vmcp_response_free()
[all …]
|
| /Linux-v5.4/drivers/scsi/ |
| D | libiscsi.c | 88 struct Scsi_Host *shost = conn->session->host; in iscsi_conn_queue_work()
96 static void __iscsi_update_cmdsn(struct iscsi_session *session, in __iscsi_update_cmdsn() argument
106 if (exp_cmdsn != session->exp_cmdsn && in __iscsi_update_cmdsn()
107 !iscsi_sna_lt(exp_cmdsn, session->exp_cmdsn)) in __iscsi_update_cmdsn()
108 session->exp_cmdsn = exp_cmdsn; in __iscsi_update_cmdsn()
110 if (max_cmdsn != session->max_cmdsn && in __iscsi_update_cmdsn()
111 !iscsi_sna_lt(max_cmdsn, session->max_cmdsn)) in __iscsi_update_cmdsn()
112 session->max_cmdsn = max_cmdsn; in __iscsi_update_cmdsn()
115 void iscsi_update_cmdsn(struct iscsi_session *session, struct iscsi_nopin *hdr) in iscsi_update_cmdsn() argument
117 __iscsi_update_cmdsn(session, be32_to_cpu(hdr->exp_cmdsn), in iscsi_update_cmdsn()
[all …]
|
| D | scsi_transport_iscsi.c | 1685 int iscsi_session_chkready(struct iscsi_cls_session *session) in iscsi_session_chkready() argument
1690 spin_lock_irqsave(&session->lock, flags); in iscsi_session_chkready()
1691 switch (session->state) { in iscsi_session_chkready()
1705 spin_unlock_irqrestore(&session->lock, flags); in iscsi_session_chkready()
1710 int iscsi_is_session_online(struct iscsi_cls_session *session) in iscsi_is_session_online() argument
1715 spin_lock_irqsave(&session->lock, flags); in iscsi_is_session_online()
1716 if (session->state == ISCSI_SESSION_LOGGED_IN) in iscsi_is_session_online()
1718 spin_unlock_irqrestore(&session->lock, flags); in iscsi_is_session_online()
1725 struct iscsi_cls_session *session = iscsi_dev_to_session(dev); in iscsi_session_release() local
1728 shost = iscsi_session_to_shost(session); in iscsi_session_release()
[all …]
|
| /Linux-v5.4/kernel/trace/ |
| D | trace_stat.c | 47 static void __reset_stat_session(struct stat_session *session) in __reset_stat_session() argument
51 rbtree_postorder_for_each_entry_safe(snode, n, &session->stat_root, node) { in __reset_stat_session()
52 if (session->ts->stat_release) in __reset_stat_session()
53 session->ts->stat_release(snode->stat); in __reset_stat_session()
57 session->stat_root = RB_ROOT; in __reset_stat_session()
60 static void reset_stat_session(struct stat_session *session) in reset_stat_session() argument
62 mutex_lock(&session->stat_mutex); in reset_stat_session()
63 __reset_stat_session(session); in reset_stat_session()
64 mutex_unlock(&session->stat_mutex); in reset_stat_session()
67 static void destroy_session(struct stat_session *session) in destroy_session() argument
[all …]
|
| /Linux-v5.4/tools/perf/util/ |
| D | session.h | 59 void perf_session__delete(struct perf_session *session);
63 int perf_session__peek_event(struct perf_session *session, off_t file_offset,
68 int perf_session__process_events(struct perf_session *session);
75 int perf_session__resolve_callchain(struct perf_session *session,
81 bool perf_session__has_traces(struct perf_session *session, const char *msg);
85 int perf_session__create_kernel_maps(struct perf_session *session);
87 void perf_session__set_id_hdr_size(struct perf_session *session);
90 struct machine *perf_session__find_machine(struct perf_session *session, pid_t pid) in perf_session__find_machine() argument
92 return machines__find(&session->machines, pid); in perf_session__find_machine()
96 struct machine *perf_session__findnew_machine(struct perf_session *session, pid_t pid) in perf_session__findnew_machine() argument
[all …]
|
| D | session.c | 39 static int perf_session__process_compressed_event(struct perf_session *session, in perf_session__process_compressed_event() argument
45 size_t mmap_len, decomp_len = session->header.env.comp_mmap_len; in perf_session__process_compressed_event()
46 struct decomp *decomp, *decomp_last = session->decomp_last; in perf_session__process_compressed_event()
73 decomp_size = zstd_decompress_stream(&(session->zstd_data), src, src_size, in perf_session__process_compressed_event()
83 if (session->decomp == NULL) { in perf_session__process_compressed_event()
84 session->decomp = decomp; in perf_session__process_compressed_event()
85 session->decomp_last = decomp; in perf_session__process_compressed_event()
87 session->decomp_last->next = decomp; in perf_session__process_compressed_event()
88 session->decomp_last = decomp; in perf_session__process_compressed_event()
99 static int perf_session__deliver_event(struct perf_session *session,
[all …]
|
| D | arm-spe.c | 33 struct perf_session *session; member
95 static int arm_spe_process_event(struct perf_session *session __maybe_unused, in arm_spe_process_event()
103 static int arm_spe_process_auxtrace_event(struct perf_session *session, in arm_spe_process_auxtrace_event() argument
107 struct arm_spe *spe = container_of(session->auxtrace, struct arm_spe, in arm_spe_process_auxtrace_event()
111 int fd = perf_data__fd(session->data); in arm_spe_process_auxtrace_event()
114 if (perf_data__is_pipe(session->data)) { in arm_spe_process_auxtrace_event()
122 err = auxtrace_queues__add_event(&spe->queues, session, event, in arm_spe_process_auxtrace_event()
139 static int arm_spe_flush(struct perf_session *session __maybe_unused, in arm_spe_flush()
154 static void arm_spe_free_events(struct perf_session *session) in arm_spe_free_events() argument
156 struct arm_spe *spe = container_of(session->auxtrace, struct arm_spe, in arm_spe_free_events()
[all …]
|
| /Linux-v5.4/tools/perf/tests/ |
| D | topology.c | 34 struct perf_session *session; in session_write_header() local
42 session = perf_session__new(&data, false, NULL); in session_write_header()
43 TEST_ASSERT_VAL("can't get session", !IS_ERR(session)); in session_write_header()
45 session->evlist = perf_evlist__new_default(); in session_write_header()
46 TEST_ASSERT_VAL("can't get evlist", session->evlist); in session_write_header()
48 perf_header__set_feat(&session->header, HEADER_CPU_TOPOLOGY); in session_write_header()
49 perf_header__set_feat(&session->header, HEADER_NRCPUS); in session_write_header()
50 perf_header__set_feat(&session->header, HEADER_ARCH); in session_write_header()
52 session->header.data_size += DATA_SIZE; in session_write_header()
55 !perf_session__write_header(session, session->evlist, data.file.fd, true)); in session_write_header()
[all …]
|
| /Linux-v5.4/fs/ceph/ |
| D | mds_client.c | 51 struct ceph_mds_session *session; member
1007 mds = cap->session->s_mds; in __choose_mds()
1155 struct ceph_mds_session *session) in __open_session() argument
1159 int mds = session->s_mds; in __open_session()
1165 session->s_state = CEPH_MDS_SESSION_OPENING; in __open_session()
1166 session->s_renew_requested = jiffies; in __open_session()
1169 msg = create_session_open_msg(mdsc, session->s_seq); in __open_session()
1172 ceph_con_send(&session->s_con, msg); in __open_session()
1184 struct ceph_mds_session *session; in __open_export_target_session() local
1186 session = __ceph_lookup_mds_session(mdsc, target); in __open_export_target_session()
[all …]
|
| /Linux-v5.4/drivers/virt/vboxguest/ |
| D | vboxguest_core.c | 574 struct vbg_session *session, in vbg_set_session_event_filter() argument
589 session->requestor); in vbg_set_session_event_filter()
599 previous = session->event_filter; in vbg_set_session_event_filter()
600 session->event_filter |= or_mask; in vbg_set_session_event_filter()
601 session->event_filter &= ~not_mask; in vbg_set_session_event_filter()
604 changed = previous ^ session->event_filter; in vbg_set_session_event_filter()
627 session->event_filter); in vbg_set_session_event_filter()
628 session->event_filter = previous; in vbg_set_session_event_filter()
676 struct vbg_session *session, in vbg_set_session_capabilities() argument
691 session->requestor); in vbg_set_session_capabilities()
[all …]
|
| /Linux-v5.4/tools/perf/ |
| D | builtin-report.c | 72 struct perf_session *session; member
213 static int process_feature_event(struct perf_session *session, in process_feature_event() argument
216 struct report *rep = container_of(session->tool, struct report, tool); in process_feature_event()
219 return perf_event__process_feature(session, event); in process_feature_event()
232 setup_forced_leader(rep, session->evlist); in process_feature_event()
332 struct perf_session *session = rep->session; in report__setup_sample_type() local
333 u64 sample_type = perf_evlist__combined_sample_type(session->evlist); in report__setup_sample_type()
334 bool is_pipe = perf_data__is_pipe(session->data); in report__setup_sample_type()
336 if (session->itrace_synth_opts->callchain || in report__setup_sample_type()
338 perf_header__has_feat(&session->header, HEADER_AUXTRACE) && in report__setup_sample_type()
[all …]
|
| D | builtin-inject.c | 36 struct perf_session *session; member
93 static int perf_event__repipe_op2_synth(struct perf_session *session, in perf_event__repipe_op2_synth() argument
96 return perf_event__repipe_synth(session->tool, event); in perf_event__repipe_op2_synth()
138 static s64 perf_event__repipe_auxtrace(struct perf_session *session, in perf_event__repipe_auxtrace() argument
141 struct perf_tool *tool = session->tool; in perf_event__repipe_auxtrace()
154 ret = auxtrace_index__auxtrace_event(&session->auxtrace_index, in perf_event__repipe_auxtrace()
160 if (perf_data__is_pipe(session->data) || !session->one_mmap) { in perf_event__repipe_auxtrace()
164 ret = copy_bytes(inject, perf_data__fd(session->data), in perf_event__repipe_auxtrace()
179 perf_event__repipe_auxtrace(struct perf_session *session __maybe_unused, in perf_event__repipe_auxtrace()
265 ret = jit_process(inject->session, &inject->output, machine, in perf_event__jit_repipe_mmap()
[all …]
|
| D | builtin-buildid-list.c | 54 struct perf_session *session; in perf_session__list_build_ids() local
68 session = perf_session__new(&data, false, &build_id__mark_dso_hit_ops); in perf_session__list_build_ids()
69 if (IS_ERR(session)) in perf_session__list_build_ids()
70 return PTR_ERR(session); in perf_session__list_build_ids()
77 perf_header__has_feat(&session->header, HEADER_AUXTRACE)) in perf_session__list_build_ids()
85 perf_session__process_events(session); in perf_session__list_build_ids()
87 perf_session__fprintf_dsos_buildid(session, stdout, dso__skip_buildid, with_hits); in perf_session__list_build_ids()
88 perf_session__delete(session); in perf_session__list_build_ids()
|
| /Linux-v5.4/drivers/net/ethernet/mellanox/mlx5/core/en/ |
| D | xdp.h | 121 struct mlx5e_xdp_mpwqe *session = &sq->mpwqe; in mlx5e_xdp_update_inline_state() local
126 if (session->inline_on) { in mlx5e_xdp_update_inline_state()
128 session->inline_on = 0; in mlx5e_xdp_update_inline_state()
134 session->inline_on = 1; in mlx5e_xdp_update_inline_state()
138 mlx5e_xdp_no_room_for_inline_pkt(struct mlx5e_xdp_mpwqe *session) in mlx5e_xdp_no_room_for_inline_pkt() argument
140 return session->inline_on && in mlx5e_xdp_no_room_for_inline_pkt()
141 session->ds_count + MLX5E_XDP_INLINE_WQE_MAX_DS_CNT > MLX5E_XDP_MPW_MAX_NUM_DS; in mlx5e_xdp_no_room_for_inline_pkt()
166 struct mlx5e_xdp_mpwqe *session = &sq->mpwqe; in mlx5e_xdp_mpwqe_add_dseg() local
168 (struct mlx5_wqe_data_seg *)session->wqe + session->ds_count; in mlx5e_xdp_mpwqe_add_dseg()
171 session->pkt_count++; in mlx5e_xdp_mpwqe_add_dseg()
[all …]
|
