Lines Matching refs:end
922 void *end = buf + buf_len; in init_sgs() local
934 len = min_t(int, end - p, PAGE_SIZE); in init_sgs()
939 } while (p != end); in init_sgs()
1844 void *end = con->v2.in_kvecs[0].iov_base + con->v2.in_kvecs[0].iov_len; in process_banner_payload() local
1852 ceph_decode_64_safe(&p, end, server_feat, bad); in process_banner_payload()
1853 ceph_decode_64_safe(&p, end, server_req_feat, bad); in process_banner_payload()
1887 static int process_hello(struct ceph_connection *con, void *p, void *end) in process_hello() argument
1899 ceph_decode_8_safe(&p, end, entity_type, bad); in process_hello()
1900 ret = ceph_decode_entity_addr(&p, end, &addr_for_me); in process_hello()
1955 void *p, void *end) in process_auth_bad_method() argument
1968 ceph_decode_32_safe(&p, end, used_proto, bad); in process_auth_bad_method()
1969 ceph_decode_32_safe(&p, end, result, bad); in process_auth_bad_method()
1973 ceph_decode_32_safe(&p, end, allowed_proto_cnt, bad); in process_auth_bad_method()
1979 ceph_decode_32_safe(&p, end, allowed_protos[i], bad); in process_auth_bad_method()
1984 ceph_decode_32_safe(&p, end, allowed_mode_cnt, bad); in process_auth_bad_method()
1990 ceph_decode_32_safe(&p, end, allowed_modes[i], bad); in process_auth_bad_method()
2017 void *p, void *end) in process_auth_reply_more() argument
2027 ceph_decode_32_safe(&p, end, payload_len, bad); in process_auth_reply_more()
2028 ceph_decode_need(&p, end, payload_len, bad); in process_auth_reply_more()
2053 static int process_auth_done(struct ceph_connection *con, void *p, void *end) in process_auth_done() argument
2069 ceph_decode_64_safe(&p, end, global_id, bad); in process_auth_done()
2070 ceph_decode_32_safe(&p, end, con->v2.con_mode, bad); in process_auth_done()
2071 ceph_decode_32_safe(&p, end, payload_len, bad); in process_auth_done()
2119 void *p, void *end) in process_auth_signature() argument
2134 ceph_decode_need(&p, end, SHA256_DIGEST_SIZE, bad); in process_auth_signature()
2169 void *p, void *end) in process_server_ident() argument
2185 ret = ceph_decode_entity_addrvec(&p, end, true, &addr); in process_server_ident()
2191 ceph_decode_64_safe(&p, end, global_id, bad); in process_server_ident()
2192 ceph_decode_64_safe(&p, end, global_seq, bad); in process_server_ident()
2193 ceph_decode_64_safe(&p, end, features, bad); in process_server_ident()
2194 ceph_decode_64_safe(&p, end, required_features, bad); in process_server_ident()
2195 ceph_decode_64_safe(&p, end, flags, bad); in process_server_ident()
2196 ceph_decode_64_safe(&p, end, cookie, bad); in process_server_ident()
2253 void *p, void *end) in process_ident_missing_features() argument
2263 ceph_decode_64_safe(&p, end, missing_features, bad); in process_ident_missing_features()
2275 void *p, void *end) in process_session_reconnect_ok() argument
2284 ceph_decode_64_safe(&p, end, seq, bad); in process_session_reconnect_ok()
2304 void *p, void *end) in process_session_retry() argument
2314 ceph_decode_64_safe(&p, end, connect_seq, bad); in process_session_retry()
2337 void *p, void *end) in process_session_retry_global() argument
2347 ceph_decode_64_safe(&p, end, global_seq, bad); in process_session_retry_global()
2370 void *p, void *end) in process_session_reset() argument
2380 ceph_decode_8_safe(&p, end, full, bad); in process_session_reset()
2418 void *p, void *end) in process_keepalive2_ack() argument
2425 ceph_decode_need(&p, end, sizeof(struct ceph_timespec), bad); in process_keepalive2_ack()
2438 static int process_ack(struct ceph_connection *con, void *p, void *end) in process_ack() argument
2447 ceph_decode_64_safe(&p, end, seq, bad); in process_ack()
2458 static int process_control(struct ceph_connection *con, void *p, void *end) in process_control() argument
2463 dout("%s con %p tag %d len %d\n", __func__, con, tag, (int)(end - p)); in process_control()
2467 ret = process_hello(con, p, end); in process_control()
2470 ret = process_auth_bad_method(con, p, end); in process_control()
2473 ret = process_auth_reply_more(con, p, end); in process_control()
2476 ret = process_auth_done(con, p, end); in process_control()
2479 ret = process_auth_signature(con, p, end); in process_control()
2482 ret = process_server_ident(con, p, end); in process_control()
2485 ret = process_ident_missing_features(con, p, end); in process_control()
2488 ret = process_session_reconnect_ok(con, p, end); in process_control()
2491 ret = process_session_retry(con, p, end); in process_control()
2494 ret = process_session_retry_global(con, p, end); in process_control()
2497 ret = process_session_reset(con, p, end); in process_control()
2500 ret = process_keepalive2_ack(con, p, end); in process_control()
2503 ret = process_ack(con, p, end); in process_control()
2526 void *p, void *end) in process_message_header() argument
2587 void *end = p + con->v2.in_desc.fd_lens[0]; in __handle_control() local
2592 return process_control(con, p, end); in __handle_control()
2594 ret = process_message_header(con, p, end); in __handle_control()