X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=stat.c;h=39aab43ebd256a6de2e20015e4519ed98b77c761;hp=7346f097e61e9933759563d64af7e7b2dedd3eb6;hb=786010c598f79d20280e6ea9ea458cad4a7e9af7;hpb=d7cda933daa35663b2b9b61d62cb514afa37fd18 diff --git a/stat.c b/stat.c index 7346f097..39aab43e 100644 --- a/stat.c +++ b/stat.c @@ -129,7 +129,6 @@ int stat_client_add(int fd, long unsigned mask) new_client = para_malloc(sizeof(struct stat_client)); new_client->fd = fd; new_client->item_mask = mask; - add_close_on_fork_list(fd); list_add(&new_client->node, &client_list); dump_stat_client_list(); num_clients++; @@ -171,7 +170,6 @@ void stat_client_write(char *msg, int itemnum) } /* write error or fd not ready for writing */ close(fd); - del_close_on_fork_list(fd); num_clients--; PARA_INFO_LOG("deleting client on fd %d\n", fd); list_del(&sc->node); @@ -211,8 +209,10 @@ void dump_empty_status(void) int stat_item_valid(const char *item) { int i; - if (!item || !*item) + if (!item || !*item) { + PARA_ERROR_LOG("%s\n", "no item"); return -E_UNKNOWN_STAT_ITEM; + } FOR_EACH_STAT_ITEM(i) if (!strcmp(status_item_list[i], item)) return i; @@ -267,6 +267,7 @@ unsigned for_each_line(char *buf, int n, void (*line_handler)(char *)) char *start = buf, *end; int i, num_lines = 0; +// PARA_INFO_LOG("buf: %s", buf); while (start < buf + n) { char *next_null; char *next_cr; @@ -284,6 +285,7 @@ unsigned for_each_line(char *buf, int n, void (*line_handler)(char *)) num_lines++; if (line_handler) { *end = '\0'; +// PARA_INFO_LOG("calling line handler: %s\n", start); line_handler(start); start = ++end; } else