diff --git a/README.md b/README.md
index 91aeef18..dd702e7d 100644
--- a/README.md
+++ b/README.md
@@ -10,6 +10,8 @@
**Unreal SDK**: [squick-unreal-sdk](https://github.com/pwnsky/squick-unreal-sdk)
+**Web Admin**: [squick-web](https://github.com/pwnsky/squick-web)
+
**QQ Group:739065686**
**Version:** 1.1.1
diff --git a/config/plugin/db_proxy.xml b/config/plugin/db_proxy.xml
index 3d6db5e2..8372ad3e 100644
--- a/config/plugin/db_proxy.xml
+++ b/config/plugin/db_proxy.xml
@@ -1,12 +1,12 @@
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/config/plugin/ds_mgr.xml b/config/plugin/ds_mgr.xml
index 4e54a0bb..e0d01c6a 100644
--- a/config/plugin/ds_mgr.xml
+++ b/config/plugin/ds_mgr.xml
@@ -1,9 +1,8 @@
-
-
-
-
-
+
+
+
+
\ No newline at end of file
diff --git a/config/plugin/game.xml b/config/plugin/game.xml
index af1b35cf..c860891d 100644
--- a/config/plugin/game.xml
+++ b/config/plugin/game.xml
@@ -1,9 +1,8 @@
-
-
-
-
-
+
+
+
+
-
+
\ No newline at end of file
diff --git a/config/plugin/login.xml b/config/plugin/login.xml
index 0512921b..f8aa994f 100644
--- a/config/plugin/login.xml
+++ b/config/plugin/login.xml
@@ -2,8 +2,7 @@
-
-
+
diff --git a/config/plugin/master.xml b/config/plugin/master.xml
index bf0929ce..2874b45d 100644
--- a/config/plugin/master.xml
+++ b/config/plugin/master.xml
@@ -1,11 +1,8 @@
-
-
-
-
-
-
-
+
+
+
+
\ No newline at end of file
diff --git a/config/plugin/player.xml b/config/plugin/player.xml
index bc8ae1db..b6ac8108 100644
--- a/config/plugin/player.xml
+++ b/config/plugin/player.xml
@@ -1,14 +1,14 @@
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
diff --git a/config/plugin/proxy.xml b/config/plugin/proxy.xml
index c99ed4d1..a0689d10 100644
--- a/config/plugin/proxy.xml
+++ b/config/plugin/proxy.xml
@@ -4,8 +4,8 @@
+
-
\ No newline at end of file
diff --git a/config/plugin/sqkcli.xml b/config/plugin/sqkcli.xml
index da063313..692294fa 100644
--- a/config/plugin/sqkcli.xml
+++ b/config/plugin/sqkcli.xml
@@ -1,9 +1,8 @@
-
-
-
-
-
-
-
+
+
+
+
+
+
\ No newline at end of file
diff --git a/config/plugin/tutorial/t1_plugin.xml b/config/plugin/tutorial/t1_plugin.xml
index 781532ee..56fd216e 100644
--- a/config/plugin/tutorial/t1_plugin.xml
+++ b/config/plugin/tutorial/t1_plugin.xml
@@ -1,5 +1,5 @@
-
-
-
+
+
+
\ No newline at end of file
diff --git a/config/plugin/tutorial/t2_property.xml b/config/plugin/tutorial/t2_property.xml
index 978ce44b..179142d1 100644
--- a/config/plugin/tutorial/t2_property.xml
+++ b/config/plugin/tutorial/t2_property.xml
@@ -1,5 +1,5 @@
-
-
-
+
+
+
\ No newline at end of file
diff --git a/config/plugin/tutorial/t5_http.xml b/config/plugin/tutorial/t5_http.xml
index c5ab0149..5ba15c78 100644
--- a/config/plugin/tutorial/t5_http.xml
+++ b/config/plugin/tutorial/t5_http.xml
@@ -2,7 +2,6 @@
-
\ No newline at end of file
diff --git a/config/plugin/tutorial/t6_rpc.xml b/config/plugin/tutorial/t6_rpc.xml
index b7f43e3c..487769fe 100644
--- a/config/plugin/tutorial/t6_rpc.xml
+++ b/config/plugin/tutorial/t6_rpc.xml
@@ -2,7 +2,6 @@
-
\ No newline at end of file
diff --git a/config/plugin/web.xml b/config/plugin/web.xml
index 4857983f..825e0f07 100644
--- a/config/plugin/web.xml
+++ b/config/plugin/web.xml
@@ -1,10 +1,8 @@
-
-
-
-
-
-
-
+
+
+
+
+
\ No newline at end of file
diff --git a/config/plugin/world.xml b/config/plugin/world.xml
index 3fd08481..d079557f 100644
--- a/config/plugin/world.xml
+++ b/config/plugin/world.xml
@@ -1,14 +1,13 @@
-
-
-
+
+
+
-
+
-
-
-
-
-
+
+
+
+
\ No newline at end of file
diff --git a/src/lua/common/base.lua b/src/lua/common/base.lua
index 37b268dc..e69de29b 100644
--- a/src/lua/common/base.lua
+++ b/src/lua/common/base.lua
@@ -1,16 +0,0 @@
-ServerType =
-{
- ST_NONE = 0,
- ST_MASTER = 1,
- ST_LOGIN = 2,
- ST_WORLD = 3,
- ST_DB_PROXY = 4,
- ST_PROXY = 5,
- ST_PLAYER = 6,
- ST_GAME_MGR = 7,
- ST_GAME = 8,
- ST_MICRO = 9,
- ST_CDN = 10,
- ST_ROBOT = 11,
- ST_MAX = 12,
-};
diff --git a/src/lua/common/net.lua b/src/lua/common/net.lua
index 99c398f9..f49ab230 100644
--- a/src/lua/common/net.lua
+++ b/src/lua/common/net.lua
@@ -8,6 +8,7 @@
Net = {}
-- function Table:func(uid, msg_data, msg_id, fd)
function Net:Register(msg_id, this, func)
+ Squick:LogInfo("Lua Register msg: " .. tostring(msg_id))
Squick:AddMsgCallBackAsServer(msg_id, this, func)
end
diff --git a/src/lua/lib/db/clickhouse.lua b/src/lua/lib/db/clickhouse.lua
index a71ea81e..7b57de68 100644
--- a/src/lua/lib/db/clickhouse.lua
+++ b/src/lua/lib/db/clickhouse.lua
@@ -9,9 +9,9 @@ local DbClickhouseID = 0;
Clickhouse = Clickhouse and Clickhouse or Object(QueryAsync).new()
function Clickhouse:Bind()
- Net:ClientRegister(ServerType.ST_DB_PROXY, NMsgId.IdNAckClickhouseExecute, self, self.AckExecute)
- Net:ClientRegister(ServerType.ST_DB_PROXY, NMsgId.IdNAckClickhouseSelect, self, self.AckSelect)
- Net:ClientRegister(ServerType.ST_DB_PROXY, NMsgId.IdNAckClickhouseInsert, self, self.AckInsert)
+ Net:ClientRegister(NodeType.ST_DB_PROXY, NMsgId.IdNAckClickhouseExecute, self, self.AckExecute)
+ Net:ClientRegister(NodeType.ST_DB_PROXY, NMsgId.IdNAckClickhouseSelect, self, self.AckSelect)
+ Net:ClientRegister(NodeType.ST_DB_PROXY, NMsgId.IdNAckClickhouseInsert, self, self.AckInsert)
DbClickhouseID = GetDbProxyID()
end
diff --git a/src/lua/lib/db/mongo.lua b/src/lua/lib/db/mongo.lua
index 46d97a29..d74dbcb5 100644
--- a/src/lua/lib/db/mongo.lua
+++ b/src/lua/lib/db/mongo.lua
@@ -9,11 +9,11 @@ local DbProxyID = 0;
Mongo = Mongo and Mongo or Object(QueryAsync).new()
function Mongo:Bind()
- Net:ClientRegister(ServerType.ST_DB_PROXY, NMsgId.IdNAckMongoInsert, self, self.AckInsert)
- Net:ClientRegister(ServerType.ST_DB_PROXY, NMsgId.IdNAckMongoFind, self, self.AckFind)
- Net:ClientRegister(ServerType.ST_DB_PROXY, NMsgId.IdNAckMongoUpdate, self, self.AckUpdate)
- Net:ClientRegister(ServerType.ST_DB_PROXY, NMsgId.IdNAckMongoDelete, self, self.AckDelete)
- Net:ClientRegister(ServerType.ST_DB_PROXY, NMsgId.IdNAckMongoCreateIndex, self, self.AckCreateIndex)
+ Net:ClientRegister(NodeType.ST_DB_PROXY, NMsgId.IdNAckMongoInsert, self, self.AckInsert)
+ Net:ClientRegister(NodeType.ST_DB_PROXY, NMsgId.IdNAckMongoFind, self, self.AckFind)
+ Net:ClientRegister(NodeType.ST_DB_PROXY, NMsgId.IdNAckMongoUpdate, self, self.AckUpdate)
+ Net:ClientRegister(NodeType.ST_DB_PROXY, NMsgId.IdNAckMongoDelete, self, self.AckDelete)
+ Net:ClientRegister(NodeType.ST_DB_PROXY, NMsgId.IdNAckMongoCreateIndex, self, self.AckCreateIndex)
DbProxyID = GetDbProxyID()
end
diff --git a/src/lua/lib/db/mysql.lua b/src/lua/lib/db/mysql.lua
index 7c32195b..eb58889b 100644
--- a/src/lua/lib/db/mysql.lua
+++ b/src/lua/lib/db/mysql.lua
@@ -9,10 +9,10 @@ local DbMysqlID = 0;
Mysql = Mysql and Mysql or Object(QueryAsync).new()
function Mysql:Bind()
- Net:ClientRegister(ServerType.ST_DB_PROXY, NMsgId.IdNAckMysqlExecute, self, self.AckExecute)
- Net:ClientRegister(ServerType.ST_DB_PROXY, NMsgId.IdNAckMysqlSelect, self, self.AckSelect)
- Net:ClientRegister(ServerType.ST_DB_PROXY, NMsgId.IdNAckMysqlInsert, self, self.AckInsert)
- Net:ClientRegister(ServerType.ST_DB_PROXY, NMsgId.IdNAckMysqlUpdate, self, self.AckUpdate)
+ Net:ClientRegister(NodeType.ST_DB_PROXY, NMsgId.IdNAckMysqlExecute, self, self.AckExecute)
+ Net:ClientRegister(NodeType.ST_DB_PROXY, NMsgId.IdNAckMysqlSelect, self, self.AckSelect)
+ Net:ClientRegister(NodeType.ST_DB_PROXY, NMsgId.IdNAckMysqlInsert, self, self.AckInsert)
+ Net:ClientRegister(NodeType.ST_DB_PROXY, NMsgId.IdNAckMysqlUpdate, self, self.AckUpdate)
DbMysqlID = GetDbProxyID()
end
diff --git a/src/lua/lib/db/redis.lua b/src/lua/lib/db/redis.lua
index a42afecf..90413e35 100644
--- a/src/lua/lib/db/redis.lua
+++ b/src/lua/lib/db/redis.lua
@@ -9,8 +9,8 @@ local DbProxyID = 0;
Redis = Redis and Redis or Object(QueryAsync).new()
function Redis:Bind()
- Net:ClientRegister(ServerType.ST_DB_PROXY, NMsgId.IdNAckRedisGet, self, self.AckGetString)
- Net:ClientRegister(ServerType.ST_DB_PROXY, NMsgId.IdNAckRedisSet, self, self.AckSetString)
+ Net:ClientRegister(NodeType.ST_DB_PROXY, NMsgId.IdNAckRedisGet, self, self.AckGetString)
+ Net:ClientRegister(NodeType.ST_DB_PROXY, NMsgId.IdNAckRedisSet, self, self.AckSetString)
DbProxyID = GetDbProxyID()
end
diff --git a/src/lua/main.lua b/src/lua/main.lua
index 06b0f4fe..d31043bc 100644
--- a/src/lua/main.lua
+++ b/src/lua/main.lua
@@ -50,7 +50,7 @@ function ReadyUpdate()
ModuleMgr:Start()
end
--- Update for per second
+-- Update 10 fps
function Update()
ModuleMgr:Update()
end
@@ -74,12 +74,12 @@ function Load()
Require("lib.init")
local node_init = {
- [ServerType.ST_GAME ] = function()
+ [NodeType.ST_GAME ] = function()
Require("node.game.init")
end,
- [ServerType.ST_PLAYER] = function ()
+ [NodeType.ST_PLAYER] = function ()
Require("node.player.init")
- --Require("test.init")
+ -- Require("test.init")
end
}
if(node_init[Env.app_type]) then
diff --git a/src/node/db_proxy/CMakeLists.txt b/src/node/db_proxy/CMakeLists.txt
index deb6fc02..2ba061c4 100644
--- a/src/node/db_proxy/CMakeLists.txt
+++ b/src/node/db_proxy/CMakeLists.txt
@@ -1,5 +1,5 @@
-add_subdirectory(node)
add_subdirectory(mysql)
add_subdirectory(mongo)
add_subdirectory(redis)
-add_subdirectory(clickhouse)
\ No newline at end of file
+add_subdirectory(clickhouse)
+add_subdirectory(logic)
\ No newline at end of file
diff --git a/src/node/db_proxy/node/CMakeLists.txt b/src/node/db_proxy/logic/CMakeLists.txt
similarity index 75%
rename from src/node/db_proxy/node/CMakeLists.txt
rename to src/node/db_proxy/logic/CMakeLists.txt
index 96b7e872..fd240f17 100644
--- a/src/node/db_proxy/node/CMakeLists.txt
+++ b/src/node/db_proxy/logic/CMakeLists.txt
@@ -1,6 +1,6 @@
-set(ProjectName "db_proxy_node")
+set(ProjectName "db_proxy_logic")
file(GLOB soruces *.cc)
file(GLOB headers *.h)
add_library(${ProjectName} SHARED ${soruces} ${headers})
LinkSquick(${ProjectName})
-SquickOut(${ProjectName} "node/db_proxy" ${SQUICK_BUILD_PLUGIN_SERVER_PATH}/db_proxy "node")
\ No newline at end of file
+SquickOut(${ProjectName} "node/db_proxy" ${SQUICK_BUILD_PLUGIN_SERVER_PATH}/db_proxy "logic")
\ No newline at end of file
diff --git a/src/node/db_proxy/logic/i_logic_module.h b/src/node/db_proxy/logic/i_logic_module.h
new file mode 100644
index 00000000..93a3acd2
--- /dev/null
+++ b/src/node/db_proxy/logic/i_logic_module.h
@@ -0,0 +1,7 @@
+#pragma once
+
+#include
+namespace db_proxy::logic {
+class ILogicModule : public IModule {};
+
+} // namespace db_proxy::logic
diff --git a/src/node/db_proxy/logic/logic_module.cc b/src/node/db_proxy/logic/logic_module.cc
new file mode 100644
index 00000000..c1cb73b7
--- /dev/null
+++ b/src/node/db_proxy/logic/logic_module.cc
@@ -0,0 +1,10 @@
+#include "logic_module.h"
+
+namespace db_proxy::logic {
+bool LogicModule::Start() {
+ m_node_ = pm_->FindModule();
+ vector node_types = {};
+ m_node_->AddSubscribeNode(node_types);
+ return true;
+}
+} // namespace db_proxy::logic
\ No newline at end of file
diff --git a/src/node/db_proxy/logic/logic_module.h b/src/node/db_proxy/logic/logic_module.h
new file mode 100644
index 00000000..125a57a9
--- /dev/null
+++ b/src/node/db_proxy/logic/logic_module.h
@@ -0,0 +1,19 @@
+#pragma once
+#include "i_logic_module.h"
+#include
+#include
+
+namespace db_proxy::logic {
+class LogicModule : public ILogicModule {
+ public:
+ LogicModule(IPluginManager *p) {
+ pm_ = p;
+ is_update_ = true; // Update
+ }
+ virtual bool Start() override;
+
+ private:
+ INodeModule *m_node_;
+};
+
+} // namespace db_proxy::logic
\ No newline at end of file
diff --git a/src/node/master/node/plugin.cc b/src/node/db_proxy/logic/plugin.cc
similarity index 57%
rename from src/node/master/node/plugin.cc
rename to src/node/db_proxy/logic/plugin.cc
index 8cc1d5c8..0fd0571e 100644
--- a/src/node/master/node/plugin.cc
+++ b/src/node/db_proxy/logic/plugin.cc
@@ -1,8 +1,8 @@
#include "plugin.h"
-#include "node_module.h"
+#include "logic_module.h"
+namespace db_proxy::logic {
-namespace master::node {
SQUICK_EXPORT void SquickPluginLoad(IPluginManager *pm){CREATE_PLUGIN(pm, Plugin)};
SQUICK_EXPORT void SquickPluginUnload(IPluginManager *pm){DESTROY_PLUGIN(pm, Plugin)};
@@ -11,8 +11,8 @@ const int Plugin::GetPluginVersion() { return 0; }
const std::string Plugin::GetPluginName() { return GET_CLASS_NAME(Plugin); }
-void Plugin::Install() { REGISTER_MODULE(pm_, INodeModule, NodeModule) }
+void Plugin::Install() { REGISTER_MODULE(pm_, ILogicModule, LogicModule) }
-void Plugin::Uninstall() { UNREGISTER_MODULE(pm_, INodeModule, NodeModule) }
+void Plugin::Uninstall() { UNREGISTER_MODULE(pm_, ILogicModule, LogicModule) }
-} // namespace master::node
\ No newline at end of file
+} // namespace db_proxy::logic
\ No newline at end of file
diff --git a/src/node/web/node/plugin.h b/src/node/db_proxy/logic/plugin.h
similarity index 67%
rename from src/node/web/node/plugin.h
rename to src/node/db_proxy/logic/plugin.h
index 85a31384..df5773a7 100644
--- a/src/node/web/node/plugin.h
+++ b/src/node/db_proxy/logic/plugin.h
@@ -1,16 +1,17 @@
#pragma once
-#include
-#include
-
-namespace web::node {
+#include
+namespace db_proxy::logic {
class Plugin : public IPlugin {
public:
Plugin(IPluginManager *p) { pm_ = p; }
virtual const int GetPluginVersion();
+
virtual const std::string GetPluginName();
+
virtual void Install();
+
virtual void Uninstall();
};
-} // namespace web::node
+} // namespace db_proxy::logic
\ No newline at end of file
diff --git a/src/node/db_proxy/mysql/mysql_module.cc b/src/node/db_proxy/mysql/mysql_module.cc
index ca4fd185..d477483a 100644
--- a/src/node/db_proxy/mysql/mysql_module.cc
+++ b/src/node/db_proxy/mysql/mysql_module.cc
@@ -54,6 +54,9 @@ void MysqlModule::OnReqExecute(const socket_t sock, const int msg_id, const char
rpc::NAckMysqlExecute ack;
uint64_t uid;
try {
+ if (!session_) {
+ throw "session_ is nullptr";
+ }
assert(m_net_->ReceivePB(msg_id, msg, len, req, uid));
session_->sql(req.sql()).execute();
} catch (const std::exception &e) {
@@ -72,6 +75,9 @@ void MysqlModule::OnReqSelect(const socket_t sock, const int msg_id, const char
rpc::NAckMysqlSelect ack;
uint64_t uid;
try {
+ if (!session_) {
+ throw "session_ is nullptr";
+ }
assert(m_net_->ReceivePB(msg_id, msg, len, req, uid));
SqlResult result = session_->sql(req.sql()).execute();
auto result_data = result.fetchAll();
@@ -139,6 +145,9 @@ void MysqlModule::OnReqInsert(const socket_t sock, const int msg_id, const char
rpc::NAckMysqlInsert ack;
uint64_t uid;
try {
+ if (!session_) {
+ throw exception("sessions_ is nullptr");
+ }
assert(m_net_->ReceivePB(msg_id, msg, len, req, uid));
auto schema = session_->getSchema(req.database());
auto table = schema.getTable(req.table());
@@ -176,7 +185,12 @@ void MysqlModule::OnReqInsert(const socket_t sock, const int msg_id, const char
LogError(e.what(), __func__, __LINE__);
code = rpc::DbProxyCode::DB_PROXY_CODE_MYSQL_EXCEPTION;
ack.set_msg(e.what());
+ } catch (...) {
+ LogError("Insert excption", __func__, __LINE__);
+ code = rpc::DbProxyCode::DB_PROXY_CODE_MYSQL_EXCEPTION;
+ ack.set_msg("Insert excption");
}
+
ack.set_code(code);
ack.set_query_id(req.query_id());
m_net_->SendPBToNode(rpc::IdNAckMysqlInsert, ack, sock);
@@ -188,6 +202,9 @@ void MysqlModule::OnReqUpdate(const socket_t sock, const int msg_id, const char
rpc::NAckMysqlUpdate ack;
uint64_t uid;
try {
+ if (!session_) {
+ throw "session_ is nullptr";
+ }
assert(m_net_->ReceivePB(msg_id, msg, len, req, uid));
auto schema = session_->getSchema(req.database());
auto table = schema.getTable(req.table());
diff --git a/src/node/db_proxy/node/i_node_module.h b/src/node/db_proxy/node/i_node_module.h
deleted file mode 100644
index 3b1df02d..00000000
--- a/src/node/db_proxy/node/i_node_module.h
+++ /dev/null
@@ -1,9 +0,0 @@
-#pragma once
-
-#include
-#include
-
-namespace db_proxy::node {
-class INodeModule : public INodeBaseModule {};
-
-} // namespace db_proxy::node
diff --git a/src/node/db_proxy/node/node_module.cc b/src/node/db_proxy/node/node_module.cc
deleted file mode 100644
index eecff82a..00000000
--- a/src/node/db_proxy/node/node_module.cc
+++ /dev/null
@@ -1,22 +0,0 @@
-#include
-
-// #include "../logic/player_redis_module.h"
-#include "node_module.h"
-
-namespace db_proxy::node {
-
-bool NodeModule::AfterStart() {
-
- Listen();
- vector node_types = {ServerType::ST_WORLD};
- AddNodesByType(node_types);
- return true;
-}
-
-bool NodeModule::Destroy() { return true; }
-
-void NodeModule::OnClientDisconnect(const socket_t sock) {}
-
-void NodeModule::OnClientConnected(const socket_t sock) {}
-
-} // namespace db_proxy::node
\ No newline at end of file
diff --git a/src/node/db_proxy/node/node_module.h b/src/node/db_proxy/node/node_module.h
deleted file mode 100644
index 5564c80b..00000000
--- a/src/node/db_proxy/node/node_module.h
+++ /dev/null
@@ -1,23 +0,0 @@
-#pragma once
-
-#include "i_node_module.h"
-#include
-#include
-namespace db_proxy::node {
-class NodeModule : public INodeModule {
- public:
- NodeModule(IPluginManager *p) {
- pm_ = p;
- is_update_ = true;
- }
- virtual bool Destroy();
- virtual bool AfterStart();
-
- protected:
- void OnClientDisconnect(const socket_t sock);
- void OnClientConnected(const socket_t sock);
-
- protected:
-};
-
-} // namespace db_proxy::node
\ No newline at end of file
diff --git a/src/node/db_proxy/redis/redis_module.h b/src/node/db_proxy/redis/redis_module.h
index 843dd1ec..ce4dbcba 100644
--- a/src/node/db_proxy/redis/redis_module.h
+++ b/src/node/db_proxy/redis/redis_module.h
@@ -1,4 +1,3 @@
-#include "../node/i_node_module.h"
#include "i_redis_module.h"
#include
#include
diff --git a/src/node/ds_mgr/CMakeLists.txt b/src/node/ds_mgr/CMakeLists.txt
index 4e7656c1..8bf6ea94 100644
--- a/src/node/ds_mgr/CMakeLists.txt
+++ b/src/node/ds_mgr/CMakeLists.txt
@@ -1,2 +1 @@
-add_subdirectory(node)
add_subdirectory(logic)
diff --git a/src/node/ds_mgr/logic/logic_module.cc b/src/node/ds_mgr/logic/logic_module.cc
index 162a8a3a..3251d3f7 100644
--- a/src/node/ds_mgr/logic/logic_module.cc
+++ b/src/node/ds_mgr/logic/logic_module.cc
@@ -31,7 +31,7 @@ bool LogicModule::AfterStart() {
}*/
// 来自Game 服务器
- m_net_client_->AddReceiveCallBack(ServerType::ST_GAME, rpc::REQ_GAMEPLAY_CREATE, this, &LogicModule::OnReqPvpInstanceCreate);
+ m_net_client_->AddReceiveCallBack(rpc::ST_GAME, rpc::REQ_GAMEPLAY_CREATE, this, &LogicModule::OnReqPvpInstanceCreate);
return true;
}
diff --git a/src/node/ds_mgr/node/CMakeLists.txt b/src/node/ds_mgr/node/CMakeLists.txt
deleted file mode 100644
index 96f32553..00000000
--- a/src/node/ds_mgr/node/CMakeLists.txt
+++ /dev/null
@@ -1,6 +0,0 @@
-set(ProjectName "ds_mgr_node")
-file(GLOB soruces *.cc)
-file(GLOB headers *.h)
-add_library(${ProjectName} SHARED ${soruces} ${headers})
-LinkSquick(${ProjectName})
-SquickOut(${ProjectName} "node/ds_mgr" ${SQUICK_BUILD_PLUGIN_SERVER_PATH}/ds_mgr "node")
\ No newline at end of file
diff --git a/src/node/ds_mgr/node/i_node_module.h b/src/node/ds_mgr/node/i_node_module.h
deleted file mode 100644
index 03eac446..00000000
--- a/src/node/ds_mgr/node/i_node_module.h
+++ /dev/null
@@ -1,10 +0,0 @@
-#pragma once
-#include
-
-namespace gameplay_manager::node {
-class INodeModule : public INodeBaseModule {
- public:
- virtual bool Transport(const socket_t sock, const int msg_id, const char *msg, const uint32_t len) = 0;
-};
-
-} // namespace gameplay_manager::node
\ No newline at end of file
diff --git a/src/node/ds_mgr/node/node_module.cc b/src/node/ds_mgr/node/node_module.cc
deleted file mode 100644
index 783601b9..00000000
--- a/src/node/ds_mgr/node/node_module.cc
+++ /dev/null
@@ -1,32 +0,0 @@
-
-
-#include "node_module.h"
-#include
-#include
-#include
-namespace gameplay_manager::node {
-
-bool NodeModule::Destroy() { return true; }
-
-bool NodeModule::AfterStart() {
- // PVP校验连接Key,校验成功后,之后的数据直接转发到Game服务器上
- // m_net_->AddReceiveCallBack(rpc::REQ_GAMEPLAY_CONNECT_GAME_SERVER, this, &NodeModule::OnReqConnect);
- // m_net_->AddReceiveCallBack(this, &NodeModule::OnOtherMessage);
- Listen();
- // AddServer(ServerType::ST);
- return true;
-}
-
-// Gameplay服务器请求连接 Gameplay manager服务器
-void NodeModule::OnReqConnect(const socket_t sock, const int msg_id, const char *msg, const uint32_t len) {}
-
-// 来自PVP服务器消息,根据校验连接成功PVP服务器数据包转发达到Game服务器
-// void NodeModule::OnOtherMessage(const socket_t sock, const int msg_id, const char *msg, const uint32_t len) {}
-
-// PVP 服务端断开连接
-void NodeModule::OnClientDisconnect(const socket_t sock) {}
-
-// 转发给PVP服务器
-bool NodeModule::Transport(const socket_t sock, const int msg_id, const char *msg, const uint32_t len) { return true; }
-
-} // namespace gameplay_manager::node
\ No newline at end of file
diff --git a/src/node/ds_mgr/node/node_module.h b/src/node/ds_mgr/node/node_module.h
deleted file mode 100644
index 4a440959..00000000
--- a/src/node/ds_mgr/node/node_module.h
+++ /dev/null
@@ -1,33 +0,0 @@
-#pragma once
-
-#include "i_node_module.h"
-#include