X-Git-Url: https://plomlompom.com/repos/berlin_corona.txt?a=blobdiff_plain;f=src%2Fserver%2Fio.c;h=4fbf6ed07fad2dee6614a9f0f6843111f9ee7823;hb=6b1d36c9e673fd8f8595119080dca63a39ba483b;hp=035f4fe1d0759436f6dc5aed53710df00e82177b;hpb=d12efb0addf420adc045cfb96647dff6241310ee;p=plomrogue diff --git a/src/server/io.c b/src/server/io.c index 035f4fe..4fbf6ed 100644 --- a/src/server/io.c +++ b/src/server/io.c @@ -1,5 +1,6 @@ /* src/server/io.c */ +#define _POSIX_C_SOURCE 199309L #include "io.h" #include /* global errno */ #include /* PIPE_BUF */ @@ -9,7 +10,7 @@ #include /* free() */ #include /* strlen(), memcpy() */ #include /* time_t */ -#include /* time() */ +#include /* time(), nanosleep() */ #include "../common/readwrite.h" /* try_fopen(), try_fclose_unlink_rename(), * try_fwrite(), try_fputc(), try_fgetc() */ @@ -27,8 +28,8 @@ */ static char * get_message_from_queue(); -/* Read input file for input into world.queue. new queue input. Wait a few - * seconds until giving up. Translate '\n' chars in input file into '\0' chars. +/* Poll input file for world.queue input. Wait a few seconds until giving up; + * poll only every 0.03 seconds.. Translate '\n' chars in input file into '\0'. */ static void read_file_into_queue(); @@ -90,9 +91,13 @@ static void read_file_into_queue() char * f_name = "read_file_into_queue()"; uint8_t wait_seconds = 5; time_t now = time(0); + struct timespec dur; + dur.tv_sec = 0; + dur.tv_nsec = 33333333; int test; while (EOF == (test = try_fgetc(world.file_in, f_name))) { + nanosleep(&dur, NULL); if (time(0) > now + wait_seconds) { return;