Lines Matching refs:resid
860 while (!cursor->resid) in get_bvec_at()
3124 static void prepare_zero_front(struct ceph_connection *con, int resid) in prepare_zero_front() argument
3128 WARN_ON(!resid || resid > front_len(con->out_msg)); in prepare_zero_front()
3129 sent = front_len(con->out_msg) - resid; in prepare_zero_front()
3130 dout("%s con %p sent %d resid %d\n", __func__, con, sent, resid); in prepare_zero_front()
3136 crc32c_zeros(con->v2.out_epil.front_crc, resid); in prepare_zero_front()
3138 con->v2.out_epil.front_crc = crc32c_zeros(-1, resid); in prepare_zero_front()
3141 con->v2.out_iter.count -= resid; in prepare_zero_front()
3142 out_zero_add(con, resid); in prepare_zero_front()
3145 static void prepare_zero_middle(struct ceph_connection *con, int resid) in prepare_zero_middle() argument
3149 WARN_ON(!resid || resid > middle_len(con->out_msg)); in prepare_zero_middle()
3150 sent = middle_len(con->out_msg) - resid; in prepare_zero_middle()
3151 dout("%s con %p sent %d resid %d\n", __func__, con, sent, resid); in prepare_zero_middle()
3157 crc32c_zeros(con->v2.out_epil.middle_crc, resid); in prepare_zero_middle()
3159 con->v2.out_epil.middle_crc = crc32c_zeros(-1, resid); in prepare_zero_middle()
3162 con->v2.out_iter.count -= resid; in prepare_zero_middle()
3163 out_zero_add(con, resid); in prepare_zero_middle()
3176 int resid; in revoke_at_queue_data() local
3180 resid = iov_iter_count(&con->v2.out_iter); in revoke_at_queue_data()
3183 if (resid > boundary) { in revoke_at_queue_data()
3184 resid -= boundary; in revoke_at_queue_data()
3185 WARN_ON(resid > MESSAGE_HEAD_PLAIN_LEN); in revoke_at_queue_data()
3192 WARN_ON(iov_iter_count(&con->v2.out_iter) != resid); in revoke_at_queue_data()
3198 if (resid > boundary) { in revoke_at_queue_data()
3199 resid -= boundary; in revoke_at_queue_data()
3201 prepare_zero_front(con, resid); in revoke_at_queue_data()
3209 WARN_ON(!resid); in revoke_at_queue_data()
3211 prepare_zero_middle(con, resid); in revoke_at_queue_data()
3218 int sent, resid; /* current piece of data */ in revoke_at_queue_data_cont() local
3222 resid = iov_iter_count(&con->v2.out_iter); in revoke_at_queue_data_cont()
3223 WARN_ON(!resid || resid > con->v2.out_bvec.bv_len); in revoke_at_queue_data_cont()
3224 sent = con->v2.out_bvec.bv_len - resid; in revoke_at_queue_data_cont()
3225 dout("%s con %p sent %d resid %d\n", __func__, con, sent, resid); in revoke_at_queue_data_cont()
3233 WARN_ON(resid > con->v2.out_cursor.total_resid); in revoke_at_queue_data_cont()
3237 con->v2.out_iter.count -= resid; in revoke_at_queue_data_cont()
3245 int resid; in revoke_at_finish_message() local
3248 resid = iov_iter_count(&con->v2.out_iter); in revoke_at_finish_message()
3252 WARN_ON(!resid || resid > MESSAGE_HEAD_PLAIN_LEN); in revoke_at_finish_message()
3260 if (resid > boundary) { in revoke_at_finish_message()
3261 resid -= boundary; in revoke_at_finish_message()
3262 WARN_ON(resid > MESSAGE_HEAD_PLAIN_LEN); in revoke_at_finish_message()
3269 WARN_ON(iov_iter_count(&con->v2.out_iter) != resid); in revoke_at_finish_message()
3275 if (resid > boundary) { in revoke_at_finish_message()
3276 resid -= boundary; in revoke_at_finish_message()
3278 prepare_zero_front(con, resid); in revoke_at_finish_message()
3287 if (resid > boundary) { in revoke_at_finish_message()
3288 resid -= boundary; in revoke_at_finish_message()
3290 prepare_zero_middle(con, resid); in revoke_at_finish_message()
3296 WARN_ON(!resid); in revoke_at_finish_message()
3330 int resid; in revoke_at_prepare_read_data() local
3334 resid = iov_iter_count(&con->v2.in_iter); in revoke_at_prepare_read_data()
3335 WARN_ON(!resid); in revoke_at_prepare_read_data()
3343 dout("%s con %p resid %d remaining %d\n", __func__, con, resid, in revoke_at_prepare_read_data()
3345 con->v2.in_iter.count -= resid; in revoke_at_prepare_read_data()
3346 set_in_skip(con, resid + remaining); in revoke_at_prepare_read_data()
3352 int recved, resid; /* current piece of data */ in revoke_at_prepare_read_data_cont() local
3357 resid = iov_iter_count(&con->v2.in_iter); in revoke_at_prepare_read_data_cont()
3358 WARN_ON(!resid || resid > con->v2.in_bvec.bv_len); in revoke_at_prepare_read_data_cont()
3359 recved = con->v2.in_bvec.bv_len - resid; in revoke_at_prepare_read_data_cont()
3360 dout("%s con %p recved %d resid %d\n", __func__, con, recved, resid); in revoke_at_prepare_read_data_cont()
3364 WARN_ON(resid > con->v2.in_cursor.total_resid); in revoke_at_prepare_read_data_cont()
3374 con->v2.in_iter.count -= resid; in revoke_at_prepare_read_data_cont()
3381 int resid; in revoke_at_handle_epilogue() local
3384 resid = iov_iter_count(&con->v2.in_iter); in revoke_at_handle_epilogue()
3385 WARN_ON(!resid); in revoke_at_handle_epilogue()
3387 dout("%s con %p resid %d\n", __func__, con, resid); in revoke_at_handle_epilogue()
3388 con->v2.in_iter.count -= resid; in revoke_at_handle_epilogue()
3389 set_in_skip(con, resid); in revoke_at_handle_epilogue()