X-Git-Url: http://www.lcore.org/git/lcore.git/blobdiff_plain/2940bfc96468965b57663b231695179dbbd3baca..9951872c6c46881c8b414bcd04a18320c457b811:/lcore.pas?ds=inline

diff --git a/lcore.pas b/lcore.pas
old mode 100755
new mode 100644
index 4be20f4..097ea79
--- a/lcore.pas
+++ b/lcore.pas
@@ -16,21 +16,21 @@ unit lcore;
 {$ifdef fpc}
   {$mode delphi}
 {$endif}
-{$ifdef win32}
+{$ifdef mswindows}
   {$define nosignal}
 {$endif}
 interface
   uses
     sysutils,
-    {$ifndef win32}
+    {$ifndef mswindows}
       {$ifdef VER1_0}
         linux,
       {$else}
-        baseunix,unix,unixutil,
+        baseunix,unix,unixutil,sockets,
       {$endif}
       fd_utils,
     {$endif}
-    classes,pgtypes,bfifo;
+    classes,pgtypes,bfifo,ltimevalstuff;
   procedure processtasks;
 
 
@@ -45,7 +45,7 @@ interface
     receivebufsize=packetbasesize*8;
 
   var
-    absoloutemaxs:integer=0;
+    absolutemaxs:integer=0;
 
   type
     {$ifdef ver1_0}
@@ -73,8 +73,8 @@ interface
     TSendData          = procedure (Sender: TObject; BytesSent: Integer) of object;
 
     tlcomponent = class(tcomponent)
-    private
-      procedure releasetaskhandler(wparam,lparam:longint);
+    private
+      procedure releasetaskhandler(wparam,lparam:longint);
     public
       procedure release; virtual;
       destructor destroy; override;
@@ -84,8 +84,8 @@ interface
     public
       state              : tsocketstate      ;
       ComponentOptions   : TWSocketOptions;
-      fdhandlein         : Longint           ;  {file discriptor}
-      fdhandleout        : Longint           ;  {file discriptor}
+      fdhandlein         : Longint           ;  {file descriptor}
+      fdhandleout        : Longint           ;  {file descriptor}
 
       onsessionclosed    : tsocketevent      ;
       ondataAvailable    : tsocketevent      ;
@@ -106,7 +106,11 @@ interface
       lasterror:integer;
       destroying:boolean;
       recvbufsize:integer;
-      function receivestr:string; virtual;
+      datasentcalled:boolean;
+      {$ifdef mswindows}
+      sendflushlasterror:integer;
+      {$endif}
+      function receivestr:tbufferstring; virtual;
       procedure close;
       procedure abort;
       procedure internalclose(error:word); virtual;
@@ -119,8 +123,8 @@ interface
       procedure dup(invalue:longint);
 
       function sendflush : integer;
-      procedure sendstr(const str : string);virtual;
-      procedure putstringinsendbuffer(const newstring : string);
+      procedure sendstr(const str : tbufferstring);virtual;
+      procedure putstringinsendbuffer(const newstring : tbufferstring);
       function send(data:pointer;len:integer):integer;virtual;
       procedure putdatainsendbuffer(data:pointer;len:integer); virtual;
       procedure deletebuffereddata;
@@ -136,9 +140,9 @@ interface
 
       function RealSend(Data : Pointer; Len : Integer) : Integer; //added for bewarehttpd
 
-      procedure myfdclose(fd : integer); virtual;{$ifdef win32}abstract;{$endif}
-      function myfdwrite(fd: LongInt;const buf;size: LongInt):LongInt; virtual;{$ifdef win32}abstract;{$endif}
-      function myfdread(fd: LongInt;var buf;size: LongInt):LongInt; virtual;{$ifdef win32}abstract;{$endif}
+      procedure myfdclose(fd : integer); virtual;{$ifdef mswindows}abstract;{$endif}
+      function myfdwrite(fd: LongInt;const buf;size: LongInt):LongInt; virtual;{$ifdef mswindows}abstract;{$endif}
+      function myfdread(fd: LongInt;var buf;size: LongInt):LongInt; virtual;{$ifdef mswindows}abstract;{$endif}
     protected
       procedure dupnowatch(invalue:longint);
     end;
@@ -154,12 +158,6 @@ interface
   var
     timerwrapperinterface : ttimerwrapperinterface;
   type
-    {$ifdef win32}
-      ttimeval = record
-        tv_sec : longint;
-        tv_usec : longint;
-      end;
-    {$endif}
     tltimer=class(tlcomponent)
     protected
 
@@ -170,8 +168,8 @@ interface
 //      finitialevent       : boolean           ;
       fontimer            : tnotifyevent      ;
       fenabled            : boolean           ;
-      finterval	          : integer	     ; {miliseconds, default 1000}
-      {$ifndef win32}
+      finterval	          : integer	     ; {milliseconds, default 1000}
+      {$ifndef mswindows}
         procedure resettimes;
       {$endif}
 //      procedure setinitialevent(newvalue : boolean);
@@ -179,7 +177,7 @@ interface
       procedure setenabled(newvalue : boolean);
       procedure setinterval(newvalue : integer);
     public
-      //making theese public for now, this code should probablly be restructured later though
+      //making these public for now, this code should probably be restructured later though
       prevtimer          : tltimer           ;
       nexttimer          : tltimer           ;
       nextts	         : ttimeval          ;
@@ -254,44 +252,45 @@ implementation
 {$ifndef nosignal}
   uses {sockets,}lloopback,lsignal;
 {$endif}
-{$ifdef win32}
+{$ifdef mswindows}
   uses windows,winsock;
 {$endif}
-{$ifndef win32}
+{$ifndef mswindows}
   {$include unixstuff.inc}
 {$endif}
-{$include ltimevalstuff.inc}
 
 
 {!!! added sleep call -beware}
 procedure sleep(i:integer);
+{$ifdef mswindows}
+begin
+  windows.sleep(i);
+{$else}
 var
   tv:ttimeval;
 begin
-  {$ifdef win32}
-    windows.sleep(i);
-  {$else}
-    tv.tv_sec := i div 1000;
-    tv.tv_usec := (i mod 1000) * 1000;
-    select(0,nil,nil,nil,@tv);
-  {$endif}
+  tv.tv_sec := i div 1000;
+  tv.tv_usec := (i mod 1000) * 1000;
+  select(0,nil,nil,nil,@tv);
+{$endif}
 end;
 
+
 destructor tlcomponent.destroy;
 begin
   disconnecttasks(self);
   inherited destroy;
 end;
 
-procedure tlcomponent.releasetaskhandler(wparam,lparam:longint);
-begin
-  free;
-end;
+procedure tlcomponent.releasetaskhandler(wparam,lparam:longint);
+begin
+  free;
+end;
 
 
 procedure tlcomponent.release;
 begin
-  addtask(releasetaskhandler,self,0,0);
+  addtask(releasetaskhandler,self,0,0);
 end;
 
 procedure tlasio.release;
@@ -400,13 +399,13 @@ begin
     eventcore.wmasterclr(fdhandleout);//fd_clr(fdhandleout,fdswmaster);
 
     if closehandles then begin
-      {$ifndef win32}
+      {$ifndef mswindows}
         //anyone remember why this is here? --plugwash
         fcntl(fdhandlein,F_SETFL,0);
       {$endif}
       myfdclose(fdhandlein);
       if fdhandleout <> fdhandlein then begin
-        {$ifndef win32}
+        {$ifndef mswindows}
           fcntl(fdhandleout,F_SETFL,0);
         {$endif}
         myfdclose(fdhandleout);
@@ -449,13 +448,13 @@ begin
   end;
 end;
 
-procedure tlasio.sendstr(const str : string);
+procedure tlasio.sendstr(const str : tbufferstring);
 begin
   putstringinsendbuffer(str);
   sendflush;
 end;
 
-procedure tlasio.putstringinsendbuffer(const newstring : string);
+procedure tlasio.putstringinsendbuffer(const newstring : tbufferstring);
 begin
   if newstring <> '' then putdatainsendbuffer(@newstring[1],length(newstring));
 end;
@@ -489,12 +488,17 @@ begin
     result := -1;
     exit;
   end;
+  datasentcalled := false;
 
   lensent := sendq.get(data,packetbasesize*2);
   if assigned(data) then result := myfdwrite(fdhandleout,data^,lensent) else result := 0;
 
   if result = -1 then lensent := 0 else lensent := result;
 
+  {$ifdef mswindows}
+  if (result = -1) then sendflushlasterror := getlasterror else sendflushlasterror := 0;
+  {$endif}
+
   //sendq := copy(sendq,lensent+1,length(sendq)-lensent);
   sendq.del(lensent);
 
@@ -533,7 +537,7 @@ begin
   fdhandlein := invalue;
   fdhandleout := invalue;
   eventcore.setfdreverse(fdhandlein,self);
-  {$ifndef win32}
+  {$ifndef mswindows}
     fcntl(fdhandlein,F_SETFL,OPEN_NONBLOCK);
   {$endif}
   state := wsconnected;
@@ -566,15 +570,15 @@ begin
           internalclose(0);
 
         end else begin
-          {$ifdef win32}
-          if getlasterror=WSAEWOULDBLOCK then begin
+          {$ifdef mswindows}
+          if sendflushlasterror=WSAEWOULDBLOCK then begin
             //the asynchronous nature of windows messages means we sometimes
             //get here with the buffer full
             //so do nothing in that case
           end else
           {$endif}
           begin
-            internalclose({$ifdef win32}getlasterror{$else}linuxerror{$endif});
+            internalclose({$ifdef mswindows}sendflushlasterror{$else}linuxerror{$endif});
           end  
         end;
       end;
@@ -582,7 +586,13 @@ begin
     end else begin
       //everything is sent fire off ondatasent event
       if fdhandleout >= 0 then eventcore.wmasterclr(fdhandleout);//fd_clr(fdhandleout,fdswmaster);
-      if assigned(ondatasent) then tltask.create(self.dodatasent,self,0,0);
+      if assigned(ondatasent) then begin
+        if not datasentcalled then begin
+          tltask.create(self.dodatasent,self,0,0);
+          datasentcalled := true;
+        end;
+      end;
+
     end;
     if assigned(onfdwrite) then onfdwrite(self,0);
   end;
@@ -595,13 +605,13 @@ begin
       if (numread=0) and (not mustrefreshfds) then begin
         {if i remember correctly numread=0 is caused by eof
         if this isn't dealt with then you get a cpu eating infinite loop
-        however if onsessionconencted has called processmessages that could
+        however if onsessionconnected has called processmessages that could
         cause us to drop to here with an empty recvq and nothing left to read
         and we don't want that to cause the socket to close}
 
         internalclose(0);
       end else if (numread=-1) then begin
-        {$ifdef win32}
+        {$ifdef mswindows}
           //sometimes on windows we get stale messages due to the inherent delays
           //in the windows message queue
           if WSAGetLastError = wsaewouldblock then begin
@@ -610,7 +620,7 @@ begin
         {$endif}
         begin
           numread := 0;
-          internalclose({$ifdef win32}wsagetlasterror{$else}linuxerror{$endif});
+          internalclose({$ifdef mswindows}wsagetlasterror{$else}linuxerror{$endif});
         end;
       end else if numread > 0 then recvq.add(@tempbuf,numread);
     end;
@@ -627,7 +637,7 @@ begin
 end;
 
 procedure tlasio.flush;
-{$ifdef win32}
+{$ifdef mswindows}
 type fdset = tfdset;
 {$endif}
 var
@@ -656,7 +666,7 @@ begin
   tlasio(sender).recvq.del(maxlongint);
 end;
 
-{$ifndef win32}
+{$ifndef mswindows}
   procedure tltimer.resettimes;
   begin
     gettimeofday(nextts);
@@ -697,7 +707,7 @@ begin
     if assigned(timerwrapperinterface) then begin
       timerwrapperinterface.setenabled(wrappedtimer,newvalue);
     end else begin
-      {$ifdef win32}
+      {$ifdef mswindows}
         raise exception.create('non wrapper timers are not permitted on windows');
       {$else}
         resettimes;
@@ -713,7 +723,7 @@ begin
     if assigned(timerwrapperinterface) then begin
       timerwrapperinterface.setinterval(wrappedtimer,newvalue);
     end else begin
-      {$ifdef win32}
+      {$ifdef mswindows}
         raise exception.create('non wrapper timers are not permitted on windows');
       {$else}
         resettimes;
@@ -839,7 +849,7 @@ begin
     end else begin
       currenttasklocal := currenttask; //needed in case called from a task
     end;
-    // note i don't bother to sestroy the links here as that will happen when
+    // note i don't bother to destroy the links here as that will happen when
     // the list of tasks is processed anyway
     while assigned(currenttasklocal) do begin
       if currenttasklocal.obj = aobj then begin
@@ -872,7 +882,7 @@ begin
   if (result > 0) and assigned(onsenddata) then onsenddata(self,result);
   eventcore.wmasterset(fdhandleout);
 end;
-{$ifndef win32}
+{$ifndef mswindows}
   procedure tlasio.myfdclose(fd : integer);
   begin
     fdclose(fd);