|
|
|
@@ -34,7 +34,6 @@ |
|
|
|
jack_port_t *output_port1, *output_port2; |
|
|
|
jack_client_t *client; |
|
|
|
pthread_t writerThread; |
|
|
|
FILE* filepointer; |
|
|
|
mqd_t tsq; |
|
|
|
char msg_send[Q_MSG_SIZE]; |
|
|
|
|
|
|
|
@@ -65,7 +64,6 @@ static void signal_handler(int sig) |
|
|
|
} else { |
|
|
|
fprintf(filepointer, "close success\n" );fflush(filepointer); |
|
|
|
} |
|
|
|
fclose(filepointer); |
|
|
|
exit(0); |
|
|
|
} |
|
|
|
|
|
|
|
@@ -80,18 +78,23 @@ static void signal_handler(int sig) |
|
|
|
void *worker_thread_listener_fileWriter() |
|
|
|
{ |
|
|
|
struct timespec tim; |
|
|
|
FILE* filepointer; |
|
|
|
|
|
|
|
tim.tv_sec = 0; |
|
|
|
tim.tv_nsec = 300000; |
|
|
|
|
|
|
|
if( ! (filepointer = fopen("client_ts.log", "a")) ){ |
|
|
|
if( ! (filepointer = fopen("client_ts.log", "w")) ){ |
|
|
|
printf("Error Opening file %d\n", errno); |
|
|
|
pthread_exit((void*)-1); |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
fprintf(filepointer, "Started Filewriter Thread\n");//fflush(filepointer); |
|
|
|
|
|
|
|
mqd_t tsq2 = mq_open(Q_NAME, O_RDWR | O_NONBLOCK); |
|
|
|
char msg_recv[Q_MSG_SIZE]; |
|
|
|
|
|
|
|
|
|
|
|
while(1){ |
|
|
|
|
|
|
|
if ( mq_receive(tsq2, msg_recv, Q_MSG_SIZE, NULL) > 0) { |
|
|
|
@@ -103,6 +106,7 @@ void *worker_thread_listener_fileWriter() |
|
|
|
} |
|
|
|
nanosleep(&tim , NULL); |
|
|
|
} |
|
|
|
fclose(filepointer); |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|