diff --git a/clusterd/clusterd b/clusterd/clusterd index d40c351..2988e48 100755 --- a/clusterd/clusterd +++ b/clusterd/clusterd @@ -951,7 +951,7 @@ sub clp_rx_LSOF { close $socket; } -sub run_cmd { +sub clp_rx_CMD { my ($socket,@cmd)=@_; my $pid=fork; unless (defined $pid) { @@ -1016,6 +1016,7 @@ sub run_cmd { } } } + close $socket; } #----------- CLP cluster protocol ----------------------------- @@ -1085,12 +1086,6 @@ sub clp_send_message { # clp_send_message($socket, @args) $s->send(pack('n',length($data)).$data); } -sub clp_rx_CMD { - my ($socket,@args)=@_; - run_cmd($socket,@args); - close $socket; -} - sub send_tcp_cp_sync { my ($s, @args) = @_; my $data = sign($CLUSTER_PW, encode(@args));