diff --git a/analyzers/Cross.h b/analyzers/Cross.h index 10790e9..288cb17 100644 --- a/analyzers/Cross.h +++ b/analyzers/Cross.h @@ -27,9 +27,9 @@ public: evtbder = GetEventBuilder(); evtbder->SetTimeWindow(500); - //========== use the influx from the Analyzer - influx = new InfluxDB("http://localhost:8086"); - dataBaseName = "testing"; + SetDatabase("http://localhost:8086/", "testing", "zKhzKk4Yhf1l9QU-yE2GsIZ1RazqUgoW3NlF8LJqq_xDMwatOJwg1sKrjgq36uLEsQf8Fmn4sJALP7Kkilk14A=="); + + printf(" %p \n", influx); SetUpCanvas(); // see below @@ -220,9 +220,11 @@ inline void Cross::UpdateHistograms(){ //printf("%llu %llu, %f %d\n", tMin1[p], tMax1[p], dT, count1[p]); printf("%10s | %d | %f Hz \n", cutNameList1[p].toStdString().c_str(), count1[p], rate); - influx->AddDataPoint("Cut,name=" + cutNameList1[p].toStdString()+ " value=" + std::to_string(rate)); - influx->WriteData("testing"); - influx->ClearDataPointsBuffer(); + if( influx ){ + influx->AddDataPoint("Cut,name=" + cutNameList1[p].toStdString()+ " value=" + std::to_string(rate)); + influx->WriteData("testing"); + influx->ClearDataPointsBuffer(); + } } } diff --git a/analyzers/MCP.h b/analyzers/MCP.h index 4050960..569dcbc 100644 --- a/analyzers/MCP.h +++ b/analyzers/MCP.h @@ -31,6 +31,7 @@ public: evtbder = GetEventBuilder(); evtbder->SetTimeWindow(500); //ns + influx = new InfluxDB(); SetDatabase("https://localhost:8086", "testing", "zKhzKk4Yhf1l9QU-yE2GsIZ1RazqUgoW3NlF8LJqq_xDMwatOJwg1sKrjgq36uLEsQf8Fmn4sJALP7Kkilk14A=="); SetUpCanvas(); // see below diff --git a/analyzers/MCPandPSD.h b/analyzers/MCPandPSD.h index 8c1a5dc..cd82b96 100644 --- a/analyzers/MCPandPSD.h +++ b/analyzers/MCPandPSD.h @@ -28,6 +28,7 @@ public: evtbder = GetEventBuilder(); evtbder->SetTimeWindow(500); + influx = new InfluxDB(); SetDatabase("https://localhost:8086", "testing", "zKhzKk4Yhf1l9QU-yE2GsIZ1RazqUgoW3NlF8LJqq_xDMwatOJwg1sKrjgq36uLEsQf8Fmn4sJALP7Kkilk14A=="); SetUpCanvas(); // see below diff --git a/analyzers/RAISOR1.h b/analyzers/RAISOR1.h index 7263117..7303860 100644 --- a/analyzers/RAISOR1.h +++ b/analyzers/RAISOR1.h @@ -25,6 +25,7 @@ public: evtbder = GetEventBuilder(); evtbder->SetTimeWindow(500); + influx = new InfluxDB(); SetDatabase("https://localhost:8086", "testing", "zKhzKk4Yhf1l9QU-yE2GsIZ1RazqUgoW3NlF8LJqq_xDMwatOJwg1sKrjgq36uLEsQf8Fmn4sJALP7Kkilk14A=="); SetUpCanvas(); // see below diff --git a/analyzers/RAISOR2.h b/analyzers/RAISOR2.h index 99bfb84..966fd04 100644 --- a/analyzers/RAISOR2.h +++ b/analyzers/RAISOR2.h @@ -26,6 +26,7 @@ public: evtbder->SetTimeWindow(500); //========== use the influx from the Analyzer + influx = new InfluxDB(); SetDatabase("https://localhost:8086", "testing", "zKhzKk4Yhf1l9QU-yE2GsIZ1RazqUgoW3NlF8LJqq_xDMwatOJwg1sKrjgq36uLEsQf8Fmn4sJALP7Kkilk14A=="); SetUpCanvas(); // see below diff --git a/analyzers/Target.h b/analyzers/Target.h index 9372b46..47ccf26 100644 --- a/analyzers/Target.h +++ b/analyzers/Target.h @@ -27,6 +27,7 @@ public: evtbder = GetEventBuilder(); evtbder->SetTimeWindow(500); + influx = new InfluxDB(); SetDatabase("https://localhost:8086", "testing", "zKhzKk4Yhf1l9QU-yE2GsIZ1RazqUgoW3NlF8LJqq_xDMwatOJwg1sKrjgq36uLEsQf8Fmn4sJALP7Kkilk14A=="); SetUpCanvas(); // see below