#include <pthread.h>

 #include <unistd.h>

 #include <stdio.h>

 #include <sys/types.h>          /* See NOTES */

 #include <sys/socket.h>

 #define SOCKET_BUFFER_SIZE      (32768U)

 #define BUF_MAX_LEN              512

 void *function_thread (void *arg)

 {

     int fd = (int)arg;

     char buf[BUF_MAX_LEN];

     int cnt = ;

     int len = -;

     while()

     {

         len = sprintf(buf,"Hello,main thread1, cnt = %d\r\n",cnt++);

         write(fd,buf,len);

         len = read(fd,buf,BUF_MAX_LEN);

         buf[len] = '\0';

         printf("thead1 read:%s\r\n",buf);

         sleep();

     }

     return NULL;

 }

 int main(int argc,char **argv)

 {

     int ret = -;

     int sockets[];

     int bufferSize = SOCKET_BUFFER_SIZE;

     pthread_t threadID;

     char buf[BUF_MAX_LEN];

     int len = ;

     int cnt = ;

     int fd = -;

     ret = socketpair(AF_UNIX,SOCK_SEQPACKET,,sockets);

     if(ret){

         printf("Error socketpair\r\n");

         return -;

     }

     setsockopt(sockets[], SOL_SOCKET, SO_SNDBUF, &bufferSize, sizeof(bufferSize));

     setsockopt(sockets[], SOL_SOCKET, SO_RCVBUF, &bufferSize, sizeof(bufferSize));

     setsockopt(sockets[], SOL_SOCKET, SO_SNDBUF, &bufferSize, sizeof(bufferSize));

     setsockopt(sockets[], SOL_SOCKET, SO_RCVBUF, &bufferSize, sizeof(bufferSize));

     ret = pthread_create(&threadID,NULL,function_thread,(void *)sockets[]);

     fd = sockets[];

     while(){

         len = read(fd,buf,BUF_MAX_LEN);

         buf[len] = '\0';

         printf("Main thread read:%s\r\n",buf);

         len = sprintf(buf,"Hello,thread1, cnt = %d\r\n",cnt++);

         write(fd,buf,len);

     }

     return ;

 }