X-Git-Url: http://www.lcore.org/git/lcore.git/blobdiff_plain/3d939725e66414faa7684bbcd5f4ffe95ee2108d..a77cd534c22418ec9a8a22ae42efef1a9500b193:/lcorewsaasyncselect.pas?ds=inline diff --git a/lcorewsaasyncselect.pas b/lcorewsaasyncselect.pas old mode 100755 new mode 100644 index b64797a..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 @@ -142,7 +147,7 @@ begin 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 + // 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 @@ -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.