Fishing-game-source-code/usermgr.cpp at main · pokerdeveloper/Fishing-game-source-code · GitHub

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
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
#include "usermgr.h"
#include "sproxy.h"


UserMgr::UserMgr()
{
	pthread_mutexattr_t m_mutexattr;
	pthread_mutexattr_init(&m_mutexattr);
	pthread_mutexattr_settype(&m_mutexattr, PTHREAD_MUTEX_RECURSIVE_NP);
	pthread_mutex_init(&m_lockGameuser,&m_mutexattr);

}

void UserMgr::init(SProxy* proxy,int maxNum)
{
	m_pLogger = proxy->getAsyncLog();
	m_pProxy = proxy;
	m_userData.m_nMaxUserNum = maxNum;

	if(m_userData.m_nMaxUserNum <=1)
	{
		throw std::string("UserMgr::usernum <= 1");
	}
	m_userData.m_pUserContainer = new GameUserInfo*[m_userData.m_nMaxUserNum];
	memset(m_userData.m_pUserContainer,0,m_userData.m_nMaxUserNum*sizeof(GameUserInfo*));
	for(int i=0; i<m_userData.m_nMaxUserNum; i++)
	{
		m_userData.m_lstUnUsedIndex.push_back(i);
		*(m_userData.m_pUserContainer+i) = new GameUserInfo();
		(*(m_userData.m_pUserContainer+i))->pGameuser = new GameUser(m_pProxy);
	}
	m_pLogger->debug ("UserMgr::init:max_user:%d",m_userData.m_nMaxUserNum);
}

UserMgr::~UserMgr()
{
	DO_LOCK_DESTROY(m_lockGameuser);
}


GameUserInfo* UserMgr::newGameUser(int iUID)
{
	GameUserInfo* pTmp = m_userData.getUnUsedUser();
	if (NULL == pTmp) return NULL;
	else return pTmp;
}

void UserMgr::delGameUser(GameUserInfo* del_user)
{
	m_userData.setUserUnUsed(del_user->m_nIndex);
}


GameUserInfo* UserMgr::linkGameUser(GameUserInfo* pTmp)
{
	DO_LOCK(m_lockGameuser);
	m_mapUid2Info[pTmp->userid] = pTmp;
	DO_UNLOCK(m_lockGameuser);
	return pTmp;
}

void UserMgr::deleteGameUser_NoLock(int iUID, bool real_del)
{
	m_pLogger->debug ("deleteGameUser:index:%d,puid:%d", m_mapUid2Info[iUID]->m_nIndex,iUID);
	m_userData.setUserUnUsed(m_mapUid2Info[iUID]->m_nIndex);
	m_mapUid2Info.erase(iUID);
}

//判断game user 是否存在
bool UserMgr::isGameUserExist(int iUID)
{
	GameUserInfo* p_uinfo = NULL;
	DO_LOCK(m_lockGameuser);
	if (m_mapUid2Info.find(iUID) != m_mapUid2Info.end())
	{
		p_uinfo = m_mapUid2Info[iUID];
	}
	DO_UNLOCK(m_lockGameuser);

	return NULL != p_uinfo;
}

bool UserMgr::isOnlineByUid(int iUID)
{
	GameUserInfo* p_uinfo = NULL;
	DO_LOCK(m_lockGameuser);
	if (m_mapUid2Info.find(iUID) != m_mapUid2Info.end())
	{
		p_uinfo = m_mapUid2Info[iUID];
	}
	DO_UNLOCK(m_lockGameuser);
	return NULL != p_uinfo;

}
GameUserInfo* UserMgr::getUserInfo(int iUID)
{
	return this->getUserInfoByUid(iUID);
}

GameUserInfo* UserMgr::getUserInfoByUid(int uid)
{
	GameUserInfo* p_uinfo = NULL;
	DO_LOCK(m_lockGameuser);
    Uid2InfoMap::iterator itr = m_mapUid2Info.find(uid);
    if(itr != m_mapUid2Info.end())
    {
        p_uinfo = itr->second;
    }
	DO_UNLOCK(m_lockGameuser);
	return p_uinfo;
}

Connection* UserMgr::getValidConn(void)
{
	Connection *pConn = NULL;
	DO_LOCK(m_lockGameuser);
	Uid2InfoMap::iterator iter = m_mapUid2Info.begin();
	for (; iter != m_mapUid2Info.end(); ++iter)
	{
		if (iter->second->pCon)
		{
			pConn = iter->second->pCon;
			break;
		}
	}
	DO_UNLOCK(m_lockGameuser);
	return pConn;
}

void UserMgr::delUserInfoByUid(int uid)
{
	DO_LOCK(m_lockGameuser);
	Uid2InfoMap::iterator iter = m_mapUid2Info.find(uid);
	int iPUID = iter->second->userid;
	deleteGameUser_NoLock(iPUID, true);
	m_mapUid2Info.erase(uid);
	DO_UNLOCK(m_lockGameuser);
}