forked from jimingmin/frame
-
Notifications
You must be signed in to change notification settings - Fork 0
/
logic_thread.cpp
89 lines (72 loc) · 1.67 KB
/
logic_thread.cpp
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
/*
* logic_thread.cpp
*
* Created on: May 3, 2015
* Author: jimm
*/
#include "logic_thread.h"
#include "frame.h"
using namespace FRAME;
CLogicThread::CLogicThread(CriticalSection *pSection, const char *szServerName, IInitFrame *pIniter, list<CFrameListenEntry *> &stListenEntryList):
m_stListenEntryList(stListenEntryList)
{
m_pSection = pSection;
memset(m_szServerName, 0, sizeof(m_szServerName));
strcpy(m_szServerName, szServerName);
m_pIniter = pIniter;
//创建网络事件处理器
m_pNetHandler = new CNetHandler();
}
CLogicThread::~CLogicThread()
{
if(m_pNetHandler != NULL)
{
delete m_pNetHandler;
m_pNetHandler = NULL;
}
}
//启动线程
int32_t CLogicThread::Start()
{
m_pSection->enter();
m_pNetHandler->CreateReactor();
g_Frame.AddRunner(m_pNetHandler);
if(g_Frame.Init(m_szServerName) != 0)
{
return 1;
}
if(m_pIniter != NULL)
{
if(m_pIniter->InitFrame(m_pNetHandler) != 0)
{
return 1;
}
}
for(list<CFrameListenEntry *>::iterator it = m_stListenEntryList.begin(); it != m_stListenEntryList.end(); ++it)
{
CAcceptor *pAcceptor = new CAcceptor(m_pNetHandler, (*it)->GetPacketParserFactory(), (*it)->GetIOHandler());
pAcceptor->Bind((*it)->GetListenAddr(), (*it)->GetListenPort());
}
return CThread::Start();
}
//结束线程
int32_t CLogicThread::Terminate()
{
CThread::Terminate();
if(m_pNetHandler != NULL)
{
g_Frame.ClearRunner();
m_pNetHandler->DestoryReactor();
for(list<CAcceptor *>::iterator it = m_stAcceptorList.begin(); it != m_stAcceptorList.end(); ++it)
{
delete (*it);
}
m_stAcceptorList.clear();
}
return 0;
}
void CLogicThread::Execute()
{
g_Frame.Run(GetTerminated());
g_Frame.Uninit();
}