Category

Development Platform
Home > SourceCode/Document > Game Program > Game Server Simulator > View Code
PingThread.h
Package: SwordOnline.rar　[view]
Upload User: dzyhzl
Upload Date: 2019-04-29
Package Size: 56270k
Code Size: 2k
Category:

Game Server Simulator

Development Platform:

C/C++

PingThread.h：Code Content
  1. ////////////////////////////////////////////////////////////////////////////////
  2. //  
  3. //  FileName    :   PingThread.h
  4. //  Version     :   1.0
  5. //  Creater     :   Linsuyi
  6. //  Date        :   2002-01-10  10:30:13
  7. //  Comment     :   Tcp/ip ping thread header file
  8. //  
  9. ////////////////////////////////////////////////////////////////////////////////
  11. #if !defined(AFX_PINGTHREAD_H__BF9EABCA_24CC_48A9_8415_DFD06A7F07AD__INCLUDED_)
  12. #define AFX_PINGTHREAD_H__BF9EABCA_24CC_48A9_8415_DFD06A7F07AD__INCLUDED_
  14. #if _MSC_VER > 1000
  15. #pragma once
  16. #endif // _MSC_VER > 1000
  18. #include "PingSocket.h"
  20. class IKPingCallback
  21. {
  22. public:
  23.     virtual int  GetNextUrl(
  24.         ULONG      *pulContextWith,
  25.         int         nUrlBufSize,
  26.         char       *pszUrlTextBuf
  27.     ) = 0;
  28.     virtual int  PingStatus(
  29.         ULONG       ulContextWith,
  30.         ULONG       ulStatusType,
  31.         ULONG       ulStatusParam
  32.     ) = 0;
  33. };
  36. #define PINGTHREAD_PINGCOUNT                3
  37. #define PINGTHREAD_WAITEXITTIME             4000
  39. #define PINGTHREAD_URLMAXLENGTH             1024
  42. class CPingThread
  43.   : public CPingSocket
  44. {
  45. public:
  46.     CPingThread();
  47.     virtual ~CPingThread();
  48.     
  49. public:
  50.     void SetTimeOut(int nTimeOut = DEFAULT_PING_TIMEOUT);
  51.     void SetSplitTimes(int nTimes = PINGTHREAD_PINGCOUNT);
  52.     
  53.     void SetCallback(IKPingCallback *piCallback);
  54.     
  55.     int StartPingThread();
  56.     int StopPingThread(int nForceStop = false);
  57.     
  58.     HANDLE GetThreadHandle();
  59.     
  60. protected:
  61.     int  DoStatusNotify(ULONG ulOccurEvent, ULONG ulOccurParam);
  62.     void SetContext(ULONG ulContext);
  63.     
  64. protected:
  65.     virtual int OnPingStatus(int nOccurEvent);
  66.     
  67. protected:
  68.     ULONG MainExecution();
  69.     
  70. private:
  71.     static ULONG WINAPI PingThreadProc(LPVOID lpThisParam);
  72.     
  73. protected:
  74.     int m_nRepeatCount;
  75.     int m_nPingTimeOut;
  76.     
  77.     HANDLE m_hPingThread;
  78.     ULONG  m_ulPingThreadId;
  79.     
  80.     ULONG m_ulContextWith;
  81.     IKPingCallback *m_piCallback;
  82. };
  84. #endif // !defined(AFX_PINGTHREAD_H__BF9EABCA_24CC_48A9_8415_DFD06A7F07AD__INCLUDED_)