| 74 | pthread_exit((void *)0); |
| 75 | } |
| 76 | int * receive_2(void * mq) |
| 77 | { |
| 78 | int i; |
| 79 | mqd_t mq2 = *(mqd_t *)mq; |
| 80 | |
| 81 | printf("Enter into receive_2 \n"); |
| 82 | for (i = 0; i< MAX_MSG; i++) { |
| 83 | if ( -1 == mq_receive(mq2, r_msg_ptr_2[i], MSG_SIZE, NULL) ) { |
| 84 | perror("mq_receive doesn't return success \n"); |
| 85 | pthread_exit((void *)1); |
| 86 | } |
| 87 | printf("[%d] receive '%s' in thread receive_2. \n", i+1, r_msg_ptr_2[i]); |
| 88 | } |
| 89 | pthread_exit((void *)0); |
| 90 | } |
| 91 | |
| 92 | int libc_mq() |
| 93 | { |
nothing calls this directly
no test coverage detected