FIFO 테스트

서버
#include
#include
#include
#include

int main( int argc , char *argv[] )
{
int i , fd , nread;
char buf[10 + 1];
if ( mkfifo( "myfifo" , 0777 ) == -1)
perror("mkfifo fail");
else
fprintf ( stderr , "fifo Successfully created!!
\n" );

//fd = open ( "myfifo" , O_RDONLY ); /* 상대방쪽에서
O_WRONLY로 open할때까지 blocking */
fd = open ( "myfifo" , O_RDWR ); /* 자체적으로 WR을 포함하
므로 blocking 되지 아니함 */
if ( fd == -1 )
perror ( "open fail" );
else
fprintf ( stderr , "opened Successfully \n" );

for ( memset( buf , 0 , sizeof buf );
/*
* O_RDONLY 상대방에서 write를 끝낸후에는 read
가 바로 0을 리턴하므로 종료됨
* O_RDWR 상대방에서 write를 끝낸후에도 자체 WR때문
에 블럭킹되어 종료하지 않음
*/
nread = read( fd , buf , sizeof buf - 1) ;
memset( buf , 0 , sizeof buf )
)
{
fprintf(stderr , "received Msg[%s] bytes[%d]\n" , buf , nread );
}
return 0;
}

클라이언트
#include
#include
#include
#include

FILE *fp;
int main( int argc , char *argv[] )
{
int i , fd , nwrite;
char buf[255];
fd = open ( "myfifo" , O_WRONLY|O_NONBLOCK );
if ( fd == -1 )
perror ( "open fail" );
else
fprintf ( stderr , "opened Successfully \n" );

if ( argc == 2 )
{
nwrite = write( fd , argv[1] , strlen( argv[1] ) );
fprintf ( stderr , "send msg[%s] bytes[%d]\n" , argv[1] , nwrite );
}
else
{
fp = fopen( "a.c" , "r" );
while ( fgets( buf , sizeof buf , fp ) )
{
//buf[strlen(buf)-1] = 0x00;
nwrite = write( fd , buf , strlen( buf ) );
fprintf ( stderr , "send msg[%s] bytes[%d]\n" , buf , nwrite );
}
fclose(fp);
}
return 0;
}