comparison c/plosc.c @ 4:8a71c55816be

Put server loop timeout in server structure and set to 50ms default.

 // Prolog from the server thread.
 
 typedef struct _my_server_thread {
 	lo_server    s;
 	pthread_t    thread;
+	int          timeout;
 	volatile int active;
 	volatile int done;
 } *my_server_thread;
 
 int my_server_thread_start(my_server_thread st);
 int my_server_thread_stop(my_server_thread st);
-int my_server_thread_run(my_server_thread st, int timeout);
+int my_server_thread_run(my_server_thread st);
 void my_server_thread_free(my_server_thread st);
 my_server_thread my_server_thread_new(const char *port, lo_err_handler err_h);
 
 // ---------------------------------------------------------------------------
 

 }
 */
 
 // run OSC server in this thread but with an extra message handler
 // to allow the /plosc/stop message to terminate the loop.
-static int run_stoppable_server(my_server_thread s, int timeout)
+static int run_stoppable_server(my_server_thread s)
 {
 	lo_server_add_method(s->s, "/plosc/stop", NULL, stop_handler, (void *)s);
-	my_server_thread_run(s,timeout);
+	my_server_thread_run(s);
 	lo_server_del_method(s->s,"/plosc/stop",NULL);
 	return TRUE;
 }
 
 foreign_t mk_server(term_t port, term_t server)

 
 foreign_t run_server( term_t server)
 {
 	my_server_thread s;
 	printf("running OSC server synchronously...\n");
-	return get_server(server,&s) && run_stoppable_server(s,10);
+	return get_server(server,&s) && run_stoppable_server(s);
 }
 
 
 // -------------------------------------------------------------------------
 // my_server_thread implementation
 
 my_server_thread my_server_thread_new(const char *port, lo_err_handler err_h)
 {
 	my_server_thread st = malloc(sizeof(struct _my_server_thread));
 	st->s = lo_server_new(port, err_h);
+	st->timeout= 100; // will check st->active at 10Hz.
 	st->active = 0;
 	st->done = 0;
 
 	if (!st->s) {
 		free(st);

 	
 	}
     return 0;
 }
 
-int my_server_thread_run(my_server_thread st, int timeout)
-{
+int my_server_thread_run(my_server_thread st)
+{
+	int timeout=st->timeout;
+
 	st->active = 1;
 	st->done = 0;
 	while (st->active) {
 		lo_server_recv_noblock(st->s, timeout);
 	}

 {
 	my_server_thread st = (my_server_thread)data;
 
 	printf("OSC server started.\n");
 	PL_thread_attach_engine(NULL);
-	my_server_thread_run(st,50);
+	my_server_thread_run(st);
 	PL_thread_destroy_engine(); 
 	printf("OSC server stopped.\n");
 	pthread_exit(NULL);
 }