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()
368 peer_req->i.size = data_size; in drbd_alloc_peer_req()
1374 unsigned data_size = peer_req->i.size; in drbd_submit_peer_request() local
1376 unsigned nr_pages = (data_size + PAGE_SIZE -1) >> PAGE_SHIFT; in drbd_submit_peer_request()
1391 sector, data_size >> 9, GFP_NOIO, false)) in drbd_submit_peer_request()
1429 bio->bi_iter.bi_size = data_size; in drbd_submit_peer_request()
1434 unsigned len = min_t(unsigned, data_size, PAGE_SIZE); in drbd_submit_peer_request()
1449 data_size -= len; in drbd_submit_peer_request()
1453 D_ASSERT(device, data_size == 0); in drbd_submit_peer_request()
1595 unsigned int data_size = pi->size, ds; in read_in_block() local
1611 data_size -= digest_size; in read_in_block()
1615 D_ASSERT(peer_device, data_size == 0); in read_in_block()
1616 data_size = be32_to_cpu(trim->size); in read_in_block()
1619 if (!expect(IS_ALIGNED(data_size, 512))) in read_in_block()
1622 if (!trim && !expect(data_size <= DRBD_MAX_BIO_SIZE)) in read_in_block()
1627 if (sector + (data_size>>9) > capacity) { in read_in_block()
1631 (unsigned long long)sector, data_size); in read_in_block()
1638 peer_req = drbd_alloc_peer_req(peer_device, id, sector, data_size, trim == NULL, GFP_NOIO); in read_in_block()
1646 ds = data_size; in read_in_block()
1668 (unsigned long long)sector, data_size); in read_in_block()
1673 device->recv_cnt += data_size >> 9; in read_in_block()
1680 static int drbd_drain_block(struct drbd_peer_device *peer_device, int data_size) in drbd_drain_block() argument
1686 if (!data_size) in drbd_drain_block()
1692 while (data_size) { in drbd_drain_block()
1693 unsigned int len = min_t(int, data_size, PAGE_SIZE); in drbd_drain_block()
1698 data_size -= len; in drbd_drain_block()
1706 sector_t sector, int data_size) in recv_dless_read() argument
1721 data_size -= digest_size; in recv_dless_read()
1726 peer_device->device->recv_cnt += data_size>>9; in recv_dless_read()
1733 expect = min_t(int, data_size, bvec.bv_len); in recv_dless_read()
1738 data_size -= expect; in recv_dless_read()
1749 D_ASSERT(peer_device->device, data_size == 0); in recv_dless_read()
3505 unsigned int header_size, data_size, exp_max_sz; in receive_SyncParam() local
3534 data_size = pi->size - header_size; in receive_SyncParam()
3537 data_size = pi->size - header_size; in receive_SyncParam()
3538 D_ASSERT(device, data_size == 0); in receive_SyncParam()
3541 data_size = pi->size - header_size; in receive_SyncParam()
3542 D_ASSERT(device, data_size == 0); in receive_SyncParam()
3572 if (data_size > SHARED_SECRET_MAX || data_size == 0) { in receive_SyncParam()
3575 data_size, SHARED_SECRET_MAX); in receive_SyncParam()
3580 err = drbd_recv_all(peer_device->connection, p->verify_alg, data_size); in receive_SyncParam()
3585 D_ASSERT(device, p->verify_alg[data_size-1] == 0); in receive_SyncParam()
3586 p->verify_alg[data_size-1] = 0; in receive_SyncParam()
4253 unsigned int data_size = DRBD_SOCKET_BUFFER_SIZE - in receive_bitmap_plain() local
4255 unsigned int num_words = min_t(size_t, data_size / sizeof(*p), in receive_bitmap_plain()
4393 unsigned int data_size = DRBD_SOCKET_BUFFER_SIZE - header_size; in INFO_bm_xfer_stats() local
4395 header_size * (DIV_ROUND_UP(c->bm_words, data_size) + 1) + in INFO_bm_xfer_stats()