summaryrefslogtreecommitdiff
path: root/Kernel/Net/UDPSocket.cpp
diff options
context:
space:
mode:
authorAndreas Kling <kling@serenityos.org>2020-12-18 17:57:58 +0100
committerAndreas Kling <kling@serenityos.org>2020-12-18 19:22:26 +0100
commitbefabe31c9affc8a6822a4d84b74b5fb9a5be77f (patch)
tree8fc9eece2e62040a11526a62165bf455f0f38af2 /Kernel/Net/UDPSocket.cpp
parent8cc81c2953d247eaa7c13227ed5d78f471cc21b4 (diff)
downloadserenity-befabe31c9affc8a6822a4d84b74b5fb9a5be77f.zip
Kernel/Net: Avoid a heap allocation for every outgoing UDP packet
We can use a stack buffer to build the UDP packet instead.
Diffstat (limited to 'Kernel/Net/UDPSocket.cpp')
-rw-r--r--Kernel/Net/UDPSocket.cpp15
1 files changed, 9 insertions, 6 deletions
diff --git a/Kernel/Net/UDPSocket.cpp b/Kernel/Net/UDPSocket.cpp
index 8698201518..0ee41ab36d 100644
--- a/Kernel/Net/UDPSocket.cpp
+++ b/Kernel/Net/UDPSocket.cpp
@@ -96,16 +96,19 @@ KResultOr<size_t> UDPSocket::protocol_send(const UserOrKernelBuffer& data, size_
auto routing_decision = route_to(peer_address(), local_address(), bound_interface());
if (routing_decision.is_zero())
return KResult(-EHOSTUNREACH);
- auto buffer = ByteBuffer::create_zeroed(sizeof(UDPPacket) + data_length);
- auto& udp_packet = *(UDPPacket*)(buffer.data());
+ const size_t buffer_size = sizeof(UDPPacket) + data_length;
+
+ alignas(UDPPacket) u8 buffer[buffer_size];
+ new (buffer) UDPPacket;
+
+ auto& udp_packet = *reinterpret_cast<UDPPacket*>(buffer);
udp_packet.set_source_port(local_port());
udp_packet.set_destination_port(peer_port());
- udp_packet.set_length(sizeof(UDPPacket) + data_length);
+ udp_packet.set_length(buffer_size);
if (!data.read(udp_packet.payload(), data_length))
return KResult(-EFAULT);
- klog() << "sending as udp packet from " << routing_decision.adapter->ipv4_address().to_string().characters() << ":" << local_port() << " to " << peer_address().to_string().characters() << ":" << peer_port() << "!";
- auto udp_packet_buffer = UserOrKernelBuffer::for_kernel_buffer((u8*)&udp_packet);
- routing_decision.adapter->send_ipv4(routing_decision.next_hop, peer_address(), IPv4Protocol::UDP, udp_packet_buffer, buffer.size(), ttl());
+
+ routing_decision.adapter->send_ipv4(routing_decision.next_hop, peer_address(), IPv4Protocol::UDP, UserOrKernelBuffer::for_kernel_buffer(buffer), buffer_size, ttl());
return data_length;
}