X-Git-Url: https://ruderich.org/simon/gitweb/?p=coloredstderr%2Fcoloredstderr.git;a=blobdiff_plain;f=src%2Ftrackfds.h;h=b9089bbd25b0444772c6442ca27dedd3ac7e4334;hp=2def68cfb99dc4233d9df7c74667108966cd1b30;hb=6d6ad4423ae87771bd44f90006a648ec03931961;hpb=b75b0ec399b1217568e08e567afdefaea0bd32ef diff --git a/src/trackfds.h b/src/trackfds.h index 2def68c..b9089bb 100644 --- a/src/trackfds.h +++ b/src/trackfds.h @@ -51,12 +51,14 @@ static void tracked_fds_debug(void) { #endif static int init_tracked_fds_list(size_t count) { + assert(count > 0); + /* Reduce reallocs. */ count += TRACKFDS_REALLOC_STEP; tracked_fds_list = malloc(count * sizeof(*tracked_fds_list)); if (!tracked_fds_list) { -#ifdef DEBUG +#ifdef WARNING warning("malloc(tracked_fds_list, %d) failed [%d]\n", count * sizeof(*tracked_fds_list), getpid()); #endif @@ -95,6 +97,9 @@ static void init_from_environment(void) { errno = saved_errno; return; } +#ifdef DEBUG + debug(" getenv(\"%s\"): \"%s\"\n", ENV_NAME_FDS, env); +#endif /* Environment is read-only. */ char env_copy[strlen(env) + 1]; strcpy(env_copy, env); @@ -161,10 +166,12 @@ next: } static char *update_environment_buffer_entry(char *x, int fd) { + assert(fd >= 0); + int length = snprintf(x, 10 + 1, "%d", fd); if (length >= 10 + 1) { /* Integer too big to fit the buffer, skip it. */ -#ifdef DEBUG +#ifdef WARNING warning("update_environment_buffer_entry(): truncated fd: %d [%d]\n", fd, getpid()); #endif @@ -180,6 +187,8 @@ static char *update_environment_buffer_entry(char *x, int fd) { return x; } static void update_environment_buffer(char *x) { + assert(initialized); + size_t i; for (i = 0; i < TRACKFDS_STATIC_COUNT; i++) { if (tracked_fds[i]) { @@ -191,6 +200,8 @@ static void update_environment_buffer(char *x) { } } inline static size_t update_environment_buffer_size(void) { + assert(initialized); + /* Use the maximum count (TRACKFDS_STATIC_COUNT) of used descriptors * because it's simple and small enough not to be a problem. * @@ -217,7 +228,7 @@ static void update_environment(void) { update_environment_buffer(env); #if 0 - debug(" setenv('%s', '%s', 1)\n", ENV_NAME_FDS, env); + debug(" setenv(\"%s\", \"%s\", 1)\n", ENV_NAME_FDS, env); #endif setenv(ENV_NAME_FDS, env, 1 /* overwrite */); @@ -226,6 +237,8 @@ static void update_environment(void) { static void tracked_fds_add(int fd) { + assert(fd >= 0); + if (fd < TRACKFDS_STATIC_COUNT) { tracked_fds[fd] = 1; #if 0 @@ -245,7 +258,7 @@ static void tracked_fds_add(int fd) { /* We can do nothing, just ignore the error. We made sure not to * destroy our state, so the new descriptor is ignored without any * other consequences. */ -#ifdef DEBUG +#ifdef WARNING warning("realloc(tracked_fds_list, %zu) failed! [%d]\n", sizeof(*tracked_fds_list) * new_space, getpid()); #endif @@ -266,6 +279,8 @@ static void tracked_fds_add(int fd) { #endif } static int tracked_fds_remove(int fd) { + assert(fd >= 0); + if (fd < TRACKFDS_STATIC_COUNT) { int old_value = tracked_fds[fd]; tracked_fds[fd] = 0; @@ -311,6 +326,8 @@ static int tracked_fds_find_slow(int fd) noinline; */ inline static int tracked_fds_find(int fd) always_inline; static int tracked_fds_find(int fd) { + assert(fd >= 0); + if (fd < TRACKFDS_STATIC_COUNT) { return tracked_fds[fd]; } @@ -318,6 +335,8 @@ static int tracked_fds_find(int fd) { return tracked_fds_find_slow(fd); } static int tracked_fds_find_slow(int fd) { + assert(initialized); + if (tracked_fds_list_count == 0) { return 0; }