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

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

P2P编程

开发平台：

Visual C++

Connector.h：源码内容
  1. // Connector.h: interface for the CConnector class.
  2. //
  3. //////////////////////////////////////////////////////////////////////
  5. #if !defined(AFX_CONNECTOR_H__8E8443EF_9C62_41C9_947E_3AE7E12ABBC3__INCLUDED_)
  6. #define AFX_CONNECTOR_H__8E8443EF_9C62_41C9_947E_3AE7E12ABBC3__INCLUDED_
  8. #if _MSC_VER > 1000
  9. #pragma once
  10. #endif // _MSC_VER > 1000
  14. class CConnection;
  15. class CEncryptedConnection;
  17. class CDownloader;
  18. class CUploader;
  19. class CStorageWrapper;
  20. class CMeasure;
  21. class CChoker;
  22. class CAddrPort;
  25. class CConnector  
  26. {
  27. public:
  28. CConnector(long lMaxUploadRate);
  29. virtual ~CConnector();
  31. void Create(CDownloader* pDownloader, CUploader* pUploader, CChoker* pchoker, 
  32. long lNumPieces, CStorageWrapper* pStorage, CMeasure* pUpTotalMeasure );
  34. long how_many_connections();
  35. void connection_flushed(CEncryptedConnection* pEConnection);
  36. void connection_made(CEncryptedConnection* pEConnection);
  37. void connection_lost(CEncryptedConnection* pEConnection);
  38. void got_message(CEncryptedConnection* pEConnection, memstream& memMessage);
  40. void _update_upload_rate(long lAmount);
  41. bool IsRatecap();
  42. void uncap();
  43. void SetMaxUploadRate(long lMaxUploadRate);
  44. void PausePeer(CAddrPort addrPort, bool bPause = true);
  45. void ClosePeer(CAddrPort addrPort);
  46. void OnIdle();
  48. const CDownloader* const GetDownloader() const;
  49. const CMeasure* const GetUpTotalMeasure() const;
  51. vector<CConnection*> m_connections;
  53. private:
  54. void _OnIdle(vector<CAddrPort>& vToPause, vector<CAddrPort>& vToContinue, vector<CAddrPort>& vToClose);
  55. void check_endgame();
  57. // data
  58. CDownloader* m_pDownloader;
  59. CUploader* m_pUploader;
  60. CStorageWrapper* m_pStorage;
  61. CMeasure* m_pUpTotalMeasure;
  62. CChoker* m_pChoker;
  63. long m_lNumPieces;
  64. long m_lMaxUploadRate;
  65. bool m_bEndgame;
  66. bool m_bRateCapped;
  68. time_t m_tTimeUntilUncap;
  69. time_t m_tcap;
  71. vector<CAddrPort> m_vToPause;
  72. vector<CAddrPort> m_vToContinue;
  73. vector<CAddrPort> m_vToClose;
  74. CCriticalSection m_criticalSection;
  76. };
  79. #endif // !defined(AFX_CONNECTOR_H__8E8443EF_9C62_41C9_947E_3AE7E12ABBC3__INCLUDED_)