diff options
Diffstat (limited to 'mq_ntf.c')
| -rw-r--r-- | mq_ntf.c | 12 |
1 files changed, 6 insertions, 6 deletions
@@ -100,8 +100,8 @@ int mq_ntf_select(mq_ntf_mdt *mq, int dir) //PNL(); FD_ZERO(&io_fds); FD_SET(fd, &io_fds); - tv.tv_sec = 3; - tv.tv_usec = 0; + tv.tv_sec = 0; + tv.tv_usec = 100000; //PNL(); //first argument magic numbder fdnum = select(fd+1, @@ -156,12 +156,12 @@ int mq_ntf_read(mq_ntf_mdt *mq, int dir, char *buf, size_t size) printf("queue %d out full\n", mq->id); return -1; } - PNL(); + //PNL(); /*bytes = mq_receive(mqd, buf, size > attr.mq_msgsize ? attr.mq_msgsize : size, &prio);*/ bytes = mq_receive(mqd, buf, size, &prio); - PNL(); + //PNL(); if (bytes == -1) { perror("mq_receive read out"); @@ -196,12 +196,12 @@ int mq_ntf_write(mq_ntf_mdt *mq, int dir, const char *buf, size_t size) printf("queue %d out full\n", mq->id); return -1; } - PNL(); + //PNL(); /*bytes = mq_send(mqd, buf, size > attr.mq_msgsize ? attr.mq_msgsize : size, prio);*/ bytes = mq_send(mqd, buf, size, prio); - PNL(); + //PNL(); if (bytes == -1) { perror("mq_send"); |