--- ea/save_time.py 2012/08/30 12:48:07 9 +++ ea/save_time.py 2012/08/31 10:40:38 10 @@ -1,87 +1,87 @@ -# -# BonFIRE Virtual Clusters on Federated Clouds Demonstration Kit -# -# Copyright (c) Fundacion Centro Tecnologico de Supercomputacion de Galicia 2012 -# -# License GPL Version 3 -# -# The research leading to these results has received funding from -# the European Community's Seventh Frameqork Programme (FP7/2007-2013) -# under agreement number 257386 -# -# This software is provided with ABSOLUTELY NO WARRANTY -# -''' -Created on 06/02/2012 - -@author: R. Valin -''' -import os - -def s_time(time,level): - -# locations='fr-inria' -# storage='@BonFIRE Debian Squeeze 2G v3' -# instance='lite' -# time=dict() -# time['broker']=1 - dire = os.getcwd() - d = os.path.dirname(dire+'/output/') - #print 'instance', instance - print dire+'/output/' - if not os.path.exists(d): - os.makedirs(d) - - file1 = open(d +'/time_cluster'+str(os.getpid())+'.csv', 'a') - file1.write(level+','+str(time)+'\n') - file1.close() - - -def st_cluster(sub_time,stats,iter,location,uris): - - #stats - dire = os.getcwd() - d = os.path.dirname(dire+'/output/'+location+'/') - print dire+'/output/'+location+'/' - if not os.path.exists(d): - os.makedirs(d) - - file1 = open(d + '/time_cluster'+str(os.getpid())+'.csv', 'a') - #Here we print the head of the file of the first experiment - if iter is 0: - for i in stats: - print i+'\t'+str(stats[str(i)]) - file1.write(i+'\t') - file1.write(i+'\n') - - #Here we print stats - file1.write(str(sub_time)+'\t') - for j in stats: - file1.write(str(stats[str(j)])+'\t') - for m in uris: - print m - file1.write(m+'\t') - file1.write('\n') - file1.close() - - - - - - - - - #mm=simplejson.dumps(jdata.decode(kk)['resources']) - #jdata= json.JSONDecoder() - #for i in jdata.decode(mm): - - - - #kk=(mm) - #for j in mm: - # print j. - - - - # for j in [i['resources']]: - # print j.split(',') +# +# BonFIRE Virtual Clusters on Federated Clouds Demonstration Kit +# +# Copyright (c) Fundacion Centro Tecnologico de Supercomputacion de Galicia 2012 +# +# License GPL Version 3 +# +# The research leading to these results has received funding from +# the European Community's Seventh Framework Programme (FP7/2007-2013) +# under agreement number 257386 +# +# This software is provided with ABSOLUTELY NO WARRANTY +# +''' +Created on 06/02/2012 + +@author: R. Valin +''' +import os + +def s_time(time,level): + +# locations='fr-inria' +# storage='@BonFIRE Debian Squeeze 2G v3' +# instance='lite' +# time=dict() +# time['broker']=1 + dire = os.getcwd() + d = os.path.dirname(dire+'/output/') + #print 'instance', instance + print dire+'/output/' + if not os.path.exists(d): + os.makedirs(d) + + file1 = open(d +'/time_cluster'+str(os.getpid())+'.csv', 'a') + file1.write(level+','+str(time)+'\n') + file1.close() + + +def st_cluster(sub_time,stats,iter,location,uris): + + #stats + dire = os.getcwd() + d = os.path.dirname(dire+'/output/'+location+'/') + print dire+'/output/'+location+'/' + if not os.path.exists(d): + os.makedirs(d) + + file1 = open(d + '/time_cluster'+str(os.getpid())+'.csv', 'a') + #Here we print the head of the file of the first experiment + if iter is 0: + for i in stats: + print i+'\t'+str(stats[str(i)]) + file1.write(i+'\t') + file1.write(i+'\n') + + #Here we print stats + file1.write(str(sub_time)+'\t') + for j in stats: + file1.write(str(stats[str(j)])+'\t') + for m in uris: + print m + file1.write(m+'\t') + file1.write('\n') + file1.close() + + + + + + + + + #mm=simplejson.dumps(jdata.decode(kk)['resources']) + #jdata= json.JSONDecoder() + #for i in jdata.decode(mm): + + + + #kk=(mm) + #for j in mm: + # print j. + + + + # for j in [i['resources']]: + # print j.split(',')