Lines Matching refs:page_offset
539 int page_offset, size_t length) in ceph_tcp_recvpage() argument
544 BUG_ON(page_offset + length > PAGE_SIZE); in ceph_tcp_recvpage()
548 ret = ceph_tcp_recvmsg(sock, kaddr + page_offset, length); in ceph_tcp_recvpage()
844 size_t *page_offset, in ceph_msg_data_bio_next() argument
858 *page_offset = (size_t) bio_vec.bv_offset; in ceph_msg_data_bio_next()
859 BUG_ON(*page_offset >= PAGE_SIZE); in ceph_msg_data_bio_next()
865 BUG_ON(*page_offset + *length > PAGE_SIZE); in ceph_msg_data_bio_next()
934 cursor->page_offset = data->alignment & ~PAGE_MASK; in ceph_msg_data_pages_cursor_init()
938 BUG_ON(length > SIZE_MAX - cursor->page_offset); in ceph_msg_data_pages_cursor_init()
939 cursor->last_piece = cursor->page_offset + cursor->resid <= PAGE_SIZE; in ceph_msg_data_pages_cursor_init()
944 size_t *page_offset, size_t *length) in ceph_msg_data_pages_next() argument
951 BUG_ON(cursor->page_offset >= PAGE_SIZE); in ceph_msg_data_pages_next()
953 *page_offset = cursor->page_offset; in ceph_msg_data_pages_next()
957 *length = PAGE_SIZE - *page_offset; in ceph_msg_data_pages_next()
967 BUG_ON(cursor->page_offset + bytes > PAGE_SIZE); in ceph_msg_data_pages_advance()
972 cursor->page_offset = (cursor->page_offset + bytes) & ~PAGE_MASK; in ceph_msg_data_pages_advance()
973 if (!bytes || cursor->page_offset) in ceph_msg_data_pages_advance()
1019 size_t *page_offset, size_t *length) in ceph_msg_data_pagelist_next() argument
1033 *page_offset = cursor->offset & ~PAGE_MASK; in ceph_msg_data_pagelist_next()
1037 *length = PAGE_SIZE - *page_offset; in ceph_msg_data_pagelist_next()
1131 size_t *page_offset, size_t *length, in ceph_msg_data_next() argument
1138 page = ceph_msg_data_pagelist_next(cursor, page_offset, length); in ceph_msg_data_next()
1141 page = ceph_msg_data_pages_next(cursor, page_offset, length); in ceph_msg_data_next()
1145 page = ceph_msg_data_bio_next(cursor, page_offset, length); in ceph_msg_data_next()
1154 BUG_ON(*page_offset + *length > PAGE_SIZE); in ceph_msg_data_next()
1535 unsigned int page_offset, in ceph_crc32c_page() argument
1542 crc = crc32c(crc, kaddr + page_offset, length); in ceph_crc32c_page()
1577 size_t page_offset; in write_partial_message_data() local
1583 page = ceph_msg_data_next(cursor, &page_offset, &length, in write_partial_message_data()
1585 ret = ceph_tcp_sendpage(con->sock, page, page_offset, in write_partial_message_data()
1594 crc = ceph_crc32c_page(crc, page, page_offset, length); in write_partial_message_data()
2266 size_t page_offset; in read_partial_msg_data() local
2278 page = ceph_msg_data_next(cursor, &page_offset, &length, NULL); in read_partial_msg_data()
2279 ret = ceph_tcp_recvpage(con->sock, page, page_offset, length); in read_partial_msg_data()
2288 crc = ceph_crc32c_page(crc, page, page_offset, ret); in read_partial_msg_data()