projects
/
collectd.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
src/daemon/utils_tail_match.c: Use match_value_reset().
[collectd.git]
/
src
/
daemon
/
common.c
diff --git
a/src/daemon/common.c
b/src/daemon/common.c
index
654a5a0
..
02df096
100644
(file)
--- a/
src/daemon/common.c
+++ b/
src/daemon/common.c
@@
-68,6
+68,11
@@
extern kstat_ctl_t *kc;
#endif
extern kstat_ctl_t *kc;
#endif
+/* AIX doesn't have MSG_DONTWAIT */
+#ifndef MSG_DONTWAIT
+# define MSG_DONTWAIT MSG_NONBLOCK
+#endif
+
#if !HAVE_GETPWNAM_R
static pthread_mutex_t getpwnam_r_lock = PTHREAD_MUTEX_INITIALIZER;
#endif
#if !HAVE_GETPWNAM_R
static pthread_mutex_t getpwnam_r_lock = PTHREAD_MUTEX_INITIALIZER;
#endif
@@
-1011,7
+1016,8
@@
int format_values (char *ret, size_t ret_len, /* {{{ */
int parse_identifier (char *str, char **ret_host,
char **ret_plugin, char **ret_plugin_instance,
int parse_identifier (char *str, char **ret_host,
char **ret_plugin, char **ret_plugin_instance,
- char **ret_type, char **ret_type_instance)
+ char **ret_type, char **ret_type_instance,
+ char *default_host)
{
char *hostname = NULL;
char *plugin = NULL;
{
char *hostname = NULL;
char *plugin = NULL;
@@
-1030,8
+1036,19
@@
int parse_identifier (char *str, char **ret_host,
type = strchr (plugin, '/');
if (type == NULL)
type = strchr (plugin, '/');
if (type == NULL)
- return (-1);
- *type = '\0'; type++;
+ {
+ if (default_host == NULL)
+ return (-1);
+ /* else: no host specified; use default */
+ type = plugin;
+ plugin = hostname;
+ hostname = default_host;
+ }
+ else
+ {
+ *type = '\0';
+ type++;
+ }
plugin_instance = strchr (plugin, '-');
if (plugin_instance != NULL)
plugin_instance = strchr (plugin, '-');
if (plugin_instance != NULL)
@@
-1072,7
+1089,8
@@
int parse_identifier_vl (const char *str, value_list_t *vl) /* {{{ */
status = parse_identifier (str_copy, &host,
&plugin, &plugin_instance,
status = parse_identifier (str_copy, &host,
&plugin, &plugin_instance,
- &type, &type_instance);
+ &type, &type_instance,
+ /* default_host = */ NULL);
if (status != 0)
return (status);
if (status != 0)
return (status);
@@
-1134,7
+1152,7
@@
int parse_value (const char *value_orig, value_t *ret_value, int ds_type)
}
if (value == endptr) {
}
if (value == endptr) {
- ERROR ("parse_value: Failed to parse string as %s:
%s
.",
+ ERROR ("parse_value: Failed to parse string as %s:
\"%s\"
.",
DS_TYPE_TO_STRING (ds_type), value);
sfree (value);
return -1;
DS_TYPE_TO_STRING (ds_type), value);
sfree (value);
return -1;
@@
-1602,10
+1620,8
@@
void set_sock_opts (int sockfd) /* {{{ */
int status;
int socktype;
int status;
int socktype;
- socklen_t socklen = sizeof (socklen_t);
- int so_keepalive = 1;
-
- status = getsockopt (sockfd, SOL_SOCKET, SO_TYPE, &socktype, &socklen);
+ status = getsockopt (sockfd, SOL_SOCKET, SO_TYPE,
+ &socktype, &(socklen_t) { sizeof (socktype) });
if (status != 0)
{
WARNING ("set_sock_opts: failed to determine socket type");
if (status != 0)
{
WARNING ("set_sock_opts: failed to determine socket type");
@@
-1615,7
+1631,7
@@
void set_sock_opts (int sockfd) /* {{{ */
if (socktype == SOCK_STREAM)
{
status = setsockopt(sockfd, SOL_SOCKET, SO_KEEPALIVE,
if (socktype == SOCK_STREAM)
{
status = setsockopt(sockfd, SOL_SOCKET, SO_KEEPALIVE,
- &
so_keepalive, sizeof (so_keepalive
));
+ &
(int) {1}, sizeof (int
));
if (status != 0)
WARNING ("set_sock_opts: failed to set socket keepalive flag");
if (status != 0)
WARNING ("set_sock_opts: failed to set socket keepalive flag");
@@
-1725,7
+1741,7
@@
int check_capability (int capability) /* {{{ */
}
cap_header->pid = getpid();
}
cap_header->pid = getpid();
- cap_header->version = _LINUX_CAPABILITY_VERSION;
+ cap_header->version = _LINUX_CAPABILITY_VERSION
_3
;
if (capget(cap_header, cap_data) < 0)
{
ERROR("check_capability: capget failed");
if (capget(cap_header, cap_data) < 0)
{
ERROR("check_capability: capget failed");