| /Zephyr-Core-3.6.0/doc/kernel/data_structures/ |
| D | mpsc_pbuf.rst | 3 Multi Producer Single Consumer Packet Buffer
6 A :dfn:`Multi Producer Single Consumer Packet Buffer (MPSC_PBUF)` is a circular
8 packets are stored in the buffer. Packet buffer works under assumption that there
11 Packet is produced in two steps: first requested amount of data is allocated,
12 producer fills the data and commits it. Consuming a packet is also performed in
13 two steps: consumer claims the packet, gets pointer to it and length and later
14 on packet is freed. This approach reduces memory copying.
16 A :dfn:`MPSC Packet Buffer` has the following key properties:
18 * Allocate, commit scheme used for packet producing.
19 * Claim, free scheme used for packet consuming.
[all …]
|
| /Zephyr-Core-3.6.0/include/zephyr/sys/ |
| D | mpsc_pbuf.h | 20 * @brief Multi producer, single consumer packet buffer API
21 * @defgroup mpsc_buf MPSC (Multi producer, single consumer) packet buffer API
27 * Multi producer, single consumer packet buffer allows to allocate variable
28 * length consecutive space for storing a packet. When space is allocated
29 * it can be filled by the user (except for the first 2 bits) and when packet
30 * is ready it is committed. It is allowed to allocate another packet before
33 * If buffer is full and packet cannot be allocated then null is returned unless
37 * packet is dropped and claimed packet is marked as invalid when freeing.
39 * Reading packets is performed in two steps. First packet is claimed. Claiming
40 * returns pointer to the packet within the buffer. Packet is freed when no
[all …]
|
| D | spsc_pbuf.h | 18 * @brief Single producer, single consumer packet buffer API
19 * @defgroup spsc_buf SPSC (Single producer, single consumer) packet buffer API
24 /**@defgroup SPSC_PBUF_FLAGS SPSC packet buffer flags
52 /** @brief Maximum packet length. */
55 /** @brief First part of packet buffer control block.
58 * by the reader. If packet is shared between to cores then data changed by
72 /** @brief Remaining part of a packet buffer when cache is used.
83 /** @brief Remaining part of a packet buffer when cache is not used. */
90 * @brief Single producer, single consumer packet buffer
92 * The SPSC packet buffer implements lightweight unidirectional packet buffer
[all …]
|
| D | mpsc_packet.h | 18 * @brief Multi producer, single consumer packet header
19 * @defgroup mpsc_packet MPSC (Multi producer, single consumer) packet header
27 /** @brief Header that must be added to the first word in each packet.
29 * This fields are controlled by the packet buffer and unless specified must
30 * not be used. Fields must be added at the top of the packet header structure.
36 /** @brief Generic packet header. */
42 /** @brief Skip packet used internally by the packet buffer. */
48 /** @brief Generic packet header. */
|
| /Zephyr-Core-3.6.0/samples/drivers/peci/src/ |
| D | main.c | 38 struct peci_msg packet; in peci_ping() local
42 packet.addr = PECI_HOST_ADDR; in peci_ping()
43 packet.cmd_code = PECI_CMD_PING; in peci_ping()
44 packet.tx_buffer.buf = NULL; in peci_ping()
45 packet.tx_buffer.len = PECI_PING_WR_LEN; in peci_ping()
46 packet.rx_buffer.buf = NULL; in peci_ping()
47 packet.rx_buffer.len = PECI_PING_RD_LEN; in peci_ping()
49 ret = peci_transfer(peci_dev, &packet); in peci_ping()
63 struct peci_msg packet; in peci_get_tjmax() local
72 packet.tx_buffer.buf = peci_req_buf; in peci_get_tjmax()
[all …]
|
| /Zephyr-Core-3.6.0/subsys/net/pkt_filter/ |
| D | Kconfig | 1 # Packet filtering config
5 menu "Network Packet Filtering"
8 bool "Network packet filtering"
10 The Network Packet Filtering facility provides the infrastructure
11 to construct custom rules for accepting and/or denying packet
17 bool "Additional network packet filtering hook inside IPv4 stack"
21 rules on the IP packet.
24 bool "Additional network packet filtering hook inside IPv6 stack"
28 rules on the IP packet.
31 bool "Additional network packet filtering hook for connection input"
[all …]
|
| /Zephyr-Core-3.6.0/doc/connectivity/networking/ |
| D | net_pkt_processing_stats.rst | 3 Network Packet Processing Statistics
10 This page describes how to get information about network packet processing
13 Network stack contains infrastructure to figure out how long the network packet
18 network packet statistics is collected. For RX, only UDP, TCP or raw packet
19 type network packet statistics is collected.
33 The TX time tells how long it took for network packet from its creation to
42 information for TX or RX network packets are collected when the network packet
54 took for a network packet to go from previous state to next.
59 * Packet was created by application so the time is **0**.
60 * Packet is about to be placed to transmit queue. The time it took from network
[all …]
|
| D | net-stack-architecture.rst | 88 1. A network data packet is received by a device driver.
91 data. The network packet is placed in the proper RX queue (implemented by
100 3. The network packet is then passed to the correct L2 driver. The L2 driver
101 can check if the packet is proper and modify it if needed, e.g. strip L2
104 4. The packet is processed by a network interface. The network statistics are
107 5. The packet is then passed to L3 processing. If the packet is IP based,
108 then the L3 layer checks if the packet is a proper IPv6 or IPv4 packet.
110 6. A socket handler then finds an active socket to which the network packet
140 4. An IP header is added to the network packet for a UDP or TCP packet.
143 for the network packet, and also will make sure that the network interface
[all …]
|
| /Zephyr-Core-3.6.0/samples/net/sockets/packet/ |
| D | README.rst | 1 .. zephyr:code-sample:: packet-socket
2 :name: Packet socket
5 Use raw packet sockets over Ethernet.
10 This sample is a simple packet socket application showing usage
11 of packet sockets over Ethernet. The sample prints every packet
12 received, and sends a dummy packet every 5 seconds.
19 When the application is run, it opens a packet socket and prints
20 the length of the packet it receives. After that it sends a dummy
21 packet every 5 seconds. You can use Wireshark to observe these
|
| D | sample.yaml | 2 description: Packet socket sample
3 name: packet-socket
5 sample.net.sockets.packet:
17 - packet-socket
|
| /Zephyr-Core-3.6.0/subsys/net/lib/mqtt/ |
| D | mqtt.c | 76 struct buf_ctx packet; in client_connect() local
83 tx_buf_init(client, &packet); in client_connect()
86 err_code = connect_request_encode(client, &packet); in client_connect()
92 err_code = mqtt_transport_write(client, packet.cur, in client_connect()
93 packet.end - packet.cur); in client_connect()
243 struct buf_ctx packet; in mqtt_publish() local
257 tx_buf_init(client, &packet); in mqtt_publish()
264 err_code = publish_encode(param, &packet); in mqtt_publish()
269 io_vector[0].iov_base = packet.cur; in mqtt_publish()
270 io_vector[0].iov_len = packet.end - packet.cur; in mqtt_publish()
[all …]
|
| /Zephyr-Core-3.6.0/drivers/bluetooth/hci/ |
| D | apollox_blue.h | 20 * @brief SPI transceive function for Bluetooth packet.
22 * @param tx Pointer of transmission packet.
23 * @param tx_len Length of transmission packet.
24 * @param rx Pointer of reception packet.
25 * @param rx_len Length of reception packet.
35 * @param data Pointer of transmission packet.
36 * @param len Length of transmission packet.
55 * @param data Pointer of transmission packet.
56 * @param len Length of transmission packet.
57 * @param transceive SPI transceive function for Bluetooth packet.
[all …]
|
| /Zephyr-Core-3.6.0/subsys/mgmt/mcumgr/transport/include/mgmt/mcumgr/transport/ |
| D | smp_reassembly.h | 32 * Note: Currently the function is not able to concatenate buffers so re-assembled packet needs
43 * @return number of expected bytes left to complete the packet, 0 means buffer is complete
45 * -ENOSR if a packet length, read from header, is bigger than
48 * -EOVERFLOW if attempting to add a fragment that would make complete packet larger
50 * -ENOMEM if failed to allocate a new buffer for packet assembly;
52 * of the packet; MTU is set too low;
57 * Return number of expected bytes to complete the packet
64 * @return number of bytes needed to complete the packet;
65 * -EINVAL if there is no packet in re-assembly;
70 * Pass packet for further processing
[all …]
|
| /Zephyr-Core-3.6.0/subsys/net/ip/ |
| D | packet_socket.h | 2 * @brief Packet Socket related functions
19 * @brief Called by net_core.c when a network packet is received.
21 * @param pkt Network packet
23 * @return NET_OK if the packet was consumed, NET_DROP if
24 * the packet parsing failed and the caller should handle
25 * the received packet. If corresponding IP protocol support is
|
| D | canbus_socket.h | 19 * @brief Called by net_core.c when a CANBUS packet is received.
21 * @param pkt Network packet
23 * @return NET_OK if the packet was consumed, NET_DROP if
24 * the packet parsing failed and the caller should handle
25 * the received packet.
|
| /Zephyr-Core-3.6.0/lib/os/ |
| D | Kconfig | 23 bool "Multi producer, single consumer packet buffer"
26 Enable usage of mpsc packet buffer. Packet buffer is capable of
31 bool "Single producer, single consumer packet buffer"
33 Enable usage of spsc packet buffer. Packet buffer is capable of
76 If a packet buffer is used for data sharing between two cores then
87 determine the size of the packet buffer.
93 bool "Clear allocated packet"
95 When enabled packet space is zeroed before returning from allocation.
|
| /Zephyr-Core-3.6.0/include/zephyr/net/ |
| D | capture.h | 2 * @brief Network packet capture definitions
23 * @brief Network packet capture support functions
24 * @defgroup net_capture Network packet capture
58 * @brief Setup network packet capturing support.
70 * @return 0 if ok, <0 if network packet capture setup failed
76 * @brief Cleanup network packet capturing support.
84 * @return 0 if ok, <0 if network packet capture cleanup failed
101 * @brief Enable network packet capturing support.
110 * @return 0 if ok, <0 if network packet capture enable failed
128 * @brief Is network packet capture enabled or disabled.
[all …]
|
| D | net_pkt_filter.h | 2 * @brief Network packet filtering public header file
4 * The network packet filtering provides a mechanism for deciding the fate
5 * of an incoming or outgoing packet based on a set of basic rules.
28 * @brief Network Packet Filter API
29 * @defgroup net_pkt_filter Network Packet Filter API
44 npf_test_fn_t *fn; /**< packet condition test function */
55 /** @brief Default rule list termination for accepting a packet */
57 /** @brief Default rule list termination for rejecting a packet */
142 * @brief Statically define one packet filter rule
146 * network packet path.
[all …]
|
| D | coap.h | 36 * @brief Set of CoAP packet options we are aware of.
40 * that all options must be added to a packet in numeric order.
94 * The packet is a request or response the destination end-point must
101 * The packet is a request or response that doesn't
114 * Rejecting a packet for any reason is done by sending a message
129 * @brief Set of response codes available for a response packet.
268 * @brief Representation of a CoAP Packet.
273 uint16_t max_len; /**< Max CoAP packet data length */
276 uint16_t delta; /**< Used for delta calculation in CoAP packet */
333 uint16_t len; /**< Length of the CoAP packet */
[all …]
|
| /Zephyr-Core-3.6.0/tests/lib/mpsc_pbuf/src/ |
| D | concurrent.c | 115 static void test_fail(int line, struct test_packet *packet) in test_fail() argument
119 test_failed_cnt = packet->data; in test_fail()
120 test_failed_ctx = packet->ctx; in test_fail()
125 static void consume_check(struct test_packet *packet) in consume_check() argument
127 bool res = track_consume(packet->ctx, packet->data); in consume_check()
130 test_fail(__LINE__, packet); in consume_check()
134 for (int i = 0; i < packet->len - 1; i++) { in consume_check()
135 if (packet->buf[i] != packet->data + i) { in consume_check()
136 test_fail(__LINE__, packet); in consume_check()
143 struct test_packet *packet = (struct test_packet *)item; in drop() local
[all …]
|
| /Zephyr-Core-3.6.0/include/zephyr/drivers/console/ |
| D | uart_mcumgr.h | 33 * @brief Function that gets called when an mcumgr packet is received.
35 * Function that gets called when an mcumgr packet is received. This function
39 * @param rx_buf A buffer containing the incoming mcumgr packet.
44 * @brief Sends an mcumgr packet over UART.
46 * @param data Buffer containing the mcumgr packet to send.
64 * mcumgr request packet is received.
67 * packet is received.
|
| /Zephyr-Core-3.6.0/scripts/coredump/gdbstubs/ |
| D | gdbstub.py | 45 # Get a full packet
49 # End of packet
59 logger.debug(f"Received GDB packet: {data}")
88 logger.debug(f"Sending GDB packet: {pkt}")
93 # the '?' packet
101 # the 'g' packet for reading a group of registers
105 # the 'G' packet for writing to a group of registers
111 # the 'p' packet for reading a single register
115 # the 'P' packet for writing to registers
121 # the 'm' packet for reading memory: m<addr>,<len>
[all …]
|
| /Zephyr-Core-3.6.0/tests/kernel/lifo/lifo_usage/src/ |
| D | main.c | 81 void *packet = k_lifo_get(&scratch_lifo_packets_lifo, K_NO_WAIT); in get_scratch_packet() local
83 zassert_true(packet != NULL); in get_scratch_packet()
84 return packet; in get_scratch_packet()
87 static void put_scratch_packet(void *packet) in put_scratch_packet() argument
89 k_lifo_put(&scratch_lifo_packets_lifo, packet); in put_scratch_packet()
270 void *packet; in ZTEST() local
278 packet = k_lifo_get(&lifo_timeout[0], K_MSEC(timeout)); in ZTEST()
280 zassert_is_null(packet); in ZTEST()
285 packet = k_lifo_get(&lifo_timeout[0], K_NO_WAIT); in ZTEST()
286 zassert_is_null(packet); in ZTEST()
[all …]
|
| /Zephyr-Core-3.6.0/tests/kernel/fifo/fifo_timeout/src/ |
| D | main.c | 90 void *packet = k_fifo_get(&scratch_fifo_packets_fifo, K_NO_WAIT); in get_scratch_packet() local
92 zassert_true(packet != NULL); in get_scratch_packet()
93 return packet; in get_scratch_packet()
96 static void put_scratch_packet(void *packet) in put_scratch_packet() argument
98 k_fifo_put(&scratch_fifo_packets_fifo, packet); in put_scratch_packet()
126 void *packet; in test_thread_pend_and_timeout() local
131 packet = k_fifo_get(d->fifo, K_MSEC(d->timeout)); in test_thread_pend_and_timeout()
132 zassert_true(packet == NULL); in test_thread_pend_and_timeout()
203 void *packet; in test_thread_pend_and_get_data() local
205 packet = k_fifo_get(d->fifo, K_MSEC(d->timeout)); in test_thread_pend_and_get_data()
[all …]
|
| /Zephyr-Core-3.6.0/subsys/mgmt/ec_host_cmd/backends/ |
| D | ec_host_cmd_backend_shi.h | 28 * 8. (response packet) - AP reads response packet
47 * Framing byte which precedes a response packet from the EC. After sending a
49 * clock in the response packet.
54 * Padding bytes which are clocked out after the end of a response packet.
60 * that the AP will send a valid packet header (starting with
79 * EC received bad data from the AP, such as a packet header with an invalid
93 * by the AP as part of a request packet, or (for old-style ECs) is processing
94 * a fully received packet but is not ready to respond yet.
|
