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

源码开发语言/平台
当前位置：首页 > 源码/资料 > Internet/网络编程 > P2P编程 > 查看源码
SPClient.cpp
资源名称：p2p_vod.rar　[点击查看]
上传用户：liguizhu
上传日期：2015-11-01
资源大小：2422k
文件大小：17k
源码类别：

P2P编程

开发平台：

Visual C++

SPClient.cpp：源码内容
  1. /*
  2. *  Openmysee
  3. *
  4. *  This program is free software; you can redistribute it and/or modify
  5. *  it under the terms of the GNU General Public License as published by
  6. *  the Free Software Foundation; either version 2 of the License, or
  7. *  (at your option) any later version.
  8. *
  9. *  This program is distributed in the hope that it will be useful,
  10. *  but WITHOUT ANY WARRANTY; without even the implied warranty of
  11. *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  12. *  GNU General Public License for more details.
  13. *
  14. *  You should have received a copy of the GNU General Public License
  15. *  along with this program; if not, write to the Free Software
  16. *  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
  17. *
  18. */
  19. #include "StdAfx.h"
  20. #include "SPClient.h"
  21. #include "CaptureServer.h"
  22. #include "MD5.h"
  24. SPClient::SPClient(CaptureServer* cServer, NormalAddress address, BufferMgr* bufferMgr, LogMgr* log) : m_freeList(8, 1) {
  25. cs = cServer;
  26. m_bufferMgr = bufferMgr;
  27. logFile = log;
  28. addr = address;
  29. isRunning = TRUE;
  30. isLogin = FALSE;
  31. m_socket = INVALID_SOCKET;
  32. sendPointer = NULL;
  33. recvPointer = NULL;
  34. recvOff = 0;
  35. errStr[0] = 0;
  37. lastSentBlockID = 0;
  38. memset(&header, 0, sizeof(header));
  39. readData = 0;
  40.  
  41. DWORD threadID;
  42. hThread = CreateThread(
  43. NULL, 0, (LPTHREAD_START_ROUTINE)(SPClient::RunReceiver), this, 0, &threadID);
  44. }
  46. SPClient::~SPClient() {
  47. isRunning = FALSE;
  48. Disconnect();
  49. if(hThread) {
  50. // 如果一段时间内不能正常停止，就强行终止线程
  51. DWORD ret = WaitForSingleObject(hThread, 5000);
  52. if(ret == WAIT_TIMEOUT) {
  53. TerminateThread(hThread, 0);
  54. }
  55. CloseHandle(hThread);
  56. hThread = NULL;
  57. }
  58. }
  60. BOOL SPClient::SendRegister() {
  61. UINT8 nameSize = cs->cfgData.chnlStr.size();
  62. if(nameSize >= 0xff)
  63. return FALSE;
  65. TCPPacket* packet;
  66. if(!SendBegin(packet, CS2SP_REGISTER))
  67. return FALSE;
  69. //2.write channel name
  70. CopyMoveDes(sendPointer, &nameSize, sizeof(nameSize));
  71. CopyMoveDes(sendPointer, cs->cfgData.chnlStr.data(), nameSize);
  73. //3.write userinfo.
  74. CopyMoveDes(sendPointer, &cs->cfgData.userID, sizeof(UINT));
  75. CopyMoveDes(sendPointer, cs->cfgData.password.data(), MD5_LEN);
  77. //4. ratio ,maxblocksize
  78. UINT maxblockSize = BLOCK_SIZE;
  79. CopyMoveDes(sendPointer, &maxblockSize, sizeof(maxblockSize));
  81. float ratio = cs->GetSpeedInKBPS();
  82. CopyMoveDes(sendPointer, &ratio, sizeof(ratio));
  84. //5. write video & audio
  85.   TVMEDIATYPESECTION videoTV, audioTV;
  86. PBYTE videoData = NULL;
  87. PBYTE audioData = NULL;
  88. do{
  89. delete [] videoData;
  90. delete [] audioData;
  91. Sleep(100);
  92. if(!isRunning) {
  93. m_freeList.Release(packet);
  94. return FALSE;
  95. }
  96. }
  97. while(!cs->GetFormatData(videoTV, videoData, FALSE) || !cs->GetFormatData(audioTV, audioData, TRUE) );
  99. // 检查媒体类型数据是否正确,关键是是否为空
  100. if(videoTV.cbFormat <= 0 && audioTV.cbFormat <= 0) {
  101. MessageBox(cs->parentWindow, "媒体数据为空！请重新启动采集端。", "错误", MB_OK|MB_ICONSTOP);
  102. return FALSE;
  103. }
  105. USHORT channelinfoLen = 2*sizeof(TVMEDIATYPESECTION)+videoTV.cbFormat + audioTV.cbFormat;
  106. CopyMoveDes(sendPointer, &channelinfoLen, sizeof(channelinfoLen));
  108. CopyMoveDes(sendPointer, &videoTV, sizeof(TVMEDIATYPESECTION));
  109. if(videoData)
  110. CopyMoveDes(sendPointer, videoData, videoTV.cbFormat);
  112. CopyMoveDes(sendPointer, &audioTV, sizeof(TVMEDIATYPESECTION));
  113. if(audioData)
  114. CopyMoveDes(sendPointer, audioData, audioTV.cbFormat);
  116. SendEnd(packet);
  117. return TRUE;
  118. }
  120. /**********发送消息的函数**********/
  121. BOOL SPClient::SendBlock() {
  122. if(m_sendList.size() > 10)
  123. return TRUE;
  124. TCPPacket* packet;
  125. if(!SendBegin(packet, CS2SP_BLOCK))
  126. return FALSE;
  127.     
  128. //2.write ID.
  129. CopyMoveDes(sendPointer, &lastSentBlockID, sizeof(lastSentBlockID));
  131. //4.write data
  132. UINT size = 0;
  133. if(!m_bufferMgr->GetBlock(lastSentBlockID, reinterpret_cast<PBYTE>(sendPointer+sizeof(size)), size)) {
  134. // 一定要释放这个packet
  135. m_freeList.Release(packet);
  136. return TRUE;
  137. }
  138. char* hashcode = "";
  139. #ifdef DEBUG
  140. MD5 md5(reinterpret_cast<PBYTE>(sendPointer+sizeof(size)), size);
  141. hashcode = md5.hex_digest();
  142. #endif
  144. // verify block
  145. char* startPos = sendPointer+sizeof(size);
  146. char* tempPos = startPos + 8;
  148. if(lastSentBlockID == 0) {
  149. if(*((UINT*)startPos + 1) != UINT_MAX)
  150. tempPos = startPos + *((UINT*)startPos + 1);
  151. else
  152. tempPos = startPos + size;
  153. }
  155. while(header.size < 1638400) {
  156. //写header信息
  157. if((UINT)readData < sizeof(header)) {
  158. if(startPos+size - tempPos < sizeof(header)-readData){
  159. memcpy((char*)&header + readData, tempPos, startPos+size - tempPos);
  160. readData += startPos+size - tempPos;
  161. break;
  162. }
  163. else {
  164. memcpy((char*)&header + readData, tempPos, sizeof(header)-readData);
  165. tempPos += sizeof(header)-readData;//头的位置tempPos
  166. readData = sizeof(header);
  168. //assert(header.size < 1638400);
  169. if(header.size >= 1638400) {
  170. logFile->StatusOut("Header size %d, blockID %d, offset %d", 
  171. header.size, lastSentBlockID, readData);
  172. break;
  173. }
  174. }
  175. }
  176. if(readData >= sizeof(header)) {
  177. if(startPos+size - tempPos < header.size - readData) {
  178. readData += startPos+size - tempPos;
  179. break;
  180. }
  181. else {
  182. tempPos += header.size - readData;
  183. readData = 0;
  184. }
  185. }
  186. }
  188.     //3.write data size 
  189. CopyMoveDes(sendPointer, &size, sizeof(size));
  191. int firstKeySampleOffset;
  192. memcpy(&firstKeySampleOffset, packet->buf+sizeof(UINT)*3+sizeof(char), sizeof(firstKeySampleOffset));
  193. LONGLONG keySample;
  194. memcpy(&keySample, packet->buf+sizeof(UINT)*3+sizeof(char)+firstKeySampleOffset, sizeof(keySample));
  195. memcpy(&firstKeySampleOffset, packet->buf+sizeof(UINT)*3+sizeof(char), sizeof(firstKeySampleOffset));
  196. if(firstKeySampleOffset == 0)
  197. keySample = 0;
  198. char temp[64];
  199. _i64toa(keySample, temp, 10);
  200. logFile->StatusOut("Queue Block. ID:%d/%d, offset: %d, keysample: %s, hash %s", 
  201. lastSentBlockID, m_bufferMgr->GetMaxBlockID(), firstKeySampleOffset, temp, hashcode);
  202. #ifdef DEBUG
  203. delete [] hashcode;
  204. #endif
  206. sendPointer += size;
  208. SendEnd(packet);
  210. lastSentBlockID++;
  211. return TRUE;
  212. }
  214. BOOL SPClient::SendUpdate(){
  215. TCPPacket* packet;
  216. if(!SendBegin(packet, CS2SP_UPDATE))
  217. return FALSE;
  219. float ratio = cs->GetSpeedInKBPS();
  220. CopyMoveDes(sendPointer, &ratio, sizeof(ratio));
  222. SendEnd(packet);
  223. return TRUE;
  224. }
  226. BOOL SPClient::SendMediaType() {
  227.     MediaData mediaData;
  228.     if(!m_bufferMgr->GetMediaData(lastSentBlockID, mediaData))
  229.         return FALSE;
  231. TCPPacket* packet;
  232. if(!SendBegin(packet, CS2SP_MEDIA_TYPE))
  233. return FALSE;
  235.     UINT size = mediaData.audioType.cbFormat + mediaData.videoType.cbFormat + 
  236.         sizeof(mediaData.audioType) + sizeof(mediaData.videoType);
  237.     CopyMoveDes(sendPointer, &size, sizeof(UINT));
  239.     CopyMoveDes(sendPointer, &mediaData.videoType, sizeof(mediaData.videoType));
  240.     CopyMoveDes(sendPointer, mediaData.videoData, mediaData.videoType.cbFormat);
  241.     CopyMoveDes(sendPointer, &mediaData.audioType, sizeof(mediaData.audioType));
  242.     CopyMoveDes(sendPointer, mediaData.audioData, mediaData.audioType.cbFormat);
  244. logFile->StatusOut("Queue Block media data. ID:%d/%d", lastSentBlockID, m_bufferMgr->GetMaxBlockID());
  246. SendEnd(packet);
  247. return TRUE;
  248. }
  250. CONNECT_RESULT SPClient::Connecting() {
  251. logFile->StatusOut("Connecting to %s:%d.", inet_ntoa(addr.sin_addr), ntohs(addr.sin_port));
  253. CONNECT_RESULT ret = CR_ERROR;
  255. // Create a TCP/IP socket that is bound to the server.
  256. // Microsoft Knowledge Base: WSA_FLAG_OVERLAPPED Is Needed for Non-Blocking Sockets
  257. // http://support.microsoft.com/default.aspx?scid=kb;EN-US;179942
  258. m_socket = WSASocket(AF_INET, SOCK_STREAM, 0, NULL, 0, WSA_FLAG_OVERLAPPED);
  259. if(m_socket == INVALID_SOCKET) {
  260. logFile->StatusErr("Creating socket", WSAGetLastError());
  261. return ret;
  262. }
  264. // 不使用Nagle算法
  265. BOOL bNoDelay = TRUE;
  266. if(setsockopt(m_socket, SOL_SOCKET, TCP_NODELAY, (const char*)&bNoDelay, sizeof(bNoDelay)) == SOCKET_ERROR) {
  267. logFile->StatusErr("Setting UDP socket as TCP_NODELAY", WSAGetLastError());
  268. return ret;
  269. }
  271. // Set this socket as a Non-blocking socket.
  272. ULONG flag = 1;
  273. if(ioctlsocket(m_socket, FIONBIO, &flag) == SOCKET_ERROR) {
  274. logFile->StatusErr("Setting socket as non-blocking", WSAGetLastError());
  275. return ret;
  276. }
  278. // Connect to remote address
  279. if(WSAConnect(m_socket, (sockaddr*)&addr, sizeof(sockaddr), NULL, NULL, NULL, NULL) == SOCKET_ERROR) {
  280. if(WSAGetLastError() != WSAEWOULDBLOCK) {
  281. logFile->StatusErr("Connecting socket", WSAGetLastError());
  282. return ret;
  283. }
  284. else {
  285. ret = CR_WOULDBLOCK;
  286. logFile->StatusOut("%s:%d is blocking.", inet_ntoa(addr.sin_addr), ntohs(addr.sin_port));
  287. }
  288. }
  289. else {
  290. ret = CR_CONNECTED;
  291. logFile->StatusOut("%s:%d is connected.", inet_ntoa(addr.sin_addr), ntohs(addr.sin_port));
  292. }
  293. return ret;
  294. }
  296. void SPClient::Disconnect() {
  297. isLogin = FALSE;
  298. m_bufferMgr->StopSave();
  299. ClearTransferInfo();
  300. m_sendList.clear();
  301. if(m_socket != INVALID_SOCKET) {
  302. ::TE_CloseSocket(m_socket, FALSE);
  303. logFile->StatusOut("SPClient: disconnected from %s:%d.", inet_ntoa(addr.sin_addr), ntohs(addr.sin_port));
  304. m_socket = INVALID_SOCKET;
  305. }
  306. }
  308. BOOL SPClient::BaseRecv() {
  309. int ret = recv(m_socket, recvBuf+recvOff, P2P_BUF_SIZE-recvOff, 0);
  310. if(ret < 0) {
  311. DWORD lastError = ::WSAGetLastError();
  312. if (WSAEWOULDBLOCK != lastError) {
  313. logFile->StatusErr("Receiving data on TCP", lastError);
  314. return FALSE;
  315. }
  316. else
  317. return TRUE;
  318. }
  319. else if(0 == ret) {
  320. logFile->StatusOut("Connection has been disconnected gracefully.");
  321. return FALSE;
  322. }
  324. recvOff += ret;
  325. totalDownBytes += ret;
  327. BOOL retVal = FALSE;
  329. for(;;) {
  330. // because multiple msgs can be received at once.
  331. // keep call parseMsg() till !MSG_COMPLETE
  332. MSG_STATE ms = ParseMsg(); 
  334. switch(ms) {
  335. case MSG_COMPLETE:
  336. continue;
  337. case MSG_UNCOMPLETE:
  338. retVal = TRUE;
  339. break;
  340. case MSG_ERR_SIZE:
  341. sprintf(errStr, "错误的消息大小!");
  342. break;
  343. case MSG_ERR_TYPE: 
  344. sprintf(errStr, "错误的消息类型!");
  345. break;
  346. break;
  347. case MSG_REMOTE_ERR:
  348. // 错误信息已经在errStr中了
  349. break;
  350. default:
  351. sprintf(errStr, "未知错误类型!");
  352. break;
  353. }
  354. if(strlen(errStr) > 0)
  355. logFile->StatusOut("错误: %s", errStr);
  356. break;
  357. }
  358. return retVal;
  359. }
  361. MSG_STATE SPClient::ParseMsg() {
  362. // 如果过小，则不是正常的包
  363. if(recvOff < sizeof(int)+sizeof(BYTE))
  364. return MSG_UNCOMPLETE;
  366. // 把移动指针放到数据的起始地址
  367. recvPointer = recvBuf;
  369. // 读取消息大小
  370. UINT msgSize;
  371. CopyMoveSrc(&msgSize, recvPointer, sizeof(msgSize));
  373. // 读取消息类型
  374. UINT8 msgType;
  375. CopyMoveSrc(&msgType, recvPointer, sizeof(msgType));
  377. // msgSize是否正常
  378. if(msgSize > P2P_BUF_SIZE || msgSize < sizeof(int)+sizeof(BYTE))
  379. return MSG_ERR_SIZE;
  381. // 是否包含完成的消息
  382. if(recvOff < msgSize)
  383. return MSG_UNCOMPLETE;
  385. MSG_STATE ret = MSG_COMPLETE;
  386. switch(msgType) {
  387. case SP2CS_WELCOME:
  388. ret = OnWelcome();
  389. break;
  390. case SP2CS_MSG:
  391. ret = OnMsg();
  392. break;
  393. default:
  394. ret = MSG_ERR_TYPE;
  395. break;
  396. }
  398. // copy left data to start of recvBuf
  399. if(recvOff >= msgSize) {
  400. memcpy(recvBuf, recvBuf+msgSize, recvOff-msgSize);
  401. recvOff -= msgSize;
  402. }
  404. return ret;
  405. }
  407. //解析注册成功消息
  408. MSG_STATE SPClient::OnWelcome() {
  409. UINT startBlockID;
  410. CopyMoveSrc(&startBlockID, recvPointer, sizeof(startBlockID));
  412. lastSentBlockID = startBlockID;
  413. logFile->StatusOut("Start Block %d.", lastSentBlockID);
  415. isLogin = TRUE;
  416. return MSG_COMPLETE;
  417. }
  419. //收到SP_MSG消息
  420. MSG_STATE SPClient::OnMsg() {
  421. // 错误代码
  422. UINT16 errCode;
  423. CopyMoveSrc(&errCode, recvPointer, sizeof(errCode));
  425. // 是否需要断开连接
  426. bool shouldDisconnect;
  427. CopyMoveSrc(&shouldDisconnect, recvPointer, sizeof(shouldDisconnect));
  429. // 根据错误代码处理
  430. switch(errCode) {
  431. case ERR_PROTOCOL_FORMAT:
  432. sprintf(errStr, "协议错误");
  433. break;
  434. case ERR_AUTHORIZATION:
  435. sprintf(errStr, "验证错误");
  436. break;
  437. case ERR_INTERNAL:
  438. sprintf(errStr, "未知错误");
  439. break;
  440. default:
  441. shouldDisconnect = true;
  442. }
  443. if(shouldDisconnect) {
  444. return MSG_REMOTE_ERR;
  445. }
  447. return MSG_COMPLETE;
  448. }
  450. BOOL SPClient::SendPackets() {
  451. if(m_sendList.empty())
  452. return TRUE;
  454. TCPPacket* packet = m_sendList.front();
  455. m_sendList.pop_front();
  457. int ret = send(m_socket, packet->buf+packet->sent, min(packet->size-packet->sent, 40000), 0);
  458. if(SOCKET_ERROR == ret) {
  459. DWORD lastError = ::WSAGetLastError();
  460. if (WSAEWOULDBLOCK == lastError) {
  461. m_sendList.push_front(packet);
  462. }
  463. else {
  464. m_sendList.push_front(packet);
  465. logFile->StatusErr("Sending data on TCP", lastError);
  466. return FALSE;
  467. }
  468. }
  469. else {
  470. totalUpBytes += ret;
  471. logFile->StatusOut("Send data %d of %d", ret, packet->size-packet->sent);
  472. assert(ret <= packet->size-packet->sent);
  473. if(ret == packet->size-packet->sent) {
  474. if(packet->size > 16384)
  475. logFile->StatusOut("Sent Block %d.", *packet->GetBlockID());
  476. // 已经发送完毕，释放Buffer
  477. m_freeList.Release(packet);
  478. }
  479. else { // 尚未发送完毕，下次继续发送
  480. packet->sent += ret;
  481. m_sendList.push_front(packet);
  482. logFile->StatusOut("!!!!!!!!!!!");
  483. }
  484. }
  485. return TRUE;
  486. }
  488. void SPClient::RunReceiver(SPClient* client)
  489. {
  490. timeval timeout; 
  491. DWORD lastSentUpdate = 0;
  493. fd_set read_set, write_set;
  495. DWORD lastManageTime=0, currTime=0;
  497. while(client->isRunning)
  498. {
  499. if(client->m_socket == INVALID_SOCKET)
  500. {
  501. if(!client->m_bufferMgr->ShouldConnect()) {
  502. Sleep(500);
  503. continue;
  504. }
  505. CONNECT_RESULT ret = client->Connecting();
  506. if(ret == CR_WOULDBLOCK) {
  507. // 等待8秒钟，看能否连接上
  508. FD_ZERO(&write_set);
  509. FD_SET(client->m_socket, &write_set);
  510. timeout.tv_sec = 8;
  511. timeout.tv_usec = 0;
  512. int s = select(0, NULL, &write_set, NULL, &timeout);
  513. if(s > 0)
  514. ret = CR_CONNECTED;
  515. }
  516. if(ret == CR_CONNECTED) {
  517. client->lastSentBlockID = 0;
  518. client->readData = 0;
  519. // 可以开始存储数据了
  520. client->m_bufferMgr->StartSave();
  521. }
  522. else {
  523. TE_CloseSocket(client->m_socket, FALSE);
  524. client->m_socket = INVALID_SOCKET;
  525. client->logFile->StatusOut("无法连接SP，请检查网络。");
  526. //MessageBox(NULL, "无法连接SP，请检查网络。然后重新打开本程序。", "错误", MB_OK|MB_ICONINFORMATION);
  527.                 for(int i = 0; i < client->cs->cfgData.reconnectSecond; ++i) {
  528.                     if(!client->isRunning)
  529.                         break;
  530.     Sleep(1000);
  531.                 }
  532. continue;
  533. }
  534. }
  535. if(client->SendRegister()) {
  536. // 开始接收发送数据
  537. while(client->isRunning) {
  538. // 获取当前时间
  539. currTime = timeGetTime();
  541. timeout.tv_sec = 0;
  542. timeout.tv_usec = 20000;
  543. FD_ZERO(&read_set);
  544. FD_SET(client->m_socket, &read_set);
  545. int s = select(0, &read_set, 0, NULL, &timeout);
  546. if(s > 0) {
  547.                     if(FD_ISSET(client->m_socket, &read_set)) {
  548.                         // 接收信息
  549.                         if(!client->BaseRecv()) {
  550.                             for(int i = 0; i < client->cs->cfgData.reconnectSecond; ++i) {
  551.                                 if(!client->isRunning)
  552.                                     break;
  553.                                 Sleep(1000);
  554.                             }
  555.                             break;
  556. }
  557. }
  558. }
  559.   else if(s == SOCKET_ERROR) {
  560. client->logFile->StatusErr("selecting", WSAGetLastError());
  561. Sleep(1); // prevent dead loop
  562. }
  563. if(currTime-lastManageTime >= 10000) {
  564. lastManageTime = currTime;
  565. // 生成传输信息并打印
  566. client->GenerateTransferInfo(TRUE);
  567. client->logFile->StatusOut("Cur: (%.2f/%.2f)KB/s. Avg: (%.2f/%.2f)KB/s. Total: %.2f/%.2fMB.", 
  568. client->currDownSpeed/1024, client->currUpSpeed/1024, 
  569. client->avgDownSpeed/1024, client->avgUpSpeed/1024, 
  570. client->totalDownBytes/1024.f/1024.f, client->totalUpBytes/1024.f/1024.f);
  571. }
  573. if(!client->m_bufferMgr->CheckRecvingSample()) {
  574. client->logFile->StatusOut("No Sample Any More!");
  575. //MessageBox(client->cs->parentWindow, "CaptureServer 20秒钟没有接收到Sample了！", "Sample中断", MB_OK|MB_ICONSTOP);
  576. if(client->cs->parentWindow)
  577. SendMessage(client->cs->parentWindow, WM_NOMORESAMPLE, 0, 0);
  578. }
  580. // 发送数据
  581.                 if(client->isLogin && client->isRunning) {
  582.                     // 目前SP尚不支持这个协议
  583.                     //client->SendMediaType();
  584. client->SendBlock();
  585.                 }
  586. if(currTime-lastSentUpdate > 10000) {
  587. if(!client->SendUpdate())
  588. break;
  589. lastSentUpdate = currTime;
  590. }
  591. if(!client->SendPackets())
  592. break;
  593. }
  594. }
  595. client->Disconnect();
  596. }
  597. }
  599. BOOL SPClient::SendBegin(TCPPacket*& packet, UINT8 msgType) {
  600. packet= m_freeList.Allocate();
  601. if(!packet)
  602. return FALSE;
  604. // 先留着消息大小不写，到最后再写
  605. sendPointer = packet->buf+sizeof(UINT);
  606. CopyMoveDes(sendPointer, &msgType, sizeof(msgType));
  608. return TRUE;
  609. }
  611. void SPClient::SendEnd(TCPPacket*& packet) {
  612. // 消息的大小就是移动的指针减去初始的指针
  613. packet->size = sendPointer-packet->buf;
  614. packet->sent = 0;
  615. memcpy(packet->buf, &packet->size, sizeof(packet->size));
  617. m_sendList.push_back(packet);
  618. }
  620. void SPClient::CopyMoveSrc(void * des, const char *& src, size_t size) {
  621. assert(des && src);
  622. if(!des || !src)
  623. return;
  624. memcpy(des, src, size);
  625. src += size;
  626. }
  628. void SPClient::CopyMoveDes(char *& des, const void * src, size_t size) {
  629. assert(des && src);
  630. if(!des || !src)
  631. return;
  632. memcpy(des, src, size);
  633. des += size;
  634. }