prosody-hg: net/server_epoll.lua comparison

net.server: Add an API for holding writes of outgoing data

comparison

equal deleted inserted replaced

-:5fe91bfb734c
+:1be99aedb0b3
 	if buffer then
 		t_insert(buffer, data);
 	else
 		self.writebuffer = { data };
 	end
-	self:setwritetimeout();
+	if not self._write_lock then
-	self:set(nil, true);
+		self:setwritetimeout();
+		self:set(nil, true);
+	end
 	return #data;
 end
 interface.send = interface.write;
 -- Close, possibly after writing is done
 		end
 		self:set(true);
 	end);
 end
+function interface:pause_writes()
+	self._write_lock = true;
+	self:setwritetimeout(false);
+	self:set(nil, false);
+end
+function interface:resume_writes()
+	self._write_lock = nil;
+	if self.writebuffer[1] then
+		self:setwritetimeout();
+		self:set(nil, true);
+	end
+end
 -- Connected!
 function interface:onconnect()
 	if self.conn and not self.peername and self.conn.getpeername then
 		self.peername, self.peerport = self.conn:getpeername();
 	end

Mercurial > prosody-hg