Lines Matching refs:end
916 void *end = buf + buf_len; in init_sgs() local
928 len = min_t(int, end - p, PAGE_SIZE); in init_sgs()
933 } while (p != end); in init_sgs()
2178 void *end = con->v2.in_kvecs[0].iov_base + con->v2.in_kvecs[0].iov_len; in process_banner_payload() local
2186 ceph_decode_64_safe(&p, end, server_feat, bad); in process_banner_payload()
2187 ceph_decode_64_safe(&p, end, server_req_feat, bad); in process_banner_payload()
2221 static int process_hello(struct ceph_connection *con, void *p, void *end) in process_hello() argument
2233 ceph_decode_8_safe(&p, end, entity_type, bad); in process_hello()
2234 ret = ceph_decode_entity_addr(&p, end, &addr_for_me); in process_hello()
2289 void *p, void *end) in process_auth_bad_method() argument
2302 ceph_decode_32_safe(&p, end, used_proto, bad); in process_auth_bad_method()
2303 ceph_decode_32_safe(&p, end, result, bad); in process_auth_bad_method()
2307 ceph_decode_32_safe(&p, end, allowed_proto_cnt, bad); in process_auth_bad_method()
2313 ceph_decode_32_safe(&p, end, allowed_protos[i], bad); in process_auth_bad_method()
2318 ceph_decode_32_safe(&p, end, allowed_mode_cnt, bad); in process_auth_bad_method()
2324 ceph_decode_32_safe(&p, end, allowed_modes[i], bad); in process_auth_bad_method()
2351 void *p, void *end) in process_auth_reply_more() argument
2361 ceph_decode_32_safe(&p, end, payload_len, bad); in process_auth_reply_more()
2362 ceph_decode_need(&p, end, payload_len, bad); in process_auth_reply_more()
2387 static int process_auth_done(struct ceph_connection *con, void *p, void *end) in process_auth_done() argument
2403 ceph_decode_64_safe(&p, end, global_id, bad); in process_auth_done()
2404 ceph_decode_32_safe(&p, end, con->v2.con_mode, bad); in process_auth_done()
2405 ceph_decode_32_safe(&p, end, payload_len, bad); in process_auth_done()
2453 void *p, void *end) in process_auth_signature() argument
2468 ceph_decode_need(&p, end, SHA256_DIGEST_SIZE, bad); in process_auth_signature()
2503 void *p, void *end) in process_server_ident() argument
2519 ret = ceph_decode_entity_addrvec(&p, end, true, &addr); in process_server_ident()
2525 ceph_decode_64_safe(&p, end, global_id, bad); in process_server_ident()
2526 ceph_decode_64_safe(&p, end, global_seq, bad); in process_server_ident()
2527 ceph_decode_64_safe(&p, end, features, bad); in process_server_ident()
2528 ceph_decode_64_safe(&p, end, required_features, bad); in process_server_ident()
2529 ceph_decode_64_safe(&p, end, flags, bad); in process_server_ident()
2530 ceph_decode_64_safe(&p, end, cookie, bad); in process_server_ident()
2587 void *p, void *end) in process_ident_missing_features() argument
2597 ceph_decode_64_safe(&p, end, missing_features, bad); in process_ident_missing_features()
2609 void *p, void *end) in process_session_reconnect_ok() argument
2618 ceph_decode_64_safe(&p, end, seq, bad); in process_session_reconnect_ok()
2638 void *p, void *end) in process_session_retry() argument
2648 ceph_decode_64_safe(&p, end, connect_seq, bad); in process_session_retry()
2671 void *p, void *end) in process_session_retry_global() argument
2681 ceph_decode_64_safe(&p, end, global_seq, bad); in process_session_retry_global()
2704 void *p, void *end) in process_session_reset() argument
2714 ceph_decode_8_safe(&p, end, full, bad); in process_session_reset()
2752 void *p, void *end) in process_keepalive2_ack() argument
2759 ceph_decode_need(&p, end, sizeof(struct ceph_timespec), bad); in process_keepalive2_ack()
2772 static int process_ack(struct ceph_connection *con, void *p, void *end) in process_ack() argument
2781 ceph_decode_64_safe(&p, end, seq, bad); in process_ack()
2792 static int process_control(struct ceph_connection *con, void *p, void *end) in process_control() argument
2797 dout("%s con %p tag %d len %d\n", __func__, con, tag, (int)(end - p)); in process_control()
2801 ret = process_hello(con, p, end); in process_control()
2804 ret = process_auth_bad_method(con, p, end); in process_control()
2807 ret = process_auth_reply_more(con, p, end); in process_control()
2810 ret = process_auth_done(con, p, end); in process_control()
2813 ret = process_auth_signature(con, p, end); in process_control()
2816 ret = process_server_ident(con, p, end); in process_control()
2819 ret = process_ident_missing_features(con, p, end); in process_control()
2822 ret = process_session_reconnect_ok(con, p, end); in process_control()
2825 ret = process_session_retry(con, p, end); in process_control()
2828 ret = process_session_retry_global(con, p, end); in process_control()
2831 ret = process_session_reset(con, p, end); in process_control()
2834 ret = process_keepalive2_ack(con, p, end); in process_control()
2837 ret = process_ack(con, p, end); in process_control()
2860 void *p, void *end) in process_message_header() argument
2921 void *end = p + con->v2.in_desc.fd_lens[0]; in __handle_control() local
2926 return process_control(con, p, end); in __handle_control()
2928 ret = process_message_header(con, p, end); in __handle_control()