Lines Matching refs:data_size

342 		    unsigned int data_size, bool has_payload, gfp_t gfp_mask) __must_hold(local)  in drbd_alloc_peer_req()  argument
347 unsigned nr_pages = (data_size + PAGE_SIZE -1) >> PAGE_SHIFT; in drbd_alloc_peer_req()
359 if (has_payload && data_size) { in drbd_alloc_peer_req()
369 peer_req->i.size = data_size; in drbd_alloc_peer_req()
1375 unsigned data_size = peer_req->i.size; in drbd_submit_peer_request() local
1377 unsigned nr_pages = (data_size + PAGE_SIZE -1) >> PAGE_SHIFT; in drbd_submit_peer_request()
1392 sector, data_size >> 9, GFP_NOIO, false)) in drbd_submit_peer_request()
1430 bio->bi_iter.bi_size = data_size; in drbd_submit_peer_request()
1435 unsigned len = min_t(unsigned, data_size, PAGE_SIZE); in drbd_submit_peer_request()
1450 data_size -= len; in drbd_submit_peer_request()
1454 D_ASSERT(device, data_size == 0); in drbd_submit_peer_request()
1596 unsigned int data_size = pi->size, ds; in read_in_block() local
1612 data_size -= digest_size; in read_in_block()
1616 D_ASSERT(peer_device, data_size == 0); in read_in_block()
1617 data_size = be32_to_cpu(trim->size); in read_in_block()
1620 if (!expect(IS_ALIGNED(data_size, 512))) in read_in_block()
1623 if (!trim && !expect(data_size <= DRBD_MAX_BIO_SIZE)) in read_in_block()
1628 if (sector + (data_size>>9) > capacity) { in read_in_block()
1632 (unsigned long long)sector, data_size); in read_in_block()
1639 peer_req = drbd_alloc_peer_req(peer_device, id, sector, data_size, trim == NULL, GFP_NOIO); in read_in_block()
1647 ds = data_size; in read_in_block()
1669 (unsigned long long)sector, data_size); in read_in_block()
1674 device->recv_cnt += data_size >> 9; in read_in_block()
1681 static int drbd_drain_block(struct drbd_peer_device *peer_device, int data_size) in drbd_drain_block() argument
1687 if (!data_size) in drbd_drain_block()
1693 while (data_size) { in drbd_drain_block()
1694 unsigned int len = min_t(int, data_size, PAGE_SIZE); in drbd_drain_block()
1699 data_size -= len; in drbd_drain_block()
1707 sector_t sector, int data_size) in recv_dless_read() argument
1722 data_size -= digest_size; in recv_dless_read()
1727 peer_device->device->recv_cnt += data_size>>9; in recv_dless_read()
1734 expect = min_t(int, data_size, bvec.bv_len); in recv_dless_read()
1739 data_size -= expect; in recv_dless_read()
1750 D_ASSERT(peer_device->device, data_size == 0); in recv_dless_read()
3506 unsigned int header_size, data_size, exp_max_sz; in receive_SyncParam() local
3535 data_size = pi->size - header_size; in receive_SyncParam()
3538 data_size = pi->size - header_size; in receive_SyncParam()
3539 D_ASSERT(device, data_size == 0); in receive_SyncParam()
3542 data_size = pi->size - header_size; in receive_SyncParam()
3543 D_ASSERT(device, data_size == 0); in receive_SyncParam()
3573 if (data_size > SHARED_SECRET_MAX || data_size == 0) { in receive_SyncParam()
3576 data_size, SHARED_SECRET_MAX); in receive_SyncParam()
3581 err = drbd_recv_all(peer_device->connection, p->verify_alg, data_size); in receive_SyncParam()
3586 D_ASSERT(device, p->verify_alg[data_size-1] == 0); in receive_SyncParam()
3587 p->verify_alg[data_size-1] = 0; in receive_SyncParam()
4254 unsigned int data_size = DRBD_SOCKET_BUFFER_SIZE - in receive_bitmap_plain() local
4256 unsigned int num_words = min_t(size_t, data_size / sizeof(*p), in receive_bitmap_plain()
4394 unsigned int data_size = DRBD_SOCKET_BUFFER_SIZE - header_size; in INFO_bm_xfer_stats() local
4396 header_size * (DIV_ROUND_UP(c->bm_words, data_size) + 1) + in INFO_bm_xfer_stats()