Lines Matching refs:peer_device

95 	struct drbd_peer_device *peer_device = peer_req->peer_device;  in drbd_endio_read_sec_final()  local
96 struct drbd_device *device = peer_device->device; in drbd_endio_read_sec_final()
107 drbd_queue_work(&peer_device->connection->sender_work, &peer_req->w); in drbd_endio_read_sec_final()
116 struct drbd_peer_device *peer_device = peer_req->peer_device; in drbd_endio_write_sec_final() local
117 struct drbd_device *device = peer_device->device; in drbd_endio_write_sec_final()
118 struct drbd_connection *connection = peer_device->connection; in drbd_endio_write_sec_final()
162 if (!queue_work(connection->ack_sender, &peer_device->send_acks_work)) in drbd_endio_write_sec_final()
185 struct drbd_device *device = peer_req->peer_device->device; in drbd_peer_request_endio()
358 struct drbd_peer_device *peer_device = peer_req->peer_device; in w_e_send_csum() local
359 struct drbd_device *device = peer_device->device; in w_e_send_csum()
370 digest_size = crypto_ahash_digestsize(peer_device->connection->csums_tfm); in w_e_send_csum()
375 drbd_csum_ee(peer_device->connection->csums_tfm, peer_req, digest); in w_e_send_csum()
384 err = drbd_send_drequest_csum(peer_device, sector, size, in w_e_send_csum()
404 static int read_for_csum(struct drbd_peer_device *peer_device, sector_t sector, int size) in read_for_csum() argument
406 struct drbd_device *device = peer_device->device; in read_for_csum()
414 peer_req = drbd_alloc_peer_req(peer_device, ID_SYNCER /* unused */, sector, in read_for_csum()
602 struct drbd_peer_device *const peer_device = first_peer_device(device); in make_resync_request() local
603 struct drbd_connection *const connection = peer_device ? peer_device->connection : NULL; in make_resync_request()
731 switch (read_for_csum(peer_device, sector, size)) { in make_resync_request()
750 err = drbd_send_drequest(peer_device, in make_resync_request()
1014 struct drbd_peer_device *peer_device; in drbd_resync_finished() local
1016 idr_for_each_entry(&connection->peer_devices, peer_device, vnr) { in drbd_resync_finished()
1017 struct drbd_device *device = peer_device->device; in drbd_resync_finished()
1069 struct drbd_peer_device *peer_device = peer_req->peer_device; in w_e_end_data_req() local
1070 struct drbd_device *device = peer_device->device; in w_e_end_data_req()
1080 err = drbd_send_block(peer_device, P_DATA_REPLY, peer_req); in w_e_end_data_req()
1086 err = drbd_send_ack(peer_device, P_NEG_DREPLY, peer_req); in w_e_end_data_req()
1130 struct drbd_peer_device *peer_device = peer_req->peer_device; in w_e_end_rsdata_req() local
1131 struct drbd_device *device = peer_device->device; in w_e_end_rsdata_req()
1146 err = drbd_send_ack(peer_device, P_RS_CANCEL, peer_req); in w_e_end_rsdata_req()
1151 err = drbd_send_rs_deallocated(peer_device, peer_req); in w_e_end_rsdata_req()
1153 err = drbd_send_block(peer_device, P_RS_DATA_REPLY, peer_req); in w_e_end_rsdata_req()
1165 err = drbd_send_ack(peer_device, P_NEG_RS_DREPLY, peer_req); in w_e_end_rsdata_req()
1183 struct drbd_peer_device *peer_device = peer_req->peer_device; in w_e_end_csum_rs_req() local
1184 struct drbd_device *device = peer_device->device; in w_e_end_csum_rs_req()
1207 if (peer_device->connection->csums_tfm) { in w_e_end_csum_rs_req()
1208 digest_size = crypto_ahash_digestsize(peer_device->connection->csums_tfm); in w_e_end_csum_rs_req()
1213 drbd_csum_ee(peer_device->connection->csums_tfm, peer_req, digest); in w_e_end_csum_rs_req()
1222 err = drbd_send_ack(peer_device, P_RS_IS_IN_SYNC, peer_req); in w_e_end_csum_rs_req()
1228 err = drbd_send_block(peer_device, P_RS_DATA_REPLY, peer_req); in w_e_end_csum_rs_req()
1231 err = drbd_send_ack(peer_device, P_NEG_RS_DREPLY, peer_req); in w_e_end_csum_rs_req()
1247 struct drbd_peer_device *peer_device = peer_req->peer_device; in w_e_end_ov_req() local
1248 struct drbd_device *device = peer_device->device; in w_e_end_ov_req()
1258 digest_size = crypto_ahash_digestsize(peer_device->connection->verify_tfm); in w_e_end_ov_req()
1266 drbd_csum_ee(peer_device->connection->verify_tfm, peer_req, digest); in w_e_end_ov_req()
1278 err = drbd_send_drequest_csum(peer_device, sector, size, digest, digest_size, P_OV_REPLY); in w_e_end_ov_req()
1304 struct drbd_peer_device *peer_device = peer_req->peer_device; in w_e_end_ov_reply() local
1305 struct drbd_device *device = peer_device->device; in w_e_end_ov_reply()
1330 digest_size = crypto_ahash_digestsize(peer_device->connection->verify_tfm); in w_e_end_ov_reply()
1333 drbd_csum_ee(peer_device->connection->verify_tfm, peer_req, digest); in w_e_end_ov_reply()
1352 err = drbd_send_ack_ex(peer_device, P_OV_RESULT, sector, size, in w_e_end_ov_reply()
1440 struct drbd_peer_device *const peer_device = first_peer_device(device); in w_send_out_of_sync() local
1441 struct drbd_connection *const connection = peer_device->connection; in w_send_out_of_sync()
1456 err = drbd_send_out_of_sync(peer_device, req); in w_send_out_of_sync()
1471 struct drbd_peer_device *const peer_device = first_peer_device(device); in w_send_dblock() local
1472 struct drbd_connection *connection = peer_device->connection; in w_send_dblock()
1486 err = drbd_send_dblock(peer_device, req); in w_send_dblock()
1490 pd_send_unplug_remote(peer_device); in w_send_dblock()
1504 struct drbd_peer_device *const peer_device = first_peer_device(device); in w_send_read_req() local
1505 struct drbd_connection *connection = peer_device->connection; in w_send_read_req()
1519 err = drbd_send_drequest(peer_device, P_DATA_REQUEST, req->i.sector, req->i.size, in w_send_read_req()
1525 pd_send_unplug_remote(peer_device); in w_send_read_req()
1747 struct drbd_peer_device *peer_device = first_peer_device(device); in drbd_start_resync() local
1748 struct drbd_connection *connection = peer_device ? peer_device->connection : NULL; in drbd_start_resync()
1884 drbd_gen_and_send_sync_uuid(peer_device); in drbd_start_resync()
2063 struct drbd_peer_device *peer_device; in do_unqueued_work() local
2067 idr_for_each_entry(&connection->peer_devices, peer_device, vnr) { in do_unqueued_work()
2068 struct drbd_device *device = peer_device->device; in do_unqueued_work()
2179 struct drbd_peer_device *peer_device; in drbd_worker() local
2234 idr_for_each_entry(&connection->peer_devices, peer_device, vnr) { in drbd_worker()
2235 struct drbd_device *device = peer_device->device; in drbd_worker()