Home
last modified time | relevance | path

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

/net/strparser/
A Dstrparser.c70 strp->cb.abort_parser(strp, err); in strp_parser_err()
213 len = (*strp->cb.parse_msg)(strp, head); in __strp_recv()
274 strp->need_bytes = stm->strp.full_len - in __strp_recv()
301 strp->cb.rcv_msg(strp, head); in __strp_recv()
362 strp->cb.read_sock(strp, &desc, strp_recv); in strp_read_sock()
404 strp->cb.lock(strp); in do_strp_work()
416 strp->cb.unlock(strp); in do_strp_work()
431 strp->cb.lock(strp); in strp_msg_timeout()
432 strp->cb.abort_parser(strp, -ETIMEDOUT); in strp_msg_timeout()
433 strp->cb.unlock(strp); in strp_msg_timeout()
[all …]
/net/tls/
A Dtls_strp.c74 skb = tls_strp_skb_copy(strp, strp->anchor, strp->stm.offset, in tls_strp_msg_make_copy()
87 struct tls_strparser *strp = &ctx->strp; in tls_strp_msg_detach() local
122 struct tls_strparser *strp = &ctx->strp; in tls_strp_msg_cow() local
135 tcp_read_done(strp->sk, strp->stm.full_len); in tls_strp_msg_cow()
489 memset(&strp->stm, 0, sizeof(strp->stm)); in tls_strp_msg_load()
522 sz = tls_rx_msg_size(strp, strp->anchor); in tls_strp_read_sock()
530 if (!strp->stm.full_len || inq < strp->stm.full_len) in tls_strp_read_sock()
545 if (unlikely(strp->stopped) || strp->msg_ready) in tls_strp_check_rcv()
585 tcp_read_done(strp->sk, strp->stm.full_len); in tls_strp_msg_done()
590 memset(&strp->stm, 0, sizeof(strp->stm)); in tls_strp_msg_done()
[all …]
A Dtls.h188 void tls_strp_done(struct tls_strparser *strp);
189 void tls_strp_stop(struct tls_strparser *strp);
190 int tls_strp_init(struct tls_strparser *strp, struct sock *sk);
191 void tls_strp_data_ready(struct tls_strparser *strp);
193 void tls_strp_check_rcv(struct tls_strparser *strp);
194 void tls_strp_msg_done(struct tls_strparser *strp);
197 void tls_rx_msg_ready(struct tls_strparser *strp);
213 DEBUG_NET_WARN_ON_ONCE(!ctx->strp.msg_ready || !ctx->strp.anchor->len); in tls_strp_msg()
214 return ctx->strp.anchor; in tls_strp_msg()
219 return READ_ONCE(ctx->strp.msg_ready); in tls_strp_msg_ready()
[all …]
A Dtls_sw.c1358 tls_strp_check_rcv(&ctx->strp); in tls_rx_rec_wait()
1836 tls_strp_msg_done(&ctx->strp); in tls_rx_rec_done()
2441 strp->mark = header[0]; in tls_rx_msg_size()
2472 tls_err_abort(strp->sk, ret); in tls_rx_msg_size()
2477 void tls_rx_msg_ready(struct tls_strparser *strp) in tls_rx_msg_ready() argument
2481 ctx = container_of(strp, struct tls_sw_context_rx, strp); in tls_rx_msg_ready()
2482 ctx->saved_data_ready(strp->sk); in tls_rx_msg_ready()
2496 tls_strp_data_ready(&ctx->strp); in tls_data_ready()
2565 tls_strp_stop(&ctx->strp); in tls_sw_release_resources_rx()
2582 tls_strp_done(&ctx->strp); in tls_sw_strparser_done()
[all …]
A Dtls_main.c750 tls_strp_check_rcv(&rx_ctx->strp); in do_tls_setsockopt_conf()
/net/xfrm/
A Despintcp.c57 strp); 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()
413 strp_data_ready(&ctx->strp); in espintcp_data_ready()
420 struct sock *sk = ctx->strp.sk; in espintcp_tx_work()
472 err = strp_init(&ctx->strp, sk, &cb); in espintcp_init_sk()
478 strp_check_rcv(&ctx->strp); in espintcp_init_sk()
534 strp_stop(&ctx->strp); in espintcp_close()
[all …]
/net/kcm/
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()
A Dkcmsock.c99 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()
368 struct kcm_psock *psock = container_of(strp, struct kcm_psock, strp); in kcm_rcv_strparser()
389 struct kcm_psock *psock = container_of(strp, struct kcm_psock, strp); in kcm_parse_func_strparser()
399 struct kcm_psock *psock = container_of(strp, struct kcm_psock, strp); in kcm_read_sock_done()
1317 strp_check_rcv(&psock->strp); in kcm_attach()
1370 strp_stop(&psock->strp); in kcm_unattach()
[all …]
/net/core/
A Dskmsg.c1085 static void sk_psock_strp_read(struct strparser *strp, struct sk_buff *skb) in sk_psock_strp_read() argument
1093 sk = strp->sk; in sk_psock_strp_read()
1114 static int sk_psock_strp_read_done(struct strparser *strp, int err) in sk_psock_strp_read_done() argument
1119 static int sk_psock_strp_parse(struct strparser *strp, struct sk_buff *skb) in sk_psock_strp_parse() argument
1121 struct sk_psock *psock = container_of(strp, struct sk_psock, strp); in sk_psock_strp_parse()
1150 strp_data_ready(&psock->strp); in sk_psock_strp_data_ready()
1167 ret = strp_init(&psock->strp, sk, &cb); in sk_psock_init_strp()
1172 psock->strp.cb.read_sock = tcp_bpf_strp_read_sock; in sk_psock_init_strp()
1197 strp_stop(&psock->strp); in sk_psock_stop_strp()
1204 strp_done(&psock->strp); in sk_psock_done_strp()
/net/ipv4/
A Dtcp_bpf.c650 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()

Completed in 32 milliseconds