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

源码开发语言/平台
当前位置：首页 > 源码/资料 > Internet/网络编程 > P2P编程 > 查看源码
cstream.h
资源名称：P2PSource-PeerCast.rar　[点击查看]
上传用户：chn_coc
上传日期：2007-12-20
资源大小：563k
文件大小：3k
源码类别：

P2P编程

开发平台：

Windows_Unix

cstream.h：源码内容
  1. // ------------------------------------------------
  2. // File : cstream.h
  3. // Date: 12-mar-2004
  4. // Author: giles
  5. //
  6. // (c) 2002-4 peercast.org
  7. // ------------------------------------------------
  8. // This program is free software; you can redistribute it and/or modify
  9. // it under the terms of the GNU General Public License as published by
  10. // the Free Software Foundation; either version 2 of the License, or
  11. // (at your option) any later version.
  13. // This program is distributed in the hope that it will be useful,
  14. // but WITHOUT ANY WARRANTY; without even the implied warranty of
  15. // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  16. // GNU General Public License for more details.
  17. // ------------------------------------------------
  19. #ifndef _CSTREAM_H
  20. #define _CSTREAM_H
  22. // ----------------------------------
  24. class Channel;
  25. class ChanPacket;
  26. class Stream;
  29. // ----------------------------------
  30. class ChanPacket
  31. {
  32. public:
  33. enum 
  34. {
  35. MAX_DATALEN = 16384
  36. };
  38. enum TYPE
  39. {
  40. T_UNKNOWN = 0,
  41. T_HEAD = 1,
  42. T_DATA = 2,
  43. T_META = 4,
  44. T_PCP = 16,
  45. T_ALL = 0xff
  46. };
  48. ChanPacket() 
  49. {
  50. init();
  51. }
  53. void init()
  54. {
  55. type = T_UNKNOWN;
  56. len = 0;
  57. pos = 0;
  58. sync = 0;
  59. }
  60. void init(TYPE t, const void *, unsigned int , unsigned int );
  62. void writeRaw(Stream &);
  63. void writePeercast(Stream &);
  64. void readPeercast(Stream &);
  67. unsigned int sync;
  68. unsigned int pos;
  69. TYPE type;
  70. unsigned int len;
  71. char data[MAX_DATALEN];
  73. };
  74. // ----------------------------------
  75. class ChanPacketBuffer 
  76. {
  77. public:
  78. enum {
  79. MAX_PACKETS = 64,
  80. NUM_SAFEPACKETS = 56
  81. };
  83. void init()
  84. {
  85. lock.on();
  86. lastPos = firstPos = safePos = 0;
  87. readPos = writePos = 0;
  88. accept = 0;
  89. lastWriteTime = 0;
  90. lock.off();
  91. }
  93. int copyFrom(ChanPacketBuffer &,unsigned in);
  95. bool writePacket(ChanPacket &,bool = false);
  96. void readPacket(ChanPacket &);
  98. bool willSkip();
  100. int numPending() {return writePos-readPos;}
  102. unsigned int getLatestPos();
  103. unsigned int getOldestPos();
  104. unsigned int findOldestPos(unsigned int);
  105. bool findPacket(unsigned int,ChanPacket &);
  106. unsigned int getStreamPos(unsigned int);
  107. unsigned int getStreamPosEnd(unsigned int);
  108. unsigned int getLastSync();
  110. ChanPacket packets[MAX_PACKETS];
  111. volatile unsigned int lastPos,firstPos,safePos;
  112. volatile unsigned int readPos,writePos;
  113. unsigned int accept;
  114. unsigned int lastWriteTime;
  115. WLock lock;
  116. };
  118. // ----------------------------------
  119. class ChannelStream
  120. {
  121. public:
  122. ChannelStream()
  123. :numListeners(0)
  124. ,numRelays(0) 
  125. ,isPlaying(false)
  126. ,fwState(0)
  127. ,lastUpdate(0) 
  128. {}
  130. void updateStatus(Channel *);
  131. bool getStatus(Channel *,ChanPacket &);
  133. virtual void kill() {}
  134. virtual bool sendPacket(ChanPacket &,GnuID &) {return false;}
  135. virtual void flush(Stream &) {}
  136. virtual void readHeader(Stream &,Channel *)=0;
  137. virtual int  readPacket(Stream &,Channel *)=0;
  138. virtual void readEnd(Stream &,Channel *)=0;
  140. void readRaw(Stream &,Channel *);
  142. int numRelays;
  143. int numListeners;
  144. bool isPlaying;
  145. int fwState;
  146. unsigned int lastUpdate;
  148. };
  150. #endif