diff options
Diffstat (limited to 'platform/src/main.cpp')
| -rw-r--r-- | platform/src/main.cpp | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/platform/src/main.cpp b/platform/src/main.cpp index 88cb26e..ae532b2 100644 --- a/platform/src/main.cpp +++ b/platform/src/main.cpp @@ -81,7 +81,7 @@ static void *worker_thread_cycle(void *arg) snprintf(thread_name, sizeof(thread_name), "sce:worker-%d", thread_index); prctl(PR_SET_NAME, (unsigned long long)thread_name, NULL, NULL, NULL); - if (packet_io_thread_init(handle, thread_ctx) != 0) + if (packet_io_init(handle, thread_ctx) != 0) { goto error_out; } @@ -90,9 +90,9 @@ static void *worker_thread_cycle(void *arg) while (!ATOMIC_READ(&is_need_stop)) { - n_packet_recved = packet_io_thread_polling_nf(handle, thread_ctx); - n_packet_recved += packet_io_thread_polling_endpoint_l3(handle, thread_ctx); - n_packet_recved += packet_io_thread_polling_endpoint_l2(handle, thread_ctx); + n_packet_recved = packet_io_polling_nf(handle, thread_ctx); + n_packet_recved += packet_io_polling_endpoint_l3(handle, thread_ctx); + n_packet_recved += packet_io_polling_endpoint_l2(handle, thread_ctx); if (n_packet_recved == 0) { timeout_ms = sf_metrics_last_send_ts + sf_metrics_send_interval - timestamp_get_msec(ts); @@ -101,7 +101,7 @@ static void *worker_thread_cycle(void *arg) timeout_ms = 0; } - packet_io_thread_wait(handle, thread_ctx, timeout_ms); + packet_io_wait(handle, thread_ctx, timeout_ms); } global_metrics_update(global_metrics, thread_metrics, thread_index); |