RGBCube/serenity
1
Fork 0
mirror of https://github.com/RGBCube/serenity synced 2025-05-31 07:48:11 +00:00
Code Issues Activity Actions

Kernel: Move incoming packet buffer off the NetworkTask stack

Browse source
This commit is contained in:
Conrad Pankoff 2019-12-28 10:07:56 +11:00 • committed by Andreas Kling
parent b5c3bc6a71
commit 876323fd7a
1 changed files with 7 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

13
Kernel/Net/NetworkTask.cpp
View file

@ -73,10 +73,13 @@ void NetworkTask_main()
return packet_size; return packet_size;
}; };
size_t buffer_size = 64 * KB;
auto buffer_region = MM.allocate_kernel_region(buffer_size, "Kernel Packet Buffer", Region::Access::Read | Region::Access::Write, false, true);
auto buffer = (u8*)buffer_region->vaddr().get();
kprintf("NetworkTask: Enter main loop.\n"); kprintf("NetworkTask: Enter main loop.\n");
for (;;) { for (;;) {
u8 packet[32 * KB]; size_t packet_size = dequeue_packet(buffer, buffer_size);
size_t packet_size = dequeue_packet(packet, sizeof(packet));
if (!packet_size) { if (!packet_size) {
current->wait_on(packet_wait_queue); current->wait_on(packet_wait_queue);
continue; continue;
@ -85,7 +88,7 @@ void NetworkTask_main()
kprintf("NetworkTask: Packet is too small to be an Ethernet packet! (%zu)\n", packet_size); kprintf("NetworkTask: Packet is too small to be an Ethernet packet! (%zu)\n", packet_size);
continue; continue;
} }
auto& eth = *(const EthernetFrameHeader*)packet; auto& eth = *(const EthernetFrameHeader*)buffer;
#ifdef ETHERNET_DEBUG #ifdef ETHERNET_DEBUG
kprintf("NetworkTask: From %s to %s, ether_type=%w, packet_length=%u\n", kprintf("NetworkTask: From %s to %s, ether_type=%w, packet_length=%u\n",
eth.source().to_string().characters(), eth.source().to_string().characters(),
@ -95,10 +98,8 @@ void NetworkTask_main()
#endif #endif
#ifdef ETHERNET_VERY_DEBUG #ifdef ETHERNET_VERY_DEBUG
u8* data = packet;
for (size_t i = 0; i < packet_size; i++) { for (size_t i = 0; i < packet_size; i++) {
kprintf("%b", data[i]); kprintf("%b", buffer[i]);
switch (i % 16) { switch (i % 16) {
case 7: case 7: