#include <iostream>
#include <sstream>
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <netinet/in.h>
#include <net/if.h>
#include <arpa/inet.h>
#include <resolv.h>
#include <signal.h>
#include <sys/wait.h>
#include <sys/ioctl.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <sys/time.h>
#include <sys/syscall.h>
#include <linux/unistd.h>
#include <fcntl.h>

using namespace std;
//Дескрипторы pipa
int client_pipe[2];

//Код потока
void * thr_loop(void * arg)
{
int i = 0;
	char wbuf[1024];
	while(1)
	{
	char num[33];
		strcpy(wbuf,"test ");
		sprintf(num,"%d",++i);
		strcat(wbuf,num);
		//Пишем в дескриптор для записи раз в секудну
		write(client_pipe[1],wbuf,10);
		sleep(1);
	}
	pthread_exit((void * )0);
}


int main(int argc,char*argv[])
{

	pipe(client_pipe);
	
	fd_set pipes_set;
    FD_ZERO(&pipes_set);
	
	int max_pipe_num = 0;
	//Нашли максимальный pipe
	if (client_pipe[0] > max_pipe_num)	max_pipe_num = client_pipe[0];
	if (client_pipe[1] > max_pipe_num)	max_pipe_num = client_pipe[1];	

	//Старт потомка
	pthread_t _thread;
	pthread_create(&_thread, NULL, thr_loop, NULL);
	while(1)
    {
			struct timeval tv;
			const int n = 1024;
			char chprbuf[n];
			int chprbuf_len = 0;
			memset(&chprbuf,0,sizeof(chprbuf));
			tv.tv_sec = 1;
			tv.tv_usec = 0;
			//Ждём данные от потомка
			if(select(max_pipe_num + 1, &pipes_set, NULL, NULL, &tv) > 0)
			{
				chprbuf_len = read(client_pipe[0],chprbuf,n);
				if(chprbuf_len>0){
					string msg = string(chprbuf);
					cout<<msg<<endl;
				}
			}
    }
	pthread_join(_thread, NULL);
    exit(0);
}