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

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

模拟服务器

开发平台：

C/C++

KRoleBlockProcess.cpp：源码内容
  1. // KRoleBlockProcess.cpp: implementation of the KRoleBlockProcess class.
  2. //
  3. //////////////////////////////////////////////////////////////////////
  5. #include "stdafx.h"
  6. //#include "RoleDBServer.h"
  7. #include "KRoleBlockProcess.h"
  8. #include "memory.h"
  9. #include "windows.h"
  11. /*#ifdef _DEBUG
  12. #undef THIS_FILE
  13. static char THIS_FILE[]=__FILE__;
  14. #define new DEBUG_NEW
  15. #endif
  16. */
  17. #define NULL 0
  19. //////////////////////////////////////////////////////////////////////
  20. // Construction/Destruction
  21. //////////////////////////////////////////////////////////////////////
  23. KRoleBlockProcess::KRoleBlockProcess()
  24. {
  25. m_pProcessData = 0;
  26. m_nStreamSize = 0;
  27. m_nCurDataLen = 0;
  28. }
  30. KRoleBlockProcess::~KRoleBlockProcess()
  31. {
  32. if (m_pProcessData)
  33. delete m_pProcessData;
  35. }
  37. //获得每块长度为nBlockSize大小的，第nNo块的KBlock
  38. size_t KRoleBlockProcess::GetBlockPtr(KBlock * pBlock, unsigned long nNo, size_t nBlockSize)
  39. {
  40. if (!pBlock || nNo < 0 || nBlockSize <= sizeof(KBlock) - 1 ) return 0;
  41. if (!m_pProcessData || m_pProcessData->nDataLen < 0) return 0;
  42. size_t nMemSize = 0;
  43. if (nNo == 0)
  44. {
  45. pBlock->bDataState = 1;
  46. pBlock->nOffset =  m_pProcessData->nDataLen;
  47. pBlock->nProtoId = m_pProcessData->nProtoId;
  49. if (m_pProcessData->nDataLen + sizeof(KBlock) - 1 <=  nBlockSize)
  50. {
  51. nMemSize = m_pProcessData->nDataLen;
  52. }
  53. else 
  54. nMemSize = nBlockSize - sizeof(KBlock) + 1;
  55. }
  56. else 
  57. {
  58. pBlock->bDataState = 0;
  59. pBlock->nOffset =  nNo * (nBlockSize - sizeof(KBlock) + 1) ;
  60. pBlock->nProtoId = m_pProcessData->nProtoId;
  63. if (m_pProcessData->nDataLen < pBlock->nOffset + nBlockSize - sizeof(KBlock) + 1)
  64. {
  65. nMemSize =  m_pProcessData->nDataLen - pBlock->nOffset;
  66. }
  67. else
  68. {
  69. nMemSize = nBlockSize - sizeof(KBlock) + 1;
  70. }
  72. }
  74. pBlock->nDataLen = nMemSize;
  75. if (!nNo)
  76. memcpy(&pBlock->pDataBuffer[0], m_pProcessData->pDataBuffer, nMemSize);
  77. else 
  78. memcpy(&pBlock->pDataBuffer[0], m_pProcessData->pDataBuffer + pBlock->nOffset, nMemSize );
  80. return nMemSize + sizeof(KBlock) - 1;
  82. }
  84. //生成Steam
  85. unsigned long KRoleBlockProcess::SetStream(TStreamData * pData, size_t nStreamSize)
  86. {
  87. if (!m_pProcessData || m_nStreamSize < nStreamSize )
  88. {
  89. GenStream(nStreamSize);
  90. }
  91. memcpy(m_pProcessData , pData, nStreamSize);
  92. return nStreamSize;
  93. }
  95. unsigned long KRoleBlockProcess::GenStream(size_t nStreamSize)
  96. {
  97. if (m_pProcessData)
  98. {
  99. delete []m_pProcessData;
  100. m_pProcessData = NULL;
  101. }
  102. m_pProcessData = (TStreamData*) new char [nStreamSize];
  103. m_nStreamSize = nStreamSize;
  104. return nStreamSize;
  105. }
  107. //设置某一块
  108. unsigned long KRoleBlockProcess::SetBlock(KBlock * pBlock, unsigned long nNo, size_t nBlockSize)
  109. {
  110. if (!pBlock || nNo < 0 || nBlockSize <= sizeof(KBlock) - 1 ) return 0;
  111. int nOffset = 0;
  112. if (pBlock->nDataLen > nBlockSize - sizeof(KBlock) + 1 )  return 0;
  113. if (pBlock->bDataState == 1)
  114. {
  115. m_pProcessData->nDataLen = pBlock->nOffset ;
  116. m_pProcessData->nProtoId = pBlock->nProtoId;
  117. nOffset = 0;
  118. }
  120. //if (nNo * nBlockSize > m_pProcessData->nDataLen + sizeof)
  122. memcpy(&m_pProcessData->pDataBuffer[0] + (nBlockSize - sizeof(KBlock) + 1) * nNo, &pBlock->pDataBuffer[0] , pBlock->nDataLen);
  123. m_nCurDataLen  += pBlock->nDataLen;
  124. return pBlock->nDataLen;
  125. }
  127. unsigned long KRoleBlockProcess::SetBlock(KBlock * pBlock)
  128. {
  129. if (!pBlock ) return 0;
  130. int nOffset = 0;
  131. if (pBlock->bDataState == 1)
  132. {
  133. m_pProcessData->nDataLen = pBlock->nOffset ;
  134. m_pProcessData->nProtoId = pBlock->nProtoId;
  135. nOffset = 0;
  136. }
  137. else 
  138. nOffset = pBlock->nOffset;
  140. memcpy(&m_pProcessData->pDataBuffer[0] + nOffset , &pBlock->pDataBuffer[0] , pBlock->nDataLen);
  141. m_nCurDataLen  += pBlock->nDataLen;
  142. return pBlock->nDataLen;
  143. }