1. 重做 "基础接口调整，使用 InitService 初始化服务，UninitService 释放服务"

fmp_epay @ 6aa8b2c2

-Subproject commit 96d23ec12b69333acdcff2753b418e34fca85a3d
+Subproject commit 6aa8b2c2dc029b9701ea0b48007da4cbb33c337c

fmp_home @ 32832ecf

-Subproject commit b1ddd768043d2039bbe4c7e9c0e777d46eefcff7
+Subproject commit 32832ecf4e867225508226eeb201d62b698540a6

fmp_logger/fmp_logger.cpp

@@ -39,14 +39,14 @@ FMPLogger::~FMPLogger()
     delete d_ptr;
 }
 
-int FMPLogger::StartService()
+void FMPLogger::InitService()
 {
-    return d_func()->Init();
+    d_func()->Init();
 }
 
-int FMPLogger::StopService()
+void FMPLogger::UninitService()
 {
-    return d_func()->Uninit();
+    d_func()->Uninit();
 }
 
 void FMPLogger::Log(short level, const QString &msg, const char* file, const char* func, int line)

fmp_logger/fmp_logger.h

@@ -22,10 +22,11 @@ public:
     explicit            FMPLogger(ctkPluginContext *context);
     ~FMPLogger();
 
-    //! BaseInterface
-    int                 StartService();
-    int                 StopService();
 protected:
+    //! BaseInterface
+    void                InitService();
+    void                UninitService();
+
     int                 PostEvent(const QString &topic, const FMPProps &pps = FMPProps());
 
 public:

fmp_logger/fmp_logger.pro

@@ -28,6 +28,7 @@ unix {
 
 #Target name
 VER = $$system($$PWD/../fmprc.bat $$TARGET)
+#VER = 0.1.1
 ORIGIN_TARGET = $$TARGET
 TARGET = $${TARGET}_$${VER}
 

fmp_logger/fmp_logger_i.h

@@ -82,15 +82,18 @@ public:
 
 
     static
-    FMPLoggerInterface*     InitContext(ctkPluginContext *ctx = nullptr)
+    FMPLoggerInterface*     InitContext(bool init = true, ctkPluginContext *ctx = nullptr)
     {
         static FMPLoggerInterface *logger = nullptr;
-        if (ctx && !logger) {
+        if (init && ctx && !logger) {
             ctkServiceReference ref = ctx->getServiceReference<FMPLoggerInterface>();
             if (ref) {
                 logger = ctx->getService<FMPLoggerInterface>(ref);
             }
         }
+        else if (!init) {
+            logger = nullptr;
+        }
 
         return logger;
     }

fmp_logger/version.h

@@ -5,7 +5,7 @@
 #define VER_MINOR 1
 #define VER_REVISION 0
 
-#define VER_BUILD 43
+#define VER_BUILD 45
 
 //! Convert version numbers to string
 #define _STR(S)  #S

fmp_manager/fmp_manager.cpp

@@ -25,9 +25,9 @@ FMPluginManager::~FMPluginManager()
     StopService();
 }
 
-int FMPluginManager::StartService()
+void FMPluginManager::InitService()
 {
-    if (_fw_factory) return FMP_SUCCESS;
+    if (_fw_factory) return;
 
     _fw_factory = new ctkPluginFrameworkFactory(_fw_props);
 
@@ -94,34 +94,45 @@ int FMPluginManager::StartService()
         FMP_ERROR() << e.cause()->what();
         exit(FMP_FAILURE);
     }
-
-    return FMP_SUCCESS;
 }
 
-int FMPluginManager::StopService()
+void FMPluginManager::UninitService()
 {
     if (_fw_factory) {
-
         FMP_INFO() << "======================== Quit ========================";
         _watcher.removePath(_fw_props[FMP_PROPKEY_PLUGINPATH].toString());
-        _event_handlers.clear();
 
+        //! 优雅关闭
+        try {
+//            QList<ctkServiceReference> svcs = _ctx->getServiceReferences();
+//            foreach(ctkServiceReference s, svcs) {
+//                QSharedPointer<ctkPlugin> p = s.getPlugin();
+//                qDebug() << p->getSymbolicName() << p->getPluginId() << "---";
+//                if (p->getPluginId() > 0) {
+//                    p->stop();
+//                }
+//            }
+            _fw->stop();
+            while(_fw->waitForStop(200).getType() == ctkPluginFrameworkEvent::FRAMEWORK_WAIT_TIMEDOUT) {
+                QCoreApplication::processEvents();
+            }
+        }
+        catch (const ctkPluginException& e) {
+            FMP_ERROR() << e.cause()->what();
+        }
+
+        delete _fw_factory;
+        _fw_factory = nullptr;
+        _ctx = nullptr;
+        _fw.clear();
 
-        //! TODO: 优雅关闭
-//        if (_fw_factory) {
-//            delete _fw_factory;
-//            _fw_factory = nullptr;
-//            _ctx = nullptr;
-//            _fw.clear();
-//        }
+        _event_handlers.clear();
 
         qApp->quit();
     }
     else {
         FMP_WARN() << "Stopping in progress...";
     }
-
-    return FMP_SUCCESS;
 }
 
 int FMPluginManager::SetProperties(const FMPProps &props)
@@ -187,6 +198,9 @@ int FMPluginManager::UpgradePlugin(long pid)
     if (p) {
         QString plugin_name = p->getSymbolicName();
         p->stop();
+
+        //! TODO: 检查停止之前，服务是否处理启动状态，
+        //! 如果是，则需要启动服务
         return LoadPlugin(plugin_name);
     }
 
@@ -218,6 +232,7 @@ void FMPluginManager::OnPluginsChanged(const QString &path)
     if (!expired_plugins.isEmpty()) {
         FMPProps props;
         props[FMP_PROPKEY_PID_LIST] = expired_plugins;
+        //! Request plugin update
         PostEvent(QString(FMP_TOPICS_SERVICES) + FMPE_SERVICE_REQ_UPDATE, props);
     }
 }

fmp_manager/fmp_manager.h

@@ -32,20 +32,25 @@ public:
     explicit        FMPluginManager();
     ~FMPluginManager();
 
-    //! 基础接口
-    int             StartService();
-    int             StopService();
-    int             SetProperties(const FMPProps &props);
 protected:
+    //! 基础接口
+    void            InitService();
+    void            UninitService();
+
     int             PostEvent(const QString &topic, const FMPProps &pps = FMPProps());
 
 public:
     //! 管理器接口
     void            LoadNewPlugins();
     int             LoadPlugin(const QString &plugin);
-    void            UpgradeOldPlugins(const QVariantList &);
     int             UpgradePlugin(long pid);
+    int             SetProperties(const FMPProps &props);
+
+public slots:
+    void            OnStartService() { StartService(); }
+    void            OnStopService() { StopService(); }
 
+    void            UpgradeOldPlugins(const QVariantList &);
 
 public slots:
     void            OnPluginsChanged(const QString &path);

fmp_manager/fmp_me_handlers.cpp

 #include <fmp_logger_i.h>
 #include "fmp_me_handlers.h"
 #include "fmp_manager.h"
+#include <QCoreApplication>
 
 /**
  * @brief 管理器事件默认构造函数
@@ -19,28 +20,33 @@ FMPManagerEventHandler::FMPManagerEventHandler(const QString &topic, FMPluginMan
 /**
  * @brief 升级事件处理方法
  */
+FMPUpgradeEventHandler::FMPUpgradeEventHandler(ctkPluginContext *ctx, FMPluginManager *pm)
+    : FMPManagerEventHandler(FMP_TOPICS_SERVICES FMPE_SERVICE_ACK_UPDATE, pm, ctx)
+{
+    connect(this, SIGNAL(upgrade(QVariantList)), _pm, SLOT(UpgradeOldPlugins(QVariantList)));
+}
+
 void FMPUpgradeEventHandler::handleEvent(const ctkEvent &event)
 {
-    if (_pm) {
-        if (event.getProperty(FMP_PROPKEY_AGREED).toBool()) {
-            _pm->UpgradeOldPlugins(event.getProperty(FMP_PROPKEY_PID_LIST).toList());
-        }
+    if (!event.getProperty(FMP_PROPKEY_PID_LIST).toList().isEmpty()) {
+        emit upgrade(event.getProperty(FMP_PROPKEY_PID_LIST).toList());
     }
     else {
-        FMP_DEBUG() << "No handler instance for event" << event.getTopic();
+        FMP_DEBUG() << "No plugin ids." << event.getTopic();
     }
 }
 
 /**
  * @brief 退出事件处理方法
  */
+FMPQuitEventHandler::FMPQuitEventHandler(ctkPluginContext *ctx, FMPluginManager *pm)
+    : FMPManagerEventHandler(FMP_TOPICS_QUIT, pm, ctx)
+{
+    connect(this, SIGNAL(quit()), _pm, SLOT(OnStopService()));
+}
+
 void FMPQuitEventHandler::handleEvent(const ctkEvent &event)
 {
-    if (_pm) {
-        _pm->deleteLater();
-    }
-    else {
-        FMP_DEBUG() << "No handler instance for event" << event.getTopic();
-    }
+    emit quit();
 }
 

fmp_manager/fmp_me_handlers.h

@@ -35,12 +35,13 @@ class FMPUpgradeEventHandler : public FMPManagerEventHandler
 {
     Q_OBJECT
 public:
-    explicit            FMPUpgradeEventHandler(ctkPluginContext *ctx, FMPluginManager *pm)
-        : FMPManagerEventHandler(FMP_TOPICS_SERVICES FMPE_SERVICE_REQ_UPDATE, pm, ctx)
-    {}
+    explicit            FMPUpgradeEventHandler(ctkPluginContext *ctx, FMPluginManager *pm);
 
     void                handleEvent(const ctkEvent &event);
 
+signals:
+    void                upgrade(const QVariantList &pid_list);
+
 private:
 };
 
@@ -52,11 +53,12 @@ class FMPQuitEventHandler : public FMPManagerEventHandler
 {
     Q_OBJECT
 public:
-    explicit            FMPQuitEventHandler(ctkPluginContext *ctx, FMPluginManager *pm)
-        : FMPManagerEventHandler(FMP_TOPICS_QUIT, pm, ctx)
-    {}
+    explicit            FMPQuitEventHandler(ctkPluginContext *ctx, FMPluginManager *pm);
 
     void                handleEvent(const ctkEvent &event);
+
+signals:
+    void                quit();
 };
 
 #endif // FMP_MANAGER_EVENT_HANDLERS_H

fmp_manager/version.h

@@ -5,7 +5,7 @@
 #define VER_MINOR 1
 #define VER_REVISION 0
 
-#define VER_BUILD 43
+#define VER_BUILD 45
 
 //! Convert version numbers to string
 #define _STR(S)  #S

fmp_network/fmp_network.cpp

@@ -13,14 +13,14 @@ FMPNetwork::FMPNetwork(ctkPluginContext *ctx)
     FMPLoggerInterface::InitContext(ctx);
 }
 
-int FMPNetwork::StartService()
+void FMPNetwork::InitService()
 {
-    return FMP_NOIMPL;
+    //! FMP_NOIMPL;
 }
 
-int FMPNetwork::StopService()
+void FMPNetwork::UninitService()
 {
-    return FMP_NOIMPL;
+    //! FMP_NOIMPL;
 }
 
 int FMPNetwork::PostEvent(const QString &topic, const FMPProps &pps)

fmp_network/fmp_network.h

@@ -17,10 +17,13 @@ class FMPNetwork : public QObject, public FMPNetworkInterface
 public:
     explicit                FMPNetwork(ctkPluginContext *ctx);
     //! 基础插件接口
-    int                     StartService();
-    int                     StopService();
+    //!
+protected:
+    void                    InitService();
+    void                    UninitService();
     int                     PostEvent(const QString &topic, const FMPProps &pps);
 
+public:
     //! 网络服务接口
     FMPHttpReplyPointer     HttpGet(const FMPHttpRequest &req);
     FMPHttpReplyPointer     HttpPost(const FMPHttpRequest &req, const QByteArray &data);

fmp_network/version.h

@@ -5,7 +5,7 @@
 #define VER_MINOR 1
 #define VER_REVISION 0
 
-#define VER_BUILD 43
+#define VER_BUILD 45
 
 //! Convert version numbers to string
 #define _STR(S)  #S

fmp_settings @ 770b2d40

-Subproject commit 121df1a23284a3244b3092597fa43786cff028fd
+Subproject commit 770b2d40f58b0dd33830d7a6db40a956f5718ae1

fmp_syncer/fmp_syncer.cpp

@@ -20,19 +20,23 @@ FMPSyncer::FMPSyncer(ctkPluginContext *ctx)
     StartService();
 }
 
-int FMPSyncer::StartService()
+FMPSyncer::~FMPSyncer()
 {
-    return d_func()->Init();
+    StopService();
 }
 
-int FMPSyncer::StopService()
+void FMPSyncer::InitService()
+{
+    d_func()->Init();
+}
+
+void FMPSyncer::UninitService()
 {
     if (d_ptr) {
+        d_ptr->terminate();
         delete d_ptr;
         d_ptr = nullptr;
     }
-
-    return FMP_SUCCESS;
 }
 
 int FMPSyncer::PostEvent(const QString &topic, const FMPProps &pps)

fmp_syncer/fmp_syncer.h

@@ -16,11 +16,12 @@ class FMPSyncer : public QObject, public FMPSyncerInterface
 
 public:
     explicit            FMPSyncer(ctkPluginContext *ctx);
+    virtual             ~FMPSyncer();
 
-    //! BaseInterface
-    int                 StartService();
-    int                 StopService();
 protected:
+    //! BaseInterface
+    void                InitService();
+    void                UninitService();
     int                 PostEvent(const QString &topic, const FMPProps &pps = FMPProps());
 public:
     //! SyncInterface

fmp_syncer/version.h

@@ -5,7 +5,7 @@
 #define VER_MINOR 1
 #define VER_REVISION 0
 
-#define VER_BUILD 43
+#define VER_BUILD 45
 
 //! Convert version numbers to string
 #define _STR(S)  #S

fmp_takeout @ b7dc6d93

-Subproject commit 6599d01c73727e60c345bfb2e8b075884fca561c
+Subproject commit b7dc6d93703aa56de6783892cbd903704f3febe3

fmp_vip @ 27759247

-Subproject commit 794b72a68d88a61c736d3839cce4ff08d50a3f3a
+Subproject commit 277592473adac876e72671fbf27a5007ea289e20

include/common/fmp_constants.h

@@ -5,6 +5,9 @@
 
 //! 插件错误代码
 #define FMP_SUCCESS 0
+#define FMP_START_PENDING 1
+#define FMP_STOP_PENDING 2
+
 #define FMP_FAILURE -1
 #define FMP_REFUSED -2
 #define FMP_NOIMPL  -3

include/interface/fmp_base_i.h

@@ -21,14 +21,14 @@ public:
       *         失败返回 \link FMP_FAILURE \endlink。
       *                       FMP_REFUSED
       */
-    virtual int     StartService() = 0;
+    virtual int     StartService() { InitService(); return FMP_SUCCESS; }
 
     /**
      * 停止插件服务
      * @brief StopService
      * @return
      */
-    virtual int     StopService() = 0;
+    virtual int     StopService() { UninitService(); return FMP_SUCCESS; }
 
     /**
      * 获取插件服务
@@ -49,6 +49,9 @@ public:
     }
 
 protected:
+    virtual void    InitService() = 0;
+    virtual void    UninitService() = 0;
+
     /**
      * 异步发送插件事件
      * @brief PostEvent

include/interface/fmp_plugin_i.h

@@ -8,6 +8,7 @@
 
 #include <fmp_base_i.h>
 #include <fmp_logger_i.h>
+#include <QSemaphore>
 #include <ctkPluginContext.h>
 #include <service/event/ctkEventAdmin.h>
 
@@ -16,9 +17,16 @@ class ctkPluginContext;
 class FMPluginInterface : public FMPBaseInterface
 {
 public:
-    explicit        FMPluginInterface(ctkPluginContext *ctx) : _ctx(ctx){}
+    explicit        FMPluginInterface(ctkPluginContext *ctx) : _ctx(ctx) {}
 
-    int             StartService()
+    /**
+     * 业务插件启动只能请求启动，由事件订阅者决定是否允许启动
+     * -允许：订阅者通知业务插件，业务插件事件处理器触发 TriggerInit
+     * -拒绝：订阅者通知业务插件
+     * @brief StartService
+     * @return
+     */
+    virtual int     StartService()
     {
         QString topic = FMP_TOPICS_SERVICES;
         topic += FMPE_SERVICE_REQ_START;
@@ -26,7 +34,22 @@ public:
         return PostEvent(topic);
     }
 
+
+    /**
+     * 默认异步启动插件，以确保业务资源释放都在主线程中
+     * @brief StopService
+     * @return
+     */
+    virtual int     StopService()
+    {
+        TriggerUninit();
+        _semaphore.acquire(1);
+        return FMP_SUCCESS;
+    }
+
 protected:
+    virtual void    TriggerInit() = 0;
+    virtual void    TriggerUninit() = 0;
     int             PostEvent(const QString &topic, const FMPProps &pps = FMPProps())
     {
         ctkEventAdmin *event_admin = GetService<ctkEventAdmin>(_ctx);
@@ -45,6 +68,7 @@ protected:
 
 protected:
     ctkPluginContext   *_ctx;
+    QSemaphore          _semaphore;
 };
 
 Q_DECLARE_INTERFACE(FMPluginInterface, "com.fmp.plugin")