Lines Matching refs:cursor
165 ceph_msg_data_cursor_init(&msg->cursor, msg, len); in prepare_message_data()
468 struct ceph_msg_data_cursor *cursor = &msg->cursor; in write_partial_message_data() local
486 while (cursor->total_resid) { in write_partial_message_data()
492 if (!cursor->resid) { in write_partial_message_data()
493 ceph_msg_data_advance(cursor, 0); in write_partial_message_data()
497 page = ceph_msg_data_next(cursor, &page_offset, &length); in write_partial_message_data()
506 if (do_datacrc && cursor->need_crc) in write_partial_message_data()
508 ceph_msg_data_advance(cursor, (size_t)ret); in write_partial_message_data()
997 struct ceph_msg_data_cursor *cursor = &con->in_msg->cursor; in read_partial_sparse_msg_extent() local
1008 while (cursor->sr_resid > 0) { in read_partial_sparse_msg_extent()
1013 page = ceph_msg_data_next(cursor, &off, &len); in read_partial_sparse_msg_extent()
1017 len = min_t(int, len, cursor->sr_resid); in read_partial_sparse_msg_extent()
1022 ceph_msg_data_advance(cursor, (size_t)ret); in read_partial_sparse_msg_extent()
1023 cursor->sr_resid -= ret; in read_partial_sparse_msg_extent()
1032 struct ceph_msg_data_cursor *cursor = &con->in_msg->cursor; in read_partial_sparse_msg_data() local
1040 while (cursor->total_resid) { in read_partial_sparse_msg_data()
1046 else if (cursor->sr_resid > 0) in read_partial_sparse_msg_data()
1052 ret = con->ops->sparse_read(con, cursor, in read_partial_sparse_msg_data()
1069 struct ceph_msg_data_cursor *cursor = &con->in_msg->cursor; in read_partial_msg_data() local
1079 while (cursor->total_resid) { in read_partial_msg_data()
1080 if (!cursor->resid) { in read_partial_msg_data()
1081 ceph_msg_data_advance(cursor, 0); in read_partial_msg_data()
1085 page = ceph_msg_data_next(cursor, &page_offset, &length); in read_partial_msg_data()
1096 ceph_msg_data_advance(cursor, (size_t)ret); in read_partial_msg_data()
1106 struct ceph_msg_data_cursor *cursor = &con->in_msg->cursor; in read_partial_msg_data_bounce() local
1121 while (cursor->total_resid) { in read_partial_msg_data_bounce()
1122 if (!cursor->resid) { in read_partial_msg_data_bounce()
1123 ceph_msg_data_advance(cursor, 0); in read_partial_msg_data_bounce()
1127 page = ceph_msg_data_next(cursor, &off, &len); in read_partial_msg_data_bounce()
1137 ceph_msg_data_advance(cursor, ret); in read_partial_msg_data_bounce()
1581 con->v1.out_skip += msg->cursor.total_resid; in ceph_con_v1_revoke()