Lines Matching refs:sector
333 drbd_alloc_peer_req(struct drbd_conf *mdev, u64 id, sector_t sector, in drbd_alloc_peer_req() argument
358 peer_req->i.sector = sector; in drbd_alloc_peer_req()
1315 sector_t sector = peer_req->i.sector; in drbd_submit_peer_request() local
1336 bio->bi_sector = sector; in drbd_submit_peer_request()
1363 sector += len >> 9; in drbd_submit_peer_request()
1487 read_in_block(struct drbd_conf *mdev, u64 id, sector_t sector, in read_in_block() argument
1518 if (sector + (data_size>>9) > capacity) { in read_in_block()
1522 (unsigned long long)sector, data_size); in read_in_block()
1529 peer_req = drbd_alloc_peer_req(mdev, id, sector, data_size, GFP_NOIO); in read_in_block()
1558 (unsigned long long)sector, data_size); in read_in_block()
1596 sector_t sector, int data_size) in recv_dless_read() argument
1618 D_ASSERT(sector == bio->bi_sector); in recv_dless_read()
1651 sector_t sector = peer_req->i.sector; in e_end_resync_block() local
1657 drbd_set_in_sync(mdev, sector, peer_req->i.size); in e_end_resync_block()
1661 drbd_rs_failed_io(mdev, sector, peer_req->i.size); in e_end_resync_block()
1670 static int recv_resync_read(struct drbd_conf *mdev, sector_t sector, int data_size) __releases(loca… in recv_resync_read() argument
1674 peer_req = read_in_block(mdev, ID_SYNCER, sector, data_size); in recv_resync_read()
1708 sector_t sector, bool missing_ok, const char *func) in find_request() argument
1714 if (drbd_contains_interval(root, sector, &req->i) && req->i.local) in find_request()
1718 (unsigned long)id, (unsigned long long)sector); in find_request()
1727 sector_t sector; in receive_DataReply() local
1735 sector = be64_to_cpu(p->sector); in receive_DataReply()
1738 req = find_request(mdev, &mdev->read_requests, p->block_id, sector, false, __func__); in receive_DataReply()
1746 err = recv_dless_read(mdev, req, sector, pi->size); in receive_DataReply()
1759 sector_t sector; in receive_RSDataReply() local
1767 sector = be64_to_cpu(p->sector); in receive_RSDataReply()
1774 err = recv_resync_read(mdev, sector, pi->size); in receive_RSDataReply()
1790 sector_t sector, int size) in restart_conflicting_writes() argument
1795 drbd_for_each_overlap(i, &mdev->write_requests, sector, size) { in restart_conflicting_writes()
1816 sector_t sector = peer_req->i.sector; in e_end_block() local
1827 drbd_set_in_sync(mdev, sector, peer_req->i.size); in e_end_block()
1842 restart_conflicting_writes(mdev, sector, peer_req->i.size); in e_end_block()
1939 if (overlaps(peer_req->i.sector, peer_req->i.size, in overlapping_resync_write()
1940 rs_req->i.sector, rs_req->i.size)) { in overlapping_resync_write()
2020 static void fail_postponed_requests(struct drbd_conf *mdev, sector_t sector, in fail_postponed_requests() argument
2026 drbd_for_each_overlap(i, &mdev->write_requests, sector, size) { in fail_postponed_requests()
2050 sector_t sector = peer_req->i.sector; in handle_write_conflicts() local
2063 drbd_for_each_overlap(i, &mdev->write_requests, sector, size) { in handle_write_conflicts()
2079 equal = i->sector == sector && i->size == size; in handle_write_conflicts()
2087 bool superseded = i->sector <= sector && i->sector + in handle_write_conflicts()
2088 (i->size >> 9) >= sector + (size >> 9); in handle_write_conflicts()
2094 (unsigned long long)i->sector, i->size, in handle_write_conflicts()
2095 (unsigned long long)sector, size, in handle_write_conflicts()
2113 (unsigned long long)i->sector, i->size, in handle_write_conflicts()
2114 (unsigned long long)sector, size); in handle_write_conflicts()
2134 fail_postponed_requests(mdev, sector, size); in handle_write_conflicts()
2158 sector_t sector; in receive_Data() local
2188 sector = be64_to_cpu(p->sector); in receive_Data()
2189 peer_req = read_in_block(mdev, p->block_id, sector, pi->size); in receive_Data()
2267 drbd_set_out_of_sync(mdev, peer_req->i.sector, peer_req->i.size); in receive_Data()
2304 int drbd_rs_should_slow_down(struct drbd_conf *mdev, sector_t sector) in drbd_rs_should_slow_down() argument
2322 tmp = lc_find(mdev->resync, BM_SECT_TO_EXT(sector)); in drbd_rs_should_slow_down()
2368 sector_t sector; in receive_DataRequest() local
2381 sector = be64_to_cpu(p->sector); in receive_DataRequest()
2386 (unsigned long long)sector, size); in receive_DataRequest()
2389 if (sector + (size>>9) > capacity) { in receive_DataRequest()
2391 (unsigned long long)sector, size); in receive_DataRequest()
2409 drbd_send_ack_ex(mdev, P_OV_RESULT, sector, size, ID_IN_SYNC); in receive_DataRequest()
2425 peer_req = drbd_alloc_peer_req(mdev, p->block_id, sector, size, GFP_NOIO); in receive_DataRequest()
2442 mdev->bm_resync_fo = BM_SECT_TO_BIT(sector); in receive_DataRequest()
2465 mdev->bm_resync_fo = BM_SECT_TO_BIT(sector); in receive_DataRequest()
2482 mdev->ov_start_sector = sector; in receive_DataRequest()
2483 mdev->ov_position = sector; in receive_DataRequest()
2484 mdev->ov_left = drbd_bm_bits(mdev) - BM_SECT_TO_BIT(sector); in receive_DataRequest()
2491 (unsigned long long)sector); in receive_DataRequest()
2523 if (mdev->state.peer != R_PRIMARY && drbd_rs_should_slow_down(mdev, sector)) in receive_DataRequest()
2525 if (drbd_rs_begin_io(mdev, sector)) in receive_DataRequest()
4341 drbd_set_out_of_sync(mdev, be64_to_cpu(p->sector), be32_to_cpu(p->blksize)); in receive_out_of_sync()
4933 sector_t sector = be64_to_cpu(p->sector); in got_IsInSync() local
4945 drbd_rs_complete_io(mdev, sector); in got_IsInSync()
4946 drbd_set_in_sync(mdev, sector, blksize); in got_IsInSync()
4958 validate_req_change_req_state(struct drbd_conf *mdev, u64 id, sector_t sector, in validate_req_change_req_state() argument
4966 req = find_request(mdev, root, id, sector, missing_ok, func); in validate_req_change_req_state()
4983 sector_t sector = be64_to_cpu(p->sector); in got_BlockAck() local
4994 drbd_set_in_sync(mdev, sector, blksize); in got_BlockAck()
5018 return validate_req_change_req_state(mdev, p->block_id, sector, in got_BlockAck()
5027 sector_t sector = be64_to_cpu(p->sector); in got_NegAck() local
5039 drbd_rs_failed_io(mdev, sector, size); in got_NegAck()
5043 err = validate_req_change_req_state(mdev, p->block_id, sector, in got_NegAck()
5052 drbd_set_out_of_sync(mdev, sector, size); in got_NegAck()
5061 sector_t sector = be64_to_cpu(p->sector); in got_NegDReply() local
5070 (unsigned long long)sector, be32_to_cpu(p->blksize)); in got_NegDReply()
5072 return validate_req_change_req_state(mdev, p->block_id, sector, in got_NegDReply()
5080 sector_t sector; in got_NegRSDReply() local
5088 sector = be64_to_cpu(p->sector); in got_NegRSDReply()
5096 drbd_rs_complete_io(mdev, sector); in got_NegRSDReply()
5099 drbd_rs_failed_io(mdev, sector, size); in got_NegRSDReply()
5138 sector_t sector; in got_OVResult() local
5145 sector = be64_to_cpu(p->sector); in got_OVResult()
5151 drbd_ov_out_of_sync_found(mdev, sector, size); in got_OVResult()
5158 drbd_rs_complete_io(mdev, sector); in got_OVResult()