Lines Matching refs:peer_device
223 struct drbd_peer_device *peer_device; in tl_release() local
226 peer_device = conn_peer_device(connection, req->device->vnr); in tl_release()
227 _req_mod(req, BARRIER_ACKED, peer_device); in tl_release()
250 struct drbd_peer_device *peer_device; in _tl_restart() local
254 peer_device = conn_peer_device(connection, req->device->vnr); in _tl_restart()
255 _req_mod(req, what, peer_device); in _tl_restart()
602 void *drbd_prepare_command(struct drbd_peer_device *peer_device, struct drbd_socket *sock) in drbd_prepare_command() argument
604 return conn_prepare_command(peer_device->connection, sock); in drbd_prepare_command()
656 int drbd_send_command(struct drbd_peer_device *peer_device, struct drbd_socket *sock, in drbd_send_command() argument
662 err = __send_command(peer_device->connection, peer_device->device->vnr, in drbd_send_command()
688 int drbd_send_sync_param(struct drbd_peer_device *peer_device) in drbd_send_sync_param() argument
693 const int apv = peer_device->connection->agreed_pro_version; in drbd_send_sync_param()
698 sock = &peer_device->connection->data; in drbd_send_sync_param()
699 p = drbd_prepare_command(peer_device, sock); in drbd_send_sync_param()
704 nc = rcu_dereference(peer_device->connection->net_conf); in drbd_send_sync_param()
718 if (get_ldev(peer_device->device)) { in drbd_send_sync_param()
719 dc = rcu_dereference(peer_device->device->ldev->disk_conf); in drbd_send_sync_param()
725 put_ldev(peer_device->device); in drbd_send_sync_param()
740 return drbd_send_command(peer_device, sock, cmd, size, NULL, 0); in drbd_send_sync_param()
798 static int _drbd_send_uuids(struct drbd_peer_device *peer_device, u64 uuid_flags) in _drbd_send_uuids() argument
800 struct drbd_device *device = peer_device->device; in _drbd_send_uuids()
808 sock = &peer_device->connection->data; in _drbd_send_uuids()
809 p = drbd_prepare_command(peer_device, sock); in _drbd_send_uuids()
822 uuid_flags |= rcu_dereference(peer_device->connection->net_conf)->discard_my_data ? 1 : 0; in _drbd_send_uuids()
829 return drbd_send_command(peer_device, sock, P_UUIDS, sizeof(*p), NULL, 0); in _drbd_send_uuids()
832 int drbd_send_uuids(struct drbd_peer_device *peer_device) in drbd_send_uuids() argument
834 return _drbd_send_uuids(peer_device, 0); in drbd_send_uuids()
837 int drbd_send_uuids_skip_initial_sync(struct drbd_peer_device *peer_device) in drbd_send_uuids_skip_initial_sync() argument
839 return _drbd_send_uuids(peer_device, 8); in drbd_send_uuids_skip_initial_sync()
860 void drbd_gen_and_send_sync_uuid(struct drbd_peer_device *peer_device) in drbd_gen_and_send_sync_uuid() argument
862 struct drbd_device *device = peer_device->device; in drbd_gen_and_send_sync_uuid()
878 sock = &peer_device->connection->data; in drbd_gen_and_send_sync_uuid()
879 p = drbd_prepare_command(peer_device, sock); in drbd_gen_and_send_sync_uuid()
882 drbd_send_command(peer_device, sock, P_SYNC_UUID, sizeof(*p), NULL, 0); in drbd_gen_and_send_sync_uuid()
886 int drbd_send_sizes(struct drbd_peer_device *peer_device, int trigger_reply, enum dds_flags flags) in drbd_send_sizes() argument
888 struct drbd_device *device = peer_device->device; in drbd_send_sizes()
896 sock = &peer_device->connection->data; in drbd_send_sizes()
897 p = drbd_prepare_command(peer_device, sock); in drbd_send_sizes()
902 if (peer_device->connection->agreed_features & DRBD_FF_WSAME) in drbd_send_sizes()
945 if (peer_device->connection->agreed_pro_version <= 94) in drbd_send_sizes()
947 else if (peer_device->connection->agreed_pro_version < 100) in drbd_send_sizes()
960 return drbd_send_command(peer_device, sock, P_SIZES, packet_size, NULL, 0); in drbd_send_sizes()
967 int drbd_send_current_state(struct drbd_peer_device *peer_device) in drbd_send_current_state() argument
972 sock = &peer_device->connection->data; in drbd_send_current_state()
973 p = drbd_prepare_command(peer_device, sock); in drbd_send_current_state()
976 p->state = cpu_to_be32(peer_device->device->state.i); /* Within the send mutex */ in drbd_send_current_state()
977 return drbd_send_command(peer_device, sock, P_STATE, sizeof(*p), NULL, 0); in drbd_send_current_state()
990 int drbd_send_state(struct drbd_peer_device *peer_device, union drbd_state state) in drbd_send_state() argument
995 sock = &peer_device->connection->data; in drbd_send_state()
996 p = drbd_prepare_command(peer_device, sock); in drbd_send_state()
1000 return drbd_send_command(peer_device, sock, P_STATE, sizeof(*p), NULL, 0); in drbd_send_state()
1003 int drbd_send_state_req(struct drbd_peer_device *peer_device, union drbd_state mask, union drbd_sta… in drbd_send_state_req() argument
1008 sock = &peer_device->connection->data; in drbd_send_state_req()
1009 p = drbd_prepare_command(peer_device, sock); in drbd_send_state_req()
1014 return drbd_send_command(peer_device, sock, P_STATE_CHG_REQ, sizeof(*p), NULL, 0); in drbd_send_state_req()
1033 void drbd_send_sr_reply(struct drbd_peer_device *peer_device, enum drbd_state_rv retcode) in drbd_send_sr_reply() argument
1038 sock = &peer_device->connection->meta; in drbd_send_sr_reply()
1039 p = drbd_prepare_command(peer_device, sock); in drbd_send_sr_reply()
1042 drbd_send_command(peer_device, sock, P_STATE_CHG_REPLY, sizeof(*p), NULL, 0); in drbd_send_sr_reply()
1181 send_bitmap_rle_or_plain(struct drbd_peer_device *peer_device, struct bm_xfer_ctx *c) in send_bitmap_rle_or_plain() argument
1183 struct drbd_device *device = peer_device->device; in send_bitmap_rle_or_plain()
1184 struct drbd_socket *sock = &peer_device->connection->data; in send_bitmap_rle_or_plain()
1185 unsigned int header_size = drbd_header_size(peer_device->connection); in send_bitmap_rle_or_plain()
1196 err = __send_command(peer_device->connection, device->vnr, sock, in send_bitmap_rle_or_plain()
1217 err = __send_command(peer_device->connection, device->vnr, sock, P_BITMAP, in send_bitmap_rle_or_plain()
1230 INFO_bm_xfer_stats(peer_device, "send", c); in send_bitmap_rle_or_plain()
1240 struct drbd_peer_device *peer_device) in _drbd_send_bitmap() argument
1252 if (drbd_bm_write(device, peer_device)) { in _drbd_send_bitmap()
1271 err = send_bitmap_rle_or_plain(peer_device, &c); in _drbd_send_bitmap()
1277 int drbd_send_bitmap(struct drbd_device *device, struct drbd_peer_device *peer_device) in drbd_send_bitmap() argument
1279 struct drbd_socket *sock = &peer_device->connection->data; in drbd_send_bitmap()
1284 err = !_drbd_send_bitmap(device, peer_device); in drbd_send_bitmap()
1314 static int _drbd_send_ack(struct drbd_peer_device *peer_device, enum drbd_packet cmd, in _drbd_send_ack() argument
1320 if (peer_device->device->state.conn < C_CONNECTED) in _drbd_send_ack()
1323 sock = &peer_device->connection->meta; in _drbd_send_ack()
1324 p = drbd_prepare_command(peer_device, sock); in _drbd_send_ack()
1330 p->seq_num = cpu_to_be32(atomic_inc_return(&peer_device->device->packet_seq)); in _drbd_send_ack()
1331 return drbd_send_command(peer_device, sock, cmd, sizeof(*p), NULL, 0); in _drbd_send_ack()
1337 void drbd_send_ack_dp(struct drbd_peer_device *peer_device, enum drbd_packet cmd, in drbd_send_ack_dp() argument
1340 if (peer_device->connection->peer_integrity_tfm) in drbd_send_ack_dp()
1341 data_size -= crypto_shash_digestsize(peer_device->connection->peer_integrity_tfm); in drbd_send_ack_dp()
1342 _drbd_send_ack(peer_device, cmd, dp->sector, cpu_to_be32(data_size), in drbd_send_ack_dp()
1346 void drbd_send_ack_rp(struct drbd_peer_device *peer_device, enum drbd_packet cmd, in drbd_send_ack_rp() argument
1349 _drbd_send_ack(peer_device, cmd, rp->sector, rp->blksize, rp->block_id); in drbd_send_ack_rp()
1358 int drbd_send_ack(struct drbd_peer_device *peer_device, enum drbd_packet cmd, in drbd_send_ack() argument
1361 return _drbd_send_ack(peer_device, cmd, in drbd_send_ack()
1369 int drbd_send_ack_ex(struct drbd_peer_device *peer_device, enum drbd_packet cmd, in drbd_send_ack_ex() argument
1372 return _drbd_send_ack(peer_device, cmd, in drbd_send_ack_ex()
1378 int drbd_send_rs_deallocated(struct drbd_peer_device *peer_device, in drbd_send_rs_deallocated() argument
1384 sock = &peer_device->connection->data; in drbd_send_rs_deallocated()
1385 p = drbd_prepare_command(peer_device, sock); in drbd_send_rs_deallocated()
1391 return drbd_send_command(peer_device, sock, P_RS_DEALLOCATED, sizeof(*p), NULL, 0); in drbd_send_rs_deallocated()
1394 int drbd_send_drequest(struct drbd_peer_device *peer_device, int cmd, in drbd_send_drequest() argument
1400 sock = &peer_device->connection->data; in drbd_send_drequest()
1401 p = drbd_prepare_command(peer_device, sock); in drbd_send_drequest()
1407 return drbd_send_command(peer_device, sock, cmd, sizeof(*p), NULL, 0); in drbd_send_drequest()
1410 int drbd_send_drequest_csum(struct drbd_peer_device *peer_device, sector_t sector, int size, in drbd_send_drequest_csum() argument
1418 sock = &peer_device->connection->data; in drbd_send_drequest_csum()
1419 p = drbd_prepare_command(peer_device, sock); in drbd_send_drequest_csum()
1425 return drbd_send_command(peer_device, sock, cmd, sizeof(*p), digest, digest_size); in drbd_send_drequest_csum()
1428 int drbd_send_ov_request(struct drbd_peer_device *peer_device, sector_t sector, int size) in drbd_send_ov_request() argument
1433 sock = &peer_device->connection->data; in drbd_send_ov_request()
1434 p = drbd_prepare_command(peer_device, sock); in drbd_send_ov_request()
1440 return drbd_send_command(peer_device, sock, P_OV_REQUEST, sizeof(*p), NULL, 0); in drbd_send_ov_request()
1498 static int _drbd_no_send_page(struct drbd_peer_device *peer_device, struct page *page, in _drbd_no_send_page() argument
1505 socket = peer_device->connection->data.socket; in _drbd_no_send_page()
1507 err = drbd_send_all(peer_device->connection, socket, addr, size, msg_flags); in _drbd_no_send_page()
1510 peer_device->device->send_cnt += size >> 9; in _drbd_no_send_page()
1514 static int _drbd_send_page(struct drbd_peer_device *peer_device, struct page *page, in _drbd_send_page() argument
1517 struct socket *socket = peer_device->connection->data.socket; in _drbd_send_page()
1532 drbd_update_congested(peer_device->connection); in _drbd_send_page()
1542 if (we_should_drop_the_connection(peer_device->connection, socket)) in _drbd_send_page()
1546 drbd_warn(peer_device->device, "%s: size=%d len=%d sent=%d\n", in _drbd_send_page()
1555 clear_bit(NET_CONGESTED, &peer_device->connection->flags); in _drbd_send_page()
1559 peer_device->device->send_cnt += size >> 9; in _drbd_send_page()
1564 static int _drbd_send_bio(struct drbd_peer_device *peer_device, struct bio *bio) in _drbd_send_bio() argument
1573 err = _drbd_no_send_page(peer_device, bvec.bv_page, in _drbd_send_bio()
1583 static int _drbd_send_zc_bio(struct drbd_peer_device *peer_device, struct bio *bio) in _drbd_send_zc_bio() argument
1592 err = _drbd_send_page(peer_device, bvec.bv_page, in _drbd_send_zc_bio()
1601 static int _drbd_send_zc_ee(struct drbd_peer_device *peer_device, in _drbd_send_zc_ee() argument
1614 err = _drbd_send_page(peer_device, page, 0, l, in _drbd_send_zc_ee()
1617 err = _drbd_no_send_page(peer_device, page, 0, l, in _drbd_send_zc_ee()
1647 int drbd_send_dblock(struct drbd_peer_device *peer_device, struct drbd_request *req) in drbd_send_dblock() argument
1649 struct drbd_device *device = peer_device->device; in drbd_send_dblock()
1657 sock = &peer_device->connection->data; in drbd_send_dblock()
1658 p = drbd_prepare_command(peer_device, sock); in drbd_send_dblock()
1659 digest_size = peer_device->connection->integrity_tfm ? in drbd_send_dblock()
1660 crypto_shash_digestsize(peer_device->connection->integrity_tfm) : 0; in drbd_send_dblock()
1667 dp_flags = bio_flags_to_wire(peer_device->connection, req->master_bio); in drbd_send_dblock()
1671 if (peer_device->connection->agreed_pro_version >= 100) { in drbd_send_dblock()
1686 err = __send_command(peer_device->connection, device->vnr, sock, cmd, sizeof(*t), NULL, 0); in drbd_send_dblock()
1694 drbd_csum_bio(peer_device->connection->integrity_tfm, req->master_bio, digest_out); in drbd_send_dblock()
1695 err = __send_command(peer_device->connection, device->vnr, sock, P_DATA, in drbd_send_dblock()
1710 err = _drbd_send_bio(peer_device, req->master_bio); in drbd_send_dblock()
1712 err = _drbd_send_zc_bio(peer_device, req->master_bio); in drbd_send_dblock()
1719 drbd_csum_bio(peer_device->connection->integrity_tfm, req->master_bio, digest); in drbd_send_dblock()
1739 int drbd_send_block(struct drbd_peer_device *peer_device, enum drbd_packet cmd, in drbd_send_block() argument
1742 struct drbd_device *device = peer_device->device; in drbd_send_block()
1748 sock = &peer_device->connection->data; in drbd_send_block()
1749 p = drbd_prepare_command(peer_device, sock); in drbd_send_block()
1751 digest_size = peer_device->connection->integrity_tfm ? in drbd_send_block()
1752 crypto_shash_digestsize(peer_device->connection->integrity_tfm) : 0; in drbd_send_block()
1761 drbd_csum_ee(peer_device->connection->integrity_tfm, peer_req, p + 1); in drbd_send_block()
1762 …err = __send_command(peer_device->connection, device->vnr, sock, cmd, sizeof(*p) + digest_size, NU… in drbd_send_block()
1764 err = _drbd_send_zc_ee(peer_device, peer_req); in drbd_send_block()
1770 int drbd_send_out_of_sync(struct drbd_peer_device *peer_device, struct drbd_request *req) in drbd_send_out_of_sync() argument
1775 sock = &peer_device->connection->data; in drbd_send_out_of_sync()
1776 p = drbd_prepare_command(peer_device, sock); in drbd_send_out_of_sync()
1781 return drbd_send_command(peer_device, sock, P_OUT_OF_SYNC, sizeof(*p), NULL, 0); in drbd_send_out_of_sync()
2159 struct drbd_peer_device *peer_device, *tmp_peer_device; in drbd_destroy_device() local
2190 for_each_peer_device_safe(peer_device, tmp_peer_device, device) { in drbd_destroy_device()
2191 kref_put(&peer_device->connection->kref, drbd_destroy_connection); in drbd_destroy_device()
2192 kfree(peer_device); in drbd_destroy_device()
2650 struct drbd_peer_device *peer_device, *tmp_peer_device; in drbd_create_device() local
2731 peer_device = kzalloc(sizeof(struct drbd_peer_device), GFP_KERNEL); in drbd_create_device()
2732 if (!peer_device) in drbd_create_device()
2734 peer_device->connection = connection; in drbd_create_device()
2735 peer_device->device = device; in drbd_create_device()
2737 list_add(&peer_device->peer_devices, &device->peer_devices); in drbd_create_device()
2740 id = idr_alloc(&connection->peer_devices, peer_device, vnr, vnr + 1, GFP_KERNEL); in drbd_create_device()
2747 INIT_WORK(&peer_device->send_acks_work, drbd_send_acks_wf); in drbd_create_device()
2762 for_each_peer_device(peer_device, device) in drbd_create_device()
2763 drbd_connected(peer_device); in drbd_create_device()
2766 for_each_peer_device(peer_device, device) in drbd_create_device()
2767 drbd_debugfs_peer_device_add(peer_device); in drbd_create_device()
2775 peer_device = idr_remove(&connection->peer_devices, vnr); in drbd_create_device()
2776 if (peer_device) in drbd_create_device()
2779 for_each_peer_device_safe(peer_device, tmp_peer_device, device) { in drbd_create_device()
2780 list_del(&peer_device->peer_devices); in drbd_create_device()
2781 kfree(peer_device); in drbd_create_device()
2803 struct drbd_peer_device *peer_device; in drbd_delete_device() local
2806 for_each_peer_device(peer_device, device) in drbd_delete_device()
2807 drbd_debugfs_peer_device_cleanup(peer_device); in drbd_delete_device()
2919 struct drbd_peer_device *peer_device; in conn_md_sync() local
2923 idr_for_each_entry(&connection->peer_devices, peer_device, vnr) { in conn_md_sync()
2924 struct drbd_device *device = peer_device->device; in conn_md_sync()
3389 struct drbd_peer_device *peer_device) __must_hold(local) in drbd_bmio_set_n_write() argument
3398 rv = drbd_bm_write(device, peer_device); in drbd_bmio_set_n_write()
3416 struct drbd_peer_device *peer_device) __must_hold(local) in drbd_bmio_clear_n_write() argument
3421 return drbd_bm_write(device, peer_device); in drbd_bmio_clear_n_write()
3440 rv = work->io_fn(device, work->peer_device); in w_bitmap_io()
3479 struct drbd_peer_device *peer_device) in drbd_queue_bitmap_io() argument
3481 D_ASSERT(device, current == peer_device->connection->worker.task); in drbd_queue_bitmap_io()
3490 device->bm_io_work.peer_device = peer_device; in drbd_queue_bitmap_io()
3502 drbd_queue_work(&peer_device->connection->sender_work, in drbd_queue_bitmap_io()
3522 struct drbd_peer_device *peer_device) in drbd_bitmap_io() argument
3534 rv = io_fn(device, peer_device); in drbd_bitmap_io()