X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=sfa%2Fsenslab%2FOARrestapi.py;h=79ec34357f2f19409a0644f311d145fb843e3abf;hb=43a30d5e8fe5e5a0b9c70b2ec5232d853355e165;hp=942f2bf6df17108880c14d712c8c7f123e96d33b;hpb=36135942ed4dd09cbae187005eb94d70c60f3164;p=sfa.git diff --git a/sfa/senslab/OARrestapi.py b/sfa/senslab/OARrestapi.py index 942f2bf6..79ec3435 100644 --- a/sfa/senslab/OARrestapi.py +++ b/sfa/senslab/OARrestapi.py @@ -92,9 +92,8 @@ class OARGETParser: return node_id def AddNodeNetworkAddr(self,tuplelist,value): - #tuplelist.append(('hostname',str(value))) - tuplelist.append(('hostname',str(value)+'.demolab.fr')) - tuplelist.append(('site_id',3)) + tuplelist.append(('hostname',str(value))) + def AddNodeSite(self,tuplelist,value): tuplelist.append(('site_login_base',str(value))) @@ -116,7 +115,8 @@ class OARGETParser: def AddPosY(self,tuplelist,value): tuplelist.append(('posy',value)) - + def AddBootState(self,tuplelist,value): + tuplelist.append(('boot_state',str(value))) def ParseVersion(self) : print self.raw_json @@ -154,7 +154,7 @@ class OARGETParser: #resources are listed inside the 'items' list from the json self.raw_json = self.raw_json['items'] self.ParseNodes() - self.ParseSites() + #self.ParseSites() @@ -165,7 +165,7 @@ class OARGETParser: if self.version_json_dict['apilib_version'] != "0.2.10" : self.raw_json = self.raw_json['items'] self.ParseNodes() - self.ParseSites() + #Parse nodes properties from OAR @@ -250,6 +250,7 @@ class OARGETParser: 'mobile': AddMobility, 'posx': AddPosX, 'posy': AddPosY, + 'state':AddBootState, } @@ -277,19 +278,7 @@ class OARapi: self.server = OARrestapi() self.parser = OARGETParser(self.server) - def GetNodes(self,node_filter= None, return_fields=None): - #print>>sys.stderr, " \r\n GetNodes node_filter %s return_fields %s" %(node_filter,return_fields) - self.parser.SendRequest("GET_resources_full") - node_dict = self.parser.GetNodesFromOARParse() - return_node_list = [] - #print>>sys.stderr, " \r\n GetNodes node_dict %s" %(node_dict) - if not (node_filter or return_fields): - return_node_list = node_dict.values() - return return_node_list - - return_node_list= parse_filter(node_dict.values(),node_filter ,'node', return_fields) - return return_node_list - + #GetNodes moved to slabdriver.py def GetSites(self, site_filter= None, return_fields=None): print>>sys.stderr, " \r\n GetSites+++++++++++++++++" @@ -308,10 +297,7 @@ class OARapi: #print>>sys.stderr, " \r\n GetSites sl %s" %(sl) if sl['site_id'] == site['site_id']: site['slice_ids'].append(sl['slice_id']) - #print>>sys.stderr, " \r\n GetSites -site['site_id'] %s --slice_list %s" %(site['site_id'],slice_list ) - - #print>>sys.stderr, " \r\n GetSites -site['site_id'] %s --admins_dict %s---site %s" %(site['site_id'],admins_dict,site ) if not (site_filter or return_fields): return_site_list = site_dict.values() return return_site_list