1 | /* SPDX-License-Identifier: GPL-2.0+ */ |
2 | /* |
3 | * RDMA Network Block Driver |
4 | * |
5 | * Copyright (c) 2022 1&1 IONOS SE. All rights reserved. |
6 | */ |
7 | #undef TRACE_SYSTEM |
8 | #define TRACE_SYSTEM rnbd_srv |
9 | |
10 | #if !defined(_TRACE_RNBD_SRV_H) || defined(TRACE_HEADER_MULTI_READ) |
11 | #define _TRACE_RNBD_SRV_H |
12 | |
13 | #include <linux/tracepoint.h> |
14 | |
15 | struct rnbd_srv_session; |
16 | struct rtrs_srv_op; |
17 | |
18 | DECLARE_EVENT_CLASS(rnbd_srv_link_class, |
19 | TP_PROTO(struct rnbd_srv_session *srv), |
20 | |
21 | TP_ARGS(srv), |
22 | |
23 | TP_STRUCT__entry( |
24 | __field(int, qdepth) |
25 | __string(sessname, srv->sessname) |
26 | ), |
27 | |
28 | TP_fast_assign( |
29 | __entry->qdepth = srv->queue_depth; |
30 | __assign_str(sessname, srv->sessname); |
31 | ), |
32 | |
33 | TP_printk("sessname: %s qdepth: %d" , |
34 | __get_str(sessname), |
35 | __entry->qdepth |
36 | ) |
37 | ); |
38 | |
39 | #define DEFINE_LINK_EVENT(name) \ |
40 | DEFINE_EVENT(rnbd_srv_link_class, name, \ |
41 | TP_PROTO(struct rnbd_srv_session *srv), \ |
42 | TP_ARGS(srv)) |
43 | |
44 | DEFINE_LINK_EVENT(create_sess); |
45 | DEFINE_LINK_EVENT(destroy_sess); |
46 | |
47 | TRACE_DEFINE_ENUM(RNBD_OP_READ); |
48 | TRACE_DEFINE_ENUM(RNBD_OP_WRITE); |
49 | TRACE_DEFINE_ENUM(RNBD_OP_FLUSH); |
50 | TRACE_DEFINE_ENUM(RNBD_OP_DISCARD); |
51 | TRACE_DEFINE_ENUM(RNBD_OP_SECURE_ERASE); |
52 | TRACE_DEFINE_ENUM(RNBD_F_SYNC); |
53 | TRACE_DEFINE_ENUM(RNBD_F_FUA); |
54 | |
55 | #define show_rnbd_rw_flags(x) \ |
56 | __print_flags(x, "|", \ |
57 | { RNBD_OP_READ, "READ" }, \ |
58 | { RNBD_OP_WRITE, "WRITE" }, \ |
59 | { RNBD_OP_FLUSH, "FLUSH" }, \ |
60 | { RNBD_OP_DISCARD, "DISCARD" }, \ |
61 | { RNBD_OP_SECURE_ERASE, "SECURE_ERASE" }, \ |
62 | { RNBD_F_SYNC, "SYNC" }, \ |
63 | { RNBD_F_FUA, "FUA" }) |
64 | |
65 | TRACE_EVENT(process_rdma, |
66 | TP_PROTO(struct rnbd_srv_session *srv, |
67 | const struct rnbd_msg_io *msg, |
68 | struct rtrs_srv_op *id, |
69 | u32 datalen, |
70 | size_t usrlen), |
71 | |
72 | TP_ARGS(srv, msg, id, datalen, usrlen), |
73 | |
74 | TP_STRUCT__entry( |
75 | __string(sessname, srv->sessname) |
76 | __field(u8, dir) |
77 | __field(u8, ver) |
78 | __field(u32, device_id) |
79 | __field(u64, sector) |
80 | __field(u32, flags) |
81 | __field(u32, bi_size) |
82 | __field(u16, ioprio) |
83 | __field(u32, datalen) |
84 | __field(size_t, usrlen) |
85 | ), |
86 | |
87 | TP_fast_assign( |
88 | __assign_str(sessname, srv->sessname); |
89 | __entry->dir = id->dir; |
90 | __entry->ver = srv->ver; |
91 | __entry->device_id = le32_to_cpu(msg->device_id); |
92 | __entry->sector = le64_to_cpu(msg->sector); |
93 | __entry->bi_size = le32_to_cpu(msg->bi_size); |
94 | __entry->flags = le32_to_cpu(msg->rw); |
95 | __entry->ioprio = le16_to_cpu(msg->prio); |
96 | __entry->datalen = datalen; |
97 | __entry->usrlen = usrlen; |
98 | ), |
99 | |
100 | TP_printk("I/O req: sess: %s, type: %s, ver: %d, devid: %u, sector: %llu, bsize: %u, flags: %s, ioprio: %d, datalen: %u, usrlen: %zu" , |
101 | __get_str(sessname), |
102 | __print_symbolic(__entry->dir, |
103 | { READ, "READ" }, |
104 | { WRITE, "WRITE" }), |
105 | __entry->ver, |
106 | __entry->device_id, |
107 | __entry->sector, |
108 | __entry->bi_size, |
109 | show_rnbd_rw_flags(__entry->flags), |
110 | __entry->ioprio, |
111 | __entry->datalen, |
112 | __entry->usrlen |
113 | ) |
114 | ); |
115 | |
116 | TRACE_EVENT(process_msg_sess_info, |
117 | TP_PROTO(struct rnbd_srv_session *srv, |
118 | const struct rnbd_msg_sess_info *msg), |
119 | |
120 | TP_ARGS(srv, msg), |
121 | |
122 | TP_STRUCT__entry( |
123 | __field(u8, proto_ver) |
124 | __field(u8, clt_ver) |
125 | __field(u8, srv_ver) |
126 | __string(sessname, srv->sessname) |
127 | ), |
128 | |
129 | TP_fast_assign( |
130 | __entry->proto_ver = srv->ver; |
131 | __entry->clt_ver = msg->ver; |
132 | __entry->srv_ver = RNBD_PROTO_VER_MAJOR; |
133 | __assign_str(sessname, srv->sessname); |
134 | ), |
135 | |
136 | TP_printk("Session %s using proto-ver %d (clt-ver: %d, srv-ver: %d)" , |
137 | __get_str(sessname), |
138 | __entry->proto_ver, |
139 | __entry->clt_ver, |
140 | __entry->srv_ver |
141 | ) |
142 | ); |
143 | |
144 | TRACE_DEFINE_ENUM(RNBD_ACCESS_RO); |
145 | TRACE_DEFINE_ENUM(RNBD_ACCESS_RW); |
146 | TRACE_DEFINE_ENUM(RNBD_ACCESS_MIGRATION); |
147 | |
148 | #define show_rnbd_access_mode(x) \ |
149 | __print_symbolic(x, \ |
150 | { RNBD_ACCESS_RO, "RO" }, \ |
151 | { RNBD_ACCESS_RW, "RW" }, \ |
152 | { RNBD_ACCESS_MIGRATION, "MIGRATION" }) |
153 | |
154 | TRACE_EVENT(process_msg_open, |
155 | TP_PROTO(struct rnbd_srv_session *srv, |
156 | const struct rnbd_msg_open *msg), |
157 | |
158 | TP_ARGS(srv, msg), |
159 | |
160 | TP_STRUCT__entry( |
161 | __field(u8, access_mode) |
162 | __string(sessname, srv->sessname) |
163 | __string(dev_name, msg->dev_name) |
164 | ), |
165 | |
166 | TP_fast_assign( |
167 | __entry->access_mode = msg->access_mode; |
168 | __assign_str(sessname, srv->sessname); |
169 | __assign_str(dev_name, msg->dev_name); |
170 | ), |
171 | |
172 | TP_printk("Open message received: session='%s' path='%s' access_mode=%s" , |
173 | __get_str(sessname), |
174 | __get_str(dev_name), |
175 | show_rnbd_access_mode(__entry->access_mode) |
176 | ) |
177 | ); |
178 | |
179 | TRACE_EVENT(process_msg_close, |
180 | TP_PROTO(struct rnbd_srv_session *srv, |
181 | const struct rnbd_msg_close *msg), |
182 | |
183 | TP_ARGS(srv, msg), |
184 | |
185 | TP_STRUCT__entry( |
186 | __field(u32, device_id) |
187 | __string(sessname, srv->sessname) |
188 | ), |
189 | |
190 | TP_fast_assign( |
191 | __entry->device_id = le32_to_cpu(msg->device_id); |
192 | __assign_str(sessname, srv->sessname); |
193 | ), |
194 | |
195 | TP_printk("Close message received: session='%s' device id='%d'" , |
196 | __get_str(sessname), |
197 | __entry->device_id |
198 | ) |
199 | ); |
200 | |
201 | #endif /* _TRACE_RNBD_SRV_H */ |
202 | |
203 | #undef TRACE_INCLUDE_PATH |
204 | #define TRACE_INCLUDE_PATH . |
205 | #define TRACE_INCLUDE_FILE rnbd-srv-trace |
206 | #include <trace/define_trace.h> |
207 | |
208 | |