X-Git-Url: http://www.lcore.org/git/lcore.git/blobdiff_plain/0e83198df591c5ed5d31f53c9bcdcd16ab26d4a6..1c8b91ca0f6891a397357c7cf7d77af18c15937d:/lcorewsaasyncselect.pas

diff --git a/lcorewsaasyncselect.pas b/lcorewsaasyncselect.pas
old mode 100755
new mode 100644
index 712bd7f..6b4c01b
--- a/lcorewsaasyncselect.pas
+++ b/lcorewsaasyncselect.pas
@@ -2,9 +2,14 @@ unit lcorewsaasyncselect;
 
 interface
 
+procedure lcoreinit;
 
 implementation
-uses wcore,lcore,bsearchtree,sysutils,windows,winsock,pgtypes,messages,classes,lsocket;
+
+uses
+  dnswin, //to call init
+  wcore,lcore,bsearchtree,sysutils,windows,winsock,pgtypes,messages,classes,lsocket;
+
 type
   twineventcore=class(teventcore)
   public
@@ -138,12 +143,12 @@ begin
       end else begin
         if (event and (FD_READ or FD_ACCEPT)) <> 0 then readtrigger := true;
         if (event and (FD_WRITE)) <> 0 then writetrigger := true;
-                      
+
         if readtrigger or writetrigger then lasio.handlefdtrigger(readtrigger,writetrigger);
       end;
       // don't reset the event manually for listen sockets to avoid unwanted
-      // extra onsessionavailible events
-      if (taddrint(findtree(@fdwatches,inttostr(socket))) and FD_ACCEPT) = 0 then dowsaasyncselect(socket,0,0); // if not a listen socket reset watches
+      // extra onsessionavailable events
+      if (taddrint(findtree(@fdwatches,inttostr(socket))) and (FD_ACCEPT)) = 0 then dowsaasyncselect(socket,0,0); // if not a listen socket reset watches
     end;
   end else if (ahwnd=hwndlcore) and (aumsg=wm_dotasks) then begin
       //writeln('processing tasks');
@@ -161,6 +166,7 @@ end;
 procedure winaddtask(ahandler:ttaskevent;aobj:tobject;awparam,alparam:longint);
 begin
   if not tasksoutstanding then PostMessage(hwndlcore,wm_dotasks,0,0);
+  tasksoutstanding := true;
 end;
 type
   twcoretimer = wcore.tltimer;
@@ -197,7 +203,14 @@ var
                                  lpszClassName : 'lcoreClass');
   GInitData: TWSAData;
 
+var
+  inited:boolean;
+procedure lcoreinit;
 begin
+  if (inited) then exit;
+
+  dnswin.init;
+
   eventcore := twineventcore.create;
   if Windows.RegisterClass(MyWindowClass) = 0 then halt;
   //writeln('about to create lcore handle, hinstance=',hinstance);
@@ -216,6 +229,12 @@ begin
   onaddtask := winaddtask;
   timerwrapperinterface := twintimerwrapperinterface.create(nil);
 
-  WSAStartup($200, GInitData);
-  absoloutemaxs := maxlongint;
+  WSAStartup(2, GInitData);
+  absolutemaxs := maxlongint;
+
+  wcoreinit;
+
+  inited := true;
+end;
+
 end.