apio/Luna
1
1
Fork 0
Code Issues Pull Requests Actions Projects Releases 8 Wiki Activity

wind+libos+libui: Handle interrupted reads properly

Browse Source
This commit is contained in:
apio 2023-08-16 16:48:39 +02:00
parent 8c4e9dff96
commit 7e7f0a96f5
Signed by: apio
GPG Key ID: B8A7D06E42258954
4 changed files with 29 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
libos/include/os/IPC.h
View File

@ -102,7 +102,7 @@ namespace os
{
u8 response_id;
auto rc = client.recv_typed(response_id);
if (rc.has_error() && rc.error() == EAGAIN) continue;
if (rc.has_error() && (rc.error() == EAGAIN || rc.error() == EINTR)) continue;
if (response_id == 0) // Error result
{
@ -110,7 +110,7 @@ namespace os
{
int code;
rc = client.recv_typed(code);
if (rc.has_error() && rc.error() == EAGAIN) continue;
if (rc.has_error() && (rc.error() == EAGAIN || rc.error() == EINTR)) continue;
return err(code);
}
}
@ -126,7 +126,7 @@ namespace os
{
ResponseType response;
rc = client.recv_typed(response);
if (rc.has_error() && rc.error() == EAGAIN) continue;
if (rc.has_error() && (rc.error() == EAGAIN || rc.error() == EINTR)) continue;
return response;
}
}

4
libos/src/IPC.cpp
View File

@ -18,6 +18,8 @@ namespace os::IPC
if (rc.has_error())
{
if (rc.error() == EAGAIN) return {}; // No messages, and the caller does not want us to block.
if (rc.error() == EINTR)
return {}; // Let the caller check for anything having happened because a signal handler ran.
return rc.release_error();
}
@ -31,6 +33,8 @@ namespace os::IPC
if (rc.has_error())
{
if (rc.error() == EAGAIN) return {}; // No messages, and the caller does not want us to block.
if (rc.error() == EINTR)
return {}; // Let the caller check for anything having happened because a signal handler ran.
return rc.release_error();
}

17
libui/src/App.cpp
View File

@ -88,13 +88,26 @@ namespace ui
return window->ptr();
}
#define READ_MESSAGE(request) \
do { \
auto rc = m_client->recv_typed(request); \
if (rc.has_error()) \
{ \
if (rc.error() == EAGAIN) { continue; } \
if (rc.error() == EINTR) { continue; } \
else \
return rc.release_error(); \
} \
break; \
} while (true)
Result<void> App::handle_ipc_event(u8 id)
{
switch (id)
{
case WINDOW_CLOSE_REQUEST_ID: {
WindowCloseRequest request;
TRY(m_client->recv_typed(request));
READ_MESSAGE(request);
os::eprintln("ui: Window close request from server! Shall comply.");
auto* window = find_window(request.window);
window->close();
@ -102,7 +115,7 @@ namespace ui
}
case MOUSE_EVENT_REQUEST_ID: {
MouseEventRequest request;
TRY(m_client->recv_typed(request));
READ_MESSAGE(request);
auto* window = find_window(request.window);
window->handle_mouse_move(request.position);
window->handle_mouse_buttons(request.position, request.buttons);

7
wind/IPC.cpp
View File

@ -68,6 +68,12 @@ static Result<u32*> create_shm_region(const char* path, int* outfd, ui::Rect rec
client.rpc_id = decltype(request)::ID; \
return {}; \
} \
if (rc.error() == EINTR) \
{ \
client.rpc_in_progress = true; \
client.rpc_id = decltype(request)::ID; \
return {}; \
} \
else \
return rc.release_error(); \
} \
@ -202,6 +208,7 @@ namespace wind
if (rc.has_error())
{
if (rc.error() == EAGAIN) { return {}; }
if (rc.error() == EINTR) { return {}; }
else
return rc.release_error();
}