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

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

P2P编程

开发平台：

Visual C++

CaptureServer.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 "CaptureServer.h"
  22. // { Implementation of CaptureServer
  23. CaptureServer::CaptureServer()
  24. : parentWindow(0), videoData(0), audioData(0), passwordStatus(2),
  25.   m_llVideoTime(0), m_llAudioTime(0), m_bTransDataEnd(FALSE),m_bIsOnlyOnePin(FALSE)
  26. {
  27. memset(&videoStruct, 0, sizeof(videoStruct));
  28. memset(&audioStruct, 0, sizeof(audioStruct));
  29. cfgData.reconnectSecond = 120;
  30. }
  32. CaptureServer::~CaptureServer()
  33. {
  34. for(UINT i = 0; i < bufferList.size();++i)
  35. {
  36. delete clientList[i];
  37. delete bufferList[i];
  38. delete logList[i];
  39. }
  41. bufferList.clear();
  42. clientList.clear();
  43. logList.clear();
  45. TE_CleanupLibrary();
  46. SAFE_ARRAYDELETE(audioData);
  47. SAFE_ARRAYDELETE(videoData);
  49. ::DeleteCriticalSection(&m_SamQueueCSec);
  50. }
  52. BOOL CaptureServer::Init()
  53. {
  54. TE_InitLibrary(); 
  56. if(!LoadConfigFile())
  57. return FALSE;
  59. logList.resize(cfgData.spAddress.size());
  60. bufferList.resize(cfgData.spAddress.size());
  61. clientList.resize(cfgData.spAddress.size());
  63. NormalAddress addr;
  64. addr.sin_family = AF_INET;
  65. addr.sin_port = htons(SP4CS_PORT);
  66. int i = 0;
  67. for(list<string>::iterator it = cfgData.spAddress.begin(); it != cfgData.spAddress.end(); ++it)
  68. {
  69. addr.sin_addr.s_addr = inet_addr(it->data());
  70. logList[i] = new LogMgr();
  71. logList[i]->Init();
  72. logList[i]->PrintTime(TRUE);
  74. bufferList[i] = new BufferMgr(this);
  75. if(!bufferList[i])
  76. return FALSE;
  78. clientList[i] = new SPClient(this, addr, bufferList[i], logList[i]);
  79. if(!clientList[i])
  80. return FALSE;
  81. i++;
  82. Sleep(100); // 防止按照时间取得文件名相同
  83. }
  85. totalBytes = 0;
  86. GetSystemTime(&startTime);
  88. ::InitializeCriticalSection(&m_SamQueueCSec);
  90. //cfgData.savePath = "f:\";
  92. return TRUE;
  93. }
  95. void CaptureServer::Stop()
  96. {
  97. /*此处之所以直接PutSample而不做任何限制是因为
  98.   CaptureServer的PutSample可以保证当音视频流
  99.   全部结束时一定能够把队列取空。如果是中途
  100.   应用层强制停止，有可能会造成某路队列数据
  101.   非空，但这是没法避免的，此时此处处理或者
  102.   是把数据丢掉只保留前面的同步后数据，或者
  103.   把剩余队列中不同步数据也写入，此处采用后者。
  104.   在依靠底层返回EC_COMPLETE来触发Stop是不会
  105.   出现此现象的。
  106. */
  108. ::EnterCriticalSection(&m_SamQueueCSec);
  109. int ii = m_AudioSamQueue.size();
  110. int iii = m_VideoSamQueue.size();
  112. SAMPLEDATA *pSAMPLEDATA = NULL;
  113. while(m_AudioSamQueue.size() > 0 && m_VideoSamQueue.size() > 0)
  114. {
  115. if (m_AudioSamQueue.front()->samplehr.start >= m_VideoSamQueue.front()->samplehr.start)
  116. {
  117. pSAMPLEDATA = m_VideoSamQueue.front();
  118. m_zzlWriter.PutSample(pSAMPLEDATA->samplehr, pSAMPLEDATA->pData);
  119. m_VideoSamQueue.pop();
  120. delete pSAMPLEDATA->pData;
  121. pSAMPLEDATA->pData = NULL;
  122. delete pSAMPLEDATA;
  123. pSAMPLEDATA = NULL;
  124. }
  125. else
  126. {
  127. pSAMPLEDATA = m_AudioSamQueue.front();
  128. m_zzlWriter.PutSample(pSAMPLEDATA->samplehr, pSAMPLEDATA->pData);
  129. m_AudioSamQueue.pop();
  130. delete pSAMPLEDATA->pData;
  131. pSAMPLEDATA->pData = NULL;
  132. delete pSAMPLEDATA;
  133. pSAMPLEDATA = NULL;
  134. }
  135. }
  137. int iiii = m_VideoSamQueue.size();
  138. int iiiii = m_AudioSamQueue.size();
  140. while(m_AudioSamQueue.size() > 0)
  141. {
  142. SAMPLEDATA *pSAMPLEDATA = m_AudioSamQueue.front();
  143. m_zzlWriter.PutSample(pSAMPLEDATA->samplehr, pSAMPLEDATA->pData);
  144. m_AudioSamQueue.pop();
  145. delete pSAMPLEDATA->pData;
  146. delete pSAMPLEDATA;
  147. }
  149. while(m_VideoSamQueue.size() > 0)
  150. {
  151. SAMPLEDATA *pSAMPLEDATA = m_VideoSamQueue.front();
  152. m_zzlWriter.PutSample(pSAMPLEDATA->samplehr, pSAMPLEDATA->pData);
  153. m_VideoSamQueue.pop();
  154. delete pSAMPLEDATA->pData;
  155. delete pSAMPLEDATA;
  156. }
  157. m_bTransDataEnd = TRUE;
  158. TRACE5("CaptureServer::Stop处理剩余包n");
  160. ::LeaveCriticalSection(&m_SamQueueCSec);
  161. /*
  162. ::EnterCriticalSection(&m_SamQueueCSec);
  163. int ii = m_AudioSamQueue.size();
  164. while(m_AudioSamQueue.size() > 0)
  165. {
  166. SAMPLEDATA *pSAMPLEDATA = m_AudioSamQueue.front();
  167. m_zzlWriter.PutSample(pSAMPLEDATA->samplehr, pSAMPLEDATA->pData);
  168. m_AudioSamQueue.pop();
  169. delete pSAMPLEDATA->pData;
  170. delete pSAMPLEDATA;
  171. }
  172. int iii = m_VideoSamQueue.size();
  173. while(m_VideoSamQueue.size() > 0)
  174. {
  175. SAMPLEDATA *pSAMPLEDATA = m_VideoSamQueue.front();
  176. m_zzlWriter.PutSample(pSAMPLEDATA->samplehr, pSAMPLEDATA->pData);
  177. m_VideoSamQueue.pop();
  178. delete pSAMPLEDATA->pData;
  179. delete pSAMPLEDATA;
  180. }
  181. m_bTransDataEnd = TRUE;
  182. ::LeaveCriticalSection(&m_SamQueueCSec);
  183. */
  184. }
  186. BOOL CaptureServer::LoadConfigFile()
  187. {
  188. char buf[MAX_PATH];
  189. GetModuleFileName(NULL, buf, MAX_PATH);
  190. string path = buf;
  191. int index = path.find_last_of('\', path.length());
  192. path.resize(index+1);
  194. ConfigFile cfgFile(path + "CaptureServer.cfg");
  195. if(cfgFile.fileNotFound) {
  196. MessageBox(parentWindow, "无法找到配置文件CaptureServer.cfg。", "错误", MB_OK|MB_ICONERROR);
  197. return FALSE;
  198. }
  199. string strSPList = cfgFile.Value("CaptureServer", "spAddress");
  200. if(cfgFile.stringNotFound) {
  201. MessageBox(parentWindow, "配置文件中必须存在spAddress一项。", "错误", MB_OK|MB_ICONERROR);
  202. return FALSE;
  203. }
  204. cfgData.chnlStr = cfgFile.Value("CaptureServer", "channelName");
  205. if(cfgFile.stringNotFound) {
  206. MessageBox(parentWindow, "配置文件中必须存在channelName一项。", "错误", MB_OK|MB_ICONERROR);
  207. return FALSE;
  208. }
  209. cfgData.savePath = cfgFile.Value("CaptureServer", "savepath");
  211. if (false == cfgData.savePath.empty())
  212. {
  213. //补路径后的斜杠
  214. string::const_iterator litSavePath = cfgData.savePath.end();
  215. --litSavePath;
  216. if ('\' != static_cast<BYTE>(*litSavePath))
  217. {
  218. cfgData.savePath += "\"; 
  219. }
  221. //去除路径前的空格
  222. while (' ' == *cfgData.savePath.c_str())
  223. {
  224. cfgData.savePath = cfgData.savePath.c_str() + 1;
  225. }
  226. }
  229. string lstrOnlyAudio = cfgFile.Value("CaptureServer", "isonlyaudio");
  231. if (false == lstrOnlyAudio.empty())
  232. {
  233. //去除路径前的空格
  234. while (' ' == *lstrOnlyAudio.c_str())
  235. {
  236. lstrOnlyAudio = lstrOnlyAudio.c_str() + 1;
  237. }
  239. //lstrOnlyAudio = lstrOnlyAudio.
  240. if ("true" == lstrOnlyAudio)
  241. {
  242. SetAudioOrVideoOnly(TRUE);
  243. }
  244. else if ("false" != lstrOnlyAudio)
  245. {
  246. MessageBox(NULL,"isonlyaudio 项是非法字符","注意", MB_OK|MB_ICONSTOP);
  247. return FALSE;
  248. }
  249. }
  251. string reconnect = cfgFile.Value("CaptureServer", "ReconnectTime");
  252. if(!cfgFile.fileNotFound) {
  253. cfgData.reconnectSecond = atoi(reconnect.data());
  254. }
  255. string id = cfgFile.Value("CaptureServer","userID");
  256. if(cfgFile.fileNotFound){
  257. MessageBox(parentWindow, "配置文件中必须存在userID一项。", "错误", MB_OK|MB_ICONERROR);
  258. return FALSE;
  259. }
  260. cfgData.userID = atoi(id.data());
  262. //读入的是32位密码
  263. cfgData.password = cfgFile.Value("CaptureServer", "password");
  264. if(cfgFile.fileNotFound){
  265. MessageBox(parentWindow, "配置文件中必须存在password一项目。", "错误", MB_OK|MB_ICONERROR);
  266. return FALSE;
  267. }
  269. string::const_iterator it = cfgData.chnlStr.begin();
  271. for(; it != cfgData.chnlStr.end(); it++)
  272. {
  273. BYTE tmpChar = static_cast<BYTE>(*it);
  274. if(isdigit(tmpChar) || isalpha(tmpChar))
  275. continue;
  276. if(tmpChar == '[' || tmpChar == ']')
  277. continue;
  278. //GB18030-2000编码标准的第一个字节的编码范围在0x81 ~ 0xFE之间；第二个字节的编码范围在0x40 ~ 0x7E和0x80 ~ 0xFE之间。
  279. //Big5编码标准的第一个字节的编码范围在0xA1 ~ 0xF9 之间；第二个字节的编码范围在0x40 ~ 0x7E 和0xA1 ~ 0xFE之间。
  280. //两者的并集是第一个字节[0x81, 0xfe]，第二个字节[0x40, 0x7e]、[0x80, 0xfe];
  281. if(tmpChar>=0x81 && tmpChar <= 0xfe && it+1 != cfgData.chnlStr.end()) {
  282. tmpChar = static_cast<BYTE>(*(it+1));
  283. if( (tmpChar>=0x40 && tmpChar <= 0x7e) || (tmpChar>=0x80 && tmpChar <= 0xfe))
  284. {
  285. it++; // 跳过一个汉字字符
  286. continue;
  287. }
  288. }
  289. MessageBox(parentWindow, "配置文件中channelName一项只能由字母、数字、汉字和方括弧组成。", "错误", MB_OK|MB_ICONERROR);
  290. return FALSE;
  291. }
  293. cfgData.canLogin = TRUE;
  295. istrstream is(strSPList.data());
  296. string line;
  297. string ip;
  298. string port;
  299. NormalAddress tmpAddr;
  300. while(getline(is,line, ':')) {
  301. if(!line.length())
  302. continue;
  303. tmpAddr.sin_addr.s_addr = TE_GetIP(line.data(), TRUE);
  304. if(tmpAddr.sin_addr.s_addr == INADDR_NONE)
  305. continue;
  306. cfgData.spAddress.push_back(inet_ntoa(tmpAddr.sin_addr));
  307. }
  309. if(cfgData.chnlStr.length() >= 64) {
  310. MessageBox(parentWindow, "配置文件中channelName一项其长度必须小于64字符。", "错误", MB_OK|MB_ICONERROR);
  311. return FALSE;
  312. }
  313. if(cfgData.password.length() != 32) {
  314. MessageBox(parentWindow, "配置文件中Password一项其长度必须等于32字符。", "错误", MB_OK|MB_ICONERROR);
  315. return FALSE;
  316. }
  318. return TRUE;
  319. }
  321. BOOL CaptureServer::SetFormatData(TVMEDIATYPESECTION& tv, BYTE* data, BOOL isAudio)
  322. {
  323. if(!data)
  324. return FALSE;
  326. // 因为SetAudioOrVideoOnly比SetFormatData先被调用，所以要在这里记录
  327. bool bIsThisPinOnly = isAudio?audioStruct.bThisPinOnly:videoStruct.bThisPinOnly;
  329. // 分别复制视频和音频数据
  330. if(!isAudio) {
  331. SAFE_ARRAYDELETE(videoData);
  332. memcpy(&videoStruct, &tv, sizeof(TVMEDIATYPESECTION));
  333. if(videoStruct.cbFormat > 512)
  334. return FALSE;
  335. videoData = new BYTE[videoStruct.cbFormat];
  336. memcpy(videoData, data, videoStruct.cbFormat);
  338. // 恢复
  339. videoStruct.bThisPinOnly = bIsThisPinOnly;
  341. }
  342. else {
  343. SAFE_ARRAYDELETE(audioData);
  344. memcpy(&audioStruct, &tv, sizeof(TVMEDIATYPESECTION));
  345. if(audioStruct.cbFormat > 512)
  346. return FALSE;
  347. audioData = new BYTE[audioStruct.cbFormat];
  348. memcpy(audioData, data, audioStruct.cbFormat);
  350. // 恢复
  351. audioStruct.bThisPinOnly = bIsThisPinOnly;
  352. }
  354. for(UINT i = 0; i < bufferList.size();++i)
  355. {
  356. if(!bufferList[i]->AttachMediaDataToCurrentBlock(tv, data, isAudio, logList[i]))
  357. return FALSE;
  358. }
  360. if((audioData&&videoData) || // 如果视频和音频的数据都有了
  361. (audioData&&audioStruct.bThisPinOnly) || // 如果只有音频
  362. (videoData&&videoStruct.bThisPinOnly)) { // 如果只有视频
  364. // 如果需要保存zzl文件，则建立zzl文件
  365. if(!cfgData.savePath.empty()) {
  366. if(!m_zzlWriter.Init(cfgData.savePath, cfgData.chnlStr)) {
  367. //MessageBox(parentWindow, "无法建立节目文件！", "错误", MB_OK);
  368. return 0;
  369. }
  370. if(!m_zzlWriter.SetMediaType(audioStruct, audioData, videoStruct, videoData)) {
  371. MessageBox(parentWindow, "无法建立节目文件！SetMediaType Error!", "错误", MB_OK);
  372. }
  373. }
  374. }
  376. return TRUE;
  377. }
  379. BOOL CaptureServer::GetFormatData(TVMEDIATYPESECTION& tv, PBYTE& data, BOOL isAudio)
  380. {
  381. if(!isAudio)
  382. {
  383. if(audioStruct.bThisPinOnly)
  384. {
  385. memset(&tv, 0, sizeof(tv));
  386. data = NULL;
  387. return TRUE;
  388. }
  390. if(!videoData)
  391. return FALSE;
  393. memcpy(&tv, &videoStruct, sizeof(TVMEDIATYPESECTION));
  394. data = new BYTE[videoStruct.cbFormat];
  395. memcpy(data, videoData, videoStruct.cbFormat);
  396. }
  397. else
  398. {
  399. if(videoStruct.bThisPinOnly)
  400. {
  401. memset(&tv, 0, sizeof(tv));
  402. data = NULL;
  403. return TRUE;
  404. }
  406. if(!audioData)
  407. return FALSE;
  409. memcpy(&tv, &audioStruct, sizeof(TVMEDIATYPESECTION));
  411. data = new BYTE[audioStruct.cbFormat];
  412. memcpy(data, audioData, audioStruct.cbFormat);
  413. }
  415. return TRUE;
  416. }
  418. void CaptureServer::SetAudioOrVideoOnly(BOOL isAudio)
  419. {
  420. if(isAudio)
  421. {
  422. audioStruct.bThisPinOnly = true;
  423. }
  424. else
  425. {
  426. videoStruct.bThisPinOnly = true;
  427. }
  428. m_bIsOnlyOnePin = TRUE;
  429. m_zzlWriter.SetIsSingleAudio(isAudio);
  430. }
  432. BOOL CaptureServer::PutSample(const SampleHeader& header, BYTE* pData)
  433. {
  434. totalBytes += header.size;
  436. for(UINT i = 0; i < bufferList.size();++i)
  437. {
  438. if(!bufferList[i]->PutSample(header, pData, logList[i]))
  439. return FALSE;
  440. }
  442. if(!cfgData.savePath.empty())
  443. {
  444. ::EnterCriticalSection(&m_SamQueueCSec);
  445. //if(!m_bTransDataEnd)
  446. {
  447. if(audioStruct.bThisPinOnly || videoStruct.bThisPinOnly)
  448. {
  449. if(!m_zzlWriter.PutSample(header, pData))
  450. {
  451. ASSERT(FALSE);
  452. }
  453. }
  454. else
  455. {
  456. if(header.bAudioSample)
  457. {
  458. if(m_llAudioTime >= m_llVideoTime + MAX_AVDELAY)
  459. {
  460. BYTE *pSamData = new BYTE[header.size];
  461. SAMPLEDATA *pSAMPLEDATA = new SAMPLEDATA;
  462. memset(pSAMPLEDATA, 0, sizeof(SAMPLEDATA));
  463. memcpy(&(pSAMPLEDATA->samplehr), &header, sizeof(SampleHeader));
  464. memcpy(pSamData, pData, header.size);
  465. pSAMPLEDATA->pData = pSamData;
  466. m_AudioSamQueue.push(pSAMPLEDATA);
  467. }
  468. else
  469. {
  470. if(m_AudioSamQueue.size() > 0)
  471. {
  472. BYTE *pSamData = new BYTE[header.size];
  473. SAMPLEDATA *pSAMPLEDATA = new SAMPLEDATA;
  474. memset(pSAMPLEDATA, 0, sizeof(SAMPLEDATA));
  475. memcpy(&(pSAMPLEDATA->samplehr), &header, sizeof(SampleHeader));
  476. memcpy(pSamData, pData, header.size);
  477. pSAMPLEDATA->pData = pSamData;
  478. m_AudioSamQueue.push(pSAMPLEDATA);
  480. SAMPLEDATA *pCurrentSampleData = m_AudioSamQueue.front();
  481. m_AudioSamQueue.pop();
  483. if(!m_zzlWriter.PutSample(pCurrentSampleData->samplehr, pCurrentSampleData->pData))
  484. {
  485. ASSERT(FALSE);
  486. }
  488. m_llAudioTime = pCurrentSampleData->samplehr.start;
  489. delete pCurrentSampleData->pData;
  490. delete pCurrentSampleData;
  491. }
  492. else
  493. {
  494. if(!m_zzlWriter.PutSample(header, pData))
  495. {
  496. ASSERT(FALSE);
  497. }
  499. m_llAudioTime = header.start;
  500. }
  501. }
  504. //以音频的动力拉动视频符合误差范围的Sample
  505. while(m_VideoSamQueue.size() > 0 && m_VideoSamQueue.front()->samplehr.start <= m_llAudioTime + MAX_AVDELAY)
  506. {
  507. SAMPLEDATA *pCurrentSampleData = m_VideoSamQueue.front();
  508. if(!m_zzlWriter.PutSample(pCurrentSampleData->samplehr, pCurrentSampleData->pData))
  509. {
  510. ASSERT(FALSE);
  511. }
  513. m_VideoSamQueue.pop();
  514. m_llVideoTime = pCurrentSampleData->samplehr.start;
  515. delete pCurrentSampleData->pData;
  516. delete pCurrentSampleData;
  517. }
  519. }
  520. else
  521. {
  522. if(m_llVideoTime >= m_llAudioTime + MAX_AVDELAY)
  523. {
  524. BYTE *pSamData = new BYTE[header.size];
  525. SAMPLEDATA *pSAMPLEDATA = new SAMPLEDATA;
  526. memset(pSAMPLEDATA, 0, sizeof(SAMPLEDATA));
  527. memcpy(&(pSAMPLEDATA->samplehr), &header, sizeof(SampleHeader));
  528. memcpy(pSamData, pData, header.size);
  529. pSAMPLEDATA->pData = pSamData;
  530. m_VideoSamQueue.push(pSAMPLEDATA);
  531. }
  532. else
  533. {
  534. if(m_VideoSamQueue.size() > 0)
  535. {
  536. BYTE *pSamData = new BYTE[header.size];
  537. SAMPLEDATA *pSAMPLEDATA = new SAMPLEDATA;
  538. memset(pSAMPLEDATA, 0, sizeof(SAMPLEDATA));
  539. memcpy(&(pSAMPLEDATA->samplehr), &header, sizeof(SampleHeader));
  540. memcpy(pSamData, pData, header.size);
  541. pSAMPLEDATA->pData = pSamData;
  542. m_VideoSamQueue.push(pSAMPLEDATA);
  544. SAMPLEDATA *pCurrentSampleData = m_VideoSamQueue.front();
  545. m_VideoSamQueue.pop();
  547. if(!m_zzlWriter.PutSample(pCurrentSampleData->samplehr, pCurrentSampleData->pData))
  548. {
  549. ASSERT(FALSE);
  550. }
  552. m_llVideoTime = pCurrentSampleData->samplehr.start;
  553. delete pCurrentSampleData->pData;
  554. delete pCurrentSampleData;
  555. }
  556. else
  557. {
  558. if(!m_zzlWriter.PutSample(header, pData))
  559. {
  560. ASSERT(FALSE);
  561. }
  563. m_llVideoTime = header.start;
  564. }
  565. }
  567. //以视频的动力拉动音频符合误差范围的Sample
  568. while(m_AudioSamQueue.size() > 0 && m_AudioSamQueue.front()->samplehr.start <= m_llVideoTime + MAX_AVDELAY)
  569. {
  570. SAMPLEDATA *pCurrentSampleData = m_AudioSamQueue.front();
  571. if(!m_zzlWriter.PutSample(pCurrentSampleData->samplehr, pCurrentSampleData->pData))
  572. {
  573. ASSERT(FALSE);
  574. }
  576. m_AudioSamQueue.pop();
  577. m_llAudioTime = pCurrentSampleData->samplehr.start;
  578. delete pCurrentSampleData->pData;
  579. delete pCurrentSampleData;
  580. }
  582. }
  583. }
  584. }
  585.   ::LeaveCriticalSection(&m_SamQueueCSec);
  586. }
  588. return TRUE;
  589. }
  591. float CaptureServer::GetSpeedInKBPS()
  592. {
  594. if(!cfgData.savePath.empty())
  595. return (float)m_zzlWriter.GetBitRate(); // 由于压缩用的时间可能超过媒体文件的实际长度，所以此处统计的码率更加准确
  597. SYSTEMTIME stNow;
  598. GetSystemTime(&stNow);
  599. LARGE_INTEGER llNow;
  600. SystemTimeToFileTime(&stNow, (FILETIME*)&llNow);
  602. LARGE_INTEGER llStart;
  603. SystemTimeToFileTime(&startTime, (FILETIME*)&llStart);
  605. if(llNow.QuadPart - llStart.QuadPart > 0) {
  606. DbgLog((LOG_TRACE, 5, TEXT("Speed: %f"), totalBytes/(double)((llNow.QuadPart-llStart.QuadPart)/10000) ));
  607. return static_cast<float>(totalBytes/(double)((llNow.QuadPart-llStart.QuadPart)/10000));
  608. }
  609. else
  610. return 0.0;
  611. }
  612. // Implementation of CaptureServer }