think库 (跨平台C语言库)

#include "routeserver.h" int main(int argc,char *argv[]) { char usage[]="usage: routeserver [-p cfgpath] [-c cfgfile] [-d cfgdomain]"; int lsnport; char lsnip[16],str[6]; THINK_NET *net; THINK_CFG *cfg; int r_net,r_timer; THINK_OPTARRAY optarray[3]={ {'p',cfgpath,sizeof(cfgpath),THINK_OPT_ARG,NULL}, {'c',cfgfile,sizeof(cfgfile),THINK_OPT_ARG|THINK_OPT_NOT_EMPTY,NULL}, {'d',cfgdomain,sizeof(cfgdomain),THINK_OPT_ARG,NULL} }; THINK_CFGARRAY cfgarray[8]={ {cfgdomain,"logname",log_name,sizeof(log_name),0,NULL}, {cfgdomain,"logflags",log_flags,sizeof(log_flags),0,NULL}, {cfgdomain,"logaddr",log_addr,sizeof(log_addr),0,NULL}, {cfgdomain,"routeid",&route_id,sizeof(route_id),THINK_CFG_INT|THINK_CFG_NOT_EMPTY,NULL}, {cfgdomain,"nextroutes",next_routes,sizeof(next_routes),0,NULL}, {cfgdomain,"alivetime",&alive_time,sizeof(alive_time),THINK_CFG_INT|THINK_CFG_NOT_EMPTY,NULL}, {cfgdomain,"lsnaddr",lsn_addr,sizeof(lsn_addr),THINK_CFG_NOT_EMPTY,NULL}, {cfgdomain,"lsnaddr_ctrl",lsn_addr_ctrl,sizeof(lsn_addr_ctrl),THINK_CFG_NOT_EMPTY,NULL} }; /* signal set */ signal(SIGPIPE,SIG_IGN); /* get options from command line */ if(think_getopts(argc,argv,optarray,3)<0){ think_showerror(); return -1; } /* get cfgs from cfg file */ if((cfg=think_loadcfg(cfgfile,cfgpath))==NULL){ think_showerror(); return -1; } if(think_getcfgs(cfg,cfgarray,8)<0){ think_showerror(); return -1; } think_freecfg(cfg); /* init next router list */ initrouterlist(next_routes); /* net start */ think_netstart(); /* netcenter */ netcenter=think_netcenter_new(); /* listening ctrl port ... */ think_strgetfield(lsn_addr_ctrl,':',0,lsnip,sizeof(lsnip)); think_strgetfield(lsn_addr_ctrl,':',1,str,sizeof(str)); lsnport=atol(str); if((net=think_netlisten(lsnip,lsnport))==NULL){ think_showerror(); return -1; } think_netcenter_netadd(netcenter,net,acceptnewclient_ctrl); lsnnet_ctrl=net; /* lsnnet_ctrl */ /* listening normal port ... */ think_strgetfield(lsn_addr,':',0,lsnip,sizeof(lsnip)); think_strgetfield(lsn_addr,':',1,str,sizeof(str)); lsnport=atol(str); if((net=think_netlisten(lsnip,lsnport))==NULL){ think_showerror(); return -1; } think_netcenter_netadd(netcenter,net,acceptnewclient); lsnnet=net; /* lsnnet */ /* open log */ if((lp=think_logopen(log_addr,log_name,think_loggetflags(log_flags)))==NULL){ think_showerror(); return -1; } /* idle */ think_logsend(lp,THINK_LOG_PRINT,"system","working ..."); while(1){ think_logsend(lp,0,"system","netcenter idle ..."); if((r_net=think_netcenter_idle(netcenter,-1))<0){ think_logsend(lp,THINK_LOG_ERROR|THINK_LOG_PRINT,"network","%s",__think_errmsg__); think_showerror(); break; } think_logsend(lp,0,"system","timerlist idle ..."); r_timer=think_timerlist_idle(&timerlist); if(r_net==0 && r_timer==0) think_sleep(10); } /* net stop */ think_netstop(); return 0; } void acceptnewclient(THINK_NETCENTER_NET *net,int event) { THINK_NET *client; switch(event){ case THINK_NETCENTER_ACCEPT: if((client=think_netaccept(net->net))==NULL){ think_logsend(lp,THINK_LOG_WARN|THINK_LOG_PRINT,"network","%s",__think_errmsg__); return; } think_logsend(lp,THINK_LOG_INFO|THINK_LOG_PRINT,"network","connected by %s:%d",client->ip,client->port); cliunitadd(client); break; case THINK_NETCENTER_ERROR: think_logsend(lp,THINK_LOG_WARN|THINK_LOG_PRINT,"network","net error on connect [%s:%d]",net->net->ip,net->net->port); break; default: break; } } void clientnethandle(THINK_NETCENTER_NET *net,int event) { char msgbuf[1024]; int msglen; int r; switch(event){ case THINK_NETCENTER_DATARECVED: /* check msg */ while(1){ if((r=think_netcenter_ismsgok(net))<0){ think_logsend(lp,THINK_LOG_WARN|THINK_LOG_PRINT,"network","%s",__think_errmsg__); cliunitdel(net); return; } if(r==0) break; /* recv msg */ if((msglen=think_netcenter_recvmsg(net,msgbuf,sizeof(msgbuf)))<0){ think_logsend(lp,THINK_LOG_WARN|THINK_LOG_PRINT,"network","%s",__think_errmsg__); cliunitdel(net); return; } /* process msg */ if(clientmsgprocess(net,msgbuf,msglen)<0){ think_logsend(lp,THINK_LOG_ERROR|THINK_LOG_PRINT,"network","%s",__think_errmsg__); cliunitdel(net); think_netcenter_netdel(netcenter,net->net); return; } } break; case THINK_NETCENTER_DISCONNECTED: think_logsend(lp,THINK_LOG_WARN|THINK_LOG_PRINT,"network","net disconnected [%s:%d]",net->net->ip,net->net->port); cliunitdel(net); break; case THINK_NETCENTER_ERROR: think_logsend(lp,THINK_LOG_WARN|THINK_LOG_PRINT,"network","net error on connect [%s:%d]",net->net->ip,net->net->port); cliunitdel(net); break; default: break; } } int clientmsgprocess(THINK_NETCENTER_NET *net,char *msgbuf,int msglen) { char msgtype[3]; bzero(msgtype,sizeof(msgtype)); if(think_gl_get(msgbuf,msglen,1,'C',2,msgtype,sizeof(msgtype))<0) return -1; if(strcmp(msgtype,"00")==0){ if(client_test(net,msgbuf,msglen)<0) return -1; }else if(strcmp(msgtype,"10")==0){ if(client_login(net,msgbuf,msglen)<0) return -1; }else if(strcmp(msgtype,"12")==0){ if(client_logout(net,msgbuf,msglen)<0) return -1; }else if(strcmp(msgtype,"20")==0){ if(client_msgroute(net,msgbuf,msglen)<0) return -1; }else if(strcmp(msgtype,"30")==0){ if(client_routenotice(net,msgbuf,msglen)<0) return -1; }else if(strcmp(msgtype,"40")==0){ if(client_ping(net,msgbuf,msglen)<0) return -1; }else{ think_error(0,"[%s]:unsupported msgtype[%s]",__func__,msgtype); return -1; } return 0; } void acceptnewclient_ctrl(THINK_NETCENTER_NET *net,int event) { THINK_NET *client; switch(event){ case THINK_NETCENTER_ACCEPT: if((client=think_netaccept(net->net))==NULL){ think_logsend(lp,THINK_LOG_WARN|THINK_LOG_PRINT,"network","%s",__think_errmsg__); return; } think_logsend(lp,THINK_LOG_INFO|THINK_LOG_PRINT,"network","connected by %s:%d",client->ip,client->port); cliunitadd_ctrl(client); break; case THINK_NETCENTER_ERROR: think_logsend(lp,THINK_LOG_WARN|THINK_LOG_PRINT,"network","net error on connect [%s:%d]",net->net->ip,net->net->port); break; default: break; } } void clientnethandle_ctrl(THINK_NETCENTER_NET *net,int event) { char msgbuf[1024]; int msglen; int r; switch(event){ case THINK_NETCENTER_DATARECVED: /* check msg */ while(1){ if((r=think_netcenter_ismsgok(net))<0){ think_logsend(lp,THINK_LOG_WARN|THINK_LOG_PRINT,"network","%s",__think_errmsg__); cliunitdel_ctrl(net); return; } if(r==0) break; /* recv msg */ if((msglen=think_netcenter_recvmsg(net,msgbuf,sizeof(msgbuf)))<0){ think_logsend(lp,THINK_LOG_WARN|THINK_LOG_PRINT,"network","%s",__think_errmsg__); cliunitdel_ctrl(net); return; } /* process msg */ if(clientmsgprocess_ctrl(net,msgbuf,msglen)<0){ think_logsend(lp,THINK_LOG_ERROR|THINK_LOG_PRINT,"network","%s",__think_errmsg__); cliunitdel_ctrl(net); think_netcenter_netdel(netcenter,net->net); return; } } break; case THINK_NETCENTER_DISCONNECTED: think_logsend(lp,THINK_LOG_WARN|THINK_LOG_PRINT,"network","net disconnected [%s:%d]",net->net->ip,net->net->port); cliunitdel_ctrl(net); break; case THINK_NETCENTER_ERROR: think_logsend(lp,THINK_LOG_WARN|THINK_LOG_PRINT,"network","net error on connect [%s:%d]",net->net->ip,net->net->port); cliunitdel_ctrl(net); break; default: break; } } int clientmsgprocess_ctrl(THINK_NETCENTER_NET *net,char *msgbuf,int msglen) { char msgtype[3]; bzero(msgtype,sizeof(msgtype)); if(think_gl_get(msgbuf,msglen,1,'C',2,msgtype,sizeof(msgtype))<0) return -1; if(strcmp(msgtype,"10")==0){ if(_logopen(net,msgbuf,msglen)<0) return -1; }else if(strcmp(msgtype,"20")==0){ if(_logsend(net,msgbuf,msglen)<0) return -1; }else if(strcmp(msgtype,"30")==0 || strcmp(msgtype,"40")==0){ if(_logview(net,