NewLife
/
SmartOS
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

只能有一个令牌客户端实例

This commit is contained in:
大石头 2017-01-09 12:54:49 +08:00
parent e5392700a4
commit 82a799c79f
2 changed files with 23 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

37
TokenNet/TokenClient.cpp
View File

@ -17,30 +17,35 @@
#include "Security\RC4.h" #include "Security\RC4.h"
TokenClient* TokenClient::Current = nullptr;
static void BroadcastHelloTask(void* param); static void BroadcastHelloTask(void* param);
TokenClient::TokenClient() TokenClient::TokenClient()
: Routes(String::Compare) : Routes(String::Compare)
{ {
Token = 0; Token = 0;
Opened = false; Opened = false;
Status = 0; Status = 0;
LoginTime = 0; LoginTime = 0;
LastSend = 0; LastSend = 0;
LastActive = 0; LastActive = 0;
Delay = 0; Delay = 0;
MaxNotActive = 0; MaxNotActive = 0;
Master = nullptr; Master = nullptr;
Cfg = nullptr; Cfg = nullptr;
Received = nullptr; Received = nullptr;
Param = nullptr; Param = nullptr;
NextReport = 0; NextReport = 0;
ReportLength = 0; ReportLength = 0;
assert(!Current, "只能有一个令牌客户端实例");
Current = this;
// 重启 // 重启
//Register("Gateway/Restart", InvokeRestart, this); //Register("Gateway/Restart", InvokeRestart, this);
@ -1075,7 +1080,7 @@ bool TokenClient::InvokeSetRemote(void * param, const Pair& args, Stream& result
String remote; String remote;
byte fixd; byte fixd;
// 远程地址 // 远程地址
if (!args.Get("remote", remote)) if (!args.Get("remote", remote))
{ {
res.Set("SetRemote", (byte)0); res.Set("SetRemote", (byte)0);
@ -1093,7 +1098,7 @@ bool TokenClient::InvokeSetRemote(void * param, const Pair& args, Stream& result
debug_printf("远程地址设置\r\n"); debug_printf("远程地址设置\r\n");
uri.Show(); uri.Show();
// 永久改变地址 // 永久改变地址
if (fixd) if (fixd)
{ {
auto cfg = client->Cfg; auto cfg = client->Cfg;

2
TokenNet/TokenClient.h
View File

@ -90,6 +90,8 @@ public:
Register(action, *(InvokeHandler*)&func, target); Register(action, *(InvokeHandler*)&func, target);
} }
static TokenClient* Current;
// 重启，重置 // 重启，重置
static bool InvokeRestart(void * param, const Pair& args, Stream& result); static bool InvokeRestart(void * param, const Pair& args, Stream& result);
static bool InvokeReset(void * param, const Pair& args, Stream& result); static bool InvokeReset(void * param, const Pair& args, Stream& result);