about summary refs log tree commit diff
path: root/collect.c
blob: dc009f198243da12c545076c6f67916a48537043 (plain) (blame)
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
63
64
65
66
/*
 * Live variable collector
 * Copyright (C) 2024-2025  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"

static uint32_t stack_size;
static int output_file = -1;

/*
 * Get an environment variable and parse as a number.
 * Return 0 on error.
 */
uint32_t getenvul(const char *name)
{
	const char *const str = getenv(name);
	if (str == NULL)
		return 0ULL;
	errno = 0;
	const uint32_t ul = strtoul(str, NULL, 0);
	if (errno)
		return 0ULL;
	return ul;
}

void init(int argc, const char *const *argv, char **envp)
{
	environ = envp;
	stack_size = getenvul("TAOSC_STACK_SIZE");
	const char *const path = getenv("TAOSC_OUTPUT");
	if (path != NULL)
		output_file = open(path, O_WRONLY | O_CREAT, 0644);
	if (output_file == -1) {
		const char *msg = "cannot open $TAOSC_OUTPUT for writing\n";
		write(2, msg, strlen(msg));
		fsync(2);
		exit(128);
	}
}

void log(const struct STATE *state)
{

	static mutex_t mutex = MUTEX_INITIALIZER;
	while (mutex_lock(&mutex) < 0);
	write(output_file, (const char *)state, sizeof(struct STATE));
	write(output_file, (const char *)state->rsp, stack_size);
	fsync(output_file);
	mutex_unlock(&mutex);
}