Changeset 2099 for Whitix/branches/netchannel/user/sdk/network/aio.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/aio.c (modified) (2 diffs)

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

@@ -5 +5 @@
 #include <pthread.h>
 
-int globalAioThr;
-int aioWork;
-struct AioCtx* workHead;
-pthread_mutex_t workLock;
-
-int SocketAsyncThreaded(Socket* socket)
+int SocketAsyncRecv(Socket* socket, struct AsyncCtx* ctx, char* buffer, int length)
 {
-        printf("Create thread to handle async requests separately\n");
-        return 0;
-}
-
-int SocketAioCreate(struct AioCtx* aio, AioCallback func, int flags)
-{
-        aio->magic = AIO_MAGIC;
-        aio->func = func;
-        aio->prev = aio->next = NULL;
-        aio->flags = flags;
-
-        return 0;
-}
-
-int SocketAsyncRecv(Socket* socket, struct AioCtx* aio)
-{
-        if (aio->magic != AIO_MAGIC)
-                return AIO_INVALID;
-
-        socket->recvAio = aio;
+        socket->recvAio = ctx;
+        ctx->buffer = buffer;
+        ctx->bufferSize = length;
 
         return AIO_SUCCESS;
 }
 
-int SocketAsyncSend(Socket* socket, struct AioCtx* aio, char* buffer, int len, int flags)
+int SocketAsyncSend(Socket* socket, struct AsyncCtx* aio, char* buffer, int len, int flags)
 {
         /* Add to queue */
@@ -42 +20 @@
 }
 
-void AioWorkerThread(void* data);
-
-int SocketAioFire(Socket* socket, struct AioCtx* aio, int len)
-{
-        if (!globalAioThr)
-        {
-                globalAioThr = SysCreateThread((unsigned long)AioWorkerThread, 0, NULL);
-                pthread_mutex_init(&workLock, NULL);
-        }
-
-        aio->length = len;
-        workHead = aio;
-
-        aioWork = 1;
-        SysResumeThread(globalAioThr);
-        SysYield();
-
-        return 0;
-}
-
-int SocketAioCancel(struct AioCtx* aio)
+int SocketAioCancel(struct AsyncCtx* aio)
 {
         return 0;
 }
 
-int SocketAioError(struct AioCtx* aio)
+int SocketAioError(struct AsyncCtx* aio)
 {
         return 0;
 }
-
-int SocketAioReturn(struct AioCtx* aio)
-{
-        return 0;
-}
-
-void AioWorkerThread(void* data)
-{
-        /* Main thread */
-        struct AioCtx* curr;
-
-        while (1)
-        {
-                if (!workHead)
-                        SysSuspendThread(-1);
-                
-                curr = workHead;
-                workHead = NULL;
-
-                if (!curr)
-                        continue;
-
-                if (curr->func)
-                        curr->func(curr);
-        }
-}