1
This commit is contained in:
parent
ea6cfe8bdb
commit
045b34151a
@ -1,6 +1,7 @@
|
|||||||
#pragma once
|
#pragma once
|
||||||
|
|
||||||
#include "framework/cpp/protoutils.h"
|
#include "framework/cpp/protoutils.h"
|
||||||
|
#include "framework/cpp/netmsghandler.h"
|
||||||
|
|
||||||
namespace a8
|
namespace a8
|
||||||
{
|
{
|
||||||
@ -30,6 +31,9 @@ class IMConn
|
|||||||
{
|
{
|
||||||
static int msgid = f8::Net_GetMessageId(msg);
|
static int msgid = f8::Net_GetMessageId(msg);
|
||||||
f8::Net_SendMsg(tcp_client_, 0, msgid, msg);
|
f8::Net_SendMsg(tcp_client_, 0, msgid, msg);
|
||||||
|
#ifdef DEBUG
|
||||||
|
f8::DumpMsgToLog(msg, "<<<<<<<IMC ");
|
||||||
|
#endif
|
||||||
}
|
}
|
||||||
|
|
||||||
private:
|
private:
|
||||||
|
@ -1,5 +1,7 @@
|
|||||||
#pragma once
|
#pragma once
|
||||||
|
|
||||||
|
#include "framework/cpp/netmsghandler.h"
|
||||||
|
|
||||||
//imserver listener
|
//imserver listener
|
||||||
namespace a8
|
namespace a8
|
||||||
{
|
{
|
||||||
@ -29,6 +31,9 @@ class IMListener : public a8::Singleton<IMListener>
|
|||||||
{
|
{
|
||||||
static int msgid = f8::Net_GetMessageId(msg);
|
static int msgid = f8::Net_GetMessageId(msg);
|
||||||
f8::Net_SendMsg(tcp_listener_, socket_handle, 0, msgid, msg);
|
f8::Net_SendMsg(tcp_listener_, socket_handle, 0, msgid, msg);
|
||||||
|
#ifdef DEBUG
|
||||||
|
f8::DumpMsgToLog(msg, "<<<<<<<IML ");
|
||||||
|
#endif
|
||||||
}
|
}
|
||||||
|
|
||||||
void ForwardTargetConnMsg(f8::MsgHdr& hdr);
|
void ForwardTargetConnMsg(f8::MsgHdr& hdr);
|
||||||
|
@ -1,6 +1,7 @@
|
|||||||
#pragma once
|
#pragma once
|
||||||
|
|
||||||
#include "framework/cpp/protoutils.h"
|
#include "framework/cpp/protoutils.h"
|
||||||
|
#include "framework/cpp/netmsghandler.h"
|
||||||
|
|
||||||
namespace a8
|
namespace a8
|
||||||
{
|
{
|
||||||
@ -29,6 +30,9 @@ class MSConn
|
|||||||
{
|
{
|
||||||
static int msgid = f8::Net_GetMessageId(msg);
|
static int msgid = f8::Net_GetMessageId(msg);
|
||||||
f8::Net_SendMsg(tcp_client_, 0, msgid, msg);
|
f8::Net_SendMsg(tcp_client_, 0, msgid, msg);
|
||||||
|
#ifdef DEBUG
|
||||||
|
f8::DumpMsgToLog(msg, "<<<<<<<MSC ");
|
||||||
|
#endif
|
||||||
}
|
}
|
||||||
|
|
||||||
private:
|
private:
|
||||||
|
@ -1,5 +1,7 @@
|
|||||||
#pragma once
|
#pragma once
|
||||||
|
|
||||||
|
#include "framework/cpp/netmsghandler.h"
|
||||||
|
|
||||||
//gate listener
|
//gate listener
|
||||||
namespace a8
|
namespace a8
|
||||||
{
|
{
|
||||||
@ -29,6 +31,9 @@ class WSListener : public a8::Singleton<WSListener>
|
|||||||
{
|
{
|
||||||
static int msgid = f8::Net_GetMessageId(msg);
|
static int msgid = f8::Net_GetMessageId(msg);
|
||||||
f8::Net_SendProxyMsg(tcp_listener_, sockhandle, 0, 0, msgid, msg);
|
f8::Net_SendProxyMsg(tcp_listener_, sockhandle, 0, 0, msgid, msg);
|
||||||
|
#ifdef DEBUG
|
||||||
|
f8::DumpMsgToLog(msg, "<<<<<<<WSL ");
|
||||||
|
#endif
|
||||||
}
|
}
|
||||||
|
|
||||||
template <typename T>
|
template <typename T>
|
||||||
@ -36,6 +41,9 @@ class WSListener : public a8::Singleton<WSListener>
|
|||||||
{
|
{
|
||||||
static int msgid = f8::Net_GetMessageId(msg);
|
static int msgid = f8::Net_GetMessageId(msg);
|
||||||
f8::Net_SendProxyMsg(tcp_listener_, sockhandle, seqid, 0, msgid, msg);
|
f8::Net_SendProxyMsg(tcp_listener_, sockhandle, seqid, 0, msgid, msg);
|
||||||
|
#ifdef DEBUG
|
||||||
|
f8::DumpMsgToLog(msg, "<<<<<<<WSL ");
|
||||||
|
#endif
|
||||||
}
|
}
|
||||||
|
|
||||||
void SendText(unsigned short sockhandle, const std::string& text);
|
void SendText(unsigned short sockhandle, const std::string& text);
|
||||||
|
@ -373,6 +373,9 @@ void App::ProcessWSProxyMsg(f8::MsgHdr& hdr)
|
|||||||
}
|
}
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
|
#ifdef DEBUG
|
||||||
|
f8::DumpMsgToLog(hdr, handler, ">>>>>>WSP ");
|
||||||
|
#endif
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -390,6 +393,9 @@ void App::ProcessIMServerMsg(f8::MsgHdr& hdr)
|
|||||||
}
|
}
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
|
#ifdef DEBUG
|
||||||
|
f8::DumpMsgToLog(hdr, handler, ">>>>>>IMS ");
|
||||||
|
#endif
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -407,6 +413,9 @@ void App::ProcessIMConnMsg(f8::MsgHdr& hdr)
|
|||||||
}
|
}
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
|
#ifdef DEBUG
|
||||||
|
f8::DumpMsgToLog(hdr, handler, ">>>>>>IMC ");
|
||||||
|
#endif
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -427,6 +436,9 @@ void App::ProcessMSConnMsg(f8::MsgHdr& hdr)
|
|||||||
}
|
}
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
|
#ifdef DEBUG
|
||||||
|
f8::DumpMsgToLog(hdr, handler, ">>>>>>MSC ");
|
||||||
|
#endif
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
2
third_party/framework
vendored
2
third_party/framework
vendored
@ -1 +1 @@
|
|||||||
Subproject commit 6a5392433ccd85ffbfea9a904fde0f5bae22c155
|
Subproject commit 6d4d04235b27818b29d0f83206052de90ac8afd8
|
Loading…
x
Reference in New Issue
Block a user