Code

Merge branch 'collectd-5.4' into collectd-5.5
authorMarc Fournier <marc.fournier@camptocamp.com>
Mon, 15 Jun 2015 19:18:04 +0000 (21:18 +0200)
committerMarc Fournier <marc.fournier@camptocamp.com>
Mon, 15 Jun 2015 19:18:04 +0000 (21:18 +0200)
Conflicts:
src/write_redis.c

1  2 
configure.ac
src/collectd.conf.pod
src/write_redis.c

diff --cc configure.ac
Simple merge
Simple merge
index 22e30abb3833687f1a423810f19c1c4860d0efd6,3b8addd2c02e63f9ea8725d2ba431d7253ffb36f..02663c6609c0d5f1923bb5192e718927782eaaa5
@@@ -74,39 -70,10 +74,42 @@@ static int wr_write (const data_set_t *
    value_size = sizeof (value);
    value_ptr = &value[0];
  
 +#define APPEND(...) do {                                             \
 +  status = snprintf (value_ptr, value_size, __VA_ARGS__);            \
 +  if (((size_t) status) > value_size)                                \
 +  {                                                                  \
 +    value_ptr += value_size;                                         \
 +    value_size = 0;                                                  \
 +  }                                                                  \
 +  else                                                               \
 +  {                                                                  \
 +    value_ptr += status;                                             \
 +    value_size -= status;                                            \
 +  }                                                                  \
 +} while (0)
 +
 +  APPEND ("%s:", time);
 +
 +  for (i = 0; i < ds->ds_num; i++)
 +  {
 +    if (ds->ds[i].type == DS_TYPE_COUNTER)
 +      APPEND ("%llu", vl->values[i].counter);
 +    else if (ds->ds[i].type == DS_TYPE_GAUGE)
 +      APPEND (GAUGE_FORMAT, vl->values[i].gauge);
 +    else if (ds->ds[i].type == DS_TYPE_DERIVE)
 +      APPEND ("%"PRIi64, vl->values[i].derive);
 +    else if (ds->ds[i].type == DS_TYPE_ABSOLUTE)
 +      APPEND ("%"PRIu64, vl->values[i].absolute);
 +    else
 +      assert (23 == 42);
 +  }
 +
 +#undef APPEND
 +
+   status = format_values (value_ptr, value_size, ds, vl, /* store rates = */ 0);
    pthread_mutex_lock (&node->lock);
+   if (status != 0)
+     return (status);
  
    if (node->conn == NULL)
    {