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

源码开发语言/平台
当前位置：首页 > 源码/资料 > Internet/网络编程 > P2P编程 > 查看源码
Downloader.cpp
资源名称：GGBT.rar　[点击查看]
上传用户：lds876
上传日期：2013-05-25
资源大小：567k
文件大小：3k
源码类别：

P2P编程

开发平台：

Visual C++

Downloader.cpp：源码内容
  1. // Downloader.cpp: implementation of the CDownloader class.
  2. //
  3. //////////////////////////////////////////////////////////////////////
  5. #include "stdafx.h"
  6. #include "testbt.h"
  7. #include "Downloader.h"
  10. /*
  11. #include "Storage.h"
  12. #include "PiecePicker.h"
  13. #include "Measure.h"
  14. #include "RateMeasure.h"
  15. //*/
  16. #include "SingleDownload.h"
  17. #include "StorageWrapper.h"
  19. #ifdef _DEBUG
  20. #undef THIS_FILE
  21. static char THIS_FILE[]=__FILE__;
  22. #define new DEBUG_NEW
  23. #endif
  25. //////////////////////////////////////////////////////////////////////
  26. // Construction/Destruction
  27. //////////////////////////////////////////////////////////////////////
  29. CDownloader::CDownloader()
  30. {
  31. m_bCreate = false;
  32. }
  34. bool CDownloader::Create(CDownloaderFeedback* pDownloaderFeedback, CStorageWrapper* pstrorage, CPiecePicker* pPicker, long lBacklog, 
  35. long lMaxRatePeriod, CMeasure* pDownMeasure, long lNumPieces, long lSnubTime, 
  36. CRateMeasure* pRateMeasure)
  37. {
  38. m_pDownloaderFeedback = pDownloaderFeedback;
  39. m_pstrorage = pstrorage;
  40. m_pPicker = pPicker;
  41. m_lBacklog = lBacklog;
  42. m_lMaxRatePeriod = lMaxRatePeriod;
  43. m_pDownMeasure = pDownMeasure;
  44. m_lNumPieces = lNumPieces;
  45. m_lSnubTime = lSnubTime;
  46. m_pRateMeasure = pRateMeasure;
  48. m_bEndgame = false;
  49. m_bCreate = true;
  50. return true;
  51. }
  53. CDownloader::~CDownloader()
  54. {
  55. // for (int i=0; i<m_vDownloads.size(); i++)
  56. // delete m_vDownloads[i];
  57. }
  59. CSingleDownload* CDownloader::make_download(CConnection* pConnection)
  60. {
  61. CSingleDownload* pnew = new CSingleDownload(m_pDownloaderFeedback, this, pConnection);
  62. m_vDownloads.push_back(pnew);
  63. if (m_bEndgame)
  64. {
  65. pnew->make_endgame(m_vRequests);
  66. pnew->mak_endgameflush();
  67. }
  68. return pnew;
  69. }
  71. void CDownloader::make_endgame()
  72. {
  73. assert(!m_bEndgame);
  74. m_bEndgame = true;
  76. for (int i=0; i<m_vDownloads.size(); i++)
  77. {
  78. m_vDownloads[i]->make_endgame(m_vRequests);
  79. }
  81. for (i=0; i<m_vDownloads.size(); i++)
  82. {
  83. m_vDownloads[i]->mak_endgameflush();
  85. TRACE("rnm_vRequests : (index, begin, length){");
  86. for (int j=0; j<m_vRequests.size(); j++)
  87. {
  88. char szText[100] = {0};
  89. sprintf(szText, "(%d, %d, %d)", m_vRequests[j].m_index, m_vRequests[j].m_begin, m_vRequests[j].m_length);
  90. TRACE(szText);
  91. }
  92. TRACE("}rn");
  93. }
  94. }
  96. /////////////////////////////////////////////////////////////////
  97. // called by storageWrapper, when files needed setup change.
  98. //
  99. bool CDownloader::is_endgame()
  100. {
  101. return m_bEndgame;
  102. }
  104. void CDownloader::cancel_endgame()
  105. {
  106. assert(m_bEndgame);
  107. m_bEndgame = false;
  109. for (int i=0; i<m_vRequests.size();i++)
  110. {
  111. CRequestsItem& item = m_vRequests[i];
  112. m_pstrorage->request_lost(item.m_index, item.m_begin, item.m_length);
  113. }
  114. m_vRequests.clear();
  116. for (i=0; i<m_vDownloads.size(); i++)
  117. {
  118. m_vDownloads[i]->cancel_endgame();
  119. }
  120. }
  122. void CDownloader::OnNeedFilesChanged()
  123. {
  124. for (int i=0; i<m_vDownloads.size(); i++)
  125. {
  126. m_vDownloads[i]->download_more();
  127. }
  128. }
  130. bool CDownloader::IsCreate()
  131. {
  132. return m_bCreate;
  133. }