summaryrefslogtreecommitdiff
path: root/main.c
diff options
context:
space:
mode:
Diffstat (limited to 'main.c')
-rw-r--r--main.c95
1 files changed, 95 insertions, 0 deletions
diff --git a/main.c b/main.c
new file mode 100644
index 0000000..fcc7511
--- /dev/null
+++ b/main.c
@@ -0,0 +1,95 @@
+/*
+ * Copyright (C) 2023 Mikhail Burakov. This file is part of receiver.
+ *
+ * receiver is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * receiver is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with receiver. If not, see <https://www.gnu.org/licenses/>.
+ */
+
+#include <errno.h>
+#include <poll.h>
+#include <signal.h>
+#include <stddef.h>
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+#include <unistd.h>
+
+#include "decode.h"
+#include "util.h"
+#include "window.h"
+
+static volatile sig_atomic_t g_signal;
+static void OnSignal(int status) { g_signal = status; }
+
+int main(int argc, char* argv[]) {
+ (void)argc;
+ (void)argv;
+
+ struct AUTO(DecodeContext)* decode_context = DecodeContextCreate();
+ if (!decode_context) {
+ LOG("Failed to create decode context");
+ return EXIT_FAILURE;
+ }
+
+ struct AUTO(Window)* window = WindowCreate();
+ if (!window) {
+ LOG("Failed to create window");
+ return EXIT_FAILURE;
+ }
+
+ int events_fd = WindowGetEventsFd(window);
+ if (events_fd == -1) {
+ LOG("Failed to get events fd");
+ return EXIT_FAILURE;
+ }
+
+ if (signal(SIGINT, OnSignal) == SIG_ERR ||
+ signal(SIGTERM, OnSignal) == SIG_ERR) {
+ LOG("Failed to set signal handlers (%s)", strerror(errno));
+ return EXIT_FAILURE;
+ }
+
+ while (!g_signal) {
+ struct pollfd pfds[] = {
+ {.fd = STDIN_FILENO, .events = POLLIN},
+ {.fd = events_fd, .events = POLLIN},
+ };
+ switch (poll(pfds, LENGTH(pfds), -1)) {
+ case -1:
+ if (errno != EINTR) {
+ LOG("Failed to poll (%s)", strerror(errno));
+ return EXIT_FAILURE;
+ }
+ __attribute__((fallthrough));
+ case 0:
+ continue;
+ default:
+ break;
+ }
+ if (pfds[0].revents && !DecodeContextDecode(decode_context, STDIN_FILENO)) {
+ LOG("Failed to decode incoming data");
+ return EXIT_FAILURE;
+ }
+ if (pfds[1].revents && !WindowProcessEvents(window)) {
+ LOG("Failed to process window events");
+ return EXIT_FAILURE;
+ }
+ const struct Frame* frame = DecodeContextGetFrame(decode_context);
+ if (frame && !WindowRenderFrame(window, frame)) {
+ LOG("Failed to render frame");
+ return EXIT_FAILURE;
+ }
+ }
+
+ return EXIT_SUCCESS;
+}