Chinaunix首页 | 论坛 | 博客

ARM+Linux挖掘机hclenblog.blog.chinaunix.net

首页　| 　博文目录　| 　关于我

hclen90615

  • 博客访问： 130043
  • 博文数量： 30
  • 博客积分： 972
  • 博客等级： 中士
  • 技术积分： 332
  • 用 户 组： 普通用户
  • 注册时间： 2012-02-08 10:04
文章分类

全部博文（30）

文章存档

2012年（30）

我的朋友
最近访客
推荐博文
相关博文
IPMSG飞鸽传书

分类： LINUX

2012-07-19 19:54:43


点击(此处)折叠或打开

  1. #include<stdio.h>
  2. #include<stdlib.h>
  3. #include<arpa/inet.h>
  4. #include<sys/types.h>
  5. #include<sys/socket.h>
  6. #include<netinet/in.h>
  7. #include<unistd.h>
  8. #include<pthread.h>
  9. #include<string.h>
  10. #include"IPMSG.h"
  11. #include"all.h"

  13. typedef void (*FUN)(int argc,char *argv[]);

  15. typedef struct cmd{
  16.                     char *name;
  17.                     FUN fun;
  18.                  }CMD;
  19.                 
  20. char user[30]="";
  21. char machine[30]="";
  22. int num=1;
  23. char blacklist[30]="";
  24. char group[10][30];

  26. IPMSG_USER *head_t;
  27. IPMSG_FILE *head_file=NULL,*head_send=NULL;

  29. CMD cmdlist[]={
  30.                 {"sendfile",sendfile},
  31.                 {"creatgroup",creatgroup},
  32.                 {"sendgroup",sendgroup},
  33.                 {"send",Sendto},
  34.                 {"cls",cls_fun},
  35.                 {"ls",ls_fun},
  36.                 {"help",help_fun},
  37.                 {"filels",filels_fun},
  38.                 {"getfile",getfile},
  39.                 {"setlist",setlist}
  40.              };

  42. int msg_deal(char *msg_src,char *stk, char *msg_done[])
  43. {
  44.     int i=0;
  45.     char *f_src,*f_stk;
  46.     f_src=msg_src;
  47.     f_stk=stk;
  48.     msg_done[i]=strtok(f_src,f_stk);
  49.     while(msg_done[i]!=NULL)
  50.         msg_done[++i]=strtok(NULL,f_stk);
  51.     
  52.     return i-1;
  53. }

  55. void get_info(void)
  56. {
  57.     printf("Pls input your name:");
  58.     fflush(stdout);
  59.     scanf("%s",user);
  60.     gethostname(machine,sizeof(machine));
  61. }

  63. int broadcast_online(int fd,char flags)
  64. {
  65.     char bro_packet[50]="";
  66.     int bro_len=0;
  67.     unsigned short port =2425;
  68.     char bro_ip[16]="192.168.1.255";
  69.     struct sockaddr_in bro_addr;
  70.     bzero(&bro_addr,sizeof(bro_addr));
  71.     
  72.     bro_addr.sin_family = AF_INET;
  73.     bro_addr.sin_port = htons(port);
  74.     inet_pton(AF_INET,bro_ip,&bro_addr.sin_addr);
  75.     
  76.     bro_len = sprintf(bro_packet,"%c:%ld:%s:%s:%c:%s",'1',(long int)time(NULL),user,machine,flags,"hello");
  77.     sendto(fd,bro_packet,bro_len,0,(struct sockaddr*)&bro_addr,sizeof(bro_addr));
  78.     
  79.     return 1;
  80. }

  82. void ls_fun(int argc, char *argv[])
  83. {
  84.     print_list(head_t);
  85. }

  87. void filels_fun(int argc, char *argv[])
  88. {
  89.     if(argv[1] == NULL)
  90.     {
  91.         printf("command is wrong\n");
  92.         return;
  93.     }
  94.     if(!strncmp(argv[1],"recv",4))
  95.     print_filelist(head_file);
  96.     if(!strncmp(argv[1],"send",4))
  97.     print_filelist(head_send);
  98. }

  100. void cls_fun(int argc, char *argv[])
  101. {
  102.     system("clear");
  103.     printf("\rIPMSG:");
  104.     fflush(stdout);
  105. }

  107. void setlist(int argc, char *argv[])
  108. {
  109.     if((argv[1] == NULL) || (!search_list(head_t,argv[1])))
  110.     {
  111.         printf("Pls check the username\n");
  112.         return;
  113.     }
  114.     strcpy(blacklist,argv[1]);
  115.     printf("\rIPMSG:");
  116.     fflush(stdout);
  117. }

  119. void help_fun(int argc, char *argv[])        //帮助
  120. {
  121.     char *cmd= "*****************************************************************************************\n"\
  122.             "* help                 :帮助                            *\n"\
  123.             "* ls/filels             :显示在线人/list                    *\n"\
  124.             "* send [username]         :发送消息                        *\n"\
  125.             "* cls                 :清屏                            *\n"\
  126.             "* exit                 :退出                            *\n"\
  127.             "* setlist [username]        :设置黑名单                        *\n"\
  128.             "* creatgroup/sendgroup         :创建组/发送组消息                    *\n"\
  129.             "*****************************************************************************************\n"
  130.             ;
  131.     printf("%s\n",cmd);
  132. }

  134. void Sendto(int argc, char *argv[])
  135. {
  136.     int snd_len=0;
  137.     char ip[16]="";
  138.     char snd_packet[50]="",buf[50]="";
  139.     unsigned short port =2425;
  140.     struct sockaddr_in snd_addr;
  141.     bzero(&snd_addr,sizeof(snd_addr));
  142.     
  143.     if((argv[1] == NULL) || (!search_list(head_t,argv[1])))
  144.     {
  145.         printf("command is wrong\n");
  146.         return;
  147.     }
  148.     
  149.     strcpy(ip,search_list(head_t,argv[1]));
  150.     snd_addr.sin_family = AF_INET;
  151.     snd_addr.sin_port = htons(port);
  152.     inet_pton(AF_INET,ip,&snd_addr.sin_addr);
  153.     
  154.     printf("Pls input sending message:");
  155.     fflush(stdout);
  156.     fgets(buf,sizeof(buf),stdin);
  157.     buf[strlen(buf)-1]='\0';
  158.     
  159.     snd_len = sprintf(snd_packet,"%c:%ld:%s:%s:%d:%s",'1',(long int)time(NULL),user,machine,288,buf);
  160.     sendto(argc,snd_packet,snd_len,0,(struct sockaddr*)&snd_addr,sizeof(snd_addr));
  161.     
  162. }

  164. void sndgroupmsg(int argc,char *buf,int i)
  165. {
  166.     int snd_len=0;
  167.     char ip[16]="";
  168.     char snd_packet[50]="";
  169.     unsigned short port =2425;
  170.     struct sockaddr_in snd_addr;
  171.     bzero(&snd_addr,sizeof(snd_addr));
  172.     if((group[i] == NULL) || (!search_list(head_t,group[i])))
  173.         return;
  174.     strcpy(ip,search_list(head_t,group[i]));
  175.     snd_addr.sin_family = AF_INET;
  176.     snd_addr.sin_port = htons(port);
  177.     inet_pton(AF_INET,ip,&snd_addr.sin_addr);
  178.     // printf("Pls input sending message:");
  179.     // fflush(stdout);
  180.     // fgets(buf,sizeof(buf),stdin);
  181.     // buf[strlen(buf)-1]='\0';
  182.     snd_len = sprintf(snd_packet,"%c:%ld:%s:%s:%d:%s",'1',(long int)time(NULL),user,machine,288,buf);
  183.     sendto(argc,snd_packet,snd_len,0,(struct sockaddr*)&snd_addr,sizeof(snd_addr));
  184.     return;
  185. }

  187. void sendgroup(int argc, char *argv[])
  188. {
  189.     int i=0;
  190.     char buf[50]="";
  191.     
  192.     printf("Pls input sending message:");
  193.     fflush(stdout);
  194.     fgets(buf,sizeof(buf),stdin);
  195.     buf[strlen(buf)-1]='\0';
  196.     for(i=0;i<10;i++)
  197.         sndgroupmsg(argc,buf,i);
  198.     return;
  199. }

  201. void creatgroup(int argc, char *argv[])
  202. {
  203.     int n=0,i=0;
  204.     char buf[30]="";
  205.     
  206.     printf("Pls input group member number:");
  207.     fflush(stdout);
  208.     scanf("%d",&n);
  209.     bzero(group,sizeof(group));
  210.     
  211.     for(i=0;i<n;i++)
  212.     {
  213.         printf("Pls input group member %d:\n",i);
  214.         scanf("%s",buf);
  215.         strncpy(group[i],buf,strlen(buf));
  216.     }
  217.     return;
  218. }

  220. int recvfile(char *filename, struct sockaddr_in recv_addr,int packetno,int fileno)
  221. {
  222.     int recv_fd=0,file_fd=0,len=0;
  223.     char buf[500]="",recv_packet[50]="";

  225.     if((recv_fd = socket(AF_INET,SOCK_STREAM,0)) < 0)
  226.     {
  227.         perror("Tcp socket");
  228.         return 0;
  229.     }
  230.     if((file_fd = open(filename,O_WRONLY|O_CREAT,0666)) < 0)
  231.     {
  232.         perror("open");
  233.         close(recv_fd);
  234.         return 0;
  235.     }
  236.     // file_fd = open(filename,O_RDWR|O_CREAT,0777);
  237.     connect(recv_fd,(struct sockaddr*)&recv_addr,sizeof(recv_addr));
  238.     
  239.     len = sprintf(recv_packet,"%c:%ld:%s:%s:%d:%x:%x:%x",'1',(long int)time(NULL),user,machine,96,packetno,fileno,0);
  240.     sendto(recv_fd,recv_packet,len,0,(struct sockaddr*)&recv_addr,sizeof(recv_addr));
  241.     
  242.     do
  243.     {    
  244.         len=read(recv_fd,buf,sizeof(buf));
  245.         write(file_fd,buf,len);
  246.     }while(len == sizeof(buf));
  247.     
  248.     close(file_fd);
  249.     close(recv_fd);
  250.     return 1;
  251. }

  253. void *handler(void *conn_fd)
  254. {
  255.     int len=0,fd=(int)conn_fd,file_fd=0;
  256.     char buf[500]="",store[100]="";
  257.     long count=0,packetno=0;
  258.     int command=0;
  259.     char *done[10];
  260.     IPMSG_FILE *temp;
  261.     
  262.     recv(fd,store,sizeof(store),0);
  263.     msg_deal(store,":",done);
  264.     command = atoi(done[4]);
  265.     
  266.     if( GET_MODE(command) == 96)
  267.     {
  268.     sscanf(done[5],"%lx",&packetno);
  269.     temp = search(head_send,packetno);
  270.     file_fd = open(temp->name,O_RDWR);
  271.     do
  272.     {
  273.         len = read(file_fd,buf,sizeof(buf));
  274.         count +=len;
  275.         write(fd,buf,len);
  276.         
  277.     }while(count < temp->size);
  278.     del_filelist(head_send,temp->name);
  279.     printf("\rFile tranfer compeleted\n");
  280.     printf("\rIPMSG:");
  281.     fflush(stdout);
  282.     close(file_fd);
  283.     }
  284.     close(fd);
  285.     return NULL;
  286. }

  288. void *send_file(void *a)
  289. {
  290.     int send_fd=0,conn_fd=0;
  291.     pthread_t tid_send;
  292.     struct sockaddr_in send_addr;
  293.     bzero(&send_addr,sizeof(send_addr));
  294.     
  295.     send_addr.sin_family = AF_INET;
  296.     send_addr.sin_port = htons(2425);
  297.     send_addr.sin_addr.s_addr = htonl(INADDR_ANY);

  299.     if((send_fd = socket(AF_INET,SOCK_STREAM,0)) < 0)
  300.     {
  301.         perror("Tcp socket");
  302.         return 0;
  303.     }
  304.     
  305.     if(bind(send_fd,(struct sockaddr*)&send_addr,sizeof(send_addr)) < 0)
  306.     {
  307.         perror("bind");
  308.         return NULL;
  309.     }
  310.     
  311.     listen(send_fd,10);
  312.     
  313.     while(1)
  314.     {
  315.         conn_fd = accept(send_fd,NULL,NULL);
  316.         
  317.         if(conn_fd < 0){
  318.             perror("accept error\n");
  319.             continue;
  320.         }
  321.         pthread_create(&tid_send,NULL,handler,(void *)conn_fd);
  322.         pthread_detach(tid_send);
  323.     }
  324.     close(send_fd);
  325.     return NULL;
  326. }

  328. void getfile(int argc, char *argv[])
  329. {
  330.     IPMSG_FILE *temp=NULL;
  331.     unsigned short port = 2425;
  332.     struct sockaddr_in recv_addr;
  333.     recv_addr.sin_family = AF_INET;
  334.     recv_addr.sin_port = htons(port);
  335.     if((argv[1] == NULL))
  336.     {
  337.         printf("command is wrong\n");
  338.         return;
  339.     }
  340.     temp = search_filelist(head_file,argv[1]);
  341.     inet_pton(AF_INET,search_list(head_t,temp->user),&recv_addr.sin_addr);
  342.     recvfile(argv[1],recv_addr,temp->pkgnum,temp->num);
  343.     del_filelist(head_file,argv[1]);
  344. }

  346. void sendfile(int argc, char *argv[])
  347. {
  348.     struct stat buf;
  349.     int len=0,size=0;
  350.     char send_packet[50]="";
  351.     long packetno=(long int)time(NULL);
  352.     int ctime;
  353.     unsigned short port = 2425;
  354.     struct sockaddr_in send_addr;
  355.     bzero(&send_addr,sizeof(send_addr));
  356.     
  357.     if((argv[1] == NULL) || (argv[1] == NULL))
  358.     {
  359.         printf("command is wrong\n");
  360.         return;
  361.     }
  362.     
  363.     if(stat(argv[2],&buf) < 0)
  364.     {
  365.         printf("The file is not here\n");
  366.         return;
  367.     }
  368.     send_addr.sin_family = AF_INET;
  369.     send_addr.sin_port = htons(port);
  370.     inet_pton(AF_INET,search_list(head_t,argv[1]),&send_addr.sin_addr);
  371.     //stat(argv[2],&buf);
  372.     size = buf.st_size;
  373.     ctime = (int)buf.st_ctime;
  374.         
  375.     len = sprintf(send_packet,"%c:%ld:%s:%s:%d:%c%d:%s:%x:%x:%x",'1',packetno,user,machine,2097440,0,num,argv[2],size,ctime,1);
  376.     sendto(argc,send_packet,len,0,(struct sockaddr*)&send_addr,sizeof(send_addr));
  377.     num++;
  378.     head_send = add_filelist(head_send,argv[2],num,packetno,size,ctime,1,argv[1]);
  379. }


  382. void *get_handler(void *arg)
  383. {
  384.     int fd=(int)arg,i;
  385.     int command=0,first=0;
  386.     unsigned short port = 2425;
  387.     char buf[500]="",opp_ip[16]="",ack_packet[50]="",buf2[500]="";
  388.     char *msg[20],*msg2[20],p=':',*p_f;
  389.     struct sockaddr_in opp_addr;
  390.     socklen_t ack_len=0,opp_len = sizeof(opp_addr);
  391.     
  392.     bzero(&opp_addr,sizeof(opp_addr));
  393.     
  394.     opp_addr.sin_family = AF_INET;
  395.     opp_addr.sin_port = htons(port);
  396.     
  397.     while(1)
  398.     {
  399.         recvfrom(fd,buf,sizeof(buf),0,(struct sockaddr*)&opp_addr,&opp_len);
  400.         strcpy(buf2,buf);
  401.         buf[strlen(buf)]='1';
  402.         //printf("buf==%s\n",buf);
  403.         msg_deal(buf2,&p,msg);
  404.         msg_deal(buf,&p,msg2);
  405.         command = atoi(msg[4]);
  406.         inet_ntop(AF_INET,&opp_addr.sin_addr,opp_ip,sizeof(opp_ip));
  407.         
  408.         if(!strcmp(msg[2],blacklist))
  409.             continue;
  410.         
  411.         if( GET_MODE(command) == 3 || GET_MODE(command) == 1)
  412.         {
  413.             if(!search_list(head_t,msg[2]))
  414.             add_list(head_t,msg[2],msg[3],opp_ip);
  415.             
  416.             if( GET_MODE(command) == 1 )
  417.             {
  418.                 broadcast_online(fd,'3');
  419.                 // printf("\r%s is online\n",msg[2]);
  420.                 // printf("\rIPMSG:");
  421.                 // fflush(stdout);
  422.             }
  423.             
  424.         }
  425.         if( GET_MODE(command) == 2 )
  426.         {
  427.             // printf("\r%s is offline\n",msg[2]);
  428.             // printf("\rIPMSG:");
  429.             // fflush(stdout);
  430.             del_list(head_t,msg[2]);
  431.         }
  432.         if( GET_MODE(command) == 32 )
  433.         {
  434.             if( GET_OPT(command) != 2097408)
  435.             {
  436.                 p_f = msg[5];
  437.                 p_f[strlen(msg[5])] = '\0';
  438.                 printf("\r[%s:%s]:%s\n",opp_ip,msg[2],msg[5]);
  439.                 ack_len = sprintf(ack_packet,"%c:%ld:%s:%s:%d:%s",'1',(long int)time(NULL),user,machine,33,msg[1]);
  440.                 sendto(fd,ack_packet,ack_len,0,(struct sockaddr*)&opp_addr,sizeof(opp_addr));
  441.                 printf("\rIPMSG:");
  442.                 fflush(stdout);
  443.             }
  444.             if( GET_OPT(command) == 2097408)
  445.             {
  446.                 if(first == 0)
  447.                 {
  448.                     printf("\rRecv a file packet:%s\n",msg2[6]);
  449.                     p_f = (char *)msg2[5];
  450.                     head_file=add_filelist(head_file,msg2[6],atoi(p_f+1),atol(msg2[1]),atol(msg2[7]),atol(msg2[8]),atoi(msg2[9]),msg2[2]);
  451.                     ack_len = sprintf(ack_packet,"%c:%ld:%s:%s:%d:%s",'1',(long int)time(NULL),user,machine,33,msg2[1]);
  452.                     for(i=0;i<5;i++)
  453.                     sendto(fd,ack_packet,ack_len,0,(struct sockaddr*)&opp_addr,sizeof(opp_addr));
  454.                     first = 1;
  455.                     printf("\rIPMSG:");
  456.                     fflush(stdout);
  457.                 }
  458.                  if((first == 1) && (!search_filelist(head_file,msg2[6])))
  459.                 {
  460.                     printf("\rRecv a file packet:%s\n",msg2[6]);
  461.                     p_f = (char *)msg2[5];
  462.                     add_filelist(head_file,msg2[6],atoi(p_f+1),atol(msg2[1]),atol(msg2[7]),atol(msg2[8]),atoi(msg2[9]),msg2[2]);
  463.                     ack_len = sprintf(ack_packet,"%c:%ld:%s:%s:%d:%s",'1',(long int)time(NULL),user,machine,33,msg2[1]);
  464.                     for(i=0;i<5;i++)
  465.                     sendto(fd,ack_packet,ack_len,0,(struct sockaddr*)&opp_addr,sizeof(opp_addr));
  466.                     printf("\rIPMSG:");
  467.                     fflush(stdout);
  468.                 }
  469.             }
  470.         }

  472.         bzero(buf,sizeof(buf));
  473.         bzero(buf2,sizeof(buf2));
  474.     }
  475.     return NULL;
  476. }

  478. void *put_handler(void *arg)
  479. {
  480.     int fd=(int)arg;
  481.     int i=0,found=0;
  482.     char buf[100]="",temp[100]="";
  483.     char *done[5];
  484.     
  485.     while(1)
  486.     {
  487.         printf("\rIPMSG:");
  488.         fflush(stdout);
  489.         bzero(buf,sizeof(buf));
  490.         bzero(temp,sizeof(temp));
  491.         
  492.         fgets(temp,sizeof(temp),stdin);
  493.         strncpy(buf,temp,strlen(temp)-1);
  494.                 
  495.         msg_deal(buf," ",done);

  497.         if(strstr(buf,"exit"))
  498.         {
  499.             broadcast_online(fd,'2');
  500.             exit(1);
  501.         }
  502.         
  503.         found = 1;
  504.         if(temp[0] != '\n')
  505.         {
  506.             for(i=0;i < sizeof(cmdlist)/sizeof(CMD);i++)
  507.             {    
  508.                 if(strcmp(cmdlist[i].name,done[0]) == 0 )
  509.                 {
  510.                     found = 0;
  511.                     cmdlist[i].fun(fd,done);
  512.                     break;
  513.                 }
  514.             }
  515.             if(found == 1)
  516.             printf("\rThe command is wrong,Pls type help\n");
  517.         }
  518.     }
  519.     return NULL;
  520. }

  522. int main()
  523. {
  524.     int udp_fd;
  525.     pthread_t tid_get,tid_put,tid_sndfile;
  526.     unsigned short port = 2425;
  527.     int broadcast_en= 1;
  528.     socklen_t broadcast_len = sizeof(broadcast_en);
  529.     
  530.     struct sockaddr_in srv_addr,cli_addr;
  531.     bzero(&srv_addr,sizeof(srv_addr));
  532.     bzero(&cli_addr,sizeof(cli_addr));
  533.     
  534.     srv_addr.sin_family = AF_INET;
  535.     srv_addr.sin_port = htons(port);
  536.     srv_addr.sin_addr.s_addr = htonl(INADDR_ANY);
  537.     
  538.     get_info();
  539.     
  540.     if((udp_fd = socket(AF_INET,SOCK_DGRAM,0)) < 0)
  541.     {
  542.         perror("socket");
  543.         exit(-1);
  544.     }
  545.     
  546.     setsockopt(udp_fd,SOL_SOCKET,SO_BROADCAST,&broadcast_en,broadcast_len);
  547.     
  548.     if( bind(udp_fd,(struct sockaddr*)&srv_addr,sizeof(srv_addr)) < 0)
  549.     {
  550.         perror("bind");
  551.         exit(-1);
  552.     }
  553.     
  554.     broadcast_online(udp_fd,'1');
  555.     head_t = creat_list();
  556.     
  557.     pthread_create(&tid_get,NULL,get_handler,(void *)udp_fd);
  558.     pthread_create(&tid_put,NULL,put_handler,(void *)udp_fd);
  559.     pthread_create(&tid_sndfile,NULL,send_file,NULL);
  560.     while(1);
  561.     return 0;
  562. }


点击(此处)折叠或打开

  1. #include"all.h"
  2. #include"IPMSG.h"

  4. IPMSG_USER *creat_list(void)
  5. {
  6.     IPMSG_USER *head=NULL,*pb=NULL;
  7.     char loc_ip[16]="192.168.1.133";
  8.     
  9.     pb = (IPMSG_USER *)malloc(sizeof(IPMSG_USER));
  10.     strcpy(pb->name,user);
  11.     strcpy(pb->host,machine);
  12.     strcpy(pb->s_addr,loc_ip);
  13.     
  14.     head = pb;    
  15.     pb->next = NULL;
  16.     
  17.     return head;
  18. }

  20. IPMSG_USER *add_list(IPMSG_USER *head,char *name,char *host,char *ip)
  21. {
  22.     
  23.     IPMSG_USER *temp=head;
  24.     IPMSG_USER *p_new=NULL;
  25.     
  26.     p_new = (IPMSG_USER *)malloc(sizeof(IPMSG_USER));
  27.     strcpy(p_new->name,name);
  28.     strcpy(p_new->host,host);
  29.     strcpy(p_new->s_addr,ip);
  30.     
  31.     if(temp == NULL)
  32.     {
  33.         head = p_new;
  34.         p_new = NULL;
  35.     }
  36.     while(temp->next != NULL)
  37.         temp = temp->next;
  38.     temp->next = p_new;
  39.     p_new->next = NULL;
  40.     
  41.     return head;
  42. }

  44. IPMSG_FILE *add_filelist(IPMSG_FILE *head,char *filename,int fileno,long packetno,long filesize,long ltime,int att,char *opp_user)
  45. {
  46.     IPMSG_FILE *temp=head;
  47.     IPMSG_FILE *p_new=NULL;
  48.     p_new = (IPMSG_FILE *)malloc(sizeof(IPMSG_FILE));
  49.     strcpy(p_new->name,filename);
  50.     p_new->num = fileno;
  51.     p_new->pkgnum = packetno;
  52.     p_new->size = filesize;
  53.     p_new->ltime = ltime;
  54.     p_new->att = att;
  55.     strcpy(p_new->user,opp_user);
  56.     
  57.     if(temp == NULL)
  58.     {
  59.         head = p_new ;
  60.         // p_new = head;
  61.         p_new = NULL;
  62.         return head;
  63.     }
  64.     while(temp->next != NULL)
  65.         temp = temp->next;
  66.     temp->next = p_new;
  67.     p_new->next = NULL;
  68.     
  69.     return head;
  70. }


  73. IPMSG_USER *del_list(IPMSG_USER *head,char *name)
  74. {
  75.     IPMSG_USER *temp=head;
  76.     IPMSG_USER *pf;
  77.     
  78.     while(temp!=NULL)
  79.     {
  80.         if(!strcmp(name,temp->name))
  81.         {        
  82.             if(temp==head)
  83.             head=temp->next;
  84.         else if(temp->next==NULL)
  85.             pf->next=NULL;
  86.         else
  87.             pf->next=temp->next;
  88.         }
  89.             pf=temp;
  90.             temp=temp->next;
  91.     }
  92.     free(temp);
  93.     return head;
  94. }

  96. IPMSG_FILE *del_filelist(IPMSG_FILE *head,char *name)
  97. {
  98.     IPMSG_FILE *temp=head;
  99.     IPMSG_FILE *pf;
  100.     
  101.     while(temp!=NULL)
  102.     {
  103.         if(!strcmp(name,temp->name))
  104.         {        
  105.             if(temp==head)
  106.             head=temp->next;
  107.         else if(temp->next==NULL)
  108.             pf->next=NULL;
  109.         else
  110.             pf->next=temp->next;
  111.         }
  112.             pf=temp;
  113.             temp=temp->next;
  114.     }
  115.     free(temp);
  116.     return head;
  117. }

  119. void print_list(IPMSG_USER *head)
  120. {
  121.     IPMSG_USER *temp=head;
  122.     while(temp!=NULL)
  123.     {
  124.         printf("%s\t%s\t%s\n",temp->name,temp->host,temp->s_addr);
  125.         temp=temp->next;
  126.     }
  127. }

  129. void print_filelist(IPMSG_FILE *head)
  130. {
  131.     IPMSG_FILE *temp=head;
  132.     while(temp!=NULL)
  133.     {
  134.         printf("%d\t%s\t%s\t%ld\n",temp->num,temp->name,temp->user,temp->pkgnum);
  135.         temp=temp->next;
  136.     }
  137. }

  139. char* search_list(IPMSG_USER *head,char *username)
  140. {
  141.     IPMSG_USER *temp=head;
  142.     while(strcmp(temp->name,username))
  143.         {
  144.             if(temp->next == NULL)
  145.                 return (char*)0;
  146.             temp=temp->next;
  147.         }
  148.         
  149.     return temp->s_addr;
  150. }

  152. IPMSG_FILE *search_filelist(IPMSG_FILE *head,char *filename)
  153. {
  154.     IPMSG_FILE *temp=head;
  155.     while(strcmp(temp->name,filename))
  156.         {
  157.             //printf("%s\n",temp->name);
  158.             if(temp->next == NULL)
  159.                 return (IPMSG_FILE *)0;
  160.             temp=temp->next;
  161.         }
  162.         
  163.     return temp;
  164. }

  166. IPMSG_FILE *search(IPMSG_FILE *head,long packetno)
  167. {
  168.     IPMSG_FILE *temp=head;
  169.     while(temp->pkgnum != packetno)
  170.         {
  171.             //printf("%s\n",temp->name);
  172.             if(temp->next == NULL)
  173.                 return (IPMSG_FILE *)0;
  174.             temp=temp->next;
  175.         }
  176.         
  177.     return temp;
  178. }


点击(此处)折叠或打开

  1. #include<stdio.h>
  2. #include<stdlib.h>
  3. #include<arpa/inet.h>
  4. #include<sys/types.h>
  5. #include<sys/socket.h>
  6. #include<netinet/in.h>
  7. #include<unistd.h>
  8. #include<pthread.h>
  9. #include<string.h>
  10. #include<sys/stat.h>
  11. #include<fcntl.h>
  12. #include"IPMSG.h"

  14. //用户信息结构体
  15. typedef struct userlist
  16. {
  17.     char name[20];    //用户名
  18.     char host[20];    //主机名
  19.     char s_addr[16];        //IP地址(32位网络字节序)
  20.     struct userlist *next;
  21. }IPMSG_USER;

  23. //文件信息结构体
  24. typedef struct filelist
  25. {
  26.     char name[50];//文件名
  27.     int num;// 文件序号
  28.     int att;//文件属性
  29.     long pkgnum;//包编号
  30.     long size;//文件大小
  31.     long ltime;//最后修改时间
  32.     char user[10];    //发送者用户名
  33.     struct filelist *next;
  34. }IPMSG_FILE;

  36. extern IPMSG_USER *creat_list(void);
  37. extern IPMSG_USER *add_list(IPMSG_USER *head,char *name,char *host,char *ip);
  38. extern IPMSG_USER *del_list(IPMSG_USER *head,char *name);
  39. extern void print_list(IPMSG_USER *head);
  40. extern char* search_list(IPMSG_USER *head,char *username);

  42. IPMSG_FILE *add_filelist(IPMSG_FILE *head,char *filename,int fileno,long packetno,long filesize,long ltime,int att,char *opp_user);
  43. extern IPMSG_FILE *del_filelist(IPMSG_FILE *head,char *name);
  44. extern void print_filelist(IPMSG_FILE *head);
  45. extern IPMSG_FILE *search_filelist(IPMSG_FILE *head,char *filename);
  46. extern IPMSG_FILE *search(IPMSG_FILE *head,long packetno);

  48. extern void ls_fun();
  49. extern void help_fun();
  50. extern void Sendto();
  51. extern void cls_fun();
  52. extern void filels_fun(int argc, char *argv[]);
  53. extern void getfile(int argc, char *argv[]);
  54. extern void sendfile(int argc, char *argv[]);

  56. extern char user[30];
  57. extern char machine[30];
  58. ern char user[30];
  59. extern char machine[30];
  60. extern void sendgroup(int argc, char *argv[]);
  61. extern void creatgroup(int argc, char *argv[]);

  63. extern char user[30];
  64. extern char machine[30];

阅读(2740) | 评论(0) | 转发(0) |
0

上一篇：Web CGI HTML搭建物联网模型

下一篇：王爽汇编---字符串输入分析

给主人留下些什么吧！~~
关于我们 | 关于IT168 | 联系方式 | 广告合作 | 法律声明 | 免费注册

Copyright 2001-2010 ChinaUnix.net All Rights Reserved 北京皓辰网域网络信息技术有限公司. 版权所有

感谢所有关心和支持过ChinaUnix的朋友们

16024965号-6