Searched refs:peer_req (Results 1 – 5 of 5) sorted by relevance
| /Linux-v4.19/drivers/block/drbd/ |
| D | drbd_worker.c | 92 static void drbd_endio_read_sec_final(struct drbd_peer_request *peer_req) __releases(local) in drbd_endio_read_sec_final() argument
95 struct drbd_peer_device *peer_device = peer_req->peer_device; in drbd_endio_read_sec_final()
99 device->read_cnt += peer_req->i.size >> 9; in drbd_endio_read_sec_final()
100 list_del(&peer_req->w.list); in drbd_endio_read_sec_final()
103 if (test_bit(__EE_WAS_ERROR, &peer_req->flags)) in drbd_endio_read_sec_final()
107 drbd_queue_work(&peer_device->connection->sender_work, &peer_req->w); in drbd_endio_read_sec_final()
113 void drbd_endio_write_sec_final(struct drbd_peer_request *peer_req) __releases(local) in drbd_endio_write_sec_final() argument
116 struct drbd_peer_device *peer_device = peer_req->peer_device; in drbd_endio_write_sec_final()
128 i = peer_req->i; in drbd_endio_write_sec_final()
129 do_al_complete_io = peer_req->flags & EE_CALL_AL_COMPLETE_IO; in drbd_endio_write_sec_final()
[all …]
|
| D | drbd_receiver.c | 206 struct drbd_peer_request *peer_req, *tmp; in reclaim_finished_net_peer_reqs() local
213 list_for_each_entry_safe(peer_req, tmp, &device->net_ee, w.list) { in reclaim_finished_net_peer_reqs()
214 if (drbd_peer_req_has_active_page(peer_req)) in reclaim_finished_net_peer_reqs()
216 list_move(&peer_req->w.list, to_be_freed); in reclaim_finished_net_peer_reqs()
223 struct drbd_peer_request *peer_req, *t; in drbd_reclaim_net_peer_reqs() local
228 list_for_each_entry_safe(peer_req, t, &reclaimed, w.list) in drbd_reclaim_net_peer_reqs()
229 drbd_free_net_peer_req(device, peer_req); in drbd_reclaim_net_peer_reqs()
374 struct drbd_peer_request *peer_req; in drbd_alloc_peer_req() local
381 peer_req = mempool_alloc(&drbd_ee_mempool, gfp_mask & ~__GFP_HIGHMEM); in drbd_alloc_peer_req()
382 if (!peer_req) { in drbd_alloc_peer_req()
[all …]
|
| D | drbd_debugfs.c | 230 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()
249 struct drbd_peer_request *peer_req; in seq_print_peer_request() local
250 list_for_each_entry(peer_req, lh, w.list) { in seq_print_peer_request()
251 if (reported_preparing && !(peer_req->flags & EE_SUBMITTED)) in seq_print_peer_request()
258 (unsigned long long)peer_req->i.sector, peer_req->i.size >> 9, in seq_print_peer_request()
259 (peer_req->flags & EE_WRITE) ? 'W' : 'R', in seq_print_peer_request()
260 jiffies_to_msecs(now - peer_req->submit_jif)); in seq_print_peer_request()
261 seq_print_peer_request_flags(m, peer_req); in seq_print_peer_request()
262 if (peer_req->flags & EE_SUBMITTED) in seq_print_peer_request()
|
| D | drbd_main.c | 1398 struct drbd_peer_request *peer_req) in drbd_send_ack() argument
1401 cpu_to_be64(peer_req->i.sector), in drbd_send_ack()
1402 cpu_to_be32(peer_req->i.size), in drbd_send_ack()
1403 peer_req->block_id); in drbd_send_ack()
1418 struct drbd_peer_request *peer_req) in drbd_send_rs_deallocated() argument
1427 p->sector = cpu_to_be64(peer_req->i.sector); in drbd_send_rs_deallocated()
1428 p->blksize = cpu_to_be32(peer_req->i.size); in drbd_send_rs_deallocated()
1643 struct drbd_peer_request *peer_req) in _drbd_send_zc_ee() argument
1645 struct page *page = peer_req->pages; in _drbd_send_zc_ee()
1646 unsigned len = peer_req->i.size; in _drbd_send_zc_ee()
[all …]
|
| D | drbd_int.h | 1555 extern void drbd_endio_write_sec_final(struct drbd_peer_request *peer_req);
1730 static inline int drbd_peer_req_has_active_page(struct drbd_peer_request *peer_req) in drbd_peer_req_has_active_page() argument
1732 struct page *page = peer_req->pages; in drbd_peer_req_has_active_page()
|
