- reply = containerof(msg_get(&test_portMain), TestMsg, msg);
- if(reply == NULL)
- break;
- count += reply->result;
- kprintf("Main recv[%d] count[%d]\n", reply->result, count);
+ while ((reply = (TestMsg *)msg_get(&test_portMain)))
+ {
+ count += reply->result;
+ kprintf("Main recv[%d] count[%d]\n", reply->result, count);
+ }
+ }
+
+ if (process_num == 6)
+ break;
+
+ if (sigs & SIG_TIMEOUT)
+ {
+ kputs("Main: sig timeout\n");
+ goto error;