add more event_thread test and cq full test

This commit is contained in:
lyon 2023-06-10 16:24:58 +08:00
parent 4a80729460
commit 5e30d7482b
2 changed files with 6 additions and 1 deletions

View File

@ -27,7 +27,8 @@
// "--gtest_filter=builtin.getitem" // "--gtest_filter=builtin.getitem"
// "--gtest_filter=except.isinstance" // "--gtest_filter=except.isinstance"
// "--gtest_filter=vm.range_1" // "--gtest_filter=vm.range_1"
"--gtest_filter=eventloop.*" // "--gtest_filter=eventloop.*"
"--gtest_filter=event.event_thread"
], ],
"stopAtEntry": false, "stopAtEntry": false,
"cwd": "${workspaceFolder}", "cwd": "${workspaceFolder}",

View File

@ -2738,9 +2738,11 @@ static void _thread_event(void* arg) {
_VMEvent_pickupEvent(); _VMEvent_pickupEvent();
pika_GIL_EXIT(); pika_GIL_EXIT();
pika_platform_thread_yield(); pika_platform_thread_yield();
#if PIKA_EVENT_ENABLE
if (g_PikaVMSignal.event_thread_exit) { if (g_PikaVMSignal.event_thread_exit) {
break; break;
} }
#endif
} }
} }
@ -2769,6 +2771,7 @@ void _do_pika_eventListener_send(PikaEventListener* self,
/* push event handler to vm event list */ /* push event handler to vm event list */
if (PIKA_RES_OK != __eventListener_pushEvent(self, eventId, eventData)) { if (PIKA_RES_OK != __eventListener_pushEvent(self, eventId, eventData)) {
goto __exit;
} }
if (pickupWhenNoVM) { if (pickupWhenNoVM) {
int vmCnt = _VMEvent_getVMCnt(); int vmCnt = _VMEvent_getVMCnt();
@ -2778,6 +2781,7 @@ void _do_pika_eventListener_send(PikaEventListener* self,
_VMEvent_pickupEvent(); _VMEvent_pickupEvent();
} }
} }
__exit:
pika_GIL_EXIT(); pika_GIL_EXIT();
#endif #endif
} }