X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=stat.c;h=23db42460a54e961de946d7dd409d5f2d8596e21;hp=dc51119267c0d18c870240898588a9fdcf0f1637;hb=d36f1dae4e1ee0756fdd885c1596fa8df8990491;hpb=505cfe0c6c8f9ef79d259ee64404ab40f2057081 diff --git a/stat.c b/stat.c index dc511192..23db4246 100644 --- a/stat.c +++ b/stat.c @@ -1,19 +1,7 @@ /* * Copyright (C) 2005-2007 Andre Noll * - * This program is free software; you can redistribute it and/or modify - * it under the terms of the GNU General Public License as published by - * the Free Software Foundation; either version 2 of the License, or - * (at your option) any later version. - * - * This program is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - * GNU General Public License for more details. - * - * You should have received a copy of the GNU General Public License - * along with this program; if not, write to the Free Software - * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111, USA. + * Licensed under the GPL v2. For licencing details see COPYING. */ /** @@ -143,15 +131,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 +231,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 +256,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; }