Home
last modified time | relevance | path

Searched refs:sp (Results 1 – 25 of 59) sorted by relevance

123

/net/rxrpc/
A Dio_thread.c93 trace_rxrpc_abort(0, why, sp->hdr.cid, sp->hdr.callNumber, sp->hdr.seq, in rxrpc_direct_abort()
108 trace_rxrpc_abort(0, why, sp->hdr.cid, 0, sp->hdr.seq, abort_code, err); in rxrpc_direct_conn_abort()
153 memset(sp, 0, sizeof(*sp)); in rxrpc_extract_header()
206 sp = rxrpc_skb(skb); in rxrpc_input_packet()
222 switch (sp->hdr.type) { in rxrpc_input_packet()
245 if (sp->hdr.seq == 0) in rxrpc_input_packet()
263 sp = rxrpc_skb(skb); in rxrpc_input_packet()
367 sp->hdr.serviceId); in rxrpc_input_packet_on_conn()
411 sp->hdr.seq, in rxrpc_input_packet_on_conn()
412 sp->hdr.serial, in rxrpc_input_packet_on_conn()
[all …]
A Doob.c37 struct rxrpc_skb_priv *sp = rxrpc_skb(skb); in rxrpc_notify_socket_oob() local
178 struct rxrpc_skb_priv *sp; in rxrpc_respond_to_oob() local
189 sp = rxrpc_skb(skb); in rxrpc_respond_to_oob()
196 conn = sp->chall.conn; in rxrpc_respond_to_oob()
269 struct rxrpc_skb_priv *sp = rxrpc_skb(oob); in rxrpc_kernel_query_oob() local
274 *_peer = sp->chall.conn->peer; in rxrpc_kernel_query_oob()
320 struct rxrpc_skb_priv *sp = rxrpc_skb(oob); in rxrpc_kernel_free_oob() local
349 *_peer = sp->chall.conn->peer; in rxrpc_kernel_query_challenge()
350 *_peer_appdata = sp->chall.conn->peer->app_data; in rxrpc_kernel_query_challenge()
351 *_service_id = sp->hdr.serviceId; in rxrpc_kernel_query_challenge()
[all …]
A Dinput.c455 trace_rxrpc_receive(call, last ? why + 1 : why, sp->hdr.serial, sp->hdr.seq); in rxrpc_input_queue_data()
479 rxrpc_seq_t seq = sp->hdr.seq; in rxrpc_input_data_one()
593 sp->hdr.serial, sp->hdr.seq); in rxrpc_input_data_one()
644 sp->hdr.flags = jhdr.flags; in rxrpc_input_split_jumbo()
646 sp->hdr.seq++; in rxrpc_input_split_jumbo()
647 sp->hdr.serial++; in rxrpc_input_split_jumbo()
653 sp->offset = offset; in rxrpc_input_split_jumbo()
654 sp->len = len; in rxrpc_input_split_jumbo()
1070 prev_pkt = sp->ack.prev_ack; in rxrpc_input_ack()
1071 nr_acks = sp->ack.nr_acks; in rxrpc_input_ack()
[all …]
A Dconn_event.c58 cid = sp->hdr.cid; in rxrpc_abort_conn()
59 call = sp->hdr.callNumber; in rxrpc_abort_conn()
60 seq = sp->hdr.seq; in rxrpc_abort_conn()
107 if (sp && sp->hdr.type == RXRPC_PACKET_TYPE_ACK) { in rxrpc_conn_retransmit_call()
255 _enter("{%d},{%u,%%%u},", conn->debug_id, sp->hdr.type, sp->hdr.serial); in rxrpc_process_event()
257 switch (sp->hdr.type) { in rxrpc_process_event()
260 sp->chall.conn = NULL; in rxrpc_process_event()
284 sp->poke_conn = rxrpc_get_connection( in rxrpc_process_event()
419 sp->chall.conn = in rxrpc_post_challenge()
448 sp->chall.conn = NULL; in rxrpc_post_challenge()
[all …]
A Dconn_service.c26 struct rxrpc_skb_priv *sp = rxrpc_skb(skb); in rxrpc_find_service_conn_rcu() local
30 k.epoch = sp->hdr.epoch; in rxrpc_find_service_conn_rcu()
31 k.cid = sp->hdr.cid & RXRPC_CIDMASK; in rxrpc_find_service_conn_rcu()
153 struct rxrpc_skb_priv *sp = rxrpc_skb(skb); in rxrpc_new_incoming_connection() local
157 conn->proto.epoch = sp->hdr.epoch; in rxrpc_new_incoming_connection()
158 conn->proto.cid = sp->hdr.cid & RXRPC_CIDMASK; in rxrpc_new_incoming_connection()
159 conn->orig_service_id = sp->hdr.serviceId; in rxrpc_new_incoming_connection()
160 conn->service_id = sp->hdr.serviceId; in rxrpc_new_incoming_connection()
161 conn->security_ix = sp->hdr.securityIndex; in rxrpc_new_incoming_connection()
173 if (sp->hdr.userStatus == RXRPC_USERSTATUS_SERVICE_UPGRADE && in rxrpc_new_incoming_connection()
A Dsecurity.c137 struct rxrpc_skb_priv *sp = rxrpc_skb(skb); in rxrpc_get_incoming_security() local
141 sec = rxrpc_security_lookup(sp->hdr.securityIndex); in rxrpc_get_incoming_security()
148 if (sp->hdr.securityIndex != RXRPC_SECURITY_NONE && in rxrpc_get_incoming_security()
165 struct rxrpc_skb_priv *sp = rxrpc_skb(skb); in rxrpc_look_up_server_security() local
176 sp->hdr.serviceId, sp->hdr.securityIndex, kvno, enctype); in rxrpc_look_up_server_security()
179 sp->hdr.serviceId, sp->hdr.securityIndex, kvno); in rxrpc_look_up_server_security()
182 sp->hdr.serviceId, sp->hdr.securityIndex); in rxrpc_look_up_server_security()
A Drecvmsg.c112 struct rxrpc_skb_priv *sp; in rxrpc_rotate_rx_window() local
124 sp = rxrpc_skb(skb); in rxrpc_rotate_rx_window()
125 tseq = sp->hdr.seq; in rxrpc_rotate_rx_window()
126 serial = sp->hdr.serial; in rxrpc_rotate_rx_window()
247 struct rxrpc_skb_priv *sp; in rxrpc_recvmsg_data() local
276 sp = rxrpc_skb(skb); in rxrpc_recvmsg_data()
277 seq = sp->hdr.seq; in rxrpc_recvmsg_data()
281 sp->hdr.serial, seq); in rxrpc_recvmsg_data()
289 sp->offset, sp->len, ret2); in rxrpc_recvmsg_data()
294 rx_pkt_offset = sp->offset; in rxrpc_recvmsg_data()
[all …]
A Drxkad.c438 if (sp->len < 8) in rxkad_verify_packet_1()
463 sp->offset += sizeof(sechdr); in rxkad_verify_packet_1()
464 sp->len -= sizeof(sechdr); in rxkad_verify_packet_1()
475 if (data_size > sp->len) in rxkad_verify_packet_1()
478 sp->len = data_size; in rxkad_verify_packet_1()
500 _enter(",{%d}", sp->len); in rxkad_verify_packet_2()
502 if (sp->len < 8) in rxkad_verify_packet_2()
520 ret = skb_to_sgvec(skb, sg, sp->offset, sp->len); in rxkad_verify_packet_2()
543 sp->offset += sizeof(sechdr); in rxkad_verify_packet_2()
556 if (data_size > sp->len) in rxkad_verify_packet_2()
[all …]
A Dlocal_event.c38 struct rxrpc_skb_priv *sp = rxrpc_skb(skb); in rxrpc_send_version_request() local
56 whdr.epoch = htonl(sp->hdr.epoch); in rxrpc_send_version_request()
57 whdr.cid = htonl(sp->hdr.cid); in rxrpc_send_version_request()
58 whdr.callNumber = htonl(sp->hdr.callNumber); in rxrpc_send_version_request()
66 whdr.serviceId = htons(sp->hdr.serviceId); in rxrpc_send_version_request()
A Drxgk.c476 unsigned int offset = sp->offset, len = sp->len; in rxgk_verify_packet_integrity()
493 hdr->seq = htonl(sp->hdr.seq); in rxgk_verify_packet_integrity()
506 sp->offset = offset; in rxgk_verify_packet_integrity()
507 sp->len = len; in rxgk_verify_packet_integrity()
525 unsigned int offset = sp->offset, len = sp->len; in rxgk_verify_packet_encrypted()
564 sp->offset = offset; in rxgk_verify_packet_encrypted()
565 sp->len = ntohl(hdr.data_len); in rxgk_verify_packet_encrypted()
581 u16 key_number = sp->hdr.cksum; in rxgk_verify_packet()
736 return sp->chall.conn->rxgk.enctype; in rxgk_kernel_query_challenge()
1212 trace_rxrpc_rx_response(conn, sp->hdr.serial, 0, sp->hdr.cksum, token_len); in rxgk_verify_response()
[all …]
A Dcall_accept.c342 struct rxrpc_skb_priv *sp = rxrpc_skb(skb); in rxrpc_new_incoming_call() local
349 if (sp->hdr.type != RXRPC_PACKET_TYPE_DATA) in rxrpc_new_incoming_call()
359 if (!rx || (sp->hdr.serviceId != rx->srx.srx_service && in rxrpc_new_incoming_call()
360 sp->hdr.serviceId != rx->second_service) in rxrpc_new_incoming_call()
362 if (sp->hdr.type == RXRPC_PACKET_TYPE_DATA && in rxrpc_new_incoming_call()
363 sp->hdr.seq == 1) in rxrpc_new_incoming_call()
390 sp->hdr.serial, sp->hdr.seq); in rxrpc_new_incoming_call()
/net/l2tp/
A Dl2tp_ppp.c919 len = sizeof(sp); in pppol2tp_getname()
920 memset(&sp, 0, len); in pppol2tp_getname()
921 sp.sa_family = AF_PPPOX; in pppol2tp_getname()
932 memcpy(uaddr, &sp, len); in pppol2tp_getname()
937 len = sizeof(sp); in pppol2tp_getname()
938 memset(&sp, 0, len); in pppol2tp_getname()
939 sp.sa_family = AF_PPPOX; in pppol2tp_getname()
955 len = sizeof(sp); in pppol2tp_getname()
956 memset(&sp, 0, len); in pppol2tp_getname()
974 len = sizeof(sp); in pppol2tp_getname()
[all …]
/net/sctp/
A Dsocket.c401 if (!sp->pf->bind_verify(sp, addr)) in sctp_do_bind()
574 sp = sctp_sk(sk); in sctp_send_asconf_add_ip()
575 ep = sp->ep; in sctp_send_asconf_add_ip()
777 sp = sctp_sk(sk); in sctp_send_asconf_del_ip()
778 ep = sp->ep; in sctp_send_asconf_del_ip()
3323 sp = sctp_sk(sk); in sctp_setsockopt_peer_primary_addr()
4866 sp = sctp_sk(sk); in sctp_accept()
4867 ep = sp->ep; in sctp_accept()
5079 if (!sp->ep) in sctp_init_sock()
5082 sp->hmac = NULL; in sctp_init_sock()
[all …]
A Dassociola.c57 struct sctp_sock *sp; in sctp_association_init() local
62 sp = sctp_sk((struct sock *)sk); in sctp_association_init()
83 asoc->user_frag = sp->user_frag; in sctp_association_init()
108 asoc->flowlabel = sp->flowlabel; in sctp_association_init()
109 asoc->dscp = sp->dscp; in sctp_association_init()
113 asoc->sackfreq = sp->sackfreq; in sctp_association_init()
123 asoc->max_burst = sp->max_burst; in sctp_association_init()
125 asoc->subscribe = sp->subscribe; in sctp_association_init()
236 asoc->pathmtu = sp->pathmtu; in sctp_association_init()
589 struct sctp_sock *sp; in sctp_assoc_add_peer() local
[all …]
A Dulpqueue.c167 atomic_inc(&sp->pd_mode); in sctp_ulpq_set_pd()
224 queue = &sp->pd_lobby; in sctp_ulpq_tail_event()
235 if (sp->frag_interleave) in sctp_ulpq_tail_event()
238 queue = &sp->pd_lobby; in sctp_ulpq_tail_event()
253 sp->data_ready_signalled = 1; in sctp_ulpq_tail_event()
1024 struct sctp_sock *sp; in sctp_ulpq_partial_delivery() local
1029 sp = sctp_sk(asoc->base.sk); in sctp_ulpq_partial_delivery()
1052 if (sp->frag_interleave || atomic_read(&sp->pd_mode) == 0) { in sctp_ulpq_partial_delivery()
1105 struct sctp_sock *sp; in sctp_ulpq_abort_pd() local
1112 sp = sctp_sk(sk); in sctp_ulpq_abort_pd()
[all …]
A Dbind_addr.c334 int sctp_bind_addrs_check(struct sctp_sock *sp, in sctp_bind_addrs_check() argument
338 struct sctp_bind_addr *bp = &sp->ep->base.bind_addr; in sctp_bind_addrs_check()
346 if (sp->pf->af->cmp_addr(&laddr->a, &laddr2->a) && in sctp_bind_addrs_check()
372 struct sctp_sock *sp; in sctp_bind_addr_conflict() local
379 sp = bp_sp; in sctp_bind_addr_conflict()
381 sp = addr_sp; in sctp_bind_addr_conflict()
383 sp = bp_sp; in sctp_bind_addr_conflict()
390 conflict = sp->pf->cmp_addr(&laddr->a, addr, sp); in sctp_bind_addr_conflict()
A Dipv6.c681 static int sctp_v6_available(union sctp_addr *addr, struct sctp_sock *sp) in sctp_v6_available() argument
684 struct sock *sk = &sp->inet.sk; in sctp_v6_available()
693 if (sp && ipv6_only_sock(sctp_opt2sk(sp))) in sctp_v6_available()
696 return sctp_get_af_specific(AF_INET)->available(addr, sp); in sctp_v6_available()
710 res = ipv6_can_nonlocal_bind(net, &sp->inet) || in sctp_v6_available()
726 struct sctp_sock *sp, in sctp_v6_addr_valid() argument
736 if (sp && ipv6_only_sock(sctp_opt2sk(sp))) in sctp_v6_addr_valid()
739 return sctp_get_af_specific(AF_INET)->addr_valid(addr, sp, skb); in sctp_v6_addr_valid()
829 static int sctp_v6_addr_to_user(struct sctp_sock *sp, union sctp_addr *addr) in sctp_v6_addr_to_user() argument
831 if (sp->v4mapped) { in sctp_v6_addr_to_user()
[all …]
/net/xfrm/
A Dxfrm_input.c125 if (!sp) in secpath_set()
129 return sp; in secpath_set()
132 memset(sp->ovec, 0, sizeof(sp->ovec)); in secpath_set()
133 sp->olen = 0; in secpath_set()
134 sp->len = 0; in secpath_set()
137 return sp; in secpath_set()
564 if (!sp) { in xfrm_input()
606 sp->xvec[sp->len++] = x; in xfrm_input()
730 if (sp) in xfrm_input()
731 sp->olen = 0; in xfrm_input()
[all …]
/net/ipv6/
A Desp6_offload.c75 struct sec_path *sp = secpath_set(skb); in esp6_gro_receive() local
77 if (!sp) in esp6_gro_receive()
80 if (sp->len == XFRM_MAX_DEPTH) in esp6_gro_receive()
98 sp->xvec[sp->len++] = x; in esp6_gro_receive()
99 sp->olen++; in esp6_gro_receive()
252 struct sec_path *sp; in esp6_gso_segment() local
260 sp = skb_sec_path(skb); in esp6_gso_segment()
261 x = sp->xvec[sp->len - 1]; in esp6_gso_segment()
A Dxfrm6_input.c240 struct sec_path *sp; in xfrm6_input_addr() local
243 sp = secpath_set(skb); in xfrm6_input_addr()
244 if (!sp) { in xfrm6_input_addr()
249 if (1 + sp->len == XFRM_MAX_DEPTH) { in xfrm6_input_addr()
308 sp->xvec[sp->len++] = x; in xfrm6_input_addr()
/net/ipv4/
A Desp4_offload.c48 struct sec_path *sp = secpath_set(skb); in esp4_gro_receive() local
50 if (!sp) in esp4_gro_receive()
53 if (sp->len == XFRM_MAX_DEPTH) in esp4_gro_receive()
71 sp->xvec[sp->len++] = x; in esp4_gro_receive()
72 sp->olen++; in esp4_gro_receive()
212 struct sec_path *sp; in esp4_gso_segment() local
220 sp = skb_sec_path(skb); in esp4_gso_segment()
221 x = sp->xvec[sp->len - 1]; in esp4_gso_segment()
A Dtcp_input.c1923 if (after(sp[j].start_seq, sp[j + 1].start_seq)) { in tcp_sacktag_write_queue()
1924 swap(sp[j], sp[j + 1]); in tcp_sacktag_write_queue()
4543 if (!after(seq, sp->end_seq) && !after(sp->start_seq, end_seq)) { in tcp_sack_extend()
4545 sp->start_seq = seq; in tcp_sack_extend()
4649 sp[i] = sp[i + 1]; in tcp_sack_maybe_coalesce()
4700 swap(*sp, *(sp - 1)); in tcp_sack_new_ofo_skb()
4719 sp--; in tcp_sack_new_ofo_skb()
4722 *sp = *(sp - 1); in tcp_sack_new_ofo_skb()
4726 sp->start_seq = seq; in tcp_sack_new_ofo_skb()
4727 sp->end_seq = end_seq; in tcp_sack_new_ofo_skb()
[all …]
/net/bridge/netfilter/
A Debt_stp.c123 const struct stp_header *sp; in ebt_stp_mt() local
127 sp = skb_header_pointer(skb, 0, sizeof(_stph), &_stph); in ebt_stp_mt()
128 if (sp == NULL) in ebt_stp_mt()
132 if (memcmp(sp, header, sizeof(header))) in ebt_stp_mt()
136 NF_INVF(info, EBT_STP_TYPE, info->type != sp->type)) in ebt_stp_mt()
139 if (sp->type == BPDU_TYPE_CONFIG && in ebt_stp_mt()
/net/netfilter/
A Dxt_policy.c56 const struct sec_path *sp = skb_sec_path(skb); in match_policy_in() local
60 if (sp == NULL) in match_policy_in()
62 if (strict && info->len != sp->len) in match_policy_in()
65 for (i = sp->len - 1; i >= 0; i--) { in match_policy_in()
66 pos = strict ? i - sp->len + 1 : 0; in match_policy_in()
71 if (match_xfrm_state(sp->xvec[i], e, family)) { in match_policy_in()
/net/sched/
A Dsch_htb.c827 sp->root = hprio->row.rb_node; in htb_lookup_leaf()
828 sp->pptr = &hprio->ptr; in htb_lookup_leaf()
832 if (!*sp->pptr && *sp->pid) { in htb_lookup_leaf()
836 *sp->pptr = in htb_lookup_leaf()
837 htb_id_find_next_upper(prio, sp->root, *sp->pid); in htb_lookup_leaf()
843 *sp->pptr = sp->root; in htb_lookup_leaf()
845 *sp->pptr = (*sp->pptr)->rb_left; in htb_lookup_leaf()
846 if (sp > stk) { in htb_lookup_leaf()
847 sp--; in htb_lookup_leaf()
848 if (!*sp->pptr) { in htb_lookup_leaf()
[all …]

Completed in 3161 milliseconds

123