From ce03dcfbb55d38d06e3014a6c489ea82131472fc Mon Sep 17 00:00:00 2001 From: Alon Levy Date: Tue, 9 Nov 2010 22:56:56 +0200 Subject: server/red_channel (all): handle MIGRATE_DATA and MIGRATE_FLUSH_DATA Handling done in red_channel instead of per channel, using call backs for the channel specific part. Intended to reduce furthur reliance of channels on RedChannel struct. The commit makes the code harder to understand because of the artificial get_serial stuff, should later be fixed by having a joint migration header with the serial (since all channels pass it). --- server/inputs_channel.c | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) (limited to 'server/inputs_channel.c') diff --git a/server/inputs_channel.c b/server/inputs_channel.c index 9ebf0509..8140c04e 100644 --- a/server/inputs_channel.c +++ b/server/inputs_channel.c @@ -529,7 +529,10 @@ static void inputs_link(Channel *channel, RedsStream *stream, int migration, ,inputs_channel_send_item ,inputs_channel_release_pipe_item ,inputs_channel_on_incoming_error - ,inputs_channel_on_outgoing_error); + ,inputs_channel_on_outgoing_error + ,NULL + ,NULL + ,NULL); ASSERT(inputs_channel); channel->data = inputs_channel; inputs_pipe_add_init(inputs_channel); -- cgit