From 74d3ec514aa480b3cd92c849879f8705db9cb196 Mon Sep 17 00:00:00 2001 From: Christoph Kuhr Date: Tue, 12 Feb 2019 09:33:38 +0100 Subject: [PATCH] simple_client_timestamps --- example-clients/simple_client.c | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/example-clients/simple_client.c b/example-clients/simple_client.c index 90383ad8..c3ad2481 100644 --- a/example-clients/simple_client.c +++ b/example-clients/simple_client.c @@ -83,16 +83,16 @@ void *worker_thread_listener_fileWriter() tim.tv_sec = 0; tim.tv_nsec = 300000; - *tsq = mq_open(Q_NAME, O_RDWR | O_NONBLOCK); + mqd_t *tsq2 = mq_open(Q_NAME, O_RDWR | O_NONBLOCK); char msg_recv[Q_MSG_SIZE]; while(1){ - if ( mq_receive(tsq, msg_recv, Q_MSG_SIZE, NULL) > 0) { + if ( mq_receive(*tsq2, msg_recv, Q_MSG_SIZE, NULL) > 0) { fprintf(filepointer, "%s\n",msg_recv);fflush(filepointer); } else { if(errno != EAGAIN){ - fprintf(filepointer, "[Q %d] recv error %d %s %s\n", tsq, errno, strerror(errno), msg_recv);fflush(filepointer); + fprintf(filepointer, "recv error %d %s %s\n", errno, strerror(errno), msg_recv);fflush(filepointer); } } nanosleep(&tim , NULL); @@ -119,7 +119,7 @@ process (jack_nframes_t nframes, void *arg) sprintf (msg_send, "%x", (sys_time.tv_sec*1000000000ULL + sys_time.tv_nsec)); if (mq_send(tsq, msg_send, Q_MSG_SIZE, NULL) < 0) { - fprintf(filepointer, "[Q %d] send error %d %s %s\n", *tsq, errno, strerror(errno), msg_send);fflush(filepointer); + fprintf(filepointer, "send error %d %s %s\n", errno, strerror(errno), msg_send);fflush(filepointer); } out1 = (jack_default_audio_sample_t*)jack_port_get_buffer (output_port1, nframes); @@ -190,15 +190,15 @@ main (int argc, char *argv[]) if( mq_unlink(Q_NAME) < 0) { - fprintf(filepointer, "[Q %d] unlink %s error %d %s\n", *tsq, Q_NAME, errno, strerror(errno));fflush(filepointer); + fprintf(filepointer, "unlink %s error %d %s\n", Q_NAME, errno, strerror(errno));fflush(filepointer); } else { - fprintf(filepointer, "[Q %d] unlink %s success\n", *tsq, Q_NAME );fflush(filepointer); + fprintf(filepointer, "unlink %s success\n", Q_NAME );fflush(filepointer); } if ((*tsq = mq_open(Q_NAME, O_RDWR | O_CREAT | O_NONBLOCK | O_EXCL, 0666, &attr)) == -1) { - fprintf(filepointer, "[Q %d] create error %s %d %s\n", *tsq, Q_NAME, errno, strerror(errno));fflush(filepointer); + fprintf(filepointer, "create error %s %d %s\n", Q_NAME, errno, strerror(errno));fflush(filepointer); } else { - fprintf(filepointer, "[Q %d] create success %s\n", *tsq, Q_NAME);fflush(filepointer); + fprintf(filepointer, "create success %s\n", Q_NAME);fflush(filepointer); } if( pthread_create( &writerThread, NULL, (&worker_thread_listener_fileWriter), NULL) != 0 ) {