3 #ifndef __ARC_JOBINFORMATIONSTORAGEBDB_H__
4 #define __ARC_JOBINFORMATIONSTORAGEBDB_H__
8 #include "JobInformationStorage.h"
19 bool ReadAll(std::list<Job>& jobs,
const std::list<std::string>& rejectEndpoints = std::list<std::string>());
20 bool Read(std::list<Job>& jobs, std::list<std::string>& jobIdentifiers,
21 const std::list<std::string>& endpoints = std::list<std::string>(),
22 const std::list<std::string>& rejectEndpoints = std::list<std::string>());
23 bool Write(
const std::list<Job>& jobs);
24 bool Write(
const std::list<Job>& jobs,
const std::set<std::string>& prunedServices, std::list<const Job*>& newJobs);
26 bool Remove(
const std::list<std::string>& jobids);
29 static void logErrorMessage(
int err);
35 JobDB(
const std::string&, u_int32_t = DB_RDONLY);
40 static void handleError(
const DbEnv *dbenv,
const char *errpfx,
const char *msg);
42 Db* operator->() {
return jobDB; }
43 Db* viaNameKeys() {
return nameSecondaryKeyDB; }
44 Db* viaEndpointKeys() {
return endpointSecondaryKeyDB; }
45 Db* viaServiceInfoKeys() {
return serviceInfoSecondaryKeyDB; }
49 Db *endpointSecondaryKeyDB;
50 Db *nameSecondaryKeyDB;
51 Db *serviceInfoSecondaryKeyDB;
56 BDBException(
const std::string& msg,
int ret,
bool writeLogMessage =
true)
throw();
57 ~BDBException()
throw() {}
58 const std::string& getMessage()
const throw() {
return message; }
59 int getReturnValue()
const throw() {
return returnvalue; }
69 #endif // __ARC_JOBINFORMATIONSTORAGEBDB_H__