Changeset 2099 for Whitix/branches/netchannel/user/sdk/network/stats.c

Timestamp:

06/03/10 22:43:33 (2 years ago)

Author:

mwhitworth

Message:

Add to network stack.

Files:

• Whitix/branches/netchannel/user/sdk/network/stats.c (modified) (8 diffs)

Whitix/branches/netchannel/user/sdk/network/stats.c

@@ -1 +1 @@
 #include <stdio.h>
+#include <types.h>
+#include <syscalls.h>
 
-#include "tcp.h"
+#include "tcp/tcp.h"
 
 #define NS_MAGIC        0xDE23FA11
@@ -11 +13 @@
 
 const char* output = NULL;
-extern struct TcpSocketInfo* tcpHead;
+extern struct TcpSocket* tcpHead;
 
 struct PortEntry
@@ -17 +19 @@
         ushort port, flags;
         ulong totalBytesSent, totalPacketsSent;
+        ulong totalBytesRecv, totalPacketsRecv;
         struct PortEntry* next;
+}__attribute__((packed));
+
+struct Host
+{
+        ulong address, flags;
+        ulong droppedPackets, droppedBytes;
+        ulong retxPacketsSent, retxBytesSent;
+        struct Host* next;
 }__attribute__((packed));
 
@@ -25 +36 @@
 struct PortEntry* PortFindEntry(int port)
 {
-        if (!portHead)
+        struct PortEntry* curr = portHead;
+
+        if (!curr)
                 return NULL;
-        
-        printf("TODO: Find\n");
+
+        do
+        {
+                if (curr->port == port)
+                        return curr;
+        } while ((curr = curr->next));
 
         return NULL;
@@ -35 +52 @@
 void PortAppendEntry(struct PortEntry* entry)
 {
+        struct PortEntry* curr = portHead;
+
         numPorts++;
 
@@ -43 +62 @@
         }
 
-        printf("AppendEntry: TODO\n");
+        while (curr->next != NULL)
+        {
+                curr = curr->next;
+        }
+
+        curr->next = entry;
 }
 
@@ -81 +105 @@
 void NetStatsWrite()
 {
-        struct TcpSocketInfo* sock = tcpHead;
+        struct TcpSocket* sock = tcpHead;
 
         if (!sock)
@@ -106 +130 @@
                 entry->totalBytesSent += sock->stats.totalBytesSent;
                 entry->totalPacketsSent += sock->stats.totalPacketsSent;
+
+                entry->totalBytesRecv += sock->stats.totalBytesRecv;
+                entry->totalPacketsRecv += sock->stats.totalPacketsRecv;
 
                 PortAppendEntry(entry);