[c++] Make agent name configurable name for runner after PR #509.

Author: mjpt777

aeron-client/src/main/cpp/Aeron.cpp

@@ -23,6 +23,8 @@ static const std::chrono::duration<long, std::milli> IDLE_SLEEP_MS_1(1);
 static const std::chrono::duration<long, std::milli> IDLE_SLEEP_MS_16(16);
 static const std::chrono::duration<long, std::milli> IDLE_SLEEP_MS_100(100);
 
+static const char* AGENT_NAME = "client-conductor";
+
 static long long currentTimeMillis()
 {
     using namespace std::chrono;
@@ -62,7 +64,7 @@ Aeron::Aeron(Context &context) :
         context.m_resourceLingerTimeout,
         CncFileDescriptor::clientLivenessTimeout(m_cncBuffer)),
     m_idleStrategy(IDLE_SLEEP_MS),
-    m_conductorRunner(m_conductor, m_idleStrategy, m_context.m_exceptionHandler),
+    m_conductorRunner(m_conductor, m_idleStrategy, m_context.m_exceptionHandler, AGENT_NAME),
     m_conductorInvoker(m_conductor, m_context.m_exceptionHandler)
 {
     if (m_context.m_useConductorAgentInvoker)

aeron-client/src/main/cpp/concurrent/AgentRunner.h

@@ -37,10 +37,31 @@ class AgentRunner
         m_agent(agent),
         m_idleStrategy(idleStrategy),
         m_exceptionHandler(exceptionHandler),
-        m_running(true)
+        m_running(true),
+        m_name("aeron-agent")
+    {
+    }
+
+    AgentRunner(
+        Agent& agent, IdleStrategy& idleStrategy, logbuffer::exception_handler_t& exceptionHandler, const std::string name) :
+        m_agent(agent),
+        m_idleStrategy(idleStrategy),
+        m_exceptionHandler(exceptionHandler),
+        m_running(true),
+        m_name(name)
     {
     }
 
+    /**
+     * Name given to the thread running the agent.
+     *
+     * @return the name given to the thread running the agent.
+     */
+    inline const std::string& name() const
+    {
+        return m_name;
+    }
+
     /**
      * Start the Agent running
      *
@@ -50,12 +71,10 @@ class AgentRunner
     {
         m_thread = std::thread([&]()
         {
-            std::string name("aeron-agent");
-
 #ifdef  __APPLE__
-            pthread_setname_np(name.c_str());
+            pthread_setname_np(m_name.c_str());
 #else
-            pthread_setname_np(pthread_self(), name.c_str());
+            pthread_setname_np(pthread_self(), m_name.c_str());
 #endif
 
             run();
@@ -112,6 +131,7 @@ class AgentRunner
     logbuffer::exception_handler_t& m_exceptionHandler;
     std::atomic<bool> m_running;
     std::thread m_thread;
+    std::string m_name;
 };
 
 }}