Changeset 529ead1224b4f4c376941c9b2091f1c4200e2cba
- Timestamp:
- 11/16/11 16:42:48 (2 years ago)
- git-parent:
- Files:
-
- src/stratcon_jlog_streamer.c (modified) (4 diffs)
- test/t/108_noit_strat.t (modified) (1 diff)
- test/t/testconfig.pm (modified) (1 diff)
Legend:
- Unmodified
- Added
- Removed
- Modified
- Copied
- Moved
src/stratcon_jlog_streamer.c
r9e9846c r529ead1 1133 1133 char str[1024]; 1134 1134 char uuid_str[UUID_STR_LEN+1]; 1135 struct timeval epoch, diff; 1136 u_int64_t uptime = 0; 1135 1137 1136 1138 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) 1137 1148 1138 1149 if(closure == NULL) { … … 1145 1156 (long unsigned int)now->tv_usec/1000UL, uuid_str, ip_str, 1146 1157 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)); 1153 1159 } 1154 1160 … … 1163 1169 pthread_mutex_unlock(&noits_lock); 1164 1170 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", 1166 1172 (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); 1184 noitL(noit_error, "HERE --> %llu\n", uptime); 1185 PUSH_BOTH(DS_OP_INSERT, strdup(str)); 1186 1174 1187 for(i=0; i<n; i++) { 1175 1188 emit_noit_info_metrics(now, uuid_str, ctxs[i]); … … 1177 1190 } 1178 1191 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); 1185 1193 1186 1194 add_timeval(e->whence, whence, &whence); test/t/108_noit_strat.t
r6acb955 r529ead1 18 18 { id => '52f1f2ec-0275-11e0-a846-b757d1de0f4a', 19 19 topic => 'numeric', 20 epl => 'select * from NoitMetricNumeric as r'20 epl => "select * from NoitMetricNumeric(check_module='selfcheck') as r" 21 21 }, 22 22 { id => '8f04d54c-0275-11e0-b62c-6fdd90cb8bde', test/t/testconfig.pm
r6acb955 r529ead1 485 485 open (my $o, ">$file") || BAIL_OUT("can't write config: $file"); 486 486 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">}; 488 488 make_eventer_config($o, $options); 489 489 make_rest_acls($o, $options);
