4
0
mirror of git://sourceware.org/git/newlib-cygwin.git synced 2025-03-04 05:55:38 +08:00

Cygwin: console: Fix race issue regarding cons_master_thread().

- With this patch, the race issue regarding starting/stopping
  cons_master_thread() introduced by commit ff4440fc is fixed.

  Addresses:
    https://cygwin.com/pipermail/cygwin/2021-April/248292.html
This commit is contained in:
Takashi Yano 2021-04-19 19:30:45 +09:00 committed by Corinna Vinschen
parent 9c6c2fb0f6
commit b4fc81edcc

View File

@ -48,6 +48,7 @@ details. */
#define con_is_legacy (shared_console_info && con.is_legacy) #define con_is_legacy (shared_console_info && con.is_legacy)
#define CONS_THREAD_SYNC "cygcons.thread_sync" #define CONS_THREAD_SYNC "cygcons.thread_sync"
static bool NO_COPY master_thread_started = false;
const unsigned fhandler_console::MAX_WRITE_CHARS = 16384; const unsigned fhandler_console::MAX_WRITE_CHARS = 16384;
@ -184,6 +185,7 @@ cons_master_thread (VOID *arg)
GetCurrentProcess (), &thread_sync_event, GetCurrentProcess (), &thread_sync_event,
0, FALSE, DUPLICATE_SAME_ACCESS); 0, FALSE, DUPLICATE_SAME_ACCESS);
SetEvent (thread_sync_event); SetEvent (thread_sync_event);
master_thread_started = true;
/* Do not touch class members after here because the class instance /* Do not touch class members after here because the class instance
may have been destroyed. */ may have been destroyed. */
fhandler_console::cons_master_thread (&handle_set, ttyp); fhandler_console::cons_master_thread (&handle_set, ttyp);
@ -370,6 +372,8 @@ fhandler_console::set_unit ()
} }
if (!created && shared_console_info) if (!created && shared_console_info)
{ {
while (con.owner > MAX_PID)
Sleep (1);
pinfo p (con.owner); pinfo p (con.owner);
if (!p) if (!p)
con.owner = myself->pid; con.owner = myself->pid;
@ -1393,14 +1397,16 @@ fhandler_console::close ()
release_output_mutex (); release_output_mutex ();
if (shared_console_info && con.owner == myself->pid) if (shared_console_info && con.owner == myself->pid
&& master_thread_started)
{ {
char name[MAX_PATH]; char name[MAX_PATH];
shared_name (name, CONS_THREAD_SYNC, get_minor ()); shared_name (name, CONS_THREAD_SYNC, get_minor ());
thread_sync_event = OpenEvent (MAXIMUM_ALLOWED, FALSE, name); thread_sync_event = OpenEvent (MAXIMUM_ALLOWED, FALSE, name);
con.owner = 0; con.owner = MAX_PID + 1;
WaitForSingleObject (thread_sync_event, INFINITE); WaitForSingleObject (thread_sync_event, INFINITE);
CloseHandle (thread_sync_event); CloseHandle (thread_sync_event);
con.owner = 0;
} }
CloseHandle (input_mutex); CloseHandle (input_mutex);