Alive Idle Timer

クライアントプログラム

#include "unp.h"

int

main(int argc, char **argv)

{

int sockfd;

int maxfdp1;

struct sockaddr_in servaddr;

fd_set rset;

char sendline[MAXLINE], recvline[MAXLINE];

if (argc != 2)

err_quit("usage: tcpcli <IPaddress>");

FD_ZERO(&rset);

sockfd = Socket(AF_INET, SOCK_STREAM, 0);

bzero(&servaddr, sizeof(servaddr));

servaddr.sin_family = AF_INET;

// ここは、プロセスA,B毎に書き換え

// プロセスA では、9877を設定、プロセスBでは9878を設定

servaddr.sin_port = htons(9877);

Inet_pton(AF_INET, argv[1], &servaddr.sin_addr);

Connect(sockfd, (SA *) &servaddr, sizeof(servaddr));

for (;;){

FD_SET(fileno(stdin), &rset);

FD_SET(sockfd, &rset);

maxfdp1 = max(fileno(stdin), sockfd)+1;

Select(maxfdp1, &rset, NULL, NULL, NULL);

if(FD_ISSET(sockfd, &rset)){

if (Readline(sockfd, recvline, MAXLINE) == 0)

err_quit("str_cli: server terminated prematurely");

Fputs(recvline, stdout);

}

if(FD_ISSET(fileno(stdin), &rset)){

if(Fgets(sendline, MAXLINE, stdin) == NULL)

return;

Writen(sockfd, sendline, strlen(sendline));

}

}

exit(0);

}

サーバプログラム

#include "unp.h"

#include <sys/socket.h>

#include <netinet/in.h>

#include <netinet/tcp.h>

int

main(int argc, char **argv)

{

int listenfd, connfd;

int flag;

pid_t childpid;

socklen_t clilen;

struct sockaddr_in cliaddr, servaddr;

listenfd = Socket(AF_INET, SOCK_STREAM, 0);

bzero(&servaddr, sizeof(servaddr));

servaddr.sin_family = AF_INET;

servaddr.sin_addr.s_addr = htonl(INADDR_ANY);

// ここは、プロセスA,B毎に書き換え

// プロセスA では、9877を設定、プロセスBでは9878を設定

servaddr.sin_port = htons(9877);

flag = 1;

Setsockopt(listenfd, SOL_SOCKET, SO_KEEPALIVE, (void *)&flag, sizeof(flag));

// ここは、プロセスA,B毎に書き換え

// プロセスA では、300を設定、プロセスBでは420を設定

flag = 300;

Setsockopt(listenfd, IPPROTO_TCP, TCP_KEEPIDLE, (void*)&flag, sizeof(flag) );

flag = 3;

Setsockopt(listenfd, IPPROTO_TCP, TCP_KEEPCNT, (void*)&flag, sizeof(flag) );

flag = 30;

Setsockopt(listenfd, IPPROTO_TCP, TCP_KEEPINTVL, (void*)&flag, sizeof(flag) );

Bind(listenfd, (SA *) &servaddr, sizeof(servaddr));

Listen(listenfd, LISTENQ);

for ( ; ; ) {

clilen = sizeof(cliaddr);

connfd = Accept(listenfd, (SA *) &cliaddr, &clilen);

if ( (childpid = Fork()) == 0) { /* child process */

Close(listenfd); /* close listening socket */

str_echo(connfd); /* process the request */

exit(0);

}

Close(connfd); /* parent closes connected socket }

}