Home
last modified time | relevance | path

Searched refs:peer_req (Results 1 – 5 of 5) sorted by relevance

/linux-6.15/drivers/block/drbd/
H A Ddrbd_worker.c117 i = peer_req->i; in drbd_endio_write_sec_final()
127 drbd_set_out_of_sync(peer_device, peer_req->i.sector, peer_req->i.size); in drbd_endio_write_sec_final()
365 peer_req = NULL; in w_e_send_csum()
377 if (peer_req) in w_e_send_csum()
399 if (!peer_req) in read_for_csum()
1137 if (peer_req->flags & EE_RS_THIN_REQ && all_zero(peer_req)) in w_e_end_rsdata_req()
1155 drbd_rs_failed_io(peer_device, peer_req->i.sector, peer_req->i.size); in w_e_end_rsdata_req()
1188 di = peer_req->digest; in w_e_end_csum_rs_req()
1206 drbd_set_in_sync(peer_device, peer_req->i.sector, peer_req->i.size); in w_e_end_csum_rs_req()
1263 peer_req = NULL; in w_e_end_ov_req()
[all …]
H A Ddrbd_receiver.c372 if (!peer_req) { in drbd_alloc_peer_req()
385 memset(peer_req, 0, sizeof(*peer_req)); in drbd_alloc_peer_req()
399 return peer_req; in drbd_alloc_peer_req()
466 err2 = peer_req->w.cb(&peer_req->w, !!err); in drbd_finish_peer_reqs()
1909 if (!peer_req) in read_in_block()
1915 return peer_req; in read_in_block()
1951 return peer_req; in read_in_block()
2066 if (!peer_req) in recv_resync_read()
2320 if (overlaps(peer_req->i.sector, peer_req->i.size, in overlapping_resync_write()
2591 if (!peer_req) { in receive_Data()
[all …]
H A Ddrbd_debugfs.c230 static void seq_print_peer_request_flags(struct seq_file *m, struct drbd_peer_request *peer_req) in seq_print_peer_request_flags() argument
232 unsigned long f = peer_req->flags; in seq_print_peer_request_flags()
251 struct drbd_peer_request *peer_req; in seq_print_peer_request() local
252 list_for_each_entry(peer_req, lh, w.list) { in seq_print_peer_request()
253 if (reported_preparing && !(peer_req->flags & EE_SUBMITTED)) in seq_print_peer_request()
260 (unsigned long long)peer_req->i.sector, peer_req->i.size >> 9, in seq_print_peer_request()
261 (peer_req->flags & EE_WRITE) ? 'W' : 'R', in seq_print_peer_request()
262 jiffies_to_msecs(now - peer_req->submit_jif)); in seq_print_peer_request()
263 seq_print_peer_request_flags(m, peer_req); in seq_print_peer_request()
264 if (peer_req->flags & EE_SUBMITTED) in seq_print_peer_request()
H A Ddrbd_main.c1369 struct drbd_peer_request *peer_req) in drbd_send_ack() argument
1372 cpu_to_be64(peer_req->i.sector), in drbd_send_ack()
1373 cpu_to_be32(peer_req->i.size), in drbd_send_ack()
1374 peer_req->block_id); in drbd_send_ack()
1389 struct drbd_peer_request *peer_req) in drbd_send_rs_deallocated() argument
1399 p->blksize = cpu_to_be32(peer_req->i.size); in drbd_send_rs_deallocated()
1612 struct drbd_peer_request *peer_req) in _drbd_send_zc_ee() argument
1614 struct page *page = peer_req->pages; in _drbd_send_zc_ee()
1615 unsigned len = peer_req->i.size; in _drbd_send_zc_ee()
1744 struct drbd_peer_request *peer_req) in drbd_send_block() argument
[all …]
H A Ddrbd_int.h335 #define peer_req_op(peer_req) \ argument
336 ((peer_req)->opf & REQ_OP_MASK)
1474 extern void drbd_endio_write_sec_final(struct drbd_peer_request *peer_req);
1485 extern int drbd_submit_peer_request(struct drbd_peer_request *peer_req);
1613 static inline int drbd_peer_req_has_active_page(struct drbd_peer_request *peer_req) in drbd_peer_req_has_active_page() argument
1615 struct page *page = peer_req->pages; in drbd_peer_req_has_active_page()