21#include <fairlogger/Logger.h>
31 LOG(
debug) <<
"Scalers not written to CCDB none";
35 using namespace std::chrono_literals;
36 std::chrono::seconds days3 = 259200s;
37 std::chrono::seconds min10 = 600s;
38 long time3days = std::chrono::duration_cast<std::chrono::milliseconds>(days3).count();
39 long time10min = std::chrono::duration_cast<std::chrono::milliseconds>(min10).count();
40 long tmin = timeStart - time10min;
41 long tmax = timeStop + time3days;
43 std::map<std::string, std::string> metadata;
49 LOG(info) <<
"CTP scalers saved in ccdb:" <<
mCCDBHost <<
" run:" << scalers.
getRunNumber() <<
" tmin:" << tmin <<
" tmax:" << tmax;
51 LOG(fatal) <<
"Problem writing to database ret:" << ret;
59 LOG(
debug) <<
"Scalers not written to QCDB none";
63 using namespace std::chrono_literals;
64 std::chrono::seconds days3 = 259200s;
65 std::chrono::seconds min10 = 600s;
66 long time3days = std::chrono::duration_cast<std::chrono::milliseconds>(days3).count();
67 long time10min = std::chrono::duration_cast<std::chrono::milliseconds>(min10).count();
68 long tmin = timeStart - time10min;
69 long tmax = timeStop + time3days;
71 std::map<std::string, std::string> metadata;
77 LOG(info) <<
"CTP scalers saved in qcdb:" <<
mQCDBHost <<
" run:" << scalers.
getRunNumber() <<
" tmin:" << tmin <<
" tmax:" << tmax;
79 LOG(fatal) <<
"CTP scalers Problem writing to database qcdb ret:" << ret;
87 LOG(info) <<
"CTP config not written to CCDB none";
90 using namespace std::chrono_literals;
91 std::chrono::seconds days3 = 259200s;
92 std::chrono::seconds min10 = 600s;
93 long time3days = std::chrono::duration_cast<std::chrono::milliseconds>(days3).count();
94 long time10min = std::chrono::duration_cast<std::chrono::milliseconds>(min10).count();
95 long tmin = timeStart - time10min;
96 long tmax = timeStart + time3days;
98 std::map<std::string, std::string> metadata;
104 LOG(info) <<
"CTP config saved in ccdb:" <<
mCCDBHost <<
" run:" << cfg->
getRunNumber() <<
" tmin:" << tmin <<
" tmax:" << tmax;
106 LOG(fatal) <<
"CTPConfig: Problem writing to database ret:" << ret;
114 LOG(info) <<
"SOX Orbit not written to CCDB none";
117 std::vector<int64_t> vect;
118 if (timestamp == 0) {
119 auto now = std::chrono::system_clock::now();
120 timestamp = std::chrono::duration_cast<std::chrono::microseconds>(now.time_since_epoch()).count();
122 vect.push_back(timestamp);
123 vect.push_back((uint64_t)runNumber);
124 vect.push_back((uint64_t)soxOrbit);
125 long tmin = timestamp / 1000;
126 long tmax = tmin + 381928219;
128 std::map<std::string, std::string> metadata;
135 LOG(info) <<
"SOX orbit saved in ccdb:" <<
mCCDBHost <<
" run:" << runNumber <<
" tmin:" << tmin <<
" tmax:" << tmax;
137 LOG(fatal) <<
"SOX orbit Problem writing to database ret:" << ret;
145 LOG(info) <<
"Orbit Reset not written to CCDB none";
148 std::vector<int64_t> vect;
149 if (timeStamp == 0) {
150 auto now = std::chrono::system_clock::now();
151 timeStamp = std::chrono::duration_cast<std::chrono::microseconds>(now.time_since_epoch()).count();
152 LOG(warn) <<
"Received timestamp = 0 , using current time:" << timeStamp;
154 vect.push_back(timeStamp);
155 long tmin = timeStamp / 1000;
156 long tmax = tmin + 381928219;
158 std::map<std::string, std::string> metadata;
161 std::cout <<
"Storing:" <<
mCCDBPathOrbitReset <<
" tmin:" << tmin <<
" tmax:" << tmax <<
" ts:" << timeStamp << std::endl;
162 std::string
filename =
"orbitReset.root";
163 auto classname =
"std::vector<int64_t>";
164 metadata[
"adjustableEOV"] =
"true";
167 adjustOverriddenEOV(api, oi);
169 LOG(info) <<
"Orbit reset saved in ccdb:" <<
mCCDBHost <<
" tmin:" << tmin <<
" tmax:" << tmax;
171 LOG(fatal) <<
"Orbit reset Problem writing to database ret:" << ret;
178 LOG(info) <<
"CtpCfg not written to CCDB none";
184 using namespace std::chrono_literals;
185 std::chrono::seconds days3 = 259200s;
186 std::chrono::seconds min10 = 600s;
187 long time3days = std::chrono::duration_cast<std::chrono::milliseconds>(days3).count();
188 long time10min = std::chrono::duration_cast<std::chrono::milliseconds>(min10).count();
189 long tmin = timeStart - time10min;
190 long tmax = timeStart + time3days;
192 std::map<std::string, std::string> metadata;
198 LOG(info) <<
"CtpCfg saved in ccdb:" <<
mCCDBHost <<
" tmin:" << tmin <<
" tmax:" << tmax;
200 LOG(error) <<
"CtpCfg Problem writing to database ret:" << ret;
209 std::map<std::string, std::string> metadata;
210 metadata[
"runNumber"] = run;
212 if (ctpconfigdb ==
nullptr) {
213 LOG(info) <<
"CTP config not in database, timestamp:" << timestamp;
217 LOG(info) <<
"CTP config found. Run:" << run;
227 LOG(error) <<
"CTP config not in CCDB";
236 std::map<std::string, std::string> metadata;
237 metadata[
"runNumber"] = run;
239 if (ctpscalers ==
nullptr) {
240 LOG(info) <<
"CTPRunScalers not in database, timestamp:" << timestamp;
static BasicCCDBManager & instance()
int storeAsTFileAny(const T *obj, std::string const &path, std::map< std::string, std::string > const &metadata, long startValidityTimestamp=-1, long endValidityTimestamp=-1, std::vector< char >::size_type maxSize=0) const
void init(std::string const &hosts)
const std::string mCCDBPathOrbitReset
static std::string mCCDBHost
Database constants.
const std::string mQCDBPathCTPScalers
int saveRunScalersToQCDB(CTPRunScalers &scalers, long timeStart, long timeStop)
static std::string mQCDBHost
int saveSoxOrbit(uint32_t runNumber, uint32_t soxOrbit, long timeStart)
CTPRunScalers getScalersFromCCDB(long timestamp, std::string, bool &ok)
int saveRunScalersToCCDB(CTPRunScalers &scalers, long timeStart, long timeStop)
int saveRunConfigToCCDB(CTPConfiguration *cfg, long timeStart)
int saveCtpCfg(uint32_t runNumber, long timeStamp)
static CTPConfiguration getConfigFromCCDB(long timestamp, std::string run, bool &ok)
const std::string mCCDBPathCtpCfg
const std::string mCCDBPathCTPScalers
int saveOrbitReset(long timeStamp)
const std::string mCCDBPathSoxOrbit
const std::string CCDBPathCTPConfig
Database constants.
std::string to_string(gsl::span< T, Size > span)
int readAndSave(std::string &path)
LOG(info)<< "Compressed in "<< sw.CpuTime()<< " s"