Software `/` code `/` prosody

Comparison

net/server_event.lua @ 5776:bd0ff8ae98a8

Remove all trailing whitespace

author	Florian Zeitz <florob@babelmonkeys.de>
date	Fri, 09 Aug 2013 17:48:21 +0200
parent	5756:61521ce49aae
child	5958:451b4649fad2
child	6054:7a5ddbaf758d

comparison

equal deleted inserted replaced

-:a6c2b8933507
+:bd0ff8ae98a8
 -- Client interface methods
 local interface_mt
 do
 	interface_mt = {}; interface_mt.__index = interface_mt;
 	local addevent = base.addevent
 	local coroutine_wrap, coroutine_yield = coroutine.wrap,coroutine.yield
 	-- Private methods
 	function interface_mt:_position(new_position)
 			self.position = new_position or self.position
 			return self.position;
 	end
 	function interface_mt:_close()
 		return self:_destroy();
 	end
 	function interface_mt:_start_connection(plainssl) -- should be called from addclient
 			local callback = function( event )
 				if EV_TIMEOUT == event then  -- timeout during connection
 					self.fatalerror = "connection timeout"
 					self:ontimeout()  -- call timeout listener
 				self.interface, self.readcallback = nil, nil
 			end
 			interfacelist( "delete", self )
 			return true
 	end
 	function interface_mt:_lock(nointerface, noreading, nowriting)  -- lock or unlock this interface or events
 			self.nointerface, self.noreading, self.nowriting = nointerface, noreading, nowriting
 			return nointerface, noreading, nowriting
 	end
 	--TODO: Deprecate
 	function interface_mt:lock_read(switch)
 		if switch then
 			return self:pause();
 		else
 		if c then
 			self._connections = self._connections + c
 		end
 		return self._connections
 	end
 	-- Public methods
 	function interface_mt:write(data)
 		if self.nowriting then return nil, "locked" end
 		--vdebug( "try to send data to client, id/data:", self.id, data )
 		data = tostring( data )
 			self:_lock( true )
 			self:_close( 0 )
 			return true
 		end
 	end
 	function interface_mt:socket()
 		return self.conn
 	end
 	function interface_mt:server()
 		return self._server or self;
 	end
 	function interface_mt:port()
 		return self._port
 	end
 	function interface_mt:serverport()
 		return self._serverport
 	end
 	function interface_mt:ip()
 		return self._ip
 	end
 	function interface_mt:ssl()
 		return self._usingssl
 	end
 	function interface_mt:type()
 		return self._type or "client"
 	end
 	function interface_mt:connections()
 		return self._connections
 	end
 	function interface_mt:address()
 		return self.addr
 	end
 	function interface_mt:set_sslctx(sslctx)
 		self._sslctx = sslctx;
 		if sslctx then
 			self.starttls = nil; -- use starttls() of interface_mt
 		else
 		if pattern then
 			self._pattern = pattern;
 		end
 		return self._pattern;
 	end
 	function interface_mt:set_send(new_send)
 		-- No-op, we always use the underlying connection's send
 	end
 	function interface_mt:starttls(sslctx, call_onconnect)
 		debug( "try to start ssl at client id:", self.id )
 		local err
 		self._sslctx = sslctx;
 		if self._usingssl then  -- startssl was already called
 			debug "ssl session delayed until writebuffer is empty..."
 		end
 		self.starttls = false;
 		return true
 	end
 	function interface_mt:setoption(option, value)
 		if self.conn.setoption then
 			return self.conn:setoption(option, value);
 		end
 		return false, "setoption not implemented";
 	end
 	function interface_mt:setlistener(listener)
 		self.onconnect, self.ondisconnect, self.onincoming, self.ontimeout, self.onreadtimeout, self.onstatus
 			= listener.onconnect, listener.ondisconnect, listener.onincoming,
 			  listener.ontimeout, listener.onreadtimeout, listener.onstatus;
 	end
 			readcallback = false;  -- will be called on read events
 			nointerface = true;  -- lock/unlock parameter of this interface
 			noreading = false, nowriting = false;  -- locks of the read/writecallback
 			startsslcallback = false;  -- starting handshake callback
 			position = false;  -- position of client in interfacelist
 			-- Properties
 			_ip = ip, _port = port, _server = server, _pattern = pattern,
 			_serverport = (server and server:port() or nil),
 			_sslctx = sslctx; -- parameters
 			_usingssl = false;  -- client is using ssl;
 					interface.eventwrite = nil
 					return -1
 				end
 			end
 		end
 		interface.readcallback = function( event )  -- called on read events
 			--vdebug( "new client read event, id/ip/port:", tostring(interface.id), tostring(ip), tostring(port) )
 			if interface.noreading or interface.fatalerror then  -- leave this event
 				--vdebug( "leaving this event because:", tostring(interface.noreading or interface.fatalerror) )
 				interface.eventread = nil
 do
 	function handleserver( server, addr, port, pattern, listener, sslctx )  -- creates an server interface
 		debug "creating server interface..."
 		local interface = {
 			_connections = 0;
 			conn = server;
 			onconnect = listener.onconnect;  -- will be called when new client connected
 			eventread = false;  -- read event handler
 			eventclose = false; -- close event handler
 			readcallback = false; -- read event callback
 			fatalerror = false; -- error message
 			nointerface = true;  -- lock/unlock parameter
 			_ip = addr, _port = port, _pattern = pattern,
 			_sslctx = sslctx;
 		}
 		interface.id = tostring(interface):match("%x+$");
 		interface.readcallback = function( event )  -- server handler, called on incoming connections
 					clientinterface:starttls(sslctx, true)
 				else
 					clientinterface:_start_session( true )
 				end
 				debug( "accepted incoming client connection from:", client_ip or "<unknown IP>", client_port or "<unknown port>", "to", port or "<unknown port>");
 				client, err = server:accept()    -- try to accept again
 			end
 			return EV_READ
 		end
 		server:settimeout( 0 )
 		setmetatable(interface, interface_mt)
 		interfacelist( "add", interface )
 		interface:_start_session()
 		return interface
 		local interface = handleclient( client, ip, port, nil, pattern, listeners, sslctx )
 		interface:_start_connection(sslctx)
 		return interface, client
 		--function handleclient( client, ip, port, server, pattern, listener, _, sslctx )  -- creates an client interface
 	end
 	function addclient( addr, serverport, listener, pattern, localaddr, localport, sslcfg, startssl )
 		local client, err = socket.tcp()  -- creating new socket
 		if not client then
 			debug( "cannot create socket:", err )
 			return nil, err
 	return signal_events[signal_num];
 end
 local function link(sender, receiver, buffersize)
 	local sender_locked;
 	function receiver:ondrain()
 		if sender_locked then
 			sender:resume();
 			sender_locked = nil;
 		end
 	end
 	function sender:onincoming(data)
 		receiver:write(data);
 		if receiver.writebufferlen >= buffersize then
 			sender_locked = true;
 			sender:pause();

prosody

bd0ff8ae98a8

net/server_event.lua

Software / code / prosody

Comparison

net/server_event.lua @ 5776:bd0ff8ae98a8

Software `/` code `/` prosody