]> err.no Git - varnish/commitdiff
More flexelint nit-picking of various sorts
authorphk <phk@d4fa192b-c00b-0410-8231-f00ffab90ce4>
Tue, 25 Sep 2007 13:19:07 +0000 (13:19 +0000)
committerphk <phk@d4fa192b-c00b-0410-8231-f00ffab90ce4>
Tue, 25 Sep 2007 13:19:07 +0000 (13:19 +0000)
git-svn-id: svn+ssh://projects.linpro.no/svn/varnish/trunk@2043 d4fa192b-c00b-0410-8231-f00ffab90ce4

13 files changed:
varnish-cache/bin/varnishd/cache.h
varnish-cache/bin/varnishd/cache_acceptor.c
varnish-cache/bin/varnishd/cache_acceptor_poll.c
varnish-cache/bin/varnishd/cache_backend_random.c
varnish-cache/bin/varnishd/cache_backend_round_robin.c
varnish-cache/bin/varnishd/cache_fetch.c
varnish-cache/bin/varnishd/cache_http.c
varnish-cache/bin/varnishd/cache_pool.c
varnish-cache/bin/varnishd/flint.lnt
varnish-cache/bin/varnishd/heritage.h
varnish-cache/bin/varnishd/mgt_event.c
varnish-cache/bin/varnishd/mgt_vcc.c
varnish-cache/bin/varnishd/varnishd.c

index 8d41d1f6794c6f79094a2c8951a06729d72e832e..c4f4ea668039e8f78e76c8780bda7f5b03224ba8 100644 (file)
@@ -161,8 +161,8 @@ struct worker {
        int                     *wfd;
        unsigned                werr;   /* valid after WRK_Flush() */
        struct iovec            iov[MAX_IOVS];
-       unsigned                niov;
-       size_t                  liov;
+       int                     niov;
+       ssize_t                 liov;
 
        struct VCL_conf         *vcl;
        struct srcaddr          *srcaddr;
@@ -446,7 +446,7 @@ void HSH_Deref(struct object *o);
 void HSH_Init(void);
 
 /* cache_http.c */
-const char *http_StatusMessage(int);
+const char *http_StatusMessage(unsigned);
 void HTTP_Init(void);
 void http_ClrHeader(struct http *to);
 unsigned http_Write(struct worker *w, const struct http *hp, int resp);
index c24d091a3650faea8008fcd7faca2c13f3be5e87..b769d0d3a77c3575440007cfcb62e92b02820eb0 100644 (file)
@@ -135,9 +135,10 @@ vca_acct(void *arg)
        socklen_t l;
        struct sockaddr_storage addr_s;
        struct sockaddr *addr;
-       int i, j;
+       int i;
        struct pollfd *pfd;
        struct listen_sock *ls;
+       unsigned u;
 
        (void)arg;
 
@@ -171,16 +172,16 @@ vca_acct(void *arg)
                                    &tv_rcvtimeo, sizeof tv_rcvtimeo));
                }
                i = poll(pfd, heritage.nsocks, 1000);
-               for (j = 0; j < heritage.nsocks; j++) {
-                       if (pfd[j].revents == 0)
+               for (u = 0; u < heritage.nsocks; u++) {
+                       if (pfd[u].revents == 0)
                                continue;
                        VSL_stats->client_conn++;
                        l = sizeof addr_s;
                        addr = (void*)&addr_s;
-                       i = accept(pfd[j].fd, addr, &l);
+                       i = accept(pfd[u].fd, addr, &l);
                        if (i < 0) {
                                if (errno != EAGAIN) {
-                                       VSL(SLT_Debug, pfd[j].fd,
+                                       VSL(SLT_Debug, pfd[u].fd,
                                            "Accept failed errno=%d", errno);
                                        /* XXX: stats ? */
                                }
index dc28f4271d50bddcf945645745bff655aa431157..2853f70d7e93afed2ee178c68171d02542501bd9 100644 (file)
@@ -56,7 +56,7 @@ static VTAILQ_HEAD(,sess) sesshead = VTAILQ_HEAD_INITIALIZER(sesshead);
 /*--------------------------------------------------------------------*/
 
 static void
-vca_pollspace(int fd)
+vca_pollspace(unsigned fd)
 {
        struct pollfd *p;
        unsigned u, v;
@@ -82,7 +82,9 @@ vca_pollspace(int fd)
 static void
 vca_poll(int fd)
 {
-       vca_pollspace(fd);
+
+       assert(fd >= 0);
+       vca_pollspace((unsigned)fd);
        pollfd[fd].fd = fd;
        pollfd[fd].events = POLLIN;
 }
@@ -90,7 +92,9 @@ vca_poll(int fd)
 static void
 vca_unpoll(int fd)
 {
-       vca_pollspace(fd);
+
+       assert(fd >= 0);
+       vca_pollspace((unsigned)fd);
        pollfd[fd].fd = -1;
        pollfd[fd].events = 0;
 }
index 645519fe2597b592e6c198b25c5e4a5f5a8fffd3..34933a2d5155ff6837e7e9c624d0c975e1838577 100644 (file)
@@ -299,7 +299,7 @@ ber_GetFd(const struct sess *sp)
        for (n = 1; n < 5; n++) {
                vc = ber_nextfd(sp);
                if (vc == NULL) {
-                       usleep(100000 * n);
+                       AZ(usleep(100000 * n));
                        continue;
                }
                assert(vc->fd >= 0);
@@ -371,7 +371,7 @@ ber_Cleanup(const struct backend *b)
                                break;
                        VTAILQ_REMOVE(&bs->connlist, vbe, list);
                        if (vbe->fd >= 0)
-                               close(vbe->fd);
+                               AZ(close(vbe->fd));
                        free(vbe);
                }
                bstmp = bs;
index 157bfd9defb602633cba3bb48b92d6dc7d0352b5..bf1736ac2d3b6969e8a00f4a0a059d92a27ead87 100644 (file)
@@ -284,7 +284,7 @@ brr_GetFd(const struct sess *sp)
        for (n = 1; n < 5; n++) {
                vc = brr_nextfd(sp);
                if (vc == NULL) {
-                       usleep(100000 * n);
+                       AZ(usleep(100000 * n));
                        continue;
                }
                assert(vc->fd >= 0);
@@ -356,7 +356,7 @@ brr_Cleanup(const struct backend *b)
                                break;
                        VTAILQ_REMOVE(&bs->connlist, vbe, list);
                        if (vbe->fd >= 0)
-                               close(vbe->fd);
+                               AZ(close(vbe->fd));
                        free(vbe);
                }
                bstmp = bs;
index ec54afc61255d09e45ced4af962444b9ea207114..ed05f136eb4afee9c21f065caf6816c7c80d506d 100644 (file)
@@ -53,13 +53,17 @@ fetch_straight(struct sess *sp, int fd, struct http *hp, const char *b)
 {
        int i;
        unsigned char *p;
-       off_t   cl;
+       uintmax_t cll;
+       unsigned cl;
        struct storage *st;
 
-       cl = strtoumax(b, NULL, 0);
-       if (cl == 0)
+       cll = strtoumax(b, NULL, 0);
+       if (cll == 0)
                return (0);
 
+       cl = (unsigned)cll;
+       assert((uintmax_t)cl == cll); /* Protect against bogusly large values */
+
        st = STV_alloc(sp, cl);
        VTAILQ_INSERT_TAIL(&sp->obj->store, st, list);
        st->len = cl;
@@ -89,7 +93,7 @@ fetch_chunked(struct sess *sp, int fd, struct http *hp)
        int i;
        char *q;
        struct storage *st;
-       unsigned u, v;
+       unsigned u, v, w;
        char buf[20];           /* XXX: arbitrary */
        char *bp, *be;
 
@@ -157,17 +161,16 @@ fetch_chunked(struct sess *sp, int fd, struct http *hp)
                                v = u;
 
                        /* Handle anything left in our buffer first */
-                       i = pdiff(q, bp);
-                       assert(i >= 0);
-                       if (i > v)
-                               i = v;
-                       if (i != 0) {
-                               memcpy(st->ptr + st->len, q, i);
-                               st->len += i;
-                               sp->obj->len += i;
-                               u -= i;
-                               v -= i;
-                               q += i;
+                       w = pdiff(q, bp);
+                       if (w > v)
+                               w = v;
+                       if (w != 0) {
+                               memcpy(st->ptr + st->len, q, w);
+                               st->len += w;
+                               sp->obj->len += w;
+                               u -= w;
+                               v -= w;
+                               q += w;
                        }
                        if (u == 0)
                                break;
@@ -263,7 +266,8 @@ Fetch(struct sess *sp)
        struct http *hp, *hp2;
        struct storage *st;
        struct bereq *bereq;
-       int len, mklen, is_head;
+       int mklen, is_head;
+       unsigned len;
 
        CHECK_OBJ_NOTNULL(sp, SESS_MAGIC);
        CHECK_OBJ_NOTNULL(sp->wrk, WORKER_MAGIC);
index 3d90a5a43758999f99d5705be3e4202d81e0cac5..84113d1779a395522830dd64dc570c177e4ceb2a 100644 (file)
@@ -89,7 +89,7 @@ http2shmlog(const struct http *hp, enum httptag t)
 }
 
 static void
-WSLH(struct worker *w, enum httptag t, int fd, const struct http *hp, int hdr)
+WSLH(struct worker *w, enum httptag t, int fd, const struct http *hp, unsigned hdr)
 {
 
        WSLR(w, http2shmlog(hp, t), fd, hp->hd[hdr].b, hp->hd[hdr].e);
@@ -146,7 +146,7 @@ static struct http_msg {
 };
 
 const char *
-http_StatusMessage(int status)
+http_StatusMessage(unsigned status)
 {
        struct http_msg *mp;
 
@@ -237,7 +237,7 @@ int
 http_GetHdrField(const struct http *hp, const char *hdr, const char *field, char **ptr)
 {
        char *h;
-       int fl;
+       unsigned fl;
 
        if (!http_GetHdr(hp, hdr, &h))
                return (0);
@@ -273,7 +273,6 @@ http_DoConnection(struct sess *sp)
 {
        struct http *hp = sp->http;
        char *p, *q;
-       int i;
        unsigned u;
 
        if (!http_GetHdr(hp, H_Connection, &p)) {
@@ -289,10 +288,10 @@ http_DoConnection(struct sess *sp)
                for (q = p + 1; *q; q++)
                        if (*q == ',' || isspace(*q))
                                break;
-               i = pdiff(p, q);
-               if (i == 5 && !strncasecmp(p, "close", i))
+               u = pdiff(p, q);
+               if (u == 5 && !strncasecmp(p, "close", u))
                        sp->doclose = "Connection: close";
-               u = http_findhdr(hp, i, p);
+               u = http_findhdr(hp, u, p);
                if (u != 0)
                        hp->hdf[u] |= HDF_FILTER;
                if (!*q)
@@ -346,7 +345,7 @@ int
 http_Read(struct http *hp, int fd, void *p, unsigned len)
 {
        int i;
-       int u;
+       unsigned u;
        char *b = p;
 
        u = 0;
@@ -363,7 +362,7 @@ http_Read(struct http *hp, int fd, void *p, unsigned len)
                hp->pl_s = hp->pl_e = NULL;
        if (len > 0) {
                i = read(fd, b, len);
-               if (i < 0)
+               if (i < 0)              /* XXX i == 0 ?? */
                        return (i);
                u += i;
        }
@@ -904,7 +903,7 @@ static void
 http_PutField(struct worker *w, int fd, struct http *to, int field, const char *string)
 {
        char *p;
-       int l;
+       unsigned l;
 
        CHECK_OBJ_NOTNULL(to, HTTP_MAGIC);
        l = strlen(string);
index 5e8e2833a3be0277a95f9763aacd4f673dbf18ca..f8ebfdcb9656d2fac714f9f0fd6f06b09eb6d0b5 100644 (file)
@@ -94,7 +94,7 @@ WRK_Reset(struct worker *w, int *fd)
 unsigned
 WRK_Flush(struct worker *w)
 {
-       int i;
+       ssize_t i;
 
        CHECK_OBJ_NOTNULL(w, WORKER_MAGIC);
        if (*w->wfd < 0 || w->niov == 0 || w->werr)
@@ -133,7 +133,7 @@ WRK_Write(struct worker *w, const void *ptr, int len)
        if (len == -1)
                len = strlen(ptr);
        if (w->niov == MAX_IOVS)
-               WRK_Flush(w);
+               (void)WRK_Flush(w);
        w->iov[w->niov].iov_base = (void*)(uintptr_t)ptr;
        w->iov[w->niov].iov_len = len;
        w->liov += len;
@@ -394,7 +394,7 @@ wrk_reaperthread(void *priv)
        (void)priv;
        while (1) {
                wrk_addpools(params->wthread_pools);
-               sleep(1);
+               AZ(sleep(1));
                if (VSL_stats->n_wrk <= params->wthread_min)
                        continue;
                now = TIM_real();
@@ -415,7 +415,6 @@ wrk_reaperthread(void *priv)
                        assert(1 == write(w->pipe[1], w, 1));
                }
        }
-       INCOMPL();
 }
 
 /*--------------------------------------------------------------------*/
index 02d3455e2aaa4fd993b0e2b4dd48335979a3062c..a11489314e5dbd85681b7dccb1cf4406fdc817fa 100644 (file)
@@ -32,6 +32,7 @@
 -emacro(740, VTAILQ_LAST) // Unusual pointer cast (incompatible indirect types)
 -emacro((826), VTAILQ_PREV) // Suspicious pointer-to-pointer conversion (area too small)
 -emacro((826), VTAILQ_LAST) // Suspicious pointer-to-pointer conversion (area too small)
+-emacro(506, VTAILQ_FOREACH_SAFE) // constant value boolean
 
 -esym(534, sprintf)    // Ignoring return value of function
 -esym(534, asprintf)   // Ignoring return value of function
index 89f248533ffcb986e4a4d776fee651988862a645..866d401752a559b197172e0295238b73604d1d67 100644 (file)
@@ -53,7 +53,7 @@ struct heritage {
 
        /* Sockets from which to accept connections */
        struct listen_sock_head         socks;
-       int                             nsocks;
+       unsigned                        nsocks;
 
        /* Share memory log fd and size (incl header) */
        int                             vsl_fd;
index a29099041e419dd9e29c62d11c7ad9dfcdb8599f..5aee213acb76b977060a8cf9a86f6e7843db27bd 100644 (file)
@@ -55,7 +55,7 @@ struct evsig {
 };
 
 static struct evsig            *ev_sigs;
-static unsigned                        ev_nsig;
+static int                     ev_nsig;
 
 struct evbase {
        unsigned                magic;
index d329c53598d1265d0651f5ba0036b61a22f7d393..325094f790657d0d360c4ccf041c1ba7efa2233a 100644 (file)
@@ -297,7 +297,7 @@ mgt_VccCompile(struct vsb *sb, const char *b, const char *e, int C_flag)
        csrc = VCC_Compile(sb, b, e);
        if (csrc != NULL) {
                if (C_flag)
-                       fputs(csrc, stdout);
+                       (void)fputs(csrc, stdout);
                vf = mgt_CallCc(csrc, sb);
                if (C_flag && vf != NULL)
                        AZ(unlink(vf));
@@ -500,7 +500,7 @@ mcf_config_inline(struct cli *cli, const char * const *av, void *priv)
                free(p);
                return;
        }
-       mgt_vcc_add(av[2], vf);
+       (void)mgt_vcc_add(av[2], vf);
 }
 
 void
@@ -531,7 +531,7 @@ mcf_config_load(struct cli *cli, const char * const *av, void *priv)
                free(p);
                return;
        }
-       mgt_vcc_add(av[2], vf);
+       (void)mgt_vcc_add(av[2], vf);
 }
 
 static struct vclprog *
index 92cea490aead20e99095453cc7c912a441ae39c8..1e88a2c189fa47ecd74291c9dd047747fb4b795b 100644 (file)
@@ -79,9 +79,9 @@ volatile struct params *params;
 static int
 cmp_hash(const struct hash_slinger *s, const char *p, const char *q)
 {
-       if (strlen(s->name) != q - p)
+       if (strlen(s->name) != (q - p))
                return (1);
-       if (strncmp(s->name, p, q - p))
+       if (strncmp(s->name, p, (q - p)))
                return (1);
        return (0);
 }
@@ -288,7 +288,7 @@ DebugStunt(void)
 
        /* close the rest */
        for (i = 5; i < getdtablesize(); i++)
-               close(i);
+               (void)close(i);
 
        pfd[0].fd = pipes[0][0];
        pfd[0].events = POLLIN;