开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 游戏 > 模拟服务器 > 查看源码
zport.h
资源名称：SwordOnline.rar　[点击查看]
上传用户：dzyhzl
上传日期：2019-04-29
资源大小：56270k
文件大小：9k
源码类别：

模拟服务器

开发平台：

C/C++

zport.h：源码内容
  1. #ifndef ZPORT_H
  2. #define ZPORT_H
  4. //Windows相关的代码----------------------------------------------------------------------------------
  5. #ifdef WIN32
  6. #include <windows.h>
  7. #else
  8. #include <pthread.h>
  9. #include <sys/types.h>
  10. #include <sys/socket.h>
  11. #include <arpa/inet.h>
  12. #include <unistd.h>
  13. #include <signal.h>
  14. #include <fcntl.h>
  15. #endif
  17. #include <stdio.h>
  18. #include <string.h>
  20. #ifndef WIN32
  21. #define WINAPI
  22. #define BYTE unsigned char
  23. #define DWORD  unsigned long
  24. #define LPVOID void *
  26. #ifdef _DEBUG
  27. //{
  28. void _trace(char *fmt, ...);
  30. #ifndef ASSERT
  31. #define ASSERT(x) { if ( !( x ) ) _asm{ int 0x03 } }
  32. #endif
  34. #ifndef VERIFY
  35. #define VERIFY(x) { if ( !( x ) ) _asm{ int 0x03 } }
  36. #endif
  37. //}
  38. #else
  39. //{
  40. #ifndef ASSERT
  41. #define ASSERT(x)
  42. #endif
  44. #ifndef VERIFY
  45. #define VERIFY(x) x
  46. #endif
  47. //}
  48. #endif
  50. #ifdef _DEBUG
  51. //{
  52. #ifndef TRACE
  53. #define TRACE _trace
  54. #endif
  55. //}
  56. #else
  57. //{
  58. inline void _trace(const char* fmt, ...) { }
  59. #ifndef TRACE
  60. #define TRACE  1 ? (void)0 : _trace
  61. #endif
  62. //}
  63. #endif
  65. #define INIT_PTR(x) do{ (x) = NULL; }while(0);
  67. #define SAFE_DELETE(x) try{ if( (x) != NULL ) { delete (x); (x) = NULL; } } catch(...) { TRACE("SAFE_DELETE errorn"); }
  68. #define SAFE_DELETE_ARRAY(x) try{ if( (x) != NULL ) { delete[] (x); (x) = NULL; } } catch(...) { TRACE("SAFE_DELETE_ARRAY errorn"); }
  70. #ifndef SAFE_FREE
  71. #undef SAFE_FREE
  72. #define SAFE_FREE(x) try{ if( (x) != NULL ) { free(x); (x)=NULL; } } catch(...) { TRACE("SAFE_FREE errorn"); }
  73. #endif
  75. #ifndef SAFE_RELEASE
  76. #undef SAFE_RELEASE
  77. #define SAFE_RELEASE(x) try{ if( (x) != NULL ) { (x)->Release(); (x) = NULL; } } catch(...) { TRACE("SAFE_RELEASE errorn"); }
  78. #endif
  80. #define SAFE_CLOSEHANDLE(x) try{ if (x) { CloseHandle(x); (x) = NULL; } } catch(...) { TRACE("SAFE_CLOSEHANDLE errorn"); }
  81. #define SAFE_FREELIB(x) try{ if (x) { FreeLibrary(x); (x) = NULL; } } catch(...) { TRACE("SAFE_FREELIB errorn"); }
  83. /*
  84.  * Quick and safely convert number format
  85.  */
  87. #ifndef MAKEFOURCC
  88. //{
  89. #define MAKEFOURCC(ch0, ch1, ch2, ch3)
  90. ((DWORD)(BYTE)(ch0) | ((DWORD)(BYTE)(ch1) << 8) |
  91. ((DWORD)(BYTE)(ch2) << 16) | ((DWORD)(BYTE)(ch3) << 24 ))
  92. //}
  93. #endif
  95. #define COUNT_OF_ARRAY(array) ( sizeof( array ) / sizeof( array[0] ) )
  97. /*
  98.  * 'c' must be a char and not be a expression in the _private macro 
  99.  */
  100. #define _private_IS_NUM(c)     ((c) >= '0' && (c) <= '9')
  101. #define _private_IS_SPACE(c)   ((c) == ' ' || (c) == 'r' || (c) == 'n' || (c) == 't' || (c) == 'x')
  103. #define IS_NUM(c) _private_IS_NUM(c)
  104. #define IS_SPACE(c) _private_IS_SPACE(c)
  106. inline void strlwr(char* sz)
  107. {
  108. char c;
  109. for (int i = 0; 0 != (c = sz[i]); i++)
  110. {
  111. if (c >= 'A' && c <= 'Z')
  112. sz[i] = c + ('a' - 'A');
  113. }
  114. }
  116. #define SOCKET int
  117. #define closesocket close
  118. #define INVALID_SOCKET -1
  119. #endif
  120. //封装的互斥量类
  121. class ZMutex {
  122. #ifdef WIN32
  123.   CRITICAL_SECTION mutex;
  124. #else
  125. public:
  126.   pthread_mutex_t mutex;
  127.   //static int all_count;
  128.   int count;
  129. #endif
  130. public:
  131.   ZMutex() {
  132. #ifdef WIN32
  133.     InitializeCriticalSection(&mutex);
  134. #else
  135. pthread_mutexattr_t attr;
  136. pthread_mutexattr_init(&attr);
  137. pthread_mutexattr_settype(&attr, PTHREAD_MUTEX_RECURSIVE);
  138.     int rc = pthread_mutex_init(&mutex, &attr);
  139. //printf("ZMutex Created..n");
  140. count = 0;
  141. #endif                
  142.   }
  143.   ~ZMutex() {
  144. #ifdef WIN32
  145.     DeleteCriticalSection(&mutex);
  146. #else
  147.     int rc = pthread_mutex_destroy(&mutex);
  148. //printf("ZMutex released..n");
  149. #endif                
  150.   }
  151.   bool trylock()
  152.   {
  153. #ifdef WIN32
  154.   return false;
  155. #else
  156. int rc = pthread_mutex_trylock(&mutex);
  157. /* if (rc != 0)
  158. {
  159. printf("trylock mutex error %dn", rc);
  160. }*/
  161. return (0 == rc);
  162. #endif
  163.   }
  164.   void lock() {
  165. #ifdef WIN32        
  166.     EnterCriticalSection(&mutex);
  167. #else
  168.     int rc = pthread_mutex_lock(&mutex);
  169. if (rc != 0)
  170. {
  171. printf("lock mutex error %dn", rc);
  172. }
  173. //all_count++;
  174. count++;
  175. #endif                
  176.   }
  177.   void unlock() {
  178. #ifdef WIN32        
  179.     LeaveCriticalSection(&mutex);
  180. #else
  181. //all_count--;
  182. count--;
  183.     int rc = pthread_mutex_unlock(&mutex);
  184. if (rc != 0)
  185. {
  186. printf("unlock mutex error %dn", rc);
  187. }
  188. #endif                
  189.   }
  190. };
  192. //封装的定时器类(精确到毫秒)
  193. class ZTimer {
  194. public:
  195.   static inline unsigned long now() { //返回当前的毫秒数
  196. #ifdef WIN32        
  197.     return GetTickCount();
  198. #else
  199.     return 0;
  200. #endif
  201.   }
  202. };
  204. //封装的线程类,继承这个类可以实现
  205. class ZThread {
  206. #ifdef WIN32
  207.   unsigned long id;
  208.   HANDLE handle;
  209. #else
  210.   pthread_t p_thread;
  211. #endif
  212. public:
  213. bool bStop;
  214. ZThread() {
  215. #ifdef WIN32
  216. id = -1;
  217. #endif
  218. bStop = false;
  219. }
  220. void start();
  221. void stop();
  222. virtual int action() = 0;
  223. };
  225. #include <map>
  226. #include <list>
  228. namespace OnlineGameLib {
  230. /*
  231.  * CNodeList
  232.  */
  233. class CNodeList
  234. {
  235. public:
  237. class Node
  238.     {
  239. public:
  241. Node *Next() const { return m_pNext; };
  243. void Next( Node *pNext );
  245. void AddToList( CNodeList *pList );
  247. void RemoveFromList();
  249. protected:
  251. Node();
  252. ~Node();
  254. private:
  256. friend class CNodeList;
  258. void Unlink();
  260. Node *m_pNext;
  261. Node *m_pPrev;
  263. CNodeList *m_pList;
  264. };
  266. CNodeList();
  268. void PushNode( Node *pNode );
  270. Node *PopNode();
  272. Node *Head() const { return m_pHead; };
  274. size_t Count() const { return m_numNodes; };
  276. bool Empty() const { return ( 0 == m_numNodes ); };
  278. private:
  280. friend void Node::RemoveFromList();
  282. void RemoveNode( Node *pNode );
  284. Node *m_pHead; 
  286. size_t m_numNodes;
  287. };
  289. inline void CNodeList::Node::Next( Node *pNext )
  290. {
  291. m_pNext = pNext;
  293. if ( pNext )
  294. {
  295. pNext->m_pPrev = this;
  296. }
  297. }
  299. /*
  300.  * TNodeList
  301.  */
  303. template <class T> class TNodeList : public CNodeList
  304. {
  305. public:
  306.          
  307. T *PopNode();
  308.    
  309. T *Head() const;
  311. static T *Next( const T *pNode );
  312. };
  314. template <class T>
  315. T *TNodeList<T>::PopNode()
  316. {
  317. return static_cast< T* >( CNodeList::PopNode() );
  318. }
  320. template <class T>
  321. T *TNodeList<T>::Head() const
  322. {
  323. return static_cast< T* >( CNodeList::Head() );
  324. }
  326. template <class T>
  327. T *TNodeList<T>::Next( const T *pNode )
  328. {
  329. return static_cast< T* >( pNode->Next() );
  330. }
  332. } // End of namespace OnlineGameLib
  334. namespace OnlineGameLib {
  335. namespace Win32 {
  337. /*
  338.  * CBuffer class
  339.  */
  340. class CBuffer : public CNodeList::Node
  341. {
  342. public:
  344. class Allocator;
  346. friend class Allocator;
  348. size_t GetUsed() const { return m_used; };
  349. size_t GetSize() const { return m_size; };
  351. const BYTE *GetBuffer() const { return m_buffer_ptr; };
  353. CBuffer *GetHeadPack( size_t packLength );
  354. CBuffer *GetNextPack();
  355. bool  HaveNextPack() { return ( m_offsetNextPack < m_used ) ? true : false; };
  357. void AddData( const char * const pData, size_t dataLength );
  358. void AddData( const BYTE * const pData, size_t dataLength );
  359. void AddData( BYTE data );
  361. void Use( size_t dataUsed ) { m_used += dataUsed; };
  363. CBuffer *SplitBuffer( size_t bytesToRemove );
  365. CBuffer *AllocateNewBuffer() const;
  367. void ConsumeAndRemove( size_t bytesToRemove );
  369. void Empty() { m_used = 0; };
  371. void AddRef() { m_ref++; };
  372. void Release();
  374. private:
  376. Allocator &m_allocator;
  378. long m_ref;
  380. const size_t m_size;
  381. size_t m_used;
  383. size_t m_packLength;
  384. size_t m_offsetNextPack;
  386. /*
  387.  * start of the actual buffer, must remain the last
  388.  * data member in the class.
  389.  */
  390. BYTE *m_buffer_ptr; // four bytes aligned
  392. //BYTE m_buffer_base_addr[0];
  394. private:
  396. static void *operator new( size_t objSize, size_t bufferSize );
  397. static void operator delete( void *pObj, size_t bufferSize );
  398.       
  399. CBuffer( Allocator &allocator, size_t size );
  400. ~CBuffer();
  402. /*
  403.  * No copies do not implement
  404.  */
  405. CBuffer( const CBuffer &rhs );
  406. CBuffer &operator=( const CBuffer &rhs );
  408. };
  410. inline void CBuffer::ConsumeAndRemove( size_t bytesToRemove )
  411. {
  412. m_used -= bytesToRemove;
  414. memmove( m_buffer_ptr, m_buffer_ptr + bytesToRemove, m_used );
  415. }
  418. /*
  419.  * CBuffer::Allocator class
  420.  */
  421. class CBuffer::Allocator
  422. {
  423. public:
  425. friend class CBuffer;
  427. explicit Allocator( size_t bufferSize, size_t maxFreeBuffers );
  429. virtual ~Allocator();
  431. CBuffer *Allocate();
  433. size_t GetBufferSize() const { return m_bufferSize; };
  435. bool ReSet( size_t bufferSize, size_t maxFreeBuffers )
  436. {
  437. memcpy((void*)&m_bufferSize, &bufferSize, sizeof( size_t ) );
  438. memcpy((void*)&m_maxFreeBuffers, &maxFreeBuffers, sizeof( size_t ) );
  440. return true;
  441. }
  443. protected:
  445. void Flush();
  447. private:
  449. void Release( CBuffer *pBuffer );
  451. virtual void OnBufferCreated() {}
  452. virtual void OnBufferAllocated() {}
  453. virtual void OnBufferReleased() {}
  455. void DestroyBuffer( CBuffer *pBuffer )
  456. {
  457. SAFE_DELETE( pBuffer );
  458. }
  460. const size_t m_bufferSize;
  462. typedef TNodeList< CBuffer > BufferList;
  464. BufferList m_freeList;
  465. BufferList m_activeList;
  467. const size_t m_maxFreeBuffers;
  469.     /*
  470.  * No copies do not implement
  471.  */
  472. Allocator( const Allocator &rhs );
  473. Allocator &operator=( const Allocator &rhs );
  475. };
  477. } // End of namespace OnlineGameLib
  478. } // End of namespace Win32
  480. #endif