arch/all-mingw32/bsdsocket/host_socket.c

   1 #include <aros/irq.h>
   2
   3 #include <stdio.h>
   4 #include <windows.h>
   5 #include <winsock2.h>
   6
   7 #include "host_socket.h"
   8
   9 #define D(x) x
  10
  11 static struct SocketController ctl;
  12
  13 static DWORD WINAPI ResolverThread(struct SocketController *ctl)
  14 {
  15     D(printf("[Resolver] Thread started\n"));
  16
  17     for (;;)
  18     {
  19         WaitForSingleObject(ctl->ResolverEvent, INFINITE);
  20
  21         switch(ctl->Command)
  22         {
  23         case SOCK_CMD_SHUTDOWN:
  24             D(printf("[Resolver] Shutdown requested\n"));
  25
  26             CloseHandle(ctl->ResolverEvent);
  27             return 0;
  28
  29         }
  30         ctl->Command = 0;
  31         KrnCauseIRQ(ctl->ResolverIRQ);
  32     }
  33 }
  34
  35 struct SocketController * __declspec(dllexport) __aros sock_init(void)
  36 {
  37     struct WSAData wsdata;
  38     HANDLE thread;
  39     int irq;
  40     int state = WSAStartup(0x0002, &wsdata);
  41
  42     D(printf("[sock_init] WSAStartup reply: %u\n", state));
  43     D(printf("[sock_init] Using WinSock v%u.%u (%s)\n", wsdata.wVersion & 0x00FF, wsdata.wVersion >> 8, wsdata.szDescription));
  44     D(printf("[sock_init] Status: %s\n", wsdata.szSystemStatus));
  45     if (state)
  46         return NULL;
  47
  48     irq = KrnAllocIRQ();
  49     if (irq != -1)
  50     {
  51         ctl.SocketIRQ = irq;
  52
  53         irq = KrnAllocIRQ();
  54         if (irq != -1)
  55         {
  56             ctl.ResolverIRQ = irq;
  57
  58             ctl.ResolverEvent = CreateEvent(NULL, FALSE, FALSE, NULL);
  59             if (ctl.ResolverEvent)
  60             {
  61                 DWORD id;
  62
  63                 thread = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)ResolverThread, &ctl, 0, &id);
  64                 if (thread)
  65                 {
  66                     CloseHandle(thread);
  67
  68                     ctl.SocketEvent = KrnGetIRQObject(ctl.SocketIRQ);
  69                     return &ctl;
  70                 }
  71                 CloseHandle(ctl.ResolverEvent);
  72             }
  73         }
  74         KrnFreeIRQ(ctl.SocketIRQ);
  75     }
  76
  77     return NULL;
  78 }
  79
  80 int __declspec(dllexport) __aros sock_shutdown(struct SocketController *ctl)
  81 {
  82     int res = WSACleanup();
  83
  84     if (res)
  85         return res;
  86
  87     ctl->Command = SOCK_CMD_SHUTDOWN;
  88     SetEvent(ctl->ResolverEvent);
  89
  90     KrnFreeIRQ(ctl->ResolverIRQ);
  91     KrnFreeIRQ(ctl->SocketIRQ);
  92
  93     return 0;
  94 }