Mercurial > lxmppd-hg-xmllex / file comparison
comparison: net/server_select.lua
net/server_select.lua
- changeset 3311
- 88cfe1bba690
- parent 3310
- ddcab5be2a5e
- child 3312
- 12fc7e005e8b
equal
deleted
inserted
replaced
| 3310:ddcab5be2a5e | 3311:88cfe1bba690 |
|---|---|
| 477 end | 477 end |
| 478 if succ then -- sending succesful | 478 if succ then -- sending succesful |
| 479 bufferqueuelen = 0 | 479 bufferqueuelen = 0 |
| 480 bufferlen = 0 | 480 bufferlen = 0 |
| 481 _sendlistlen = removesocket( _sendlist, socket, _sendlistlen ) -- delete socket from writelist | 481 _sendlistlen = removesocket( _sendlist, socket, _sendlistlen ) -- delete socket from writelist |
| 482 _ = needtls and handler:starttls(nil, true) | |
| 483 _writetimes[ handler ] = nil | 482 _writetimes[ handler ] = nil |
| 484 if drain then | 483 if drain then |
| 485 drain(handler) | 484 drain(handler) |
| 486 end | 485 end |
| 486 _ = needtls and handler:starttls(nil, true) | |
| 487 _ = toclose and handler:close( ) | 487 _ = toclose and handler:close( ) |
| 488 return true | 488 return true |
| 489 elseif byte and ( err == "timeout" or err == "wantwrite" ) then -- want write | 489 elseif byte and ( err == "timeout" or err == "wantwrite" ) then -- want write |
| 490 buffer = string_sub( buffer, byte + 1, bufferlen ) -- new buffer | 490 buffer = string_sub( buffer, byte + 1, bufferlen ) -- new buffer |
| 491 bufferqueue[ 1 ] = buffer -- insert new buffer in queue | 491 bufferqueue[ 1 ] = buffer -- insert new buffer in queue |
