225 	struct drbd_peer_device *peer_device;  in conn_reclaim_net_peer_reqs()  local
229 	idr_for_each_entry(&connection->peer_devices, peer_device, vnr) {  in conn_reclaim_net_peer_reqs()
230 		struct drbd_device *device = peer_device->device;  in conn_reclaim_net_peer_reqs()
263 struct page *drbd_alloc_pages(struct drbd_peer_device *peer_device, unsigned int number,  in drbd_alloc_pages()  argument
266 	struct drbd_device *device = peer_device->device;  in drbd_alloc_pages()
273 	nc = rcu_dereference(peer_device->connection->net_conf);  in drbd_alloc_pages()
361 drbd_alloc_peer_req(struct drbd_peer_device *peer_device, u64 id, sector_t sector,  in drbd_alloc_peer_req()  argument
364 	struct drbd_device *device = peer_device->device;  in drbd_alloc_peer_req()
380 		page = drbd_alloc_pages(peer_device, nr_pages,  in drbd_alloc_peer_req()
392 	peer_req->peer_device = peer_device;  in drbd_alloc_peer_req()
890 int drbd_connected(struct drbd_peer_device *peer_device)  in drbd_connected()  argument
892 	struct drbd_device *device = peer_device->device;  in drbd_connected()
898 	device->state_mutex = peer_device->connection->agreed_pro_version < 100 ?  in drbd_connected()
899 		&peer_device->connection->cstate_mutex :  in drbd_connected()
902 	err = drbd_send_sync_param(peer_device);  in drbd_connected()
904 		err = drbd_send_sizes(peer_device, 0, 0);  in drbd_connected()
906 		err = drbd_send_uuids(peer_device);  in drbd_connected()
908 		err = drbd_send_current_state(peer_device);  in drbd_connected()
927 	struct drbd_peer_device *peer_device;  in conn_connect()  local
1092 	idr_for_each_entry(&connection->peer_devices, peer_device, vnr)  in conn_connect()
1093 		mutex_lock(peer_device->device->state_mutex);  in conn_connect()
1100 	idr_for_each_entry(&connection->peer_devices, peer_device, vnr)  in conn_connect()
1101 		mutex_unlock(peer_device->device->state_mutex);  in conn_connect()
1104 	idr_for_each_entry(&connection->peer_devices, peer_device, vnr) {  in conn_connect()
1105 		struct drbd_device *device = peer_device->device;  in conn_connect()
1114 		drbd_connected(peer_device);  in conn_connect()
1313 		struct drbd_peer_device *peer_device;  in drbd_flush()  local
1322 		idr_for_each_entry(&connection->peer_devices, peer_device, vnr) {  in drbd_flush()
1323 			struct drbd_device *device = peer_device->device;  in drbd_flush()
1643 		conn_wait_active_ee_empty(peer_req->peer_device->connection);  in drbd_submit_peer_request()
1720 	struct drbd_peer_device *peer_device;  in conn_wait_active_ee_empty()  local
1724 	idr_for_each_entry(&connection->peer_devices, peer_device, vnr) {  in conn_wait_active_ee_empty()
1725 		struct drbd_device *device = peer_device->device;  in conn_wait_active_ee_empty()
1825 read_in_block(struct drbd_peer_device *peer_device, u64 id, sector_t sector,  in read_in_block()  argument
1828 	struct drbd_device *device = peer_device->device;  in read_in_block()
1834 	void *dig_in = peer_device->connection->int_dig_in;  in read_in_block()
1835 	void *dig_vv = peer_device->connection->int_dig_vv;  in read_in_block()
1841 	if (!trim && peer_device->connection->peer_integrity_tfm) {  in read_in_block()
1842 		digest_size = crypto_shash_digestsize(peer_device->connection->peer_integrity_tfm);  in read_in_block()
1847 		err = drbd_recv_all_warn(peer_device->connection, dig_in, digest_size);  in read_in_block()
1886 	peer_req = drbd_alloc_peer_req(peer_device, id, sector, ds, data_size, GFP_NOIO);  in read_in_block()
1906 		err = drbd_recv_all_warn(peer_device->connection, data, len);  in read_in_block()
1920 		drbd_csum_ee_size(peer_device->connection->peer_integrity_tfm, peer_req, dig_vv, data_size);  in read_in_block()
1935 static int drbd_drain_block(struct drbd_peer_device *peer_device, int data_size)  in drbd_drain_block()  argument
1944 	page = drbd_alloc_pages(peer_device, 1, 1);  in drbd_drain_block()
1950 		err = drbd_recv_all_warn(peer_device->connection, data, len);  in drbd_drain_block()
1956 	drbd_free_pages(peer_device->device, page, 0);  in drbd_drain_block()
1960 static int recv_dless_read(struct drbd_peer_device *peer_device, struct drbd_request *req,  in recv_dless_read()  argument
1967 	void *dig_in = peer_device->connection->int_dig_in;  in recv_dless_read()
1968 	void *dig_vv = peer_device->connection->int_dig_vv;  in recv_dless_read()
1971 	if (peer_device->connection->peer_integrity_tfm) {  in recv_dless_read()
1972 		digest_size = crypto_shash_digestsize(peer_device->connection->peer_integrity_tfm);  in recv_dless_read()
1973 		err = drbd_recv_all_warn(peer_device->connection, dig_in, digest_size);  in recv_dless_read()
1981 	peer_device->device->recv_cnt += data_size>>9;  in recv_dless_read()
1984 	D_ASSERT(peer_device->device, sector == bio->bi_iter.bi_sector);  in recv_dless_read()
1989 		err = drbd_recv_all_warn(peer_device->connection, mapped, expect);  in recv_dless_read()
1997 		drbd_csum_bio(peer_device->connection->peer_integrity_tfm, bio, dig_vv);  in recv_dless_read()
1999 			drbd_err(peer_device, "Digest integrity check FAILED. Broken NICs?\n");  in recv_dless_read()
2004 	D_ASSERT(peer_device->device, data_size == 0);  in recv_dless_read()
2016 	struct drbd_peer_device *peer_device = peer_req->peer_device;  in e_end_resync_block()  local
2017 	struct drbd_device *device = peer_device->device;  in e_end_resync_block()
2025 		err = drbd_send_ack(peer_device, P_RS_WRITE_ACK, peer_req);  in e_end_resync_block()
2030 		err  = drbd_send_ack(peer_device, P_NEG_ACK, peer_req);  in e_end_resync_block()
2037 static int recv_resync_read(struct drbd_peer_device *peer_device, sector_t sector,  in recv_resync_read()  argument
2040 	struct drbd_device *device = peer_device->device;  in recv_resync_read()
2043 	peer_req = read_in_block(peer_device, ID_SYNCER, sector, pi);  in recv_resync_read()
2096 	struct drbd_peer_device *peer_device;  in receive_DataReply()  local
2103 	peer_device = conn_peer_device(connection, pi->vnr);  in receive_DataReply()
2104 	if (!peer_device)  in receive_DataReply()
2106 	device = peer_device->device;  in receive_DataReply()
2116 	err = recv_dless_read(peer_device, req, sector, pi->size);  in receive_DataReply()
2128 	struct drbd_peer_device *peer_device;  in receive_RSDataReply()  local
2134 	peer_device = conn_peer_device(connection, pi->vnr);  in receive_RSDataReply()
2135 	if (!peer_device)  in receive_RSDataReply()
2137 	device = peer_device->device;  in receive_RSDataReply()
2146 		err = recv_resync_read(peer_device, sector, pi);  in receive_RSDataReply()
2151 		err = drbd_drain_block(peer_device, pi->size);  in receive_RSDataReply()
2153 		drbd_send_ack_dp(peer_device, P_NEG_ACK, p, pi->size);  in receive_RSDataReply()
2187 	struct drbd_peer_device *peer_device = peer_req->peer_device;  in e_end_block()  local
2188 	struct drbd_device *device = peer_device->device;  in e_end_block()
2198 			err = drbd_send_ack(peer_device, pcmd, peer_req);  in e_end_block()
2202 			err = drbd_send_ack(peer_device, P_NEG_ACK, peer_req);  in e_end_block()
2221 …drbd_may_finish_epoch(peer_device->connection, peer_req->epoch, EV_PUT + (cancel ? EV_CLEANUP : 0)…  in e_end_block()
2230 	struct drbd_peer_device *peer_device = peer_req->peer_device;  in e_send_ack()  local
2233 	err = drbd_send_ack(peer_device, ack, peer_req);  in e_send_ack()
2234 	dec_unacked(peer_device->device);  in e_send_ack()
2248 	struct drbd_connection *connection = peer_req->peer_device->connection;  in e_send_retry_write()
2269 static void update_peer_seq(struct drbd_peer_device *peer_device, unsigned int peer_seq)  in update_peer_seq()  argument
2271 	struct drbd_device *device = peer_device->device;  in update_peer_seq()
2274 	if (test_bit(RESOLVE_CONFLICTS, &peer_device->connection->flags)) {  in update_peer_seq()
2330 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
2332 	struct drbd_device *device = peer_device->device;  in wait_for_and_update_peer_seq()
2337 	if (!test_bit(RESOLVE_CONFLICTS, &peer_device->connection->flags))  in wait_for_and_update_peer_seq()
2353 		tp = rcu_dereference(peer_device->connection->net_conf)->two_primaries;  in wait_for_and_update_peer_seq()
2363 		timeout = rcu_dereference(peer_device->connection->net_conf)->ping_timeo*HZ/10;  in wait_for_and_update_peer_seq()
2426 	struct drbd_connection *connection = peer_req->peer_device->connection;  in handle_write_conflicts()
2481 			queue_work(connection->ack_sender, &peer_req->peer_device->send_acks_work);  in handle_write_conflicts()
2534 	struct drbd_peer_device *peer_device;  in receive_Data()  local
2546 	peer_device = conn_peer_device(connection, pi->vnr);  in receive_Data()
2547 	if (!peer_device)  in receive_Data()
2549 	device = peer_device->device;  in receive_Data()
2554 		err = wait_for_and_update_peer_seq(peer_device, peer_seq);  in receive_Data()
2555 		drbd_send_ack_dp(peer_device, P_NEG_ACK, p, pi->size);  in receive_Data()
2557 		err2 = drbd_drain_block(peer_device, pi->size);  in receive_Data()
2570 	peer_req = read_in_block(peer_device, p->block_id, sector, pi);  in receive_Data()
2584 		D_ASSERT(peer_device, peer_req->i.size > 0);  in receive_Data()
2585 		D_ASSERT(peer_device, op == REQ_OP_DISCARD);  in receive_Data()
2586 		D_ASSERT(peer_device, peer_req->pages == NULL);  in receive_Data()
2592 		D_ASSERT(peer_device, peer_req->i.size > 0);  in receive_Data()
2593 		D_ASSERT(peer_device, op == REQ_OP_WRITE_ZEROES);  in receive_Data()
2594 		D_ASSERT(peer_device, peer_req->pages == NULL);  in receive_Data()
2613 	nc = rcu_dereference(peer_device->connection->net_conf);  in receive_Data()
2615 	if (peer_device->connection->agreed_pro_version < 100) {  in receive_Data()
2637 		drbd_send_ack(peer_device, P_RECV_ACK, peer_req);  in receive_Data()
2644 		err = wait_for_and_update_peer_seq(peer_device, peer_seq);  in receive_Data()
2658 		update_peer_seq(peer_device, peer_seq);  in receive_Data()
2785 	struct drbd_peer_device *peer_device;  in receive_DataRequest()  local
2795 	peer_device = conn_peer_device(connection, pi->vnr);  in receive_DataRequest()
2796 	if (!peer_device)  in receive_DataRequest()
2798 	device = peer_device->device;  in receive_DataRequest()
2819 			drbd_send_ack_rp(peer_device, P_NEG_DREPLY, p);  in receive_DataRequest()
2825 			drbd_send_ack_rp(peer_device, P_NEG_RS_DREPLY , p);  in receive_DataRequest()
2830 			drbd_send_ack_ex(peer_device, P_OV_RESULT, sector, size, ID_IN_SYNC);  in receive_DataRequest()
2840 		return drbd_drain_block(peer_device, pi->size);  in receive_DataRequest()
2846 	peer_req = drbd_alloc_peer_req(peer_device, p->block_id, sector, size,  in receive_DataRequest()
2888 		if (drbd_recv_all(peer_device->connection, di->digest, pi->size))  in receive_DataRequest()
2892 			D_ASSERT(device, peer_device->connection->agreed_pro_version >= 89);  in receive_DataRequest()
2911 		    peer_device->connection->agreed_pro_version >= 90) {  in receive_DataRequest()
2999 static int drbd_asb_recover_0p(struct drbd_peer_device *peer_device) __must_hold(local)  in drbd_asb_recover_0p()  argument
3001 	struct drbd_device *device = peer_device->device;  in drbd_asb_recover_0p()
3013 	after_sb_0p = rcu_dereference(peer_device->connection->net_conf)->after_sb_0p;  in drbd_asb_recover_0p()
3049 			rv = test_bit(RESOLVE_CONFLICTS, &peer_device->connection->flags)  in drbd_asb_recover_0p()
3066 			rv = test_bit(RESOLVE_CONFLICTS, &peer_device->connection->flags)  in drbd_asb_recover_0p()
3082 static int drbd_asb_recover_1p(struct drbd_peer_device *peer_device) __must_hold(local)  in drbd_asb_recover_1p()  argument
3084 	struct drbd_device *device = peer_device->device;  in drbd_asb_recover_1p()
3089 	after_sb_1p = rcu_dereference(peer_device->connection->net_conf)->after_sb_1p;  in drbd_asb_recover_1p()
3103 		hg = drbd_asb_recover_0p(peer_device);  in drbd_asb_recover_1p()
3110 		rv = drbd_asb_recover_0p(peer_device);  in drbd_asb_recover_1p()
3115 		hg = drbd_asb_recover_0p(peer_device);  in drbd_asb_recover_1p()
3139 static int drbd_asb_recover_2p(struct drbd_peer_device *peer_device) __must_hold(local)  in drbd_asb_recover_2p()  argument
3141 	struct drbd_device *device = peer_device->device;  in drbd_asb_recover_2p()
3146 	after_sb_2p = rcu_dereference(peer_device->connection->net_conf)->after_sb_2p;  in drbd_asb_recover_2p()
3160 		rv = drbd_asb_recover_0p(peer_device);  in drbd_asb_recover_2p()
3165 		hg = drbd_asb_recover_0p(peer_device);  in drbd_asb_recover_2p()
3218 	struct drbd_peer_device *const peer_device = first_peer_device(device);  in drbd_uuid_compare()  local
3219 	struct drbd_connection *const connection = peer_device ? peer_device->connection : NULL;  in drbd_uuid_compare()
3309 				drbd_warn(peer_device, "Equivalent unrotated UUIDs, but current primary present.\n");  in drbd_uuid_compare()
3316 …drbd_err(peer_device, "Equivalent unrotated UUIDs, but both are primary. Can not resolve this.\n");  in drbd_uuid_compare()
3434 static enum drbd_conns drbd_sync_handshake(struct drbd_peer_device *peer_device,  in drbd_sync_handshake()  argument
3438 	struct drbd_device *device = peer_device->device;  in drbd_sync_handshake()
3492 	nc = rcu_dereference(peer_device->connection->net_conf);  in drbd_sync_handshake()
3505 			hg = drbd_asb_recover_0p(peer_device);  in drbd_sync_handshake()
3508 			hg = drbd_asb_recover_1p(peer_device);  in drbd_sync_handshake()
3511 			hg = drbd_asb_recover_2p(peer_device);  in drbd_sync_handshake()
3568 	if (tentative || test_bit(CONN_DRY_RUN, &peer_device->connection->flags)) {  in drbd_sync_handshake()
3825 	struct drbd_peer_device *peer_device;  in receive_SyncParam()  local
3838 	peer_device = conn_peer_device(connection, pi->vnr);  in receive_SyncParam()
3839 	if (!peer_device)  in receive_SyncParam()
3841 	device = peer_device->device;  in receive_SyncParam()
3873 	err = drbd_recv_all(peer_device->connection, p, header_size);  in receive_SyncParam()
3878 	old_net_conf = peer_device->connection->net_conf;  in receive_SyncParam()
3903 			err = drbd_recv_all(peer_device->connection, p->verify_alg, data_size);  in receive_SyncParam()
3975 				crypto_free_shash(peer_device->connection->verify_tfm);  in receive_SyncParam()
3976 				peer_device->connection->verify_tfm = verify_tfm;  in receive_SyncParam()
3982 				crypto_free_shash(peer_device->connection->csums_tfm);  in receive_SyncParam()
3983 				peer_device->connection->csums_tfm = csums_tfm;  in receive_SyncParam()
4029 	conn_request_state(peer_device->connection, NS(conn, C_DISCONNECTING), CS_HARD);  in receive_SyncParam()
4048 	struct drbd_peer_device *peer_device;  in receive_sizes()  local
4058 	peer_device = conn_peer_device(connection, pi->vnr);  in receive_sizes()
4059 	if (!peer_device)  in receive_sizes()
4061 	device = peer_device->device;  in receive_sizes()
4096 			conn_request_state(peer_device->connection, NS(conn, C_DISCONNECTING), CS_HARD);  in receive_sizes()
4169 			conn_request_state(peer_device->connection, NS(conn, C_DISCONNECTING), CS_HARD);  in receive_sizes()
4199 			drbd_send_sizes(peer_device, 0, ddsf);  in receive_sizes()
4219 	struct drbd_peer_device *peer_device;  in receive_uuids()  local
4225 	peer_device = conn_peer_device(connection, pi->vnr);  in receive_uuids()
4226 	if (!peer_device)  in receive_uuids()
4228 	device = peer_device->device;  in receive_uuids()
4246 		conn_request_state(peer_device->connection, NS(conn, C_DISCONNECTING), CS_HARD);  in receive_uuids()
4253 			peer_device->connection->agreed_pro_version >= 90 &&  in receive_uuids()
4324 	struct drbd_peer_device *peer_device;  in receive_req_state()  local
4330 	peer_device = conn_peer_device(connection, pi->vnr);  in receive_req_state()
4331 	if (!peer_device)  in receive_req_state()
4333 	device = peer_device->device;  in receive_req_state()
4338 	if (test_bit(RESOLVE_CONFLICTS, &peer_device->connection->flags) &&  in receive_req_state()
4340 		drbd_send_sr_reply(peer_device, SS_CONCURRENT_ST_CHG);  in receive_req_state()
4348 	drbd_send_sr_reply(peer_device, rv);  in receive_req_state()
4381 	struct drbd_peer_device *peer_device;  in receive_state()  local
4389 	peer_device = conn_peer_device(connection, pi->vnr);  in receive_state()
4390 	if (!peer_device)  in receive_state()
4392 	device = peer_device->device;  in receive_state()
4506 			ns.conn = drbd_sync_handshake(peer_device, peer_state.role, real_peer_disk);  in receive_state()
4518 				if (test_and_clear_bit(CONN_DRY_RUN, &peer_device->connection->flags))  in receive_state()
4521 				conn_request_state(peer_device->connection, NS(conn, C_DISCONNECTING), CS_HARD);  in receive_state()
4543 		tl_clear(peer_device->connection);  in receive_state()
4546 		conn_request_state(peer_device->connection, NS2(conn, C_PROTOCOL_ERROR, susp, 0), CS_HARD);  in receive_state()
4554 		conn_request_state(peer_device->connection, NS(conn, C_DISCONNECTING), CS_HARD);  in receive_state()
4564 			drbd_send_uuids(peer_device);  in receive_state()
4565 			drbd_send_current_state(peer_device);  in receive_state()
4578 	struct drbd_peer_device *peer_device;  in receive_sync_uuid()  local
4582 	peer_device = conn_peer_device(connection, pi->vnr);  in receive_sync_uuid()
4583 	if (!peer_device)  in receive_sync_uuid()
4585 	device = peer_device->device;  in receive_sync_uuid()
4618 receive_bitmap_plain(struct drbd_peer_device *peer_device, unsigned int size,  in receive_bitmap_plain()  argument
4622 				 drbd_header_size(peer_device->connection);  in receive_bitmap_plain()
4629 		drbd_err(peer_device, "%s:want (%u) != size (%u)\n", __func__, want, size);  in receive_bitmap_plain()
4634 	err = drbd_recv_all(peer_device->connection, p, want);  in receive_bitmap_plain()
4638 	drbd_bm_merge_lel(peer_device->device, c->word_offset, num_words, p);  in receive_bitmap_plain()
4670 recv_bm_rle_bits(struct drbd_peer_device *peer_device,  in recv_bm_rle_bits()  argument
4699 				drbd_err(peer_device, "bitmap overflow (e:%lu) while decoding bm RLE packet\n", e);  in recv_bm_rle_bits()
4702 			_drbd_bm_set_bits(peer_device->device, s, e);  in recv_bm_rle_bits()
4706 			drbd_err(peer_device, "bitmap decoding error: h:%d b:%d la:0x%08llx l:%u/%u\n",  in recv_bm_rle_bits()
4739 decode_bitmap_c(struct drbd_peer_device *peer_device,  in decode_bitmap_c()  argument
4745 		return recv_bm_rle_bits(peer_device, p, c, len - sizeof(*p));  in decode_bitmap_c()
4751 	drbd_err(peer_device, "receive_bitmap_c: unknown encoding %u\n", p->encoding);  in decode_bitmap_c()
4752 	conn_request_state(peer_device->connection, NS(conn, C_PROTOCOL_ERROR), CS_HARD);  in decode_bitmap_c()
4802 	struct drbd_peer_device *peer_device;  in receive_bitmap()  local
4807 	peer_device = conn_peer_device(connection, pi->vnr);  in receive_bitmap()
4808 	if (!peer_device)  in receive_bitmap()
4810 	device = peer_device->device;  in receive_bitmap()
4823 			err = receive_bitmap_plain(peer_device, pi->size, pi->data, &c);  in receive_bitmap()
4839 			err = drbd_recv_all(peer_device->connection, p, pi->size);  in receive_bitmap()
4842 			err = decode_bitmap_c(peer_device, p, &c, pi->size);  in receive_bitmap()
4857 		err = drbd_recv_header(peer_device->connection, pi);  in receive_bitmap()
4906 	struct drbd_peer_device *peer_device;  in receive_out_of_sync()  local
4910 	peer_device = conn_peer_device(connection, pi->vnr);  in receive_out_of_sync()
4911 	if (!peer_device)  in receive_out_of_sync()
4913 	device = peer_device->device;  in receive_out_of_sync()
4932 	struct drbd_peer_device *peer_device;  in receive_rs_deallocated()  local
4938 	peer_device = conn_peer_device(connection, pi->vnr);  in receive_rs_deallocated()
4939 	if (!peer_device)  in receive_rs_deallocated()
4941 	device = peer_device->device;  in receive_rs_deallocated()
4952 		peer_req = drbd_alloc_peer_req(peer_device, ID_SYNCER, sector,  in receive_rs_deallocated()
4989 		drbd_send_ack_ex(peer_device, P_NEG_ACK, sector, size, ID_SYNCER);  in receive_rs_deallocated()
5093 	struct drbd_peer_device *peer_device;  in conn_disconnect()  local
5116 	idr_for_each_entry(&connection->peer_devices, peer_device, vnr) {  in conn_disconnect()
5117 		struct drbd_device *device = peer_device->device;  in conn_disconnect()
5120 		drbd_disconnected(peer_device);  in conn_disconnect()
5148 static int drbd_disconnected(struct drbd_peer_device *peer_device)  in drbd_disconnected()  argument
5150 	struct drbd_device *device = peer_device->device;  in drbd_disconnected()
5182 	drbd_flush_workqueue(&peer_device->connection->sender_work);  in drbd_disconnected()
5189 	drbd_flush_workqueue(&peer_device->connection->sender_work);  in drbd_disconnected()
5199 		tl_clear(peer_device->connection);  in drbd_disconnected()
5577 	struct drbd_peer_device *peer_device;  in got_RqSReply()  local
5582 	peer_device = conn_peer_device(connection, pi->vnr);  in got_RqSReply()
5583 	if (!peer_device)  in got_RqSReply()
5585 	device = peer_device->device;  in got_RqSReply()
5622 	struct drbd_peer_device *peer_device;  in got_IsInSync()  local
5628 	peer_device = conn_peer_device(connection, pi->vnr);  in got_IsInSync()
5629 	if (!peer_device)  in got_IsInSync()
5631 	device = peer_device->device;  in got_IsInSync()
5633 	D_ASSERT(device, peer_device->connection->agreed_pro_version >= 89);  in got_IsInSync()
5635 	update_peer_seq(peer_device, be32_to_cpu(p->seq_num));  in got_IsInSync()
5674 	struct drbd_peer_device *peer_device;  in got_BlockAck()  local
5681 	peer_device = conn_peer_device(connection, pi->vnr);  in got_BlockAck()
5682 	if (!peer_device)  in got_BlockAck()
5684 	device = peer_device->device;  in got_BlockAck()
5686 	update_peer_seq(peer_device, be32_to_cpu(p->seq_num));  in got_BlockAck()
5720 	struct drbd_peer_device *peer_device;  in got_NegAck()  local
5727 	peer_device = conn_peer_device(connection, pi->vnr);  in got_NegAck()
5728 	if (!peer_device)  in got_NegAck()
5730 	device = peer_device->device;  in got_NegAck()
5732 	update_peer_seq(peer_device, be32_to_cpu(p->seq_num));  in got_NegAck()
5756 	struct drbd_peer_device *peer_device;  in got_NegDReply()  local
5761 	peer_device = conn_peer_device(connection, pi->vnr);  in got_NegDReply()
5762 	if (!peer_device)  in got_NegDReply()
5764 	device = peer_device->device;  in got_NegDReply()
5766 	update_peer_seq(peer_device, be32_to_cpu(p->seq_num));  in got_NegDReply()
5778 	struct drbd_peer_device *peer_device;  in got_NegRSDReply()  local
5784 	peer_device = conn_peer_device(connection, pi->vnr);  in got_NegRSDReply()
5785 	if (!peer_device)  in got_NegRSDReply()
5787 	device = peer_device->device;  in got_NegRSDReply()
5792 	update_peer_seq(peer_device, be32_to_cpu(p->seq_num));  in got_NegRSDReply()
5816 	struct drbd_peer_device *peer_device;  in got_BarrierAck()  local
5822 	idr_for_each_entry(&connection->peer_devices, peer_device, vnr) {  in got_BarrierAck()
5823 		struct drbd_device *device = peer_device->device;  in got_BarrierAck()
5839 	struct drbd_peer_device *peer_device;  in got_OVResult()  local
5846 	peer_device = conn_peer_device(connection, pi->vnr);  in got_OVResult()
5847 	if (!peer_device)  in got_OVResult()
5849 	device = peer_device->device;  in got_OVResult()
5854 	update_peer_seq(peer_device, be32_to_cpu(p->seq_num));  in got_OVResult()
5878 			drbd_queue_work(&peer_device->connection->sender_work, &dw->w);  in got_OVResult()
6084 	struct drbd_peer_device *peer_device =  in drbd_send_acks_wf()  local
6086 	struct drbd_connection *connection = peer_device->connection;  in drbd_send_acks_wf()
6087 	struct drbd_device *device = peer_device->device;  in drbd_send_acks_wf()