83 	mqd_t mqd;  member
93 static void remove_mqueue(mqd_t mqd)  in remove_mqueue()  argument
95 	mq_close(mqd);  in remove_mqueue()
103 static void cleanup_resources(int step, mqd_t mqd)  in cleanup_resources()  argument
110 		mq_close(mqd);  in cleanup_resources()
114 		remove_mqueue(mqd);  in cleanup_resources()
119 		ltp_syscall(__NR_mq_notify, mqd, NULL);  in cleanup_resources()
122 		remove_mqueue(mqd);  in cleanup_resources()
138 void cleanup_mqueue(int result, int step, mqd_t mqd)  in cleanup_mqueue()  argument
141 		cleanup_resources(step, mqd);  in cleanup_mqueue()
152 	mqd_t mqd;  in child_fn()  local
175 	mqd = ltp_syscall(__NR_mq_open, mqname, O_WRONLY, 0, NULL);  in child_fn()
176 	if (mqd == (mqd_t) - 1) {  in child_fn()
183 	if (mq_send(mqd, MSG, strlen(MSG), MSG_PRIO) == (mqd_t) - 1) {  in child_fn()
186 		cleanup_mqueue(TBROK, C_STEP_0, mqd);  in child_fn()
191 	cleanup_resources(C_STEP_1, mqd);  in child_fn()
237 	if (!mq_getattr(info->mqd, &attr))  in father_signal_handler()
238 		mq_receive(info->mqd, buf, attr.mq_msgsize, NULL);  in father_signal_handler()
254 	mqd_t mqd;  in main()  local
268 	mqd =  in main()
271 	if (mqd == (mqd_t) - 1) {  in main()
282 		cleanup_mqueue(TBROK, F_STEP_1, mqd);  in main()
289 	info.mqd = mqd;  in main()
292 	if (ltp_syscall(__NR_mq_notify, mqd, &notif) == (mqd_t) -1) {  in main()
295 		cleanup_mqueue(TBROK, F_STEP_1, mqd);  in main()
306 		cleanup_mqueue(TBROK, F_STEP_2, mqd);  in main()
316 		cleanup_mqueue(TBROK, F_STEP_2, mqd);  in main()
324 		cleanup_mqueue(TBROK, F_STEP_1, mqd);  in main()
327 	cleanup_mqueue(result, F_STEP_3, mqd);  in main()