aboutsummaryrefslogtreecommitdiffstats
path: root/fs/common.c
blob: f651009ea669265b4e40bf8086e3609605b92f82 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
#include <unistd.h>
#include <stdlib.h>
#include <sys/types.h>

#include <sys/time.h>
#include <stdio.h>
#include <signal.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);
}

void common_send_tabfs_to_ws(char *request_data) {
  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));

  return request_data;
}

void common_send_ws_to_tabfs(char *response_data) {
  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));

  return response_data;
}