Mercurial > lxmppd-hg-xmllex / file comparison
comparison: net/server_event.lua
net/server_event.lua
- changeset 3001
- fa00c6f563b4
- parent 3000
- 43a4cb707fe4
- child 3002
- d1f864ed44c0
equal
deleted
inserted
replaced
| 3000:43a4cb707fe4 | 3001:fa00c6f563b4 |
|---|---|
| 400 self.starttls = nil; -- use starttls() of interface_mt | 400 self.starttls = nil; -- use starttls() of interface_mt |
| 401 else | 401 else |
| 402 self.starttls = false; -- prevent starttls() | 402 self.starttls = false; -- prevent starttls() |
| 403 end | 403 end |
| 404 end | 404 end |
| 405 | |
| 406 function interface_mt:set_mode(pattern) | |
| 407 if pattern then | |
| 408 self._pattern = pattern; | |
| 409 end | |
| 410 return self._pattern; | |
| 411 end | |
| 405 | 412 |
| 406 function interface_mt:set_send(new_send) | 413 function interface_mt:set_send(new_send) |
| 407 -- No-op, we always use the underlying connection's send | 414 -- No-op, we always use the underlying connection's send |
| 408 end | 415 end |
| 409 | 416 |
| 597 if interface.eventreadtimeout then | 604 if interface.eventreadtimeout then |
| 598 interface.eventreadtimeout:close( ) | 605 interface.eventreadtimeout:close( ) |
| 599 interface.eventreadtimeout = nil | 606 interface.eventreadtimeout = nil |
| 600 end | 607 end |
| 601 end | 608 end |
| 602 local buffer, err, part = interface.conn:receive( pattern ) -- receive buffer with "pattern" | 609 local buffer, err, part = interface.conn:receive( interface._pattern ) -- receive buffer with "pattern" |
| 603 --vdebug( "read data:", tostring(buffer), "error:", tostring(err), "part:", tostring(part) ) | 610 --vdebug( "read data:", tostring(buffer), "error:", tostring(err), "part:", tostring(part) ) |
| 604 buffer = buffer or part or "" | 611 buffer = buffer or part or "" |
| 605 local len = string_len( buffer ) | 612 local len = string_len( buffer ) |
| 606 if len > cfg.MAX_READ_LENGTH then -- check buffer length | 613 if len > cfg.MAX_READ_LENGTH then -- check buffer length |
| 607 interface.fatalerror = "receive buffer exceeded" | 614 interface.fatalerror = "receive buffer exceeded" |
