€•¥r      Œsphinx.addnodes”Œdocument”“”)”}”(Œ	rawsource”Œ ”Œchildren”]”(Œtranslations”ŒLanguagesNode”“”)”}”(hhh]”(h Œpending_xref”“”)”}”(hhh]”Œdocutils.nodes”ŒText”“”ŒChinese (Simplified)”…””}”Œparent”hsbaŒ
attributes”}”(Œids”]”Œclasses”]”Œnames”]”Œdupnames”]”Œbackrefs”]”Œ	refdomain”Œstd”Œreftype”Œdoc”Œ	reftarget”Œ(/translations/zh_CN/networking/strparser”Œmodname”NŒ	classname”NŒrefexplicit”ˆuŒtagname”hhhubh)”}”(hhh]”hŒChinese (Traditional)”…””}”hh2sbah}”(h]”h ]”h"]”h$]”h&]”Œ	refdomain”h)Œreftype”h+Œ	reftarget”Œ(/translations/zh_TW/networking/strparser”Œmodname”NŒ	classname”NŒrefexplicit”ˆuh1hhhubh)”}”(hhh]”hŒItalian”…””}”hhFsbah}”(h]”h ]”h"]”h$]”h&]”Œ	refdomain”h)Œreftype”h+Œ	reftarget”Œ(/translations/it_IT/networking/strparser”Œmodname”NŒ	classname”NŒrefexplicit”ˆuh1hhhubh)”}”(hhh]”hŒJapanese”…””}”hhZsbah}”(h]”h ]”h"]”h$]”h&]”Œ	refdomain”h)Œreftype”h+Œ	reftarget”Œ(/translations/ja_JP/networking/strparser”Œmodname”NŒ	classname”NŒrefexplicit”ˆuh1hhhubh)”}”(hhh]”hŒKorean”…””}”hhnsbah}”(h]”h ]”h"]”h$]”h&]”Œ	refdomain”h)Œreftype”h+Œ	reftarget”Œ(/translations/ko_KR/networking/strparser”Œmodname”NŒ	classname”NŒrefexplicit”ˆuh1hhhubh)”}”(hhh]”hŒPortuguese (Brazilian)”…””}”hh‚sbah}”(h]”h ]”h"]”h$]”h&]”Œ	refdomain”h)Œreftype”h+Œ	reftarget”Œ(/translations/pt_BR/networking/strparser”Œmodname”NŒ	classname”NŒrefexplicit”ˆuh1hhhubh)”}”(hhh]”hŒSpanish”…””}”hh–sbah}”(h]”h ]”h"]”h$]”h&]”Œ	refdomain”h)Œreftype”h+Œ	reftarget”Œ(/translations/sp_SP/networking/strparser”Œmodname”NŒ	classname”NŒrefexplicit”ˆuh1hhhubeh}”(h]”h ]”h"]”h$]”h&]”Œcurrent_language”ŒEnglish”uh1h
hhŒ	_document”hŒsource”NŒline”NubhŒcomment”“”)”}”(hŒ SPDX-License-Identifier: GPL-2.0”h]”hŒ SPDX-License-Identifier: GPL-2.0”…””}”hh·sbah}”(h]”h ]”h"]”h$]”h&]”Œ	xml:space”Œpreserve”uh1hµhhh²hh³ŒB/var/lib/git/docbuild/linux/Documentation/networking/strparser.rst”h´KubhŒsection”“”)”}”(hhh]”(hŒtitle”“”)”}”(hŒStream Parser (strparser)”h]”hŒStream Parser (strparser)”…””}”(hhÏh²hh³Nh´Nubah}”(h]”h ]”h"]”h$]”h&]”uh1hÍhhÊh²hh³hÇh´KubhÉ)”}”(hhh]”(hÎ)”}”(hŒIntroduction”h]”hŒIntroduction”…””}”(hhàh²hh³Nh´Nubah}”(h]”h ]”h"]”h$]”h&]”uh1hÍhhÝh²hh³hÇh´KubhŒ	paragraph”“”)”}”(hXr  The stream parser (strparser) is a utility that parses messages of an
application layer protocol running over a TCP connection. The stream
parser works in conjunction with an upper layer in the kernel to provide
kernel support for application layer messages. For instance, Kernel
Connection Multiplexor (KCM) uses the Stream Parser to parse messages
using a BPF program.”h]”hXr  The stream parser (strparser) is a utility that parses messages of an
application layer protocol running over a TCP connection. The stream
parser works in conjunction with an upper layer in the kernel to provide
kernel support for application layer messages. For instance, Kernel
Connection Multiplexor (KCM) uses the Stream Parser to parse messages
using a BPF program.”…””}”(hhðh²hh³Nh´Nubah}”(h]”h ]”h"]”h$]”h&]”uh1hîh³hÇh´K
hhÝh²hubhï)”}”(hŒ‹The strparser is called from the data_ready callback of a TCP
socket. Messages are parsed and delivered as they are received on the
socket.”h]”hŒ‹The strparser is called from the data_ready callback of a TCP
socket. Messages are parsed and delivered as they are received on the
socket.”…””}”(hhþh²hh³Nh´Nubah}”(h]”h ]”h"]”h$]”h&]”uh1hîh³hÇh´KhhÝh²hubeh}”(h]”Œintroduction”ah ]”h"]”Œintroduction”ah$]”h&]”uh1hÈhhÊh²hh³hÇh´KubhÉ)”}”(hhh]”(hÎ)”}”(hŒ	Interface”h]”hŒ	Interface”…””}”(hj  h²hh³Nh´Nubah}”(h]”h ]”h"]”h$]”h&]”uh1hÍhj  h²hh³hÇh´Kubhï)”}”(hX%  The API includes a context structure, a set of callbacks, utility
functions, and a data_ready function. The callbacks include a
parse_msg function that is called to perform parsing (e.g. BPF parsing
in case of KCM), and a rcv_msg function that is called when a full
message has been completed.”h]”hX%  The API includes a context structure, a set of callbacks, utility
functions, and a data_ready function. The callbacks include a
parse_msg function that is called to perform parsing (e.g. BPF parsing
in case of KCM), and a rcv_msg function that is called when a full
message has been completed.”…””}”(hj%  h²hh³Nh´Nubah}”(h]”h ]”h"]”h$]”h&]”uh1hîh³hÇh´Khj  h²hubeh}”(h]”Œ	interface”ah ]”h"]”Œ	interface”ah$]”h&]”uh1hÈhhÊh²hh³hÇh´KubhÉ)”}”(hhh]”(hÎ)”}”(hŒ	Functions”h]”hŒ	Functions”…””}”(hj>  h²hh³Nh´Nubah}”(h]”h ]”h"]”h$]”h&]”uh1hÍhj;  h²hh³hÇh´KubhŒblock_quote”“”)”}”(hXœ   ::

    int strp_init(struct strparser *strp, struct sock *sk,
                  const struct strp_callbacks *cb)

 Called to initialize a stream parser. strp is a struct of type
 strparser that is allocated by the upper layer. sk is the TCP
 socket associated with the stream parser. Callbacks are called by
 the stream parser (the callbacks are listed below).

 ::

    void strp_pause(struct strparser *strp)

 Temporarily pause a stream parser. Message parsing is suspended
 and no new messages are delivered to the upper layer.

 ::

    void strp_unpause(struct strparser *strp)

 Unpause a paused stream parser.

 ::

    void strp_stop(struct strparser *strp);

 strp_stop is called to completely stop stream parser operations.
 This is called internally when the stream parser encounters an
 error, and it is called from the upper layer to stop parsing
 operations.

 ::

    void strp_done(struct strparser *strp);

 strp_done is called to release any resources held by the stream
 parser instance. This must be called after the stream processor
 has been stopped. The socket lock must not be held.

::

    void strp_data_ready(struct strparser *strp);

The upper layer calls strp_data_ready when data is ready on
the lower socket for strparser to process. This should be called
from a data_ready callback that is set on the socket. Note that
maximum messages size is the limit of the receive socket
buffer and message timeout is the receive timeout for the socket.

::

    void strp_check_rcv(struct strparser *strp);

strp_check_rcv is called to check for new messages on the socket.
This is normally called at initialization of a stream parser
instance or after strp_unpause.
”h]”(jM  )”}”(hX=  ::

   int strp_init(struct strparser *strp, struct sock *sk,
                 const struct strp_callbacks *cb)

Called to initialize a stream parser. strp is a struct of type
strparser that is allocated by the upper layer. sk is the TCP
socket associated with the stream parser. Callbacks are called by
the stream parser (the callbacks are listed below).

::

   void strp_pause(struct strparser *strp)

Temporarily pause a stream parser. Message parsing is suspended
and no new messages are delivered to the upper layer.

::

   void strp_unpause(struct strparser *strp)

Unpause a paused stream parser.

::

   void strp_stop(struct strparser *strp);

strp_stop is called to completely stop stream parser operations.
This is called internally when the stream parser encounters an
error, and it is called from the upper layer to stop parsing
operations.

::

   void strp_done(struct strparser *strp);

strp_done is called to release any resources held by the stream
parser instance. This must be called after the stream processor
has been stopped. The socket lock must not be held.
”h]”(hŒliteral_block”“”)”}”(hŒeint strp_init(struct strparser *strp, struct sock *sk,
              const struct strp_callbacks *cb)”h]”hŒeint strp_init(struct strparser *strp, struct sock *sk,
              const struct strp_callbacks *cb)”…””}”hjX  sbah}”(h]”h ]”h"]”h$]”h&]”hÅhÆuh1jV  h³hÇh´K#hjR  ubhï)”}”(hŒòCalled to initialize a stream parser. strp is a struct of type
strparser that is allocated by the upper layer. sk is the TCP
socket associated with the stream parser. Callbacks are called by
the stream parser (the callbacks are listed below).”h]”hŒòCalled to initialize a stream parser. strp is a struct of type
strparser that is allocated by the upper layer. sk is the TCP
socket associated with the stream parser. Callbacks are called by
the stream parser (the callbacks are listed below).”…””}”(hjf  h²hh³Nh´Nubah}”(h]”h ]”h"]”h$]”h&]”uh1hîh³hÇh´K&hjR  ubjW  )”}”(hŒ'void strp_pause(struct strparser *strp)”h]”hŒ'void strp_pause(struct strparser *strp)”…””}”hjt  sbah}”(h]”h ]”h"]”h$]”h&]”hÅhÆuh1jV  h³hÇh´K-hjR  ubhï)”}”(hŒuTemporarily pause a stream parser. Message parsing is suspended
and no new messages are delivered to the upper layer.”h]”hŒuTemporarily pause a stream parser. Message parsing is suspended
and no new messages are delivered to the upper layer.”…””}”(hj‚  h²hh³Nh´Nubah}”(h]”h ]”h"]”h$]”h&]”uh1hîh³hÇh´K/hjR  ubjW  )”}”(hŒ)void strp_unpause(struct strparser *strp)”h]”hŒ)void strp_unpause(struct strparser *strp)”…””}”hj  sbah}”(h]”h ]”h"]”h$]”h&]”hÅhÆuh1jV  h³hÇh´K4hjR  ubhï)”}”(hŒUnpause a paused stream parser.”h]”hŒUnpause a paused stream parser.”…””}”(hjž  h²hh³Nh´Nubah}”(h]”h ]”h"]”h$]”h&]”uh1hîh³hÇh´K6hjR  ubjW  )”}”(hŒ'void strp_stop(struct strparser *strp);”h]”hŒ'void strp_stop(struct strparser *strp);”…””}”hj¬  sbah}”(h]”h ]”h"]”h$]”h&]”hÅhÆuh1jV  h³hÇh´K:hjR  ubhï)”}”(hŒÈstrp_stop is called to completely stop stream parser operations.
This is called internally when the stream parser encounters an
error, and it is called from the upper layer to stop parsing
operations.”h]”hŒÈstrp_stop is called to completely stop stream parser operations.
This is called internally when the stream parser encounters an
error, and it is called from the upper layer to stop parsing
operations.”…””}”(hjº  h²hh³Nh´Nubah}”(h]”h ]”h"]”h$]”h&]”uh1hîh³hÇh´K<hjR  ubjW  )”}”(hŒ'void strp_done(struct strparser *strp);”h]”hŒ'void strp_done(struct strparser *strp);”…””}”hjÈ  sbah}”(h]”h ]”h"]”h$]”h&]”hÅhÆuh1jV  h³hÇh´KChjR  ubhï)”}”(hŒ³strp_done is called to release any resources held by the stream
parser instance. This must be called after the stream processor
has been stopped. The socket lock must not be held.”h]”hŒ³strp_done is called to release any resources held by the stream
parser instance. This must be called after the stream processor
has been stopped. The socket lock must not be held.”…””}”(hjÖ  h²hh³Nh´Nubah}”(h]”h ]”h"]”h$]”h&]”uh1hîh³hÇh´KEhjR  ubeh}”(h]”h ]”h"]”h$]”h&]”uh1jL  h³hÇh´K!hjN  ubjW  )”}”(hŒ-void strp_data_ready(struct strparser *strp);”h]”hŒ-void strp_data_ready(struct strparser *strp);”…””}”hjê  sbah}”(h]”h ]”h"]”h$]”h&]”hÅhÆuh1jV  h³hÇh´KKhjN  ubhï)”}”(hX7  The upper layer calls strp_data_ready when data is ready on
the lower socket for strparser to process. This should be called
from a data_ready callback that is set on the socket. Note that
maximum messages size is the limit of the receive socket
buffer and message timeout is the receive timeout for the socket.”h]”hX7  The upper layer calls strp_data_ready when data is ready on
the lower socket for strparser to process. This should be called
from a data_ready callback that is set on the socket. Note that
maximum messages size is the limit of the receive socket
buffer and message timeout is the receive timeout for the socket.”…””}”(hjø  h²hh³Nh´Nubah}”(h]”h ]”h"]”h$]”h&]”uh1hîh³hÇh´KMhjN  ubjW  )”}”(hŒ,void strp_check_rcv(struct strparser *strp);”h]”hŒ,void strp_check_rcv(struct strparser *strp);”…””}”hj  sbah}”(h]”h ]”h"]”h$]”h&]”hÅhÆuh1jV  h³hÇh´KUhjN  ubhï)”}”(hŒžstrp_check_rcv is called to check for new messages on the socket.
This is normally called at initialization of a stream parser
instance or after strp_unpause.”h]”hŒžstrp_check_rcv is called to check for new messages on the socket.
This is normally called at initialization of a stream parser
instance or after strp_unpause.”…””}”(hj  h²hh³Nh´Nubah}”(h]”h ]”h"]”h$]”h&]”uh1hîh³hÇh´KWhjN  ubeh}”(h]”h ]”h"]”h$]”h&]”uh1jL  h³hÇh´K!hj;  h²hubeh}”(h]”Œ	functions”ah ]”h"]”Œ	functions”ah$]”h&]”uh1hÈhhÊh²hh³hÇh´KubhÉ)”}”(hhh]”(hÎ)”}”(hŒ	Callbacks”h]”hŒ	Callbacks”…””}”(hj3  h²hh³Nh´Nubah}”(h]”h ]”h"]”h$]”h&]”uh1hÍhj0  h²hh³hÇh´K\ubhï)”}”(hŒThere are four callbacks:”h]”hŒThere are four callbacks:”…””}”(hjA  h²hh³Nh´Nubah}”(h]”h ]”h"]”h$]”h&]”uh1hîh³hÇh´K^hj0  h²hubjM  )”}”(hX»
  ::

    int (*parse_msg)(struct strparser *strp, struct sk_buff *skb);

parse_msg is called to determine the length of the next message in
the stream. It should parse the sk_buff as containing the headers
for the next application layer message in the stream.

The strparser metadata in the input skb can be accessed with
strp_msg(skb). Only the offset field is relevant in parse_msg and
gives the offset where the message starts in the skb.

The return values of this function are:

=========    ===========================================================
>0           indicates length of successfully parsed message
0            indicates more data must be received to parse the message
-ESTRPIPE    current message should not be processed by the
             kernel, return control of the socket to userspace which
             can proceed to read the messages itself
other < 0    Error in parsing, give control back to userspace
             assuming that synchronization is lost and the stream
             is unrecoverable (application expected to close TCP socket)
=========    ===========================================================

In the case that an error is returned (return value is less than
zero), it will set the error on TCP socket and wake it up. If
parse_msg returned -ESTRPIPE and the stream parser had previously
read some bytes for the current message, then the error set on the
attached socket is ENODATA since the stream is unrecoverable in
that case.

This callback must be set.

::

    void (*rcv_msg)(struct strparser *strp, struct sk_buff *skb);

rcv_msg is called when a full message has been received and
is queued. The callee must consume the sk_buff; it can
call strp_pause to prevent any further messages from being
received in rcv_msg (see strp_pause above).

The strparser metadata in the input skb can be accessed with
strp_msg(skb). This struct contains two fields: offset and full_len.
Offset is where the message starts in the skb, and full_len is
the length of the message. skb->len - offset may be greater than
full_len since strparser does not trim the skb.

This callback must be set.

::

    int (*read_sock)(struct strparser *strp, read_descriptor_t *desc,
                 sk_read_actor_t recv_actor);

The read_sock callback is used by strparser instead of
sock->ops->read_sock, if provided.

This callback is optional.

::

    int (*read_sock_done)(struct strparser *strp, int err);

 read_sock_done is called when the stream parser is done reading
 the TCP socket. The stream parser may read multiple messages in a
 loop and this function allows cleanup to occur when exiting the
 loop. If the callback is not set (NULL in strp_init) a default
 function is used.

This callback is optional.
”h]”(jW  )”}”(hŒ>int (*parse_msg)(struct strparser *strp, struct sk_buff *skb);”h]”hŒ>int (*parse_msg)(struct strparser *strp, struct sk_buff *skb);”…””}”hjS  sbah}”(h]”h ]”h"]”h$]”h&]”hÅhÆuh1jV  h³hÇh´KbhjO  ubhï)”}”(hŒºparse_msg is called to determine the length of the next message in
the stream. It should parse the sk_buff as containing the headers
for the next application layer message in the stream.”h]”hŒºparse_msg is called to determine the length of the next message in
the stream. It should parse the sk_buff as containing the headers
for the next application layer message in the stream.”…””}”(hja  h²hh³Nh´Nubah}”(h]”h ]”h"]”h$]”h&]”uh1hîh³hÇh´KdhjO  ubhï)”}”(hŒ´The strparser metadata in the input skb can be accessed with
strp_msg(skb). Only the offset field is relevant in parse_msg and
gives the offset where the message starts in the skb.”h]”hŒ´The strparser metadata in the input skb can be accessed with
strp_msg(skb). Only the offset field is relevant in parse_msg and
gives the offset where the message starts in the skb.”…””}”(hjo  h²hh³Nh´Nubah}”(h]”h ]”h"]”h$]”h&]”uh1hîh³hÇh´KhhjO  ubhï)”}”(hŒ'The return values of this function are:”h]”hŒ'The return values of this function are:”…””}”(hj}  h²hh³Nh´Nubah}”(h]”h ]”h"]”h$]”h&]”uh1hîh³hÇh´KlhjO  ubhŒtable”“”)”}”(hhh]”hŒtgroup”“”)”}”(hhh]”(hŒcolspec”“”)”}”(hhh]”h}”(h]”h ]”h"]”h$]”h&]”Œcolwidth”K	uh1j•  hj’  ubj–  )”}”(hhh]”h}”(h]”h ]”h"]”h$]”h&]”Œcolwidth”K;uh1j•  hj’  ubhŒtbody”“”)”}”(hhh]”(hŒrow”“”)”}”(hhh]”(hŒentry”“”)”}”(hhh]”hï)”}”(hŒ>0”h]”hŒ>0”…””}”(hjº  h²hh³Nh´Nubah}”(h]”h ]”h"]”h$]”h&]”uh1hîh³hÇh´Kohj·  ubah}”(h]”h ]”h"]”h$]”h&]”uh1jµ  hj²  ubj¶  )”}”(hhh]”hï)”}”(hŒ/indicates length of successfully parsed message”h]”hŒ/indicates length of successfully parsed message”…””}”(hjÑ  h²hh³Nh´Nubah}”(h]”h ]”h"]”h$]”h&]”uh1hîh³hÇh´KohjÎ  ubah}”(h]”h ]”h"]”h$]”h&]”uh1jµ  hj²  ubeh}”(h]”h ]”h"]”h$]”h&]”uh1j°  hj­  ubj±  )”}”(hhh]”(j¶  )”}”(hhh]”hï)”}”(hŒ0”h]”hŒ0”…””}”(hjñ  h²hh³Nh´Nubah}”(h]”h ]”h"]”h$]”h&]”uh1hîh³hÇh´Kphjî  ubah}”(h]”h ]”h"]”h$]”h&]”uh1jµ  hjë  ubj¶  )”}”(hhh]”hï)”}”(hŒ9indicates more data must be received to parse the message”h]”hŒ9indicates more data must be received to parse the message”…””}”(hj  h²hh³Nh´Nubah}”(h]”h ]”h"]”h$]”h&]”uh1hîh³hÇh´Kphj  ubah}”(h]”h ]”h"]”h$]”h&]”uh1jµ  hjë  ubeh}”(h]”h ]”h"]”h$]”h&]”uh1j°  hj­  ubj±  )”}”(hhh]”(j¶  )”}”(hhh]”hï)”}”(hŒ	-ESTRPIPE”h]”hŒ	-ESTRPIPE”…””}”(hj(  h²hh³Nh´Nubah}”(h]”h ]”h"]”h$]”h&]”uh1hîh³hÇh´Kqhj%  ubah}”(h]”h ]”h"]”h$]”h&]”uh1jµ  hj"  ubj¶  )”}”(hhh]”hï)”}”(hŒŽcurrent message should not be processed by the
kernel, return control of the socket to userspace which
can proceed to read the messages itself”h]”hŒŽcurrent message should not be processed by the
kernel, return control of the socket to userspace which
can proceed to read the messages itself”…””}”(hj?  h²hh³Nh´Nubah}”(h]”h ]”h"]”h$]”h&]”uh1hîh³hÇh´Kqhj<  ubah}”(h]”h ]”h"]”h$]”h&]”uh1jµ  hj"  ubeh}”(h]”h ]”h"]”h$]”h&]”uh1j°  hj­  ubj±  )”}”(hhh]”(j¶  )”}”(hhh]”hï)”}”(hŒ	other < 0”h]”hŒ	other < 0”…””}”(hj_  h²hh³Nh´Nubah}”(h]”h ]”h"]”h$]”h&]”uh1hîh³hÇh´Kthj\  ubah}”(h]”h ]”h"]”h$]”h&]”uh1jµ  hjY  ubj¶  )”}”(hhh]”hï)”}”(hŒ¡Error in parsing, give control back to userspace
assuming that synchronization is lost and the stream
is unrecoverable (application expected to close TCP socket)”h]”hŒ¡Error in parsing, give control back to userspace
assuming that synchronization is lost and the stream
is unrecoverable (application expected to close TCP socket)”…””}”(hjv  h²hh³Nh´Nubah}”(h]”h ]”h"]”h$]”h&]”uh1hîh³hÇh´Kthjs  ubah}”(h]”h ]”h"]”h$]”h&]”uh1jµ  hjY  ubeh}”(h]”h ]”h"]”h$]”h&]”uh1j°  hj­  ubeh}”(h]”h ]”h"]”h$]”h&]”uh1j«  hj’  ubeh}”(h]”h ]”h"]”h$]”h&]”Œcols”Kuh1j  hj  ubah}”(h]”h ]”h"]”h$]”h&]”uh1j‹  hjO  ubhï)”}”(hXN  In the case that an error is returned (return value is less than
zero), it will set the error on TCP socket and wake it up. If
parse_msg returned -ESTRPIPE and the stream parser had previously
read some bytes for the current message, then the error set on the
attached socket is ENODATA since the stream is unrecoverable in
that case.”h]”hXN  In the case that an error is returned (return value is less than
zero), it will set the error on TCP socket and wake it up. If
parse_msg returned -ESTRPIPE and the stream parser had previously
read some bytes for the current message, then the error set on the
attached socket is ENODATA since the stream is unrecoverable in
that case.”…””}”(hj£  h²hh³Nh´Nubah}”(h]”h ]”h"]”h$]”h&]”uh1hîh³hÇh´KyhjO  ubhï)”}”(hŒThis callback must be set.”h]”hŒThis callback must be set.”…””}”(hj±  h²hh³Nh´Nubah}”(h]”h ]”h"]”h$]”h&]”uh1hîh³hÇh´K€hjO  ubjW  )”}”(hŒ=void (*rcv_msg)(struct strparser *strp, struct sk_buff *skb);”h]”hŒ=void (*rcv_msg)(struct strparser *strp, struct sk_buff *skb);”…””}”hj¿  sbah}”(h]”h ]”h"]”h$]”h&]”hÅhÆuh1jV  h³hÇh´K„hjO  ubhï)”}”(hŒÙrcv_msg is called when a full message has been received and
is queued. The callee must consume the sk_buff; it can
call strp_pause to prevent any further messages from being
received in rcv_msg (see strp_pause above).”h]”hŒÙrcv_msg is called when a full message has been received and
is queued. The callee must consume the sk_buff; it can
call strp_pause to prevent any further messages from being
received in rcv_msg (see strp_pause above).”…””}”(hjÍ  h²hh³Nh´Nubah}”(h]”h ]”h"]”h$]”h&]”uh1hîh³hÇh´K†hjO  ubhï)”}”(hX1  The strparser metadata in the input skb can be accessed with
strp_msg(skb). This struct contains two fields: offset and full_len.
Offset is where the message starts in the skb, and full_len is
the length of the message. skb->len - offset may be greater than
full_len since strparser does not trim the skb.”h]”hX1  The strparser metadata in the input skb can be accessed with
strp_msg(skb). This struct contains two fields: offset and full_len.
Offset is where the message starts in the skb, and full_len is
the length of the message. skb->len - offset may be greater than
full_len since strparser does not trim the skb.”…””}”(hjÛ  h²hh³Nh´Nubah}”(h]”h ]”h"]”h$]”h&]”uh1hîh³hÇh´K‹hjO  ubhï)”}”(hŒThis callback must be set.”h]”hŒThis callback must be set.”…””}”(hjé  h²hh³Nh´Nubah}”(h]”h ]”h"]”h$]”h&]”uh1hîh³hÇh´K‘hjO  ubjW  )”}”(hŒkint (*read_sock)(struct strparser *strp, read_descriptor_t *desc,
             sk_read_actor_t recv_actor);”h]”hŒkint (*read_sock)(struct strparser *strp, read_descriptor_t *desc,
             sk_read_actor_t recv_actor);”…””}”hj÷  sbah}”(h]”h ]”h"]”h$]”h&]”hÅhÆuh1jV  h³hÇh´K•hjO  ubhï)”}”(hŒYThe read_sock callback is used by strparser instead of
sock->ops->read_sock, if provided.”h]”hŒYThe read_sock callback is used by strparser instead of
sock->ops->read_sock, if provided.”…””}”(hj  h²hh³Nh´Nubah}”(h]”h ]”h"]”h$]”h&]”uh1hîh³hÇh´K˜hjO  ubhï)”}”(hŒThis callback is optional.”h]”hŒThis callback is optional.”…””}”(hj  h²hh³Nh´Nubah}”(h]”h ]”h"]”h$]”h&]”uh1hîh³hÇh´K›hjO  ubjW  )”}”(hXN     int (*read_sock_done)(struct strparser *strp, int err);

read_sock_done is called when the stream parser is done reading
the TCP socket. The stream parser may read multiple messages in a
loop and this function allows cleanup to occur when exiting the
loop. If the callback is not set (NULL in strp_init) a default
function is used.”h]”hXN     int (*read_sock_done)(struct strparser *strp, int err);

read_sock_done is called when the stream parser is done reading
the TCP socket. The stream parser may read multiple messages in a
loop and this function allows cleanup to occur when exiting the
loop. If the callback is not set (NULL in strp_init) a default
function is used.”…””}”hj!  sbah}”(h]”h ]”h"]”h$]”h&]”hÅhÆuh1jV  h³hÇh´KŸhjO  ubhï)”}”(hŒThis callback is optional.”h]”hŒThis callback is optional.”…””}”(hj/  h²hh³Nh´Nubah}”(h]”h ]”h"]”h$]”h&]”uh1hîh³hÇh´K§hjO  ubeh}”(h]”h ]”h"]”h$]”h&]”uh1jL  h³hÇh´K`hj0  h²hubeh}”(h]”Œ	callbacks”ah ]”h"]”Œ	callbacks”ah$]”h&]”uh1hÈhhÊh²hh³hÇh´K\ubhÉ)”}”(hhh]”(hÎ)”}”(hŒ
Statistics”h]”hŒ
Statistics”…””}”(hjN  h²hh³Nh´Nubah}”(h]”h ]”h"]”h$]”h&]”uh1hÍhjK  h²hh³hÇh´Kªubhï)”}”(hX.  Various counters are kept for each stream parser instance. These are in
the strp_stats structure. strp_aggr_stats is a convenience structure for
accumulating statistics for multiple stream parser instances.
save_strp_stats and aggregate_strp_stats are helper functions to save
and aggregate statistics.”h]”hX.  Various counters are kept for each stream parser instance. These are in
the strp_stats structure. strp_aggr_stats is a convenience structure for
accumulating statistics for multiple stream parser instances.
save_strp_stats and aggregate_strp_stats are helper functions to save
and aggregate statistics.”…””}”(hj\  h²hh³Nh´Nubah}”(h]”h ]”h"]”h$]”h&]”uh1hîh³hÇh´K¬hjK  h²hubeh}”(h]”Œ
statistics”ah ]”h"]”Œ
statistics”ah$]”h&]”uh1hÈhhÊh²hh³hÇh´KªubhÉ)”}”(hhh]”(hÎ)”}”(hŒMessage assembly limits”h]”hŒMessage assembly limits”…””}”(hju  h²hh³Nh´Nubah}”(h]”h ]”h"]”h$]”h&]”uh1hÍhjr  h²hh³hÇh´K³ubhï)”}”(hŒYThe stream parser provide mechanisms to limit the resources consumed by
message assembly.”h]”hŒYThe stream parser provide mechanisms to limit the resources consumed by
message assembly.”…””}”(hjƒ  h²hh³Nh´Nubah}”(h]”h ]”h"]”h$]”h&]”uh1hîh³hÇh´Kµhjr  h²hubhï)”}”(hŒûA timer is set when assembly starts for a new message. The message
timeout is taken from rcvtime for the associated TCP socket. If the
timer fires before assembly completes the stream parser is aborted and
the ETIMEDOUT error is set on the TCP socket.”h]”hŒûA timer is set when assembly starts for a new message. The message
timeout is taken from rcvtime for the associated TCP socket. If the
timer fires before assembly completes the stream parser is aborted and
the ETIMEDOUT error is set on the TCP socket.”…””}”(hj‘  h²hh³Nh´Nubah}”(h]”h ]”h"]”h$]”h&]”uh1hîh³hÇh´K¸hjr  h²hubhï)”}”(hXj  Message length is limited to the receive
buffer size of the associated TCP socket. If the length returned by
parse_msg is greater than the socket buffer size then the stream parser
is aborted with EMSGSIZE error set on the TCP socket. Note that this
makes the maximum size of receive skbuffs for a socket with a stream
parser to be 2*sk_rcvbuf of the TCP socket.”h]”hXj  Message length is limited to the receive
buffer size of the associated TCP socket. If the length returned by
parse_msg is greater than the socket buffer size then the stream parser
is aborted with EMSGSIZE error set on the TCP socket. Note that this
makes the maximum size of receive skbuffs for a socket with a stream
parser to be 2*sk_rcvbuf of the TCP socket.”…””}”(hjŸ  h²hh³Nh´Nubah}”(h]”h ]”h"]”h$]”h&]”uh1hîh³hÇh´K½hjr  h²hubeh}”(h]”Œmessage-assembly-limits”ah ]”h"]”Œmessage assembly limits”ah$]”h&]”uh1hÈhhÊh²hh³hÇh´K³ubhÉ)”}”(hhh]”(hÎ)”}”(hŒAuthor”h]”hŒAuthor”…””}”(hj¸  h²hh³Nh´Nubah}”(h]”h ]”h"]”h$]”h&]”uh1hÍhjµ  h²hh³hÇh´KÅubhï)”}”(hŒ Tom Herbert (tom@quantonium.net)”h]”(hŒTom Herbert (”…””}”(hjÆ  h²hh³Nh´NubhŒ	reference”“”)”}”(hŒtom@quantonium.net”h]”hŒtom@quantonium.net”…””}”(hjÐ  h²hh³Nh´Nubah}”(h]”h ]”h"]”h$]”h&]”Œrefuri”Œmailto:tom@quantonium.net”uh1jÎ  hjÆ  ubhŒ)”…””}”(hjÆ  h²hh³Nh´Nubeh}”(h]”h ]”h"]”h$]”h&]”uh1hîh³hÇh´KÇhjµ  h²hubeh}”(h]”Œauthor”ah ]”h"]”Œauthor”ah$]”h&]”uh1hÈhhÊh²hh³hÇh´KÅubeh}”(h]”Œstream-parser-strparser”ah ]”h"]”Œstream parser (strparser)”ah$]”h&]”uh1hÈhhh²hh³hÇh´Kubeh}”(h]”h ]”h"]”h$]”h&]”Œsource”hÇuh1hŒcurrent_source”NŒcurrent_line”NŒsettings”Œdocutils.frontend”ŒValues”“”)”}”(hÍNŒ	generator”NŒ	datestamp”NŒsource_link”NŒ
source_url”NŒtoc_backlinks”jµ  Œfootnote_backlinks”KŒsectnum_xform”KŒstrip_comments”NŒstrip_elements_with_classes”NŒstrip_classes”NŒreport_level”KŒ
halt_level”KŒexit_status_level”KŒdebug”NŒwarning_stream”NŒ	traceback”ˆŒinput_encoding”Œ	utf-8-sig”Œinput_encoding_error_handler”Œstrict”Œoutput_encoding”Œutf-8”Œoutput_encoding_error_handler”j  Œerror_encoding”Œutf-8”Œerror_encoding_error_handler”Œbackslashreplace”Œlanguage_code”Œen”Œrecord_dependencies”NŒconfig”NŒ	id_prefix”hŒauto_id_prefix”Œid”Œdump_settings”NŒdump_internals”NŒdump_transforms”NŒdump_pseudo_xml”NŒexpose_internals”NŒstrict_visitor”NŒ_disable_config”NŒ_source”hÇŒ_destination”NŒ_config_files”]”Œ7/var/lib/git/docbuild/linux/Documentation/docutils.conf”aŒfile_insertion_enabled”ˆŒraw_enabled”KŒline_length_limit”M'Œpep_references”NŒpep_base_url”Œhttps://peps.python.org/”Œpep_file_url_template”Œpep-%04d”Œrfc_references”NŒrfc_base_url”Œ&https://datatracker.ietf.org/doc/html/”Œ	tab_width”KŒtrim_footnote_reference_space”‰Œsyntax_highlight”Œlong”Œsmart_quotes”ˆŒsmartquotes_locales”]”Œcharacter_level_inline_markup”‰Œdoctitle_xform”‰Œdocinfo_xform”KŒsectsubtitle_xform”‰Œimage_loading”Œlink”Œembed_stylesheet”‰Œcloak_email_addresses”ˆŒsection_self_link”‰Œenv”NubŒreporter”NŒindirect_targets”]”Œsubstitution_defs”}”Œsubstitution_names”}”Œrefnames”}”Œrefids”}”Œnameids”}”(j÷  jô  j  j  j8  j5  j-  j*  jH  jE  jo  jl  j²  j¯  jï  jì  uŒ	nametypes”}”(j÷  ‰j  ‰j8  ‰j-  ‰jH  ‰jo  ‰j²  ‰jï  ‰uh}”(jô  hÊj  hÝj5  j  j*  j;  jE  j0  jl  jK  j¯  jr  jì  jµ  uŒfootnote_refs”}”Œcitation_refs”}”Œautofootnotes”]”Œautofootnote_refs”]”Œsymbol_footnotes”]”Œsymbol_footnote_refs”]”Œ	footnotes”]”Œ	citations”]”Œautofootnote_start”KŒsymbol_footnote_start”K Œ
id_counter”Œcollections”ŒCounter”“”}”…”R”Œparse_messages”]”Œtransform_messages”]”Œtransformer”NŒinclude_log”]”Œ
decoration”Nh²hub.