AppServer/include/DBSClient.hpp

#ifndef _DBSClient_hpp_
#define _DBSClient_hpp_

//#include "Socket.hpp"
//#include "GSS.hpp"
//#include "SocketException.hpp"
//#include "GSSException.hpp"
#include "Message.hpp"
//#include "Communicate.hpp"
#include "Configuration.hpp"
#include "DBSDispatcher.hpp"
#include "ClientAPIData.hpp"  
#include "Util.hpp"
#include "common.hpp"
#include <log4cxx/logger.h>
#include <iostream>
  
class DBSClient {

public:
        DBSClient();
        ~DBSClient();
  
        //std::string buildDataset(std::string basepathName, std::string analysisDataset);
  /*  
        int buildDataset(std::string basepathName, std::string analysisDataset);

        int addEventCollection(std::string basePathName, ECInfo);
        pathName buildDataset(std::string basepathName, AD, std::list<EventColllections>);
        pathName buildDataset(styring basepathName, AD, predicate);    
        pathName buildDataset(std::string basepathName, AD); 

        std::list<EventColllections> displayDatasetContents(std::string pathName); 
        std::list<EventColllections> displayDatasetContents(sttring initialPathName, std::string predicate); 
  
        closeDataset();
        deleteDataset(pathName, deepFlag);
  
        addToDataset(pathName, std::list<EventColllections>); 
  
        globalPathName = publishDataset(pathName);
  
        std::list<EventColllections>, foundLumi = partialDataset(pathName, lumiDesired); */

        int addPerson(Person_ClientAPIData& personInfo) throw (const char*);
        //int addRole(Role_ClientAPIData& roleInfo);
        //int assignRole(Administrative_ClientAPIData& adminInfo);
        int assignPhysicsGroup(Physicsgroup_ClientAPIData& phgrpInfo) throw (const char*);
        int createProcessedDataset(Processingpath_ClientAPIData& processingPathInfo) throw (const char*);
        int createAnalysisDataset(Analysisdataset_ClientAPIData& analysisDatasetInfo) throw (const char*);

        int createPrimaryDataset(Primarydataset_ClientAPIData& primaryDatasetInfo) throw (const char*);

        int insertApps(Insertapps_ClientAPIData& appsInfo) throw (const char*);
        int insertEventCollections(Evcollview_ClientAPIData& ecInfo) throw (const char*);
        int insertFiles(std::vector<Fileview_ClientAPIData*>& fileInfo) throw (const char*);

        int readPrimaryDataset(Primarydataset_ClientAPIData, std::vector<Primarydataset_ClientAPIData>& primaryDatasetInfo) throw (const char*);
        int readEvColls(Evcollview_ClientAPIData, std::vector<Evcollview_ClientAPIData>& evCollInfo) throw (const char*);
        int readProcessingPath(Processingpath_ClientAPIData, vector<Processingpath_ClientAPIData>& procPathInfo) throw (const char*);
        int readEvCollFiles(Fileview_ClientAPIData, vector<Fileview_ClientAPIData>& fileInfo) throw (const char*);
        int getDatasetProvenenceParent(Datasetprovenenceevparent_ClientAPIData, 
                                   vector<Datasetprovenenceevparent_ClientAPIData>& dspInfo) throw (const char*);
        int getDatasetProvenenceChild(Datasetprovenenceevchild_ClientAPIData, 
                                   vector<Datasetprovenenceevchild_ClientAPIData>& dspInfo) throw (const char*);
        int readCRABEvColls(Crabevcollview_ClientAPIData apiDataToSend,
                                              vector<Crabevcollview_ClientAPIData>& evCollInfo) throw (const char*);

        //createProcessedDataset(/primary/DT/processedDatasetName, processedDatasetInfo);
        //showDatasetInfo(outputSelector);

private:
        int raiseServerException(void);

        Message mSend;
        Message mRecv;
        int callServer(void);
        bool localServer;
        //GSS* gSecure;
        Util util;
        log4cxx::LoggerPtr logger;
};

#endif
Revision:	1.5
Committed:	Thu Dec 8 16:40:24 2005 UTC (19 years, 5 months ago) by sekhri
Branch:	MAIN
Changes since 1.4:	+18 -18 lines
Log Message:	Api call added for createPrimaryDataset. Added exception propogation from c++ implementation to python wrapper client.
#	User	Rev	Content
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	sekhri	1.5	int addPerson(Person_ClientAPIData& personInfo) throw (const char*);
46	afaq	1.1	//int addRole(Role_ClientAPIData& roleInfo);
47			//int assignRole(Administrative_ClientAPIData& adminInfo);
48	sekhri	1.5	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
54			int insertApps(Insertapps_ClientAPIData& appsInfo) throw (const char*);
55			int insertEventCollections(Evcollview_ClientAPIData& ecInfo) throw (const char*);
56			int insertFiles(std::vector<Fileview_ClientAPIData>& fileInfo) throw (const char);
57
58			int readPrimaryDataset(Primarydataset_ClientAPIData, std::vector<Primarydataset_ClientAPIData>& primaryDatasetInfo) throw (const char*);
59			int readEvColls(Evcollview_ClientAPIData, std::vector<Evcollview_ClientAPIData>& evCollInfo) throw (const char*);
60			int readProcessingPath(Processingpath_ClientAPIData, vector<Processingpath_ClientAPIData>& procPathInfo) throw (const char*);
61			int readEvCollFiles(Fileview_ClientAPIData, vector<Fileview_ClientAPIData>& fileInfo) throw (const char*);
62	afaq	1.1	int getDatasetProvenenceParent(Datasetprovenenceevparent_ClientAPIData,
63	sekhri	1.5	vector<Datasetprovenenceevparent_ClientAPIData>& dspInfo) throw (const char*);
64	afaq	1.1	int getDatasetProvenenceChild(Datasetprovenenceevchild_ClientAPIData,
65	sekhri	1.5	vector<Datasetprovenenceevchild_ClientAPIData>& dspInfo) throw (const char*);
66	sekhri	1.4	int readCRABEvColls(Crabevcollview_ClientAPIData apiDataToSend,
67	sekhri	1.5	vector<Crabevcollview_ClientAPIData>& evCollInfo) throw (const char*);
68	sekhri	1.4
69	afaq	1.1	//createProcessedDataset(/primary/DT/processedDatasetName, processedDatasetInfo);
70			//showDatasetInfo(outputSelector);
71
72			private:
73			int raiseServerException(void);
74
75			Message mSend;
76			Message mRecv;
77			int callServer(void);
78			bool localServer;
79			//GSS* gSecure;
80			Util util;
81	afaq	1.2	log4cxx::LoggerPtr logger;
82	afaq	1.1	};
83
84			#endif