Comparison

net.server: Add watchfd, a simple API for watching file descriptors

comparison

equal deleted inserted replaced

-:4cab4ee5dfcc
+:53178b6ba589
 local t_remove = table.remove;
 local t_concat = table.concat;
 local setmetatable = setmetatable;
 local tostring = tostring;
 local pcall = pcall;
+local type = type;
 local next = next;
 local pairs = pairs;
 local log = require "util.logger".init("server_epoll");
 local epoll = require "epoll";
 local socket = require "socket";
 	conn:connect(addr, port);
 	local client = wrapsocket(conn, nil, pattern, listeners, tls)
 	client:init();
 	return client, conn;
 end
+local function watchfd(fd, onreadable, onwriteable)
+	local conn = setmetatable({
+		conn = fd;
+		onreadable = onreadable;
+		onwriteable = onwriteable;
+		close = function (self)
+			self:setflags(false, false);
+		end
+	}, interface_mt);
+	if type(fd) == "number" then
+		conn.getfd = function ()
+			return fd;
+		end;
+		-- Otherwise it'll need to be something LuaSocket-compatible
+	end
+	conn:setflags(onreadable, onwriteable);
+	return conn;
+end;
 -- Dump all data from one connection into another
 local function link(from, to)
 	from.listeners = setmetatable({
 		onincoming = function (_, data)
 	at = at;
 	loop = loop;
 	closeall = closeall;
 	setquitting = setquitting;
 	wrapclient = wrapclient;
+	watchfd = watchfd;
 	link = link;
 	set_config = function (newconfig)
 		cfg = setmetatable(newconfig, default_config);
 	end;