diff options
author | Matthew Wild <mwild1@gmail.com> | 2020-06-29 12:51:28 +0100 |
---|---|---|
committer | Matthew Wild <mwild1@gmail.com> | 2020-06-29 12:51:28 +0100 |
commit | 67cf276ba2e23710c9ab2abd7e2f7b377aab1070 (patch) | |
tree | 39ea1cc4258cbcb5291e08c8998863cb2f9ae5ba /util/dbuffer.lua | |
parent | e93be0e96ecfd43425b06f230d3b2efd9ff7fe5e (diff) | |
download | prosody-67cf276ba2e23710c9ab2abd7e2f7b377aab1070.tar.gz prosody-67cf276ba2e23710c9ab2abd7e2f7b377aab1070.zip |
util.dbuffer: If no bytes parameter passed to read, return remainder of frontmost chunk
Diffstat (limited to 'util/dbuffer.lua')
-rw-r--r-- | util/dbuffer.lua | 9 |
1 files changed, 7 insertions, 2 deletions
diff --git a/util/dbuffer.lua b/util/dbuffer.lua index c38a16f5..63dca750 100644 --- a/util/dbuffer.lua +++ b/util/dbuffer.lua @@ -24,6 +24,9 @@ function dbuffer_methods:read_chunk(requested_bytes) if not chunk then return; end local chunk_length = #chunk; local remaining_chunk_length = chunk_length - consumed; + if not requested_bytes then + requested_bytes = remaining_chunk_length; + end if remaining_chunk_length <= requested_bytes then self.front_consumed = 0; self._length = self._length - remaining_chunk_length; @@ -41,12 +44,14 @@ end function dbuffer_methods:read(requested_bytes) local chunks; - if requested_bytes > self._length then + if requested_bytes and requested_bytes > self._length then return nil; end local chunk, read_bytes = self:read_chunk(requested_bytes); - if chunk then + if not requested_bytes then + return chunk; + elseif chunk then requested_bytes = requested_bytes - read_bytes; if requested_bytes == 0 then -- Already read everything we need return chunk; |