58 int trace_pid(struct request *rq)  in trace_pid()  argument
65 	bpf_map_update_elem(&infobyreq, &rq, &piddata, 0);  in trace_pid()
70 int BPF_PROG(blk_account_io_start, struct request *rq)  in BPF_PROG()  argument
75 	return trace_pid(rq);  in BPF_PROG()
79 int BPF_KPROBE(blk_account_io_merge_bio, struct request *rq)  in BPF_KPROBE()  argument
84 	return trace_pid(rq);  in BPF_KPROBE()
88 int trace_rq_start(struct request *rq, bool insert)  in trace_rq_start()  argument
93 	stagep = bpf_map_lookup_elem(&start, &rq);  in trace_rq_start()
95 		struct gendisk *disk = BPF_CORE_READ(rq, rq_disk);  in trace_rq_start()
108 		bpf_map_update_elem(&start, &rq, stagep, 0);  in trace_rq_start()
147 int BPF_PROG(block_rq_complete, struct request *rq, int error,  in BPF_PROG()  argument
159 	stagep = bpf_map_lookup_elem(&start, &rq);  in BPF_PROG()
165 	piddatap = bpf_map_lookup_elem(&infobyreq, &rq);  in BPF_PROG()
174 	if (targ_queued && BPF_CORE_READ(rq, q, elevator)) {  in BPF_PROG()
181 	event.sector = rq->__sector;  in BPF_PROG()
182 	event.len = rq->__data_len;  in BPF_PROG()
183 	event.cmd_flags = rq->cmd_flags;  in BPF_PROG()
189 	bpf_map_delete_elem(&start, &rq);  in BPF_PROG()
190 	bpf_map_delete_elem(&infobyreq, &rq);  in BPF_PROG()