Request/Response between threads now works

1 files changed, 6 insertions, 6 deletions

diff --git a/mq_ntf.c b/mq_ntf.c
index d7c119b..dbeb9b8 100644
--- a/mq_ntf.c
+++ b/mq_ntf.c
@@ -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");