Home
last modified time | relevance | path

Searched refs:strp (Results 1 – 25 of 26) sorted by relevance

12

/linux/net/strparser/
H A Dstrparser.c33 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->skb_head) { in strp_abort_strp()
49 kfree_skb(strp->skb_head); in strp_abort_strp()
50 strp->skb_head = NULL; in strp_abort_strp()
53 strp->skb_nextp = NULL; in strp_abort_strp()
54 strp in strp_abort_strp()
57 strp_start_timer(struct strparser * strp,long timeo) strp_start_timer() argument
64 strp_parser_err(struct strparser * strp,int err,read_descriptor_t * desc) strp_parser_err() argument
73 strp_peek_len(struct strparser * strp) strp_peek_len() argument
93 struct strparser *strp = (struct strparser *)desc->arg.data; __strp_recv() local
317 strp_process(struct strparser * strp,struct sk_buff * orig_skb,unsigned int orig_offset,size_t orig_len,size_t max_msg_size,long timeo) strp_process() argument
333 struct strparser *strp = (struct strparser *)desc->arg.data; strp_recv() local
339 default_read_sock_done(struct strparser * strp,int err) default_read_sock_done() argument
345 strp_read_sock(struct strparser * strp) strp_read_sock() argument
372 strp_data_ready(struct strparser * strp) strp_data_ready() argument
399 do_strp_work(struct strparser * strp) do_strp_work() argument
426 struct strparser *strp = container_of(w, struct strparser, strp_msg_timeout() local
436 strp_sock_lock(struct strparser * strp) strp_sock_lock() argument
441 strp_sock_unlock(struct strparser * strp) strp_sock_unlock() argument
446 strp_init(struct strparser * strp,struct sock * sk,const struct strp_callbacks * cb) strp_init() argument
488 strp_unpause(struct strparser * strp) strp_unpause() argument
502 strp_done(struct strparser * strp) strp_done() argument
516 strp_stop(struct strparser * strp) strp_stop() argument
522 strp_check_rcv(struct strparser * strp) strp_check_rcv() argument
[all...]
/linux/net/tls/
H A Dtls_strp.c16 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 Dtls.h145 void tls_strp_abort_strp(struct tls_strparser *strp, int err);
190 void tls_strp_done(struct tls_strparser *strp);
191 void __tls_strp_done(struct tls_strparser *strp);
192 void tls_strp_stop(struct tls_strparser *strp);
193 int tls_strp_init(struct tls_strparser *strp, struct sock *sk);
194 void tls_strp_data_ready(struct tls_strparser *strp);
196 void tls_strp_check_rcv(struct tls_strparser *strp, bool announce);
197 void tls_strp_msg_consume(struct tls_strparser *strp);
199 int tls_rx_msg_size(struct tls_strparser *strp, struct sk_buff *skb);
200 void tls_rx_msg_maybe_announce(struct tls_strparser *strp);
[all...]
H A Dtls_sw.c1125 tls_strp_check_rcv(&ctx->strp, false); in tls_rx_rec_wait()
1162 if (unlikely(!tls_strp_msg_load(&ctx->strp, released))) in tls_rx_rec_wait()
1414 err = tls_strp_msg_hold(&ctx->strp, &ctx->async_hold); in tls_decrypt_sg()
1626 tls_strp_msg_consume(&ctx->strp); in tls_rx_rec_done()
1627 tls_strp_check_rcv(&ctx->strp, false); in tls_rx_rec_done()
1786 tls_rx_msg_maybe_announce(&ctx->strp); in tls_rx_reader_release()
1919 DEBUG_NET_WARN_ON_ONCE(darg.skb == ctx->strp.anchor); in tls_sw_recvmsg()
2184 int tls_rx_msg_size(struct tls_strparser *strp, struct sk_buff *skb) in tls_rx_msg_size() argument
2186 struct tls_context *tls_ctx = tls_get_ctx(strp->sk); in tls_rx_msg_size()
2194 if (strp->stm.offset + prot->prepend_size > skb->len) in tls_rx_msg_size()
[all …]
H A Dtls_main.c771 tls_strp_check_rcv(&rx_ctx->strp, true); in do_tls_setsockopt_conf()
/linux/include/net/
H A Dstrparser.h44 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 Despintcp.h22 struct strparser strp; member
H A Dkcm.h91 struct strparser strp; member
/linux/tools/testing/selftests/bpf/prog_tests/
H A Dsockmap_strp.c49 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 …]
H A Dsockmap_basic.c1139 static void test_sockmap_copied_seq(bool strp) in test_sockmap_copied_seq() argument
1161 if (strp) { in test_sockmap_copied_seq()
/linux/net/xfrm/
H A Despintcp.c51 static void espintcp_rcv(struct strparser *strp, struct sk_buff *skb) in espintcp_rcv() argument
53 struct espintcp_ctx *ctx = container_of(strp, struct espintcp_ctx, in espintcp_rcv()
54 strp); in espintcp_rcv()
66 XFRM_INC_STATS(sock_net(strp->sk), LINUX_MIB_XFRMINHDRERROR); in espintcp_rcv()
79 XFRM_INC_STATS(sock_net(strp->sk), LINUX_MIB_XFRMINHDRERROR); in espintcp_rcv()
87 XFRM_INC_STATS(sock_net(strp->sk), LINUX_MIB_XFRMINHDRERROR); in espintcp_rcv()
94 XFRM_INC_STATS(sock_net(strp->sk), LINUX_MIB_XFRMINERROR); in espintcp_rcv()
100 XFRM_INC_STATS(sock_net(strp->sk), LINUX_MIB_XFRMINERROR); in espintcp_rcv()
106 handle_nonesp(ctx, skb, strp->sk); in espintcp_rcv()
108 handle_esp(skb, strp->sk); in espintcp_rcv()
[all …]
/linux/net/kcm/
H A Dkcmproc.c145 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()
H A Dkcmsock.c101 psock->strp.stats.bytes - in kcm_update_rx_mux_stats()
104 psock->strp.stats.msgs - psock->saved_rx_msgs; in kcm_update_rx_mux_stats()
105 psock->saved_rx_msgs = psock->strp.stats.msgs; in kcm_update_rx_mux_stats()
106 psock->saved_rx_bytes = psock->strp.stats.bytes; in kcm_update_rx_mux_stats()
162 strp_unpause(&psock->strp); in kcm_rcv_ready()
163 strp_check_rcv(&psock->strp); in kcm_rcv_ready()
279 strp_pause(&psock->strp); in reserve_rx_kcm()
362 strp_data_ready(&psock->strp); in psock_data_ready()
368 static void kcm_rcv_strparser(struct strparser *strp, struct sk_buff *skb) in kcm_rcv_strparser() argument
370 struct kcm_psock *psock = container_of(strp, struct kcm_psock, strp); in kcm_rcv_strparser()
[all …]
/linux/drivers/net/ovpn/
H A Dtcp.c36 static int ovpn_tcp_parse(struct strparser *strp, struct sk_buff *skb) in ovpn_tcp_parse() argument
102 static void ovpn_tcp_rcv(struct strparser *strp, struct sk_buff *skb) in ovpn_tcp_rcv() argument
104 struct ovpn_peer *peer = container_of(strp, struct ovpn_peer, tcp.strp); in ovpn_tcp_rcv()
136 ovpn_tcp_to_userspace(peer, strp->sk, skb); in ovpn_tcp_rcv()
215 strp_stop(&peer->tcp.strp); in ovpn_tcp_socket_detach()
249 strp_done(&peer->tcp.strp); in ovpn_tcp_socket_wait_finish()
478 strp_data_ready(&sock->peer->tcp.strp); in ovpn_tcp_data_ready()
535 ret = strp_init(&peer->tcp.strp, ovpn_sock->sk, &cb); in ovpn_tcp_socket_attach()
570 strp_check_rcv(&peer->tcp.strp); in ovpn_tcp_socket_attach()
H A Dpeer.h80 struct strparser strp; member
/linux/tools/perf/util/
H A Dutil.c386 int perf_tip(char **strp, const char *dirpath) in perf_event_paranoid_check()
396 *strp = NULL; in perf_tip()
405 if (asprintf(strp, "Tip: %s", node->s) < 0) in perf_tip()
394 perf_tip(char ** strp,const char * dirpath) perf_tip() argument
H A Dbuild-id.c136 static int asnprintf(char **strp, size_t size, const char *fmt, ...) in asnprintf()
141 if (!strp) in asnprintf()
145 if (*strp) in asnprintf()
146 ret = vsnprintf(*strp, size, fmt, ap); in asnprintf()
148 ret = vasprintf(strp, fmt, ap); in asnprintf()
133 asnprintf(char ** strp,size_t size,const char * fmt,...) asnprintf() argument
H A Dutil.h49 int perf_tip(char **strp, const char *dirpath);
H A Dsort.c4382 char *str, *strp;
4388 strp = str = strdup(field_order);
4395 strp++;
4397 if (!strlen(strp)) {
4402 ret = setup_output_list(&perf_hpp_list, strp);
4210 char *str, *strp; __setup_output_field() local
/linux/security/apparmor/
H A Dlabel.c1676 int aa_label_asxprint(char **strp, struct aa_ns *ns, struct aa_label *label, in aa_label_asxprint() argument
1681 AA_BUG(!strp); in aa_label_asxprint()
1688 *strp = kmalloc(size + 1, gfp); in aa_label_asxprint()
1689 if (!*strp) in aa_label_asxprint()
1691 return aa_label_snxprint(*strp, size + 1, ns, label, flags); in aa_label_asxprint()
1705 int aa_label_acntsxprint(char __counted **strp, struct aa_ns *ns, in aa_label_acntsxprint() argument
1710 AA_BUG(!strp); in aa_label_acntsxprint()
1717 *strp = aa_str_alloc(size + 1, gfp); in aa_label_acntsxprint()
1718 if (!*strp) in aa_label_acntsxprint()
1720 return aa_label_snxprint(*strp, size + 1, ns, label, flags); in aa_label_acntsxprint()
/linux/security/apparmor/include/
H A Dlabel.h299 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 Dpolicydb.h414 extern int str_read(char **strp, gfp_t flags, struct policy_file *fp, u32 len);
H A Dpolicydb.c1178 int str_read(char **strp, gfp_t flags, struct policy_file *fp, u32 len) in str_read() argument
1200 *strp = str; in str_read()
/linux/net/ipv4/
H A Dtcp_bpf.c690 int tcp_bpf_strp_read_sock(struct strparser *strp, read_descriptor_t *desc, in tcp_bpf_strp_read_sock() argument
693 struct sock *sk = strp->sk; in tcp_bpf_strp_read_sock()
/linux/include/linux/
H A Dskmsg.h94 struct strparser strp; member

12