| 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 |
#include <log4cxx/logger.h>
|
| 16 |
#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) throw (const char*);
|
| 46 |
//int addRole(Role_ClientAPIData& roleInfo);
|
| 47 |
//int assignRole(Administrative_ClientAPIData& adminInfo);
|
| 48 |
int assignPhysicsGroup(Physicsgroup_ClientAPIData& phgrpInfo) throw (const char*);
|
| 49 |
int createProcessedDataset(Processingpath_ClientAPIData& processingPathInfo) throw (const char*);
|
| 50 |
int createAnalysisDataset(Analysisdataset_ClientAPIData& analysisDatasetInfo) throw (const char*);
|
| 51 |
|
| 52 |
int createPrimaryDataset(Primarydataset_ClientAPIData& primaryDatasetInfo) throw (const char*);
|
| 53 |
int insertFileBlock(Blockview_ClientAPIData& blockInfo) throw (const char*);
|
| 54 |
|
| 55 |
int insertApps(Insertapps_ClientAPIData& appsInfo) throw (const char*);
|
| 56 |
int insertEventCollections(Evcollview_ClientAPIData& ecInfo) throw (const char*);
|
| 57 |
int insertFiles(std::vector<Fileview_ClientAPIData>& fileInfo) throw (const char*);
|
| 58 |
|
| 59 |
int readPrimaryDataset(Primarydataset_ClientAPIData, std::vector<Primarydataset_ClientAPIData>& primaryDatasetInfo) throw (const char*);
|
| 60 |
int readEvColls(Evcollview_ClientAPIData, std::vector<Evcollview_ClientAPIData>& evCollInfo) throw (const char*);
|
| 61 |
int readProcessingPath(Processingpath_ClientAPIData, vector<Processingpath_ClientAPIData>& procPathInfo) throw (const char*);
|
| 62 |
int readEvCollFiles(Fileview_ClientAPIData, vector<Fileview_ClientAPIData>& fileInfo) throw (const char*);
|
| 63 |
int getDatasetProvenenceParent(Datasetprovenenceevparent_ClientAPIData,
|
| 64 |
vector<Datasetprovenenceevparent_ClientAPIData>& dspInfo) throw (const char*);
|
| 65 |
int getDatasetProvenenceChild(Datasetprovenenceevchild_ClientAPIData,
|
| 66 |
vector<Datasetprovenenceevchild_ClientAPIData>& dspInfo) throw (const char*);
|
| 67 |
int readCRABEvColls(Crabevcollview_ClientAPIData apiDataToSend,
|
| 68 |
vector<Crabevcollview_ClientAPIData>& evCollInfo) throw (const char*);
|
| 69 |
|
| 70 |
//createProcessedDataset(/primary/DT/processedDatasetName, processedDatasetInfo);
|
| 71 |
//showDatasetInfo(outputSelector);
|
| 72 |
|
| 73 |
private:
|
| 74 |
int raiseServerException(void);
|
| 75 |
|
| 76 |
Message mSend;
|
| 77 |
Message mRecv;
|
| 78 |
int callServer(void);
|
| 79 |
bool localServer;
|
| 80 |
//GSS* gSecure;
|
| 81 |
Util util;
|
| 82 |
log4cxx::LoggerPtr logger;
|
| 83 |
};
|
| 84 |
|
| 85 |
#endif
|
