システムプログラム（第7週）: Pthreadによる複数のクライアントに対するサービスの同時提供

電子・情報工学系/システム情報工学研究科CS専攻
新城 靖
<yas@is.tsukuba.ac.jp>

このページは、次の URL にあります。
http://www.coins.tsukuba.ac.jp/~syspro/2005/No7_files/echo-server-pthread.html
あるいは、次のページから手繰っていくこともできます。
http://www.coins.tsukuba.ac.jp/~syspro/2005/
http://www.coins.tsukuba.ac.jp/~yas/

Ptheadとは

echo-server-pthread.c

   1:	
   2:	/*
   3:	        echo-server-pthread.c -- 受け取った文字列をそのまま返すサーバ(pthread版)
   4:	        ~yas/syspro/ipc/echo-server-pthread.c
   5:	        Created on 2002/02/04 21:17:04
   6:	*/
   7:	#include <stdio.h>
   8:	#include <sys/types.h>  /* socket(), time() */
   9:	#include <sys/socket.h> /* socket() */
  10:	#include <netinet/in.h> /* struct sockaddr_in */
  11:	#include <pthread.h>    /* pthread_create */
  12:	#include <netdb.h>      /* getnameinfo() */
  13:	
  14:	extern  void echo_server( int portno );
  15:	extern  void echo_reply( int com );
  16:	extern  void print_my_host_port( int portno );
  17:	extern  void tcp_peeraddr_print( int com );
  18:	extern  void sockaddr_print( struct sockaddr *addrp, int addr_len );
  19:	extern  tcp_acc_port( int portno );
  20:	extern  int fdopen_sock( int sock, FILE **inp, FILE **outp );
  21:	
  22:	main( int argc, char *argv[] )
  23:	{
  24:	    int portno ;
  25:	        if( argc >= 3 )
  26:	        {
  27:	            fprintf( stdout,"Usage: %s [portno] \n",argv[0] );
  28:	            exit( -1 );
  29:	        }
  30:	        if( argc == 2 )
  31:	            portno = strtol( argv[1],0,10 );
  32:	        else
  33:	            portno = getuid();
  34:	        echo_server( portno );
  35:	}

  36:	
  37:	void
  38:	echo_server( int portno )
  39:	{
  40:	    int acc,com ;
  41:	    pthread_t worker ;
  42:	        acc = tcp_acc_port( portno );
  43:	        if( acc<0 )
  44:	            exit( -1 );
  45:	        print_my_host_port( portno );
  46:	        while( 1 )
  47:	        {
  48:	            if( (com = accept( acc,0,0 )) < 0 )
  49:	            {
  50:	                perror("accept");
  51:	                exit( -1 );
  52:	            }
  53:	            tcp_peeraddr_print( com );
  54:	            if( pthread_create( &worker, NULL, (void *)echo_reply, (void *)com)
  55:	                != 0 )
  56:	            {
  57:	                perror("pthread_create()");
  58:	                exit( 1 );
  59:	            }
  60:	            pthread_detach( worker );
  61:	        }
  62:	}
  63:	

このプログラムの特徴を以下にまとめる。

• fork() の代りに pthread_create() をしている。元の fork() のプログ ラムよりすっきりしている。
• wait しない代りに pthread_detach() している。fork版では必要だった delete_zombie() が不要である。

他の関数は、fork版と同じである。

 % diff -c echo-server-nofork-fdopen.c echo-server-pthread.c 
 *** echo-server-nofork-fdopen.c	Sun May  9 23:19:57 2004
 --- echo-server-pthread.c	Sun May  9 23:19:53 2004
 ***************
 *** 1,16 ****

   /*
 ! 	echo-server-nofork-fdopen.c -- 受け取った文字列をそのまま返すサーバ(fork無し版)
 ! 	~yas/syspro/ipc/echo-server-nofork-fdopen.c
 ! 	Created on 2004/05/09 19:08:47
   */
 - #define _USE_BSD	/* wait4() */
   #include <stdio.h>
 ! #include <sys/types.h>	/* socket(), wait4() */
   #include <sys/socket.h>	/* socket() */
   #include <netinet/in.h>	/* struct sockaddr_in */
 ! #include <sys/resource.h> /* wait4() */
 ! #include <sys/wait.h>	/* wait4() */
   #include <netdb.h>	/* getnameinfo() */

   extern	void echo_server( int portno );
 --- 1,14 ----

   /*
 ! 	echo-server-pthread.c -- 受け取った文字列をそのまま返すサーバ(pthread版)
 ! 	~yas/syspro/ipc/echo-server-pthread.c
 ! 	Created on 2002/02/04 21:17:04
   */
   #include <stdio.h>
 ! #include <sys/types.h>	/* socket(), time() */
   #include <sys/socket.h>	/* socket() */
   #include <netinet/in.h>	/* struct sockaddr_in */
 ! #include <pthread.h>	/* pthread_create */
   #include <netdb.h>	/* getnameinfo() */

   extern	void echo_server( int portno );
 ***************
 *** 40,45 ****
 --- 38,44 ----
   echo_server( int portno )
   {
       int acc,com ;
 +     pthread_t worker ;
	 acc = tcp_acc_port( portno );
	 if( acc<0 )
	     exit( -1 );
 ***************
 *** 52,58 ****
		 exit( -1 );
	     }
	     tcp_peeraddr_print( com );
 ! 	    echo_reply( com );
	 }
   }

 --- 51,63 ----
		 exit( -1 );
	     }
	     tcp_peeraddr_print( com );
 ! 	    if( pthread_create( &worker, NULL, (void *)echo_reply, (void *)com)
 ! 		!= 0 )
 ! 	    {
 ! 	        perror("pthread_create()");
 ! 		exit( 1 );
 ! 	    }
 ! 	    pthread_detach( worker );
	 }
   }

 % 

サーバ側。サーバは、終了しないので、最後に、^C を押して、割り 込みを掛けて終了させる。

注意：全員がポート番号 1231 を使うとプログラムが動かないことがある。

% ./echo-server-pthread 1231 
run telnet adonis9.coins.tsukuba.ac.jp 1231 
[7298] connection (fd==4) from 130.158.86.28:47333
[7300] received (fd==4) 5 bytes, [012
]
[7298] connection (fd==8) from 127.0.0.1:42170
[7302] received (fd==8) 5 bytes, [abc
]
[7302] received (fd==8) 5 bytes, [def
]
[7302] connection (fd==8) closed.
[7300] received (fd==4) 5 bytes, [345
]
[7300] connection (fd==4) closed.
^C
% 

% telnet adonis9.coins.tsukuba.ac.jp 1231 
Trying 130.158.86.29...
Connected to adonis9.coins.tsukuba.ac.jp.
Escape character is '^]'.
012
012
345
345
^]
telnet> quit
Connection closed.
% 

% telnet adonis9.coins.tsukuba.ac.jp 1231 
Trying 130.158.86.29...
Connected to adonis9.coins.tsukuba.ac.jp.
Escape character is '^]'.
abc
abc
def
def
^]
telnet> quit
Connection closed.
%