Lines Matching refs:page_offset

538 		     int page_offset, size_t length)  in ceph_tcp_recvpage()  argument
543 BUG_ON(page_offset + length > PAGE_SIZE); in ceph_tcp_recvpage()
547 ret = ceph_tcp_recvmsg(sock, kaddr + page_offset, length); in ceph_tcp_recvpage()
847 size_t *page_offset, in ceph_msg_data_bio_next() argument
861 *page_offset = (size_t) bio_vec.bv_offset; in ceph_msg_data_bio_next()
862 BUG_ON(*page_offset >= PAGE_SIZE); in ceph_msg_data_bio_next()
868 BUG_ON(*page_offset + *length > PAGE_SIZE); in ceph_msg_data_bio_next()
937 cursor->page_offset = data->alignment & ~PAGE_MASK; in ceph_msg_data_pages_cursor_init()
941 BUG_ON(length > SIZE_MAX - cursor->page_offset); in ceph_msg_data_pages_cursor_init()
942 cursor->last_piece = cursor->page_offset + cursor->resid <= PAGE_SIZE; in ceph_msg_data_pages_cursor_init()
947 size_t *page_offset, size_t *length) in ceph_msg_data_pages_next() argument
954 BUG_ON(cursor->page_offset >= PAGE_SIZE); in ceph_msg_data_pages_next()
956 *page_offset = cursor->page_offset; in ceph_msg_data_pages_next()
960 *length = PAGE_SIZE - *page_offset; in ceph_msg_data_pages_next()
970 BUG_ON(cursor->page_offset + bytes > PAGE_SIZE); in ceph_msg_data_pages_advance()
975 cursor->page_offset = (cursor->page_offset + bytes) & ~PAGE_MASK; in ceph_msg_data_pages_advance()
976 if (!bytes || cursor->page_offset) in ceph_msg_data_pages_advance()
1022 size_t *page_offset, size_t *length) in ceph_msg_data_pagelist_next() argument
1036 *page_offset = cursor->offset & ~PAGE_MASK; in ceph_msg_data_pagelist_next()
1040 *length = PAGE_SIZE - *page_offset; in ceph_msg_data_pagelist_next()
1134 size_t *page_offset, size_t *length, in ceph_msg_data_next() argument
1141 page = ceph_msg_data_pagelist_next(cursor, page_offset, length); in ceph_msg_data_next()
1144 page = ceph_msg_data_pages_next(cursor, page_offset, length); in ceph_msg_data_next()
1148 page = ceph_msg_data_bio_next(cursor, page_offset, length); in ceph_msg_data_next()
1157 BUG_ON(*page_offset + *length > PAGE_SIZE); in ceph_msg_data_next()
1528 unsigned int page_offset, in ceph_crc32c_page() argument
1535 crc = crc32c(crc, kaddr + page_offset, length); in ceph_crc32c_page()
1570 size_t page_offset; in write_partial_message_data() local
1576 page = ceph_msg_data_next(&msg->cursor, &page_offset, &length, in write_partial_message_data()
1578 ret = ceph_tcp_sendpage(con->sock, page, page_offset, in write_partial_message_data()
1587 crc = ceph_crc32c_page(crc, page, page_offset, length); in write_partial_message_data()
2253 size_t page_offset; in read_partial_msg_data() local
2265 page = ceph_msg_data_next(&msg->cursor, &page_offset, &length, in read_partial_msg_data()
2267 ret = ceph_tcp_recvpage(con->sock, page, page_offset, length); in read_partial_msg_data()
2276 crc = ceph_crc32c_page(crc, page, page_offset, ret); in read_partial_msg_data()