added:heart active for session module

Author: xengine-qyt

XEngine_Source/MQCore_SessionModule/MQCore_SessionModule.def

@@ -9,6 +9,7 @@ EXPORTS
 	SessionModule_Client_Delete
 	SessionModule_Client_GetAuth
 	SessionModule_Client_GetUser
+	SessionModule_Client_Heart
 
 	SessionModule_Notify_Create
 	SessionModule_Notify_Destory

XEngine_Source/MQCore_SessionModule/SessionModule_Client/SessionModule_Client.cpp

@@ -236,6 +236,42 @@ BOOL CSessionModule_Client::SessionModule_Client_GetUser(LPCTSTR lpszSessionStr,
 	st_Locker.unlock_shared();
 	return TRUE;
 }
+/********************************************************************
+函数名称：SessionModule_Client_Heart
+函数功能：触发一次心跳
+ 参数.一：lpszClientAddr
+  In/Out：In
+  类型：常量字符指针
+  可空：N
+  意思：输入要触发的客户端
+返回值
+  类型：逻辑型
+  意思：是否成功
+备注：
+*********************************************************************/
+BOOL CSessionModule_Client::SessionModule_Client_Heart(LPCTSTR lpszClientAddr)
+{
+	Session_IsErrorOccur = FALSE;
+
+	if (NULL == lpszClientAddr)
+	{
+		Session_IsErrorOccur = TRUE;
+		Session_dwErrorCode = ERROR_MQ_MODULE_SESSION_PARAMENT;
+		return FALSE;
+	}
+	st_Locker.lock_shared();
+	unordered_map<tstring, XENGINE_SESSIONINFO>::iterator stl_MapIterator = stl_MapSession.find(lpszClientAddr);
+	if (stl_MapIterator == stl_MapSession.end())
+	{
+		Session_IsErrorOccur = TRUE;
+		Session_dwErrorCode = ERROR_MQ_MODULE_SESSION_NOTFOUND;
+		st_Locker.unlock_shared();
+		return FALSE;
+	}
+	stl_MapIterator->second.nTimeStart = time(NULL);
+	st_Locker.unlock_shared();
+	return TRUE;
+}
 ///////////////////////////////////////////////////////////////////////////////
 //                      线程函数
 ///////////////////////////////////////////////////////////////////////////////

XEngine_Source/MQCore_SessionModule/SessionModule_Client/SessionModule_Client.h

@@ -30,6 +30,7 @@ class CSessionModule_Client
     BOOL SessionModule_Client_Delete(LPCTSTR lpszClientAddr);
     BOOL SessionModule_Client_GetAuth(LPCTSTR lpszClientAddr, TCHAR* ptszUserName = NULL);
     BOOL SessionModule_Client_GetUser(LPCTSTR lpszSessionStr, TCHAR* ptszUserName = NULL);
+    BOOL SessionModule_Client_Heart(LPCTSTR lpszClientAddr);
 protected:
     static XHTHREAD CALLBACK SessionModule_Client_Thread(LPVOID lParam);
 private:

XEngine_Source/MQCore_SessionModule/Session_Define.h

@@ -148,6 +148,20 @@ extern "C" BOOL SessionModule_Client_GetAuth(LPCTSTR lpszClientAddr, TCHAR * pts
 备注：
 ************************************************************************/
 extern "C" BOOL SessionModule_Client_GetUser(LPCTSTR lpszSessionStr, TCHAR* ptszUserName = NULL);
+/********************************************************************
+函数名称：SessionModule_Client_Heart
+函数功能：触发一次心跳
+ 参数.一：lpszClientAddr
+  In/Out：In
+  类型：常量字符指针
+  可空：N
+  意思：输入要触发的客户端
+返回值
+  类型：逻辑型
+  意思：是否成功
+备注：
+*********************************************************************/
+extern "C" BOOL SessionModule_Client_Heart(LPCTSTR lpszClientAddr);
 /************************************************************************/
 /*                        订阅                                          */
 /************************************************************************/

XEngine_Source/MQCore_SessionModule/pch.cpp

@@ -55,6 +55,10 @@ extern "C" BOOL SessionModule_Client_GetUser(LPCTSTR lpszSessionStr, TCHAR * pts
 {
 	return m_SessionClient.SessionModule_Client_GetUser(lpszSessionStr, ptszUserName);
 }
+extern "C" BOOL SessionModule_Client_Heart(LPCTSTR lpszClientAddr)
+{
+	return m_SessionClient.SessionModule_Client_Heart(lpszClientAddr);
+}
 /************************************************************************/
 /*                        订阅                                          */
 /************************************************************************/