Changeset 529ead1224b4f4c376941c9b2091f1c4200e2cba

Show
Ignore:
Timestamp:
11/16/11 16:42:48 (3 years ago)
Author:
Theo Schlossnagle <jesus@omniti.com>
git-committer:
Theo Schlossnagle <jesus@omniti.com> 1321461768 -0500
git-parent:

[7e10f7cd6a31e714c883c3b0f528f09b004a2d9f]

git-author:
Theo Schlossnagle <jesus@omniti.com> 1321461768 -0500
Message:

add an uptime metric to the internal stratcond metrics

Files:

Legend:

Unmodified
Added
Removed
Modified
Copied
Moved
  • src/stratcon_jlog_streamer.c

    r9e9846c r529ead1  
    11331133  char str[1024]; 
    11341134  char uuid_str[UUID_STR_LEN+1]; 
     1135  struct timeval epoch, diff; 
     1136  u_int64_t uptime = 0; 
    11351137 
    11361138  uuid_unparse_lower(self_stratcon_id, uuid_str); 
     1139 
     1140#define PUSH_BOTH(type, str) do { \ 
     1141  stratcon_datastore_push(type, \ 
     1142                          (struct sockaddr *)&self_stratcon_ip, \ 
     1143                          self_stratcon_hostname, str, NULL); \ 
     1144  stratcon_iep_line_processor(type, \ 
     1145                              (struct sockaddr *)&self_stratcon_ip, \ 
     1146                              self_stratcon_hostname, str, NULL); \ 
     1147} while(0) 
    11371148 
    11381149  if(closure == NULL) { 
     
    11451156             (long unsigned int)now->tv_usec/1000UL, uuid_str, ip_str, 
    11461157             self_stratcon_hostname); 
    1147     stratcon_datastore_push(DS_OP_INSERT, 
    1148                             (struct sockaddr *)&self_stratcon_ip, 
    1149                             self_stratcon_hostname, strdup(str), NULL); 
    1150     stratcon_iep_line_processor(DS_OP_INSERT, 
    1151                                 (struct sockaddr *)&self_stratcon_ip, 
    1152                                 self_stratcon_hostname, strdup(str), NULL); 
     1158    PUSH_BOTH(DS_OP_INSERT, strdup(str)); 
    11531159  } 
    11541160 
     
    11631169  pthread_mutex_unlock(&noits_lock); 
    11641170 
    1165   snprintf(str, sizeof(str), "S\t%lu.%03lu\t%s\tG\tA\t0\tok\n", 
     1171  snprintf(str, sizeof(str), "S\t%lu.%03lu\t%s\tG\tA\t0\tok %d noits\n", 
    11661172           (long unsigned int)now->tv_sec, 
    1167            (long unsigned int)now->tv_usec/1000UL, uuid_str); 
    1168   stratcon_datastore_push(DS_OP_INSERT, 
    1169                           (struct sockaddr *)&self_stratcon_ip, 
    1170                           self_stratcon_hostname, strdup(str), NULL); 
    1171   stratcon_iep_line_processor(DS_OP_INSERT, \ 
    1172                               (struct sockaddr *)&self_stratcon_ip, \ 
    1173                               self_stratcon_hostname, strdup(str), NULL); \ 
     1173           (long unsigned int)now->tv_usec/1000UL, uuid_str, n); 
     1174  PUSH_BOTH(DS_OP_INSERT, strdup(str)); 
     1175 
     1176  if(eventer_get_epoch(&epoch) != 0) 
     1177    memcpy(&epoch, now, sizeof(epoch)); 
     1178  sub_timeval(*now, epoch, &diff); 
     1179  uptime = diff.tv_sec; 
     1180  snprintf(str, sizeof(str), "M\t%lu.%03lu\t%s\tuptime\tL\t%llu\n", 
     1181           (long unsigned int)now->tv_sec, 
     1182           (long unsigned int)now->tv_usec/1000UL, 
     1183           uuid_str, uptime); 
     1184noitL(noit_error, "HERE --> %llu\n", uptime); 
     1185  PUSH_BOTH(DS_OP_INSERT, strdup(str)); 
     1186 
    11741187  for(i=0; i<n; i++) { 
    11751188    emit_noit_info_metrics(now, uuid_str, ctxs[i]); 
     
    11771190  } 
    11781191  free(ctxs); 
    1179   stratcon_datastore_push(DS_OP_CHKPT, 
    1180                           (struct sockaddr *)&self_stratcon_ip, 
    1181                           self_stratcon_hostname, NULL, NULL); 
    1182   stratcon_iep_line_processor(DS_OP_CHKPT, \ 
    1183                               (struct sockaddr *)&self_stratcon_ip, \ 
    1184                               self_stratcon_hostname, NULL, NULL); \ 
     1192  PUSH_BOTH(DS_OP_CHKPT, NULL); 
    11851193 
    11861194  add_timeval(e->whence, whence, &whence); 
  • test/t/108_noit_strat.t

    r6acb955 r529ead1  
    1818  { id => '52f1f2ec-0275-11e0-a846-b757d1de0f4a', 
    1919    topic => 'numeric', 
    20     epl => 'select * from NoitMetricNumeric as r' 
     20    epl => "select * from NoitMetricNumeric(check_module='selfcheck') as r" 
    2121  }, 
    2222  { id => '8f04d54c-0275-11e0-b62c-6fdd90cb8bde', 
  • test/t/testconfig.pm

    r6acb955 r529ead1  
    485485  open (my $o, ">$file") || BAIL_OUT("can't write config: $file"); 
    486486  print $o qq{<?xml version="1.0" encoding="utf8" standalone="yes"?>\n}; 
    487   print $o qq{<stratcon>}; 
     487  print $o qq{<stratcon id="8325581c-1068-11e1-ac63-db8546d81c8b" metric_period="1000">}; 
    488488  make_eventer_config($o, $options); 
    489489  make_rest_acls($o, $options);