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

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

P2P编程

开发平台：

Visual C++

Rerequester.h：源码内容
  1. // Rerequester.h: interface for the CRerequester class.
  2. //
  3. //////////////////////////////////////////////////////////////////////
  5. #if !defined(AFX_REREQUESTER_H__79411383_1CEA_45EC_92A2_D1B53A363000__INCLUDED_)
  6. #define AFX_REREQUESTER_H__79411383_1CEA_45EC_92A2_D1B53A363000__INCLUDED_
  8. #if _MSC_VER > 1000
  9. #pragma once
  10. #endif // _MSC_VER > 1000
  13. #include <afxinet.h>
  14. #include "memstream.h"
  15. #include "Encrypter.h"
  17. class CConnector;
  18. class CStorageWrapper;
  19. class CMeasure;
  20. class CDownloaderFeedback;
  22. #define REQ_STARTED 0
  23. #define REQ_COMPLETED 1
  24. #define REQ_STOPPED 2
  25. #define REQ_QUERY 3
  28. class CRerequesterSingle
  29. {
  30. public:
  31. CRerequesterSingle();
  32. ~CRerequesterSingle();
  34. bool OpenUrlEx(string strUrl, HANDLE hHttpDone, long lEvent);
  35. int GetResult(string& strErr);
  36. void WaitTerminate();
  38. memstream m_RetStream;
  39. long m_lEvent;
  41. private:
  42. static DWORD WINAPI SendRequestProc(void *pParam);
  43. void SendRequest();
  44. void OpenUrl(string strUrl, memstream& buf);
  46. HANDLE m_hHttpDone;
  47. HANDLE m_hDone;
  48. CInternetSession m_session;
  49. string m_strUrl;
  51. bool m_iResult;
  52. string m_strErr;
  53. };
  55. class CRerequester  
  56. {
  57. public:
  58. CRerequester(long lConnectErrorMax, long lConnectIntval, long minpeers, long maxpeers);
  60. void Create(CDownloaderFeedback* pMain,CStorageWrapper* pStorageWrapper, CMeasure* pupmeasure,  CMeasure* pdownmeasure, 
  61. CConnector* pConnector, CEncrypter* pEncrypter, string strUrl, long port, string strIP, 
  62. char* pMyId, char* pInfoHash, long interval, 
  63. long lTimeOut, HANDLE hevDone);
  65. virtual ~CRerequester();
  67. void SetConnectErrorMax(long lConnectErrorMax, long lConnectIntval, long minpeers, long maxpeers);
  69. void AnnounceEx(long lEvent = REQ_QUERY);
  70. void PostExcute();
  71. void Excute();
  72. void Close();
  73. HANDLE GetHttpEvent();
  76. private:
  77. void announce(long lEvent = REQ_QUERY);
  78. bool postrequest();
  80. CDownloaderFeedback* m_pMain;
  81. CStorageWrapper* m_pStorageWrapper;
  82. CMeasure* m_pupmeasure;
  83. CMeasure* m_pdownmeasure;
  84. CConnector* m_pConnector;
  85. CEncrypter* m_pEncrypter;
  87. string m_strUrl;
  88. long m_minpeers;
  89. long m_maxpeers;
  90. long m_lTimeOut;
  91. HANDLE m_hevDone;
  93. long m_lAannounce_interval;
  94. long m_lInterval;
  95. string m_strTrackerid;
  96. long m_lLast;
  98. long m_lFileCount;
  99. long m_lConnectErrorMax;
  100. long m_lConnectIntval;
  102. HANDLE m_hHttpDone;
  103. time_t m_tLast;
  104. time_t m_tStartLast;
  106. bool m_never_succeeded;
  107. bool m_bStarted;
  108. vector<long> m_commands;
  109. bool m_bCommand;
  111. vector<CRerequesterSingle*> m_vSingles;
  112. CRerequesterSingle* m_pSingle;
  113. };
  116. #endif // !defined(AFX_REREQUESTER_H__79411383_1CEA_45EC_92A2_D1B53A363000__INCLUDED_)