| /net/ceph/ |
| A D | cls_lock_client.c | 36 void *p, *end; in ceph_cls_lock() local 57 end = p + lock_op_buf_size; in ceph_cls_lock() 101 void *p, *end; in ceph_cls_unlock() local 116 end = p + unlock_op_buf_size; in ceph_cls_unlock() 154 void *p, *end; in ceph_cls_break_lock() local 169 end = p + break_op_buf_size; in ceph_cls_break_lock() 201 void *p, *end; in ceph_cls_set_cookie() local 344 void *p, *end; in ceph_cls_lock_info() local 378 end = p + reply_len; in ceph_cls_lock_info() 397 void *p, *end; in ceph_cls_assert_locked() local [all …]
|
| A D | osdmap.c | 440 dout("crush_decode %p to %p len %d\n", *p, end, (int)(end - *p)); in crush_decode() 645 if (*p != end) { in crush_decode() 654 if (*p != end) { in crush_decode() 1367 ret = decode_pool(p, end, pi); in __decode_pools() 1415 pg = fn(p, end, incremental); 1676 dout("%s %p to %p len %d\n", __func__, *p, end, (int)(end - *p)); in osdmap_decode() 1691 err = decode_pools(p, end, map); in osdmap_decode() 1798 *p = end; in osdmap_decode() 1979 dout("%s %p to %p len %d\n", __func__, *p, end, (int)(end - *p)); in osdmap_apply_incremental() 1999 len, *p, end); in osdmap_apply_incremental() [all …]
|
| A D | decode.c | 10 ceph_decode_entity_addr_versioned(void **p, void *end, in ceph_decode_entity_addr_versioned() argument 30 ceph_decode_32_safe(p, end, addr_len, bad); in ceph_decode_entity_addr_versioned() 50 ceph_decode_entity_addr_legacy(void **p, void *end, in ceph_decode_entity_addr_legacy() argument 56 ceph_decode_skip_n(p, end, 3, bad); in ceph_decode_entity_addr_legacy() 65 ceph_decode_copy_safe(p, end, &addr->in_addr, in ceph_decode_entity_addr_legacy() 79 ceph_decode_8_safe(p, end, marker, bad); in ceph_decode_entity_addr() 81 return ceph_decode_entity_addr_versioned(p, end, addr); in ceph_decode_entity_addr() 83 return ceph_decode_entity_addr_legacy(p, end, addr); in ceph_decode_entity_addr() 107 ceph_decode_8_safe(p, end, marker, e_inval); in ceph_decode_entity_addrvec() 113 ceph_decode_32_safe(p, end, addr_cnt, e_inval); in ceph_decode_entity_addrvec() [all …]
|
| A D | auth.c | 109 if (*p + 2*sizeof(u32) + len > end) in ceph_auth_entity_name_encode() 167 void *end = buf + buf_len; in build_request() local 174 ceph_encode_64_safe(&p, end, 0, e_range); in build_request() 176 ceph_encode_64_safe(&p, end, 0, e_range); in build_request() 203 void *end = buf + len; in ceph_handle_auth_reply() local 214 dout("handle_auth_reply %p %p\n", p, end); in ceph_handle_auth_reply() 226 if (p != end) in ceph_handle_auth_reply() 410 ceph_encode_32_safe(p, end, 2, e_range); in encode_con_modes() 430 void *end = buf + buf_len; in ceph_auth_get_request() local 551 void *end = buf + *buf_len; in ceph_auth_get_authorizer() local [all …]
|
| A D | auth_x.c | 162 void **p, void *end) in process_one_ticket() argument 233 tpend = end; in process_one_ticket() 272 void **p, void *end) in ceph_x_proc_ticket_reply() argument 307 void *p, *end; in encrypt_authorizer() local 333 WARN_ON(p != end); in encrypt_authorizer() 335 WARN_ON(p > end); in encrypt_authorizer() 419 void **p, void *end) in ceph_x_encode_ticket() argument 489 void *buf, void *end) in ceph_x_build_request() argument 514 if (p > end) in ceph_x_build_request() 617 if (*p == end) { in handle_auth_session_key() [all …]
|
| A D | armor.c | 5 int ceph_armor(char *dst, const char *src, const char *end); 6 int ceph_unarmor(char *dst, const char *src, const char *end); 37 int ceph_armor(char *dst, const char *src, const char *end) in ceph_armor() argument 42 while (src < end) { in ceph_armor() 47 if (src < end) { in ceph_armor() 50 if (src < end) { in ceph_armor() 75 int ceph_unarmor(char *dst, const char *src, const char *end) in ceph_unarmor() argument 79 while (src < end) { in ceph_unarmor() 86 if (src + 4 > end) in ceph_unarmor()
|
| A D | auth_none.c | 46 void *const end = p + sizeof(au->buf); in ceph_auth_none_build_authorizer() local 49 ceph_encode_8_safe(&p, end, 1, e_range); in ceph_auth_none_build_authorizer() 50 ret = ceph_auth_entity_name_encode(ac->name, &p, end); in ceph_auth_none_build_authorizer() 54 ceph_encode_64_safe(&p, end, ac->global_id, e_range); in ceph_auth_none_build_authorizer() 63 static int build_request(struct ceph_auth_client *ac, void *buf, void *end) in build_request() argument 73 void *buf, void *end, u8 *session_key, in handle_reply() argument
|
| A D | osd_client.c | 2299 BUG_ON(p > end); in encode_request_finish() 4334 m->end = kzalloc(sizeof(*m->end), GFP_NOIO); in decode_MOSDBackoff() 4335 if (!m->end) { in decode_MOSDBackoff() 4340 ret = decode_hoid(&p, end, m->end); in decode_MOSDBackoff() 4358 void *p, *end; in create_backoff_message() local 4381 encode_hoid(&p, end, backoff->end); in create_backoff_message() 4382 BUG_ON(p != end); in create_backoff_message() 4420 backoff->end = m->end; in handle_backoff_block() 4469 hoid_compare(backoff->end, m->end)) { in handle_backoff_unblock() 5303 void *p, *end; in osd_req_op_copy_from_init() local [all …]
|
| A D | mon_client.c | 82 ceph_decode_32_safe(p, end, blob_len, e_inval); in ceph_monmap_decode() 83 ceph_decode_need(p, end, blob_len, e_inval); in ceph_monmap_decode() 91 ceph_decode_32_safe(p, end, epoch, e_inval); in ceph_monmap_decode() 113 ceph_decode_32_safe(p, end, num_mon, e_inval); in ceph_monmap_decode() 336 void *const end = p + msg->front_alloc_len; in __send_subscribe() local 370 ceph_encode_string(&p, end, buf, len); in __send_subscribe() 375 BUG_ON(p > end); in __send_subscribe() 544 void *p, *end; in ceph_monc_handle_map() local 550 end = p + msg->front.iov_len; in ceph_monc_handle_map() 822 void *end = p + msg->front_alloc_len; in handle_get_version_reply() local [all …]
|
| A D | messenger_v2.c | 916 void *end = buf + buf_len; in init_sgs() local 933 } while (p != end); in init_sgs() 2289 void *p, void *end) in process_auth_bad_method() argument 2453 void *p, void *end) in process_auth_signature() argument 2503 void *p, void *end) in process_server_ident() argument 2609 void *p, void *end) in process_session_reconnect_ok() argument 2638 void *p, void *end) in process_session_retry() argument 2671 void *p, void *end) in process_session_retry_global() argument 2704 void *p, void *end) in process_session_reset() argument 2752 void *p, void *end) in process_keepalive2_ack() argument [all …]
|
| /net/ipv4/ |
| A D | bpf_tcp_ca.c | 66 size_t end; in bpf_tcp_ca_btf_struct_access() local 76 end = offsetofend(struct sock, sk_pacing_rate); in bpf_tcp_ca_btf_struct_access() 79 end = offsetofend(struct sock, sk_pacing_status); in bpf_tcp_ca_btf_struct_access() 85 end = offsetofend(struct inet_connection_sock, in bpf_tcp_ca_btf_struct_access() 89 end = offsetofend(struct tcp_sock, snd_cwnd); in bpf_tcp_ca_btf_struct_access() 92 end = offsetofend(struct tcp_sock, snd_cwnd_cnt); in bpf_tcp_ca_btf_struct_access() 98 end = offsetofend(struct tcp_sock, snd_ssthresh); in bpf_tcp_ca_btf_struct_access() 101 end = offsetofend(struct tcp_sock, ecn_flags); in bpf_tcp_ca_btf_struct_access() 104 end = offsetofend(struct tcp_sock, app_limited); in bpf_tcp_ca_btf_struct_access() 111 if (off + size > end) { in bpf_tcp_ca_btf_struct_access() [all …]
|
| A D | ip_fragment.c | 222 unsigned int start, end; in ip_frag_too_far() local 230 end = atomic_inc_return(&peer->rid); in ip_frag_too_far() 231 qp->rid = end; in ip_frag_too_far() 270 int ihl, end, flags, offset; in ip_frag_queue() local 307 if (end < qp->q.len || in ip_frag_queue() 311 qp->q.len = end; in ip_frag_queue() 313 if (end&7) { in ip_frag_queue() 314 end &= ~7; in ip_frag_queue() 318 if (end > qp->q.len) { in ip_frag_queue() 322 qp->q.len = end; in ip_frag_queue() [all …]
|
| /net/ipv6/ |
| A D | calipso.c | 844 unsigned int *end) in calipso_opt_find() argument 885 *end = opt_len; in calipso_opt_find() 921 end = 0; in calipso_opt_insert() 944 if (end != hop_len) { in calipso_opt_insert() 945 memcpy((char *)new + buf_len, (char *)hop + end, hop_len - end); in calipso_opt_insert() 992 pad = (end - start) & 7; in calipso_opt_del() 994 if (end != hop_len) in calipso_opt_del() 996 hop_len - end); in calipso_opt_del() 1323 unsigned int start, end; in calipso_skbuff_setattr() local 1333 end = 0; in calipso_skbuff_setattr() [all …]
|
| A D | reassembly.c | 112 int offset, end, fragsize; in ip6_frag_queue() local 127 end = offset + (ntohs(ipv6_hdr(skb)->payload_len) - in ip6_frag_queue() 130 if ((unsigned int)end > IPV6_MAXPLEN) { in ip6_frag_queue() 152 if (end < fq->q.len || in ip6_frag_queue() 156 fq->q.len = end; in ip6_frag_queue() 161 if (end & 0x7) { in ip6_frag_queue() 168 if (end > fq->q.len) { in ip6_frag_queue() 172 fq->q.len = end; in ip6_frag_queue() 176 if (end == offset) in ip6_frag_queue() 184 err = pskb_trim_rcsum(skb, end - offset); in ip6_frag_queue() [all …]
|
| /net/netfilter/ |
| A D | nf_conntrack_sip.c | 170 if (end < limit && *end == ']') in sip_parse_addr() 171 end++; in sip_parse_addr() 180 *endp = end; in sip_parse_addr() 270 if (end < limit && *end == ':') { in ct_sip_parse_request() 271 end++; in ct_sip_parse_request() 272 p = simple_strtoul(end, (char **)&end, 10); in ct_sip_parse_request() 557 if (!end) in ct_sip_parse_param() 558 end = limit; in ct_sip_parse_param() 601 char *end; in ct_sip_parse_numerical_param() local 1578 if (end[0] == '\r' && end[1] == '\n' && in sip_help_tcp() [all …]
|
| /net/sctp/ |
| A D | tsnmap.c | 31 __u16 len, __u16 *start, __u16 *end); 154 __u16 *start, __u16 *end) in sctp_tsnmap_next_gap_ack() argument 179 *end = end_ + 1; in sctp_tsnmap_next_gap_ack() 182 iter->start = map->cumulative_tsn_ack_point + *end + 1; in sctp_tsnmap_next_gap_ack() 273 __u16 len, __u16 *start, __u16 *end) in sctp_tsnmap_find_gap_ack() argument 295 *end = i - 1; in sctp_tsnmap_find_gap_ack() 325 __u16 start = 0, end = 0; in sctp_tsnmap_num_gabs() local 329 &end)) { in sctp_tsnmap_num_gabs() 332 gabs[ngaps].end = htons(end); in sctp_tsnmap_num_gabs()
|
| /net/mac80211/ |
| A D | wbrf.c | 29 static void get_chan_freq_boundary(u32 center_freq, u32 bandwidth, u64 *start, u64 *end) in get_chan_freq_boundary() argument 35 *end = center_freq + bandwidth / 2; in get_chan_freq_boundary() 39 *end = *end * HZ_PER_KHZ; in get_chan_freq_boundary() 54 ranges_in->band_list[0].end = end_freq1; in get_ranges_from_chandef() 61 ranges_in->band_list[1].end = end_freq2; in get_ranges_from_chandef()
|
| /net/sunrpc/auth_gss/ |
| A D | auth_gss_internal.h | 16 simple_get_bytes(const void *p, const void *end, void *res, size_t len) in simple_get_bytes() argument 19 if (unlikely(q > end || q < p)) in simple_get_bytes() 26 simple_get_netobj_noprof(const void *p, const void *end, struct xdr_netobj *dest) in simple_get_netobj_noprof() argument 31 p = simple_get_bytes(p, end, &len, sizeof(len)); in simple_get_netobj_noprof() 35 if (unlikely(q > end || q < p)) in simple_get_netobj_noprof()
|
| /net/sched/ |
| A D | bpf_qdisc.c | 56 int off, size_t *end) in bpf_qdisc_qdisc_access() argument 60 *end = offsetofend(struct Qdisc, limit); in bpf_qdisc_qdisc_access() 66 *end = offsetofend(struct Qdisc, qstats); in bpf_qdisc_qdisc_access() 77 int off, size_t *end) in bpf_qdisc_sk_buff_access() argument 81 *end = offsetofend(struct sk_buff, tstamp); in bpf_qdisc_sk_buff_access() 86 *end = offsetof(struct sk_buff, cb) + in bpf_qdisc_sk_buff_access() 101 size_t end; in bpf_qdisc_btf_struct_access() local 109 err = bpf_qdisc_sk_buff_access(log, reg, off, &end); in bpf_qdisc_btf_struct_access() 111 err = bpf_qdisc_qdisc_access(log, reg, off, &end); in bpf_qdisc_btf_struct_access() 123 if (off + size > end) { in bpf_qdisc_btf_struct_access() [all …]
|
| /net/core/ |
| A D | skmsg.c | 52 i = msg->sg.end; in sk_msg_alloc() 70 sk_msg_iter_next(msg, end); in sk_msg_alloc() 110 if (dst->sg.end) in sk_msg_clone() 173 } while (i != msg->sg.end); in sk_msg_return() 266 u32 i = msg->sg.end; in sk_msg_trim() 291 msg->sg.end = i; in sk_msg_trim() 382 if (i == msg->sg.end) in sk_msg_memcopy_from_iter() 564 msg->sg.end = num_sge; in sk_psock_skb_ingress_enqueue() 707 goto end; in sk_psock_backlog() 712 goto end; in sk_psock_backlog() [all …]
|
| A D | datagram.c | 416 int end; in __skb_datagram_iter() local 422 if ((copy = end - offset) > 0) { in __skb_datagram_iter() 446 start = end; in __skb_datagram_iter() 450 int end; in __skb_datagram_iter() local 454 end = start + frag_iter->len; in __skb_datagram_iter() 465 start = end; in __skb_datagram_iter() 570 int end; in skb_copy_datagram_from_iter() local 591 start = end; in skb_copy_datagram_from_iter() 595 int end; in skb_copy_datagram_from_iter() local 599 end = start + frag_iter->len; in skb_copy_datagram_from_iter() [all …]
|
| /net/ipv6/netfilter/ |
| A D | nf_conntrack_reasm.c | 177 int offset, end, err; in nf_ct_frag6_queue() local 188 end = offset + (payload_len - in nf_ct_frag6_queue() 191 if ((unsigned int)end > IPV6_MAXPLEN) { in nf_ct_frag6_queue() 210 if (end < fq->q.len || in nf_ct_frag6_queue() 216 fq->q.len = end; in nf_ct_frag6_queue() 221 if (end & 0x7) { in nf_ct_frag6_queue() 229 if (end > fq->q.len) { in nf_ct_frag6_queue() 235 fq->q.len = end; in nf_ct_frag6_queue() 239 if (end == offset) in nf_ct_frag6_queue() 247 if (pskb_trim_rcsum(skb, end - offset)) { in nf_ct_frag6_queue() [all …]
|
| /net/netfilter/ipvs/ |
| A D | ip_vs_ftp.c | 100 __u16 af, char **start, char **end) in ip_vs_ftp_get_addrport() argument 161 *end = data; in ip_vs_ftp_get_addrport() 229 *end = s; in ip_vs_ftp_get_addrport() 253 char *start, *end; in ip_vs_ftp_out() local 285 &start, &end) != 1) in ip_vs_ftp_out() 306 &start, &end) != 1) in ip_vs_ftp_out() 377 end - start, in ip_vs_ftp_out() 423 char *start, *end; in ip_vs_ftp_in() local 497 &start, &end) == 1) { in ip_vs_ftp_in() 511 &start, &end) == 1) { in ip_vs_ftp_in()
|
| /net/rose/ |
| A D | rose_out.c | 49 unsigned short start, end; in rose_kick() local 61 end = (rose->va + sysctl_rose_window_size) % ROSE_MODULUS; in rose_kick() 63 if (start == end) in rose_kick() 95 } while (rose->vs != end && in rose_kick()
|
| /net/ieee802154/6lowpan/ |
| A D | reassembly.c | 92 int end, offset, err; in lowpan_frag_queue() local 104 end = lowpan_802154_cb(skb)->d_size; in lowpan_frag_queue() 107 if (offset + skb->len == end) { in lowpan_frag_queue() 111 if (end < fq->q.len || in lowpan_frag_queue() 112 ((fq->q.flags & INET_FRAG_LAST_IN) && end != fq->q.len)) in lowpan_frag_queue() 115 fq->q.len = end; in lowpan_frag_queue() 117 if (end > fq->q.len) { in lowpan_frag_queue() 121 fq->q.len = end; in lowpan_frag_queue() 131 err = inet_frag_queue_insert(&fq->q, skb, offset, end); in lowpan_frag_queue()
|