aboutsummaryrefslogtreecommitdiffstats
path: root/fs/common.c
diff options
context:
space:
mode:
Diffstat (limited to 'fs/common.c')
-rw-r--r--fs/common.c68
1 files changed, 0 insertions, 68 deletions
diff --git a/fs/common.c b/fs/common.c
deleted file mode 100644
index d810fb9..0000000
--- a/fs/common.c
+++ /dev/null
@@ -1,68 +0,0 @@
-#include <unistd.h>
-#include <stdlib.h>
-#include <sys/types.h>
-#include <stdatomic.h>
-
-#include "common.h"
-
-static int tabfs_to_ws[2];
-static int ws_to_tabfs[2];
-
-void common_init() {
- if (pipe(tabfs_to_ws)) exit(1);
- if (pipe(ws_to_tabfs)) exit(1);
-}
-
-// We probably technically need memory fences here? especially on
-// non-x86?? Are these right? idk. See
-// https://stackoverflow.com/questions/35837539/does-the-use-of-an-anonymous-pipe-introduce-a-memory-barrier-for-interthread-com
-// https://preshing.com/20120913/acquire-and-release-semantics/
-
-void common_send_tabfs_to_ws(char *request_data) {
- atomic_thread_fence(memory_order_release);
- write(tabfs_to_ws[1], &request_data, sizeof(request_data));
-}
-
-char *common_receive_tabfs_to_ws(fd_set_filler_fn_t filler) {
- fd_set read_fds, write_fds, except_fds;
- FD_ZERO(&read_fds);
- FD_ZERO(&write_fds);
- FD_ZERO(&except_fds);
-
- int max_fd = filler(&read_fds, &write_fds, &except_fds);
-
- FD_SET(tabfs_to_ws[0], &read_fds);
- if (tabfs_to_ws[0] > max_fd) { max_fd = tabfs_to_ws[0]; }
-
- struct timeval timeout;
- timeout.tv_sec = 0;
- timeout.tv_usec = 200000;
-
- select(max_fd + 1, &read_fds, &write_fds, &except_fds, &timeout);
-
- if (!FD_ISSET(tabfs_to_ws[0], &read_fds)) {
- // We can't read from tabfs_to_ws right now. Could be that it
- // timed out, could be that we got a websocket event instead,
- // whatever.
-
- return NULL;
- }
-
- char *request_data;
- read(tabfs_to_ws[0], &request_data, sizeof(request_data));
- atomic_thread_fence(memory_order_acquire);
-
- return request_data;
-}
-
-void common_send_ws_to_tabfs(char *response_data) {
- atomic_thread_fence(memory_order_release);
- write(ws_to_tabfs[1], &response_data, sizeof(response_data));
-}
-char *common_receive_ws_to_tabfs() {
- char *response_data;
- read(ws_to_tabfs[0], &response_data, sizeof(response_data));
- atomic_thread_fence(memory_order_acquire);
-
- return response_data;
-}