X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=stat.c;h=e640e4c6994ca830e769c34dc6072a17ac254606;hp=89a1f49b9f823120c36e8c3f29922d45497a9225;hb=1889013e900f08d5ee842a50dc13c66689ebf15b;hpb=7d912dbad687503f2a8d4895b0e48b4584b4940b diff --git a/stat.c b/stat.c index 89a1f49b..e640e4c6 100644 --- a/stat.c +++ b/stat.c @@ -1,5 +1,5 @@ /* - * Copyright (C) 2005-2007 Andre Noll + * Copyright (C) 2005-2008 Andre Noll * * Licensed under the GPL v2. For licencing details see COPYING. */ @@ -103,22 +103,17 @@ void stat_client_write(const char *msg, int itemnum) { struct stat_client *sc, *tmp; size_t len = strlen(msg); - struct timeval tv = {0 , 0}; if (!initialized || !len) return; list_for_each_entry_safe(sc, tmp, &client_list, node) { int fd = sc->fd, ret; - fd_set wfds; if (!((1 << itemnum) & sc->item_mask)) continue; - FD_ZERO(&wfds); - FD_SET(fd, &wfds); - ret = para_select(fd + 1, NULL, &wfds, &tv); - if (ret > 0) { + if (write_ok(fd) > 0) { ret = write(fd, msg, len); - PARA_DEBUG_LOG("dumped %s to fd %d, ret = %d\n", msg, fd, ret); + // PARA_DEBUG_LOG("dumped %s to fd %d, ret = %d\n", msg, fd, ret); if (ret == len) continue; } @@ -130,7 +125,8 @@ void stat_client_write(const char *msg, int itemnum) free(sc); dump_stat_client_list(); } - PARA_DEBUG_LOG("%d client(s)\n", num_clients); +// if (num_clients) +// PARA_DEBUG_LOG("%d client(s)\n", num_clients); } /**