Glue things together into a pipeline

1 files changed, 47 insertions, 0 deletions

diff --git a/collect.c b/collect.c
new file mode 100644
index 0000000..875213a
--- /dev/null
+++ b/collect.c
@@ -0,0 +1,47 @@
+/*
+ * Live variable collector
+ * Copyright (C) 2021, 2023  Gregory James Duck
+ * Copyright (C) 2024  Nguyễn Gia Phong
+ *
+ * This file is part of taosc.
+ *
+ * Taosc is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU Affero General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * Taosc 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 Affero General Public License for more details.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with taosc.  If not, see <https://www.gnu.org/licenses/>.
+ */
+
+#include "stdlib.c"
+
+char *path;
+
+void init(int argc, const char *const *argv, const char **envp)
+{
+	environ = envp;
+	path = getenv("TAOSC_COLLECT"); /* TODO: fopen */
+	setvbuf(stderr, NULL, _IOFBF, 0);
+}
+
+
+void log(const struct STATE *state)
+{
+	static mutex_t mutex = MUTEX_INITIALIZER;
+	if (mutex_lock(&mutex) < 0)
+		return;
+	clearerr(stderr);
+	fprintf(stderr, "[begin]\n");
+	const int64_t *const env = (const int64_t *) state;
+	for (unsigned char i = 1; i < sizeof(state) / sizeof(int64_t); ++i)
+		fprintf(stderr, "%hhu %lld\n", i, env[i]);
+	fprintf(stderr, "[end]\n");
+	fflush(stderr);
+	mutex_unlock(&mutex);
+}