| 1 |
afaq |
1.1 |
#ifndef _DBSClient_hpp_
|
| 2 |
|
|
#define _DBSClient_hpp_
|
| 3 |
|
|
|
| 4 |
|
|
//#include "Socket.hpp"
|
| 5 |
|
|
//#include "GSS.hpp"
|
| 6 |
|
|
//#include "SocketException.hpp"
|
| 7 |
|
|
//#include "GSSException.hpp"
|
| 8 |
|
|
#include "Message.hpp"
|
| 9 |
|
|
//#include "Communicate.hpp"
|
| 10 |
|
|
#include "Configuration.hpp"
|
| 11 |
|
|
#include "DBSDispatcher.hpp"
|
| 12 |
|
|
#include "ClientAPIData.hpp"
|
| 13 |
|
|
#include "Util.hpp"
|
| 14 |
|
|
#include "common.hpp"
|
| 15 |
afaq |
1.2 |
#include <log4cxx/logger.h>
|
| 16 |
afaq |
1.1 |
#include <iostream>
|
| 17 |
|
|
|
| 18 |
|
|
class DBSClient {
|
| 19 |
|
|
|
| 20 |
|
|
public:
|
| 21 |
|
|
DBSClient();
|
| 22 |
|
|
~DBSClient();
|
| 23 |
|
|
|
| 24 |
|
|
//std::string buildDataset(std::string basepathName, std::string analysisDataset);
|
| 25 |
|
|
/*
|
| 26 |
|
|
int buildDataset(std::string basepathName, std::string analysisDataset);
|
| 27 |
|
|
|
| 28 |
|
|
int addEventCollection(std::string basePathName, ECInfo);
|
| 29 |
|
|
pathName buildDataset(std::string basepathName, AD, std::list<EventColllections>);
|
| 30 |
|
|
pathName buildDataset(styring basepathName, AD, predicate);
|
| 31 |
|
|
pathName buildDataset(std::string basepathName, AD);
|
| 32 |
|
|
|
| 33 |
|
|
std::list<EventColllections> displayDatasetContents(std::string pathName);
|
| 34 |
|
|
std::list<EventColllections> displayDatasetContents(sttring initialPathName, std::string predicate);
|
| 35 |
|
|
|
| 36 |
|
|
closeDataset();
|
| 37 |
|
|
deleteDataset(pathName, deepFlag);
|
| 38 |
|
|
|
| 39 |
|
|
addToDataset(pathName, std::list<EventColllections>);
|
| 40 |
|
|
|
| 41 |
|
|
globalPathName = publishDataset(pathName);
|
| 42 |
|
|
|
| 43 |
|
|
std::list<EventColllections>, foundLumi = partialDataset(pathName, lumiDesired); */
|
| 44 |
|
|
|
| 45 |
|
|
int addPerson(Person_ClientAPIData& personInfo);
|
| 46 |
|
|
//int addRole(Role_ClientAPIData& roleInfo);
|
| 47 |
|
|
//int assignRole(Administrative_ClientAPIData& adminInfo);
|
| 48 |
|
|
int assignPhysicsGroup(Physicsgroup_ClientAPIData& phgrpInfo);
|
| 49 |
|
|
int createProcessedDataset(Processingpath_ClientAPIData& processingPathInfo);
|
| 50 |
|
|
int createAnalysisDataset(Analysisdataset_ClientAPIData& analysisDatasetInfo);
|
| 51 |
|
|
|
| 52 |
|
|
int createPrimaryDataset(std::string primaryDatasetName, Primarydataset_ClientAPIData& primaryDatasetInfo);
|
| 53 |
|
|
|
| 54 |
|
|
int insertApps(Insertapps_ClientAPIData& appsInfo);
|
| 55 |
|
|
int insertEventCollections(Evcollview_ClientAPIData& ecInfo);
|
| 56 |
|
|
|
| 57 |
|
|
int readPrimaryDataset(Primarydataset_ClientAPIData, std::vector<Primarydataset_ClientAPIData*>& primaryDatasetInfo);
|
| 58 |
|
|
int readEvColls(Evcollview_ClientAPIData, std::vector<Evcollview_ClientAPIData*>& evCollInfo);
|
| 59 |
|
|
int readProcessingPath(Processingpath_ClientAPIData, vector<Processingpath_ClientAPIData*>& procPathInfo);
|
| 60 |
|
|
int readEvCollFiles(Fileview_ClientAPIData, vector<Fileview_ClientAPIData*>& fileInfo);
|
| 61 |
|
|
int getDatasetProvenenceParent(Datasetprovenenceevparent_ClientAPIData,
|
| 62 |
|
|
vector<Datasetprovenenceevparent_ClientAPIData*>& dspInfo);
|
| 63 |
|
|
int getDatasetProvenenceChild(Datasetprovenenceevchild_ClientAPIData,
|
| 64 |
|
|
vector<Datasetprovenenceevchild_ClientAPIData*>& dspInfo);
|
| 65 |
|
|
int readCRABEvColls(Crabevcollview_ClientAPIData apiDataToSend,
|
| 66 |
|
|
vector<Crabevcollview_ClientAPIData*>& evCollInfo);
|
| 67 |
|
|
//createProcessedDataset(/primary/DT/processedDatasetName, processedDatasetInfo);
|
| 68 |
|
|
//showDatasetInfo(outputSelector);
|
| 69 |
|
|
|
| 70 |
|
|
private:
|
| 71 |
|
|
int raiseServerException(void);
|
| 72 |
|
|
|
| 73 |
|
|
Message mSend;
|
| 74 |
|
|
Message mRecv;
|
| 75 |
|
|
int callServer(void);
|
| 76 |
|
|
bool localServer;
|
| 77 |
|
|
//GSS* gSecure;
|
| 78 |
|
|
Util util;
|
| 79 |
afaq |
1.2 |
log4cxx::LoggerPtr logger;
|
| 80 |
afaq |
1.1 |
};
|
| 81 |
|
|
|
| 82 |
|
|
#endif
|
