Lines Matching refs:peer_device
222 struct drbd_peer_device *peer_device; in conn_reclaim_net_peer_reqs() local
226 idr_for_each_entry(&connection->peer_devices, peer_device, vnr) { in conn_reclaim_net_peer_reqs()
227 struct drbd_device *device = peer_device->device; in conn_reclaim_net_peer_reqs()
260 struct page *drbd_alloc_pages(struct drbd_peer_device *peer_device, unsigned int number, in drbd_alloc_pages() argument
263 struct drbd_device *device = peer_device->device; in drbd_alloc_pages()
270 nc = rcu_dereference(peer_device->connection->net_conf); in drbd_alloc_pages()
358 drbd_alloc_peer_req(struct drbd_peer_device *peer_device, u64 id, sector_t sector, in drbd_alloc_peer_req() argument
361 struct drbd_device *device = peer_device->device; in drbd_alloc_peer_req()
377 page = drbd_alloc_pages(peer_device, nr_pages, in drbd_alloc_peer_req()
389 peer_req->peer_device = peer_device; in drbd_alloc_peer_req()
887 int drbd_connected(struct drbd_peer_device *peer_device) in drbd_connected() argument
889 struct drbd_device *device = peer_device->device; in drbd_connected()
895 device->state_mutex = peer_device->connection->agreed_pro_version < 100 ? in drbd_connected()
896 &peer_device->connection->cstate_mutex : in drbd_connected()
899 err = drbd_send_sync_param(peer_device); in drbd_connected()
901 err = drbd_send_sizes(peer_device, 0, 0); in drbd_connected()
903 err = drbd_send_uuids(peer_device); in drbd_connected()
905 err = drbd_send_current_state(peer_device); in drbd_connected()
924 struct drbd_peer_device *peer_device; in conn_connect() local
1089 idr_for_each_entry(&connection->peer_devices, peer_device, vnr) in conn_connect()
1090 mutex_lock(peer_device->device->state_mutex); in conn_connect()
1097 idr_for_each_entry(&connection->peer_devices, peer_device, vnr) in conn_connect()
1098 mutex_unlock(peer_device->device->state_mutex); in conn_connect()
1101 idr_for_each_entry(&connection->peer_devices, peer_device, vnr) { in conn_connect()
1102 struct drbd_device *device = peer_device->device; in conn_connect()
1111 drbd_connected(peer_device); in conn_connect()
1312 struct drbd_peer_device *peer_device; in drbd_flush() local
1321 idr_for_each_entry(&connection->peer_devices, peer_device, vnr) { in drbd_flush()
1322 struct drbd_device *device = peer_device->device; in drbd_flush()
1659 conn_wait_active_ee_empty(peer_req->peer_device->connection); in drbd_submit_peer_request()
1753 struct drbd_peer_device *peer_device; in conn_wait_active_ee_empty() local
1757 idr_for_each_entry(&connection->peer_devices, peer_device, vnr) { in conn_wait_active_ee_empty()
1758 struct drbd_device *device = peer_device->device; in conn_wait_active_ee_empty()
1858 read_in_block(struct drbd_peer_device *peer_device, u64 id, sector_t sector, in read_in_block() argument
1861 struct drbd_device *device = peer_device->device; in read_in_block()
1867 void *dig_in = peer_device->connection->int_dig_in; in read_in_block()
1868 void *dig_vv = peer_device->connection->int_dig_vv; in read_in_block()
1875 if (!trim && peer_device->connection->peer_integrity_tfm) { in read_in_block()
1876 digest_size = crypto_shash_digestsize(peer_device->connection->peer_integrity_tfm); in read_in_block()
1881 err = drbd_recv_all_warn(peer_device->connection, dig_in, digest_size); in read_in_block()
1899 drbd_err(peer_device, "data size (%u) != drbd logical block size (%u)\n", in read_in_block()
1904 drbd_err(peer_device, "data size (%u) != backend logical block size (%u)\n", in read_in_block()
1932 peer_req = drbd_alloc_peer_req(peer_device, id, sector, ds, data_size, GFP_NOIO); in read_in_block()
1954 err = drbd_recv_all_warn(peer_device->connection, data, len); in read_in_block()
1968 drbd_csum_ee_size(peer_device->connection->peer_integrity_tfm, peer_req, dig_vv, data_size); in read_in_block()
1983 static int drbd_drain_block(struct drbd_peer_device *peer_device, int data_size) in drbd_drain_block() argument
1992 page = drbd_alloc_pages(peer_device, 1, 1); in drbd_drain_block()
1998 err = drbd_recv_all_warn(peer_device->connection, data, len); in drbd_drain_block()
2004 drbd_free_pages(peer_device->device, page, 0); in drbd_drain_block()
2008 static int recv_dless_read(struct drbd_peer_device *peer_device, struct drbd_request *req, in recv_dless_read() argument
2015 void *dig_in = peer_device->connection->int_dig_in; in recv_dless_read()
2016 void *dig_vv = peer_device->connection->int_dig_vv; in recv_dless_read()
2019 if (peer_device->connection->peer_integrity_tfm) { in recv_dless_read()
2020 digest_size = crypto_shash_digestsize(peer_device->connection->peer_integrity_tfm); in recv_dless_read()
2021 err = drbd_recv_all_warn(peer_device->connection, dig_in, digest_size); in recv_dless_read()
2029 peer_device->device->recv_cnt += data_size>>9; in recv_dless_read()
2032 D_ASSERT(peer_device->device, sector == bio->bi_iter.bi_sector); in recv_dless_read()
2037 err = drbd_recv_all_warn(peer_device->connection, mapped, expect); in recv_dless_read()
2045 drbd_csum_bio(peer_device->connection->peer_integrity_tfm, bio, dig_vv); in recv_dless_read()
2047 drbd_err(peer_device, "Digest integrity check FAILED. Broken NICs?\n"); in recv_dless_read()
2052 D_ASSERT(peer_device->device, data_size == 0); in recv_dless_read()
2064 struct drbd_peer_device *peer_device = peer_req->peer_device; in e_end_resync_block() local
2065 struct drbd_device *device = peer_device->device; in e_end_resync_block()
2073 err = drbd_send_ack(peer_device, P_RS_WRITE_ACK, peer_req); in e_end_resync_block()
2078 err = drbd_send_ack(peer_device, P_NEG_ACK, peer_req); in e_end_resync_block()
2085 static int recv_resync_read(struct drbd_peer_device *peer_device, sector_t sector, in recv_resync_read() argument
2088 struct drbd_device *device = peer_device->device; in recv_resync_read()
2091 peer_req = read_in_block(peer_device, ID_SYNCER, sector, pi); in recv_resync_read()
2144 struct drbd_peer_device *peer_device; in receive_DataReply() local
2151 peer_device = conn_peer_device(connection, pi->vnr); in receive_DataReply()
2152 if (!peer_device) in receive_DataReply()
2154 device = peer_device->device; in receive_DataReply()
2167 err = recv_dless_read(peer_device, req, sector, pi->size); in receive_DataReply()
2179 struct drbd_peer_device *peer_device; in receive_RSDataReply() local
2185 peer_device = conn_peer_device(connection, pi->vnr); in receive_RSDataReply()
2186 if (!peer_device) in receive_RSDataReply()
2188 device = peer_device->device; in receive_RSDataReply()
2197 err = recv_resync_read(peer_device, sector, pi); in receive_RSDataReply()
2202 err = drbd_drain_block(peer_device, pi->size); in receive_RSDataReply()
2204 drbd_send_ack_dp(peer_device, P_NEG_ACK, p, pi->size); in receive_RSDataReply()
2238 struct drbd_peer_device *peer_device = peer_req->peer_device; in e_end_block() local
2239 struct drbd_device *device = peer_device->device; in e_end_block()
2249 err = drbd_send_ack(peer_device, pcmd, peer_req); in e_end_block()
2253 err = drbd_send_ack(peer_device, P_NEG_ACK, peer_req); in e_end_block()
2272 …drbd_may_finish_epoch(peer_device->connection, peer_req->epoch, EV_PUT + (cancel ? EV_CLEANUP : 0)… in e_end_block()
2281 struct drbd_peer_device *peer_device = peer_req->peer_device; in e_send_ack() local
2284 err = drbd_send_ack(peer_device, ack, peer_req); in e_send_ack()
2285 dec_unacked(peer_device->device); in e_send_ack()
2299 struct drbd_connection *connection = peer_req->peer_device->connection; in e_send_retry_write()
2320 static void update_peer_seq(struct drbd_peer_device *peer_device, unsigned int peer_seq) in update_peer_seq() argument
2322 struct drbd_device *device = peer_device->device; in update_peer_seq()
2325 if (test_bit(RESOLVE_CONFLICTS, &peer_device->connection->flags)) { in update_peer_seq()
2381 static int wait_for_and_update_peer_seq(struct drbd_peer_device *peer_device, const u32 peer_seq) in wait_for_and_update_peer_seq() argument
2383 struct drbd_device *device = peer_device->device; in wait_for_and_update_peer_seq()
2388 if (!test_bit(RESOLVE_CONFLICTS, &peer_device->connection->flags)) in wait_for_and_update_peer_seq()
2404 tp = rcu_dereference(peer_device->connection->net_conf)->two_primaries; in wait_for_and_update_peer_seq()
2414 timeout = rcu_dereference(peer_device->connection->net_conf)->ping_timeo*HZ/10; in wait_for_and_update_peer_seq()
2479 struct drbd_connection *connection = peer_req->peer_device->connection; in handle_write_conflicts()
2534 queue_work(connection->ack_sender, &peer_req->peer_device->send_acks_work); in handle_write_conflicts()
2587 struct drbd_peer_device *peer_device; in receive_Data() local
2598 peer_device = conn_peer_device(connection, pi->vnr); in receive_Data()
2599 if (!peer_device) in receive_Data()
2601 device = peer_device->device; in receive_Data()
2606 err = wait_for_and_update_peer_seq(peer_device, peer_seq); in receive_Data()
2607 drbd_send_ack_dp(peer_device, P_NEG_ACK, p, pi->size); in receive_Data()
2609 err2 = drbd_drain_block(peer_device, pi->size); in receive_Data()
2622 peer_req = read_in_block(peer_device, p->block_id, sector, pi); in receive_Data()
2636 D_ASSERT(peer_device, peer_req->i.size > 0); in receive_Data()
2637 D_ASSERT(peer_device, op == REQ_OP_DISCARD); in receive_Data()
2638 D_ASSERT(peer_device, peer_req->pages == NULL); in receive_Data()
2644 D_ASSERT(peer_device, peer_req->i.size > 0); in receive_Data()
2645 D_ASSERT(peer_device, op == REQ_OP_WRITE_ZEROES); in receive_Data()
2646 D_ASSERT(peer_device, peer_req->pages == NULL); in receive_Data()
2665 nc = rcu_dereference(peer_device->connection->net_conf); in receive_Data()
2667 if (peer_device->connection->agreed_pro_version < 100) { in receive_Data()
2689 drbd_send_ack(peer_device, P_RECV_ACK, peer_req); in receive_Data()
2696 err = wait_for_and_update_peer_seq(peer_device, peer_seq); in receive_Data()
2710 update_peer_seq(peer_device, peer_seq); in receive_Data()
2837 struct drbd_peer_device *peer_device; in receive_DataRequest() local
2847 peer_device = conn_peer_device(connection, pi->vnr); in receive_DataRequest()
2848 if (!peer_device) in receive_DataRequest()
2850 device = peer_device->device; in receive_DataRequest()
2871 drbd_send_ack_rp(peer_device, P_NEG_DREPLY, p); in receive_DataRequest()
2877 drbd_send_ack_rp(peer_device, P_NEG_RS_DREPLY , p); in receive_DataRequest()
2882 drbd_send_ack_ex(peer_device, P_OV_RESULT, sector, size, ID_IN_SYNC); in receive_DataRequest()
2892 return drbd_drain_block(peer_device, pi->size); in receive_DataRequest()
2898 peer_req = drbd_alloc_peer_req(peer_device, p->block_id, sector, size, in receive_DataRequest()
2940 if (drbd_recv_all(peer_device->connection, di->digest, pi->size)) in receive_DataRequest()
2944 D_ASSERT(device, peer_device->connection->agreed_pro_version >= 89); in receive_DataRequest()
2963 peer_device->connection->agreed_pro_version >= 90) { in receive_DataRequest()
3051 static int drbd_asb_recover_0p(struct drbd_peer_device *peer_device) __must_hold(local) in drbd_asb_recover_0p() argument
3053 struct drbd_device *device = peer_device->device; in drbd_asb_recover_0p()
3065 after_sb_0p = rcu_dereference(peer_device->connection->net_conf)->after_sb_0p; in drbd_asb_recover_0p()
3101 rv = test_bit(RESOLVE_CONFLICTS, &peer_device->connection->flags) in drbd_asb_recover_0p()
3118 rv = test_bit(RESOLVE_CONFLICTS, &peer_device->connection->flags) in drbd_asb_recover_0p()
3134 static int drbd_asb_recover_1p(struct drbd_peer_device *peer_device) __must_hold(local) in drbd_asb_recover_1p() argument
3136 struct drbd_device *device = peer_device->device; in drbd_asb_recover_1p()
3141 after_sb_1p = rcu_dereference(peer_device->connection->net_conf)->after_sb_1p; in drbd_asb_recover_1p()
3155 hg = drbd_asb_recover_0p(peer_device); in drbd_asb_recover_1p()
3162 rv = drbd_asb_recover_0p(peer_device); in drbd_asb_recover_1p()
3167 hg = drbd_asb_recover_0p(peer_device); in drbd_asb_recover_1p()
3191 static int drbd_asb_recover_2p(struct drbd_peer_device *peer_device) __must_hold(local) in drbd_asb_recover_2p() argument
3193 struct drbd_device *device = peer_device->device; in drbd_asb_recover_2p()
3198 after_sb_2p = rcu_dereference(peer_device->connection->net_conf)->after_sb_2p; in drbd_asb_recover_2p()
3212 rv = drbd_asb_recover_0p(peer_device); in drbd_asb_recover_2p()
3217 hg = drbd_asb_recover_0p(peer_device); in drbd_asb_recover_2p()
3270 struct drbd_peer_device *const peer_device = first_peer_device(device); in drbd_uuid_compare() local
3271 struct drbd_connection *const connection = peer_device ? peer_device->connection : NULL; in drbd_uuid_compare()
3361 drbd_warn(peer_device, "Equivalent unrotated UUIDs, but current primary present.\n"); in drbd_uuid_compare()
3368 …drbd_err(peer_device, "Equivalent unrotated UUIDs, but both are primary. Can not resolve this.\n"); in drbd_uuid_compare()
3486 static enum drbd_conns drbd_sync_handshake(struct drbd_peer_device *peer_device, in drbd_sync_handshake() argument
3490 struct drbd_device *device = peer_device->device; in drbd_sync_handshake()
3544 nc = rcu_dereference(peer_device->connection->net_conf); in drbd_sync_handshake()
3557 hg = drbd_asb_recover_0p(peer_device); in drbd_sync_handshake()
3560 hg = drbd_asb_recover_1p(peer_device); in drbd_sync_handshake()
3563 hg = drbd_asb_recover_2p(peer_device); in drbd_sync_handshake()
3620 if (tentative || test_bit(CONN_DRY_RUN, &peer_device->connection->flags)) { in drbd_sync_handshake()
3880 struct drbd_peer_device *peer_device; in receive_SyncParam() local
3893 peer_device = conn_peer_device(connection, pi->vnr); in receive_SyncParam()
3894 if (!peer_device) in receive_SyncParam()
3896 device = peer_device->device; in receive_SyncParam()
3927 err = drbd_recv_all(peer_device->connection, p, header_size); in receive_SyncParam()
3932 old_net_conf = peer_device->connection->net_conf; in receive_SyncParam()
3958 err = drbd_recv_all(peer_device->connection, p->verify_alg, data_size); in receive_SyncParam()
4032 crypto_free_shash(peer_device->connection->verify_tfm); in receive_SyncParam()
4033 peer_device->connection->verify_tfm = verify_tfm; in receive_SyncParam()
4039 crypto_free_shash(peer_device->connection->csums_tfm); in receive_SyncParam()
4040 peer_device->connection->csums_tfm = csums_tfm; in receive_SyncParam()
4086 conn_request_state(peer_device->connection, NS(conn, C_DISCONNECTING), CS_HARD); in receive_SyncParam()
4105 struct drbd_peer_device *peer_device; in receive_sizes() local
4115 peer_device = conn_peer_device(connection, pi->vnr); in receive_sizes()
4116 if (!peer_device) in receive_sizes()
4118 device = peer_device->device; in receive_sizes()
4153 conn_request_state(peer_device->connection, NS(conn, C_DISCONNECTING), CS_HARD); in receive_sizes()
4228 conn_request_state(peer_device->connection, NS(conn, C_DISCONNECTING), CS_HARD); in receive_sizes()
4258 drbd_send_sizes(peer_device, 0, ddsf); in receive_sizes()
4278 struct drbd_peer_device *peer_device; in receive_uuids() local
4284 peer_device = conn_peer_device(connection, pi->vnr); in receive_uuids()
4285 if (!peer_device) in receive_uuids()
4287 device = peer_device->device; in receive_uuids()
4307 conn_request_state(peer_device->connection, NS(conn, C_DISCONNECTING), CS_HARD); in receive_uuids()
4314 peer_device->connection->agreed_pro_version >= 90 && in receive_uuids()
4385 struct drbd_peer_device *peer_device; in receive_req_state() local
4391 peer_device = conn_peer_device(connection, pi->vnr); in receive_req_state()
4392 if (!peer_device) in receive_req_state()
4394 device = peer_device->device; in receive_req_state()
4399 if (test_bit(RESOLVE_CONFLICTS, &peer_device->connection->flags) && in receive_req_state()
4401 drbd_send_sr_reply(peer_device, SS_CONCURRENT_ST_CHG); in receive_req_state()
4409 drbd_send_sr_reply(peer_device, rv); in receive_req_state()
4442 struct drbd_peer_device *peer_device; in receive_state() local
4450 peer_device = conn_peer_device(connection, pi->vnr); in receive_state()
4451 if (!peer_device) in receive_state()
4453 device = peer_device->device; in receive_state()
4567 ns.conn = drbd_sync_handshake(peer_device, peer_state.role, real_peer_disk); in receive_state()
4579 if (test_and_clear_bit(CONN_DRY_RUN, &peer_device->connection->flags)) in receive_state()
4582 conn_request_state(peer_device->connection, NS(conn, C_DISCONNECTING), CS_HARD); in receive_state()
4604 tl_clear(peer_device->connection); in receive_state()
4607 conn_request_state(peer_device->connection, NS2(conn, C_PROTOCOL_ERROR, susp, 0), CS_HARD); in receive_state()
4615 conn_request_state(peer_device->connection, NS(conn, C_DISCONNECTING), CS_HARD); in receive_state()
4625 drbd_send_uuids(peer_device); in receive_state()
4626 drbd_send_current_state(peer_device); in receive_state()
4639 struct drbd_peer_device *peer_device; in receive_sync_uuid() local
4643 peer_device = conn_peer_device(connection, pi->vnr); in receive_sync_uuid()
4644 if (!peer_device) in receive_sync_uuid()
4646 device = peer_device->device; in receive_sync_uuid()
4679 receive_bitmap_plain(struct drbd_peer_device *peer_device, unsigned int size, in receive_bitmap_plain() argument
4683 drbd_header_size(peer_device->connection); in receive_bitmap_plain()
4690 drbd_err(peer_device, "%s:want (%u) != size (%u)\n", __func__, want, size); in receive_bitmap_plain()
4695 err = drbd_recv_all(peer_device->connection, p, want); in receive_bitmap_plain()
4699 drbd_bm_merge_lel(peer_device->device, c->word_offset, num_words, p); in receive_bitmap_plain()
4731 recv_bm_rle_bits(struct drbd_peer_device *peer_device, in recv_bm_rle_bits() argument
4760 drbd_err(peer_device, "bitmap overflow (e:%lu) while decoding bm RLE packet\n", e); in recv_bm_rle_bits()
4763 _drbd_bm_set_bits(peer_device->device, s, e); in recv_bm_rle_bits()
4767 drbd_err(peer_device, "bitmap decoding error: h:%d b:%d la:0x%08llx l:%u/%u\n", in recv_bm_rle_bits()
4800 decode_bitmap_c(struct drbd_peer_device *peer_device, in decode_bitmap_c() argument
4806 return recv_bm_rle_bits(peer_device, p, c, len - sizeof(*p)); in decode_bitmap_c()
4812 drbd_err(peer_device, "receive_bitmap_c: unknown encoding %u\n", p->encoding); in decode_bitmap_c()
4813 conn_request_state(peer_device->connection, NS(conn, C_PROTOCOL_ERROR), CS_HARD); in decode_bitmap_c()
4863 struct drbd_peer_device *peer_device; in receive_bitmap() local
4868 peer_device = conn_peer_device(connection, pi->vnr); in receive_bitmap()
4869 if (!peer_device) in receive_bitmap()
4871 device = peer_device->device; in receive_bitmap()
4884 err = receive_bitmap_plain(peer_device, pi->size, pi->data, &c); in receive_bitmap()
4900 err = drbd_recv_all(peer_device->connection, p, pi->size); in receive_bitmap()
4903 err = decode_bitmap_c(peer_device, p, &c, pi->size); in receive_bitmap()
4918 err = drbd_recv_header(peer_device->connection, pi); in receive_bitmap()
4968 struct drbd_peer_device *peer_device; in receive_out_of_sync() local
4972 peer_device = conn_peer_device(connection, pi->vnr); in receive_out_of_sync()
4973 if (!peer_device) in receive_out_of_sync()
4975 device = peer_device->device; in receive_out_of_sync()
4994 struct drbd_peer_device *peer_device; in receive_rs_deallocated() local
5000 peer_device = conn_peer_device(connection, pi->vnr); in receive_rs_deallocated()
5001 if (!peer_device) in receive_rs_deallocated()
5003 device = peer_device->device; in receive_rs_deallocated()
5014 peer_req = drbd_alloc_peer_req(peer_device, ID_SYNCER, sector, in receive_rs_deallocated()
5050 drbd_send_ack_ex(peer_device, P_NEG_ACK, sector, size, ID_SYNCER); in receive_rs_deallocated()
5155 struct drbd_peer_device *peer_device; in conn_disconnect() local
5178 idr_for_each_entry(&connection->peer_devices, peer_device, vnr) { in conn_disconnect()
5179 struct drbd_device *device = peer_device->device; in conn_disconnect()
5182 drbd_disconnected(peer_device); in conn_disconnect()
5210 static int drbd_disconnected(struct drbd_peer_device *peer_device) in drbd_disconnected() argument
5212 struct drbd_device *device = peer_device->device; in drbd_disconnected()
5244 drbd_flush_workqueue(&peer_device->connection->sender_work); in drbd_disconnected()
5251 drbd_flush_workqueue(&peer_device->connection->sender_work); in drbd_disconnected()
5261 tl_clear(peer_device->connection); in drbd_disconnected()
5642 struct drbd_peer_device *peer_device; in got_RqSReply() local
5647 peer_device = conn_peer_device(connection, pi->vnr); in got_RqSReply()
5648 if (!peer_device) in got_RqSReply()
5650 device = peer_device->device; in got_RqSReply()
5687 struct drbd_peer_device *peer_device; in got_IsInSync() local
5693 peer_device = conn_peer_device(connection, pi->vnr); in got_IsInSync()
5694 if (!peer_device) in got_IsInSync()
5696 device = peer_device->device; in got_IsInSync()
5698 D_ASSERT(device, peer_device->connection->agreed_pro_version >= 89); in got_IsInSync()
5700 update_peer_seq(peer_device, be32_to_cpu(p->seq_num)); in got_IsInSync()
5739 struct drbd_peer_device *peer_device; in got_BlockAck() local
5746 peer_device = conn_peer_device(connection, pi->vnr); in got_BlockAck()
5747 if (!peer_device) in got_BlockAck()
5749 device = peer_device->device; in got_BlockAck()
5751 update_peer_seq(peer_device, be32_to_cpu(p->seq_num)); in got_BlockAck()
5785 struct drbd_peer_device *peer_device; in got_NegAck() local
5792 peer_device = conn_peer_device(connection, pi->vnr); in got_NegAck()
5793 if (!peer_device) in got_NegAck()
5795 device = peer_device->device; in got_NegAck()
5797 update_peer_seq(peer_device, be32_to_cpu(p->seq_num)); in got_NegAck()
5821 struct drbd_peer_device *peer_device; in got_NegDReply() local
5826 peer_device = conn_peer_device(connection, pi->vnr); in got_NegDReply()
5827 if (!peer_device) in got_NegDReply()
5829 device = peer_device->device; in got_NegDReply()
5831 update_peer_seq(peer_device, be32_to_cpu(p->seq_num)); in got_NegDReply()
5843 struct drbd_peer_device *peer_device; in got_NegRSDReply() local
5849 peer_device = conn_peer_device(connection, pi->vnr); in got_NegRSDReply()
5850 if (!peer_device) in got_NegRSDReply()
5852 device = peer_device->device; in got_NegRSDReply()
5857 update_peer_seq(peer_device, be32_to_cpu(p->seq_num)); in got_NegRSDReply()
5880 struct drbd_peer_device *peer_device; in got_BarrierAck() local
5886 idr_for_each_entry(&connection->peer_devices, peer_device, vnr) { in got_BarrierAck()
5887 struct drbd_device *device = peer_device->device; in got_BarrierAck()
5903 struct drbd_peer_device *peer_device; in got_OVResult() local
5910 peer_device = conn_peer_device(connection, pi->vnr); in got_OVResult()
5911 if (!peer_device) in got_OVResult()
5913 device = peer_device->device; in got_OVResult()
5918 update_peer_seq(peer_device, be32_to_cpu(p->seq_num)); in got_OVResult()
5942 drbd_queue_work(&peer_device->connection->sender_work, &dw->w); in got_OVResult()
6151 struct drbd_peer_device *peer_device = in drbd_send_acks_wf() local
6153 struct drbd_connection *connection = peer_device->connection; in drbd_send_acks_wf()
6154 struct drbd_device *device = peer_device->device; in drbd_send_acks_wf()