refactor jsapi - command listener

src/commands/listener.cc

@@ -2,17 +2,11 @@
 #include "commands/parser.h"
 #include "environment_data.h"
 #include "logger.h"
-#include "nan.h"
 #include "platform/platform.h"
 #include "uv.h"
 #include "xpf_mutex-inl.h"
 
 namespace xprofiler {
-using Nan::False;
-using Nan::FunctionCallbackInfo;
-using Nan::ThrowTypeError;
-using Nan::True;
-using v8::Value;
 
 namespace per_process {
 Mutex command_listener_mutex;
@@ -24,25 +18,20 @@ static void CreateCommandsListenerThread(void* unused) {
   CreateIpcServer(ParseCmd);
 }
 
-void RunCommandsListener(const FunctionCallbackInfo<Value>& info) {
+int StartCommandsListener(EnvironmentData* env_data) {
   Mutex::ScopedLock lock(per_process::command_listener_mutex);
   if (per_process::command_listener_thread_created) {
-    info.GetReturnValue().Set(True());
-    return;
+    return 0;
   }
-  int rc = 0;
+
   // init commands listener thread
-  rc = uv_thread_create(&per_process::uv_commands_listener_thread,
-                        CreateCommandsListenerThread, nullptr);
-  if (rc != 0) {
-    ThrowTypeError("xprofiler: create uv commands listener thread failed!");
-    info.GetReturnValue().Set(False());
-    return;
+  int rc = uv_thread_create(&per_process::uv_commands_listener_thread,
+                            CreateCommandsListenerThread, nullptr);
+  if (rc == 0) {
+    InfoT("init", env_data->thread_id(),
+          "commands listener: listener thread created.");
   }
-  EnvironmentData* env_data = EnvironmentData::GetCurrent(info);
-  InfoT("init", env_data->thread_id(),
-        "commands listener: listener thread created.");
 
-  info.GetReturnValue().Set(True());
+  return rc;
 }
 }  // namespace xprofiler

src/commands/listener.h

@@ -1,14 +1,9 @@
 #ifndef XPROFILER_SRC_COMMANDS_LISTENER_H
 #define XPROFILER_SRC_COMMANDS_LISTENER_H
-
-#include "nan.h"
+#include "environment_data.h"
 
 namespace xprofiler {
-using Nan::FunctionCallbackInfo;
-using v8::Value;
-
-// javascript-accessible
-void RunCommandsListener(const FunctionCallbackInfo<Value>& info);
-}  // namespace xprofiler
+int StartCommandsListener(EnvironmentData* env_data);
+}
 
 #endif /* XPROFILER_SRC_COMMANDS_LISTENER_H */

src/jsapi/export_thread_listener.cc

@@ -0,0 +1,21 @@
+#include "include/export_thread_listener.h"
+
+#include "commands/listener.h"
+#include "environment_data.h"
+
+namespace xprofiler {
+using Nan::False;
+using Nan::FunctionCallbackInfo;
+using Nan::ThrowTypeError;
+using Nan::True;
+using v8::Value;
+
+void RunCommandsListener(const FunctionCallbackInfo<Value>& info) {
+  EnvironmentData* env_data = EnvironmentData::GetCurrent(info);
+  int rc = StartCommandsListener(env_data);
+  if (rc != 0) {
+    ThrowTypeError("xprofiler: create uv commands listener thread failed!");
+  }
+  info.GetReturnValue().Set(rc == 0 ? True() : False());
+}
+}  // namespace xprofiler

src/jsapi/include/export_thread_listener.h

@@ -0,0 +1,10 @@
+#ifndef XPROFILER_SRC_JSAPI_THREAD_LISTENER_H
+#define XPROFILER_SRC_JSAPI_THREAD_LISTENER_H
+
+#include "nan.h"
+
+namespace xprofiler {
+void RunCommandsListener(const Nan::FunctionCallbackInfo<v8::Value>& info);
+}
+
+#endif /* XPROFILER_SRC_JSAPI_THREAD_LISTENER_H */

src/xprofiler.cc

@@ -1,9 +1,9 @@
-#include "commands/listener.h"
 #include "jsapi/include/export_configure.h"
 #include "jsapi/include/export_environment.h"
 #include "jsapi/include/export_hooks.h"
 #include "jsapi/include/export_http.h"
 #include "jsapi/include/export_logger.h"
+#include "jsapi/include/export_thread_listener.h"
 #include "jsapi/include/export_thread_logbypass.h"
 #include "library/common.h"
 #include "nan.h"