| /linux/net/strparser/ |
| H A D | strparser.c | 33 offsetof(struct sk_skb_cb, strp)); in _strp_msg()
37 static void strp_abort_strp(struct strparser *strp, int err) in strp_abort_strp() argument
41 cancel_delayed_work(&strp->msg_timer_work); in strp_abort_strp()
43 if (strp->stopped) in strp_abort_strp()
46 strp->stopped = 1; in strp_abort_strp()
48 if (strp->sk) { in strp_abort_strp()
49 struct sock *sk = strp->sk; in strp_abort_strp()
57 static void strp_start_timer(struct strparser *strp, long timeo) in strp_start_timer() argument
60 mod_delayed_work(strp_wq, &strp->msg_timer_work, timeo); in strp_start_timer()
64 static void strp_parser_err(struct strparser *strp, int err, in strp_parser_err() argument
[all …]
|
| /linux/net/tls/ |
| H A D | tls_strp.c | 16 void tls_strp_abort_strp(struct tls_strparser *strp, int err) in tls_strp_abort_strp() argument
18 if (strp->stopped) in tls_strp_abort_strp()
21 strp->stopped = 1; in tls_strp_abort_strp()
24 WRITE_ONCE(strp->sk->sk_err, -err); in tls_strp_abort_strp()
27 sk_error_report(strp->sk); in tls_strp_abort_strp()
30 static void tls_strp_anchor_free(struct tls_strparser *strp) in tls_strp_anchor_free() argument
32 struct skb_shared_info *shinfo = skb_shinfo(strp->anchor); in tls_strp_anchor_free()
35 if (!strp->copy_mode) in tls_strp_anchor_free()
37 consume_skb(strp->anchor); in tls_strp_anchor_free()
38 strp->anchor = NULL; in tls_strp_anchor_free()
[all …]
|
| H A D | tls.h | 145 void tls_strp_abort_strp(struct tls_strparser *strp, int err);
190 void tls_strp_done(struct tls_strparser *strp);
191 void tls_strp_stop(struct tls_strparser *strp);
192 int tls_strp_init(struct tls_strparser *strp, struct sock *sk);
193 void tls_strp_data_ready(struct tls_strparser *strp);
195 void tls_strp_check_rcv(struct tls_strparser *strp);
196 void tls_strp_msg_done(struct tls_strparser *strp);
198 int tls_rx_msg_size(struct tls_strparser *strp, struct sk_buff *skb);
199 void tls_rx_msg_ready(struct tls_strparser *strp);
201 bool tls_strp_msg_load(struct tls_strparser *strp, bool force_refresh);
[all …]
|
| H A D | tls_sw.c | 1375 tls_strp_check_rcv(&ctx->strp); in tls_rx_rec_wait()
1404 if (unlikely(!tls_strp_msg_load(&ctx->strp, released))) in tls_rx_rec_wait()
1656 err = tls_strp_msg_hold(&ctx->strp, &ctx->async_hold); in tls_decrypt_sg()
1858 tls_strp_msg_done(&ctx->strp); in tls_rx_rec_done()
2162 DEBUG_NET_WARN_ON_ONCE(darg.skb == ctx->strp.anchor); in tls_sw_recvmsg()
2441 int tls_rx_msg_size(struct tls_strparser *strp, struct sk_buff *skb) in tls_rx_msg_size() argument
2443 struct tls_context *tls_ctx = tls_get_ctx(strp->sk); in tls_rx_msg_size()
2451 if (strp->stm.offset + prot->prepend_size > skb->len) in tls_rx_msg_size()
2461 ret = skb_copy_bits(skb, strp->stm.offset, header, prot->prepend_size); in tls_rx_msg_size()
2465 strp->mark = header[0]; in tls_rx_msg_size()
[all …]
|
| H A D | tls_main.c | 772 tls_strp_check_rcv(&rx_ctx->strp); in do_tls_setsockopt_conf()
|
| /linux/include/net/ |
| H A D | strparser.h | 44 int (*parse_msg)(struct strparser *strp, struct sk_buff *skb);
45 void (*rcv_msg)(struct strparser *strp, struct sk_buff *skb);
46 int (*read_sock)(struct strparser *strp, read_descriptor_t *desc,
48 int (*read_sock_done)(struct strparser *strp, int err);
49 void (*abort_parser)(struct strparser *strp, int err);
50 void (*lock)(struct strparser *strp);
51 void (*unlock)(struct strparser *strp);
63 struct strp_msg strp; member
70 /* align strp on cache line boundary within skb->cb[] */
72 struct _strp_msg strp; member
110 strp_pause(struct strparser * strp) strp_pause() argument
120 save_strp_stats(struct strparser * strp,struct strp_aggr_stats * agg_stats) save_strp_stats() argument
[all...] |
| H A D | espintcp.h | 22 struct strparser strp; member
|
| H A D | kcm.h | 91 struct strparser strp; member
|
| H A D | tls.h | 139 struct tls_strparser strp; member
|
| H A D | tcp.h | 2720 int tcp_bpf_strp_read_sock(struct strparser *strp, read_descriptor_t *desc,
|
| /linux/tools/testing/selftests/bpf/prog_tests/ |
| H A D | sockmap_strp.c | 49 struct test_sockmap_strp *strp = NULL; in sockmap_strp_init() local
53 strp = test_sockmap_strp__open_and_load(); in sockmap_strp_init()
54 *out_map = bpf_map__fd(strp->maps.sock_map); in sockmap_strp_init()
57 parser = bpf_program__fd(strp->progs.prog_skb_parser_partial); in sockmap_strp_init()
59 parser = bpf_program__fd(strp->progs.prog_skb_parser); in sockmap_strp_init()
62 verdict = bpf_program__fd(strp->progs.prog_skb_verdict_pass); in sockmap_strp_init()
64 verdict = bpf_program__fd(strp->progs.prog_skb_verdict); in sockmap_strp_init()
74 return strp; in sockmap_strp_init()
76 test_sockmap_strp__destroy(strp); in sockmap_strp_init()
95 struct test_sockmap_strp *strp = NULL; in test_sockmap_strp_dispatch_pkt() local
[all …]
|
| /linux/net/xfrm/ |
| H A D | espintcp.c | 54 static void espintcp_rcv(struct strparser *strp, struct sk_buff *skb) in espintcp_rcv() argument
56 struct espintcp_ctx *ctx = container_of(strp, struct espintcp_ctx, in espintcp_rcv()
57 strp); in espintcp_rcv()
69 XFRM_INC_STATS(sock_net(strp->sk), LINUX_MIB_XFRMINHDRERROR); in espintcp_rcv()
82 XFRM_INC_STATS(sock_net(strp->sk), LINUX_MIB_XFRMINHDRERROR); in espintcp_rcv()
90 XFRM_INC_STATS(sock_net(strp->sk), LINUX_MIB_XFRMINHDRERROR); in espintcp_rcv()
97 XFRM_INC_STATS(sock_net(strp->sk), LINUX_MIB_XFRMINERROR); in espintcp_rcv()
103 XFRM_INC_STATS(sock_net(strp->sk), LINUX_MIB_XFRMINERROR); in espintcp_rcv()
109 handle_nonesp(ctx, skb, strp->sk); in espintcp_rcv()
111 handle_esp(skb, strp->sk); in espintcp_rcv()
[all …]
|
| /linux/Documentation/networking/ |
| H A D | strparser.rst | 43 strp_init(struct strparser *strp, struct sock *sk,
46 Called to initialize a stream parser. strp is a struct of type
54 void strp_pause(struct strparser *strp)
61 void strp_unpause(struct strparser *strp)
67 void strp_stop(struct strparser *strp);
76 void strp_done(struct strparser *strp);
84 int strp_process(struct strparser *strp, struct sk_buff *orig_skb,
96 void strp_data_ready(struct strparser *strp);
106 void strp_check_rcv(struct strparser *strp);
119 int (*parse_msg)(struct strparser *strp, struct sk_buff *skb);
[all …]
|
| /linux/net/kcm/ |
| H A D | kcmproc.c | 145 psock->strp.stats.msgs, in kcm_format_psock()
146 psock->strp.stats.bytes, in kcm_format_psock()
160 if (psock->strp.stopped) in kcm_format_psock()
166 if (!psock->strp.paused && !psock->ready_rx_msg) { in kcm_format_psock()
168 if (psock->strp.need_bytes) in kcm_format_psock()
170 psock->strp.need_bytes); in kcm_format_psock()
175 if (psock->strp.paused) in kcm_format_psock()
273 save_strp_stats(&psock->strp, &strp_stats); in kcm_stats_seq_show()
|
| /linux/drivers/net/ovpn/ |
| H A D | tcp.c | 36 static int ovpn_tcp_parse(struct strparser *strp, struct sk_buff *skb) in ovpn_tcp_parse() argument
73 static void ovpn_tcp_rcv(struct strparser *strp, struct sk_buff *skb) in ovpn_tcp_rcv() argument
75 struct ovpn_peer *peer = container_of(strp, struct ovpn_peer, tcp.strp); in ovpn_tcp_rcv()
117 ovpn_tcp_to_userspace(peer, strp->sk, skb); in ovpn_tcp_rcv()
195 strp_stop(&peer->tcp.strp); in ovpn_tcp_socket_detach()
217 strp_done(&peer->tcp.strp); in ovpn_tcp_socket_wait_finish()
446 strp_data_ready(&sock->peer->tcp.strp); in ovpn_tcp_data_ready()
501 ret = strp_init(&peer->tcp.strp, ovpn_sock->sk, &cb); in ovpn_tcp_socket_attach()
536 strp_check_rcv(&peer->tcp.strp); in ovpn_tcp_socket_attach()
|
| /linux/drivers/scsi/aic7xxx/aicasm/ |
| H A D | aicasm_scan.l | 549 const char *strp;
552 strp = next_match + strlen(next_match);
553 while (strp > next_match)
554 unput(*--strp);
|
| /linux/security/apparmor/ |
| H A D | label.c | 1677 int aa_label_asxprint(char **strp, struct aa_ns *ns, struct aa_label *label, in aa_label_asxprint() argument
1682 AA_BUG(!strp); in aa_label_asxprint()
1689 *strp = kmalloc(size + 1, gfp); in aa_label_asxprint()
1690 if (!*strp) in aa_label_asxprint()
1692 return aa_label_snxprint(*strp, size + 1, ns, label, flags); in aa_label_asxprint()
1706 int aa_label_acntsxprint(char __counted **strp, struct aa_ns *ns, in aa_label_acntsxprint() argument
1711 AA_BUG(!strp); in aa_label_acntsxprint()
1718 *strp = aa_str_alloc(size + 1, gfp); in aa_label_acntsxprint()
1719 if (!*strp) in aa_label_acntsxprint()
1721 return aa_label_snxprint(*strp, size + 1, ns, label, flags); in aa_label_acntsxprint()
|
| /linux/tools/perf/util/ |
| H A D | build-id.c | 133 static int asnprintf(char **strp, size_t size, const char *fmt, ...) in asnprintf() argument
138 if (!strp) in asnprintf()
142 if (*strp) in asnprintf()
143 ret = vsnprintf(*strp, size, fmt, ap); in asnprintf()
145 ret = vasprintf(strp, fmt, ap); in asnprintf()
|
| H A D | sort.c | 4192 char *str, *strp; in __setup_output_field() local
4198 strp = str = strdup(field_order); in __setup_output_field()
4205 strp++; in __setup_output_field()
4207 if (!strlen(strp)) { in __setup_output_field()
4212 ret = setup_output_list(&perf_hpp_list, strp); in __setup_output_field()
|
| /linux/security/apparmor/include/ |
| H A D | label.h | 299 int aa_label_asxprint(char **strp, struct aa_ns *ns, struct aa_label *label,
301 int aa_label_acntsxprint(char __counted **strp, struct aa_ns *ns,
|
| /linux/security/selinux/ss/ |
| H A D | policydb.h | 391 extern int str_read(char **strp, gfp_t flags, struct policy_file *fp, u32 len);
|
| H A D | policydb.c | 1103 int str_read(char **strp, gfp_t flags, struct policy_file *fp, u32 len) in str_read() argument
1122 *strp = str; in str_read()
|
| /linux/net/ipv4/ |
| H A D | tcp_bpf.c | 653 int tcp_bpf_strp_read_sock(struct strparser *strp, read_descriptor_t *desc, in tcp_bpf_strp_read_sock() argument
656 struct sock *sk = strp->sk; in tcp_bpf_strp_read_sock()
|
| /linux/drivers/usb/gadget/function/ |
| H A D | f_midi2.c | 2194 const char **strp, size_t maxlen, in f_midi2_opts_str_store() argument
2212 kfree(*strp); in f_midi2_opts_str_store()
2214 *strp = c; in f_midi2_opts_str_store()
|