IPv4 UDP packets are given to application
with specified UDP destination port given
by user.
Signed-off-by: Rakesh Kudurumalla <rkuduruma...@marvell.com>
---
doc/api/doxy-api-index.md | 3 +-
doc/guides/prog_guide/graph_lib.rst | 25 ++
.../img/graph_inbuilt_node_flow.svg | 165 ++++++++-----
lib/node/meson.build | 2 +
lib/node/rte_node_udp4_input_api.h | 60 +++++
lib/node/udp4_input.c | 226 ++++++++++++++++++
lib/node/version.map | 2 +
7 files changed, 417 insertions(+), 66 deletions(-)
create mode 100644 lib/node/rte_node_udp4_input_api.h
create mode 100644 lib/node/udp4_input.c
diff --git a/doc/api/doxy-api-index.md b/doc/api/doxy-api-index.md
index 3bc8778981..b81777b3fb 100644
--- a/doc/api/doxy-api-index.md
+++ b/doc/api/doxy-api-index.md
@@ -209,7 +209,8 @@ The public API headers are grouped by topics:
* graph_nodes:
[eth_node](@ref rte_node_eth_api.h),
[ip4_node](@ref rte_node_ip4_api.h),
- [ip6_node](@ref rte_node_ip6_api.h)
+ [ip6_node](@ref rte_node_ip6_api.h),
+ [udp4_input_node](@ref rte_node_udp4_input_api.h)
- **basic**:
[bitops](@ref rte_bitops.h),
diff --git a/doc/guides/prog_guide/graph_lib.rst
b/doc/guides/prog_guide/graph_lib.rst
index eaa8ee337e..98473383f1 100644
--- a/doc/guides/prog_guide/graph_lib.rst
+++ b/doc/guides/prog_guide/graph_lib.rst
@@ -513,3 +513,28 @@ On packet_type lookup failure, objects are redirected to
``pkt_drop`` node.
depth to receive to packets.
To achieve home run, node use ``rte_node_stream_move()`` as mentioned in above
sections.
+
+udp4_input
+~~~~~~~~~~
+This node is an intermediate node that does udp destination port lookup for
+the received ipv4 packets and the result determines each packets next node.
+
+User registers a new node ``udp4_input`` into graph library during
initialization
+and attach user specified node as edege to this node using
+``rte_node_udp4_usr_node_add()``, and create empty hash table with destination
+port and node id as its feilds.
+
+After successful addition of user node as edege, edge id is returned to the
user.
+
+User would register ``ip4_lookup`` table with specified ip address and 32 bit
as mask
+for ip filtration using api ``rte_node_ip4_route_add()``.
+
+After graph is created user would update hash table with custom port with
+and previously obtained edge id using API ``rte_node_udp4_dst_port_add()``.
+
+When packet is received lpm look up is performed if ip is matched the packet
+is handed over to ip4_local node, then packet is verified for udp proto and
+on success packet is enqueued to ``udp4_input`` node.
+
+Hash lookup is performed in ``udp4_input`` node with registered destination
port
+and destination port in UDP packet , on success packet is handed to
``udp_user_node``.
diff --git a/doc/guides/prog_guide/img/graph_inbuilt_node_flow.svg
b/doc/guides/prog_guide/img/graph_inbuilt_node_flow.svg
index 7a3ace48dc..5db96adb01 100644
--- a/doc/guides/prog_guide/img/graph_inbuilt_node_flow.svg
+++ b/doc/guides/prog_guide/img/graph_inbuilt_node_flow.svg
@@ -39,192 +39,227 @@ digraph dpdk_inbuilt_nodes_flow {
kernel_tx -> kernel_rx [color="red" style="dashed"]
ip4_lookup -> ip4_local
ip4_local -> pkt_drop [color="cyan" style="dashed"]
+ ip4_local -> udp4_input [ label="udpv4"]
+ udp4_input -> udp_user_node
+ udp4_input -> pkt_drop [color="cyan" style="dashed"]
+
}
-->
<!-- input nodes -->
<!-- Title: dpdk_inbuilt_nodes_flow Pages: 1 -->
-<svg width="525pt" height="458pt"
- viewBox="0.00 0.00 524.91 458.00" xmlns="http://www.w3.org/2000/svg";
xmlns:xlink="http://www.w3.org/1999/xlink";>
-<g id="graph0" class="graph" transform="scale(1 1) rotate(0) translate(4 454)">
+<svg width="631pt" height="437pt"
+ viewBox="0.00 0.00 630.95 437.00" xmlns="http://www.w3.org/2000/svg";
xmlns:xlink="http://www.w3.org/1999/xlink";>
+<g id="graph0" class="graph" transform="scale(1 1) rotate(0) translate(4 433)">
<title>dpdk_inbuilt_nodes_flow</title>
-<polygon fill="white" stroke="transparent" points="-4,4 -4,-454 520.91,-454
520.91,4 -4,4"/>
+<polygon fill="white" stroke="transparent" points="-4,4 -4,-433 626.95,-433
626.95,4 -4,4"/>
<!-- ethdev_rx -->
<g id="node1" class="node">
<title>ethdev_rx</title>
-<ellipse fill="none" stroke="green" cx="120" cy="-432" rx="56.59" ry="18"/>
-<text text-anchor="middle" x="120" y="-428.3" font-family="Times,serif"
font-size="14.00">ethdev_rx</text>
+<ellipse fill="none" stroke="green" cx="261.95" cy="-411" rx="56.59" ry="18"/>
+<text text-anchor="middle" x="261.95" y="-407.3" font-family="Times,serif"
font-size="14.00">ethdev_rx</text>
</g>
<!-- pkt_cls -->
<g id="node6" class="node">
<title>pkt_cls</title>
-<ellipse fill="none" stroke="red" cx="120" cy="-359" rx="42.79" ry="18"/>
-<text text-anchor="middle" x="120" y="-355.3" font-family="Times,serif"
font-size="14.00">pkt_cls</text>
+<ellipse fill="none" stroke="red" cx="261.95" cy="-338" rx="42.79" ry="18"/>
+<text text-anchor="middle" x="261.95" y="-334.3" font-family="Times,serif"
font-size="14.00">pkt_cls</text>
</g>
<!-- ethdev_rx->pkt_cls -->
<g id="edge1" class="edge">
<title>ethdev_rx->pkt_cls</title>
-<path fill="none" stroke="black" d="M120,-413.81C120,-405.79 120,-396.05
120,-387.07"/>
-<polygon fill="black" stroke="black" points="123.5,-387.03 120,-377.03
116.5,-387.03 123.5,-387.03"/>
+<path fill="none" stroke="black" d="M261.95,-392.81C261.95,-384.79
261.95,-375.05 261.95,-366.07"/>
+<polygon fill="black" stroke="black" points="265.45,-366.03 261.95,-356.03
258.45,-366.03 265.45,-366.03"/>
</g>
<!-- kernel_rx -->
<g id="node2" class="node">
<title>kernel_rx</title>
-<ellipse fill="none" stroke="green" cx="82" cy="-199" rx="53.89" ry="18"/>
-<text text-anchor="middle" x="82" y="-195.3" font-family="Times,serif"
font-size="14.00">kernel_rx</text>
+<ellipse fill="none" stroke="green" cx="53.95" cy="-178" rx="53.89" ry="18"/>
+<text text-anchor="middle" x="53.95" y="-174.3" font-family="Times,serif"
font-size="14.00">kernel_rx</text>
</g>
<!-- kernel_rx->pkt_cls -->
<g id="edge2" class="edge">
<title>kernel_rx->pkt_cls</title>
-<path fill="none" stroke="black" d="M70.87,-216.92C60.28,-235.27 47.29,-265.24
57,-290 64.12,-308.16 78.62,-324.37 91.92,-336.4"/>
-<polygon fill="black" stroke="black" points="89.69,-339.1 99.54,-342.99
94.26,-333.8 89.69,-339.1"/>
+<path fill="none" stroke="black" d="M74.75,-194.8C112.31,-223.33
191.45,-283.45 233.8,-315.62"/>
+<polygon fill="black" stroke="black" points="231.92,-318.59 242,-321.85
236.16,-313.01 231.92,-318.59"/>
</g>
<!-- ethdev_tx -->
<g id="node3" class="node">
<title>ethdev_tx</title>
-<ellipse fill="none" stroke="magenta" cx="338" cy="-91" rx="55.79" ry="18"/>
-<text text-anchor="middle" x="338" y="-87.3" font-family="Times,serif"
font-size="14.00">ethdev_tx</text>
+<ellipse fill="none" stroke="magenta" cx="347.95" cy="-91" rx="55.79" ry="18"/>
+<text text-anchor="middle" x="347.95" y="-87.3" font-family="Times,serif"
font-size="14.00">ethdev_tx</text>
</g>
<!-- pkt_drop -->
<g id="node4" class="node">
<title>pkt_drop</title>
-<ellipse fill="none" stroke="cyan" cx="254" cy="-18" rx="51.99" ry="18"/>
-<text text-anchor="middle" x="254" y="-14.3" font-family="Times,serif"
font-size="14.00">pkt_drop</text>
+<ellipse fill="none" stroke="cyan" cx="404.95" cy="-18" rx="51.99" ry="18"/>
+<text text-anchor="middle" x="404.95" y="-14.3" font-family="Times,serif"
font-size="14.00">pkt_drop</text>
</g>
<!-- ethdev_tx->pkt_drop -->
<g id="edge14" class="edge">
<title>ethdev_tx->pkt_drop</title>
-<path fill="none" stroke="cyan" stroke-dasharray="5,2"
d="M318.94,-73.89C307.58,-64.29 293,-51.96 280.53,-41.42"/>
-<polygon fill="cyan" stroke="cyan" points="282.59,-38.58 272.7,-34.8
278.07,-43.93 282.59,-38.58"/>
+<path fill="none" stroke="cyan" stroke-dasharray="5,2"
d="M361.45,-73.17C368.55,-64.33 377.39,-53.33 385.23,-43.55"/>
+<polygon fill="cyan" stroke="cyan" points="388,-45.69 391.53,-35.71
382.54,-41.31 388,-45.69"/>
</g>
<!-- kernel_tx -->
<g id="node5" class="node">
<title>kernel_tx</title>
-<ellipse fill="none" stroke="blue" cx="120" cy="-272" rx="53.89" ry="18"/>
-<text text-anchor="middle" x="120" y="-268.3" font-family="Times,serif"
font-size="14.00">kernel_tx</text>
+<ellipse fill="none" stroke="blue" cx="53.95" cy="-251" rx="53.89" ry="18"/>
+<text text-anchor="middle" x="53.95" y="-247.3" font-family="Times,serif"
font-size="14.00">kernel_tx</text>
</g>
<!-- kernel_tx->kernel_rx -->
<g id="edge16" class="edge">
<title>kernel_tx->kernel_rx</title>
-<path fill="none" stroke="red" stroke-dasharray="5,2"
d="M110.99,-254.17C106.52,-245.81 101,-235.51 95.99,-226.14"/>
-<polygon fill="red" stroke="red" points="99.01,-224.36 91.2,-217.2
92.84,-227.67 99.01,-224.36"/>
+<path fill="none" stroke="red" stroke-dasharray="5,2"
d="M53.95,-232.81C53.95,-224.79 53.95,-215.05 53.95,-206.07"/>
+<polygon fill="red" stroke="red" points="57.45,-206.03 53.95,-196.03
50.45,-206.03 57.45,-206.03"/>
</g>
<!-- pkt_cls->pkt_drop -->
<g id="edge15" class="edge">
<title>pkt_cls->pkt_drop</title>
-<path fill="none" stroke="cyan" stroke-dasharray="5,2"
d="M84,-348.97C48.65,-337.7 0,-314.61 0,-273 0,-273 0,-273 0,-90 0,-49.99
118.4,-31.52 193.52,-23.82"/>
-<polygon fill="cyan" stroke="cyan" points="194.21,-27.27 203.82,-22.81
193.52,-20.31 194.21,-27.27"/>
+<path fill="none" stroke="cyan" stroke-dasharray="5,2"
d="M304.77,-335.88C400.4,-332.2 622.95,-316.71 622.95,-252 622.95,-252
622.95,-252 622.95,-90 622.95,-56.33 527.72,-36.15 463.14,-26.34"/>
+<polygon fill="cyan" stroke="cyan" points="463.46,-22.85 453.06,-24.85
462.44,-29.77 463.46,-22.85"/>
</g>
<!-- pkt_cls->kernel_tx -->
<g id="edge5" class="edge">
<title>pkt_cls->kernel_tx</title>
-<path fill="none" stroke="blue" d="M120,-340.8C120,-329.16 120,-313.55
120,-300.24"/>
-<polygon fill="blue" stroke="blue" points="123.5,-300.18 120,-290.18
116.5,-300.18 123.5,-300.18"/>
-<text text-anchor="middle" x="172.5" y="-311.8" font-family="Times,serif"
font-size="14.00">exception pkts</text>
+<path fill="none" stroke="blue" d="M219.14,-335.96C164.86,-333.64
75.77,-326.15 54.95,-302 49.6,-295.81 48.06,-287.4 48.24,-279.24"/>
+<polygon fill="blue" stroke="blue" points="51.73,-279.54 49.23,-269.24
44.76,-278.84 51.73,-279.54"/>
+<text text-anchor="middle" x="107.45" y="-290.8" font-family="Times,serif"
font-size="14.00">exception pkts</text>
</g>
<!-- ip4_lookup -->
<g id="node7" class="node">
<title>ip4_lookup</title>
-<ellipse fill="none" stroke="black" cx="252" cy="-272" rx="60.39" ry="18"/>
-<text text-anchor="middle" x="252" y="-268.3" font-family="Times,serif"
font-size="14.00">ip4_lookup</text>
+<ellipse fill="none" stroke="black" cx="261.95" cy="-251" rx="60.39" ry="18"/>
+<text text-anchor="middle" x="261.95" y="-247.3" font-family="Times,serif"
font-size="14.00">ip4_lookup</text>
</g>
<!-- pkt_cls->ip4_lookup -->
<g id="edge3" class="edge">
<title>pkt_cls->ip4_lookup</title>
-<path fill="none" stroke="black" d="M160.54,-352.79C182.64,-348.15
209.23,-339.41 228,-323 235.09,-316.81 240.26,-308.05 243.95,-299.6"/>
-<polygon fill="black" stroke="black" points="247.32,-300.57 247.62,-289.98
240.78,-298.07 247.32,-300.57"/>
-<text text-anchor="middle" x="254.5" y="-311.8" font-family="Times,serif"
font-size="14.00">ipv4</text>
+<path fill="none" stroke="black" d="M261.95,-319.8C261.95,-308.16
261.95,-292.55 261.95,-279.24"/>
+<polygon fill="black" stroke="black" points="265.45,-279.18 261.95,-269.18
258.45,-279.18 265.45,-279.18"/>
+<text text-anchor="middle" x="277.45" y="-290.8" font-family="Times,serif"
font-size="14.00">ipv4</text>
</g>
<!-- ip6_lookup -->
<g id="node8" class="node">
<title>ip6_lookup</title>
-<ellipse fill="none" stroke="black" cx="439" cy="-272" rx="60.39" ry="18"/>
-<text text-anchor="middle" x="439" y="-268.3" font-family="Times,serif"
font-size="14.00">ip6_lookup</text>
+<ellipse fill="none" stroke="black" cx="492.95" cy="-251" rx="60.39" ry="18"/>
+<text text-anchor="middle" x="492.95" y="-247.3" font-family="Times,serif"
font-size="14.00">ip6_lookup</text>
</g>
<!-- pkt_cls->ip6_lookup -->
<g id="edge4" class="edge">
<title>pkt_cls->ip6_lookup</title>
-<path fill="none" stroke="black" d="M157.52,-350.25C188.82,-343.6
234.51,-333.46 274,-323 313.2,-312.62 357.13,-299.22 389.79,-288.91"/>
-<polygon fill="black" stroke="black" points="391.08,-292.17 399.55,-285.81
388.96,-285.5 391.08,-292.17"/>
-<text text-anchor="middle" x="339.5" y="-311.8" font-family="Times,serif"
font-size="14.00">ipv6</text>
+<path fill="none" stroke="black" d="M293.1,-325.54C332.57,-311.01
400.93,-285.86 446.54,-269.07"/>
+<polygon fill="black" stroke="black" points="448.02,-272.26 456.2,-265.52
445.61,-265.69 448.02,-272.26"/>
+<text text-anchor="middle" x="407.45" y="-290.8" font-family="Times,serif"
font-size="14.00">ipv6</text>
</g>
<!-- ip4_lookup->pkt_drop -->
<g id="edge7" class="edge">
<title>ip4_lookup->pkt_drop</title>
-<path fill="none" stroke="cyan" stroke-dasharray="5,2"
d="M239.17,-254.03C232.31,-243.87 224.56,-230.37 221,-217 204.89,-156.57
227.58,-83.56 242.59,-45.31"/>
-<polygon fill="cyan" stroke="cyan" points="245.89,-46.5 246.4,-35.92
239.4,-43.87 245.89,-46.5"/>
+<path fill="none" stroke="cyan" stroke-dasharray="5,2"
d="M258.85,-232.91C253.68,-198.83 247.1,-121.54 282.95,-73 299.1,-51.12
326.1,-37.95 350.6,-30.11"/>
+<polygon fill="cyan" stroke="cyan" points="351.6,-33.46 360.19,-27.26
349.61,-26.75 351.6,-33.46"/>
</g>
<!-- ip4_rewrite -->
<g id="node9" class="node">
<title>ip4_rewrite</title>
-<ellipse fill="none" stroke="black" cx="294" cy="-199" rx="63.89" ry="18"/>
-<text text-anchor="middle" x="294" y="-195.3" font-family="Times,serif"
font-size="14.00">ip4_rewrite</text>
+<ellipse fill="none" stroke="black" cx="347.95" cy="-178" rx="63.89" ry="18"/>
+<text text-anchor="middle" x="347.95" y="-174.3" font-family="Times,serif"
font-size="14.00">ip4_rewrite</text>
</g>
<!-- ip4_lookup->ip4_rewrite -->
<g id="edge6" class="edge">
<title>ip4_lookup->ip4_rewrite</title>
-<path fill="none" stroke="black" d="M261.95,-254.17C266.95,-245.72
273.12,-235.29 278.71,-225.85"/>
-<polygon fill="black" stroke="black" points="281.75,-227.59 283.83,-217.2
275.72,-224.02 281.75,-227.59"/>
+<path fill="none" stroke="black" d="M281.46,-233.89C292.92,-224.42
307.6,-212.31 320.25,-201.87"/>
+<polygon fill="black" stroke="black" points="322.73,-204.36 328.21,-195.29
318.27,-198.96 322.73,-204.36"/>
</g>
<!-- ip4_local -->
<g id="node11" class="node">
<title>ip4_local</title>
-<ellipse fill="none" stroke="black" cx="136" cy="-145" rx="51.19" ry="18"/>
-<text text-anchor="middle" x="136" y="-141.3" font-family="Times,serif"
font-size="14.00">ip4_local</text>
+<ellipse fill="none" stroke="black" cx="176.95" cy="-178" rx="51.19" ry="18"/>
+<text text-anchor="middle" x="176.95" y="-174.3" font-family="Times,serif"
font-size="14.00">ip4_local</text>
</g>
<!-- ip4_lookup->ip4_local -->
<g id="edge17" class="edge">
<title>ip4_lookup->ip4_local</title>
-<path fill="none" stroke="black" d="M218.11,-256.86C207.64,-251.39
196.61,-244.41 188,-236 169.45,-217.88 155.34,-191.74 146.53,-172.29"/>
-<polygon fill="black" stroke="black" points="149.72,-170.86 142.52,-163.08
143.3,-173.65 149.72,-170.86"/>
+<path fill="none" stroke="black" d="M242.66,-233.89C231.17,-224.29
216.41,-211.96 203.79,-201.42"/>
+<polygon fill="black" stroke="black" points="205.78,-198.53 195.86,-194.8
201.29,-203.9 205.78,-198.53"/>
</g>
<!-- ip6_lookup->pkt_drop -->
<g id="edge11" class="edge">
<title>ip6_lookup->pkt_drop</title>
-<path fill="none" stroke="cyan" stroke-dasharray="5,2"
d="M470.57,-256.44C486.08,-247.46 503.27,-234.31 512,-217 519.2,-202.71
517.24,-196.12 512,-181 486.88,-108.48 466,-83.15 395,-54 367.69,-42.79
335.88,-34.51 309.39,-28.83"/>
-<polygon fill="cyan" stroke="cyan" points="310.02,-25.39 299.52,-26.78
308.6,-32.24 310.02,-25.39"/>
+<path fill="none" stroke="cyan" stroke-dasharray="5,2"
d="M524.51,-235.44C540.02,-226.46 557.22,-213.31 565.95,-196 573.15,-181.71
572.55,-174.57 565.95,-160 540.59,-104.08 480.88,-61.6 441.74,-38.51"/>
+<polygon fill="cyan" stroke="cyan" points="443.16,-35.29 432.75,-33.34
439.67,-41.36 443.16,-35.29"/>
</g>
<!-- ip6_rewrite -->
<g id="node10" class="node">
<title>ip6_rewrite</title>
-<ellipse fill="none" stroke="black" cx="439" cy="-199" rx="63.89" ry="18"/>
-<text text-anchor="middle" x="439" y="-195.3" font-family="Times,serif"
font-size="14.00">ip6_rewrite</text>
+<ellipse fill="none" stroke="black" cx="492.95" cy="-178" rx="63.89" ry="18"/>
+<text text-anchor="middle" x="492.95" y="-174.3" font-family="Times,serif"
font-size="14.00">ip6_rewrite</text>
</g>
<!-- ip6_lookup->ip6_rewrite -->
<g id="edge10" class="edge">
<title>ip6_lookup->ip6_rewrite</title>
-<path fill="none" stroke="black" d="M439,-253.81C439,-245.79 439,-236.05
439,-227.07"/>
-<polygon fill="black" stroke="black" points="442.5,-227.03 439,-217.03
435.5,-227.03 442.5,-227.03"/>
+<path fill="none" stroke="black" d="M492.95,-232.81C492.95,-224.79
492.95,-215.05 492.95,-206.07"/>
+<polygon fill="black" stroke="black" points="496.45,-206.03 492.95,-196.03
489.45,-206.03 496.45,-206.03"/>
</g>
<!-- ip4_rewrite->ethdev_tx -->
<g id="edge8" class="edge">
<title>ip4_rewrite->ethdev_tx</title>
-<path fill="none" stroke="green" d="M301.07,-180.97C308.09,-164.05
318.96,-137.86 327.09,-118.28"/>
-<polygon fill="green" stroke="green" points="330.35,-119.57 330.95,-108.99
323.88,-116.88 330.35,-119.57"/>
+<path fill="none" stroke="green" d="M347.95,-159.8C347.95,-148.16
347.95,-132.55 347.95,-119.24"/>
+<polygon fill="green" stroke="green" points="351.45,-119.18 347.95,-109.18
344.45,-119.18 351.45,-119.18"/>
</g>
<!-- ip4_rewrite->pkt_drop -->
<g id="edge9" class="edge">
<title>ip4_rewrite->pkt_drop</title>
-<path fill="none" stroke="cyan" stroke-dasharray="5,2"
d="M289.85,-180.97C285.53,-163.07 278.61,-134.1 273,-109 268.3,-87.99
263.29,-64.16 259.59,-46.3"/>
-<polygon fill="cyan" stroke="cyan" points="262.97,-45.37 257.52,-36.28
256.11,-46.78 262.97,-45.37"/>
+<path fill="none" stroke="cyan" stroke-dasharray="5,2"
d="M370.32,-161.1C385.53,-148.83 404.37,-130.37 412.95,-109 421.04,-88.82
418.02,-64.12 413.56,-45.7"/>
+<polygon fill="cyan" stroke="cyan" points="416.9,-44.66 410.91,-35.93
410.15,-46.49 416.9,-44.66"/>
</g>
<!-- ip6_rewrite->ethdev_tx -->
<g id="edge12" class="edge">
<title>ip6_rewrite->ethdev_tx</title>
-<path fill="none" stroke="green" d="M423.22,-181.44C406.47,-163.86
379.84,-135.91 360.81,-115.94"/>
-<polygon fill="green" stroke="green" points="363.1,-113.27 353.67,-108.45
358.03,-118.1 363.1,-113.27"/>
+<path fill="none" stroke="green" d="M466.35,-161.41C442.8,-147.6
408.27,-127.36 382.57,-112.3"/>
+<polygon fill="green" stroke="green" points="384.28,-109.24 373.88,-107.21
380.74,-115.28 384.28,-109.24"/>
</g>
<!-- ip6_rewrite->pkt_drop -->
<g id="edge13" class="edge">
<title>ip6_rewrite->pkt_drop</title>
-<path fill="none" stroke="cyan" stroke-dasharray="5,2"
d="M438.77,-180.67C437.49,-154.09 431.22,-103.19 403,-73 379.35,-47.7
342.93,-34.22 312.02,-27.06"/>
-<polygon fill="cyan" stroke="cyan" points="312.71,-23.63 302.2,-24.95
311.24,-30.47 312.71,-23.63"/>
+<path fill="none" stroke="cyan" stroke-dasharray="5,2"
d="M485.15,-159.86C473.93,-135.7 452.15,-90.48 429.95,-54 427.97,-50.75
425.78,-47.4 423.55,-44.13"/>
+<polygon fill="cyan" stroke="cyan" points="426.28,-41.92 417.67,-35.75
420.55,-45.94 426.28,-41.92"/>
</g>
<!-- ip4_local->pkt_drop -->
<g id="edge18" class="edge">
<title>ip4_local->pkt_drop</title>
-<path fill="none" stroke="cyan" stroke-dasharray="5,2"
d="M142.47,-126.87C150.6,-107.23 166.18,-75.04 188,-54 195,-47.25 203.56,-41.45
212.16,-36.63"/>
-<polygon fill="cyan" stroke="cyan" points="213.85,-39.7 221.08,-31.95
210.6,-33.5 213.85,-39.7"/>
+<path fill="none" stroke="cyan" stroke-dasharray="5,2"
d="M191.02,-160.51C195.47,-154.86 200.21,-148.35 203.95,-142 225.57,-105.29
209.02,-81.03 241.95,-54 257.83,-40.96 306.22,-31.62 346.19,-25.89"/>
+<polygon fill="cyan" stroke="cyan" points="346.72,-29.35 356.14,-24.51
345.75,-22.41 346.72,-29.35"/>
+</g>
+<!-- udp4_input -->
+<g id="node12" class="node">
+<title>udp4_input</title>
+<ellipse fill="none" stroke="black" cx="126.95" cy="-91" rx="63.09" ry="18"/>
+<text text-anchor="middle" x="126.95" y="-87.3" font-family="Times,serif"
font-size="14.00">udp4_input</text>
+</g>
+<!-- ip4_local->udp4_input -->
+<g id="edge19" class="edge">
+<title>ip4_local->udp4_input</title>
+<path fill="none" stroke="black" d="M167.07,-160.21C159.99,-148.18
150.33,-131.75 142.26,-118.03"/>
+<polygon fill="black" stroke="black" points="145.06,-115.89 136.97,-109.05
139.03,-119.44 145.06,-115.89"/>
+<text text-anchor="middle" x="177.45" y="-130.8" font-family="Times,serif"
font-size="14.00">udpv4</text>
+</g>
+<!-- udp4_input->pkt_drop -->
+<g id="edge21" class="edge">
+<title>udp4_input->pkt_drop</title>
+<path fill="none" stroke="cyan" stroke-dasharray="5,2"
d="M154.75,-74.82C169.08,-67.56 187.05,-59.32 203.95,-54 250.51,-39.35
305.19,-30.33 345.76,-25.12"/>
+<polygon fill="cyan" stroke="cyan" points="346.26,-28.59 355.75,-23.88
345.4,-21.64 346.26,-28.59"/>
+</g>
+<!-- udp_user_node -->
+<g id="node13" class="node">
+<title>udp_user_node</title>
+<ellipse fill="none" stroke="black" cx="126.95" cy="-18" rx="79.89" ry="18"/>
+<text text-anchor="middle" x="126.95" y="-14.3" font-family="Times,serif"
font-size="14.00">udp_user_node</text>
+</g>
+<!-- udp4_input->udp_user_node -->
+<g id="edge20" class="edge">
+<title>udp4_input->udp_user_node</title>
+<path fill="none" stroke="black" d="M126.95,-72.81C126.95,-64.79 126.95,-55.05
126.95,-46.07"/>
+<polygon fill="black" stroke="black" points="130.45,-46.03 126.95,-36.03
123.45,-46.03 130.45,-46.03"/>
</g>
</g>
</svg>
diff --git a/lib/node/meson.build b/lib/node/meson.build
index c0d5b09e2f..c5b8ee656e 100644
--- a/lib/node/meson.build
+++ b/lib/node/meson.build
@@ -22,11 +22,13 @@ sources = files(
'null.c',
'pkt_cls.c',
'pkt_drop.c',
+ 'udp4_input.c',
)
headers = files(
'rte_node_eth_api.h',
'rte_node_ip4_api.h',
'rte_node_ip6_api.h',
+ 'rte_node_udp4_input_api.h',
)
# Strict-aliasing rules are violated by uint8_t[] to context size casts.
diff --git a/lib/node/rte_node_udp4_input_api.h
b/lib/node/rte_node_udp4_input_api.h
new file mode 100644
index 0000000000..7217b914ec
--- /dev/null
+++ b/lib/node/rte_node_udp4_input_api.h
@@ -0,0 +1,60 @@
+/* SPDX-License-Identifier: BSD-3-Clause
+ * Copyright(C) 2023 Marvell International Ltd.
+ */
+
+#ifndef __INCLUDE_RTE_NODE_UDP4_INPUT_API_H__
+#define __INCLUDE_RTE_NODE_UDP4_INPUT_API_H__
+
+/**
+ * @file rte_node_udp4_input_api.h
+ *
+ * @warning
+ * @b EXPERIMENTAL:
+ * All functions in this file may be changed or removed without prior notice.
+ *
+ * This API allows to control path functions of udp4_* nodes
+ * like udp4_input.
+ *
+ */
+#ifdef __cplusplus
+extern "C" {
+#endif
+
+#include <rte_common.h>
+#include <rte_compat.h>
+
+/**
+ * UDP4 lookup next nodes.
+ */
+enum rte_node_udp4_input_next {
+ RTE_NODE_UDP4_INPUT_NEXT_PKT_DROP,
+ /**< Packet drop node. */
+};
+
+/**
+ * Add usr node to receive udp4 frames.
+ *
+ * @param usr_node
+ * Node registered by user to receive data.
+ */
+__rte_experimental
+int rte_node_udp4_usr_node_add(const char *usr_node);
+
+/**
+ * Add udpv4 dst_port to lookup table.
+ *
+ * @param dst_port
+ * Dst Port of packet to be added for consumption.
+ * @param next_node
+ * Next node packet to be added for consumption.
+ * @return
+ * 0 on success, negative otherwise.
+ */
+__rte_experimental
+int rte_node_udp4_dst_port_add(uint32_t dst_port, rte_edge_t next_node);
+
+#ifdef __cplusplus
+}
+#endif
+
+#endif /* __INCLUDE_RTE_NODE_UDP4_API_H__ */
diff --git a/lib/node/udp4_input.c b/lib/node/udp4_input.c
new file mode 100644
index 0000000000..80cedce548
--- /dev/null
+++ b/lib/node/udp4_input.c
@@ -0,0 +1,226 @@
+/* SPDX-License-Identifier: BSD-3-Clause
+ * Copyright(C) 2023 Marvell International Ltd.
+ */
+
+#include <arpa/inet.h>
+#include <sys/socket.h>
+
+#include <rte_ethdev.h>
+#include <rte_ether.h>
+#include <rte_graph.h>
+#include <rte_graph_worker.h>
+#include <rte_ip.h>
+#include <rte_lpm.h>
+#include <rte_hash.h>
+#include <rte_fbk_hash.h>
+#include <rte_jhash.h>
+#include <rte_hash_crc.h>
+
+
+#include "rte_node_udp4_input_api.h"
+
+#include "node_private.h"
+
+#define UDP4_INPUT_HASH_TBL_SIZE 1024
+
+#define UDP4_INPUT_NODE_HASH(ctx) \
+ (((struct udp4_input_node_ctx *)ctx)->hash)
+
+#define UDP4_INPUT_NODE_NEXT_INDEX(ctx) \
+ (((struct udp4_input_node_ctx *)ctx)->next_index)
+
+
+/* UDP4 input global data struct */
+struct udp4_input_node_main {
+ struct rte_hash *hash_tbl[RTE_MAX_NUMA_NODES];
+};
+
+static struct udp4_input_node_main udp4_input_nm;
+
+struct udp4_input_node_ctx {
+ /* Socket's Hash table */
+ struct rte_hash *hash;
+ /* Cached next index */
+ uint16_t next_index;
+};
+
+struct flow_key {
+ uint32_t prt_dst;
+};
+
+static struct rte_hash_parameters udp4_params = {
+ .entries = UDP4_INPUT_HASH_TBL_SIZE,
+ .key_len = sizeof(uint32_t),
+ .hash_func = rte_jhash,
+ .hash_func_init_val = 0,
+ .socket_id = 0,
+};
+
+int
+rte_node_udp4_dst_port_add(uint32_t dst_port, rte_edge_t next_node)
+{
+ uint8_t socket;
+ int rc;
+
+ for (socket = 0; socket < RTE_MAX_NUMA_NODES; socket++) {
+ if (!udp4_input_nm.hash_tbl[socket])
+ continue;
+
+ rc = rte_hash_add_key_data(udp4_input_nm.hash_tbl[socket],
+ &dst_port, (void
*)(uintptr_t)next_node);
+ if (rc < 0) {
+ node_err("udp4_lookup", "Failed to add key for sock %u,
rc=%d",
+ socket, rc);
+ return rc;
+ }
+ }
+ return 0;
+}
+
+int
+rte_node_udp4_usr_node_add(const char *usr_node)
+{
+ const char *next_nodes = usr_node;
+ rte_node_t udp4_input_node_id, count;
+
+ udp4_input_node_id = rte_node_from_name("udp4_input");
+ count = rte_node_edge_update(udp4_input_node_id, RTE_EDGE_ID_INVALID,
+ &next_nodes, 1);
+ if (count == 0) {
+ node_dbg("udp4_input", "Adding usr node as edge to udp4_input
failed");
+ return count;
+ }
+ count = rte_node_edge_count(udp4_input_node_id) - 1;
+ return count;
+}
+
+static int
+setup_udp4_dstprt_hash(struct udp4_input_node_main *nm, int socket)
+{
+ struct rte_hash_parameters *hash_udp4 = &udp4_params;
+ char s[RTE_HASH_NAMESIZE];
+
+ /* One Hash table per socket */
+ if (nm->hash_tbl[socket])
+ return 0;
+
+ /* create Hash table */
+ snprintf(s, sizeof(s), "UDP4_INPUT_HASH_%d", socket);
+ hash_udp4->name = s;
+ hash_udp4->socket_id = socket;
+ nm->hash_tbl[socket] = rte_hash_create(hash_udp4);
+ if (nm->hash_tbl[socket] == NULL)
+ return -rte_errno;
+
+ return 0;
+}
+
+static int
+udp4_input_node_init(const struct rte_graph *graph, struct rte_node *node)
+{
+ uint16_t socket, lcore_id;
+ static uint8_t init_once;
+ int rc;
+
+ RTE_SET_USED(graph);
+ RTE_BUILD_BUG_ON(sizeof(struct udp4_input_node_ctx) > RTE_NODE_CTX_SZ);
+
+ if (!init_once) {
+
+ /* Setup HASH tables for all sockets */
+ RTE_LCORE_FOREACH(lcore_id)
+ {
+ socket = rte_lcore_to_socket_id(lcore_id);
+ rc = setup_udp4_dstprt_hash(&udp4_input_nm, socket);
+ if (rc) {
+ node_err("udp4_lookup",
+ "Failed to setup hash tbl for
sock %u, rc=%d",
+ socket, rc);
+ return rc;
+ }
+ }
+ init_once = 1;
+ }
+
+ UDP4_INPUT_NODE_HASH(node->ctx) = udp4_input_nm.hash_tbl[graph->socket];
+
+ node_dbg("udp4_input", "Initialized udp4_input node");
+ return 0;
+}
+
+static uint16_t
+udp4_input_node_process_scalar(struct rte_graph *graph, struct rte_node *node,
+ void **objs, uint16_t nb_objs)
+{
+ struct rte_hash *hash_tbl_handle = UDP4_INPUT_NODE_HASH(node->ctx);
+ rte_edge_t next_index, udplookup_node;
+ struct rte_udp_hdr *pkt_udp_hdr;
+ uint16_t last_spec = 0;
+ void **to_next, **from;
+ struct rte_mbuf *mbuf;
+ uint16_t held = 0;
+ uint16_t next = 0;
+ int i, rc;
+
+ /* Speculative next */
+ next_index = UDP4_INPUT_NODE_NEXT_INDEX(node->ctx);
+
+ from = objs;
+
+ to_next = rte_node_next_stream_get(graph, node, next_index, nb_objs);
+ for (i = 0; i < nb_objs; i++) {
+ struct flow_key key_port;
+
+ mbuf = (struct rte_mbuf *)objs[i];
+ pkt_udp_hdr = rte_pktmbuf_mtod_offset(mbuf, struct rte_udp_hdr
*,
+ sizeof(struct rte_ether_hdr) +
+ sizeof(struct rte_ipv4_hdr));
+
+ key_port.prt_dst = rte_cpu_to_be_16(pkt_udp_hdr->dst_port);
+ rc = rte_hash_lookup_data(hash_tbl_handle,
+ &key_port.prt_dst,
+ (void **)&udplookup_node);
+ next = (rc < 0) ? RTE_NODE_UDP4_INPUT_NEXT_PKT_DROP
+ : udplookup_node;
+
+ if (unlikely(next_index != next)) {
+ /* Copy things successfully speculated till now */
+ rte_memcpy(to_next, from, last_spec * sizeof(from[0]));
+ from += last_spec;
+ to_next += last_spec;
+ held += last_spec;
+ last_spec = 0;
+
+ rte_node_enqueue_x1(graph, node, next, from[0]);
+ from += 1;
+ } else {
+ last_spec += 1;
+ }
+ }
+ /* !!! Home run !!! */
+ if (likely(last_spec == nb_objs)) {
+ rte_node_next_stream_move(graph, node, next_index);
+ return nb_objs;
+ }
+ held += last_spec;
+ rte_memcpy(to_next, from, last_spec * sizeof(from[0]));
+ rte_node_next_stream_put(graph, node, next_index, held);
+ /* Save the last next used */
+ UDP4_INPUT_NODE_NEXT_INDEX(node->ctx) = next;
+
+ return nb_objs;
+}
+
+static struct rte_node_register udp4_input_node = {
+ .process = udp4_input_node_process_scalar,
+ .name = "udp4_input",
+
+ .init = udp4_input_node_init,
+
+ .nb_edges = RTE_NODE_UDP4_INPUT_NEXT_PKT_DROP + 1,
+ .next_nodes = {
+ [RTE_NODE_UDP4_INPUT_NEXT_PKT_DROP] = "pkt_drop",
+ },
+};
+
+RTE_NODE_REGISTER(udp4_input_node);
diff --git a/lib/node/version.map b/lib/node/version.map
index 40df308bfe..c51befce09 100644
--- a/lib/node/version.map
+++ b/lib/node/version.map
@@ -6,6 +6,8 @@ EXPERIMENTAL {
rte_node_ip4_rewrite_add;
rte_node_ip6_rewrite_add;
rte_node_ip6_route_add;
+ rte_node_udp4_usr_node_add;
+ rte_node_udp4_dst_port_add;
rte_node_logtype;
local: *;
};
--
2.25.1
