Fix a crash when TizenVsyncWaiter is destroyed.

* Don't have vblank_ecore_pipe as a member anymore
* Does not consider abnormal situations.
  This means, this situation should never happen.
* Refactor TizenVsyncWaiter

Signed-off-by: Boram Bae <[email protected]>

Author: bbrto21

shell/platform/tizen/tizen_embedder_engine.cc

@@ -164,7 +164,10 @@ bool TizenEmbedderEngine::RunEngine(
     return false;
   }
 
-  tizen_vsync_waiter_->AsyncWaitForRunEngineSuccess(flutter_engine);
+  tizen_vsync_waiter_->SetFlutterEngine(flutter_engine);
+  if (!tizen_vsync_waiter_->IsValid()) {
+    LoggerW("TizenVsyncWaiter is not valid");
+  }
 
   std::unique_ptr<FlutterTextureRegistrar> textures =
       std::make_unique<FlutterTextureRegistrar>();
@@ -330,7 +333,9 @@ void TizenEmbedderEngine::OnFlutterPlatformMessage(
 void TizenEmbedderEngine::OnVsyncCallback(void* user_data, intptr_t baton) {
   TizenEmbedderEngine* tizen_embedder_engine =
       reinterpret_cast<TizenEmbedderEngine*>(user_data);
-  tizen_embedder_engine->tizen_vsync_waiter_->AsyncWaitForVsync(baton);
+  if (tizen_embedder_engine->tizen_vsync_waiter_->IsValid()) {
+    tizen_embedder_engine->tizen_vsync_waiter_->AsyncWaitForVsync(baton);
+  }
 }
 
 // Converts a FlutterPlatformMessage to an equivalent FlutterDesktopMessage.

shell/platform/tizen/tizen_vsync_waiter.cc

@@ -4,65 +4,85 @@
 
 #include "tizen_vsync_waiter.h"
 
+#include <Ecore.h>
+
 #include "flutter/shell/platform/tizen/logger.h"
 
-TizenVsyncWaiter::TizenVsyncWaiter()
-    : client_(NULL),
-      output_(NULL),
-      vblank_(NULL),
-      flutter_engine_(nullptr),
-      baton_(0),
-      vblank_ecore_pipe_(NULL) {
-  if (CreateTDMVblank()) {
-    std::thread t(CreateVblankEventLoop, this);
-    t.join();
-  } else {
-    LoggerE("CreateVsyncVaiter fail");
+static std::atomic<Ecore_Pipe*> g_vblank_ecore_pipe = nullptr;
+
+static const int VBLANK_LOOP_REQUEST = 1;
+static const int VBLANK_LOOP_DEL_PIPE = 2;
+
+static void SendVblankLoopRequest(int event_type) {
+  if (ecore_pipe_write(g_vblank_ecore_pipe.load(), &event_type,
+                       sizeof(event_type)) == EINA_FALSE) {
+    LoggerE("Failed to Send Reqeust [%s]", event_type == VBLANK_LOOP_REQUEST
+                                               ? "VBLANK_LOOP_REQUEST"
+                                               : "VBLANK_LOOP_DEL_PIPE");
   }
 }
 
-void TizenVsyncWaiter::CreateVblankEventLoop(void* data) {
-  TizenVsyncWaiter* tizen_vsync_waiter =
-      reinterpret_cast<TizenVsyncWaiter*>(data);
-  if (!ecore_init()) {
-    LoggerE("ERROR: Cannot init Ecore!");
+TizenVsyncWaiter::TizenVsyncWaiter() {
+  if (!CreateTDMVblank()) {
+    LoggerE("Failed to create TDM vblank");
     return;
   }
-  tizen_vsync_waiter->vblank_ecore_pipe_ =
-      ecore_pipe_add(VblankEventLoopCallback, tizen_vsync_waiter);
-  LoggerD("ecore_init successful");
-  ecore_main_loop_begin();
-  ecore_shutdown();
-}
 
-void TizenVsyncWaiter::VblankEventLoopCallback(void* data, void* buffer,
-                                               unsigned int nbyte) {
-  TizenVsyncWaiter* tizen_vsync_waiter =
-      reinterpret_cast<TizenVsyncWaiter*>(data);
-  int* event_type = reinterpret_cast<int*>(buffer);
-  if ((*event_type) == VBLANK_LOOP_REQUEST) {
-    tizen_vsync_waiter->AsyncWaitForVsyncCallback();
-  } else if ((*event_type) == VBLANK_LOOP_DEL_PIPE) {
-    tizen_vsync_waiter->DeleteVblankEventPipe();
+  std::thread t(
+      [this](void* data) {
+        if (!ecore_init()) {
+          LoggerE("Failed to init Ecore");
+          return;
+        }
+        Ecore_Pipe* vblank_ecore_pipe = ecore_pipe_add(
+            [](void* data, void* buffer, unsigned int nbyte) {
+              TizenVsyncWaiter* tizen_vsync_waiter =
+                  reinterpret_cast<TizenVsyncWaiter*>(data);
+              int event_type = *(reinterpret_cast<int*>(buffer));
+              if (event_type == VBLANK_LOOP_REQUEST) {
+                tizen_vsync_waiter->HandleVblankLoopRequest();
+              } else if (event_type == VBLANK_LOOP_DEL_PIPE) {
+                if (g_vblank_ecore_pipe.load()) {
+                  ecore_pipe_del(g_vblank_ecore_pipe);
+                  g_vblank_ecore_pipe = NULL;
+                }
+                ecore_main_loop_quit();
+              }
+            },
+            this);
+
+        g_vblank_ecore_pipe.store(vblank_ecore_pipe);
+        ecore_main_loop_begin();
+        ecore_shutdown();
+      },
+      nullptr);
+  t.join();
+
+  if (g_vblank_ecore_pipe.load() == nullptr) {
+    LoggerE("Failed to create Ecore Pipe");
   }
 }
 
-void TizenVsyncWaiter::AsyncWaitForVsyncCallback() {
-  tdm_error ret;
-  ret = tdm_client_vblank_wait(vblank_, 1, TdmClientVblankCallback, this);
-  if (ret != TDM_ERROR_NONE) {
-    LoggerE("ERROR, ret = %d", ret);
-    return;
+TizenVsyncWaiter::~TizenVsyncWaiter() {
+  if (g_vblank_ecore_pipe.load()) {
+    SendVblankLoopRequest(VBLANK_LOOP_DEL_PIPE);
+  }
+  if (vblank_) {
+    tdm_client_vblank_destroy(vblank_);
+  }
+  if (client_) {
+    tdm_client_destroy(client_);
   }
-  tdm_client_handle_events(client_);
 }
 
-void TizenVsyncWaiter::DeleteVblankEventPipe() {
-  if (vblank_ecore_pipe_) {
-    ecore_pipe_del(vblank_ecore_pipe_);
-    vblank_ecore_pipe_ = NULL;
-  }
-  ecore_main_loop_quit();
+void TizenVsyncWaiter::AsyncWaitForVsync(intptr_t baton) {
+  baton_ = baton;
+  SendVblankLoopRequest(VBLANK_LOOP_REQUEST);
+}
+
+bool TizenVsyncWaiter::IsValid() {
+  return g_vblank_ecore_pipe.load() && client_ && output_ && vblank_ &&
+         flutter_engine_;
 }
 
 bool TizenVsyncWaiter::CreateTDMVblank() {
@@ -94,57 +114,20 @@ void TizenVsyncWaiter::TdmClientVblankCallback(
     unsigned int tv_sec, unsigned int tv_usec, void* user_data) {
   TizenVsyncWaiter* tizen_vsync_waiter =
       reinterpret_cast<TizenVsyncWaiter*>(user_data);
-  if (tizen_vsync_waiter == nullptr) {
-    LoggerE("tizen_vsync_waiter is null");
-    return;
-  }
-  if (tizen_vsync_waiter->flutter_engine_ == nullptr) {
-    LoggerI("flutter engine creation is not completed");
-    return;
-  }
+
   uint64_t frame_start_time_nanos = tv_sec * 1e9 + tv_usec * 1e3;
   uint64_t frame_target_time_nanos = 16.6 * 1e6 + frame_start_time_nanos;
   FlutterEngineOnVsync(tizen_vsync_waiter->flutter_engine_,
                        tizen_vsync_waiter->baton_, frame_start_time_nanos,
                        frame_target_time_nanos);
 }
 
-bool TizenVsyncWaiter::AsyncWaitForVsync() {
-  if (nullptr == flutter_engine_) {
-    LoggerD("flutter_engine_ is null");
-    return false;
-  }
-  if (vblank_ecore_pipe_) {
-    int event_type = VBLANK_LOOP_REQUEST;
-    ecore_pipe_write(vblank_ecore_pipe_, &event_type, sizeof(event_type));
-  }
-  return true;
-}
-
-TizenVsyncWaiter::~TizenVsyncWaiter() {
-  if (vblank_ecore_pipe_) {
-    int event_type = VBLANK_LOOP_DEL_PIPE;
-    ecore_pipe_write(vblank_ecore_pipe_, &event_type, sizeof(event_type));
-  }
-  if (vblank_) {
-    tdm_client_vblank_destroy(vblank_);
-  }
-  if (client_) {
-    tdm_client_destroy(client_);
-  }
-}
-
-void TizenVsyncWaiter::AsyncWaitForVsync(intptr_t baton) {
-  baton_ = baton;
-  AsyncWaitForVsync();
-}
-
-void TizenVsyncWaiter::AsyncWaitForRunEngineSuccess(
-    FLUTTER_API_SYMBOL(FlutterEngine) flutter_engine) {
-  flutter_engine_ = flutter_engine;
-  if (baton_ == 0) {
-    LoggerD("baton_ == 0");
+void TizenVsyncWaiter::HandleVblankLoopRequest() {
+  tdm_error ret;
+  ret = tdm_client_vblank_wait(vblank_, 1, TdmClientVblankCallback, this);
+  if (ret != TDM_ERROR_NONE) {
+    LoggerE("ERROR, ret = %d", ret);
     return;
   }
-  AsyncWaitForVsync();
-}
+  tdm_client_handle_events(client_);
+}

shell/platform/tizen/tizen_vsync_waiter.h

@@ -5,7 +5,6 @@
 #ifndef EMBEDDER_TIZEN_VSYNC_WAITER_H_
 #define EMBEDDER_TIZEN_VSYNC_WAITER_H_
 
-#include <Ecore.h>
 #include <tdm_client.h>
 
 #include <thread>
@@ -16,30 +15,25 @@ class TizenVsyncWaiter {
  public:
   TizenVsyncWaiter();
   virtual ~TizenVsyncWaiter();
-  bool CreateTDMVblank();
-  bool AsyncWaitForVsync();
   void AsyncWaitForVsync(intptr_t baton);
-  void AsyncWaitForRunEngineSuccess(FLUTTER_API_SYMBOL(FlutterEngine)
-                                        flutter_engine);
+  void SetFlutterEngine(FLUTTER_API_SYMBOL(FlutterEngine) flutter_engine) {
+    flutter_engine_ = flutter_engine;
+  }
+  bool IsValid();
 
  private:
-  static const int VBLANK_LOOP_REQUEST = 1;
-  static const int VBLANK_LOOP_DEL_PIPE = 2;
-  void AsyncWaitForVsyncCallback();
-  void DeleteVblankEventPipe();
-  static void CreateVblankEventLoop(void* data);
+  bool CreateTDMVblank();
+  void HandleVblankLoopRequest();
   static void TdmClientVblankCallback(tdm_client_vblank* vblank,
                                       tdm_error error, unsigned int sequence,
                                       unsigned int tv_sec, unsigned int tv_usec,
                                       void* user_data);
-  static void VblankEventLoopCallback(void* data, void* buffer,
-                                      unsigned int nbyte);
-  tdm_client* client_;
-  tdm_client_output* output_;
-  tdm_client_vblank* vblank_;
-  FLUTTER_API_SYMBOL(FlutterEngine) flutter_engine_;
-  intptr_t baton_;
-  Ecore_Pipe* vblank_ecore_pipe_;
+
+  tdm_client* client_{nullptr};
+  tdm_client_output* output_{nullptr};
+  tdm_client_vblank* vblank_{nullptr};
+  FLUTTER_API_SYMBOL(FlutterEngine) flutter_engine_{nullptr};
+  intptr_t baton_{0};
 };
 
 #endif  // EMBEDDER_TIZEN_VSYNC_WAITER_H_