| /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_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); 197 void tls_strp_msg_done(struct tls_strparser *strp); 199 int tls_rx_msg_size(struct tls_strparser *strp, struct sk_buff *skb); 200 void tls_rx_msg_ready(struct tls_strparser *strp); [all …]
|
| H A D | tls_sw.c | 1404 tls_strp_check_rcv(&ctx->strp); in tls_rx_rec_wait() 1433 if (unlikely(!tls_strp_msg_load(&ctx->strp, released))) in tls_rx_rec_wait() 1685 err = tls_strp_msg_hold(&ctx->strp, &ctx->async_hold); in tls_decrypt_sg() 1887 tls_strp_msg_done(&ctx->strp); in tls_rx_rec_done() 2190 DEBUG_NET_WARN_ON_ONCE(darg.skb == ctx->strp.anchor); in tls_sw_recvmsg() 2468 int tls_rx_msg_size(struct tls_strparser *strp, struct sk_buff *skb) in tls_rx_msg_size() argument 2470 struct tls_context *tls_ctx = tls_get_ctx(strp->sk); in tls_rx_msg_size() 2478 if (strp->stm.offset + prot->prepend_size > skb->len) in tls_rx_msg_size() 2488 ret = skb_copy_bits(skb, strp->stm.offset, header, prot->prepend_size); in tls_rx_msg_size() 2492 strp->mark = header[0]; in tls_rx_msg_size() [all …]
|
| /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->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/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
|
| /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 …]
|
| H A D | sockmap_basic.c | 1141 static void test_sockmap_copied_seq(bool strp) in test_sockmap_copied_seq() argument 1163 if (strp) { in test_sockmap_copied_seq() 1400 if (test__start_subtest("sockmap recover with strp")) in test_sockmap_basic()
|
| /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/xfrm/ |
| H A D | espintcp.c | 51 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 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()
|
| H A D | kcmsock.c | 99 psock->strp.stats.bytes - in kcm_update_rx_mux_stats() 102 psock->strp.stats.msgs - psock->saved_rx_msgs; in kcm_update_rx_mux_stats() 103 psock->saved_rx_msgs = psock->strp.stats.msgs; in kcm_update_rx_mux_stats() 104 psock->saved_rx_bytes = psock->strp.stats.bytes; in kcm_update_rx_mux_stats() 160 strp_unpause(&psock->strp); in kcm_rcv_ready() 161 strp_check_rcv(&psock->strp); in kcm_rcv_ready() 277 strp_pause(&psock->strp); in reserve_rx_kcm() 360 strp_data_ready(&psock->strp); in psock_data_ready() 366 static void kcm_rcv_strparser(struct strparser *strp, struct sk_buff *skb) in kcm_rcv_strparser() argument 368 struct kcm_psock *psock = container_of(strp, struct kcm_psock, strp); in kcm_rcv_strparser() [all …]
|
| /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 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() 214 strp_stop(&peer->tcp.strp); in ovpn_tcp_socket_detach() 248 strp_done(&peer->tcp.strp); in ovpn_tcp_socket_wait_finish() 477 strp_data_ready(&sock->peer->tcp.strp); in ovpn_tcp_data_ready() 534 ret = strp_init(&peer->tcp.strp, ovpn_sock->sk, &cb); in ovpn_tcp_socket_attach() 569 strp_check_rcv(&peer->tcp.strp); in ovpn_tcp_socket_attach()
|
| H A D | peer.h | 35 * @tcp.strp: stream parser context (TCP only) 80 struct strparser strp; member
|
| /linux/net/core/ |
| H A D | skmsg.c | 1109 static void sk_psock_strp_read(struct strparser *strp, struct sk_buff *skb) in sk_psock_strp_read() argument 1117 sk = strp->sk; in sk_psock_strp_read() 1138 static int sk_psock_strp_read_done(struct strparser *strp, int err) in sk_psock_strp_read_done() argument 1143 static int sk_psock_strp_parse(struct strparser *strp, struct sk_buff *skb) in sk_psock_strp_parse() argument 1145 struct sk_psock *psock = container_of(strp, struct sk_psock, strp); in sk_psock_strp_parse() 1174 strp_data_ready(&psock->strp); in sk_psock_strp_data_ready() 1191 ret = strp_init(&psock->strp, sk, &cb); in sk_psock_init_strp() 1196 psock->strp.cb.read_sock = tcp_bpf_strp_read_sock; in sk_psock_init_strp() 1221 strp_stop(&psock->strp); in sk_psock_stop_strp() 1228 strp_done(&psock->strp); in sk_psock_done_strp()
|
| /linux/security/apparmor/ |
| H A D | label.c | 1667 * @strp: Returns - the allocated buffer with the label name. (NOT NULL) 1676 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() 1696 * @strp: buffer to write to. 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() [all …]
|
| /linux/tools/perf/util/ |
| H A D | util.c | 392 int perf_tip(char **strp, const char *dirpath) in perf_event_paranoid_check() 402 *strp = NULL; in perf_tip() 411 if (asprintf(strp, "Tip: %s", node->s) < 0) in perf_tip() 394 perf_tip(char ** strp,const char * dirpath) perf_tip() argument
|
| 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 | util.h | 49 int perf_tip(char **strp, const char *dirpath);
|
| /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/net/ipv4/ |
| H A D | tcp_bpf.c | 673 int tcp_bpf_strp_read_sock(struct strparser *strp, read_descriptor_t *desc, in tcp_bpf_strp_read_sock() argument 676 struct sock *sk = strp->sk; in tcp_bpf_strp_read_sock()
|
| /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);
|
| /linux/include/linux/ |
| H A D | skmsg.h | 93 struct strparser strp; member
|