lsocket.pas

   1 {lsocket.pas}\r
   2 \r
   3 {socket code by plugwash}\r
   4 \r
   5 { Copyright (C) 2005 Bas Steendijk and Peter Green\r
   6   For conditions of distribution and use, see copyright notice in zlib_license.txt\r
   7   which is included in the package\r
   8   ----------------------------------------------------------------------------- }\r
   9 {\r
  10 changes by plugwash (20030728)\r
  11 * created handlefdtrigger virtual method in tlasio (overridden in tlsocket) and moved a lot of code from messageloop into it\r
  12 * changed tlasio to tlasio\r
  13 * split fdhandle into fdhandlein and fdhandleout\r
  14 * i now use fdsrmaster and fdswmaster instead of rebuilding the lists every loop\r
  15 * split lsocket.pas into lsocket.pas and lcore.pas\r
  16 \r
  17 \r
  18 changes by beware (20030903)\r
  19 * added getxaddr, getxport (local addr, port, as string)\r
  20 * added getpeername, remote addr+port as binary\r
  21 * added htons and htonl functions (endian swap, same interface as windows API)\r
  22 \r
  23 beware (20030905)\r
  24 * if connect failed (conn refused) set state to connected and call internalclose, to get closed handler (instead of fdclose)\r
  25 * (lcore) if closing the fd's in internalcose, set fd's to -1 because closing an fd makes it invalid\r
  26 \r
  27 beware (20030927)\r
  28 * fixed: on connect failed, tried to close fdhandle's which were already set to -1, added check\r
  29 \r
  30 beware (20031017)\r
  31 * added getpeeraddr, getpeerport, remote addr+port as string\r
  32 }\r
  33 \r
  34 \r
  35 unit lsocket;\r
  36 {$ifdef fpc}\r
  37   {$mode delphi}\r
  38 {$endif}\r
  39 \r
  40 {$include lcoreconfig.inc}\r
  41 \r
  42 interface\r
  43   uses\r
  44     sysutils,\r
  45     {$ifdef win32}\r
  46       windows,winsock,\r
  47     {$else}\r
  48 \r
  49       {$ifdef VER1_0}\r
  50         linux,\r
  51       {$else}\r
  52         baseunix,unix,unixutil,\r
  53       {$endif}\r
  54       sockets,\r
  55     {$endif}\r
  56     classes,{pgdebugout,}pgtypes,lcore,fd_utils,binipstuff,dnssync;\r
  57 type\r
  58   sunB = packed record\r
  59     s_b1, s_b2, s_b3, s_b4: byte;\r
  60   end;\r
  61 \r
  62   SunW = packed record\r
  63     s_w1, s_w2: word;\r
  64   end;\r
  65 \r
  66   TInAddr = packed record\r
  67     case integer of\r
  68       0: (S_un_b: SunB);\r
  69       1: (S_un_w: SunW);\r
  70       2: (S_addr: cardinal);\r
  71   end;\r
  72 \r
  73   type\r
  74     TLsocket = class(tlasio)\r
  75     public\r
  76       //a: string;\r
  77 \r
  78       inAddr             : TInetSockAddrV;\r
  79 \r
  80       biniplist:tbiniplist;\r
  81       trymoreips:boolean;\r
  82       currentip:integer;\r
  83       connecttimeout:tltimer;\r
  84 \r
  85 {      inAddrSize:integer;}\r
  86 \r
  87       //host               : THostentry      ;\r
  88 \r
  89       //mainthread         : boolean         ; //for debuggin only\r
  90       addr:string;\r
  91       port:string;\r
  92       localaddr:string;\r
  93       localport:string;\r
  94       proto:string;\r
  95       udp:boolean;\r
  96       listenqueue:integer;\r
  97       procedure connectionfailedhandler(error:word);\r
  98       procedure connecttimeouthandler(sender:tobject);\r
  99       procedure connectsuccesshandler;\r
 100       function getaddrsize:integer;\r
 101       procedure connect; virtual;\r
 102       procedure realconnect;\r
 103       procedure bindsocket;\r
 104       procedure listen;\r
 105       function accept : longint;\r
 106       function sendto(dest:TInetSockAddrV;destlen:integer;data:pointer;len:integer):integer; virtual;\r
 107       function receivefrom(data:pointer;len:integer;var src:TInetSockAddrV;var srclen:integer):integer; virtual;\r
 108       //procedure internalclose(error:word);override;\r
 109       procedure handlefdtrigger(readtrigger,writetrigger:boolean); override;\r
 110       function send(data:pointer;len:integer):integer;override;\r
 111       procedure sendstr(const str : string);override;\r
 112       function Receive(Buf:Pointer;BufSize:integer):integer; override;\r
 113       function getpeername(var addr:tsockaddrin;addrlen:integer):integer; virtual;\r
 114       procedure getXaddrbin(var binip:tbinip); virtual;\r
 115       procedure getpeeraddrbin(var binip:tbinip); virtual;\r
 116       function getXaddr:string; virtual;\r
 117       function getpeeraddr:string; virtual;\r
 118       function getXport:string; virtual;\r
 119       function getpeerport:string; virtual;\r
 120       constructor Create(AOwner: TComponent); override;\r
 121       {$ifdef win32}\r
 122         procedure myfdclose(fd : integer); override;\r
 123         function myfdwrite(fd: LongInt;const buf;size: LongInt):LongInt; override;\r
 124         function myfdread(fd: LongInt;var buf;size: LongInt):LongInt; override;\r
 125       {$endif}\r
 126     end;\r
 127     tsocket=longint; // for compatibility with twsocket\r
 128 \r
 129   twsocket=tlsocket; {easy}\r
 130 \r
 131 \r
 132 {!!!function longipdns(s:string):longint;}\r
 133 \r
 134 {$ifdef ipv6}\r
 135 const\r
 136   v4listendefault:boolean=false;\r
 137 {$endif}\r
 138 \r
 139 \r
 140 const\r
 141   TCP_NODELAY=1;\r
 142   IPPROTO_TCP=6;\r
 143 \r
 144 implementation\r
 145 {$include unixstuff.inc}\r
 146 \r
 147 \r
 148 function tlsocket.getaddrsize:integer;\r
 149 begin\r
 150   result := inaddrsize(inaddr);\r
 151 end;\r
 152 \r
 153 \r
 154 procedure tlsocket.realconnect;\r
 155 var\r
 156   a:integer;\r
 157 \r
 158 begin\r
 159 //  writeln('trying to connect to ',ipbintostr(biniplist_get(biniplist,currentip)),'#',port);\r
 160   makeinaddrv(biniplist_get(biniplist,currentip),port,inaddr);\r
 161   inc(currentip);\r
 162   if (currentip >= biniplist_getcount(biniplist)) then trymoreips := false;\r
 163   udp := uppercase(proto) = 'UDP';\r
 164   if udp then a := SOCK_DGRAM else a := SOCK_STREAM;\r
 165   a := Socket(inaddr.inaddr.family,a,0);\r
 166   //writeln(ord(inaddr.inaddr.family));\r
 167   if a = -1 then begin\r
 168     lasterror := {$ifdef win32}getlasterror{$else}socketerror{$endif};\r
 169     raise esocketexception.create('unable to create socket');\r
 170   end;\r
 171   try\r
 172     dup(a);\r
 173     bindsocket;\r
 174     if udp then begin\r
 175       {$ifndef win32}\r
 176         SetSocketOptions(fdhandleout, SOL_SOCKET, SO_BROADCAST, 'TRUE', Length('TRUE'));\r
 177       {$endif}\r
 178       state := wsconnected;\r
 179       if assigned(onsessionconnected) then onsessionconnected(self,0);\r
 180 \r
 181       eventcore.rmasterset(fdhandlein,false);\r
 182       eventcore.wmasterclr(fdhandleout);\r
 183     end else begin\r
 184       state :=wsconnecting;\r
 185       {$ifdef win32}\r
 186         //writeln(inaddr.inaddr.port);\r
 187         winsock.Connect(fdhandlein,winsock.psockaddr(@inADDR)^,getaddrsize);\r
 188       {$else}\r
 189         sockets.Connect(fdhandlein,inADDR,getaddrsize);\r
 190       {$endif}\r
 191       eventcore.rmasterset(fdhandlein,false);\r
 192       eventcore.wmasterset(fdhandleout);\r
 193       if trymoreips then connecttimeout.enabled := true;\r
 194     end;\r
 195     //sendq := '';\r
 196   except\r
 197     on e: exception do begin\r
 198       fdcleanup;\r
 199       raise; //reraise the exception\r
 200     end;\r
 201   end;\r
 202 \r
 203 end;\r
 204 \r
 205 procedure tlsocket.connecttimeouthandler(sender:tobject);\r
 206 begin\r
 207   connecttimeout.enabled := false;\r
 208   destroying := true; //hack to not cause handler to trigger\r
 209   internalclose(0);\r
 210   destroying := false;\r
 211   realconnect;\r
 212 end;\r
 213 \r
 214 procedure tlsocket.connect;\r
 215 var\r
 216   a:integer;\r
 217   ip:tbinip;\r
 218 begin\r
 219   if state <> wsclosed then close;\r
 220   //prevtime := 0;\r
 221   if isbiniplist(addr) then biniplist := addr else biniplist := forwardlookuplist(addr,0);\r
 222   if biniplist_getcount(biniplist) = 0 then raise exception.create('unable to resolve '+addr);\r
 223 \r
 224   //makeinaddrv(addr,port,inaddr);\r
 225 \r
 226   currentip := 0;\r
 227   if not assigned(connecttimeout) then begin\r
 228     connecttimeout := tltimer.create(self);\r
 229     connecttimeout.Tag := integer(self);\r
 230     connecttimeout.ontimer := connecttimeouthandler;\r
 231     connecttimeout.interval := 2500;\r
 232     connecttimeout.enabled := false;\r
 233   end;\r
 234   realconnect;\r
 235 end;\r
 236 \r
 237 procedure tlsocket.sendstr(const str : string);\r
 238 begin\r
 239   if udp then begin\r
 240     send(@str[1],length(str))\r
 241   end else begin\r
 242     inherited sendstr(str);\r
 243   end;\r
 244 end;\r
 245 \r
 246 function tlsocket.send(data:pointer;len:integer):integer;\r
 247 begin\r
 248   if udp then begin\r
 249 //    writeln('sending to '+ipbintostr(inaddrvtobinip(inaddr)),' ',htons(inaddr.inaddr.port),' ',len,' bytes');\r
 250     result := sendto(inaddr,getaddrsize,data,len);\r
 251 \r
 252 //    writeln('send result ',result);\r
 253 //    writeln('errno',errno);\r
 254   end else begin\r
 255     result := inherited send(data,len);\r
 256   end;\r
 257 end;\r
 258 \r
 259 \r
 260 function tlsocket.receive(Buf:Pointer;BufSize:integer):integer;\r
 261 begin\r
 262   if udp then begin\r
 263     result := myfdread(self.fdhandlein,buf^,bufsize);\r
 264   end else begin\r
 265     result := inherited receive(buf,bufsize);\r
 266   end;\r
 267 end;\r
 268 \r
 269 procedure tlsocket.bindsocket;\r
 270 var\r
 271   a:integer;\r
 272   inAddrtemp:TInetSockAddrV;\r
 273   inAddrtempx:{$ifdef win32}winsock.TSockaddr{$else}TInetSockAddrV{$endif} absolute inaddrtemp;\r
 274   inaddrtempsize:integer;\r
 275 begin\r
 276   try\r
 277     if (localaddr <> '') or (localport <> '') then begin\r
 278       if localaddr = '' then begin\r
 279         {$ifdef ipv6}\r
 280         if inaddr.inaddr.family = AF_INET6 then localaddr := '::' else\r
 281         {$endif}\r
 282         localaddr := '0.0.0.0';\r
 283       end;\r
 284       //gethostbyname(localaddr,host);\r
 285 \r
 286       inaddrtempsize := makeinaddrv(forwardlookup(localaddr,0),localport,inaddrtemp);\r
 287 \r
 288       If Bind(fdhandlein,inaddrtempx,inaddrtempsize)<> {$ifdef win32}0{$else}true{$endif} Then begin\r
 289         state := wsclosed;\r
 290         lasterror := {$ifdef win32}getlasterror{$else}socketerror{$endif};\r
 291         raise ESocketException.create('unable to bind, error '+inttostr(lasterror));\r
 292       end;\r
 293       state := wsbound;\r
 294     end;\r
 295   except\r
 296     on e: exception do begin\r
 297       fdcleanup;\r
 298       raise; //reraise the exception\r
 299     end;\r
 300   end;\r
 301 end;\r
 302 \r
 303 procedure tlsocket.listen;\r
 304 var\r
 305   yes:longint;\r
 306   socktype:integer;\r
 307   biniptemp:tbinip;\r
 308   origaddr:string;\r
 309 begin\r
 310   if state <> wsclosed then close;\r
 311   udp := uppercase(proto) = 'UDP';\r
 312   if udp then socktype := SOCK_DGRAM else socktype := SOCK_STREAM;\r
 313   origaddr := addr;\r
 314 \r
 315   if addr = '' then begin\r
 316     {$ifdef ipv6}\r
 317     if not v4listendefault then begin\r
 318       addr := '::';\r
 319     end else\r
 320     {$endif}\r
 321     addr := '0.0.0.0';\r
 322   end;\r
 323   if isbiniplist(addr) then biniptemp := biniplist_get(addr,0) else biniptemp := forwardlookup(addr,10);\r
 324   addr := ipbintostr(biniptemp);\r
 325   fdhandlein := socket(biniptemp.family,socktype,0);\r
 326   {$ifdef ipv6}\r
 327   if (addr = '::') and (origaddr = '') and (fdhandlein < 0) then begin\r
 328     addr := '0.0.0.0';\r
 329     fdhandlein := socket(AF_INET,socktype,0);\r
 330   end;\r
 331   {$endif}\r
 332   if fdhandlein = -1 then raise ESocketException.create('unable to create socket');\r
 333   dupnowatch(fdhandlein); // sets up maxs and copies handle to fdhandleout among other things\r
 334   //eventcore.setfdreverse(fdhandlein,self); //already taken care of by dup\r
 335   state := wsclosed; // then set this back as it was an undesired side effect of dup\r
 336 \r
 337   try\r
 338     yes := $01010101;  {Copied this from existing code. Value is empiric,\r
 339                     but works. (yes=true<>0) }\r
 340     {$ifndef win32}\r
 341       if SetSocketOptions(fdhandlein, SOL_SOCKET, SO_REUSEADDR,yes,sizeof(yes))=-1 then begin\r
 342         raise ESocketException.create('unable to set socket options');\r
 343       end;\r
 344     {$endif}\r
 345     localaddr := addr;\r
 346     localport := port;\r
 347     bindsocket;\r
 348 \r
 349     if not udp then begin\r
 350       {!!! allow custom queue length? default 5}\r
 351       if listenqueue = 0 then listenqueue := 5;\r
 352       If {$ifdef win32}winsock{$else}sockets{$endif}.Listen(fdhandlein,listenqueue)<>{$ifdef win32}0{$else}true{$endif} Then raise esocketexception.create('unable to listen');\r
 353       state := wsListening;\r
 354     end else begin\r
 355       {$ifndef win32}\r
 356         SetSocketOptions(fdhandleout, SOL_SOCKET, SO_BROADCAST, 'TRUE', Length('TRUE'));\r
 357       {$endif}\r
 358       state := wsconnected;\r
 359     end;\r
 360   finally\r
 361     if state = wsclosed then begin\r
 362       if fdhandlein >= 0 then begin\r
 363         {one *can* get here without fd -beware}\r
 364         eventcore.rmasterclr(fdhandlein);\r
 365         myfdclose(fdhandlein); // we musnt leak file discriptors\r
 366         eventcore.setfdreverse(fdhandlein,nil);\r
 367         fdhandlein := -1;\r
 368       end;\r
 369     end else begin\r
 370       eventcore.rmasterset(fdhandlein,not udp);\r
 371     end;\r
 372     if fdhandleout >= 0 then eventcore.wmasterclr(fdhandleout);\r
 373   end;\r
 374   //writeln('listened on addr '+addr+':'+port+' '+proto+' using socket number ',fdhandlein);\r
 375 end;\r
 376 \r
 377 function tlsocket.accept : longint;\r
 378 var\r
 379   FromAddrSize     : LongInt;        // i don't realy know what to do with these at this\r
 380   FromAddr         : TInetSockAddrV;  // at this point time will tell :)\r
 381   a:integer;\r
 382 begin\r
 383 \r
 384   FromAddrSize := Sizeof(FromAddr);\r
 385   {$ifdef win32}\r
 386     result := winsock.accept(fdhandlein,@fromaddr,@fromaddrsize);\r
 387   {$else}\r
 388     result := sockets.accept(fdhandlein,fromaddr,fromaddrsize);\r
 389   {$endif}\r
 390   //now we have accepted one request start monitoring for more again\r
 391   eventcore.rmasterset(fdhandlein,true);\r
 392 \r
 393   if result = -1 then begin\r
 394     raise esocketexception.create('error '+inttostr({$ifdef win32}getlasterror{$else}socketerror{$endif})+' while accepting');\r
 395   end;\r
 396   if result > absoloutemaxs then begin\r
 397     myfdclose(result);\r
 398     a := result;\r
 399     result := -1;\r
 400     raise esocketexception.create('file discriptor out of range: '+inttostr(a));\r
 401   end;\r
 402 end;\r
 403 \r
 404 function tlsocket.sendto(dest:TInetSockAddrV;destlen:integer;data:pointer;len:integer):integer;\r
 405 var\r
 406   destx : {$ifdef win32}winsock.TSockAddr{$else}TInetSockAddrV{$endif} absolute dest;\r
 407 begin\r
 408   result := {$ifdef win32}winsock{$else}sockets{$endif}.sendto(self.fdhandleout,data^,len,0,destx,destlen);\r
 409 end;\r
 410 \r
 411 function tlsocket.receivefrom(data:pointer;len:integer;var src:TInetSockAddrV;var srclen:integer):integer;\r
 412 var\r
 413   srcx : {$ifdef win32}winsock.TSockAddr{$else}TInetSockAddrV{$endif} absolute src;\r
 414 begin\r
 415   result := {$ifdef win32}winsock{$else}sockets{$endif}.recvfrom(self.fdhandlein,data^,len,0,srcx,srclen);\r
 416 end;\r
 417 \r
 418 procedure tlsocket.connectionfailedhandler(error:word);\r
 419 begin\r
 420    if trymoreips then begin\r
 421 //     writeln('failed with error ',error);\r
 422      connecttimeout.enabled := false;\r
 423      destroying := true;\r
 424      state := wsconnected;\r
 425      self.internalclose(0);\r
 426      destroying := false;\r
 427      realconnect;\r
 428    end else begin\r
 429      state := wsconnected;\r
 430      if assigned(onsessionconnected) then onsessionconnected(self,error);\r
 431      self.internalclose(0);\r
 432      recvq.del(maxlongint);\r
 433    end;\r
 434 end;\r
 435 \r
 436 procedure tlsocket.connectsuccesshandler;\r
 437 begin\r
 438    trymoreips := false;\r
 439    connecttimeout.enabled := false;\r
 440    if assigned(onsessionconnected) then onsessionconnected(self,0);\r
 441 end;\r
 442 \r
 443 \r
 444 procedure tlsocket.handlefdtrigger(readtrigger,writetrigger:boolean);\r
 445 var\r
 446   tempbuf:array[0..receivebufsize-1] of byte;\r
 447 begin\r
 448 //  writeln('got a fd trigger, readtrigger=',readtrigger,' writetrigger=',writetrigger,' state=',integer(state));\r
 449   if (state =wslistening) and readtrigger then begin\r
 450 {    debugout('listening socket triggered on read');}\r
 451     eventcore.rmasterclr(fdhandlein);\r
 452     if assigned(onsessionAvailable) then onsessionAvailable(self,0);\r
 453   end;\r
 454   if udp and readtrigger then begin\r
 455     if assigned(ondataAvailable) then ondataAvailable(self,0);\r
 456     {!!!test}\r
 457     exit;\r
 458   end;\r
 459   if (state =wsconnecting) and writetrigger then begin\r
 460     // code for dealing with the reults of a non-blocking connect is\r
 461     // rather complex\r
 462     // if just write is triggered it means connect suceeded\r
 463     // if both read and write are triggered it can mean 2 things\r
 464     // 1: connect ok and data availible\r
 465     // 2: connect fail\r
 466     // to find out which you must read from the socket and look for errors\r
 467     // there if we read successfully we drop through into the code for fireing\r
 468     // the read event\r
 469     if not readtrigger then begin\r
 470       state := wsconnected;\r
 471       connectsuccesshandler;\r
 472     end else begin\r
 473       numread := myfdread(fdhandlein,tempbuf,sizeof(tempbuf));\r
 474       if numread <> -1 then begin\r
 475         state := wsconnected;\r
 476         connectsuccesshandler;\r
 477         //connectread := true;\r
 478         recvq.add(@tempbuf,numread);\r
 479       end else begin\r
 480         connectionfailedhandler({$ifdef win32}wsagetlasterror{$else}linuxerror{$endif});\r
 481         exit;\r
 482       end;\r
 483       // if things went well here we are now in the state wsconnected with data sitting in our receive buffer\r
 484       // so we drop down into the processing for data availible\r
 485     end;\r
 486     if fdhandlein >= 0 then begin\r
 487       if state = wsconnected then begin\r
 488         eventcore.rmasterset(fdhandlein,false);\r
 489       end else begin\r
 490         eventcore.rmasterclr(fdhandlein);\r
 491       end;\r
 492     end;\r
 493     if fdhandleout >= 0 then begin\r
 494       if sendq.size = 0 then begin\r
 495         //don't clear the bit in fdswmaster if data is in the sendq\r
 496         eventcore.wmasterclr(fdhandleout);\r
 497       end;\r
 498     end;\r
 499 \r
 500   end;\r
 501   inherited handlefdtrigger(readtrigger,writetrigger);\r
 502 end;\r
 503 \r
 504 constructor tlsocket.Create(AOwner: TComponent);\r
 505 begin\r
 506   inherited create(aowner);\r
 507   closehandles := true;\r
 508   trymoreips := true;\r
 509 end;\r
 510 \r
 511 \r
 512 function tlsocket.getpeername(var addr:tsockaddrin;addrlen:integer):integer;\r
 513 var\r
 514   addrx : {$ifdef win32}winsock.tsockaddr{$else}tsockaddrin{$endif} absolute addr;\r
 515 begin\r
 516   result := {$ifdef win32}winsock{$else}sockets{$endif}.getpeername(self.fdhandlein,addrx,addrlen);\r
 517 end;\r
 518 \r
 519 procedure tlsocket.getxaddrbin(var binip:tbinip);\r
 520 var\r
 521   addr:tinetsockaddrv;\r
 522   i:integer;\r
 523 begin\r
 524   i := sizeof(addr);\r
 525   fillchar(addr,sizeof(addr),0);\r
 526 \r
 527   {$ifdef win32}\r
 528     winsock.getsockname(self.fdhandlein,psockaddr(@addr)^,i);\r
 529   {$else}\r
 530     sockets.getsocketname(self.fdhandlein,addr,i);\r
 531   {$endif}\r
 532   binip.family := addr.inaddr.family;\r
 533   {$ifdef ipv6}\r
 534   if addr.inaddr6.sin6_family = AF_INET6 then begin\r
 535     binip.ip6 := addr.inaddr6.sin6_addr;\r
 536   end else\r
 537   {$endif}\r
 538   begin\r
 539     binip.ip := addr.inaddr.addr;\r
 540   end;\r
 541   converttov4(binip);\r
 542 end;\r
 543 \r
 544 procedure tlsocket.getpeeraddrbin(var binip:tbinip);\r
 545 var\r
 546   addr:tinetsockaddrv;\r
 547   i:integer;\r
 548 begin\r
 549   i := sizeof(addr);\r
 550   fillchar(addr,sizeof(addr),0);\r
 551   {$ifdef win32}\r
 552     winsock.getpeername(self.fdhandlein,psockaddr(@addr)^,i);\r
 553   {$else}\r
 554     sockets.getpeername(self.fdhandlein,addr,i);\r
 555   {$endif}\r
 556 \r
 557   binip.family := addr.inaddr.family;\r
 558   {$ifdef ipv6}\r
 559   if addr.inaddr6.sin6_family = AF_INET6 then begin\r
 560     binip.ip6 := addr.inaddr6.sin6_addr;\r
 561   end else\r
 562   {$endif}\r
 563   begin\r
 564     binip.ip := addr.inaddr.addr;\r
 565   end;\r
 566   converttov4(binip);\r
 567 end;\r
 568 \r
 569 function tlsocket.getXaddr:string;\r
 570 var\r
 571   biniptemp:tbinip;\r
 572 begin\r
 573   getxaddrbin(biniptemp);\r
 574   result := ipbintostr(biniptemp);\r
 575   if result = '' then result := 'error';\r
 576 end;\r
 577 \r
 578 function tlsocket.getpeeraddr:string;\r
 579 var\r
 580   biniptemp:tbinip;\r
 581 begin\r
 582   getpeeraddrbin(biniptemp);\r
 583   result := ipbintostr(biniptemp);\r
 584   if result = '' then result := 'error';\r
 585 end;\r
 586 \r
 587 function tlsocket.getXport:string;\r
 588 var\r
 589   addr:tinetsockaddrv;\r
 590   i:integer;\r
 591 begin\r
 592   i := sizeof(addr);\r
 593   {$ifdef win32}\r
 594     winsock.getsockname(self.fdhandlein,psockaddrin(@addr)^,i);\r
 595 \r
 596   {$else}\r
 597     sockets.getsocketname(self.fdhandlein,addr,i);\r
 598 \r
 599   {$endif}\r
 600   result := inttostr(htons(addr.InAddr.port));\r
 601 end;\r
 602 \r
 603 function tlsocket.getpeerport:string;\r
 604 var\r
 605   addr:tinetsockaddrv;\r
 606   i:integer;\r
 607 begin\r
 608   i := sizeof(addr);\r
 609   {$ifdef win32}\r
 610     winsock.getpeername(self.fdhandlein,psockaddrin(@addr)^,i);\r
 611 \r
 612   {$else}\r
 613     sockets.getpeername(self.fdhandlein,addr,i);\r
 614 \r
 615   {$endif}\r
 616   result := inttostr(htons(addr.InAddr.port));\r
 617 end;\r
 618 \r
 619 {$ifdef win32}\r
 620   procedure tlsocket.myfdclose(fd : integer);\r
 621   begin\r
 622     closesocket(fd);\r
 623   end;\r
 624   function tlsocket.myfdwrite(fd: LongInt;const buf;size: LongInt):LongInt;\r
 625   begin\r
 626     result := winsock.send(fd,(@buf)^,size,0);\r
 627   end;\r
 628   function tlsocket.myfdread(fd: LongInt;var buf;size: LongInt):LongInt;\r
 629   begin\r
 630     result := winsock.recv(fd,buf,size,0);\r
 631   end;\r
 632 {$endif}\r
 633 \r
 634 end.\r
 635 \r