cook/bytenuts
Watch
1
0
Fork
You've already forked bytenuts
 0
Code Issues 7 Pull requests 1 Projects Releases 5 Packages Wiki Activity Actions

#10 Process specific backup log files

Browse source 
A process will open outbuf/inbuf.pid.log and move it to the outbuf/inbuf.log upon close, allowing for multiple processes to be open at once
This commit is contained in:
Aaron Cook 2023-05-08 10:00:37 -05:00
commit 1989c36886
5 changed files with 96 additions and 21 deletions
Download patch file Download diff file Expand all files Collapse all files

52
src/ingest.c
View file

@ -40,19 +40,29 @@ ingest_start(bytenuts_t *bytenuts)
HOME = getenv("HOME");
if (HOME) {
char *cwd = getcwd(NULL, 0);
int idx = 0;
chdir(HOME);
int name_len;
pid_t pid;
while (!read_cmd_page(idx)) {
idx++;
}
ingest.history_fd = fopen(".config/bytenuts/inbuf.log", "w");
/* ensure that a process has a unique log */
pid = getpid();
name_len = snprintf(
NULL, 0,
"%s/.config/bytenuts/inbuf.%d.log",
HOME, pid
);
ingest.history_filename = calloc(1, name_len + 1);
snprintf(
ingest.history_filename, name_len + 1,
"%s/.config/bytenuts/inbuf.%d.log",
HOME, pid
);
chdir(cwd);
free(cwd);
ingest.history_fd = fopen(ingest.history_filename, "w");
}
if (ingest.cmd_pgs_n > 0) {
@ -73,10 +83,6 @@ ingest_stop()
{
ingest.running = 0;
pthread_join(ingest.thr, NULL);
if (ingest.history_fd)
fclose(ingest.history_fd);
return 0;
}
@ -419,6 +425,32 @@ ingest_thread(void *arg)
sched_yield();
}
if (ingest.history_fd) {
char *in_filename;
int in_filename_len;
char *home = getenv("HOME");
/* do not chdir as other threads can still be running */
in_filename_len = snprintf(
NULL, 0,
"%s/.config/bytenuts/inbuf.log",
home
);
in_filename = calloc(1, in_filename_len + 1);
snprintf(
in_filename, in_filename_len + 1,
"%s/.config/bytenuts/inbuf.log",
home
);
/* move this processes history to the path that can be loaded on resumption */
fclose(ingest.history_fd);
rename(ingest.history_filename, in_filename);
free(in_filename);
free(ingest.history_filename);
}
pthread_exit(NULL);
return NULL;
}