aboutsummaryrefslogtreecommitdiffstats
path: root/net/connect.lua
diff options
context:
space:
mode:
authorMatthew Wild <mwild1@gmail.com>2020-01-25 14:25:29 +0000
committerMatthew Wild <mwild1@gmail.com>2020-01-25 14:25:29 +0000
commitc5fcad823ae67e81cb2b9b674d70fb6290117218 (patch)
tree9a563e56c063cb3e452f6f43ea0948879a7a8a56 /net/connect.lua
parent6e108728a10ae420bd4c9734af21d12fdaf335bc (diff)
downloadprosody-c5fcad823ae67e81cb2b9b674d70fb6290117218.tar.gz
prosody-c5fcad823ae67e81cb2b9b674d70fb6290117218.zip
Backed out changeset 44ef46e1a951 (not optimal API)
Diffstat (limited to 'net/connect.lua')
-rw-r--r--net/connect.lua33
1 files changed, 12 insertions, 21 deletions
diff --git a/net/connect.lua b/net/connect.lua
index 2d929087..6d399dda 100644
--- a/net/connect.lua
+++ b/net/connect.lua
@@ -2,17 +2,13 @@ local server = require "net.server";
local log = require "util.logger".init("net.connect");
local new_id = require "util.id".short;
+-- TODO Respect use_ipv4, use_ipv6
-- TODO #1246 Happy Eyeballs
-- FIXME RFC 6724
-- FIXME Error propagation from resolvers doesn't work
-- FIXME #1428 Reuse DNS resolver object between service and basic resolver
-- FIXME #1429 Close DNS resolver object when done
-local default_connector_options = {
- use_ipv4 = true;
- use_ipv6 = true;
-};
-
local pending_connection_methods = {};
local pending_connection_mt = {
__name = "pending_connection";
@@ -82,24 +78,19 @@ function pending_connection_listeners.ondisconnect(conn, reason)
attempt_connection(p);
end
-local function new_connector(connector_options)
- local function connect(target_resolver, listeners, options, data)
- local p = setmetatable({
- id = new_id();
- target_resolver = target_resolver;
- listeners = assert(listeners);
- options = options or {};
- data = data;
- connector_options = connector_options or default_connector_options;
- }, pending_connection_mt);
+local function connect(target_resolver, listeners, options, data)
+ local p = setmetatable({
+ id = new_id();
+ target_resolver = target_resolver;
+ listeners = assert(listeners);
+ options = options or {};
+ data = data;
+ }, pending_connection_mt);
- p:log("debug", "Starting connection process");
- attempt_connection(p);
- end
- return connect;
+ p:log("debug", "Starting connection process");
+ attempt_connection(p);
end
return {
- connect = new_connector(default_connector_options);
- new_connector = new_connector;
+ connect = connect;
};