projects
/
collectd.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Merge pull request #1454 from rubenk/libi2c-dev-mark-as-linux-only
[collectd.git]
/
src
/
gmond.c
diff --git
a/src/gmond.c
b/src/gmond.c
index
09d7137
..
c778d48
100644
(file)
--- a/
src/gmond.c
+++ b/
src/gmond.c
@@
-33,9
+33,6
@@
#if HAVE_PTHREAD_H
# include <pthread.h>
#endif
#if HAVE_PTHREAD_H
# include <pthread.h>
#endif
-#if HAVE_SYS_SOCKET_H
-# include <sys/socket.h>
-#endif
#if HAVE_NETDB_H
# include <netdb.h>
#endif
#if HAVE_NETDB_H
# include <netdb.h>
#endif
@@
-83,12
+80,12
@@
typedef struct staging_entry_s staging_entry_t;
struct metric_map_s
{
struct metric_map_s
{
- char *ganglia_name;
- char *type;
- char *type_instance;
- char *ds_name;
- int ds_type;
-
int
ds_index;
+ char
*ganglia_name;
+ char
*type;
+ char
*type_instance;
+ char
*ds_name;
+ int
ds_type;
+
size_t
ds_index;
};
typedef struct metric_map_s metric_map_t;
};
typedef struct metric_map_s metric_map_t;
@@
-166,7
+163,7
@@
static metric_map_t *metric_lookup (const char *key) /* {{{ */
return (NULL);
/* Look up the DS type and ds_index. */
return (NULL);
/* Look up the DS type and ds_index. */
- if (
(map[i].ds_type < 0) || (map[i].ds_index < 0)
) /* {{{ */
+ if (
map[i].ds_type < 0
) /* {{{ */
{
const data_set_t *ds;
{
const data_set_t *ds;
@@
-191,7
+188,7
@@
static metric_map_t *metric_lookup (const char *key) /* {{{ */
}
else
{
}
else
{
-
in
t j;
+
size_
t j;
for (j = 0; j < ds->ds_num; j++)
if (strcasecmp (ds->ds[j].name, map[i].ds_name) == 0)
for (j = 0; j < ds->ds_num; j++)
if (strcasecmp (ds->ds[j].name, map[i].ds_name) == 0)
@@
-511,7
+508,7
@@
static int staging_entry_submit (const char *host, const char *name, /* {{{ */
static int staging_entry_update (const char *host, const char *name, /* {{{ */
const char *type, const char *type_instance,
static int staging_entry_update (const char *host, const char *name, /* {{{ */
const char *type, const char *type_instance,
-
in
t ds_index, int ds_type, value_t value)
+
size_
t ds_index, int ds_type, value_t value)
{
const data_set_t *ds;
staging_entry_t *se;
{
const data_set_t *ds;
staging_entry_t *se;
@@
-525,7
+522,7
@@
static int staging_entry_update (const char *host, const char *name, /* {{{ */
if (ds->ds_num <= ds_index)
{
if (ds->ds_num <= ds_index)
{
- ERROR ("gmond plugin: Invalid index %
i: %s has only %i
data source(s).",
+ ERROR ("gmond plugin: Invalid index %
zu: %s has only %zu
data source(s).",
ds_index, ds->type, ds->ds_num);
return (-1);
}
ds_index, ds->type, ds->ds_num);
return (-1);
}
@@
-875,6
+872,7
@@
static void *mc_receive_thread (void *arg) /* {{{ */
}
} /* while (mc_receive_thread_loop != 0) */
}
} /* while (mc_receive_thread_loop != 0) */
+ free (mc_receive_socket_entries);
return ((void *) 0);
} /* }}} void *mc_receive_thread */
return ((void *) 0);
} /* }}} void *mc_receive_thread */