CLOSE_WAITについて

Proto Recv-Q Send-Q Local Address               Foreign Address             State

tcp        1      0 192.168.0.1:12345          192.168.0.2:37689          CLOSE_WAIT

#define BUFSIZE 8192

#define PORT 12345

#define FILE_NAME "/var/tmp/check.dat"

#define REHTTP_PROG "/etc/rc.d/init.d/httpd restart"



int main() {



	struct sockaddr_in server;

	struct sockaddr_in client;

	int i, len, ret, val;

	int flg, size;

	int sum, fsize;

	int sock, sock_waiting;

	char send_buf[BUFSIZE];

	char recv_buf[BUFSIZE];

	FILE *fp;



	// サーバーのアドレスを設定する

	memset((char *)&server, 0, sizeof(server));

	server.sin_family = AF_INET;

	server.sin_addr.s_addr = htonl(INADDR_ANY);

	server.sin_port = htons(PORT);



	// TCPでソケットの作成

	if((sock_waiting = socket(AF_INET, SOCK_STREAM, 0)) < 0) {

		perror("socket");

		exit(EXIT_FAILURE);

	}



	val = 1;

	val = setsockopt(sock_waiting, SOL_SOCKET, SO_REUSEADDR, &val, sizeof(val));

	if (val < 0) {

		perror("setsockopt");

		exit(EXIT_FAILURE);

	}



	// サーバーへのポート番号割り当て

	if(bind(sock_waiting, (struct sockaddr *)&server, sizeof(server)) < 0) {

		perror("bind");

		exit(EXIT_FAILURE);

	}



	// コネクション確立要求受付開始

	listen(sock_waiting, SOMAXCONN);



	// コネクション受付ループ

	while(1) {

		printf("waiting...\n");

		}

		len = sizeof(client);

		if((sock = accept(sock_waiting, (struct sockaddr *)&client, (size_t*)&len)) < 0) {

			perror("accept");

			exit(EXIT_FAILURE);

		}



		// 接続完了メッセージの送信

		strcpy(send_buf, "Connect Success");

		if(size = send(sock, send_buf, strlen(send_buf) + 1, 0) < 0) {

			perror("send error");

			close(sock);

			exit(EXIT_FAILURE);

		}



		i = 0;

		sum = 0;

		// サーバー処理メインルーチン

		while(1) {

			if((size = recv(sock, recv_buf, BUFSIZE - 1, 0)) < 0) {

				perror("recv error");

				close(sock);

				exit(EXIT_FAILURE);

			} else if(size == 0) {

				break;

			}

			sum += size;



			recv_buf[sum - 1] = '\0';



			if(strncmp(recv_buf, "rehttp", 6) == 0) {

				ret = http_reboot();

			}

			if(ret != 0) {

				perror("error");

				close(sock);

				exit(EXIT_FAILURE);

			}

			memset(&recv_buf, 0, sizeof(recv_buf));

			flg = 0;



			fsize = GetFileSize(FILE_NAME);

			if((fp = fopen(FILE_NAME, "r")) == NULL) {

				perror("file open error");

				close(sock);

				exit(EXIT_FAILURE);

			}



			// ファイルサイズ分読み込む

			while(flg == 0) {

				if(fgets(send_buf, fsize + 1, fp) == NULL) {

					flg = 1;

					strcpy(send_buf, "END");

					if(size = send(sock, send_buf, strlen(send_buf) + 1, 0) < 0) {

						perror("send error");

						close(sock);

						exit(EXIT_FAILURE);

					}

					continue;

					}

					if(size = send(sock, send_buf, strlen(send_buf) + 1, 0) < 0) {

					perror("send error");

					close(sock);

					exit(EXIT_FAILURE);

				}



				if(size = recv(sock, recv_buf, BUFSIZE - 1, 0) < 0) {

					perror("recv error");

					close(sock);

					exit(EXIT_FAILURE);

				}



				if((strcmp(recv_buf, "OK")) == 0) {

					continue;

				}

				fclose(fp);

				break;

			}

		close(sock);

		printf("sock closed\n");

		break;

		}

	}

	close(sock_waiting);

	return EXIT_SUCCESS;

}



int http_reboot()

{

    int ret;

    char    buff[MAX_LENGTH];



    sprintf(buff, "%s > %s", REHTTP_PROG, FILE_NAME);

    ret = system(buff);



    return(ret);



}