Signed-off-by: vlad shkapenyuk <vshkap@research.att.com>
Change-Id: I57132f752afb928d4a5af9bb4d254edb59d4b57a
memcpy(new_data + temp_tup.tuple_size + sizeof(gs_uint64_t) + tup_trace_sz * sizeof(fta_stat), (char*)&stats, sizeof(fta_stat));
// Send a hearbeat message to clearinghouse.
memcpy(new_data + temp_tup.tuple_size + sizeof(gs_uint64_t) + tup_trace_sz * sizeof(fta_stat), (char*)&stats, sizeof(fta_stat));
// Send a hearbeat message to clearinghouse.
- fta_heartbeat(ftap->_fta.ftaid, trace_id, tup_trace_sz + 1, (fta_stat *)((char*)new_data + temp_tup.tuple_size + sizeof(gs_uint64_t)));
+ // Disable sending heartbeats for now to avoid overloading clearinghouse
+ // fta_heartbeat(ftap->_fta.ftaid, trace_id, tup_trace_sz + 1, (fta_stat *)((char*)new_data + temp_tup.tuple_size + sizeof(gs_uint64_t)));
temp_tup.free_tuple();
temp_tup.data = new_data;
temp_tup.free_tuple();
temp_tup.data = new_data;
gs_retval_t UNOP_HFTA_clock_fta(struct FTA *ftap) {
// Send a hearbeat message to clearinghouse.to indicate we are alive
gs_retval_t UNOP_HFTA_clock_fta(struct FTA *ftap) {
// Send a hearbeat message to clearinghouse.to indicate we are alive
- fta_heartbeat(ftap->ftaid, 0, 0, 0);
+ // Disable sending heartbeats for now to avoid overloading clearinghouse
+ // fta_heartbeat(ftap->ftaid, 0, 0, 0);
memcpy(new_data + temp_tup.tuple_size + sizeof(gs_uint64_t) + tup_trace_sz * sizeof(fta_stat), (char*)&stats, sizeof(fta_stat));
// Send a hearbeat message to clearinghouse.
memcpy(new_data + temp_tup.tuple_size + sizeof(gs_uint64_t) + tup_trace_sz * sizeof(fta_stat), (char*)&stats, sizeof(fta_stat));
// Send a hearbeat message to clearinghouse.
- fta_heartbeat(fta->ftaid, trace_id, tup_trace_sz + 1, (fta_stat *)((char*)new_data + temp_tup.tuple_size + sizeof(gs_uint64_t)));
+ // Disable sending heartbeats for now to avoid overloading clearinghouse
+ // fta_heartbeat(fta->ftaid, trace_id, tup_trace_sz + 1, (fta_stat *)((char*)new_data + temp_tup.tuple_size + sizeof(gs_uint64_t)));
// reset the stats
ftap->in_tuple_cnt = 0;
// reset the stats
ftap->in_tuple_cnt = 0;
stats.cycle_cnt = ftap->cycle_cnt;
// Send a hearbeat message to clearinghouse.
stats.cycle_cnt = ftap->cycle_cnt;
// Send a hearbeat message to clearinghouse.
- fta_heartbeat(fta->ftaid, ftap->trace_id++, 1, &stats);
+ // Disable sending heartbeats for now to avoid overloading clearinghouse
+ // fta_heartbeat(fta->ftaid, ftap->trace_id++, 1, &stats);
// resets runtime stats
ftap->in_tuple_cnt = 0;
// resets runtime stats
ftap->in_tuple_cnt = 0;
ret+="\tpost_tuple(tuple);\n";
ret += "\n\t/* Send a heartbeat message to clearinghouse */\n";
ret+="\tpost_tuple(tuple);\n";
ret += "\n\t/* Send a heartbeat message to clearinghouse */\n";
- ret += "\tfta_heartbeat(f->ftaid, t->trace_id++, 1, &stats);\n";
+ ret += "\n\t/* Disable heartbeats for now to avoid overloading clearinghouse */\n";
+ ret += "\t/* fta_heartbeat(f->ftaid, t->trace_id++, 1, &stats); */\n";
ret += "\n\t/* Reset runtime stats */\n";
ret += "\tt->in_tuple_cnt = 0;\n";
ret += "\n\t/* Reset runtime stats */\n";
ret += "\tt->in_tuple_cnt = 0;\n";
memcpy(trace_buffer + (sz * sizeof(fta_stat)), &myftaid, sizeof(FTAID));
memcpy(trace_buffer + (sz * sizeof(fta_stat)), &myftaid, sizeof(FTAID));
- fta_heartbeat(gscpipc_getftaid(), trace_id, sz+1, (fta_stat *)trace_buffer);
+ /* disable heartbeats for now to avoid overloading clearinghouse */
+ /* fta_heartbeat(gscpipc_getftaid(), trace_id, sz+1, (fta_stat *)trace_buffer); */
free(trace_buffer);
res=2; //indicate that it is a temporal tuple
}
free(trace_buffer);
res=2; //indicate that it is a temporal tuple
}
// to avoid sending redundant FTA instance stats to GSHUB we will only send statistics that have trace size of 1
// for application heartbeats (streamid=0) we will only send last stat in their traces
if ((sz == 1) || (trace[sz-1].ftaid.streamid == 0)) {
// to avoid sending redundant FTA instance stats to GSHUB we will only send statistics that have trace size of 1
// for application heartbeats (streamid=0) we will only send last stat in their traces
if ((sz == 1) || (trace[sz-1].ftaid.streamid == 0)) {
- if (set_instancestats(gshub,get_instance_name(),&trace[sz-1])!=0) {
+ /* disable sending heartbeats for now to avoid overloading gshub */
+ /*if (set_instancestats(gshub,get_instance_name(),&trace[sz-1])!=0) {
gslog(LOG_EMERG,"ERROR:could not set instancestats");
return -1;
gslog(LOG_EMERG,"ERROR:could not set instancestats");
return -1;