diff --git a/src/control_socket.cpp b/src/control_socket.cpp index 83c9e0df5..e3c36cfd9 100644 --- a/src/control_socket.cpp +++ b/src/control_socket.cpp @@ -349,7 +349,7 @@ static int process_msg(struct control_state *s, fd_t client_fd, char *message) char *compress = suffix(message, "compress "); if(prefix_matches(compress, "param ")) { - compress = suffix(compress, " param"); + compress = suffix(compress, "param "); msg->what = CHANGE_PARAMS; } else { msg->what = CHANGE_COMPRESS; @@ -357,7 +357,7 @@ static int process_msg(struct control_state *s, fd_t client_fd, char *message) strncpy(msg->config_string, compress, sizeof(msg->config_string) - 1); if(!resp) { - enum module_class path_compress[] = { MODULE_CLASS_COMPRESS, MODULE_CLASS_NONE }; + enum module_class path_compress[] = { MODULE_CLASS_SENDER, MODULE_CLASS_COMPRESS, MODULE_CLASS_NONE }; append_message_path(path, sizeof(path), path_compress); resp = send_message(s->root_module, path, (struct message *) msg); } diff --git a/src/video_rxtx.cpp b/src/video_rxtx.cpp index 9ed865e74..017102a18 100644 --- a/src/video_rxtx.cpp +++ b/src/video_rxtx.cpp @@ -183,6 +183,8 @@ void *video_rxtx::sender_loop() { if (!m_paused) { send_frame(tx_frame); + } else { + VIDEO_FRAME_DISPOSE(tx_frame); } if (dynamic_cast(this)) {