Home
last modified time | relevance | path

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

123

/net/rxrpc/
Dinput.c346 struct rxrpc_skb_priv *sp = rxrpc_skb(skb); in rxrpc_validate_data() local
349 u8 flags = sp->hdr.flags; in rxrpc_validate_data()
353 __set_bit(sp->nr_subpackets, sp->rx_req_ack); in rxrpc_validate_data()
354 sp->nr_subpackets++; in rxrpc_validate_data()
370 sp->rx_flags |= RXRPC_SKB_INCL_LAST; in rxrpc_validate_data()
413 struct rxrpc_skb_priv *sp = rxrpc_skb(skb); in rxrpc_input_data() local
416 rxrpc_serial_t serial = sp->hdr.serial, ack_serial = serial; in rxrpc_input_data()
417 rxrpc_seq_t seq0 = sp->hdr.seq, hard_ack; in rxrpc_input_data()
425 sp->hdr.serial, seq0, sp->hdr.flags, sp->nr_subpackets); in rxrpc_input_data()
458 nr_subpackets = sp->nr_subpackets; in rxrpc_input_data()
[all …]
Dsecurity.c111 struct rxrpc_skb_priv *sp = rxrpc_skb(skb); in rxrpc_get_incoming_security() local
115 sec = rxrpc_security_lookup(sp->hdr.securityIndex); in rxrpc_get_incoming_security()
118 sp->hdr.cid, sp->hdr.callNumber, sp->hdr.seq, in rxrpc_get_incoming_security()
125 if (sp->hdr.securityIndex != RXRPC_SECURITY_NONE && in rxrpc_get_incoming_security()
128 sp->hdr.cid, sp->hdr.callNumber, sp->hdr.seq, in rxrpc_get_incoming_security()
145 struct rxrpc_skb_priv *sp = rxrpc_skb(skb); in rxrpc_look_up_server_security() local
156 sp->hdr.serviceId, sp->hdr.securityIndex, kvno, enctype); in rxrpc_look_up_server_security()
159 sp->hdr.serviceId, sp->hdr.securityIndex, kvno); in rxrpc_look_up_server_security()
162 sp->hdr.serviceId, sp->hdr.securityIndex); in rxrpc_look_up_server_security()
Dlocal_event.c29 struct rxrpc_skb_priv *sp = rxrpc_skb(skb); in rxrpc_send_version_request() local
47 whdr.epoch = htonl(sp->hdr.epoch); in rxrpc_send_version_request()
48 whdr.cid = htonl(sp->hdr.cid); in rxrpc_send_version_request()
49 whdr.callNumber = htonl(sp->hdr.callNumber); in rxrpc_send_version_request()
57 whdr.serviceId = htons(sp->hdr.serviceId); in rxrpc_send_version_request()
91 struct rxrpc_skb_priv *sp = rxrpc_skb(skb); in rxrpc_process_local_events() local
94 _debug("{%d},{%u}", local->debug_id, sp->hdr.type); in rxrpc_process_local_events()
96 switch (sp->hdr.type) { in rxrpc_process_local_events()
103 rxrpc_send_version_request(local, &sp->hdr, skb); in rxrpc_process_local_events()
Dconn_service.c32 struct rxrpc_skb_priv *sp = rxrpc_skb(skb); in rxrpc_find_service_conn_rcu() local
36 k.epoch = sp->hdr.epoch; in rxrpc_find_service_conn_rcu()
37 k.cid = sp->hdr.cid & RXRPC_CIDMASK; in rxrpc_find_service_conn_rcu()
162 struct rxrpc_skb_priv *sp = rxrpc_skb(skb); in rxrpc_new_incoming_connection() local
166 conn->proto.epoch = sp->hdr.epoch; in rxrpc_new_incoming_connection()
167 conn->proto.cid = sp->hdr.cid & RXRPC_CIDMASK; in rxrpc_new_incoming_connection()
168 conn->params.service_id = sp->hdr.serviceId; in rxrpc_new_incoming_connection()
169 conn->service_id = sp->hdr.serviceId; in rxrpc_new_incoming_connection()
170 conn->security_ix = sp->hdr.securityIndex; in rxrpc_new_incoming_connection()
182 if (sp->hdr.userStatus == RXRPC_USERSTATUS_SERVICE_UPGRADE && in rxrpc_new_incoming_connection()
Doutput.c355 struct rxrpc_skb_priv *sp = rxrpc_skb(skb); in rxrpc_send_data_packet() local
376 whdr.seq = htonl(sp->hdr.seq); in rxrpc_send_data_packet()
379 whdr.flags = sp->hdr.flags; in rxrpc_send_data_packet()
382 whdr._rsvd = htons(sp->hdr._rsvd); in rxrpc_send_data_packet()
386 sp->hdr.seq == 1) in rxrpc_send_data_packet()
408 if ((!(sp->hdr.flags & RXRPC_LAST_PACKET) || in rxrpc_send_data_packet()
409 rxrpc_to_server(sp) in rxrpc_send_data_packet()
414 (call->peer->rtt_count < 3 && sp->hdr.seq & 1) || in rxrpc_send_data_packet()
423 trace_rxrpc_tx_data(call, sp->hdr.seq, serial, in rxrpc_send_data_packet()
429 trace_rxrpc_tx_data(call, sp->hdr.seq, serial, whdr.flags, retrans, in rxrpc_send_data_packet()
[all …]
Dsendmsg.c195 struct rxrpc_skb_priv *sp = rxrpc_skb(skb); in rxrpc_queue_packet() local
197 rxrpc_seq_t seq = sp->hdr.seq; in rxrpc_queue_packet()
293 struct rxrpc_skb_priv *sp; in rxrpc_send_data() local
363 sp = rxrpc_skb(skb); in rxrpc_send_data()
364 sp->rx_flags |= RXRPC_SKB_TX_BUFFER; in rxrpc_send_data()
373 sp->remain = chunk; in rxrpc_send_data()
374 if (sp->remain > skb_tailroom(skb)) in rxrpc_send_data()
375 sp->remain = skb_tailroom(skb); in rxrpc_send_data()
381 sp->remain); in rxrpc_send_data()
387 sp = rxrpc_skb(skb); in rxrpc_send_data()
[all …]
Dconn_event.c26 struct rxrpc_skb_priv *sp = skb ? rxrpc_skb(skb) : NULL; in rxrpc_conn_retransmit_call() local
44 if (sp && sp->hdr.type == RXRPC_PACKET_TYPE_ACK) { in rxrpc_conn_retransmit_call()
60 if (skb && call_id != sp->hdr.callNumber) in rxrpc_conn_retransmit_call()
103 pkt.ack.serial = htonl(skb ? sp->hdr.serial : 0); in rxrpc_conn_retransmit_call()
295 struct rxrpc_skb_priv *sp = rxrpc_skb(skb); in rxrpc_process_event() local
305 _enter("{%d},{%u,%%%u},", conn->debug_id, sp->hdr.type, sp->hdr.serial); in rxrpc_process_event()
307 switch (sp->hdr.type) { in rxrpc_process_event()
311 sp->hdr.cid & RXRPC_CHANNELMASK); in rxrpc_process_event()
321 trace_rxrpc_rx_eproto(NULL, sp->hdr.serial, in rxrpc_process_event()
326 _proto("Rx ABORT %%%u { ac=%d }", sp->hdr.serial, abort_code); in rxrpc_process_event()
[all …]
Drecvmsg.c224 struct rxrpc_skb_priv *sp; in rxrpc_rotate_rx_window() local
242 sp = rxrpc_skb(skb); in rxrpc_rotate_rx_window()
245 serial = sp->hdr.serial + subpacket; in rxrpc_rotate_rx_window()
247 if (subpacket == sp->nr_subpackets - 1 && in rxrpc_rotate_rx_window()
248 sp->rx_flags & RXRPC_SKB_INCL_LAST) in rxrpc_rotate_rx_window()
282 struct rxrpc_skb_priv *sp = rxrpc_skb(skb); in rxrpc_verify_packet() local
283 rxrpc_seq_t seq = sp->hdr.seq; in rxrpc_verify_packet()
284 u16 cksum = sp->hdr.cksum; in rxrpc_verify_packet()
319 struct rxrpc_skb_priv *sp = rxrpc_skb(skb); in rxrpc_locate_data() local
330 if (subpacket < sp->nr_subpackets - 1) in rxrpc_locate_data()
[all …]
Dinsecure.c54 struct rxrpc_skb_priv *sp = rxrpc_skb(skb); in none_respond_to_challenge() local
56 trace_rxrpc_rx_eproto(NULL, sp->hdr.serial, in none_respond_to_challenge()
65 struct rxrpc_skb_priv *sp = rxrpc_skb(skb); in none_verify_response() local
67 trace_rxrpc_rx_eproto(NULL, sp->hdr.serial, in none_verify_response()
Drxkad.c265 struct rxrpc_skb_priv *sp = rxrpc_skb(skb); in rxkad_secure_packet_auth() local
274 check = sp->hdr.seq ^ call->call_id; in rxkad_secure_packet_auth()
310 struct rxrpc_skb_priv *sp; in rxkad_secure_packet_encrypt() local
318 sp = rxrpc_skb(skb); in rxkad_secure_packet_encrypt()
322 check = sp->hdr.seq ^ call->call_id; in rxkad_secure_packet_encrypt()
373 struct rxrpc_skb_priv *sp; in rxkad_secure_packet() local
380 sp = rxrpc_skb(skb); in rxkad_secure_packet()
384 sp->hdr.seq, data_size); in rxkad_secure_packet()
402 x |= sp->hdr.seq & 0x3fffffff; in rxkad_secure_packet()
417 sp->hdr.cksum = y; in rxkad_secure_packet()
[all …]
Dcall_accept.c246 struct rxrpc_skb_priv *sp = rxrpc_skb(skb); in rxrpc_send_ping() local
251 rxrpc_propose_ACK(call, RXRPC_ACK_PING, sp->hdr.serial, in rxrpc_send_ping()
351 struct rxrpc_skb_priv *sp = rxrpc_skb(skb); in rxrpc_new_incoming_call() local
362 trace_rxrpc_abort(0, "CLS", sp->hdr.cid, sp->hdr.callNumber, in rxrpc_new_incoming_call()
363 sp->hdr.seq, RX_INVALID_OPERATION, ESHUTDOWN); in rxrpc_new_incoming_call()
389 sp->hdr.serial, sp->hdr.seq); in rxrpc_new_incoming_call()
418 rxrpc_abort_call("CON", call, sp->hdr.seq, in rxrpc_new_incoming_call()
/net/l2tp/
Dl2tp_ppp.c929 struct sockaddr_pppol2tp sp; in pppol2tp_getname() local
931 len = sizeof(sp); in pppol2tp_getname()
932 memset(&sp, 0, len); in pppol2tp_getname()
933 sp.sa_family = AF_PPPOX; in pppol2tp_getname()
934 sp.sa_protocol = PX_PROTO_OL2TP; in pppol2tp_getname()
935 sp.pppol2tp.fd = tunnel->fd; in pppol2tp_getname()
936 sp.pppol2tp.pid = pls->owner; in pppol2tp_getname()
937 sp.pppol2tp.s_tunnel = tunnel->tunnel_id; in pppol2tp_getname()
938 sp.pppol2tp.d_tunnel = tunnel->peer_tunnel_id; in pppol2tp_getname()
939 sp.pppol2tp.s_session = session->session_id; in pppol2tp_getname()
[all …]
/net/sctp/
Dsocket.c361 static void sctp_auto_asconf_init(struct sctp_sock *sp) in sctp_auto_asconf_init() argument
363 struct net *net = sock_net(&sp->inet.sk); in sctp_auto_asconf_init()
367 list_add_tail(&sp->auto_asconf_list, &net->sctp.auto_asconf_splist); in sctp_auto_asconf_init()
369 sp->do_auto_asconf = 1; in sctp_auto_asconf_init()
377 struct sctp_sock *sp = sctp_sk(sk); in sctp_do_bind() local
378 struct sctp_endpoint *ep = sp->ep; in sctp_do_bind()
385 af = sctp_sockaddr_af(sp, addr, len); in sctp_do_bind()
398 if (!sp->pf->bind_verify(sp, addr)) in sctp_do_bind()
422 if (sctp_bind_addr_match(bp, addr, sp)) in sctp_do_bind()
436 sctp_auto_asconf_init(sp); in sctp_do_bind()
[all …]
Dassociola.c57 struct sctp_sock *sp; in sctp_association_init() local
62 sp = sctp_sk((struct sock *)sk); in sctp_association_init()
82 asoc->cookie_life = ms_to_ktime(sp->assocparams.sasoc_cookie_life); in sctp_association_init()
83 asoc->user_frag = sp->user_frag; in sctp_association_init()
88 asoc->max_retrans = sp->assocparams.sasoc_asocmaxrxt; in sctp_association_init()
89 asoc->pf_retrans = sp->pf_retrans; in sctp_association_init()
90 asoc->ps_retrans = sp->ps_retrans; in sctp_association_init()
91 asoc->pf_expose = sp->pf_expose; in sctp_association_init()
93 asoc->rto_initial = msecs_to_jiffies(sp->rtoinfo.srto_initial); in sctp_association_init()
94 asoc->rto_max = msecs_to_jiffies(sp->rtoinfo.srto_max); in sctp_association_init()
[all …]
Dulpqueue.c130 struct sctp_sock *sp = sctp_sk(sk); in sctp_clear_pd() local
132 if (atomic_dec_and_test(&sp->pd_mode)) { in sctp_clear_pd()
136 if (!skb_queue_empty(&sp->pd_lobby)) { in sctp_clear_pd()
137 skb_queue_splice_tail_init(&sp->pd_lobby, in sctp_clear_pd()
147 if (!skb_queue_empty(&sp->pd_lobby) && asoc) { in sctp_clear_pd()
151 sctp_skb_for_each(skb, &sp->pd_lobby, tmp) { in sctp_clear_pd()
154 __skb_unlink(skb, &sp->pd_lobby); in sctp_clear_pd()
168 struct sctp_sock *sp = sctp_sk(ulpq->asoc->base.sk); in sctp_ulpq_set_pd() local
170 atomic_inc(&sp->pd_mode); in sctp_ulpq_set_pd()
185 struct sctp_sock *sp = sctp_sk(sk); in sctp_ulpq_tail_event() local
[all …]
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()
Dipv6.c681 static int sctp_v6_available(union sctp_addr *addr, struct sctp_sock *sp) in sctp_v6_available() argument
684 struct net *net = sock_net(&sp->inet.sk); in sctp_v6_available()
691 if (sp && ipv6_only_sock(sctp_opt2sk(sp))) in sctp_v6_available()
694 return sctp_get_af_specific(AF_INET)->available(addr, sp); in sctp_v6_available()
699 return ipv6_can_nonlocal_bind(net, &sp->inet) || in sctp_v6_available()
711 struct sctp_sock *sp, in sctp_v6_addr_valid() argument
721 if (sp && ipv6_only_sock(sctp_opt2sk(sp))) in sctp_v6_addr_valid()
724 return sctp_get_af_specific(AF_INET)->addr_valid(addr, sp, skb); in sctp_v6_addr_valid()
816 static int sctp_v6_addr_to_user(struct sctp_sock *sp, union sctp_addr *addr) in sctp_v6_addr_to_user() argument
818 if (sp->v4mapped) { in sctp_v6_addr_to_user()
[all …]
/net/xfrm/
Dxfrm_input.c121 struct sec_path *sp, *tmp = skb_ext_find(skb, SKB_EXT_SEC_PATH); in secpath_set() local
123 sp = skb_ext_add(skb, SKB_EXT_SEC_PATH); in secpath_set()
124 if (!sp) in secpath_set()
128 return sp; in secpath_set()
131 memset(sp->ovec, 0, sizeof(sp->ovec)); in secpath_set()
132 sp->olen = 0; in secpath_set()
133 sp->len = 0; in secpath_set()
134 sp->verified_cnt = 0; in secpath_set()
136 return sp; in secpath_set()
463 struct sec_path *sp; in xfrm_input() local
[all …]
/net/dccp/
Dfeat.c258 if (val == NULL || (type == FEAT_SP && val->sp.vec == NULL)) in dccp_feat_printval()
261 for (i = 0; i < val->sp.len; i++) in dccp_feat_printval()
262 dccp_pr_debug_cat("%s%u", i ? " " : "", val->sp.vec[i]); in dccp_feat_printval()
272 dccp_feat_val fval = { .sp.vec = list, .sp.len = len }; in dccp_feat_printvals()
319 if (fval->sp.vec == NULL) { in __dccp_feat_activate()
328 val = fval->sp.vec[0]; in __dccp_feat_activate()
369 fval->sp.len = len; in dccp_feat_clone_sp_val()
370 if (fval->sp.len > 0) { in dccp_feat_clone_sp_val()
371 fval->sp.vec = kmemdup(val, len, gfp_any()); in dccp_feat_clone_sp_val()
372 if (fval->sp.vec == NULL) { in dccp_feat_clone_sp_val()
[all …]
/net/ipv4/
Desp4_offload.c46 struct sec_path *sp = secpath_set(skb); in esp4_gro_receive() local
48 if (!sp) in esp4_gro_receive()
51 if (sp->len == XFRM_MAX_DEPTH) in esp4_gro_receive()
62 sp->xvec[sp->len++] = x; in esp4_gro_receive()
63 sp->olen++; in esp4_gro_receive()
200 struct sec_path *sp; in esp4_gso_segment() local
208 sp = skb_sec_path(skb); in esp4_gso_segment()
209 x = sp->xvec[sp->len - 1]; in esp4_gso_segment()
/net/ipv6/
Desp6_offload.c69 struct sec_path *sp = secpath_set(skb); in esp6_gro_receive() local
71 if (!sp) in esp6_gro_receive()
74 if (sp->len == XFRM_MAX_DEPTH) in esp6_gro_receive()
85 sp->xvec[sp->len++] = x; in esp6_gro_receive()
86 sp->olen++; in esp6_gro_receive()
239 struct sec_path *sp; in esp6_gso_segment() local
247 sp = skb_sec_path(skb); in esp6_gso_segment()
248 x = sp->xvec[sp->len - 1]; in esp6_gso_segment()
Dxfrm6_input.c183 struct sec_path *sp; in xfrm6_input_addr() local
186 sp = secpath_set(skb); in xfrm6_input_addr()
187 if (!sp) { in xfrm6_input_addr()
192 if (1 + sp->len == XFRM_MAX_DEPTH) { in xfrm6_input_addr()
244 sp->xvec[sp->len++] = x; in xfrm6_input_addr()
/net/bridge/netfilter/
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/
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/
Dsch_htb.c818 } stk[TC_HTB_MAXDEPTH], *sp = stk; in htb_lookup_leaf() local
821 sp->root = hprio->row.rb_node; in htb_lookup_leaf()
822 sp->pptr = &hprio->ptr; in htb_lookup_leaf()
823 sp->pid = &hprio->last_ptr_id; in htb_lookup_leaf()
826 if (!*sp->pptr && *sp->pid) { in htb_lookup_leaf()
830 *sp->pptr = in htb_lookup_leaf()
831 htb_id_find_next_upper(prio, sp->root, *sp->pid); in htb_lookup_leaf()
833 *sp->pid = 0; /* ptr is valid now so that remove this hint as it in htb_lookup_leaf()
836 if (!*sp->pptr) { /* we are at right end; rewind & go up */ in htb_lookup_leaf()
837 *sp->pptr = sp->root; in htb_lookup_leaf()
[all …]

123