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

源码开发语言/平台
当前位置：首页 > 源码/资料 > 游戏 > 模拟服务器 > 查看源码
main.c
资源名称：saac.tar.gz　[点击查看]
上传用户：qys8201
上传日期：2021-12-11
资源大小：978k
文件大小：39k
源码类别：

模拟服务器

开发平台：

C/C++

main.c：源码内容
  1. #define _MAIN_C_
  3. #include "main.h"
  4. #include "util.h"
  5. #include "mail.h"
  6. #include "db.h"
  7. #include "saacproto_util.h"
  8. #include "saacproto_serv.h"
  9. // CoolFish: Family 2001/5/9
  10. #include "acfamily.h"
  11. #include "version.h"
  12. #ifdef _SEND_EFFECT   // WON ADD 送下雪、下雨等特效 
  13. #include "recv.h"
  14. #endif
  16. #include "char.h"
  18. #ifdef _SASQL
  19. #include "sasql.h"
  20. #endif
  22. #include <stdio.h> 
  23. #include <time.h> 
  25. #include <signal.h>
  26. #include <sys/types.h>
  27. #include <time.h>
  28. #include <sys/time.h>
  29. #include <errno.h>
  30. #include <sys/wait.h>
  31. #include <getopt.h>
  32. #include <stdio.h>
  33. #include <malloc.h>
  34. #include <strings.h>
  35. #include <string.h>
  36. #include <unistd.h>
  37. #include <netdb.h>
  38. #include <errno.h>
  39. #include <sys/socket.h>
  40. #include <netinet/in.h>
  41. #include <arpa/inet.h>
  42. #include <time.h>
  43. #include <fcntl.h>
  44. #include <netinet/tcp.h>
  46. #include "lock.h"
  47. #define BACKLOGNUM 5
  49. int worksockfd;
  51. struct membuf
  52. {
  53.     int use;
  54.     char buf[512];
  55. //    char buf[1024*128];
  56.     int len;
  57.     int next;
  58. };
  60. struct connection
  61. {
  62.     int use;    
  63.     int fd;       
  64.     int mbtop_ri;
  65.     int mbtop_wi;
  66.     struct sockaddr_in remoteaddr;
  67.     int closed_by_remote;
  68. };
  70. struct membuf *mb;
  71. int mbsize;
  72. int mbuse ;
  74. int cpuuse;
  77. int mainsockfd;             /* accept 及  域娄醒卞中木月 */
  78. struct sockaddr_in localaddr;       /* bind 允月失玉伊旦 */
  79.     
  81. struct connection *con;        /* 戊生弁扑亦件     */
  83. static int mb_finder=0;              /* mb及坞五毛腹绸允月凶户及
  84.                                腹绸玄永皿及匏  筏盛迕 */
  85. // WON FIX
  86. //char tmpbuf[65536];
  87. char tmpbuf[1024*32];
  88. //char tmpbuf[65536*3];         /* read迕 */
  90. struct timeval select_timeout;
  92. time_t sys_time =0; // Robin add
  94. extern gmsv gs[MAXCONNECTION];
  96. int tcpstruct_init( char *addr, int port, int timeout_ms, int mem_use, int deb);
  97. int tcpstruct_accept1( void );
  98. int tcpstruct_accept( int *tis , int ticount );
  99. int tcpstruct_close( int ti );
  100. int tcpstruct_read( int ti , char *buf , int len );
  101. int tcpstruct_readline( int ti , char *buf , int len ,int k ,int r);
  102. int tcpstruct_readline_chop( int ti , char *buf, int len );
  103. int tcpstruct_write( int ti , char *buf , int len );
  104. int tcpstruct_countmbuse( void );
  105. int tcpstruct_connect( char *addr , int port );
  106. void set_nodelay( int sock );
  109. #define OK     0        /* 岳   */
  110. #define TCPSTRUCT_ENOMEM -1       /* malloc 撩   */
  111. #define TCPSTRUCT_ESOCK -2        /* socket 撩   */
  112. #define TCPSTRUCT_EBIND -3        /* bind 撩   */
  113. #define TCPSTRUCT_ELISTEN -4      /* listen 撩   */
  114. #define TCPSTRUCT_EBUG -6         /* 田弘匹丐月 */
  115. #define TCPSTRUCT_EINVCIND -7     /* con尺及index互云井仄中方 */
  116. #define TCPSTRUCT_EREADFIN -8     /* read 允月犯□正互卅仁化 closed by remote */
  117. #define TCPSTRUCT_EHOST -9        /* gethostbyname 撩   */
  118. #define TCPSTRUCT_ECONNECT -10    /* connect 撩   */
  119. #define TCPSTRUCT_ECFULL -11      /* con 互中匀天中 */
  120. #define TCPSTRUCT_ETOOLONG -12    /* 垫互卅互允亢 */
  121. #define TCPSTRUCT_EMBFULL -13     /* mb 互中匀天中  */
  122. #define TCPSTRUCT_ECLOSEAGAIN -14 /* close 互2荚今木凶 */
  125. int port;               /* 必□丞扔□田□互涛粮仄化仁月禾□玄 */
  126. int Total_Charlist;
  127. int Expired_mail;
  128. int Del_Family_or_Member;
  129. int Write_Family;
  131. // Nuke start
  132. char *chartime()
  133. {
  134.     static char buf[80];
  135.     time_t t;
  136.     t=time(0);
  137.     strcpy(buf,ctime(&t));
  138.     buf[strlen(buf)-1]=0;
  139.     return(buf);
  140. }
  141. #ifdef _ANGEL_SUMMON
  142. extern struct MissionTable missiontable[MAXMISSIONTABLE];
  143. static int initMissionTable( void );
  144. int saveMissionTable( void );
  145. void checkMissionTimelimit( void);
  146. #endif
  148. static int initRankTable( void );
  150. /*
  151.   sigaction白弁
  152.  */
  153. void sighandle( int a )
  154. {
  155.   if (a==SIGUSR1) log("sigusr1信号!n");
  156.   log("得到一个信号! 异常中断......n" );
  157.   writeFamily(familydir);
  158.   writeFMPoint(fmpointdir);
  159.   writeFMSMemo(fmsmemodir);
  160. #ifdef _ANGEL_SUMMON
  161. saveMissionTable();
  162. #endif
  163.   exit(1);
  164. }
  166. // Arminius 7.20 memory unlock
  167. void sigusr1(int a)
  168. {
  169.   int i;
  170.   FILE *f;
  171.   char key[4096],buf[4096];
  173.   signal(SIGUSR1, sigusr1);
  174.   
  175.   f = fopen("./unlock.arg", "r");
  177.   if (f) {
  178.     memset(key, 0, 4096);
  179.     fread(key, 4096, 1, f);
  180.     for (i=0; i<strlen(key); i++) if (key[i]=='n') key[i]='';
  182.     switch (key[0]) {
  183.     case 'P': // unlock player
  184.       if (DeleteMemLock(getHash(&key[1]) & 0xff,&key[1],&i)) {
  185.         log("ADM: memunlock: %s success.n", key);
  186.       } else {
  187.         log("ADM: memunlock: %s failed.n", key);
  188.       }
  189.     break;
  190.     case 'S': // unlock server
  191.       DeleteMemLockServer(&key[1]);
  192.       log("ADM: memunlock: %sn", key);
  193.     break;
  194.     case 'C': // check player lock
  195.       GetMemLockState(getHash(&key[1]) & 0xff, &key[1], buf);
  196.       sprintf(key, "echo "%s" > ./sigusr1.result", buf);
  197.       system(key);
  198.     break;
  199. #ifdef _SEND_EFFECT    // WON ADD 送下雪、下雨等特效
  200. case 'E':
  201. log("nAC 向 GS 发送下雪特效!!n");
  202.     SendEffect(&key[1]);
  203. break;
  204. #endif
  206. case 'L':  // Robin 列出所有Server连线
  207. log("nList All Server Conncet!!!!!n");
  208. for( i =0; i <MAXCONNECTION; i++)
  209. if( gs[i].use)
  210. log("n gs[%d] fd:%d name:%s ", i, gs[i].fd, gs[i].name );
  211. break;
  213.   }
  214. log(" sigusr1_over_1 ");
  215. fclose(f);
  216. log(" sigusr1_over_2 ");
  218.   }
  219. }
  221. static int netWrite( int ti , char *buf , int len)
  222. {
  223.     return tcpstruct_write( ti , buf, len );
  224. }
  226. gmsv gs[MAXCONNECTION];
  227. #ifdef _VIP
  228. int login_game_server( int ti , char *svname , char *svpas , int checkvip,
  229.                char *result , int resultlen ,
  230.                char *retdata , int retdatalen )
  231. #else
  232. int login_game_server( int ti , char *svname , char *svpas ,
  233.                char *result , int resultlen ,
  234.                char *retdata , int retdatalen )
  235. #endif
  236. {
  237. #ifndef _VIP
  238. char buff[50];
  239. sprintf(buff,"longzoro-%s-%d",svpass,123);
  240.     if( strcmp( svpas , buff ) == 0 ){
  241. #else
  242. if( strcmp( svpas , svpass ) == 0 ){
  243. #endif
  244.         log( "服务器密码正确 %sn" , svname );
  245.     } else {
  246.         log( "服务器密码错误 %sn" , svname );
  247.         snprintf( result , resultlen , "失败" );
  248.         snprintf( retdata , retdatalen , "密码错误" );
  249.         return 0;
  250.     }
  251. #ifdef _VIP
  252.     if(checkvip==0 || checkvip!=55575556 * 2)
  253.     {
  254.      snprintf( result , resultlen , "failed" );
  255.       snprintf( retdata , retdatalen , "duplicate login" );
  256.       return 0;
  257.     }
  258. #endif
  259.     {
  260.         int i;
  261.         for(i=0;i<MAXCONNECTION;i++){
  262.             if( gs[i].use &&
  263.                 strcmp( gs[i].name , svname ) == 0 ){
  264.                 snprintf( result, resultlen, "failed" );
  265.                 snprintf( retdata , retdatalen, "duplicate login" );
  266.                 return 0;
  267.             } 
  268.         }
  269.     }
  270.     snprintf( gs[ti].name , sizeof(gs[ti].name), "%s" , svname );
  271.   gs[ti].fd = ti;
  272.     snprintf( result , resultlen ,SUCCESSFUL );
  273.     snprintf( retdata , retdatalen , "Nothing special" );
  274.     DeleteMemLockServer(svname); // Arminius 7.31 unlock server
  275.     return 0;
  276. }
  278. int logout_game_server( int ti )
  279. {
  281.     gs[ti].use = 0;
  282. gs[ti].fd = -1;
  283.     gs[ti].name[0] = 0;
  284.     tcpstruct_close( ti );
  285.     return 0;
  286. }
  287. int is_game_server_login( int ti )
  288. {
  289.     return gs[ti].use;
  290. }
  292. static int readConfig( char *path )
  293. {
  294.     char buf[2048];
  295.     FILE *fp;
  297.     fp = fopen( path , "r" );
  298.     if( fp == NULL ){ return -2; }
  300.     while( fgets( buf , sizeof( buf ) , fp )){
  301.         char command[128];
  302.         char param[128];
  303.         chop(buf);
  304.         
  305.         easyGetTokenFromString( buf , 1 , command , sizeof( command ));
  306.         easyGetTokenFromString( buf , 2 , param , sizeof( param ));
  308.         if( strcmp( command , "port" ) == 0 ){
  309.             port = atoi( param );
  310.          log( "端口:%dn",port );
  311.         } else if( strcmp( command , "logdir" ) == 0 ){
  312.             snprintf( logdir , sizeof( logdir) , param );
  313.             log( "日志目录:%sn",logdir );
  314.         } else if( strcmp( command , "chardir" ) == 0 ){
  315.             snprintf( chardir , sizeof( chardir) , param );
  316.             log( "档案目录:%sn",chardir );
  317. #ifdef _SLEEP_CHAR
  318. snprintf( sleepchardir , sizeof( sleepchardir), "%s_sleep", chardir);
  319. log( "睡眠目录:%sn",sleepchardir );
  320. #endif
  321.         } else if( strcmp( command , "pass" ) == 0 ){
  322.          snprintf( svpass , sizeof( svpass ) , param);
  323.             log( "密码:%sn",param );
  324.         } else if( strcmp( command , "dbdir" ) == 0 ){
  325.             snprintf( dbdir , sizeof( dbdir) , param );    
  326.             log( "数据目录:%sn",dbdir );        
  327.         } else if( strcmp( command, "rotate_interval" ) == 0 ){
  328.             log_rotate_interval = atoi( param );
  329.             log( "日志循环间隔:%dn",log_rotate_interval ); 
  330.         } else if( strcmp( command, "maildir" ) == 0 ){
  331.             snprintf( maildir, sizeof( maildir ), param );
  332.             log( "邮件目录:%sn",maildir );
  333. #ifdef _FAMILY
  334.         // CoolFish: Family 2001/5/9
  335.         } else if( strcmp( command, "familydir" ) == 0 ){
  336.             snprintf( familydir, sizeof( familydir ), param );
  337.             log( "家族目录:%sn",familydir );
  338.         } else if( strcmp( command, "fmpointdir" ) == 0 ){
  339.             snprintf( fmpointdir, sizeof( fmpointdir ), param );
  340.             log( "庄园表列:%sn",fmpointdir );
  341.         } else if( strcmp( command, "fmsmemodir" ) == 0 ){
  342.             snprintf( fmsmemodir, sizeof( fmsmemodir ), param );
  343.             log( "家族备份:%sn",fmsmemodir );
  344. #endif
  345.   } else if( strcmp( command , "Total_Charlist" ) == 0 ){
  346.          Total_Charlist = atoi( param );
  347.          log( "更新人物点数间隔:%d秒n",Total_Charlist );
  348.         } else if( strcmp( command , "Expired_mail" ) == 0 ){
  349.          Expired_mail = atoi( param );
  350.          log( "更新过期邮件间隔:%d秒n",Expired_mail );
  351.         } else if( strcmp( command , "Del_Family_or_Member" ) == 0 ){
  352.          Del_Family_or_Member = atoi( param );
  353.          log( "删除家族成员间隔:%d秒n",Del_Family_or_Member );
  354.         } else if( strcmp( command , "Write_Family" ) == 0 ){
  355.          Write_Family = atoi( param );
  356.          log( "更新家族信息间隔:%d秒n",Write_Family );
  357. } else if( strcmp( command , "SameIpMun" ) == 0 ){
  358.          sameipmun = atoi( param );
  359.          if(sameipmun>0){
  360.          log( "同IP允许同时登陆:%d次n",sameipmun );
  361.          }else{
  362.          log( "同IP允许同时登陆:无限制n" );
  363.          }
  364. }
  365.     }
  367.     fclose(fp);
  368.     return 0;
  369. }
  372. static void parseOpts( int argc, char **argv )
  373. {
  374.     int c , option_index;
  376. while(1){
  377.         static struct option long_options[] = {
  378.             {"nice" , 1 , 0 , 'n'},
  379.             {"help" , 0 , 0 , 'h' },
  380.             {"userinfo",0 , 0 , 'i'},
  381.             {"lockuser",0 , 0 , 'l'}
  382.         };
  383.         c = getopt_long( argc , argv , "n:hil" , long_options , &option_index );
  384.         if( c == -1 )break;
  385.         switch( c ){
  386.         case 'h':
  387.             fprintf( stderr ,
  388.                      "使用方法: saac [-h] [-w port] [-w port] ... n"
  389.                      "-h : 显示saac的帮助n"
  390.                      "-w port : 添加一个工作站进程端口n"
  391.                      "Copyright 2006 龙zoro工作室 "
  392.                      "( Longzoro System Supply )n");
  393.             exit(0);
  394.             break;
  395.         case 'i':
  396. #ifdef _SASQL
  397.          sasql_init();
  398.          sasql_craete_userinfo();
  399.          sasql_close();
  400. #endif
  401. exit(0);
  402.             break;
  403.         case 'l':
  404. #ifdef _SASQL
  405.          sasql_init();
  406.          sasql_craete_lock();
  407.          sasql_close();
  408. #endif
  409.          exit(0);
  410.             break;
  411.         case 'n':
  412.          nice(atoi( optarg ));
  413.          break;
  414.         default:
  415.             log( "不能读懂选项 %cn" , c );
  416.             exit(0);
  417.         }
  418.     }
  419. }
  420. double time_diff(struct timeval subtrahend,  struct timeval subtractor);
  423. int main( int argc , char **argv )
  424. {
  425. parseOpts( argc, argv );
  427.     // Nuke +1 1012: Loop counter
  428.     int counter1 = 0;
  429.     
  430.     int counter2 = 0;
  431.     
  432.     int counter3 = 0;
  433.     
  434.     int counter4 = 0;
  436.     signal(SIGUSR1, sigusr1);
  438.     log_rotate_interval = 3600 * 24 * 7;
  440.     Lock_Init(); // Arminius 7.17 memory lock
  442. UNlockM_Init();
  443.     
  444.     if(readConfig( "acserv.cf" )<0){
  445.         log( "无法在当前目录里读取 acserv.cf .n" );
  446.         exit(1);
  447.     }
  449. #ifdef _SASQL
  450.     sasql_init();
  451. #endif
  452.     log( "读取数据目录n" );
  453.     dbRead( dbdir );
  454. #ifdef _FAMILY
  455.     log("读取 家族庄园n");
  456.     readFMSMemo(fmsmemodir);
  457.     log("读取 家族留言n");
  458.     readFMPoint(fmpointdir);
  459.     log("读取 家族目录n");
  460.     readFamily(familydir);
  461. #endif
  462.     log( "准备 档案目录n" );
  463.     prepareDirectories( chardir );
  464.     log( "准备 日志目录n" );
  465.     prepareDirectories( logdir );
  466.     log( "准备 邮件目录n" );
  467.     prepareDirectories( maildir );
  469. #ifdef _SLEEP_CHAR
  470.     prepareDirectories( sleepchardir );
  471.     log( "准备 睡眠档案目录n" );
  472. #endif
  474.     /* 凶引匀化月丢□伙毛  心仇戈 */
  475.     if( readMail(maildir) < 0 ){
  476.         log( "不能初始化邮件n" );
  477.         exit(1);
  478. }
  480.     /* TCPSTRUCT 毛赓渝祭 */
  481.     {
  482.         int tcpr;
  483.         if( ( tcpr = tcpstruct_init( NULL , port , 0 ,
  484. CHARDATASIZE * 16 * MAXCONNECTION , 1 /* DEBUG */ ) ) < 0 ){
  485.             log( "不能开启TCP: %dn", tcpr );
  486.             return 1;
  487.         }
  488.     }
  489.     saacproto_InitServer( netWrite , CHARDATASIZE );
  491.     {
  492.         struct sigaction s,os;
  493.         
  494.         bzero( &s, sizeof(s));
  495.         s.sa_handler = sighandle;
  496.         s.sa_flags = SA_NOMASK;
  497.         sigaction( SIGTERM,  &s, &os );
  499.         bzero( &s, sizeof(s));
  500.         s.sa_handler = sighandle;
  501.         s.sa_flags = SA_NOMASK;
  502.         sigaction( SIGINT,  &s, &os );
  504.         bzero( &s, sizeof( s ));
  505.         s.sa_handler = SIG_IGN;
  506.         s.sa_flags = SA_NOMASK;
  507.         sigaction( SIGPIPE, &s, &os );
  509.     }
  511. #ifdef _AC_SEND_FM_PK  // WON ADD 庄园对战列表储存在AC
  512. load_fm_pk_list();
  513. #endif
  515. #ifdef _ACFMPK_LIST
  516. FMPK_LoadList();
  517. #endif
  518. #ifdef _ALLDOMAN
  519. LOAD_herolist();  // Syu ADD 排行榜NPC
  520. #endif
  522. #ifdef _ANGEL_SUMMON
  523. initMissionTable();
  524. #endif
  526. #ifdef _VIP
  527. log( "n服务端版本: <%s 会员版>n" , SERVER_VERSION );
  528. #else
  529. log( "n服务端版本: <%s 普通版>n" , SERVER_VERSION );
  530. #endif
  531. log( "n服务端编译完成时间:%s %s by 龙zoro工作室n" , __DATE__ , __TIME__ );
  533.     log( "n开始工作...n" );
  535.     signal(SIGUSR1,sigusr1); // Arminius 7.20 memory lock
  536. int itime=0;
  537. while(1){
  538. itime++;
  539. if(itime>cpuuse){
  540. itime=0;
  541. usleep(1);
  542. }
  543.     int newti,i;
  544.     static time_t main_loop_time;
  546. sys_time = time(NULL);
  548. if( main_loop_time != sys_time){
  549.             main_loop_time = time(NULL);
  550.             counter1++;
  551.             counter2++;
  552.             counter3++;
  553.             counter4++;
  554. //andy add 2002/06/20
  555. UNlockM_UnlockPlayer();
  557. #ifdef _ANGEL_SUMMON
  558. checkMissionTimelimit();
  559. #endif
  560.             // Nuke *1 1012
  561.             if( counter1 > Total_Charlist ){
  562.              counter1=0;
  563.                 char *c = ctime( &main_loop_time );
  564.                 if( c ){
  565.                     struct timeval st,et;
  566.                     log( "nTIME:%sn",c );
  567.                     gettimeofday( &st,NULL);
  568.                     dbFlush(dbdir);
  569.                     gettimeofday( &et,NULL);
  570.                     log( "Flushed db(%fsec)n", time_diff(et,st) );
  571.                     log( "档案表列总数:%d NG:%dn",
  572.                          total_ok_charlist, total_ng_charlist );
  573.                 }
  574.             }
  575.             // Nuke **1 1012
  576.             //if( ( counter % 600 ) == 0 ){
  577.             if( counter2 > Expired_mail ){
  578.              counter2=0;
  579.                 struct timeval st,et;
  580.                 gettimeofday( &st,NULL);
  581.                 expireMail();
  582.                 gettimeofday( &et,NULL);
  583.                 log( "过期邮件(%fsec)n", time_diff(et,st) );
  584.             }
  585. #ifdef _FAMILY
  586.             //if ((counter % 300) == 0) // 300( -> 60)
  587.       if( counter4 > Write_Family ) // 300( -> 60)
  588.       {
  589.          counter4=0;
  590.           struct timeval st, et;
  591.           gettimeofday(&st, NULL);
  592.           writeFamily(familydir);
  593.           writeFMPoint(fmpointdir);
  594.           writeFMSMemo(fmsmemodir);
  595.           gettimeofday(&et, NULL);
  596.           log("记录家族(%fsec)n", time_diff(et, st));
  597.       }
  598. #endif
  599.         }
  600.     newti = tcpstruct_accept1();
  601.     if( newti >= 0 ){
  602. log( "同意: %dn" , newti );
  603. gs[newti].use = 1;
  604.     }
  606.         for(i=0;i<MAXCONNECTION;i++){
  607. //         char buf[CHARDATASIZE * 16;
  608.             char buf[CHARDATASIZE];
  609.             int l;
  610.             l = tcpstruct_readline_chop( i , buf , sizeof( buf )- 1);
  611. {
  612.                 if( !gs[i].use )continue;
  613.                 if( l > 0 ){
  614. char debugfun[256];
  615.                     buf[l]=0;
  616.                     if( saacproto_ServerDispatchMessage( i , buf, debugfun)<0){
  617.                         // Nuke start
  618.                         tcpstruct_close(i);// avoid the shutdown the gmsv ttom
  619.                         log( "GMSV(%s) 消息:%sn", gs[i].name, debugfun);
  620.                     }
  621.                 } else if( l == TCPSTRUCT_ETOOLONG ){
  622.                     log( "很长:%d 服务器名::%sn", i , gs[i].name );
  623.                     logout_game_server( i );
  624.                 } else if( l < 0 ){
  625.                     log( "关闭:%d 服务器名:%sn", i , gs[i].name );
  626.                     logout_game_server(i);
  627.                 } else if( l == 0 ){
  628.                     ;
  629.                 }
  630.             }
  631.         }
  632.         {
  633.             static struct timeval tv_loop_store ;
  634.             struct timeval now;
  635.             double dif;
  636.             gettimeofday( &now , NULL );
  637.             dif = time_diff( now, tv_loop_store );
  638.             if( dif > 0.5 ){ // CoolFish 0.1 -> 0.5 2001/5/19
  639.                 //log( "Sl:%f" , dif );
  640.             }
  641.             tv_loop_store = now;
  642.         }
  644.         /* 伐□市□及正奶丞失它玄毛譬屯月［
  645.            正奶丞失它玄仄凶日夫弘毛分仄化伐□市□毛诮仄化仄引丹［
  646.            匹必□丞扔□田□卞  蔽读卞反骚襞允月           */
  647.     }
  648.     return 0;       
  649. }
  650. double
  651. time_diff(struct timeval subtrahend,
  652.           struct timeval subtractor)
  653. {
  654.     return( (subtrahend.tv_sec - subtractor.tv_sec)
  655.             + (subtrahend.tv_usec
  656.             - subtractor.tv_usec  ) / (double)1E6 );
  657. }
  660. /*
  661.   夫弘及夫□  □玄市它件玄毛  月［
  662.   云卅元凛渝及手及反允屯化及夫弘白央奶伙互云卅元卞卅月方丹卞允月［
  664.   仇及酷  反醒侬及瑕互云云仁卅月互｝    匹奶件正□田伙毛  凳仄化手
  665.     暹屺分［
  666.   
  667.  */
  668. int get_rotate_count(void )
  669. {
  670.     int a;
  671.     unsigned int t = (unsigned int ) time(NULL);
  672.         
  673.     a = ( t / log_rotate_interval ) * log_rotate_interval;
  674.     
  675.     return a;
  676. }
  678. static int findregBlankMemBuf( void );
  679. static int unregMemBuf( int index );
  680. static int findregBlankCon( void );
  681. static int getFreeMem( void );
  683. static int appendReadBuffer( int index, char *data, int len );
  684. static int appendWriteBuffer( int index , char *data, int len );
  685. static int appendMemBufList( int top, char *data, int len );
  686. static int consumeMemBufList( int top, char *out, int len, int flag, int copyflag );
  687. static int getLineReadBuffer( int index, char *buf, int len );
  689. int tcpstruct_init( char *addr , int p , int timeout_ms , int mem_use , int db )
  690. {
  691.     mbsize = mem_use / sizeof( struct membuf );
  692.     mbuse =0;
  693.     mb_finder = 0;
  694.     mb = ( struct membuf * ) calloc( 1, mbsize * sizeof(struct membuf ));
  696.     if( mb == NULL ) return TCPSTRUCT_ENOMEM;
  697.     bzero( mb , mbsize * sizeof( struct membuf ));
  699.     con = ( struct connection *) calloc( 1, MAXCONNECTION * sizeof( struct connection ));
  700.     if( con == NULL ){
  701.         free( mb );
  702.         return TCPSTRUCT_ENOMEM;
  703.     } else {
  704.         int i;
  705.         for(i=0;i<MAXCONNECTION;i++){
  706.             con[i].use = 0;
  707.             con[i].fd = -1;
  708.         }
  709.     }
  710.     select_timeout.tv_sec = timeout_ms / 1000;
  711.     select_timeout.tv_usec = (timeout_ms - ( timeout_ms/1000)*1000)*1000;
  713.     /* socket */
  714.     mainsockfd = socket( AF_INET , SOCK_STREAM ,  0 );
  715.     if( mainsockfd < 0 ) return TCPSTRUCT_ESOCK;
  716.     
  717.     /* bind */
  718.     bzero( &localaddr ,sizeof( localaddr ));
  719.     localaddr.sin_family = AF_INET;
  720.     localaddr.sin_port = htons( p );
  721.     
  722.     if( addr ){
  723.         localaddr.sin_addr.s_addr = inet_addr( addr );
  724.     } else {
  725.         localaddr.sin_addr.s_addr = htonl( INADDR_ANY );
  726.     }
  727.     if( bind( mainsockfd , (struct sockaddr*) &localaddr ,
  728.               sizeof( localaddr )) < 0 ) return TCPSTRUCT_EBIND;
  730.     /* listen */
  731.     if( listen( mainsockfd , BACKLOGNUM )<0) return TCPSTRUCT_ELISTEN;
  733.     return OK;
  734. }
  736. int tcpstruct_accept1( void )
  737. {
  738.     int tis[BACKLOGNUM];
  739.     int ret;
  741.     ret = tcpstruct_accept( tis , 1 );
  742.     if( ret < 0 ){
  743.         return ret;
  744.     } else if( ret == 1 ){
  745.         return tis[0];
  746.     } else {
  747.         return TCPSTRUCT_EBUG ;
  748.     }
  749. }
  751. int tcpstruct_accept( int *tis , int ticount )
  752. {
  753.     int i;
  754.     int sret;
  755.     int accepted = 0;
  756.     struct timeval t;
  757.     fd_set rfds, wfds , efds;  
  758.     FD_ZERO( & rfds );
  759.     FD_ZERO( & wfds );
  760.     FD_ZERO( & efds );    
  762.     for(i=0;i<MAXCONNECTION;i++){
  763.         if( con[i].use &&
  764.             con[i].fd >= 0 && con[i].closed_by_remote ==0 ){
  765.             FD_SET( con[i].fd , & rfds );
  766.             FD_SET( con[i].fd , & wfds );
  767.             FD_SET( con[i].fd , & efds );
  768.         }
  769.     }
  770.     
  771.     t = select_timeout;
  772.     sret = select( 1024, & rfds , (fd_set*)NULL, & efds , &t);
  773. if( sret > 0 ) {
  774. for(i=0;i< MAXCONNECTION;i++){
  775. if( ( con[i].fd >= 0 ) && FD_ISSET( con[i].fd , &rfds ) ){
  776. int fr = getFreeMem( );
  777. int rr , readsize ;
  778. if( fr <= 0 ) continue;
  779. if( fr > sizeof(tmpbuf ) ){
  780. readsize = sizeof( tmpbuf);
  781. } else {
  782. readsize = fr;
  783. }
  784. rr = read( con[i].fd , tmpbuf , readsize );
  785. if( rr <= 0 ){
  786. con[i].closed_by_remote = 1;
  787. } else {
  788. appendReadBuffer( i , tmpbuf , rr );
  789. }
  790. }
  791. }
  792.     }    
  793.     /* write */
  794.     t = select_timeout;    
  795.     sret = select( 1024, (fd_set*)NULL, &wfds, & efds , &t);
  796. if( sret > 0 ) {
  797. for(i=0;i<MAXCONNECTION;i++){
  798. if( ( con[i].fd >= 0 ) && FD_ISSET( con[i].fd , &wfds )){
  799. char send_buf[4096];
  800. int l , rr;
  801. memset( send_buf, 0, sizeof( send_buf));
  802. l = consumeMemBufList( con[i].mbtop_wi ,send_buf, sizeof(send_buf),0 , 1 );
  803. rr = write( con[i].fd , send_buf , l );
  804. if( rr < 0 ){
  805. con[i].closed_by_remote = 1;
  806. } else {
  807. consumeMemBufList( con[i].mbtop_wi , send_buf, l, 1 , 0 );
  808. }
  809. }
  810. }
  811. }
  813.     for( i=0; i<ticount; i++){
  814.         int asret;
  815.         struct timeval t;
  816.         t.tv_sec =0;
  817.         t.tv_usec =0;
  818.         FD_ZERO( & rfds );
  819.         FD_ZERO( & wfds );
  820.         FD_ZERO( & efds );
  822.         FD_SET( mainsockfd , & rfds );
  823.         FD_SET( mainsockfd , & wfds );
  824.         FD_SET( mainsockfd , & efds );
  825.         asret = select( 1024, &rfds , &wfds , &efds, &t );
  826. // Nuke 20040610: add asret>0 to avoid signal interrupt in select
  827.         if( (asret>0) && FD_ISSET( mainsockfd , & rfds )){
  828.             struct sockaddr_in c;
  829.             int len , newsockfd;
  830.             int newcon;
  831.             bzero( &c , sizeof( c ));
  832.             len = sizeof( c );
  833.             fprintf( stderr, "i can accept " );
  834.             newcon = findregBlankCon( );
  835.             if( newcon < 0 ) continue;
  836.             newsockfd = accept( mainsockfd, (struct sockaddr*)&c , &len );
  837.         log( "同意: %dn" , newsockfd );
  838.             if( newsockfd < 0 ){
  839.                 unregMemBuf( newcon );
  840.                 continue;
  841.             }
  842.             set_nodelay( newsockfd );
  843.             con[newcon].fd = newsockfd;
  844.             memcpy( &con[newcon].remoteaddr , &c ,sizeof(c));
  845.             tis[accepted] = newcon;
  846.             accepted ++;
  847.         }
  848.     }
  850.     return accepted;
  851. }
  853. int tcpstruct_close( int ti )
  854. {
  856.     if( ti < 0 || ti >= MAXCONNECTION )return TCPSTRUCT_EINVCIND;
  857.     if( con[ti].use == 0 ){
  858.         return TCPSTRUCT_ECLOSEAGAIN;
  859.     }
  860.     close( con[ti].fd );
  861.     con[ti].use = 0;
  862.     con[ti].fd = -1;
  864.     /* 伉旦玄毛凶升匀化蝈  毛弁伉失允月 */
  865.     consumeMemBufList( con[ti].mbtop_ri , NULL,
  866.                    mbsize * sizeof( mb[0].buf ), 1, 0 );
  867.     consumeMemBufList( con[ti].mbtop_wi , NULL,
  868.                    mbsize * sizeof( mb[0].buf ), 1, 0 );
  869.     unregMemBuf( con[ti].mbtop_ri );
  870.     unregMemBuf( con[ti].mbtop_wi );
  871.     con[ti].mbtop_ri = -1;
  872.     con[ti].mbtop_wi = -1;    
  873.     return OK;
  874. }
  876. /*
  877.     心仇戈手及互手丹卅仁化｝仄井手 remoteclose 分匀凶日 -1 毛井尹允
  878.   
  879.  */
  880. int tcpstruct_read( int ti , char *buf , int len )
  881. {
  882.     int l;
  884.     if( ti < 0 || ti >= MAXCONNECTION || con[ti].use == 0 )
  885.         return TCPSTRUCT_EINVCIND;
  886.     l = consumeMemBufList( con[ti].mbtop_ri , buf , len , 1 , 1);
  887.     if( l == 0  && con[ti].closed_by_remote ) return TCPSTRUCT_EREADFIN;
  889.     return l;
  890. }
  892. /*
  893.   1垫毛方心仇戈［
  894.   int kend : 1卅日垫  及 n 毛诮允
  895.   int kend_r : 1卅日垫  及 r 手诮允(丐木壬)
  897.     心仇戈手及互手丹卅仁化｝井勾 remote closed 分匀凶日-1毛井尹允
  898.   // Nuke
  899. Read 1 line
  900. if kend==1 then delete n at the tail
  901. if kend_r== 1 then delete r at the tail (if any)
  902. if no data read, it means 'remote closed' then return -1
  903.  */
  904. int tcpstruct_readline( int ti , char *buf , int len , int kend , int kend_r )
  905. {
  906.     int l;
  907.     int minus = 0;
  909.     if( ti < 0 || ti >= MAXCONNECTION || con[ti].use == 0 )
  910.         return TCPSTRUCT_EINVCIND;
  912.     l = getLineReadBuffer( ti , buf , len );
  913.     if( l == 0 ){
  914.         if( con[ti].closed_by_remote ){
  915.             return TCPSTRUCT_EREADFIN;
  916.         } else {
  917.             return 0;
  918.         }
  919.     }
  920.     
  921.     if( kend ){
  922.         if( buf[l-1]=='n' ){
  923.             buf[l-1] = 0; minus =-1;
  924.         }
  925.     }
  926.     if( kend_r ){
  927.         if( buf[l-1]=='r' ){
  928.             buf[l-1] = 0; minus = -1;
  929.         }
  930.         if( buf[l-2]=='r' ){
  931.             buf[l-2] = 0; minus = -2;
  932.         }
  933.     }
  934.     return l + minus;
  935. }
  936. int tcpstruct_readline_chop( int ti , char *buf, int len )
  937. {
  938.     return tcpstruct_readline( ti , buf , len , 1,1);
  939. }
  941. int tcpstruct_write( int ti , char *buf , int len )
  942. {
  943.     if( ti < 0 || ti >= MAXCONNECTION || con[ti].use == 0 )
  944.         return TCPSTRUCT_EINVCIND;    
  945.     return appendWriteBuffer( ti , buf , len );
  946. }
  948. int tcpstruct_connect( char *addr , int port )
  949. {
  950.     int newti ;
  951.     int s, r;
  952.     struct sockaddr_in svaddr;
  953.     struct hostent *he;
  954.     
  955.     s = socket( AF_INET, SOCK_STREAM , 0 );
  956.     if(s<0)return -2;
  958.     bzero( &svaddr , sizeof( svaddr ));
  959.     svaddr.sin_family = AF_INET;
  960.     svaddr.sin_port = htons( port );
  962.     if( inet_aton( addr, &svaddr.sin_addr ) == 0 ){
  963.         he = gethostbyname( addr );
  964.         if( he == NULL ){
  965.             return TCPSTRUCT_EHOST;
  966.         }
  967.         memcpy( & svaddr.sin_addr.s_addr , he->h_addr ,
  968.                 sizeof( struct in_addr));
  969.     }
  970.     r = connect( s , ( struct sockaddr*)&svaddr,sizeof(svaddr));
  971.     if( r < 0 ){
  972.         return TCPSTRUCT_ECONNECT;
  973.     }
  974.     set_nodelay( s );
  975.     newti = findregBlankCon( );
  976.     if( newti < 0 ){
  977.         fprintf( stderr , "连接失败: newti:%dn", newti );
  978.         return TCPSTRUCT_ECFULL;
  979.     }
  980.     con[newti].fd = s;
  981.     memcpy( & con[newti].remoteaddr , &svaddr ,
  982.             sizeof( struct sockaddr_in));
  983.     return newti;
  984. }
  986. static int appendReadBuffer(  int index , char *data , int len )
  987. {
  988.     int top;
  990.     top = con[index].mbtop_ri;
  991.     for(;;){
  992.         int nextind = mb[top].next;
  994.         if( nextind == -1 ) break;
  995.         top = nextind;
  996.     }
  997.     return appendMemBufList( top , data , len );
  998. }
  1000. static int appendWriteBuffer( int index , char *data , int len )
  1001. {
  1002.     int top;
  1003.     top = con[index].mbtop_wi;
  1004.     for(;;){
  1005.         int nextind = mb[top].next;
  1006.         if( nextind == -1 ) break;
  1007.         top = nextind;
  1008.     }
  1009.     return appendMemBufList( top , data , len );
  1010. }
  1011. static int appendMemBufList( int top , char *data , int len )
  1012. {
  1013.     int fr = getFreeMem( );
  1014.     int rest = len;
  1015.     int data_topaddr = 0;
  1016.     
  1017.     if( len >= fr ){
  1018. FILE *fp;
  1019. if( (fp=fopen( "badsysinfo.txt", "a+")) != NULL ){
  1020. fprintf( fp, "appendMemBufList() len:%d / fr:%d err !! n", len, fr);
  1021. fclose( fp);
  1022. }
  1023. //andy_log
  1024. log( "appendMemBufList() len:%d / fr:%d err !! n", len, fr);
  1025.         return -1;
  1026.     }
  1027. data[len] = 0;
  1028.     for(;;){
  1029.         int blanksize = sizeof( mb[0].buf ) - mb[top].len;
  1030.         int cpsize = ( rest <= blanksize ) ? rest : blanksize;
  1031.         memcpy( mb[top].buf + mb[top].len ,
  1032.                 data + data_topaddr , cpsize );
  1033.         mb[top].len += cpsize;
  1034.         if( rest <= blanksize ){
  1035.             return len;
  1036.         } else {
  1037.             int newmb;
  1038.             rest -= cpsize;
  1039.             data_topaddr += cpsize;
  1040.             if( (newmb = findregBlankMemBuf( ) ) == TCPSTRUCT_EMBFULL ){
  1041. FILE *fp;
  1042. if( (fp=fopen( "badsysinfo.txt", "a+")) != NULL ){
  1043. fprintf( fp, "find newmb == TCPSTRUCT_EMBFULL err data:%s !!n", data);
  1044. fclose( fp);
  1045. }
  1046. log( "find newmb == TCPSTRUCT_EMBFULL err data:%s !!n", data);
  1047. }
  1048.             mb[top].next = newmb;
  1049.             top = mb[top].next;
  1050.         }
  1051.     }
  1052.     return TCPSTRUCT_EBUG;
  1053. }
  1055. static int consumeMemBufList( int top , char *out , int len ,
  1056.                           int consumeflag , int copyflag )
  1057. {
  1058.     int total = 0;
  1059.     int top_store = top;
  1060.     for(;;){
  1061.         int cpsize;
  1062.         if( top == -1 ) break;
  1063.         cpsize = ( mb[top].len <= ( len - total) ) ?
  1064.             mb[top].len : ( len - total );
  1066.         if( copyflag ) memcpy( out + total , mb[top].buf , cpsize );
  1067.         total += cpsize;
  1069.         if( consumeflag ){
  1070.             mb[top].len -= cpsize;
  1071.             if( mb[top].len > 0 ){
  1072.                 /* 勾井中反凶仄化卅中及匹memmove */
  1073.                 memmove( mb[top].buf , mb[top].buf + cpsize ,
  1074.                          sizeof( mb[top].buf ) - cpsize );
  1075.             }
  1076.         }
  1077.         top = mb[top].next;
  1078.         if( total == len ){
  1079.             break;
  1080.         }
  1081.     }
  1083.     if( consumeflag ){
  1084.         /* 卅互今互0卞卅匀化月卅日荸  ［匹手  赓及支勾反荸  仄卅中冗 */
  1085.         top = mb[top_store].next;
  1086.         for(;;){
  1087.             if( top == -1 )break;
  1088.             if( mb[top].len == 0 ){
  1089.                 int prev;
  1090.                 mb[top_store].next = mb[top].next;
  1091.                 prev = top;
  1092.                 top = mb[top].next;
  1093.                 unregMemBuf( prev );
  1094.             } else {
  1095.                 top = mb[top].next;
  1096.             }
  1097.         }
  1098.     }
  1099.     
  1100.     return total;
  1101. }
  1103. static int getLineReadBuffer( int index , char *buf, int len )
  1104. {
  1106.     int top = con[index].mbtop_ri;
  1107.     int ti = 0 , breakflag = 0;
  1109.     for(;;){
  1110.         int i;        
  1111.         int l = mb[top].len;
  1112.         if( top == -1 )break;
  1113.         for( i=0 ; i < l ; i++){
  1114.             if( mb[top].buf[i] == 'n' ){
  1115.                 breakflag = 1;
  1116.                 break;
  1117.             }
  1118.             ti ++;
  1119.         }
  1120.         if( breakflag )break;
  1121.         top = mb[top].next;
  1122.     }
  1123.     if( ti > len ){
  1124.         /* 1垫互卅互允亢月［    卅巨仿□毛井尹六 */
  1125.         return TCPSTRUCT_ETOOLONG;
  1126.     }
  1127.     /* 垫互敦岳仄化卅中 */
  1128.     if( breakflag == 0 ){
  1129.         return 0;
  1130.     }
  1132.     return consumeMemBufList( con[index].mbtop_ri , buf , ti+1 , 1 , 1 );
  1133. }
  1137. /*
  1138.     心仇户月    赢今毛忒允
  1139.   int index : con index
  1141.   return:
  1142.     反巨仿□
  1143.   0动晓及桦宁反 read 仄化手方中赢今［
  1146.   mbsize 井日mbuse 毛娄中化扔奶术毛井仃月分仃［
  1147.   仇引井中芴曰及坌反  骰允月［公氏卅称井中袄卞仇分歹日卅仁化手第［
  1148.   
  1149.  */   
  1150. static int getFreeMem( void )
  1151. {
  1152.     return ( mbsize - mbuse ) * sizeof( mb[0].buf );
  1153. }
  1155. /*
  1156.   
  1157.   membuf 及坞五毛茧仄分允［
  1159.   return : 心勾井匀凶日 >=0 匹 index.
  1160.   心勾井日卅井匀凶日  
  1162.   腹绸及午五卞反 mb_finder 毛勾井丹［
  1163.   仇木匹腹绸仄化｝    卞reg允月［
  1164.  */
  1166. static int findregBlankMemBuf( void  )
  1167. {
  1168.     int i;
  1169.     for(i=0;i<mbsize;i++){
  1170.         mb_finder ++;
  1171.         if( mb_finder >= mbsize || mb_finder < 0 ) mb_finder = 0;
  1173.         if( mb[mb_finder].use == 0 ){
  1174.             mb[mb_finder].use = 1;
  1175.             mb[mb_finder].len = 0;
  1176.             mb[mb_finder].next = -1;
  1177.             mbuse ++;
  1178.             return mb_finder;
  1179.         }
  1180.     }
  1181.     return TCPSTRUCT_EMBFULL;
  1182. }
  1184. /*
  1185.   mb 毛荸  允月
  1186.   
  1187.  */
  1188. static int unregMemBuf(  int index )
  1189. {
  1190.     mb[index].use=0;
  1191.     mb[index].next = -1;
  1192.     mb[index].len = 0;
  1193.     mbuse --;
  1194.     return OK;
  1195. }
  1197. static int findregBlankCon( void )
  1198. {
  1199.     int i;
  1200. // Nuke changed 0->1
  1201. //for(i=0;i<MAXCONNECTION;i++){
  1202.     for(i=1;i<MAXCONNECTION;i++){
  1203.         if( con[i].use == 0 ){
  1204.             con[i].use = 1;
  1205.             con[i].fd = -1;
  1207.             con[i].mbtop_ri = findregBlankMemBuf();
  1208.             if( con[i].mbtop_ri < 0 ){
  1209.                 fprintf( stderr , "EMBFULLn" );
  1210.                 return TCPSTRUCT_EMBFULL;
  1211.             }
  1212.             
  1213.             con[i].mbtop_wi = findregBlankMemBuf();
  1214.             if( con[i].mbtop_wi < 0 ){
  1215.                 unregMemBuf( con[i].mbtop_ri );
  1216.                 fprintf( stderr , "EMBFULLn" );
  1217.                 return TCPSTRUCT_EMBFULL;
  1218.             }
  1219.             bzero( & con[i].remoteaddr , sizeof( struct sockaddr_in));
  1220.             con[i].closed_by_remote = 0;
  1221.             return i;
  1222.         }
  1223.     }
  1224.     return TCPSTRUCT_ECFULL;
  1225. }
  1227. int tcpstruct_countmbuse( void )
  1228. {
  1229.     int i,c=0;
  1230.     for(i=0;i<mbsize;i++){
  1231.         if( mb[i].use )c++;
  1232.     }
  1233.     return c;
  1234. }
  1236. char * getGSName( int i )
  1237. {
  1238.     return gs[i].name;
  1239. }
  1241. void checkGSUCheck( char *id )
  1242. {
  1243.     int i;
  1244.     char gname[256];
  1245.     if(!id[0]) return;
  1246. memset( gname, 0,  sizeof( gname) );
  1247. if( LockNode_getGname( (getHash(id) & 0xff), id, gname) <= 0 ){
  1248. log("无法从游戏中找到账号:%x/%s !!n", getHash( id), id);
  1249. return;
  1250. }
  1251. log("n");
  1252.     for(i=0; i < MAXCONNECTION; i++ ){
  1253.         if( gs[i].name[0] && strcmp( gs[i].name , gname )==0){
  1254.           log("发送解锁检查[%s] 到 %d.%x/%s 服务器:%d !!n", id, i, getHash( id), gname, gs[i].fd);
  1255. saacproto_ACUCheck_send( gs[i].fd , id );
  1256. return;
  1257.         }
  1258.     }
  1259. // log("Can't find gname:%s sending err !!n", gname);
  1261. int ret = -1;
  1262. if( !isLocked( id) ) {
  1263. log( "删除内存信息: 用户:%x/%s 没有锁定!!n", getHash(id), id);
  1264. }
  1265. if( DeleteMemLock( getHash(id) & 0xff, id, &ret) ) {
  1267. } else {
  1268. log( "不能解锁 %x:%s !n", getHash(id), id);
  1269. }
  1270. }
  1272. void set_nodelay( int sock )
  1273. {
  1274.     int flag = 1;
  1275.     int result = setsockopt( sock, IPPROTO_TCP, TCP_NODELAY,
  1276.                              (char*)&flag, sizeof(int));
  1277.     if( result < 0 ){
  1278.         log( "不能设置延迟.n" );
  1279.     } else {
  1280.         log( "设置延迟: fd:%dn", sock );
  1281.     }
  1282. }
  1285. /*
  1286.   允屯化及必□丞扔□田□卞  霜［
  1288.   int flag : 1分匀凶日霜耨葭卞反云仁日卅中
  1289.   
  1290.  */
  1291. void gmsvBroadcast( int fd, char *p1, char *p2, char *p3 , int flag )
  1292. {
  1293.     int i,c=0;
  1294.     
  1295.     for(i=0;i<MAXCONNECTION;i++){
  1296.         if( ( flag == 1 ) && ( i == fd ) )continue;
  1297.         if( gs[i].use && gs[i].name[0] ){
  1298.             saacproto_Broadcast_send( i, p1,p2,p3);
  1299.             c++;
  1300.         }
  1301.     }
  1302. /*
  1303. #if 1
  1304.     {
  1305.         char fn[1000];
  1306.         FILE *fp;
  1307.         snprintf( fn, sizeof(fn), "%s/broadcast.log" , logdir );
  1308.         fp = fopen( fn,"a" );
  1309.         if(fp){
  1310.             fprintf( fp, "From %s(%d) Id:[%s] Char:[%s] Mesg:[%s]n",
  1311.                      gs[fd].name, fd, p1,p2,p3 );
  1312.             fclose(fp);
  1313.         }
  1314.     }
  1315. #endif
  1316. */
  1317. }
  1319. #ifdef _ANGEL_SUMMON
  1321. #define MISSIONFILE "db/missiontable.txt"
  1323. static int initMissionTable( void )
  1324. {
  1325. FILE *fp;
  1326. char onedata[1024];
  1327. char buf[1024];
  1328. int index =0;
  1330. memset( missiontable, 0, sizeof(missiontable));
  1331. fp = fopen( MISSIONFILE, "r");
  1332. if( !fp ) {
  1333. log("n加载精灵召唤错误!!!! n");
  1334. //return false;
  1335. }
  1336. log("n加载精灵召唤...");
  1337. while(1) {
  1338. //
  1339. if( fgets( onedata, sizeof(onedata), fp) == NULL)
  1340. break;
  1341. if( onedata[0] == '' || onedata[0] == '#' )
  1342. continue;
  1343. //easyGetTokenFromBuf( onedata, ",", 1, buf, sizeof( buf));
  1344. //index = atoi( buf);
  1345. easyGetTokenFromBuf( onedata, ",", 1, buf, sizeof( buf));
  1346. if( buf[0] == '' ) continue;
  1347. strcpy( missiontable[index].angelinfo, buf);
  1348. easyGetTokenFromBuf( onedata, ",", 2, buf, sizeof( buf));
  1349. if( buf[0] == '' ) continue;
  1350. strcpy( missiontable[index].heroinfo, buf);
  1351. easyGetTokenFromBuf( onedata, ",", 3, buf, sizeof( buf));
  1352. if( buf[0] == '' ) continue;
  1353. missiontable[index].mission = atoi( buf);
  1354. easyGetTokenFromBuf( onedata, ",", 4, buf, sizeof( buf));
  1355. if( buf[0] == '' ) continue;
  1356. missiontable[index].flag = atoi( buf);
  1357. easyGetTokenFromBuf( onedata, ",", 5, buf, sizeof( buf));
  1358. if( buf[0] == '' ) continue;
  1359. missiontable[index].time = atoi( buf);
  1360. easyGetTokenFromBuf( onedata, ",", 6, buf, sizeof( buf));
  1361. if( buf[0] == '' ) continue;
  1362. missiontable[index].limittime = atoi( buf);
  1364. log("%d=%s,%s,%d,%d,%d,%d n", index,
  1365. missiontable[index].angelinfo,
  1366. missiontable[index].heroinfo,
  1367. missiontable[index].mission,
  1368. missiontable[index].flag,
  1369. missiontable[index].time,
  1370. missiontable[index].limittime );
  1372. index++;
  1373. if( index >= MAXMISSIONTABLE) break;
  1374. }
  1375. fclose( fp);
  1376. log("..成功! n");
  1377. //return true;
  1378. }
  1381. int saveMissionTable( void )
  1382. {
  1383. FILE *fp;
  1384. char onedata[1024];
  1385. char buf[1024];
  1386. int index =0;
  1388. fp = fopen( MISSIONFILE, "w");
  1389. if( !fp ) {
  1390. log("n打开精灵召唤错误!!!! n");
  1391. //return false;
  1392. }
  1393. log("n保存精灵召唤...");
  1394. for( index =0; index < MAXMISSIONTABLE; index++) {
  1396. if( missiontable[index].angelinfo[0] == '' )
  1397. continue;
  1398. sprintf( onedata, "%s,%s,%d,%d,%d,%dn",
  1399. missiontable[index].angelinfo,
  1400. missiontable[index].heroinfo,
  1401. missiontable[index].mission,
  1402. missiontable[index].flag,
  1403. missiontable[index].time,
  1404. missiontable[index].limittime );
  1405. fputs( onedata, fp);
  1406. }
  1407. fclose( fp);
  1408. log("..成功! n");
  1409. //return true;
  1410. }
  1412. void delMissionTableOnedata( int index)
  1413. {
  1414. int gi;
  1416. log("n删除精灵召唤:%d:%s:%s n", index, missiontable[index].angelinfo, missiontable[index].heroinfo);
  1418. if( index <0 || index >=MAXMISSIONTABLE) return;
  1419. strcpy( missiontable[index].angelinfo, "");
  1420. strcpy( missiontable[index].heroinfo, "");
  1421. missiontable[index].mission = 0;
  1422. missiontable[index].flag = MISSION_NONE;
  1423. missiontable[index].time = 0;
  1424. missiontable[index].limittime = 0;
  1426. for( gi=0; gi<MAXCONNECTION; gi++) {
  1427. if (gs[gi].use && gs[gi].name[0]) {
  1428. saacproto_ACMissionTable_send( gi, index, 3, "", "");
  1429. }
  1430. }
  1431. }
  1433. #define ANSWERTIME 1 // 等待回答时间(小时)
  1434. //#define DOINGTIME 3*24 // 任务时间(小时)
  1435. #define BOUNDSTIME 1*24 // 保留时间(小时)
  1437. void checkMissionTimelimit( void)
  1438. {
  1439. int index;
  1440. static time_t lastcheck =0;
  1442. if( sys_time < lastcheck + 5*60 )
  1443. return;
  1445. log("n检查精灵召唤时间限制:%d n", sys_time);
  1446. for( index =0; index < MAXMISSIONTABLE; index++) {
  1447. if( missiontable[index].flag == MISSION_NONE) {
  1448. continue;
  1449. }
  1450. // 等待使者回应1小时
  1451. else if( missiontable[index].flag == MISSION_WAIT_ANSWER
  1452. && sys_time > missiontable[index].time + ANSWERTIME*60*60 ) {
  1454. delMissionTableOnedata( index);// 删
  1455. }
  1456. // 等待领奖完成 limittime小时
  1457. else if( ( missiontable[index].flag == MISSION_DOING || missiontable[index].flag == MISSION_HERO_COMPLETE )
  1458. && ( sys_time > (missiontable[index].time + missiontable[index].limittime*60*60))  ) {
  1460. char buf[1024];
  1461. int gi;
  1462. // 改TIMEOVER
  1463. log("精灵召唤及领奖时间过:%d ", index);
  1464. missiontable[index].flag = MISSION_TIMEOVER;
  1465. missiontable[index].time = time(NULL);
  1466. missiontable[index].limittime = BOUNDSTIME;
  1468. sprintf( buf, "%d|%s|%s|%d|%d|%d|%d ", index,
  1469. missiontable[index].angelinfo,
  1470. missiontable[index].heroinfo,
  1471. missiontable[index].mission,
  1472. missiontable[index].flag,
  1473. missiontable[index].time,
  1474. missiontable[index].limittime );
  1475. for( gi=0; gi<MAXCONNECTION; gi++) {
  1476. if (gs[gi].use && gs[gi].name[0]) {
  1477. saacproto_ACMissionTable_send( gi, 1, 1, buf, "");
  1478. }
  1479. }
  1481. continue;
  1482. }
  1483. //else if( missiontable[index].flag == MISSION_HERO_COMPLETE
  1484. // && sys_time > missiontable[index].time + BOUNDSTIME*60*60 ) {
  1485. // log(" 领奖时间过:%d ", index);
  1486. // delMissionTableOnedata( index);// 删
  1487. //}
  1489. // 资料保留时间(BOUNDSTIME小时)
  1490. else if( missiontable[index].flag == MISSION_TIMEOVER
  1491. && sys_time > missiontable[index].time + BOUNDSTIME*60*60 ) {
  1492. log(" 保留时间过:%d ", index);
  1493. delMissionTableOnedata( index);// 删
  1494. }
  1496. }
  1497. saveMissionTable();
  1499. lastcheck = sys_time;
  1500. }
  1502. #endif