Changeset 2101 for Whitix/branches/netchannel/user/sdk/network/tcp/tcp_events.c

Timestamp:

06/16/10 15:11:16 (2 years ago)

Author:

mwhitworth

Message:

Add to TCP.

Files:

• Whitix/branches/netchannel/user/sdk/network/tcp/tcp_events.c (modified) (2 diffs)

Whitix/branches/netchannel/user/sdk/network/tcp/tcp_events.c

@@ -29 +29 @@
 int TcpRetxTimerOutRegister(Socket* socket, struct TcpEventCtx* ctx)
 {
-        /* 1. Verify socket is TCP */
-        /* 2. Use internal buffer when posting events. Have general TCP state structure */
+        struct TcpSocket* tcpSock = TcpInfo(socket);
+        ctx->ctx.socket = socket;
 
-        return 0;
+        return SocketAsyncAdd(&tcpSock->retxTimerOut, &ctx->ctx);
 }
 
-int TcpDroppedPktsRegister(Socket* socket, struct TcpEventCtx* ctx, int flags)
+int TcpDroppedPktsRegister(Socket* socket, struct TcpEventCtx* ctx)
 {
-        /* 1. Verify socket is TCP */
-        /* 2. flags could be CHECKSUM, DUP, etc. */
-        return 0;
+        struct TcpSocket* tcpSock = TcpInfo(socket);
+        ctx->ctx.socket = socket;
+
+        return SocketAsyncAdd(&tcpSock->droppedPkts, &ctx->ctx);
 }
 
 int TcpLocalWinRegister(Socket* socket, struct TcpEventCtx* ctx)
 {
-        return 0;
+        struct TcpSocket* tcpSock = TcpInfo(socket);
+        ctx->ctx.socket = socket;
+
+        return SocketAsyncAdd(&tcpSock->localWinChanged, &ctx->ctx);
 }
 
@@ -54 +58 @@
         return SocketAsyncAdd(&tcpSock->remWinChanged, &ctx->ctx);
 }
-
-int TcpStateUpdateRegister(Socket* socket, struct TcpEventCtx* ctx, int seconds)
-{
-        return 0;
-}
-
-int TcpSetTransfer(Socket* socket, int length, int blockSize)
-{
-        return 0;
-}