Mercurial > prosody-hg

comparison plugins/s2s/s2sout.lib.lua @ 4756:f8ddaaa08a8e

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
mod_s2s/s2sout.lib: Fix imports and some undefined variables
author Matthew Wild <mwild1@gmail.com>
date Sat, 28 Apr 2012 03:11:45 +0100
parents bdafc3e729db
children c01066f27a5d
comparison
equal deleted inserted replaced
4755:844019f369a5 4756:f8ddaaa08a8e
10 10
11 local portmanager = require "core.portmanager"; 11 local portmanager = require "core.portmanager";
12 local wrapclient = require "net.server".wrapclient; 12 local wrapclient = require "net.server".wrapclient;
13 local initialize_filters = require "util.filters".initialize; 13 local initialize_filters = require "util.filters".initialize;
14 local idna_to_ascii = require "util.encodings".idna.to_ascii; 14 local idna_to_ascii = require "util.encodings".idna.to_ascii;
15 local add_task = require "util.timer".add_task;
16 local new_ip = require "util.ip".new_ip; 15 local new_ip = require "util.ip".new_ip;
17 local rfc3484_dest = require "util.rfc3484".destination; 16 local rfc3484_dest = require "util.rfc3484".destination;
18 local socket = require "socket"; 17 local socket = require "socket";
18 local adns = require "net.adns";
19 local dns = require "net.dns";
19 local t_insert, t_sort, ipairs = table.insert, table.sort, ipairs; 20 local t_insert, t_sort, ipairs = table.insert, table.sort, ipairs;
20 local st = require "util.stanza"; 21 local st = require "util.stanza";
21 22
22 local s2s_new_outgoing = require "core.s2smanager".new_outgoing;
23 local s2s_destroy_session = require "core.s2smanager".destroy_session; 23 local s2s_destroy_session = require "core.s2smanager".destroy_session;
24
25 local log = module._log;
24 26
25 local sources = {}; 27 local sources = {};
26 28
27 local max_dns_depth = module:get_option_number("dns_max_depth", 3); 29 local max_dns_depth = module:get_option_number("dns_max_depth", 3);
28 30
65 function host_session.sends2s(data) 67 function host_session.sends2s(data)
66 if not buffer then 68 if not buffer then
67 buffer = {}; 69 buffer = {};
68 host_session.send_buffer = buffer; 70 host_session.send_buffer = buffer;
69 end 71 end
70 log("debug", "Buffering data on unconnected s2sout to %s", to_host); 72 log("debug", "Buffering data on unconnected s2sout to %s", tostring(host_session.to_host));
71 buffer[#buffer+1] = data; 73 buffer[#buffer+1] = data;
72 log("debug", "Buffered item %d: %s", #buffer, tostring(data)); 74 log("debug", "Buffered item %d: %s", #buffer, tostring(data));
73 end 75 end
74 end 76 end
75 end 77 end