[Minor] Some fixes

diff --git a/src/libserver/rspamd_control.c b/src/libserver/rspamd_control.c
index cc336174e48d4925362c71f1680bf080ce9c3c94..7c5f365ddfeee0f9600eaa39f550bcad9711b30b 100644 (file)
--- a/src/libserver/rspamd_control.c
+++ b/src/libserver/rspamd_control.c
@@ -809,6 +809,7 @@ rspamd_srv_handler (gint fd, short what, gpointer ud)
                                wcmd.cmd.log_pipe.type = cmd.cmd.log_pipe.type;
                                rspamd_control_broadcast_cmd (srv, &wcmd, rfd,
                                                rspamd_control_log_pipe_io_handler, NULL);
+                               break;
                        default:
                                msg_err ("unknown command type: %d", cmd.type);
                                break;

diff --git a/src/worker.c b/src/worker.c
index 8056b3f0f9d3a491f524b55090139f59281a151e..4a646b730e0c1f832d19906d31cdde800f82fd6d 100644 (file)
--- a/src/worker.c
+++ b/src/worker.c
@@ -376,9 +376,11 @@ rspamd_worker_log_pipe_handler (struct rspamd_main *rspamd_main,
                lp->type = cmd->cmd.log_pipe.type;
 
                DL_APPEND (ctx->log_pipes, lp);
+               msg_info ("added new log pipe");
        }
        else {
                rep.reply.log_pipe.status = ENOENT;
+               msg_err ("cannot attach log pipe: invalid fd");
        }
 
        if (write (fd, &rep, sizeof (rep)) != sizeof (rep)) {