ithewei 4 years ago
parent
commit
2683201366

+ 1 - 1
examples/multi-thread/multi-acceptor-threads.c

@@ -39,7 +39,7 @@ static void on_accept(hio_t* io) {
     hio_read(io);
 }
 
-static HTHREAD_RETTYPE loop_thread(void* userdata) {
+static HTHREAD_ROUTINE(loop_thread) {
     hloop_t* loop = hloop_new(HLOOP_FLAG_AUTO_FREE);
     haccept(loop, listenfd, on_accept);
     hloop_run(loop);

+ 2 - 2
examples/multi-thread/one-acceptor-multi-workers.c

@@ -64,13 +64,13 @@ static void on_accept(hio_t* io) {
     hloop_post_event(worker_loop, &ev);
 }
 
-static HTHREAD_RETTYPE worker_thread(void* userdata) {
+static HTHREAD_ROUTINE(worker_thread) {
     hloop_t* loop = (hloop_t*)userdata;
     hloop_run(loop);
     return 0;
 }
 
-static HTHREAD_RETTYPE accept_thread(void* userdata) {
+static HTHREAD_ROUTINE(accept_thread) {
     hloop_t* loop = (hloop_t*)userdata;
     hio_t* listenio = hloop_create_tcp_server(loop, host, port, on_accept);
     if (listenio == NULL) {

+ 2 - 2
examples/tinyhttpd.c

@@ -410,13 +410,13 @@ static void on_accept(hio_t* io) {
     hloop_post_event(worker_loop, &ev);
 }
 
-static HTHREAD_RETTYPE worker_thread(void* userdata) {
+static HTHREAD_ROUTINE(worker_thread) {
     hloop_t* loop = (hloop_t*)userdata;
     hloop_run(loop);
     return 0;
 }
 
-static HTHREAD_RETTYPE accept_thread(void* userdata) {
+static HTHREAD_ROUTINE(accept_thread) {
     hloop_t* loop = (hloop_t*)userdata;
     hio_t* listenio = hloop_create_tcp_server(loop, host, port, on_accept);
     if (listenio == NULL) {

+ 2 - 2
examples/tinyproxyd.c

@@ -433,13 +433,13 @@ static void on_accept(hio_t* io) {
     hloop_post_event(worker_loop, &ev);
 }
 
-static HTHREAD_RETTYPE worker_thread(void* userdata) {
+static HTHREAD_ROUTINE(worker_thread) {
     hloop_t* loop = (hloop_t*)userdata;
     hloop_run(loop);
     return 0;
 }
 
-static HTHREAD_RETTYPE accept_thread(void* userdata) {
+static HTHREAD_ROUTINE(accept_thread) {
     hloop_t* loop = (hloop_t*)userdata;
     hio_t* listenio = hloop_create_tcp_server(loop, proxy_host, proxy_port, on_accept);
     if (listenio == NULL) {