mserver_b_getdata.h

linux下的人机对话编程

// Mserver_B_getdata.h 
Mserver_B_getdata()
{
	/* attach parent's shared memory */
        bw=(struct area_window *)shmat(shmid_winb, 0, 0);
      /* note: shmid is still set correctly */
	int port=8020;
	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[500]={};
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,500,0)==-1)
		{
		perror("call to recv");
		close(sock_descriptor);
		break;;
		}
      printf("Received form client: %s\n",buf);
// for this server example,we just convert the
	len1=strlen(buf);
	 /* set semaphore */
        buf_winb.sem_op=-1;
        semop(semid_winb, (struct sembuf *) &buf_winb, 1);
	strcpy(bw->test,buf);
	 /* set semaphore */
        buf_winb.sem_op=1;
        semop(semid_winb, (struct sembuf *) &buf_winb, 1);

	if(send(temp_sock_descriptor,bw->test,len1,0)==-1)
		{
		perror("call to send");
		close(sock_descriptor);
	        break;;
		}
	close(temp_sock_descriptor);
    }//while nei bu
 }//while wai bu
}//Mserver_B_getdata