488 	struct drbd_peer_device *peer_device;  in conn_lowest_minor()  local
492 	peer_device = idr_get_next(&connection->peer_devices, &vnr);  in conn_lowest_minor()
493 	if (peer_device)  in conn_lowest_minor()
494 		minor = device_to_minor(peer_device->device);  in conn_lowest_minor()
638 void *drbd_prepare_command(struct drbd_peer_device *peer_device, struct drbd_socket *sock)  in drbd_prepare_command()  argument
640 	return conn_prepare_command(peer_device->connection, sock);  in drbd_prepare_command()
692 int drbd_send_command(struct drbd_peer_device *peer_device, struct drbd_socket *sock,  in drbd_send_command()  argument
698 	err = __send_command(peer_device->connection, peer_device->device->vnr,  in drbd_send_command()
724 int drbd_send_sync_param(struct drbd_peer_device *peer_device)  in drbd_send_sync_param()  argument
729 	const int apv = peer_device->connection->agreed_pro_version;  in drbd_send_sync_param()
734 	sock = &peer_device->connection->data;  in drbd_send_sync_param()
735 	p = drbd_prepare_command(peer_device, sock);  in drbd_send_sync_param()
740 	nc = rcu_dereference(peer_device->connection->net_conf);  in drbd_send_sync_param()
753 	if (get_ldev(peer_device->device)) {  in drbd_send_sync_param()
754 		dc = rcu_dereference(peer_device->device->ldev->disk_conf);  in drbd_send_sync_param()
760 		put_ldev(peer_device->device);  in drbd_send_sync_param()
775 	return drbd_send_command(peer_device, sock, cmd, size, NULL, 0);  in drbd_send_sync_param()
834 static int _drbd_send_uuids(struct drbd_peer_device *peer_device, u64 uuid_flags)  in _drbd_send_uuids()  argument
836 	struct drbd_device *device = peer_device->device;  in _drbd_send_uuids()
844 	sock = &peer_device->connection->data;  in _drbd_send_uuids()
845 	p = drbd_prepare_command(peer_device, sock);  in _drbd_send_uuids()
858 	uuid_flags |= rcu_dereference(peer_device->connection->net_conf)->discard_my_data ? 1 : 0;  in _drbd_send_uuids()
865 	return drbd_send_command(peer_device, sock, P_UUIDS, sizeof(*p), NULL, 0);  in _drbd_send_uuids()
868 int drbd_send_uuids(struct drbd_peer_device *peer_device)  in drbd_send_uuids()  argument
870 	return _drbd_send_uuids(peer_device, 0);  in drbd_send_uuids()
873 int drbd_send_uuids_skip_initial_sync(struct drbd_peer_device *peer_device)  in drbd_send_uuids_skip_initial_sync()  argument
875 	return _drbd_send_uuids(peer_device, 8);  in drbd_send_uuids_skip_initial_sync()
896 void drbd_gen_and_send_sync_uuid(struct drbd_peer_device *peer_device)  in drbd_gen_and_send_sync_uuid()  argument
898 	struct drbd_device *device = peer_device->device;  in drbd_gen_and_send_sync_uuid()
914 	sock = &peer_device->connection->data;  in drbd_gen_and_send_sync_uuid()
915 	p = drbd_prepare_command(peer_device, sock);  in drbd_gen_and_send_sync_uuid()
918 		drbd_send_command(peer_device, sock, P_SYNC_UUID, sizeof(*p), NULL, 0);  in drbd_gen_and_send_sync_uuid()
922 int drbd_send_sizes(struct drbd_peer_device *peer_device, int trigger_reply, enum dds_flags flags)  in drbd_send_sizes()  argument
924 	struct drbd_device *device = peer_device->device;  in drbd_send_sizes()
948 	sock = &peer_device->connection->data;  in drbd_send_sizes()
949 	p = drbd_prepare_command(peer_device, sock);  in drbd_send_sizes()
953 	if (peer_device->connection->agreed_pro_version <= 94)  in drbd_send_sizes()
955 	else if (peer_device->connection->agreed_pro_version < 100)  in drbd_send_sizes()
964 	return drbd_send_command(peer_device, sock, P_SIZES, sizeof(*p), NULL, 0);  in drbd_send_sizes()
971 int drbd_send_current_state(struct drbd_peer_device *peer_device)  in drbd_send_current_state()  argument
976 	sock = &peer_device->connection->data;  in drbd_send_current_state()
977 	p = drbd_prepare_command(peer_device, sock);  in drbd_send_current_state()
980 	p->state = cpu_to_be32(peer_device->device->state.i); /* Within the send mutex */  in drbd_send_current_state()
981 	return drbd_send_command(peer_device, sock, P_STATE, sizeof(*p), NULL, 0);  in drbd_send_current_state()
994 int drbd_send_state(struct drbd_peer_device *peer_device, union drbd_state state)  in drbd_send_state()  argument
999 	sock = &peer_device->connection->data;  in drbd_send_state()
1000 	p = drbd_prepare_command(peer_device, sock);  in drbd_send_state()
1004 	return drbd_send_command(peer_device, sock, P_STATE, sizeof(*p), NULL, 0);  in drbd_send_state()
1007 int drbd_send_state_req(struct drbd_peer_device *peer_device, union drbd_state mask, union drbd_sta…  in drbd_send_state_req()  argument
1012 	sock = &peer_device->connection->data;  in drbd_send_state_req()
1013 	p = drbd_prepare_command(peer_device, sock);  in drbd_send_state_req()
1018 	return drbd_send_command(peer_device, sock, P_STATE_CHG_REQ, sizeof(*p), NULL, 0);  in drbd_send_state_req()
1037 void drbd_send_sr_reply(struct drbd_peer_device *peer_device, enum drbd_state_rv retcode)  in drbd_send_sr_reply()  argument
1042 	sock = &peer_device->connection->meta;  in drbd_send_sr_reply()
1043 	p = drbd_prepare_command(peer_device, sock);  in drbd_send_sr_reply()
1046 		drbd_send_command(peer_device, sock, P_STATE_CHG_REPLY, sizeof(*p), NULL, 0);  in drbd_send_sr_reply()
1315 static int _drbd_send_ack(struct drbd_peer_device *peer_device, enum drbd_packet cmd,  in _drbd_send_ack()  argument
1321 	if (peer_device->device->state.conn < C_CONNECTED)  in _drbd_send_ack()
1324 	sock = &peer_device->connection->meta;  in _drbd_send_ack()
1325 	p = drbd_prepare_command(peer_device, sock);  in _drbd_send_ack()
1331 	p->seq_num = cpu_to_be32(atomic_inc_return(&peer_device->device->packet_seq));  in _drbd_send_ack()
1332 	return drbd_send_command(peer_device, sock, cmd, sizeof(*p), NULL, 0);  in _drbd_send_ack()
1338 void drbd_send_ack_dp(struct drbd_peer_device *peer_device, enum drbd_packet cmd,  in drbd_send_ack_dp()  argument
1341 	if (peer_device->connection->peer_integrity_tfm)  in drbd_send_ack_dp()
1342 		data_size -= crypto_hash_digestsize(peer_device->connection->peer_integrity_tfm);  in drbd_send_ack_dp()
1343 	_drbd_send_ack(peer_device, cmd, dp->sector, cpu_to_be32(data_size),  in drbd_send_ack_dp()
1347 void drbd_send_ack_rp(struct drbd_peer_device *peer_device, enum drbd_packet cmd,  in drbd_send_ack_rp()  argument
1350 	_drbd_send_ack(peer_device, cmd, rp->sector, rp->blksize, rp->block_id);  in drbd_send_ack_rp()
1359 int drbd_send_ack(struct drbd_peer_device *peer_device, enum drbd_packet cmd,  in drbd_send_ack()  argument
1362 	return _drbd_send_ack(peer_device, cmd,  in drbd_send_ack()
1370 int drbd_send_ack_ex(struct drbd_peer_device *peer_device, enum drbd_packet cmd,  in drbd_send_ack_ex()  argument
1373 	return _drbd_send_ack(peer_device, cmd,  in drbd_send_ack_ex()
1379 int drbd_send_drequest(struct drbd_peer_device *peer_device, int cmd,  in drbd_send_drequest()  argument
1385 	sock = &peer_device->connection->data;  in drbd_send_drequest()
1386 	p = drbd_prepare_command(peer_device, sock);  in drbd_send_drequest()
1392 	return drbd_send_command(peer_device, sock, cmd, sizeof(*p), NULL, 0);  in drbd_send_drequest()
1395 int drbd_send_drequest_csum(struct drbd_peer_device *peer_device, sector_t sector, int size,  in drbd_send_drequest_csum()  argument
1403 	sock = &peer_device->connection->data;  in drbd_send_drequest_csum()
1404 	p = drbd_prepare_command(peer_device, sock);  in drbd_send_drequest_csum()
1410 	return drbd_send_command(peer_device, sock, cmd, sizeof(*p), digest, digest_size);  in drbd_send_drequest_csum()
1413 int drbd_send_ov_request(struct drbd_peer_device *peer_device, sector_t sector, int size)  in drbd_send_ov_request()  argument
1418 	sock = &peer_device->connection->data;  in drbd_send_ov_request()
1419 	p = drbd_prepare_command(peer_device, sock);  in drbd_send_ov_request()
1425 	return drbd_send_command(peer_device, sock, P_OV_REQUEST, sizeof(*p), NULL, 0);  in drbd_send_ov_request()
1483 static int _drbd_no_send_page(struct drbd_peer_device *peer_device, struct page *page,  in _drbd_no_send_page()  argument
1490 	socket = peer_device->connection->data.socket;  in _drbd_no_send_page()
1492 	err = drbd_send_all(peer_device->connection, socket, addr, size, msg_flags);  in _drbd_no_send_page()
1495 		peer_device->device->send_cnt += size >> 9;  in _drbd_no_send_page()
1499 static int _drbd_send_page(struct drbd_peer_device *peer_device, struct page *page,  in _drbd_send_page()  argument
1502 	struct socket *socket = peer_device->connection->data.socket;  in _drbd_send_page()
1514 		return _drbd_no_send_page(peer_device, page, offset, size, msg_flags);  in _drbd_send_page()
1517 	drbd_update_congested(peer_device->connection);  in _drbd_send_page()
1525 				if (we_should_drop_the_connection(peer_device->connection, socket))  in _drbd_send_page()
1529 			drbd_warn(peer_device->device, "%s: size=%d len=%d sent=%d\n",  in _drbd_send_page()
1539 	clear_bit(NET_CONGESTED, &peer_device->connection->flags);  in _drbd_send_page()
1543 		peer_device->device->send_cnt += size >> 9;  in _drbd_send_page()
1548 static int _drbd_send_bio(struct drbd_peer_device *peer_device, struct bio *bio)  in _drbd_send_bio()  argument
1557 		err = _drbd_no_send_page(peer_device, bvec.bv_page,  in _drbd_send_bio()
1567 static int _drbd_send_zc_bio(struct drbd_peer_device *peer_device, struct bio *bio)  in _drbd_send_zc_bio()  argument
1576 		err = _drbd_send_page(peer_device, bvec.bv_page,  in _drbd_send_zc_bio()
1585 static int _drbd_send_zc_ee(struct drbd_peer_device *peer_device,  in _drbd_send_zc_ee()  argument
1596 		err = _drbd_send_page(peer_device, page, 0, l,  in _drbd_send_zc_ee()
1619 int drbd_send_dblock(struct drbd_peer_device *peer_device, struct drbd_request *req)  in drbd_send_dblock()  argument
1621 	struct drbd_device *device = peer_device->device;  in drbd_send_dblock()
1628 	sock = &peer_device->connection->data;  in drbd_send_dblock()
1629 	p = drbd_prepare_command(peer_device, sock);  in drbd_send_dblock()
1630 	digest_size = peer_device->connection->integrity_tfm ?  in drbd_send_dblock()
1631 		      crypto_hash_digestsize(peer_device->connection->integrity_tfm) : 0;  in drbd_send_dblock()
1638 	dp_flags = bio_flags_to_wire(peer_device->connection, req->master_bio->bi_rw);  in drbd_send_dblock()
1642 	if (peer_device->connection->agreed_pro_version >= 100) {  in drbd_send_dblock()
1656 		err = __send_command(peer_device->connection, device->vnr, sock, P_TRIM, sizeof(*t), NULL, 0);  in drbd_send_dblock()
1663 		drbd_csum_bio(peer_device->connection->integrity_tfm, req->master_bio, p + 1);  in drbd_send_dblock()
1664 …err = __send_command(peer_device->connection, device->vnr, sock, P_DATA, sizeof(*p) + digest_size,…  in drbd_send_dblock()
1678 			err = _drbd_send_bio(peer_device, req->master_bio);  in drbd_send_dblock()
1680 			err = _drbd_send_zc_bio(peer_device, req->master_bio);  in drbd_send_dblock()
1687 			drbd_csum_bio(peer_device->connection->integrity_tfm, req->master_bio, digest);  in drbd_send_dblock()
1707 int drbd_send_block(struct drbd_peer_device *peer_device, enum drbd_packet cmd,  in drbd_send_block()  argument
1710 	struct drbd_device *device = peer_device->device;  in drbd_send_block()
1716 	sock = &peer_device->connection->data;  in drbd_send_block()
1717 	p = drbd_prepare_command(peer_device, sock);  in drbd_send_block()
1719 	digest_size = peer_device->connection->integrity_tfm ?  in drbd_send_block()
1720 		      crypto_hash_digestsize(peer_device->connection->integrity_tfm) : 0;  in drbd_send_block()
1729 		drbd_csum_ee(peer_device->connection->integrity_tfm, peer_req, p + 1);  in drbd_send_block()
1730 …err = __send_command(peer_device->connection, device->vnr, sock, cmd, sizeof(*p) + digest_size, NU…  in drbd_send_block()
1732 		err = _drbd_send_zc_ee(peer_device, peer_req);  in drbd_send_block()
1738 int drbd_send_out_of_sync(struct drbd_peer_device *peer_device, struct drbd_request *req)  in drbd_send_out_of_sync()  argument
1743 	sock = &peer_device->connection->data;  in drbd_send_out_of_sync()
1744 	p = drbd_prepare_command(peer_device, sock);  in drbd_send_out_of_sync()
1749 	return drbd_send_command(peer_device, sock, P_OUT_OF_SYNC, sizeof(*p), NULL, 0);  in drbd_send_out_of_sync()
2168 	struct drbd_peer_device *peer_device, *tmp_peer_device;  in drbd_destroy_device()  local
2203 	for_each_peer_device_safe(peer_device, tmp_peer_device, device) {  in drbd_destroy_device()
2204 		kref_put(&peer_device->connection->kref, drbd_destroy_connection);  in drbd_destroy_device()
2205 		kfree(peer_device);  in drbd_destroy_device()
2720 	struct drbd_peer_device *peer_device, *tmp_peer_device;  in drbd_create_device()  local
2807 		peer_device = kzalloc(sizeof(struct drbd_peer_device), GFP_KERNEL);  in drbd_create_device()
2808 		if (!peer_device)  in drbd_create_device()
2810 		peer_device->connection = connection;  in drbd_create_device()
2811 		peer_device->device = device;  in drbd_create_device()
2813 		list_add(&peer_device->peer_devices, &device->peer_devices);  in drbd_create_device()
2816 		id = idr_alloc(&connection->peer_devices, peer_device, vnr, vnr + 1, GFP_KERNEL);  in drbd_create_device()
2835 		for_each_peer_device(peer_device, device)  in drbd_create_device()
2836 			drbd_connected(peer_device);  in drbd_create_device()
2839 	for_each_peer_device(peer_device, device)  in drbd_create_device()
2840 		drbd_debugfs_peer_device_add(peer_device);  in drbd_create_device()
2848 		peer_device = idr_find(&connection->peer_devices, vnr);  in drbd_create_device()
2849 		if (peer_device) {  in drbd_create_device()
2854 	for_each_peer_device_safe(peer_device, tmp_peer_device, device) {  in drbd_create_device()
2855 		list_del(&peer_device->peer_devices);  in drbd_create_device()
2856 		kfree(peer_device);  in drbd_create_device()
2880 	struct drbd_peer_device *peer_device;  in drbd_delete_device()  local
2884 	for_each_peer_device(peer_device, device)  in drbd_delete_device()
2885 		drbd_debugfs_peer_device_cleanup(peer_device);  in drbd_delete_device()
3013 	struct drbd_peer_device *peer_device;  in conn_md_sync()  local
3017 	idr_for_each_entry(&connection->peer_devices, peer_device, vnr) {  in conn_md_sync()
3018 		struct drbd_device *device = peer_device->device;  in conn_md_sync()