334 		    unsigned int data_size, gfp_t gfp_mask) __must_hold(local)  in drbd_alloc_peer_req()  argument
338 	unsigned nr_pages = (data_size + PAGE_SIZE -1) >> PAGE_SHIFT;  in drbd_alloc_peer_req()
350 	if (data_size) {  in drbd_alloc_peer_req()
357 	peer_req->i.size = data_size;  in drbd_alloc_peer_req()
1488 	      int data_size) __must_hold(local)  in read_in_block()  argument
1508 		data_size -= dgs;  in read_in_block()
1511 	if (!expect(IS_ALIGNED(data_size, 512)))  in read_in_block()
1513 	if (!expect(data_size <= DRBD_MAX_BIO_SIZE))  in read_in_block()
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()
1533 	if (!data_size)  in read_in_block()
1536 	ds = data_size;  in read_in_block()
1558 				(unsigned long long)sector, data_size);  in read_in_block()
1563 	mdev->recv_cnt += data_size>>9;  in read_in_block()
1570 static int drbd_drain_block(struct drbd_conf *mdev, int data_size)  in drbd_drain_block()  argument
1576 	if (!data_size)  in drbd_drain_block()
1582 	while (data_size) {  in drbd_drain_block()
1583 		unsigned int len = min_t(int, data_size, PAGE_SIZE);  in drbd_drain_block()
1588 		data_size -= len;  in drbd_drain_block()
1596 			   sector_t sector, int data_size)  in recv_dless_read()  argument
1610 		data_size -= dgs;  in recv_dless_read()
1615 	mdev->recv_cnt += data_size>>9;  in recv_dless_read()
1622 		expect = min_t(int, data_size, bvec->bv_len);  in recv_dless_read()
1627 		data_size -= expect;  in recv_dless_read()
1638 	D_ASSERT(data_size == 0);  in recv_dless_read()
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()
1690 	atomic_add(data_size >> 9, &mdev->rs_sect_ev);  in recv_resync_read()
3325 	unsigned int header_size, data_size, exp_max_sz;  in receive_SyncParam()  local
3353 		data_size = pi->size - header_size;  in receive_SyncParam()
3356 		data_size = pi->size - header_size;  in receive_SyncParam()
3357 		D_ASSERT(data_size == 0);  in receive_SyncParam()
3360 		data_size = pi->size - header_size;  in receive_SyncParam()
3361 		D_ASSERT(data_size == 0);  in receive_SyncParam()
3391 			if (data_size > SHARED_SECRET_MAX || data_size == 0) {  in receive_SyncParam()
3394 					data_size, SHARED_SECRET_MAX);  in receive_SyncParam()
3399 			err = drbd_recv_all(mdev->tconn, p->verify_alg, data_size);  in receive_SyncParam()
3404 			D_ASSERT(p->verify_alg[data_size-1] == 0);  in receive_SyncParam()
3405 			p->verify_alg[data_size-1] = 0;  in receive_SyncParam()
4044 	unsigned int data_size = DRBD_SOCKET_BUFFER_SIZE -  in receive_bitmap_plain()  local
4046 	unsigned int num_words = min_t(size_t, data_size / sizeof(*p),  in receive_bitmap_plain()
4180 	unsigned int data_size = DRBD_SOCKET_BUFFER_SIZE - header_size;  in INFO_bm_xfer_stats()  local
4182 		header_size * (DIV_ROUND_UP(c->bm_words, data_size) + 1) +  in INFO_bm_xfer_stats()