summaryrefslogtreecommitdiff
path: root/kernel/network
diff options
context:
space:
mode:
Diffstat (limited to 'kernel/network')
-rw-r--r--kernel/network/tcp.c8
1 files changed, 3 insertions, 5 deletions
diff --git a/kernel/network/tcp.c b/kernel/network/tcp.c
index 997b699..8740a63 100644
--- a/kernel/network/tcp.c
+++ b/kernel/network/tcp.c
@@ -186,7 +186,6 @@ void handle_tcp(ipv4_t src_ip, const u8 *payload, u32 payload_length) {
}
struct TcpConnection *incoming_connection = tcp_find_connection(dst_port);
- kprintf("dst_port: %d\n", dst_port);
if (!incoming_connection) {
kprintf("unable to find open port for incoming connection\n");
}
@@ -214,10 +213,9 @@ void handle_tcp(ipv4_t src_ip, const u8 *payload, u32 payload_length) {
}
u16 tcp_payload_length = payload_length - header->data_offset * sizeof(u32);
if (tcp_payload_length > 0) {
- int len = fifo_object_write(
- (u8 *)(payload + header->data_offset * sizeof(u32)), 0,
- tcp_payload_length, incoming_connection->data_file);
- assert(len >= 0);
+ const u8 *tcp_payload = payload + header->data_offset * sizeof(u32);
+ u32 len = ringbuffer_write(&incoming_connection->buffer, tcp_payload,
+ tcp_payload_length);
assert(len == tcp_payload_length);
incoming_connection->ack += len;
tcp_send_ack(incoming_connection);