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

源码开发语言/平台
当前位置：首页 > 源码/资料 > Internet/网络编程 > P2P编程 > 查看源码
echo.h
资源名称：p2p_vod.rar　[点击查看]
上传用户：liguizhu
上传日期：2015-11-01
资源大小：2422k
文件大小：10k
源码类别：

P2P编程

开发平台：

Visual C++

echo.h：源码内容
  1. /*
  2.  *  Openmysee
  3.  *
  4.  *  This program is free software; you can redistribute it and/or modify
  5.  *  it under the terms of the GNU General Public License as published by
  6.  *  the Free Software Foundation; either version 2 of the License, or
  7.  *  (at your option) any later version.
  8.  *
  9.  *  This program is distributed in the hope that it will be useful,
  10.  *  but WITHOUT ANY WARRANTY; without even the implied warranty of
  11.  *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  12.  *  GNU General Public License for more details.
  13.  *
  14.  *  You should have received a copy of the GNU General Public License
  15.  *  along with this program; if not, write to the Free Software
  16.  *  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
  17.  *
  18.  */
  19.  
  20. #ifndef __ECHO_H_INCLUDED
  21. #define __ECHO_H_INCLUDED
  23. #include <stdio.h>
  24. #include <stdlib.h>
  25. #include <ctype.h>
  26. #include <sys/types.h>
  27. #include <sys/time.h>
  28. #include <sys/resource.h>
  29. #include <sys/stat.h>
  30. #include <sys/wait.h>
  31. #include <sys/socket.h>
  32. #include <netinet/in.h>
  33. #include <arpa/inet.h>
  34. #include <netdb.h>
  35. #include <unistd.h>
  36. #include <fcntl.h>
  37. #include <errno.h>
  38. #include <assert.h>
  39. #include <syslog.h>
  40. #include <string.h>
  41. #include <time.h>
  42. #include <dirent.h>
  43. #include "md5.h"
  44. #include "ProtocolDefine.h"
  45. #include "StructDefine.h"
  46. #include "ErrorDefine.h"
  47. #include "util.h"
  49. #define AUTH_HEADER 12
  50. #define NORMAL_HEADER 5
  51. #define MAX_REPSP 10 // Max number of reported sp for cp
  52. #define MAX_NEARPEER 10
  53. #define MAX_CHANNEL 1024 /* max number of Channel */
  54. #define MAX_CONN 75 /* connect timeout, after MAX_CONN reconnect */
  55. #define MAX_CLIENT 3072 // max number of client
  57. #define MAX_QUEUE 4194304 /* max BlockData malloced for a channel */
  58. #define MAX_FILEINPUT 1024
  60. #define MIN_IPADDR_LEN 8
  61. #define IPADDR_LEN 16 /*****IP地址最大长度*****/
  62. #define CHNLURL_LEN 128 /*****频道的标志URL*****/
  63. #define DEFAULT_BLOCK 16384 // default size of Media Block
  65. #define TYPE_LIVE 0
  66. #define TYPE_ORDER 1
  68. #define MAX_LINE 1024
  69. #define MAX_MSG_SIZE 17000
  70. #define MAX_PENDING_JOB 3
  72. #define MAX_TRANSFER_IDLE 60
  74. #define FLAG_SERVER 0
  75. #define FLAG_CLIENT 1
  77. #define MAX_DATA 65536 /* max size of message */
  78. #define MAX_BLOCK_SIZE 65000
  79. #define MIN_BLOCK_SIZE 0
  80. #define LIVE_PREFIX "/channel/"
  81. #define ORDER_PREFIX "/data/"
  82. #define PLIST_PREFIX "/playlist/"
  83. #define PROG_PREFIX "/program/"
  85. #define BLOCK_PER_FILE 163840
  87. #define MAX_TYPE 2
  88. #define TYPE_P2PC 0
  89. #define TYPE_P2PS 1
  90. #define TYPE_CS 0
  91. #define TYPE_CP 1
  93. #define MAX_JOB 10
  94. #ifdef __CP_SOURCE
  95. #define IDENTITY "CP"
  96. #endif
  97. #ifdef __SP_SOURCE
  98. #define IDENTITY "SP"
  99. #endif
  101. #ifndef IDENTITY
  102. #define IDENTITY "PP"
  103. #endif
  105. enum TS_INDEX
  106. {
  107. EDUTS = 0,
  108. CNCTS = 1,
  109. UNITS = 2,
  110. TELTS = 3,
  111. // add new TS here!!
  112. };
  114. enum CHTYPE
  115. {
  116. T_ORDER = 0,
  117. T_LIVE = 1,
  118. T_PLIST = 2
  119. };
  121. #define MAX_TS 4
  122. struct Message
  123. {
  124. int len;
  125. char type;
  126. char buffer[MAX_DATA];
  127. };
  129. struct MList
  130. {
  131. struct Channel *m_lists[MAX_FILEINPUT];
  132. int m_startID[MAX_FILEINPUT]; // start block id for each chan
  133. int m_totalchannel; // total number of channels
  134. int m_cursampleid; // cur sample file id
  135. int m_lastmaxid;
  136. };
  138. struct MediaData
  139. {
  140. int start;
  141. unsigned int len;
  142. int dlen;
  143. char *data;
  144. char progname[CHNLURL_LEN];
  145. #ifdef __CP_SOURCE
  146. char channel_name[CHNLURL_LEN];
  147. #endif
  148. };
  151. typedef int (*TimerFunc) (void *, void *);
  152. struct Timertask
  153. {
  154. unsigned int time;
  155. TimerFunc process;
  156. void *entity;
  157. void *data;
  158. struct Timertask *next;
  159. };
  162. struct TSMessage
  163. {
  164. unsigned int len;
  165. unsigned char type;
  166. unsigned int authcode1:24;
  167. unsigned int authcode2;
  168. char buffer[MAX_DATA];
  169. };
  171. struct LiveChannelInfo
  172. {
  173. unsigned int maxID;
  174. struct Session *dataSource; // source of data, a connection to SP or uplevel CP
  175. unsigned int total;
  176. struct SPUpdate s;
  177. unsigned int max_queue;
  178. float bitrate;
  179. // struct BlockData *blocks;
  180. int max_channel;
  181. int cur_channel;
  182. struct MediaData *media;
  183. int isSave;
  185. #ifdef __CP_SOURCE
  186. char *bitflag; // for CP, it is pending status, for SP, it is keysample status
  187. unsigned char *indisk;
  188. unsigned int numofsp;
  189. struct NormalAddress SPLIST[256];
  190. #endif
  192. #ifdef __SP_SOURCE
  193. unsigned int startid;
  194. struct MList *mlist;
  195. FILE *input[MAX_FILEINPUT];
  196. FILE *keyfile;
  197. unsigned int numinput;
  198. unsigned int numblocks;
  199. unsigned int userid;
  200. float limitedBitRate;
  201. unsigned int status;
  202. time_t updated;
  203. #endif
  204. };
  206. struct Channel
  207. {
  208. int type;
  209. int ref;
  210. char fname[CHNLURL_LEN];
  211. char channel_name[CHNLURL_LEN];
  212. char channel_md5[MD5_LEN+1];
  213. int maxblocksize;
  214. int numclient;
  215. int numjob; // number of jobs
  216. unsigned int ctime;
  217. #ifdef __SP_SOURCE
  218. int numofnp[MAX_TS];
  219. #endif
  220. #ifdef __CP_SOURCE
  221. time_t last_nearpeer;
  222. #endif
  223. long long downsize; // recv from SP for CP, file size for SP;
  224. long long upsize; // send to NP
  225. FILE *db;
  226. struct LiveChannelInfo *pcinfo;
  227. struct Edge *PeerHead;
  228. struct Channel *next;
  229. struct Channel *lnext;
  230. };
  232. struct Session
  233. {
  234. int type;
  235. int socket;
  236. #ifdef __CP_SOURCE
  237. unsigned char npcp; //TYPE_CP
  238. unsigned char flag;
  239. unsigned short first;
  240. unsigned int sock_flag; /* saved for restore after connection succed */
  241. float version;
  242. long long totalup;
  243. struct PeerInfoWithAddr addr;
  244. // struct CorePeerInfo *c;
  245. // struct TransferInfo *t;
  246. #endif
  247. unsigned int host;
  248. unsigned int port;
  249. unsigned int time_sec; //time of creation
  250. unsigned int last_transferblock; //time of last send or recv a block
  251. char *buf;
  252. unsigned int start;
  253. unsigned int off;
  254. unsigned int numjob;
  255. struct JobDes *head;
  256. struct Channel *pc;
  257. struct Edge *header;
  258. struct Session *next;
  259. };
  261. struct ServerDesc
  262. {
  263. int flag;
  264. int sock;
  265. int type;
  266. int cur;
  267. int max;
  268. int maxid;
  269. unsigned int port;
  270. // char buf[MAX_DATA];
  271. unsigned int start;
  272. unsigned int off;
  273. struct Session *head;
  274. int (*init) (int listnum);
  275. int (*process) (int listnum);
  276. int (*closure) (int listnum);
  277. };
  279. struct Edge
  280. {
  281. struct Channel *head;
  282. struct Session *me;
  283. struct Edge *cnext;
  284. struct Edge *enext;
  285. };
  287. struct JobDes
  288. {
  289. struct Session *p;
  290. struct Channel *pc;
  291. struct JobDes *prev;
  292. struct JobDes *next;
  293. int blockid;
  294. int start;
  295. int len;
  296. char buffer[MAX_MSG_SIZE];
  297. };
  299. struct cachetype
  300. {
  301. struct cachetype *next;
  302. };
  304. struct DBRec
  305. {
  306. char md5pass[MD5_LEN];
  307. char *cname;
  308. float bitrate;
  309. int isSave;
  310. };
  312. struct logrec
  313. {
  314. unsigned int id;
  315. unsigned int keysample;
  316. };
  318. #ifdef DEBUG
  319. #ifdef HAVE_SYSLOG
  320. #define OPENLOG openlog (IDENTITY, LOG_PID, LOG_USER)
  321. #define PDEBUG(fmt, args...) syslog(LOG_INFO, "(%s,%d)" fmt, __FILE__, __LINE__, ## args)
  322. #define CLOSELOG closelog ()
  323. #else /* HAVE_SYSLOG */
  324. #define PDEBUG(fmt, args...) fprintf(stderr, IDENTITY ": (%s,%d)" fmt, __FILE__, __LINE__, ## args)
  325. #endif /* HAVE_SYSLOG */
  326. #endif
  328. #ifndef OPENLOG
  329. #define OPENLOG do {} while (0)
  330. #endif
  331. #ifndef CLOSELOG
  332. #define CLOSELOG do {} while (0)
  333. #endif
  334. #ifndef PDEBUG
  335. #define PDEBUG(a,...) do {} while (0)
  336. #endif
  338. #define PINFO(fmt, args...) fprintf(stderr, IDENTITY ": (%s,%d)" fmt, __FILE__, __LINE__, ## args)
  340. #define IPADDR(a) (a >> 24), ((a)>>16) & 0xff, ((a)>>8) & 0xff, (a) & 0xff
  342. #ifdef HAVE_MYSQL
  343. #include <mysql/mysql.h>
  344. #define MAX_QUERY 1024
  345. #endif
  347. #define isSet(buf,i) ((buf[i>>3] & (0x80>>(i&7))) != 0)
  348. #define setBit(buf,i) do {buf[i>>3] |= (0x80>>(i&7));}while (0)
  349. #define clrBit(buf,i) do {buf[i>>3] &= ~(0x80>>(i&7));}while (0)
  351. #define FIX_MAGIC 1134224000
  353. inline struct JobDes *newJob ();
  354. void addJob (struct Session *q, struct Channel *pc, struct JobDes *n);
  355. inline struct JobDes *findEnoughBuffer (struct Session *q, struct Channel *pc, int size);
  356. void deleteJob (struct Session *q, struct Channel *pc, int *job, int num);
  357. int processJobs (struct Session *q);
  358. void deleteAll (struct Session *q);
  359. void deleteChannel (struct Session *q, struct Channel *pc);
  361. int newChannel (struct Channel *pc, struct NormalAddress *client, int n, int type);
  362. struct Channel *newLiveChannel (char *name, struct Session *source, char *cmd5, float bitrate, int maxblocksize);
  363. void freeAllChannel ();
  365. inline int hash_str (unsigned char *str, int len);
  366. int saveBlock (struct Channel *c, char *buf, struct Session *p);
  367. int locate_by_id (struct Channel *c, unsigned int id, char *buf, int max);
  368. struct Channel *findChannel (char *name, int len);
  369. int freeChannel (struct Channel **phash, struct Channel **plist, int *count, struct Channel *p);
  370. void freeLiveChannel (struct Channel *pc, void *p);
  371. int free_livechannel (struct Channel *pc);
  372. struct Channel *getChannel (struct Channel **phash, char *name, int len);
  374. struct Edge *newEdge (struct Channel *head, struct Session *me);
  375. int delEdge (struct Edge *e);
  377. int process_P2P_REQUEST_real (struct Session *p, struct Channel *pc, int id);
  378. void freeMedia (struct Channel *pc);
  379. #ifdef __CP_SOURCE
  380. void addMedia (struct Channel *pc, int start, int len, int dlen, char *data, char *progname, char *channel_name);
  381. #endif
  382. #ifdef __SP_SOURCE
  383. void addMedia (struct Channel *pc, int start, int len, int dlen, char *data, char *progname);
  384. #endif
  385. int isHit (struct Channel *pc, int blockid);
  386. void sendHitMedia (struct Session *p, struct Channel *pc, int i, int id, int copymd5);
  387. void sendMedia (struct Session *p, struct Channel *pc);
  389. struct Channel *getProgrambymd5 (char *name, int len);
  390. int locateprog_by_id (struct Channel *pc, unsigned int id, char *buf, int max);
  391. void freeAllProgram ();
  393. struct Channel *newOrder (char *md5);
  394. int locate_order_by_id (struct Channel *c, uint32_t id, char *buf, int max);
  395. struct Channel *findOrder (char *name, int len);
  396. void freeAllOrder ();
  398. void apply_hash (struct Channel **phash, void apply (struct Channel *,void *), void *p);
  399. void apply_list (struct Channel *plist, void apply (struct Channel *, void *), void *p);
  401. int timer_remove (void *entity, void *data);
  402. void sendIdMedia (struct Session *p, struct Channel *pc, int id, int copymd5);
  404. int writeMessage (struct Session *p, struct Channel *pc, char *ptr);
  405. #endif //__ECHO_H_INCLUDED