도움말 : 잘못된 동작 코드 : POSIX Message Queue UNIX C 프로그래밍

Question

에 대한 클라이언트 - 서버 IPC 신호 처리가 단일 main() 기능에 있으므로 신호 처리가 필요합니다.

클라이언트 :하여 Posix 메시지 큐 IPC 메커니즘을 사용하여, 우선 순위 및 기타 연결리스트 메시지는 무시해도, 시나리오 구현 노크 노크를

서버 : 단락 기호

서버 :이

클라이언트의 : pilcrow, 고마워.

클라이언트 : 다시 클라이언트

에 "있다"출구

모든 프로세스가 stdin-> POSIX MSGQ 클라이언트가 서버 -에 '노크 노크'> 서버가

문자열을 비교 보내기 종결 된 무엇 내가 가지고있어 :

클라이언트 : 노크 노크

서버 : 누가 거기에 있니?

클라이언트 : 단락 기호

클라이언트

단락 기호 : 종료

종료

1 라운드는 성공적으로 클라이언트 출력을, 나에게 콘솔 같은 입력을 오른쪽 result.From 2 라운드를 제공합니다.

도와주세요. gcc -lrt를 사용하여 mq_function을 링크해야합니다.

다음

내 코드는이

#include <mqueue.h> 
#include <stdlib.h> 
#include <stdio.h> 
#include <unistd.h> 
#include <signal.h> 
#include <sys/types.h> 
#define MSG_SIZE 100 //max size of msg 
#define MAX_MSG 1 //max # of msg 
#define FILE_MODE (S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH) 
volatile sig_atomic_t mqflag; /* set nonzero by signal handler */ 
static void sig_usr1(int); 
sigset_t zeromask, newmask, oldmask; 

int main(int argc, char **argv) { 
int c,flags;/* for getopt() */ 
pid_t child_pid; 
mqd_t msgq_id; 
struct mq_attr attr; 
struct sigevent sigev; 
char *buff_forward,*buff_backward; 
flags=O_RDWR | O_CREAT; 
attr.mq_msgsize=MSG_SIZE; 
attr.mq_maxmsg=MAX_MSG; 
buff_forward=malloc(attr.mq_msgsize); 
buff_backward=malloc(attr.mq_msgsize); 

while ((c= getopt(argc, argv, "e")) != -1) { 
    switch (c) { 
     case 'e': /* create the queue exclusive */ 
      flags|= O_EXCL; 
      break; 
    } 
} 

if (optind!=argc-1){ 
    printf("usage: [-e] <name>"); 
    exit(1); 
} 

msgq_id = mq_open(argv[optind],flags,FILE_MODE,&attr); 
/* producing the message */ 
mq_getattr(msgq_id, &attr) ; 
printf("Queue \"%s\":\n\t- stores at most %ld messages\n\t- " 
     "large at most %ld bytes each\n\t- currently holds %ld messages\n", 
     argv[optind], attr.mq_maxmsg, attr.mq_msgsize, attr.mq_curmsgs); 

sigemptyset(&zeromask); /* no signals blocked */ 
sigemptyset(&newmask); 
sigemptyset(&oldmask); 
sigaddset(&newmask, SIGUSR1); 
/* establish signal handler, enable notification */ 
signal(SIGUSR1, sig_usr1); 
sigev.sigev_notify = SIGEV_SIGNAL; 
sigev.sigev_signo = SIGUSR1; 
sigprocmask(SIG_BLOCK, &newmask, &oldmask);/* block SIGUSR1 */ 

if ((child_pid=fork())==0){ 
    for (; ;) { 
     while (mqflag == 0) 
      sigsuspend(&zeromask); 
     mqflag =0; /* reset flag */ 
     msgq_id=mq_open(argv[optind],O_RDONLY); 
     mq_receive(msgq_id, buff_forward, attr.mq_msgsize, NULL); 
     mq_close(msgq_id); 

     if (strcasecmp ("Knock Knock",buff_forward)==0){ 
      strcpy(buff_backward,"Server:Who's there?"); 
     } 
     else if(strcasecmp ("pilcrow", buff_forward)==0){ 
      strcpy(buff_backward,"Server:Pilcrow,thanks a lot!"); 
     } 
     else if(strcasecmp ("Exit",buff_forward)==0){ 
      kill(getppid(),SIGTERM); 
      exit(0); 
     } 

    msgq_id=mq_open(argv[optind],O_WRONLY); 
    mq_send(msgq_id,buff_backward,MSG_SIZE,NULL); 
    mq_close(msgq_id); 
     mq_notify(msgq_id, &sigev); /* reregister */ 
    } 
    sigprocmask(SIG_UNBLOCK, &newmask, NULL); /* unblock SIGUSR1 */ 
    exit(0); 
} 
else if(child_pid>0){ 
    for(;;){ 
     printf("client:"); 
     gets(buff_forward); 
     msgq_id=mq_open(argv[optind],O_WRONLY); 
     mq_send(msgq_id,buff_forward,MSG_SIZE,NULL); 
     mq_close(msgq_id); 
     mq_notify(msgq_id, &sigev); 
     while(mqflag==0) 
      sigsuspend(&zeromask); 
     mqflag==0; 
     msgq_id=mq_open(argv[optind],O_RDONLY); 
     mq_receive(msgq_id, buff_backward, attr.mq_msgsize, NULL); 
     printf("%s\n",buff_backward); 
     mq_close(msgq_id); 
     } 
    sigprocmask(SIG_UNBLOCK, &newmask, NULL); /* unblock SIGUSR1 */ 
    exit(0); 
    } 
return (EXIT_SUCCESS); 
} 
static void sig_usr1(int signo) { 
    mqflag = 1; 
    sigprocmask(SIG_BLOCK, &newmask, &oldmask); 
    return; 
} 

Answer 1

아이 (mq_flag 암시 적으로 0으로 초기화되고 중단에 대한 검사가 부적절하게 통지하기 전에 수행되기 때문에) 전에 sigsuspend이 mq_notify를 호출 호출합니다. 의도 한대로 절대로 깨울 수 없습니다.

차이점을 확인하려면 mq_flag을 1로 초기화하십시오. 리팩토링.

영업 이익은 실질적으로 코드를 변경, 그래서 나도이 대답을 변경

업데이트되었습니다.