Changeset 57a327349609ef60a33dc6da15017c5d6642320a

Show
Ignore:
Timestamp:
02/02/08 19:10:26 (5 years ago)
Author:
Theo Schlossnagle <jesus@omniti.com>
git-committer:
Theo Schlossnagle <jesus@omniti.com> 1201979426 +0000
git-parent:

[ee84f469e10bfc29803bd472e4d06ea090574f12]

git-author:
Theo Schlossnagle <jesus@omniti.com> 1201979426 +0000
Message:

renaming something before it becomes crazy painful

Files:

Legend:

Unmodified
Added
Removed
Modified
Copied
Moved

  • src/Makefile.in

    rd091766 r57a3273  
    2525SUBS=utils jlog eventer modules 
    2626 
    27 OBJS=noitd.o noit_listener.o noit_console.o noit_poller.o \ 
     27OBJS=noitd.o noit_listener.o noit_console.o noit_check.o \ 
    2828        noit_module.o noit_conf.o 
    2929 

  • src/modules/http.c

    r5f413b7 r57a3273  
    1717 
    1818#include "noit_module.h" 
    19 #include "noit_poller.h" 
     19#include "noit_check.h" 
    2020#include "utils/noit_log.h" 
    2121#include "utils/noit_hash.h" 
    …… 
    3030typedef struct { 
    3131  noit_hash_table *options; 
    32   void (*results)(noit_module_t *, noit_check_t); 
     32  void (*results)(noit_module_t *, noit_check_t *); 
    3333} serf_module_conf_t; 
    3434 
    …… 
    5050 
    5151  noit_module_t *self; 
    52   noit_check_t check; 
     52  noit_check_t *check; 
    5353} handler_baton_t; 
    5454 
    …… 
    8989typedef struct { 
    9090  noit_module_t *self; 
    91   noit_check_t check; 
     91  noit_check_t *check; 
    9292  void *serf_baton; 
    9393  apr_socket_t *skt; 
    …… 
    100100static int serf_recur_handler(eventer_t e, int mask, void *closure, 
    101101                              struct timeval *now); 
    102 static void serf_log_results(noit_module_t *self, noit_check_t check); 
    103 static void resmon_log_results(noit_module_t *self, noit_check_t check); 
    104 static void resmon_part_log_results(noit_module_t *self, noit_check_t check, 
    105                                     noit_check_t parent); 
     102static void serf_log_results(noit_module_t *self, noit_check_t *check); 
     103static void resmon_log_results(noit_module_t *self, noit_check_t *check); 
     104static void resmon_part_log_results(noit_module_t *self, noit_check_t *check, 
     105                                    noit_check_t *parent); 
    106106 
    107107static int serf_config(noit_module_t *self, noit_hash_table *options) { 
    …… 
    124124  return 0; 
    125125} 
    126 static void generic_log_results(noit_module_t *self, noit_check_t check) { 
     126static void generic_log_results(noit_module_t *self, noit_check_t *check) { 
    127127  serf_module_conf_t *module_conf; 
    128128  module_conf = noit_module_get_userdata(self); 
    129129  module_conf->results(self, check); 
    130130} 
    131 static void serf_log_results(noit_module_t *self, noit_check_t check) { 
     131static void serf_log_results(noit_module_t *self, noit_check_t *check) { 
    132132  serf_check_info_t *ci = check->closure; 
    133133  struct timeval duration; 
    …… 
    161161  current.status = human_buffer; 
    162162  if(current.available == NP_AVAILABLE) { 
    163     noit_poller_set_metric_int(&current, "code", &ci->status.code); 
    164     noit_poller_set_metric_int(&current, "bytes", &ci->body.l); 
     163    noit_stats_set_metric_int(&current, "code", &ci->status.code); 
     164    noit_stats_set_metric_int(&current, "bytes", &ci->body.l); 
    165165  } 
    166166  else { 
    167     noit_poller_set_metric_int(&current, "code", NULL); 
    168     noit_poller_set_metric_int(&current, "bytes", NULL); 
    169   } 
    170   noit_poller_set_state(self, check, &current); 
     167    noit_stats_set_metric_int(&current, "code", NULL); 
     168    noit_stats_set_metric_int(&current, "bytes", NULL); 
     169  } 
     170  noit_check_set_stats(self, check, &current); 
    171171} 
    172172static void resmon_part_log_results_xml(noit_module_t *self, 
    173                                         noit_check_t check, 
     173                                        noit_check_t *check, 
    174174                                        xmlDocPtr xml) { 
    175175  resmon_check_info_t *rci = check->closure; 
    …… 
    213213  noitL(nldeb, "resmon_part(%s/%s/%s) [%s]\n", check->target, 
    214214        rci->resmod, rci->resserv, current.status); 
    215   noit_poller_set_state(self, check, &current); 
    216 } 
    217 static void resmon_part_log_results(noit_module_t *self, noit_check_t check, 
    218                                     noit_check_t parent) { 
     215  noit_check_set_stats(self, check, &current); 
     216} 
     217static void resmon_part_log_results(noit_module_t *self, noit_check_t *check, 
     218                                    noit_check_t *parent) { 
    219219  resmon_check_info_t *rci = parent->closure; 
    220220  resmon_part_log_results_xml(self, check, rci->xml_doc); 
    221221} 
    222 static void resmon_log_results(noit_module_t *self, noit_check_t check) { 
     222static void resmon_log_results(noit_module_t *self, noit_check_t *check) { 
    223223  serf_check_info_t *ci = check->closure; 
    224224  resmon_check_info_t *rci = check->closure; 
    …… 
    273273  current.status = human_buffer; 
    274274 
    275   noit_poller_set_metric_int(&current, "services", &services); 
     275  noit_stats_set_metric_int(&current, "services", &services); 
    276276  if(services) { 
    277277    int i; 
    …… 
    304304              /* The first is integer */ 
    305305              intval = (int)(atof(value) * 1000.0); 
    306               noit_poller_set_metric_int(&current, attr, &intval); 
     306              noit_stats_set_metric_int(&current, attr, &intval); 
    307307              break; 
    308308            case 1: 
    309309            case 2: 
    310               noit_poller_set_metric_string(&current, attr, (char *)value); 
     310              noit_stats_set_metric_string(&current, attr, (char *)value); 
    311311              break; 
    312312          } 
    …… 
    316316  } 
    317317 
    318   noit_poller_set_state(self, check, &current); 
     318  noit_check_set_stats(self, check, &current); 
    319319 
    320320 out: 
    …… 
    605605} 
    606606 
    607 static int serf_initiate(noit_module_t *self, noit_check_t check) { 
     607static int serf_initiate(noit_module_t *self, noit_check_t *check) { 
    608608  serf_closure_t *ccl; 
    609609  serf_check_info_t *ci; 
    …… 
    718718} 
    719719static int serf_schedule_next(noit_module_t *self, 
    720                               eventer_t e, noit_check_t check, 
     720                              eventer_t e, noit_check_t *check, 
    721721                              struct timeval *now) { 
    722722  eventer_t newe; 
    …… 
    762762  return 0; 
    763763} 
    764 static int serf_initiate_check(noit_module_t *self, noit_check_t check, 
    765                                int once, noit_check_t cause) { 
     764static int serf_initiate_check(noit_module_t *self, noit_check_t *check, 
     765                               int once, noit_check_t *cause) { 
    766766  if(!check->closure) check->closure = calloc(1, sizeof(serf_check_info_t)); 
    767767  if(once) { 
    …… 
    774774  return 0; 
    775775} 
    776 static int resmon_initiate_check(noit_module_t *self, noit_check_t check, 
    777                                  int once, noit_check_t parent) { 
     776static int resmon_initiate_check(noit_module_t *self, noit_check_t *check, 
     777                                 int once, noit_check_t *parent) { 
    778778  /* resmon_check_info_t gives us a bit more space */ 
    779779  if(!check->closure) check->closure = calloc(1, sizeof(resmon_check_info_t)); 
    …… 
    787787} 
    788788 
    789 static int resmon_part_initiate_check(noit_module_t *self, noit_check_t check, 
    790                                       int once, noit_check_t parent) { 
     789static int resmon_part_initiate_check(noit_module_t *self, noit_check_t *check, 
     790                                      int once, noit_check_t *parent) { 
    791791  char xpathexpr[1024]; 
    792792  const char *resmod, *resserv; 

  • src/modules/ping_icmp.c

    r5f413b7 r57a3273  
    1818 
    1919#include "noit_module.h" 
    20 #include "noit_poller.h" 
     20#include "noit_check.h" 
    2121#include "utils/noit_log.h" 
    2222 
    …… 
    4141struct ping_closure { 
    4242  noit_module_t *self; 
    43   noit_check_t check; 
     43  noit_check_t *check; 
    4444  void *payload; 
    4545  int payload_len; 
    …… 
    5959  return 0; 
    6060} 
    61 static int ping_icmp_is_complete(noit_module_t *self, noit_check_t check) { 
     61static int ping_icmp_is_complete(noit_module_t *self, noit_check_t *check) { 
    6262  int i; 
    6363  struct check_info *data; 
    …… 
    7171  return 1; 
    7272} 
    73 static void ping_icmp_log_results(noit_module_t *self, noit_check_t check) { 
     73static void ping_icmp_log_results(noit_module_t *self, noit_check_t *check) { 
    7474  struct check_info *data; 
    7575  float avail, min = MAXFLOAT, max = 0.0, avg = 0.0, cnt; 
    …… 
    109109  current.state = (avail < 1.0) ? NP_BAD : NP_GOOD; 
    110110  current.status = human_buffer; 
    111   noit_poller_set_metric_int(&current, "count", &data->expected_count); 
     111  noit_stats_set_metric_int(&current, "count", &data->expected_count); 
    112112  avail *= 100.0; 
    113   noit_poller_set_metric_float(&current, "available", &avail); 
    114   noit_poller_set_metric_float(&current, "minimum", avail > 0.0 ? &min : NULL); 
    115   noit_poller_set_metric_float(&current, "maximum", avail > 0.0 ? &max : NULL); 
    116   noit_poller_set_metric_float(&current, "average", avail > 0.0 ? &avg : NULL); 
    117   noit_poller_set_state(self, check, &current); 
     113  noit_stats_set_metric_float(&current, "available", &avail); 
     114  noit_stats_set_metric_float(&current, "minimum", avail > 0.0 ? &min : NULL); 
     115  noit_stats_set_metric_float(&current, "maximum", avail > 0.0 ? &max : NULL); 
     116  noit_stats_set_metric_float(&current, "average", avail > 0.0 ? &avg : NULL); 
     117  noit_check_set_stats(self, check, &current); 
    118118} 
    119119static int ping_icmp_timeout(eventer_t e, int mask, 
    …… 
    145145  while(1) { 
    146146    int inlen, iphlen; 
    147     noit_check_t check; 
     147    noit_check_t *check; 
    148148    struct timeval tt; 
    149149 
    …… 
    321321  return 0; 
    322322} 
    323 static int ping_icmp_send(noit_module_t *self, noit_check_t check) { 
     323static int ping_icmp_send(noit_module_t *self, noit_check_t *check) { 
    324324  struct timeval when, p_int; 
    325325  struct icmp *icp; 
    …… 
    415415} 
    416416static int ping_icmp_schedule_next(noit_module_t *self, 
    417                                    eventer_t e, noit_check_t check, 
     417                                   eventer_t e, noit_check_t *check, 
    418418                                   struct timeval *now) { 
    419419  eventer_t newe; 
    …… 
    459459  return 0; 
    460460} 
    461 static int ping_icmp_initiate_check(noit_module_t *self, noit_check_t check, 
    462                                     int once, noit_check_t cause) { 
     461static int ping_icmp_initiate_check(noit_module_t *self, noit_check_t *check, 
     462                                    int once, noit_check_t *cause) { 
    463463  if(!check->closure) check->closure = calloc(1, sizeof(struct check_info)); 
    464464  if(once) { 

  • src/noit_console.c

    rcaa7b86 r57a3273  
    1212#include "utils/noit_log.h" 
    1313#include "noit_listener.h" 
    14 #include "noit_poller.h" 
    1514#include "noit_console.h" 
    1615 

  • src/noit_module.h

    r5f413b7 r57a3273  
    99#include "noit_defines.h" 
    1010#include "utils/noit_hash.h" 
    11 #include "noit_poller.h" 
     11#include "noit_check.h" 
    1212 
    1313#define NOIT_MODULE_MAGIC         0x4017DA7A 
    …… 
    2222  int (*config)(struct _noit_module *, noit_hash_table *options); 
    2323  int (*init)(struct _noit_module *); 
    24   int (*initiate_check)(struct _noit_module *, noit_check_t check, 
    25                         int once, noit_check_t cause); 
     24  int (*initiate_check)(struct _noit_module *, noit_check_t *check, 
     25                        int once, noit_check_t *cause); 
    2626  void *opaque_handle; 
    2727} noit_module_t;