From 67dd4933e6ae5517426de93ce8a3a448eeb48797 Mon Sep 17 00:00:00 2001 From: Jethro Grassie Date: Wed, 16 Aug 2017 08:44:52 -0400 Subject: [PATCH 1/2] Add sync lock on stop Also added and moved two free's hoping to fix leaks. --- contrib/epee/src/readline_buffer.cpp | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) diff --git a/contrib/epee/src/readline_buffer.cpp b/contrib/epee/src/readline_buffer.cpp index ce8260ef6..d4051bcb8 100644 --- a/contrib/epee/src/readline_buffer.cpp +++ b/contrib/epee/src/readline_buffer.cpp @@ -61,7 +61,8 @@ void rdln::readline_buffer::start() void rdln::readline_buffer::stop() { - std::unique_lock lock(process_mutex); + std::unique_lock lock_process(process_mutex); + std::unique_lock lock_sync(sync_mutex); have_line.notify_all(); if(m_cout_buf == NULL) return; @@ -152,9 +153,7 @@ static int process_input() static void handle_line(char* line) { - // This function never gets called now as we are trapping newlines. - // However, it still needs to be present for readline to know we are - // manually handling lines. + free(line); rl_done = 1; return; } @@ -166,6 +165,7 @@ static int handle_enter(int x, int y) line = rl_copy_text(0, rl_end); std::string test_line = line; + free(line); boost::trim_right(test_line); rl_crlf(); @@ -191,7 +191,6 @@ static int handle_enter(int x, int y) add_history(test_line.c_str()); history_set_pos(history_length); } - free(line); if(last_line != "exit" && last_line != "q") { From 1249a2a550c7a297823f6fa81eb3094b01863eab Mon Sep 17 00:00:00 2001 From: Jethro Grassie Date: Wed, 16 Aug 2017 09:34:32 -0400 Subject: [PATCH 2/2] Construct on first use for completion_commands --- contrib/epee/include/readline_buffer.h | 14 +++----------- contrib/epee/src/readline_buffer.cpp | 24 ++++++++++++++++++++---- 2 files changed, 23 insertions(+), 15 deletions(-) diff --git a/contrib/epee/include/readline_buffer.h b/contrib/epee/include/readline_buffer.h index 8dd082a70..28a153414 100644 --- a/contrib/epee/include/readline_buffer.h +++ b/contrib/epee/include/readline_buffer.h @@ -21,23 +21,15 @@ namespace rdln } void get_line(std::string& line) const; void set_prompt(const std::string& prompt); - static void add_completion(const std::string& command) - { - if(std::find(completion_commands.begin(), completion_commands.end(), command) != completion_commands.end()) - return; - completion_commands.push_back(command); - } - static const std::vector& get_completions() - { - return completion_commands; - } + static void add_completion(const std::string& command); + static const std::vector& get_completions(); protected: virtual int sync(); private: std::streambuf* m_cout_buf; - static std::vector completion_commands; + static std::vector& completion_commands(); }; class suspend_readline diff --git a/contrib/epee/src/readline_buffer.cpp b/contrib/epee/src/readline_buffer.cpp index d4051bcb8..42b474052 100644 --- a/contrib/epee/src/readline_buffer.cpp +++ b/contrib/epee/src/readline_buffer.cpp @@ -14,10 +14,8 @@ static void remove_line_handler(); static std::string last_line; static std::string last_prompt; -std::mutex line_mutex, sync_mutex, process_mutex; -std::condition_variable have_line; - -std::vector rdln::readline_buffer::completion_commands = {"exit"}; +static std::mutex line_mutex, sync_mutex, process_mutex; +static std::condition_variable have_line; namespace { @@ -43,6 +41,12 @@ rdln::suspend_readline::~suspend_readline() m_buffer->start(); } +std::vector& rdln::readline_buffer::completion_commands() +{ + static std::vector commands = {"exit"}; + return commands; +} + rdln::readline_buffer::readline_buffer() : std::stringbuf(), m_cout_buf(NULL) { @@ -88,6 +92,18 @@ void rdln::readline_buffer::set_prompt(const std::string& prompt) rl_redisplay(); } +void rdln::readline_buffer::add_completion(const std::string& command) +{ + if(std::find(completion_commands().begin(), completion_commands().end(), command) != completion_commands().end()) + return; + completion_commands().push_back(command); +} + +const std::vector& rdln::readline_buffer::get_completions() +{ + return completion_commands(); +} + int rdln::readline_buffer::process() { process_mutex.lock();