[BACK]Return to mod_rrdtool.c CVS log [TXT] [DIR] Up to [ELWIX - Embedded LightWeight unIX -] / embedaddon / lighttpd / src

Diff for /embedaddon/lighttpd/src/mod_rrdtool.c between versions 1.1.1.2 and 1.1.1.3

version 1.1.1.2, 2014/06/15 20:20:06 version 1.1.1.3, 2016/11/02 10:35:00
Line 1 Line 1
   #include "first.h"
   
 #include "server.h"  #include "server.h"
 #include "connections.h"  #include "connections.h"
 #include "response.h"  #include "response.h"
Line 65  FREE_FUNC(mod_rrd_free) { Line 67  FREE_FUNC(mod_rrd_free) {
                 for (i = 0; i < srv->config_context->used; i++) {                  for (i = 0; i < srv->config_context->used; i++) {
                         plugin_config *s = p->config_storage[i];                          plugin_config *s = p->config_storage[i];
   
                           if (NULL == s) continue;
   
                         buffer_free(s->path_rrdtool_bin);                          buffer_free(s->path_rrdtool_bin);
                         buffer_free(s->path_rrd);                          buffer_free(s->path_rrd);
   
Line 264  static int mod_rrdtool_create_rrd(server *srv, plugin_ Line 268  static int mod_rrdtool_create_rrd(server *srv, plugin_
                 "RRA:MIN:0.5:24:775 "                  "RRA:MIN:0.5:24:775 "
                 "RRA:MIN:0.5:288:797\n"));                  "RRA:MIN:0.5:288:797\n"));
   
        if (-1 == (safe_write(p->write_fd, p->cmd->ptr, p->cmd->used - 1))) {        if (-1 == (safe_write(p->write_fd, CONST_BUF_LEN(p->cmd)))) {
                 log_error_write(srv, __FILE__, __LINE__, "ss",                  log_error_write(srv, __FILE__, __LINE__, "ss",
                         "rrdtool-write: failed", strerror(errno));                          "rrdtool-write: failed", strerror(errno));
   
                 return HANDLER_ERROR;                  return HANDLER_ERROR;
         }          }
   
        buffer_prepare_copy(p->resp, 4096);        buffer_string_prepare_copy(p->resp, 4095);
        if (-1 == (r = safe_read(p->read_fd, p->resp->ptr, p->resp->size))) {        if (-1 == (r = safe_read(p->read_fd, p->resp->ptr, p->resp->size - 1))) {
                 log_error_write(srv, __FILE__, __LINE__, "ss",                  log_error_write(srv, __FILE__, __LINE__, "ss",
                         "rrdtool-read: failed", strerror(errno));                          "rrdtool-read: failed", strerror(errno));
   
                 return HANDLER_ERROR;                  return HANDLER_ERROR;
         }          }
   
        p->resp->used = r;        buffer_commit(p->resp, r);
   
         if (p->resp->ptr[0] != 'O' ||          if (p->resp->ptr[0] != 'O' ||
                 p->resp->ptr[1] != 'K') {                  p->resp->ptr[1] != 'K') {
Line 337  SETDEFAULTS_FUNC(mod_rrd_set_defaults) { Line 341  SETDEFAULTS_FUNC(mod_rrd_set_defaults) {
         size_t i;          size_t i;
   
         config_values_t cv[] = {          config_values_t cv[] = {
                { "rrdtool.binary",              NULL, T_CONFIG_STRING, T_CONFIG_SCOPE_SERVER },                { "rrdtool.binary",  NULL, T_CONFIG_STRING, T_CONFIG_SCOPE_CONNECTION }, /* 0 */
                { "rrdtool.db-name",             NULL, T_CONFIG_STRING, T_CONFIG_SCOPE_CONNECTION },                { "rrdtool.db-name", NULL, T_CONFIG_STRING, T_CONFIG_SCOPE_CONNECTION }, /* 1 */
                { NULL,                          NULL, T_CONFIG_UNSET, T_CONFIG_SCOPE_UNSET }                { NULL,              NULL, T_CONFIG_UNSET,  T_CONFIG_SCOPE_UNSET      }
         };          };
   
         if (!p) return HANDLER_ERROR;          if (!p) return HANDLER_ERROR;
Line 348  SETDEFAULTS_FUNC(mod_rrd_set_defaults) { Line 352  SETDEFAULTS_FUNC(mod_rrd_set_defaults) {
         p->config_storage = calloc(1, srv->config_context->used * sizeof(plugin_config *));          p->config_storage = calloc(1, srv->config_context->used * sizeof(plugin_config *));
   
         for (i = 0; i < srv->config_context->used; i++) {          for (i = 0; i < srv->config_context->used; i++) {
                   data_config const* config = (data_config const*)srv->config_context->data[i];
                 plugin_config *s;                  plugin_config *s;
   
                 s = calloc(1, sizeof(plugin_config));                  s = calloc(1, sizeof(plugin_config));
Line 362  SETDEFAULTS_FUNC(mod_rrd_set_defaults) { Line 367  SETDEFAULTS_FUNC(mod_rrd_set_defaults) {
   
                 p->config_storage[i] = s;                  p->config_storage[i] = s;
   
                if (0 != config_insert_values_global(srv, ((data_config *)srv->config_context->data[i])->value, cv)) {                if (0 != config_insert_values_global(srv, config->value, cv, i == 0 ? T_CONFIG_SCOPE_SERVER : T_CONFIG_SCOPE_CONNECTION)) {
                         return HANDLER_ERROR;                          return HANDLER_ERROR;
                 }                  }
   
                if (i > 0 && !buffer_is_empty(s->path_rrdtool_bin)) {                if (i > 0 && !buffer_string_is_empty(s->path_rrdtool_bin)) {
                         /* path_rrdtool_bin is a global option */                          /* path_rrdtool_bin is a global option */
   
                         log_error_write(srv, __FILE__, __LINE__, "s",                          log_error_write(srv, __FILE__, __LINE__, "s",
Line 382  SETDEFAULTS_FUNC(mod_rrd_set_defaults) { Line 387  SETDEFAULTS_FUNC(mod_rrd_set_defaults) {
   
         /* check for dir */          /* check for dir */
   
        if (buffer_is_empty(p->conf.path_rrdtool_bin)) {        if (buffer_string_is_empty(p->conf.path_rrdtool_bin)) {
                 log_error_write(srv, __FILE__, __LINE__, "s",                  log_error_write(srv, __FILE__, __LINE__, "s",
                                 "rrdtool.binary has to be set");                                  "rrdtool.binary has to be set");
                 return HANDLER_ERROR;                  return HANDLER_ERROR;
Line 409  TRIGGER_FUNC(mod_rrd_trigger) { Line 414  TRIGGER_FUNC(mod_rrd_trigger) {
                 plugin_config *s = p->config_storage[i];                  plugin_config *s = p->config_storage[i];
                 int r;                  int r;
   
                if (buffer_is_empty(s->path_rrd)) continue;                if (buffer_string_is_empty(s->path_rrd)) continue;
   
                 /* write the data down every minute */                  /* write the data down every minute */
   
Line 418  TRIGGER_FUNC(mod_rrd_trigger) { Line 423  TRIGGER_FUNC(mod_rrd_trigger) {
                 buffer_copy_string_len(p->cmd, CONST_STR_LEN("update "));                  buffer_copy_string_len(p->cmd, CONST_STR_LEN("update "));
                 buffer_append_string_buffer(p->cmd, s->path_rrd);                  buffer_append_string_buffer(p->cmd, s->path_rrd);
                 buffer_append_string_len(p->cmd, CONST_STR_LEN(" N:"));                  buffer_append_string_len(p->cmd, CONST_STR_LEN(" N:"));
                buffer_append_off_t(p->cmd, s->bytes_read);                buffer_append_int(p->cmd, s->bytes_read);
                 buffer_append_string_len(p->cmd, CONST_STR_LEN(":"));                  buffer_append_string_len(p->cmd, CONST_STR_LEN(":"));
                buffer_append_off_t(p->cmd, s->bytes_written);                buffer_append_int(p->cmd, s->bytes_written);
                 buffer_append_string_len(p->cmd, CONST_STR_LEN(":"));                  buffer_append_string_len(p->cmd, CONST_STR_LEN(":"));
                buffer_append_long(p->cmd, s->requests);                buffer_append_int(p->cmd, s->requests);
                 buffer_append_string_len(p->cmd, CONST_STR_LEN("\n"));                  buffer_append_string_len(p->cmd, CONST_STR_LEN("\n"));
   
                if (-1 == (r = safe_write(p->write_fd, p->cmd->ptr, p->cmd->used - 1))) {                if (-1 == (r = safe_write(p->write_fd, CONST_BUF_LEN(p->cmd)))) {
                         p->rrdtool_running = 0;                          p->rrdtool_running = 0;
   
                         log_error_write(srv, __FILE__, __LINE__, "ss",                          log_error_write(srv, __FILE__, __LINE__, "ss",
Line 434  TRIGGER_FUNC(mod_rrd_trigger) { Line 439  TRIGGER_FUNC(mod_rrd_trigger) {
                         return HANDLER_ERROR;                          return HANDLER_ERROR;
                 }                  }
   
                buffer_prepare_copy(p->resp, 4096);                buffer_string_prepare_copy(p->resp, 4095);
                 if (-1 == (r = safe_read(p->read_fd, p->resp->ptr, p->resp->size - 1))) {                  if (-1 == (r = safe_read(p->read_fd, p->resp->ptr, p->resp->size - 1))) {
                         p->rrdtool_running = 0;                          p->rrdtool_running = 0;
   
Line 444  TRIGGER_FUNC(mod_rrd_trigger) { Line 449  TRIGGER_FUNC(mod_rrd_trigger) {
                         return HANDLER_ERROR;                          return HANDLER_ERROR;
                 }                  }
   
                p->resp->used = r + 1;                buffer_commit(p->resp, r);
                p->resp->ptr[r] = '\0'; 
   
                 if (p->resp->ptr[0] != 'O' ||                  if (p->resp->ptr[0] != 'O' ||
                     p->resp->ptr[1] != 'K') {                      p->resp->ptr[1] != 'K') {
Removed from v.1.1.1.2  
changed lines
  Added in v.1.1.1.3

FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>