function session.data(conn, data)
local ok, err = parser:parse(data);
if ok then return; end
function session.data(conn, data)
local ok, err = parser:parse(data);
if ok then return; end
local function session_close(session, reason)
local log = session.log or log;
if session.conn then
local function session_close(session, reason)
local log = session.log or log;
if session.conn then
if reason then
if type(reason) == "string" then -- assume stream error
log("info", "Disconnecting %s[%s], <stream:error> is: %s", session.host or "(unknown host)", session.type, reason);
if reason then
if type(reason) == "string" then -- assume stream error
log("info", "Disconnecting %s[%s], <stream:error> is: %s", session.host or "(unknown host)", session.type, reason);