mserver_getdata.h

linux下的人机对话编程

Mserver_getdata()
{
	/* attach parent's shared memory */
        aw=(struct area_window *)shmat(shmid_win, 0, 0);
      /* note: shmid is still set correctly */
	int port=8000;
	struct sockaddr_in sin;
	struct sockaddr_in pin;
	int sock_descriptor;
	int temp_sock_descriptor;
	int address_size;
	int i,len1,len2;
while(1)
{
	sock_descriptor=socket(AF_INET,SOCK_STREAM,0);
	if(sock_descriptor==-1)
		{
		perror("call to socket");
         	continue;
		}
	bzero(&sin,sizeof(sin));
	sin.sin_family=AF_INET;
	sin.sin_addr.s_addr=htonl(INADDR_ANY);
	sin.sin_port=htons(port);
	if(bind(sock_descriptor,(struct sockaddr *)&sin,sizeof(sin))==-1)
		{
		perror("call to bind");
		close(sock_descriptor);
		sleep(50);
		continue;
		}
	if(listen(sock_descriptor,20)==-1)
		{
		perror("call to listen");
		close(sock_descriptor);
		continue;
		}
      printf("Accepting connections ...\n");
while(1)
	{
	char buf[1000]={};
temp_sock_descriptor=accept(sock_descriptor,(struct sockaddr *)&pin,&address_size);
	if(temp_sock_descriptor==-1)
		{
		perror("call to accept");
		close(sock_descriptor);
		break;;
		}
	if(recv(temp_sock_descriptor,buf,1000,0)==-1)
		{
		perror("call to recv");
		close(sock_descriptor);
		break;
		}
// for this server example,we just convert the
	//receive
if(strlen(buf)!=0)
   {
         buf_win.sem_op=-1;
        semop(semid_win, (struct sembuf *) &buf_win, 1);
        printf("\nM Receive from AB: %s,len:%d\n",buf,strlen(buf));
	strcpy(aw->ID,buf);
	aw->flag_revInfo=1;
        //modify the dong tai table
         //Receive(buf);
    int k=0,j=1,m=0,n=0,n1=0;
        char *sp="#";
        char *tmp;
        int i=1;
	int len=strlen(buf);
        aw->SgNode_DynTab[k][1]=strtoul(strtok(buf,sp),NULL,16);
        while(tmp=strtok(NULL,sp))
                {
                if(j<30)
                aw->SgNode_DynTab[++k][1]=strtoul(tmp,NULL,16);
                else if((j>29)&&(j<47))
                aw->SwNode_DynTab[m++][1]=strtoul(tmp,NULL,16);
                else if((j>46)&&(j<72))
                aw->FdNode_DynTab[n++][1]=strtoul(tmp,NULL,16);
		
		else if((j>71)&&(j<97))
		{
		 printf("j=%d\n",j);
         	aw->FdNode_DynTab[n1++][2]=strtoul(tmp,NULL,16);
		}
                j++;
                }
	for(i=0;i<25;i++)
		{aw->flag_SG[i]=1;}
         buf_win.sem_op=1;
        semop(semid_win, (struct sembuf *) &buf_win, 1);
        send(temp_sock_descriptor,"success reveive!",strlen("success reveive!"),0);
  }//if

	close(temp_sock_descriptor);
    }//while nei bu
 }//while wai bu
}//Mserver_B_getdata