Mercurial > prosody-hg

comparison net/server_select.lua @ 9576:913a17d6c449

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
net.server_select: Move code from :lock_read into :pause and :resume
author Kim Alvefur <zash@zash.se>
date Sun, 28 Oct 2018 16:53:10 +0100
parents 03214e6e3272
children 388b93b3eecf
comparison
equal deleted inserted replaced
9575:1fb3e7c550bf 9576:913a17d6c449
457 return bufferlen, maxreadlen, maxsendlen 457 return bufferlen, maxreadlen, maxsendlen
458 end 458 end
459 handler.lock_read = function (self, switch) 459 handler.lock_read = function (self, switch)
460 out_error( "server.lua, lock_read() is deprecated, use pause() and resume()" ) 460 out_error( "server.lua, lock_read() is deprecated, use pause() and resume()" )
461 if switch == true then 461 if switch == true then
462 local tmp = _readlistlen 462 return self:pause()
463 _readlistlen = removesocket( _readlist, socket, _readlistlen )
464 _readtimes[ handler ] = nil
465 if _readlistlen ~= tmp then
466 noread = true
467 end
468 elseif switch == false then 463 elseif switch == false then
469 if noread then 464 return self:resume()
470 noread = false
471 _readlistlen = addsocket(_readlist, socket, _readlistlen)
472 _readtimes[ handler ] = _currenttime
473 end
474 end 465 end
475 return noread 466 return noread
476 end 467 end
477 handler.pause = function (self) 468 handler.pause = function (self)
478 return self:lock_read(true); 469 local tmp = _readlistlen
470 _readlistlen = removesocket( _readlist, socket, _readlistlen )
471 _readtimes[ handler ] = nil
472 if _readlistlen ~= tmp then
473 noread = true
474 end
475 return noread;
479 end 476 end
480 handler.resume = function (self) 477 handler.resume = function (self)
481 return self:lock_read(false); 478 if noread then
479 noread = false
480 _readlistlen = addsocket(_readlist, socket, _readlistlen)
481 _readtimes[ handler ] = _currenttime
482 end
483 return noread;
482 end 484 end
483 handler.lock = function( self, switch ) 485 handler.lock = function( self, switch )
484 handler.lock_read (switch) 486 handler.lock_read (switch)
485 if switch == true then 487 if switch == true then
486 handler.write = idfalse 488 handler.write = idfalse