From 082e78ad710da10754d667c8e1d411c923b87a85 Mon Sep 17 00:00:00 2001 From: Donald Buczek Date: Wed, 6 Dec 2017 17:13:59 +0100 Subject: [PATCH] clusterd: Add send_tcp_cp() to send a cluster protocol message over tcp --- clusterd/clusterd | 11 +++++++++++ 1 file changed, 11 insertions(+) diff --git a/clusterd/clusterd b/clusterd/clusterd index 8ee7aea..fcefac3 100755 --- a/clusterd/clusterd +++ b/clusterd/clusterd @@ -1366,6 +1366,17 @@ sub clp_rx_CMD { return 1; } +# send_tcp_cp($socket,$cb,$timeout,@args) +# +# send a cluster protocoll message over an async tcp socket. +# +# assume $CLUSTER_PW is valid +# +sub send_tcp_cp { + my ($s,$cb,$timeout,@args)=@_; + my $data=sign($CLUSTER_PW,encode(@args)); + My::Select::INET::send_tcp($s,pack('n',length($data)).$data,$timeout,$cb); +} #---------------------------------------------------------- #our $CLUSTER_PW;