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

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

P2P编程

开发平台：

Visual C++

Upload.h：源码内容
  1. // Upload.h: interface for the CUpload class.
  2. //
  3. //////////////////////////////////////////////////////////////////////
  5. #if !defined(AFX_UPLOAD_H__0488CF2F_D474_4738_9253_5BBA416475A1__INCLUDED_)
  6. #define AFX_UPLOAD_H__0488CF2F_D474_4738_9253_5BBA416475A1__INCLUDED_
  8. #if _MSC_VER > 1000
  9. #pragma once
  10. #endif // _MSC_VER > 1000
  14. #include "Connection.h"
  15. #include "StorageWrapper.h"
  16. #include "Measure.h"
  17. #include "Choker.h"
  18. class CDownloaderFeedback;
  20. class CUpload  
  21. {
  22. class CRequestsItem
  23. {
  24. public:
  25. CRequestsItem(long index, long begin, long length)
  26. {
  27. m_index = index;
  28. m_begin = begin;
  29. m_length = length;
  30. }
  32. long m_index;
  33. long m_begin;
  34. long m_length;
  35. };
  36. public:
  37. CUpload(CDownloaderFeedback* pDownloaderFeedback,
  38. CConnection* pconnection,
  39. CChoker* pchoker,
  40. CStorageWrapper* pstorage,
  41. long lMaxSliceLength,
  42. long lMaxRatePeriod,
  43. long lFudge);
  44. virtual ~CUpload();
  46. long get_rate();
  47. long get_total();
  48. bool has_queries();
  49. bool is_interested();
  50. bool is_choked();
  51. void unchoke();
  52. void choke();
  53. bool flushed();
  55. void got_cancel(long index, long begin, long length);
  56. void got_request(long index, long begin, long length);
  57. void got_interested();
  58. void got_not_interested();
  60. private:
  62. CConnection* m_pconnection;
  63. CStorageWrapper* m_pstorage;
  64. long m_lMaxSliceLength;
  65. long m_lMaxRatePeriod;
  66. bool m_bChoked;
  67. bool m_bInterested;
  68. vector <CRequestsItem> m_vBuffer;
  69. CMeasure m_Measure;
  71. // for feedback
  72. CDownloaderFeedback* m_pDownloaderFeedback;
  73. long m_lAddr;
  74. short m_sPort;
  75. };
  77. class CUploader
  78. {
  79. public :
  80. CUploader(CDownloaderFeedback* pDownloaderFeedback, CStorageWrapper* pstorage, CChoker* pchoker,long lMaxSliceLength, long lMaxRatePeriod, long lFudge);
  81. CUpload* make_upload(CConnection* pconnection);
  83. private:
  84. CChoker* m_pChoker;
  85. CStorageWrapper* m_pstorage;
  86. long m_lMaxSliceLength;
  87. long m_lMaxRatePeriod;
  88. long m_lFudge;
  90. // for feedback
  91. CDownloaderFeedback* m_pDownloaderFeedback;
  93. };
  95. #endif // !defined(AFX_UPLOAD_H__0488CF2F_D474_4738_9253_5BBA416475A1__INCLUDED_)