Lines Matching defs:cursor
162 /* Initialize data cursor if it's not a sparse read */
165 ceph_msg_data_cursor_init(&msg->cursor, msg, len);
468 struct ceph_msg_data_cursor *cursor = &msg->cursor;
486 while (cursor->total_resid) {
492 if (!cursor->resid) {
493 ceph_msg_data_advance(cursor, 0);
497 page = ceph_msg_data_next(cursor, &page_offset, &length);
506 if (do_datacrc && cursor->need_crc)
508 ceph_msg_data_advance(cursor, (size_t)ret);
997 struct ceph_msg_data_cursor *cursor = &con->in_msg->cursor;
1008 while (cursor->sr_resid > 0) {
1013 page = ceph_msg_data_next(cursor, &off, &len);
1017 len = min_t(int, len, cursor->sr_resid);
1022 ceph_msg_data_advance(cursor, (size_t)ret);
1023 cursor->sr_resid -= ret;
1032 struct ceph_msg_data_cursor *cursor = &con->in_msg->cursor;
1040 while (cursor->total_resid) {
1046 else if (cursor->sr_resid > 0)
1052 ret = con->ops->sparse_read(con, cursor,
1069 struct ceph_msg_data_cursor *cursor = &con->in_msg->cursor;
1079 while (cursor->total_resid) {
1080 if (!cursor->resid) {
1081 ceph_msg_data_advance(cursor, 0);
1085 page = ceph_msg_data_next(cursor, &page_offset, &length);
1096 ceph_msg_data_advance(cursor, (size_t)ret);
1106 struct ceph_msg_data_cursor *cursor = &con->in_msg->cursor;
1121 while (cursor->total_resid) {
1122 if (!cursor->resid) {
1123 ceph_msg_data_advance(cursor, 0);
1127 page = ceph_msg_data_next(cursor, &off, &len);
1137 ceph_msg_data_advance(cursor, ret);
1581 con->v1.out_skip += msg->cursor.total_resid;