Searched defs:peer_req (Results 1 - 5 of 5) sorted by relevance
/drivers/block/drbd/ |
H A D | drbd_debugfs.c | 228 /* pretty print enum peer_req->flags */ 229 static void seq_print_peer_request_flags(struct seq_file *m, struct drbd_peer_request *peer_req) argument 231 unsigned long f = peer_req->flags; 256 struct drbd_peer_request *peer_req; local 257 list_for_each_entry(peer_req, lh, w.list) { 258 if (reported_preparing && !(peer_req->flags & EE_SUBMITTED)) 265 (unsigned long long)peer_req->i.sector, peer_req->i.size >> 9, 266 (peer_req->flags & EE_WRITE) ? 'W' : 'R', 267 jiffies_to_msecs(now - peer_req [all...] |
H A D | drbd_worker.c | 97 static void drbd_endio_read_sec_final(struct drbd_peer_request *peer_req) __releases(local) 100 struct drbd_peer_device *peer_device = peer_req->peer_device; 104 device->read_cnt += peer_req->i.size >> 9; 105 list_del(&peer_req->w.list); 108 if (test_bit(__EE_WAS_ERROR, &peer_req->flags)) 112 drbd_queue_work(&peer_device->connection->sender_work, &peer_req->w); 118 void drbd_endio_write_sec_final(struct drbd_peer_request *peer_req) __releases(local) 121 struct drbd_peer_device *peer_device = peer_req->peer_device; 128 /* after we moved peer_req to done_ee, 132 i = peer_req 175 struct drbd_peer_request *peer_req = bio->bi_private; local 294 drbd_csum_ee(struct crypto_hash *tfm, struct drbd_peer_request *peer_req, void *digest) argument 344 struct drbd_peer_request *peer_req = container_of(w, struct drbd_peer_request, w); local 394 struct drbd_peer_request *peer_req; local 997 move_to_net_ee_or_free(struct drbd_device *device, struct drbd_peer_request *peer_req) argument 1020 struct drbd_peer_request *peer_req = container_of(w, struct drbd_peer_request, w); local 1057 struct drbd_peer_request *peer_req = container_of(w, struct drbd_peer_request, w); local 1107 struct drbd_peer_request *peer_req = container_of(w, struct drbd_peer_request, w); local 1171 struct drbd_peer_request *peer_req = container_of(w, struct drbd_peer_request, w); local 1228 struct drbd_peer_request *peer_req = container_of(w, struct drbd_peer_request, w); local [all...] |
H A D | drbd_main.c | 1357 * @peer_req: peer request 1360 struct drbd_peer_request *peer_req) 1363 cpu_to_be64(peer_req->i.sector), 1364 cpu_to_be32(peer_req->i.size), 1365 peer_req->block_id); 1586 struct drbd_peer_request *peer_req) 1588 struct page *page = peer_req->pages; 1589 unsigned len = peer_req->i.size; 1708 struct drbd_peer_request *peer_req) 1724 p->sector = cpu_to_be64(peer_req 1359 drbd_send_ack(struct drbd_peer_device *peer_device, enum drbd_packet cmd, struct drbd_peer_request *peer_req) argument 1585 _drbd_send_zc_ee(struct drbd_peer_device *peer_device, struct drbd_peer_request *peer_req) argument 1707 drbd_send_block(struct drbd_peer_device *peer_device, enum drbd_packet cmd, struct drbd_peer_request *peer_req) argument [all...] |
H A D | drbd_receiver.c | 204 struct drbd_peer_request *peer_req, *tmp; local 211 list_for_each_entry_safe(peer_req, tmp, &device->net_ee, w.list) { 212 if (drbd_peer_req_has_active_page(peer_req)) 214 list_move(&peer_req->w.list, to_be_freed); 221 struct drbd_peer_request *peer_req, *t; local 227 list_for_each_entry_safe(peer_req, t, &reclaimed, w.list) 228 drbd_free_net_peer_req(device, peer_req); 345 struct drbd_peer_request *peer_req; local 352 peer_req = mempool_alloc(drbd_ee_mempool, gfp_mask & ~__GFP_HIGHMEM); 353 if (!peer_req) { 386 __drbd_free_peer_req(struct drbd_device *device, struct drbd_peer_request *peer_req, int is_net) argument 405 struct drbd_peer_request *peer_req, *t; local 427 struct drbd_peer_request *peer_req, *t; local 1366 drbd_submit_peer_request(struct drbd_device *device, struct drbd_peer_request *peer_req, const unsigned rw, const int fault_type) argument 1479 drbd_remove_epoch_entry_interval(struct drbd_device *device, struct drbd_peer_request *peer_req) argument 1592 struct drbd_peer_request *peer_req; local 1759 struct drbd_peer_request *peer_req = local 1786 struct drbd_peer_request *peer_req; local 1932 struct drbd_peer_request *peer_req = local 1975 struct drbd_peer_request *peer_req = local 1993 struct drbd_peer_request *peer_req = local 2038 overlapping_resync_write(struct drbd_device *device, struct drbd_peer_request *peer_req) argument 2161 handle_write_conflicts(struct drbd_device *device, struct drbd_peer_request *peer_req) argument 2276 struct drbd_peer_request *peer_req; local 2366 drbd_send_ack(first_peer_device(device), P_RECV_ACK, peer_req); local 2518 struct drbd_peer_request *peer_req; local [all...] |
H A D | drbd_int.h | 464 /* Is set when net_conf had two_primaries set while creating this peer_req */ 1536 extern void drbd_endio_write_sec_final(struct drbd_peer_request *peer_req); 1709 static inline int drbd_peer_req_has_active_page(struct drbd_peer_request *peer_req) argument 1711 struct page *page = peer_req->pages;
|
Completed in 43 milliseconds