paul
/
monocoque
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Improve handling of shutdown when in udp mode

This commit is contained in:
Paul Dino Jones 2026-01-27 01:43:01 -05:00
parent d047543c19
commit 835b04fc13
1 changed files with 21 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
src/monocoque/gameloop/gameloop.c
View File

@ -39,6 +39,15 @@ void showstatscallback(uv_timer_t* handle);
void datacheckcallback(uv_timer_t* handle); void datacheckcallback(uv_timer_t* handle);
void startdatalogger(MonocoqueSettings* ms, loop_data* l); void startdatalogger(MonocoqueSettings* ms, loop_data* l);
static void close_walk_cb(uv_handle_t* handle, void* arg)
{
if (!uv_is_closing(handle))
{
uv_close(handle, NULL);
}
}
#define ASSERT(expr) expr
int showstats(SimData* simdata) int showstats(SimData* simdata)
{ {
printf("\r"); printf("\r");
@ -339,7 +348,7 @@ void showstatscallback(uv_timer_t* handle)
void releaseloop(loop_data* f, SimData* simdata, SimMap* simmap) void releaseloop(loop_data* f, SimData* simdata, SimMap* simmap)
{ {
slogi("release loop");
if(f->releasing == false) if(f->releasing == false)
{ {
f->releasing = true; f->releasing = true;
@ -408,6 +417,7 @@ void releaseloop(loop_data* f, SimData* simdata, SimMap* simmap)
if(appstate > 0) if(appstate > 0)
{ {
slogi("restarting data check timer");
uv_timer_start(&datachecktimer, datacheckcallback, 3000, 1000); uv_timer_start(&datachecktimer, datacheckcallback, 3000, 1000);
} }
f->releasing = false; f->releasing = false;
@ -493,7 +503,6 @@ void udpstart(MonocoqueSettings* sms, loop_data* f, SimData* simdata, SimMap* si
{ {
if (appstate == 2) if (appstate == 2)
{ {
fprintf(stderr, "udpstart\n");
simdatamap(simdata, simmap, NULL, f->sim, true, NULL); simdatamap(simdata, simmap, NULL, f->sim, true, NULL);
if (doui == true) if (doui == true)
{ {
@ -540,6 +549,7 @@ void datacheckcallback(uv_timer_t* handle)
udpstart(f->ms, f, simdata, simmap); udpstart(f->ms, f, simdata, simmap);
uv_udp_recv_start(&recv_socket, on_alloc, on_udp_recv); uv_udp_recv_start(&recv_socket, on_alloc, on_udp_recv);
slogt("udp receive loop started"); slogt("udp receive loop started");
uv_timer_stop(handle);
} }
else else
{ {
@ -547,7 +557,7 @@ void datacheckcallback(uv_timer_t* handle)
slogd("starting telemetry mapping at %i fps (%i ms ticks)", f->ms->fps, interval); slogd("starting telemetry mapping at %i fps (%i ms ticks)", f->ms->fps, interval);
uv_timer_start(&datamaptimer, shmdatamapcallback, 2000, interval); uv_timer_start(&datamaptimer, shmdatamapcallback, 2000, interval);
} }
//uv_timer_stop(handle); //uv_timer_start(&datachecktimer, datacheckcallback, 0, 3000);
} }
if(appstate == 2) if(appstate == 2)
{ {
@ -562,7 +572,7 @@ void datacheckcallback(uv_timer_t* handle)
if (appstate == 0) if (appstate == 0)
{ {
slogi("stopping checking for data"); slogi("stopped checking for data");
uv_timer_stop(handle); uv_timer_stop(handle);
} }
} }
@ -587,8 +597,15 @@ void cb(uv_poll_t* handle, int status, int events)
if (appstate == 0) if (appstate == 0)
{ {
slogi("Monocoque is exiting..."); slogi("Monocoque is exiting...");
uv_udp_recv_stop(&recv_socket);
uv_timer_stop(&datachecktimer); uv_timer_stop(&datachecktimer);
uv_timer_stop(&datamaptimer);
uv_timer_stop(&showstatstimer);
uv_poll_stop(handle); uv_poll_stop(handle);
uv_walk(uv_default_loop(), close_walk_cb, NULL);
uv_loop_close(uv_default_loop());
uv_library_shutdown();
slogi("All threads stopped...");
} }
} }