/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 static 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_sw.c | 1334 tls_strp_check_rcv(&ctx->strp); in tls_rx_rec_wait() 1363 tls_strp_msg_load(&ctx->strp, released); in tls_rx_rec_wait() 1614 err = tls_strp_msg_hold(&ctx->strp, &ctx->async_hold); in tls_decrypt_sg() 1811 tls_strp_msg_done(&ctx->strp); in tls_rx_rec_done() 2113 DEBUG_NET_WARN_ON_ONCE(darg.skb == ctx->strp.anchor); in tls_sw_recvmsg() 2392 int tls_rx_msg_size(struct tls_strparser *strp, struct sk_buff *skb) in tls_rx_msg_size() argument 2394 struct tls_context *tls_ctx = tls_get_ctx(strp->sk); in tls_rx_msg_size() 2402 if (strp->stm.offset + prot->prepend_size > skb->len) in tls_rx_msg_size() 2412 ret = skb_copy_bits(skb, strp->stm.offset, header, prot->prepend_size); in tls_rx_msg_size() 2416 strp->mark = header[0]; in tls_rx_msg_size() [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 72 struct _strp_msg strp; member 87 offsetof(struct sk_skb_cb, strp)); in strp_msg() [all …]
|
H A D | espintcp.h | 22 struct strparser strp; member
|
H A D | kcm.h | 92 struct strparser strp; member
|
H A D | tcp.h | 2621 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/scripts/dtc/ |
H A D | util.c | 47 int xavsprintf_append(char **strp, const char *fmt, va_list ap) in xavsprintf_append() argument 53 p = *strp; in xavsprintf_append() 65 *strp = p; in xavsprintf_append() 69 int xasprintf_append(char **strp, const char *fmt, ...) in xasprintf_append() argument 75 n = xavsprintf_append(strp, fmt, ap); in xasprintf_append() 81 int xasprintf(char **strp, const char *fmt, ...) in xasprintf() argument 86 *strp = NULL; in xasprintf() 89 n = xavsprintf_append(strp, fmt, ap); in xasprintf()
|
H A D | util.h | 68 extern int PRINTF(2, 3) xasprintf(char **strp, const char *fmt, ...); 69 extern int PRINTF(2, 3) xasprintf_append(char **strp, const char *fmt, ...); 70 extern int PRINTF(2, 0) xavsprintf_append(char **strp, const char *fmt, va_list ap);
|
/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 | 98 psock->strp.stats.bytes - in kcm_update_rx_mux_stats() 101 psock->strp.stats.msgs - psock->saved_rx_msgs; in kcm_update_rx_mux_stats() 102 psock->saved_rx_msgs = psock->strp.stats.msgs; in kcm_update_rx_mux_stats() 103 psock->saved_rx_bytes = psock->strp.stats.bytes; in kcm_update_rx_mux_stats() 159 strp_unpause(&psock->strp); in kcm_rcv_ready() 160 strp_check_rcv(&psock->strp); in kcm_rcv_ready() 276 strp_pause(&psock->strp); in reserve_rx_kcm() 359 strp_data_ready(&psock->strp); in psock_data_ready() 365 static void kcm_rcv_strparser(struct strparser *strp, struct sk_buff *skb) in kcm_rcv_strparser() argument 367 struct kcm_psock *psock = container_of(strp, struct kcm_psock, strp); in kcm_rcv_strparser() [all …]
|
/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/net/core/ |
H A D | skmsg.c | 1064 static void sk_psock_strp_read(struct strparser *strp, struct sk_buff *skb) in sk_psock_strp_read() argument 1072 sk = strp->sk; in sk_psock_strp_read() 1093 static int sk_psock_strp_read_done(struct strparser *strp, int err) in sk_psock_strp_read_done() argument 1098 static int sk_psock_strp_parse(struct strparser *strp, struct sk_buff *skb) in sk_psock_strp_parse() argument 1100 struct sk_psock *psock = container_of(strp, struct sk_psock, strp); in sk_psock_strp_parse() 1129 strp_data_ready(&psock->strp); in sk_psock_strp_data_ready() 1146 ret = strp_init(&psock->strp, sk, &cb); in sk_psock_init_strp() 1151 psock->strp.cb.read_sock = tcp_bpf_strp_read_sock; in sk_psock_init_strp() 1176 strp_stop(&psock->strp); in sk_psock_stop_strp() 1183 strp_done(&psock->strp); in sk_psock_done_strp()
|
/linux/tools/perf/util/ |
H A D | build-id.c | 118 static int asnprintf(char **strp, size_t size, const char *fmt, ...) in asnprintf() argument 123 if (!strp) in asnprintf() 127 if (*strp) in asnprintf() 128 ret = vsnprintf(*strp, size, fmt, ap); in asnprintf() 130 ret = vasprintf(strp, fmt, ap); in asnprintf()
|
/linux/net/ipv4/ |
H A D | tcp_bpf.c | 650 int tcp_bpf_strp_read_sock(struct strparser *strp, read_descriptor_t *desc, in tcp_bpf_strp_read_sock() argument 653 struct sock *sk = strp->sk; in tcp_bpf_strp_read_sock()
|
/linux/include/linux/ |
H A D | skmsg.h | 93 struct strparser strp; member
|
/linux/drivers/usb/gadget/function/ |
H A D | f_midi2.c | 2187 const char **strp, size_t maxlen, in f_midi2_opts_str_store() argument 2205 kfree(*strp); in f_midi2_opts_str_store() 2207 *strp = c; in f_midi2_opts_str_store()
|