X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=stat.c;h=e881ae09fed1f0d77983cb6eb6081598f3fc3f90;hp=dc51119267c0d18c870240898588a9fdcf0f1637;hb=c4ecbd8f75be7847f7332dd64f11a0ba54233891;hpb=505cfe0c6c8f9ef79d259ee64404ab40f2057081 diff --git a/stat.c b/stat.c index dc511192..e881ae09 100644 --- a/stat.c +++ b/stat.c @@ -143,15 +143,14 @@ int stat_client_add(int fd, long unsigned mask) * On write errors, remove the status client from the client list and close its * file descriptor. */ -void stat_client_write(char *msg, int itemnum) +void stat_client_write(const char *msg, int itemnum) { struct stat_client *sc, *tmp; - ssize_t len; + size_t len = strlen(msg); struct timeval tv = {0 , 0}; - if (!initialized) + if (!initialized || !len) return; - len = strlen(msg); list_for_each_entry_safe(sc, tmp, &client_list, node) { int fd = sc->fd, ret; fd_set wfds; @@ -244,18 +243,18 @@ int stat_line_valid(const char *line) * \return If line_handler is not NULL, this function returns the number * of bytes not handled to \a line_handler. */ -unsigned for_each_line(char *buf, int n, void (*line_handler)(char *)) +size_t for_each_line(char *buf, size_t n, void (*line_handler)(char *)) { char *start = buf, *end; - int i, num_lines = 0; + size_t num_lines = 0, bytes_left = n; // PARA_INFO_LOG("buf: %s", buf); - while (start < buf + n) { + while (bytes_left) { char *next_null; char *next_cr; - next_cr = memchr(start, '\n', buf + n - start); - next_null = memchr(start, '\0', buf + n - start); + next_cr = memchr(start, '\n', bytes_left); + next_null = memchr(start, '\0', bytes_left); if (!next_cr && !next_null) break; if (next_cr && next_null) { @@ -269,15 +268,14 @@ unsigned for_each_line(char *buf, int n, void (*line_handler)(char *)) *end = '\0'; // PARA_INFO_LOG("calling line handler: %s\n", start); line_handler(start); - start = ++end; - } else - start = ++end; + } + start = ++end; + bytes_left = buf + n - start; } if (!line_handler) return num_lines; - i = buf + n - start; - if (i && i != n) - memmove(buf, start, i); - return i; + if (bytes_left && bytes_left != n) + memmove(buf, start, bytes_left); + return bytes_left; }