ViewVC Help
View File | Revision Log | Show Annotations | Root Listing
root/cvsroot/COMP/DBS/Servers/AppServer/test/swigTestReadEC.py
Revision: 1.1.1.1 (vendor branch)
Committed: Mon Oct 31 22:10:36 2005 UTC (19 years, 6 months ago) by afaq
Content type: text/x-python
Branch: v00, MAIN
CVS Tags: DBS_0_0_3a, DBS_0_0_3, DBS_0_0_2, DBS_0_0_1, pre_DBS_0_0_1, post_dict_type_checking_merge, post_MiniPythonAPI_merged_to_trunk, pre_MiniPythonAPI_merge_to_trunk, DBS_0_0_0, vs20060320, AfterJan2006SchemaChanges_v01_00_01, AfterJan2006SchemaChanges_v01_00_00, AfterJan2006SchemaChanges, BeforeJan2006SchemaChanges, before_message_removal, preXOverChanges, start, HEAD
Branch point for: BranchForCPPWebServiceTesting
Changes since 1.1: +0 -0 lines
Log Message: 
Adding Server code to the repository

File Contents

# User Rev Content
1 afaq 1.1
2     import dbsclient
3    
4    
5    
6     def readPrimaryDataset(prdsName):
7     priDSVector = dbsclient.PriDSVector()
8     client.readPrimaryDataset(prdsName, priDSVector)
9     print "no of Primary Datasets ",priDSVector.size()
10     for i in range( priDSVector.size() ):
11     print "************************************************************************************************"
12     primaryDsId = dbsclient.intp_value(priDSVector[i].t_primary_dataset_id.getValue())
13     print "primary_dataset_id = ",primaryDsId
14     print "primary_dataset_name = ",dbsclient.stringp_value(priDSVector[i].t_primary_dataset_name.getValue())
15     print "primary_dataset_description = ",dbsclient.intp_value(priDSVector[i].t_primary_dataset_description.getValue())
16     readProcessingPath(primaryDsId)
17    
18    
19    
20     def readProcessingPath(primaryDsId):
21     proPathVector = dbsclient.ProPathVector()
22     client.readProcessingPath(primaryDsId, proPathVector)
23     print "no of Processing Path ",proPathVector.size()
24     for i in range( proPathVector.size() ):
25     print "************************************************************************************************"
26     proDsId = dbsclient.intp_value(proPathVector[i].t_processed_dataset_id.getValue())
27     print "processed_dataset_id = ",proDsId
28     print "data tiername = ",dbsclient.stringp_value(proPathVector[i].t_data_tier_name.getValue())
29     readEvColls(proDsId)
30    
31    
32     def readEvColls(proDsId):
33     evCollVector = dbsclient.EVCollVector()
34     client.readEvColls(proDsId, evCollVector)
35     print "no of Event Collections ",evCollVector.size()
36     for i in range( evCollVector.size() ):
37     evCollId = dbsclient.intp_value(evCollVector[i].t_event_collection_id.getValue())
38     print "************************************************************************************************"
39     print "status = ",dbsclient.intp_value(evCollVector[i].t_info_evcoll_status.getValue())
40     print "validation_status = ",dbsclient.intp_value(evCollVector[i].t_info_evcoll_validation_status.getValue())
41     print "processed_dataset = ",dbsclient.intp_value(evCollVector[i].t_event_collection_processed_dataset.getValue())
42     print "events = ",dbsclient.intp_value(evCollVector[i].t_info_evcoll_events.getValue())
43     print "collection_index = ",dbsclient.intp_value(evCollVector[i].t_event_collection_collection_index.getValue())
44     print "id = ",evCollId
45     print "name = ",dbsclient.stringp_value(evCollVector[i].t_info_evcoll_name.getValue())
46     readEvCollFiles(evCollId)
47    
48     def readEvCollFiles(evCollId):
49     evCollFileVector = dbsclient.EVCollFileVector()
50     client.readEvCollFiles(evCollId, evCollFileVector)
51     print "no of Files in Event Collection",evCollFileVector.size()
52     for i in range( evCollFileVector.size() ):
53     print "************************************************************************************************"
54     print "file_logical_name = ",dbsclient.stringp_value(evCollFileVector[i].t_file_logical_name.getValue())
55     print "file_guid = ",dbsclient.stringp_value(evCollFileVector[i].t_file_guid.getValue())
56     print "file_inblock = ",dbsclient.intp_value(evCollFileVector[i].t_file_inblock.getValue())
57    
58    
59    
60    
61     client = dbsclient.DBSClient()
62     prdsName = dbsclient.DBSClient.str("mu03b_MBforPU")
63     readPrimaryDataset(prdsName)
64