pipe()를 사용하여 데이터를 전송하고자 할 때 질문입니다.

data의 크기는 최대 크기로 잡으시는 것이구요.
write 예제는 fd 값이 빠졌군요. ㅋ~
보내기 위해 패킷을 만들 때, seq와 데이터 길이를 조합한 값을 len에 넣어 두면 가변 길이를 의미하게 됩니다.
어차피 프로토콜을 설계할 때 데이터의 최대 크기는 정하는 것이 맞고,
그렇다면, 그 크기가 수용될만한 공간을 어디엔가에는 잡아 둬야,
전송이나 수신할 때 사용할 수 있게됩니다.

받을 때는 상대가 얼마나 되는 크기를 보낼지 모르므로, 일단
4 byte 정도로 앞으로 올 길이를 먼저 수신해보고, 그 길이 만큼 스트림을
읽는 방식으로 생각하여 설계하시면 됩니다.

write, read 의 회수를 생각하시면 안되고, 보내는 양과 받는 양을 생각하셔서 설계하세요.
즉, 저쪽에서 몇번에 보냈는지를 이쪽에서 아는 설계를 하면 안된다는 것이고,
다른 말로 하면, 모든 데이터가 다닥다닥 붙어서 왔을경우에도 쪼갤 수 있는
패킷을 설계하라는 것입니다.

도움이 되시길..

시스템 네트웍 프로그래머지망생입니다....
초보인지라 따라해보았습니다.....
감사합니다.

#include<stdio.h>
#include<unistd.h>
#include<stdlib.h>
#include <string.h>
#include <sys/wait.h>
#include <signal.h>
#include <limits.h>

const int MAXLEN=31;

typedef struct {
  int len;
  unsigned short int seq;
  char data[MAXLEN];
}header;

void alrm_action(int signo)
{
  printf("ding ding ding\n");
  exit(1);
}
void DataLinkSend(int fd)
{
  printf("Send Start\n");
  header *Header = (header *)malloc(sizeof(header));
  char *buffer = (char *)malloc(sizeof(char)*41);

  memset(buffer, '*', 10);//10
  memset(buffer+10, '@',10);//20
  memset(buffer+10+10,'$',10);//30
  memset(buffer+10+10+10,'!',10);//40
  memset(buffer+40,'\0',1);//41

  int bufsize=strlen(buffer)+1;
  printf("bufsize %d\n",bufsize);
  int writesize=0;
  int count=0;
  //close(fda[0]);
  while(bufsize>0)
    {
      if(bufsize<MAXLEN)
        writesize=bufsize;
      else
        writesize=MAXLEN;
      printf("%d\n",writesize);
      Header->len=writesize;
      Header->seq=count;
      strncpy(Header->data,buffer+count,Header->len);
      printf("HD %s\n",Header->data);
      write(fd,&(Header->len),sizeof(int));
      write(fd,&(Header->seq),sizeof(unsigned short int));
      
      write(fd,Header->data,writesize);
      bufsize-=writesize;
      count+=writesize;
    }


  free(buffer);
  printf("Send end\n");
}

void DataLinkRecv(int fd)
{
  static struct sigaction act;
  act.sa_handler=alrm_action;
  sigfillset(&(act.sa_mask));
  sigaction(SIGALRM,&act,NULL);

  printf("Rec Start\n");
  header *temp = (header *)malloc(sizeof(header)) ;
  ssize_t nread;
  int i=0;
  char S[32];
  //close(fda[1]);
   while(1)
    {
      alarm(5);
      
      if((nread=read(fd,&(temp->len),sizeof(int))) == 0)break;
      read(fd, &(temp->seq), sizeof(unsigned short int) );
      read(fd,temp->data,temp->len);
      printf("S %s %d \n",temp->data,strlen(temp->data));
      
      alarm(0);
    }

  printf("Rev end\n");
}

int main(int argc, char **argv)
{
  int fda[2];
  pid_t pid;

  pipe(fda);

  pid = fork();

  if(pid == 0){
    printf("Child Start\n");
    close(fda[0]);
    DataLinkSend(fda[1]);
    printf("Child end\n");
  }
  else{
    printf("Parent Start\n");
    wait(NULL);
    close(fda[1]);
    DataLinkRecv(fda[0]);
    printf("Parrent end\n");
  }

  return 0;
}