mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-12-20 07:16:55 +00:00
Code Issues 1 Projects Releases Wiki Activity

pluginloader-win32: Check pipe state in child process

Browse source 
Retry if server is not ready for the connection

Part-of: <https://gitlab.freedesktop.org/gstreamer/gstreamer/-/merge_requests/3863>
This commit is contained in:
Seungha Yang 2023-02-02 00:19:55 +09:00 committed by GStreamer Marge Bot
parent 0df7cd852c
commit 464a8be3a4
1 changed files with 18 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
subprojects/gstreamer/gst/gstpluginloader-win32.c
View file

@ -1152,12 +1152,26 @@ _gst_plugin_loader_client_run (const gchar * pipe_name)
GENERIC_READ | GENERIC_WRITE, 0, NULL, OPEN_EXISTING, GENERIC_READ | GENERIC_WRITE, 0, NULL, OPEN_EXISTING,
FILE_FLAG_OVERLAPPED, NULL); FILE_FLAG_OVERLAPPED, NULL);
loader.last_err = GetLastError (); loader.last_err = GetLastError ();
if (loader.pipe == INVALID_HANDLE_VALUE) {
/* Server should be pending (waiting for connection) state already,
* but do retry if it's not the case */
if (loader.last_err == ERROR_PIPE_BUSY) {
if (WaitNamedPipeA (pipe_name, 5000)) {
loader.pipe = CreateFileA (pipe_name,
GENERIC_READ | GENERIC_WRITE, 0, NULL, OPEN_EXISTING,
FILE_FLAG_OVERLAPPED, NULL);
}
loader.last_err = GetLastError ();
}
if (loader.pipe == INVALID_HANDLE_VALUE) { if (loader.pipe == INVALID_HANDLE_VALUE) {
err = g_win32_error_message (loader.last_err); err = g_win32_error_message (loader.last_err);
GST_ERROR ("CreateFileA failed with 0x%x (%s)", GST_ERROR ("CreateFileA failed with 0x%x (%s)",
loader.last_err, GST_STR_NULL (err)); loader.last_err, GST_STR_NULL (err));
goto out; goto out;
} }
}
/* We use message mode */ /* We use message mode */
if (!SetNamedPipeHandleState (loader.pipe, &pipe_mode, NULL, NULL)) { if (!SetNamedPipeHandleState (loader.pipe, &pipe_mode, NULL, NULL)) {