|
|
@@ -2,7 +2,7 @@ |
|
|
|
|
|
|
|
buffer = {} |
|
|
|
|
|
|
|
function buffer.new(mode, stream) |
|
|
|
function buffer.new(mode, stream) -- create a new buffer in mode *mode* backed by stream object *stream* |
|
|
|
local result = { |
|
|
|
mode = {}, |
|
|
|
stream = stream, |
|
|
@@ -23,7 +23,6 @@ function buffer.new(mode, stream) |
|
|
|
return setmetatable(result, metatable) |
|
|
|
end |
|
|
|
|
|
|
|
|
|
|
|
local function badFileDescriptor() |
|
|
|
return nil, "bad file descriptor" |
|
|
|
end |
|
|
@@ -44,7 +43,7 @@ function buffer:flush() |
|
|
|
if reason then |
|
|
|
return nil, reason |
|
|
|
else |
|
|
|
return nil, "bad file descriptor" |
|
|
|
return badFileDescriptor() |
|
|
|
end |
|
|
|
end |
|
|
|
|
|
|
@@ -105,7 +104,6 @@ function buffer:read(...) |
|
|
|
self.bufferRead = sub(self.bufferRead, left + 1) |
|
|
|
until len(buffer) == n |
|
|
|
|
|
|
|
--kernel.io.println("buffer read: "..tostring(buffer)) |
|
|
|
return buffer |
|
|
|
end |
|
|
|
|
|
|
@@ -360,7 +358,7 @@ end |
|
|
|
|
|
|
|
function buffer:write(...) |
|
|
|
if self.closed then |
|
|
|
return nil, "bad file descriptor" |
|
|
|
return badFileDescriptor() |
|
|
|
end |
|
|
|
local args = table.pack(...) |
|
|
|
for i = 1, args.n do |
|
|
|