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 createProcessedDataset(Processingpath_ClientAPIData& processingPathInfo, int & processedDatasetId, int & processingPathId ) throw (const char*);
        int createAnalysisDataset(Analysisdataset_ClientAPIData& analysisDatasetInfo) throw (const char*);

        int createPrimaryDataset(Primarydataset_ClientAPIData& primaryDatasetInfo) throw (const char*);
        int insertFileBlock(Blockview_ClientAPIData& blockInfo) 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.7
Committed:	Tue Jan 10 20:55:16 2006 UTC (19 years, 3 months ago) by sekhri
Branch:	MAIN
Changes since 1.6:	+2 -1 lines
Log Message:	Code changes accomodating RefDBXOver Dataset insertion
#	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	sekhri	1.7	//int createProcessedDataset(Processingpath_ClientAPIData& processingPathInfo) throw (const char*);
50			int createProcessedDataset(Processingpath_ClientAPIData& processingPathInfo, int & processedDatasetId, int & processingPathId ) throw (const char*);
51	sekhri	1.5	int createAnalysisDataset(Analysisdataset_ClientAPIData& analysisDatasetInfo) throw (const char*);
52
53			int createPrimaryDataset(Primarydataset_ClientAPIData& primaryDatasetInfo) throw (const char*);
54	sekhri	1.6	int insertFileBlock(Blockview_ClientAPIData& blockInfo) throw (const char*);
55	sekhri	1.5
56			int insertApps(Insertapps_ClientAPIData& appsInfo) throw (const char*);
57			int insertEventCollections(Evcollview_ClientAPIData& ecInfo) throw (const char*);
58	sekhri	1.6	int insertFiles(std::vector<Fileview_ClientAPIData>& fileInfo) throw (const char*);
59	sekhri	1.5
60			int readPrimaryDataset(Primarydataset_ClientAPIData, std::vector<Primarydataset_ClientAPIData>& primaryDatasetInfo) throw (const char*);
61			int readEvColls(Evcollview_ClientAPIData, std::vector<Evcollview_ClientAPIData>& evCollInfo) throw (const char*);
62			int readProcessingPath(Processingpath_ClientAPIData, vector<Processingpath_ClientAPIData>& procPathInfo) throw (const char*);
63			int readEvCollFiles(Fileview_ClientAPIData, vector<Fileview_ClientAPIData>& fileInfo) throw (const char*);
64	afaq	1.1	int getDatasetProvenenceParent(Datasetprovenenceevparent_ClientAPIData,
65	sekhri	1.5	vector<Datasetprovenenceevparent_ClientAPIData>& dspInfo) throw (const char*);
66	afaq	1.1	int getDatasetProvenenceChild(Datasetprovenenceevchild_ClientAPIData,
67	sekhri	1.5	vector<Datasetprovenenceevchild_ClientAPIData>& dspInfo) throw (const char*);
68	sekhri	1.4	int readCRABEvColls(Crabevcollview_ClientAPIData apiDataToSend,
69	sekhri	1.5	vector<Crabevcollview_ClientAPIData>& evCollInfo) throw (const char*);
70	sekhri	1.4
71	afaq	1.1	//createProcessedDataset(/primary/DT/processedDatasetName, processedDatasetInfo);
72			//showDatasetInfo(outputSelector);
73
74			private:
75			int raiseServerException(void);
76
77			Message mSend;
78			Message mRecv;
79			int callServer(void);
80			bool localServer;
81			//GSS* gSecure;
82			Util util;
83	afaq	1.2	log4cxx::LoggerPtr logger;
84	afaq	1.1	};
85
86			#endif