Mercurial > lxmppd-hg-xmllex / file comparison
comparison: net/server_select.lua
net/server_select.lua
- changeset 3000
- 43a4cb707fe4
- parent 2970
- 9b8e139eff5f
- child 3001
- fa00c6f563b4
equal
deleted
inserted
replaced
| 2988:0c61f73ac0fb | 3000:43a4cb707fe4 |
|---|---|
| 390 handler.bufferlen = function( self, readlen, sendlen ) | 390 handler.bufferlen = function( self, readlen, sendlen ) |
| 391 maxsendlen = sendlen or maxsendlen | 391 maxsendlen = sendlen or maxsendlen |
| 392 maxreadlen = readlen or maxreadlen | 392 maxreadlen = readlen or maxreadlen |
| 393 return bufferlen, maxreadlen, maxsendlen | 393 return bufferlen, maxreadlen, maxsendlen |
| 394 end | 394 end |
| 395 --TODO: Deprecate | |
| 395 handler.lock_read = function (self, switch) | 396 handler.lock_read = function (self, switch) |
| 396 if switch == true then | 397 if switch == true then |
| 397 local tmp = _readlistlen | 398 local tmp = _readlistlen |
| 398 _readlistlen = removesocket( _readlist, socket, _readlistlen ) | 399 _readlistlen = removesocket( _readlist, socket, _readlistlen ) |
| 399 _readtimes[ handler ] = nil | 400 _readtimes[ handler ] = nil |
| 406 _readlistlen = addsocket(_readlist, socket, _readlistlen) | 407 _readlistlen = addsocket(_readlist, socket, _readlistlen) |
| 407 _readtimes[ handler ] = _currenttime | 408 _readtimes[ handler ] = _currenttime |
| 408 end | 409 end |
| 409 end | 410 end |
| 410 return noread | 411 return noread |
| 412 end | |
| 413 handler.pause = function (self) | |
| 414 return self:lock_read(true); | |
| 415 end | |
| 416 handler.resume = function (self) | |
| 417 return self:lock_read(false); | |
| 411 end | 418 end |
| 412 handler.lock = function( self, switch ) | 419 handler.lock = function( self, switch ) |
| 413 handler.lock_read (switch) | 420 handler.lock_read (switch) |
| 414 if switch == true then | 421 if switch == true then |
| 415 handler.write = idfalse | 422 handler.write = idfalse |
