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

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

P2P编程

开发平台：

Windows_Unix

pcp.h：源码内容
  1. // ------------------------------------------------
  2. // File : pcp.h
  3. // Date: 1-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 _PCP_H
  20. #define _PCP_H
  22. // ------------------------------------------------
  25. #include "id.h"
  26. #include "cstream.h"
  28. // ------------------------------------------------
  30. class Servent;
  33. // ------------------------------------------------
  35. static const ID4 PCP_CONNECT = "pcpn";
  37. static const ID4 PCP_OK = "ok";
  39. static const ID4 PCP_HELO = "helo";
  40. static const ID4 PCP_HELO_AGENT = "agnt";
  41. static const ID4 PCP_HELO_OSTYPE = "ostp";
  42. static const ID4 PCP_HELO_SESSIONID = "sid";
  43. static const ID4 PCP_HELO_PORT = "port";
  44. static const ID4 PCP_HELO_PING = "ping";
  45. static const ID4 PCP_HELO_PONG = "pong";
  46. static const ID4 PCP_HELO_REMOTEIP = "rip";
  47. static const ID4 PCP_HELO_VERSION = "ver";
  48. static const ID4 PCP_HELO_BCID = "bcid";
  49. static const ID4 PCP_HELO_DISABLE = "dis";
  51. static const ID4 PCP_OLEH = "oleh";
  53. static const ID4 PCP_MODE = "mode";
  54. static const ID4 PCP_MODE_GNUT06 = "gn06";
  56. static const ID4 PCP_ROOT = "root";
  57. static const ID4 PCP_ROOT_UPDINT = "uint";
  58. static const ID4 PCP_ROOT_CHECKVER = "chkv";
  59. static const ID4 PCP_ROOT_URL = "url";
  60. static const ID4 PCP_ROOT_UPDATE = "upd";
  61. static const ID4 PCP_ROOT_NEXT = "next";
  64. static const ID4 PCP_OS_LINUX = "lnux";
  65. static const ID4 PCP_OS_WINDOWS = "w32";
  66. static const ID4 PCP_OS_OSX = "osx";
  67. static const ID4 PCP_OS_WINAMP = "wamp";
  68. static const ID4 PCP_OS_ZAURUS = "zaur";
  70. static const ID4 PCP_GET = "get";
  71. static const ID4 PCP_GET_ID = "id";
  72. static const ID4 PCP_GET_NAME = "name";
  74. static const ID4 PCP_HOST = "host";
  75. static const ID4 PCP_HOST_ID = "id";
  76. static const ID4 PCP_HOST_IP = "ip";
  77. static const ID4 PCP_HOST_PORT = "port";
  78. static const ID4 PCP_HOST_NUML = "numl";
  79. static const ID4 PCP_HOST_NUMR = "numr";
  80. static const ID4 PCP_HOST_UPTIME = "uptm";
  81. static const ID4 PCP_HOST_TRACKER = "trkr";
  82. static const ID4 PCP_HOST_CHANID = "cid";
  83. static const ID4 PCP_HOST_VERSION = "ver";
  84. static const ID4 PCP_HOST_FLAGS1 = "flg1";
  85. static const ID4 PCP_HOST_OLDPOS = "oldp";
  86. static const ID4 PCP_HOST_NEWPOS = "newp";
  89. static const ID4 PCP_QUIT = "quit";
  91. static const ID4 PCP_CHAN = "chan";
  92. static const ID4 PCP_CHAN_ID = "id";
  93. static const ID4 PCP_CHAN_BCID = "bcid";
  94. static const ID4 PCP_CHAN_KEY = "key";
  96. static const ID4 PCP_CHAN_PKT = "pkt";
  97. static const ID4 PCP_CHAN_PKT_TYPE = "type";
  98. static const ID4 PCP_CHAN_PKT_POS = "pos";
  99. static const ID4 PCP_CHAN_PKT_HEAD = "head";
  100. static const ID4 PCP_CHAN_PKT_DATA = "data";
  101. static const ID4 PCP_CHAN_PKT_META = "meta";
  103. static const ID4 PCP_CHAN_INFO = "info";
  104. static const ID4 PCP_CHAN_INFO_TYPE = "type";
  105. static const ID4 PCP_CHAN_INFO_BITRATE = "bitr";
  106. static const ID4 PCP_CHAN_INFO_GENRE = "gnre";
  107. static const ID4 PCP_CHAN_INFO_NAME = "name";
  108. static const ID4 PCP_CHAN_INFO_URL = "url";
  109. static const ID4 PCP_CHAN_INFO_DESC = "desc";
  110. static const ID4 PCP_CHAN_INFO_COMMENT = "cmnt";
  112. static const ID4 PCP_CHAN_TRACK = "trck";
  113. static const ID4 PCP_CHAN_TRACK_TITLE = "titl";
  114. static const ID4 PCP_CHAN_TRACK_CREATOR = "crea";
  115. static const ID4 PCP_CHAN_TRACK_URL = "url";
  116. static const ID4 PCP_CHAN_TRACK_ALBUM = "albm";
  118. static const ID4 PCP_MESG = "mesg";
  119. static const ID4 PCP_MESG_ASCII = "asci"; // ascii/sjis to be depreciated.. utf8/unicode is the only supported format from now.
  120. static const ID4 PCP_MESG_SJIS = "sjis";
  122. static const ID4 PCP_BCST = "bcst";
  123. static const ID4 PCP_BCST_TTL = "ttl";
  124. static const ID4 PCP_BCST_HOPS = "hops";
  125. static const ID4 PCP_BCST_FROM = "from";
  126. static const ID4 PCP_BCST_DEST = "dest";
  127. static const ID4 PCP_BCST_GROUP = "grp";
  128. static const ID4 PCP_BCST_CHANID = "cid";
  129. static const ID4 PCP_BCST_VERSION = "vers";
  131. static const ID4 PCP_PUSH = "push";
  132. static const ID4 PCP_PUSH_IP = "ip";
  133. static const ID4 PCP_PUSH_PORT = "port";
  134. static const ID4 PCP_PUSH_CHANID = "cid";
  136. static const ID4 PCP_SPKT = "spkt";
  138. static const ID4 PCP_ATOM = "atom";
  140. static const ID4 PCP_SESSIONID = "sid";
  142. static const int PCP_BCST_GROUP_ALL = (char)0xff;
  143. static const int PCP_BCST_GROUP_ROOT = 1;
  144. static const int PCP_BCST_GROUP_TRACKERS = 2;
  145. static const int PCP_BCST_GROUP_RELAYS = 4;
  148. static const int PCP_ERROR_QUIT = 1000;
  149. static const int PCP_ERROR_BCST = 2000;
  150. static const int PCP_ERROR_READ = 3000;
  151. static const int PCP_ERROR_WRITE = 4000;
  152. static const int PCP_ERROR_GENERAL = 5000;
  154. static const int PCP_ERROR_SKIP = 1;
  155. static const int PCP_ERROR_ALREADYCONNECTED = 2;
  156. static const int PCP_ERROR_UNAVAILABLE = 3;
  157. static const int PCP_ERROR_LOOPBACK = 4;
  158. static const int PCP_ERROR_NOTIDENTIFIED = 5;
  159. static const int PCP_ERROR_BADRESPONSE = 6;
  160. static const int PCP_ERROR_BADAGENT = 7;
  161. static const int PCP_ERROR_OFFAIR = 8;
  162. static const int PCP_ERROR_SHUTDOWN = 9;
  163. static const int PCP_ERROR_NOROOT = 10;
  164. static const int PCP_ERROR_BANNED = 11;
  166. static const int PCP_HOST_FLAGS1_TRACKER = 0x01;
  167. static const int PCP_HOST_FLAGS1_RELAY = 0x02;
  168. static const int PCP_HOST_FLAGS1_DIRECT = 0x04;
  169. static const int PCP_HOST_FLAGS1_PUSH = 0x08;
  170. static const int PCP_HOST_FLAGS1_RECV = 0x10;
  171. static const int PCP_HOST_FLAGS1_CIN = 0x20;
  172. static const int PCP_HOST_FLAGS1_PRIVATE = 0x40;
  175. // ----------------------------------------------
  176. class BroadcastState 
  177. {
  178. public:
  179. BroadcastState()
  180. :numHops(0)
  181. ,forMe(false) 
  182. ,streamPos(0)
  183. ,group(0)
  184. {
  185. chanID.clear();
  186. bcID.clear();
  187. }
  190. void initPacketSettings()
  191. {
  192. forMe = false;
  193. group = 0;
  194. numHops = 0;
  195. bcID.clear();
  196. chanID.clear();
  197. }
  200. GnuID chanID,bcID;
  201. int numHops;
  202. bool forMe;
  203. unsigned int streamPos;
  204. int group;
  205. };
  207. // ----------------------------------------------
  208. class PCPStream : public ChannelStream
  209. {
  210. public:
  211. PCPStream(GnuID &rid) 
  212. :routeList(1000)
  213. {
  214. init(rid);
  215. }
  217. void init(GnuID &);
  219. virtual void kill()
  220. {
  221. inData.lock.on();
  222. outData.lock.on();
  223. }
  225. virtual bool sendPacket(ChanPacket &,GnuID &);
  226. virtual void flush(Stream &);
  227. virtual void readHeader(Stream &,Channel *);
  228. virtual int readPacket(Stream &,Channel *);
  229. virtual void readEnd(Stream &,Channel *);
  231. int readPacket(Stream &,BroadcastState &);
  232. void flushOutput(Stream &in,BroadcastState &);
  233. static void readVersion(Stream &);
  235. int procAtom(AtomStream &,ID4,int,int,BroadcastState &);
  236. int readAtom(AtomStream &,BroadcastState &);
  237. void readChanAtoms(AtomStream &,int,BroadcastState &);
  238. void readHostAtoms(AtomStream &, int, BroadcastState &);
  239. void readPushAtoms(AtomStream &, int,BroadcastState &);
  241. void readPktAtoms(Channel *,AtomStream &,int,BroadcastState &);
  242. void readRootAtoms(AtomStream &, int,BroadcastState &);
  244. int readBroadcastAtoms(AtomStream &,int,BroadcastState &);
  246. ChanPacketBuffer inData,outData;
  247. unsigned int lastPacketTime;
  248. unsigned int nextRootPacket;
  250. //int error;
  251. GnuIDList routeList;
  252. GnuID remoteID;
  254. };
  256. #endif