From a22e2228658189c68d1125f1fb6623088f8bc3cb Mon Sep 17 00:00:00 2001 From: Matthew Wild Date: Wed, 5 May 2010 15:25:48 +0100 Subject: net.server_select, net.server_event: Add server.link() to link 2 connections with an intermediate buffer of the specified size --- net/server_event.lua | 21 +++++++++++++++++++++ 1 file changed, 21 insertions(+) (limited to 'net/server_event.lua') diff --git a/net/server_event.lua b/net/server_event.lua index 8eaa96da..43e70a0f 100644 --- a/net/server_event.lua +++ b/net/server_event.lua @@ -845,11 +845,32 @@ function hook_signal(signal_num, handler) return signal_events[signal_num]; end +local function link(sender, receiver, buffersize) + sender:set_mode(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(); + end + end +end + return { cfg = cfg, base = base, loop = loop, + link = link, event = event, event_base = base, addevent = newevent, -- cgit v1.2.3