1

server/imserver/dbengine.cc

@@ -1,14 +1,36 @@
 #include "precompile.h"
 
 #include <a8/openssl.h>
+#include <a8/udplog.h>
 
 #include "dbengine.h"
 #include "jsondatamgr.h"
 
+static void OnDBError(a8::XParams& param, int error_code, const std::string& error_msg)
+{
+#ifdef DEBUG
+    a8::UdpLog::Instance()->Debug
+        (
+         "on dberror %s",
+         {
+             error_msg
+         }
+         );
+#endif
+    a8::UdpLog::Instance()->Warning
+        (
+         "on dberror %s",
+         {
+             error_msg
+         }
+         );
+}
+
 void DBEngine::Init()
 {
     f8::DBPool::Instance()->Init();
     f8::DBPool::Instance()->SetThreadNum(16);
+    f8::DBPool::Instance()->on_dberror = OnDBError;
 }
 
 void DBEngine::UnInit()

third_party/framework

@@ -1 +1 @@
-Subproject commit 2cd0d756d8b4314dd261c1b4a10036447b3da358
+Subproject commit e53cddeed3445074b9f1fb3a16d4f4475a5e8e2a