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 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.6
Committed:	Wed Dec 14 20:13:23 2005 UTC (19 years, 4 months ago) by sekhri
Branch:	MAIN
CVS Tags:	before_message_removal, preXOverChanges
Changes since 1.5:	+2 -1 lines
Log Message:	CreateBlock and getProcessedDataset api calls implemented and integrated with Top level API
#	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	sekhri	1.6	int insertFileBlock(Blockview_ClientAPIData& blockInfo) throw (const char*);
54	sekhri	1.5
55			int insertApps(Insertapps_ClientAPIData& appsInfo) throw (const char*);
56			int insertEventCollections(Evcollview_ClientAPIData& ecInfo) throw (const char*);
57	sekhri	1.6	int insertFiles(std::vector<Fileview_ClientAPIData>& fileInfo) throw (const char*);
58	sekhri	1.5
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	afaq	1.1	int getDatasetProvenenceParent(Datasetprovenenceevparent_ClientAPIData,
64	sekhri	1.5	vector<Datasetprovenenceevparent_ClientAPIData>& dspInfo) throw (const char*);
65	afaq	1.1	int getDatasetProvenenceChild(Datasetprovenenceevchild_ClientAPIData,
66	sekhri	1.5	vector<Datasetprovenenceevchild_ClientAPIData>& dspInfo) throw (const char*);
67	sekhri	1.4	int readCRABEvColls(Crabevcollview_ClientAPIData apiDataToSend,
68	sekhri	1.5	vector<Crabevcollview_ClientAPIData>& evCollInfo) throw (const char*);
69	sekhri	1.4
70	afaq	1.1	//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	afaq	1.2	log4cxx::LoggerPtr logger;
83	afaq	1.1	};
84
85			#endif