Context Navigation

Changeset 734 for DCWoRMS/trunk

Timestamp:

01/02/13 08:12:13 (12 years ago)

Author:

wojtekp

Message:

Location:

DCWoRMS/trunk/src/test/article/recs/plugins

Files:

r662	r734
8	8	import java.util.ResourceBundle;
9	9
	10	import schedframe.resources.computing.ComputingNode;
10	11	import schedframe.resources.computing.Core;
11	12	import schedframe.resources.computing.Processor;
…	…
46	47
47	48	ProcessingElements pe = (ProcessingElements) peUnit;
	49	if(pe.get(0) instanceof ComputingNode)
	50	return ((ComputingNode)pe.get(0)).getCategory();
48	51	Core core = (Core)pe.get(0);
49	52	return core.getParent().getParent().getCategory();
…	…
52	55	private int getFrequency(PEUnit peUnit){
53	56	ProcessingElements pe = (ProcessingElements) peUnit;
	57	if(pe.get(0) instanceof ComputingNode)
	58	return Double.valueOf(((ComputingNode)pe.get(0)).getProcessors().get(0).getPowerInterface().getFrequency()).intValue();
54	59	Core core = (Core)pe.get(0);
55	60	Processor proc = (Processor) core.getParent();

r708	r734
93	93
94	94	List<ComputingResource> choosenResources = new ArrayList<ComputingResource>();
95		for (int i = 0; i < cores.size() ~~&& cpuRequest > 0~~; i++) {
	95	for (int i = 0; i < cores.size(); i++) {
96	96	if (cores.get(i).getStatus() == ResourceStatus.FREE) {
97		choosenResources.add(cores.get(i));
	97	//choosenResources.add(cores.get(i));
98	98	cpuRequest--;
99	99	}
100	100	}
	101	choosenResources.add(node);
101	102	if (cpuRequest > 0) {
102		return null;
	103	//return null;
103	104	}
104	105	ProcessingElements pe = new ProcessingElements();

r711	r734
132	132
133	133	List<ComputingResource> choosenResources = new ArrayList<ComputingResource>();
134		for (int i = 0; i < cores.size() ~~&& cpuRequest > 0~~; i++) {
	134	for (int i = 0; i < cores.size(); i++) {
135	135	if (cores.get(i).getStatus() == ResourceStatus.FREE) {
136		choosenResources.add(cores.get(i));
	136	//choosenResources.add(cores.get(i));
137	137	cpuRequest--;
138	138	}
139	139	}
	140	choosenResources.add(node);
140	141	if (cpuRequest > 0) {
141		continue;
	142	//continue;
142	143	}
143	144	map = new HashMap<ResourceUnitName, ResourceUnit>();

r711	r734
127	127
128	128	List<ComputingResource> choosenResources = new ArrayList<ComputingResource>();
129		for (int i = 0; i < cores.size() ~~&& cpuRequest > 0~~; i++) {
	129	for (int i = 0; i < cores.size(); i++) {
130	130	if (cores.get(i).getStatus() == ResourceStatus.FREE) {
131		choosenResources.add(cores.get(i));
	131	//choosenResources.add(cores.get(i));
132	132	cpuRequest--;
133	133	}
134	134	}
	135	choosenResources.add(node);
135	136	if (cpuRequest > 0) {
136		continue;
	137	//continue;
137	138	}
138	139	map = new HashMap<ResourceUnitName, ResourceUnit>();

r708	r734
95	95
96	96	List<ComputingResource> choosenResources = new ArrayList<ComputingResource>();
97		for (int i = 0; i < cores.size() ~~&& cpuRequest > 0~~; i++) {
	97	for (int i = 0; i < cores.size(); i++) {
98	98	if (cores.get(i).getStatus() == ResourceStatus.FREE) {
99		choosenResources.add(cores.get(i));
	99	//choosenResources.add(cores.get(i));
100	100	cpuRequest--;
101	101	}
102	102	}
	103	choosenResources.add(node);
103	104	if (cpuRequest > 0) {
104		return null;
	105	//return null;
105	106	}
106	107	ProcessingElements pe = new ProcessingElements();

r708	r734
91	91
92	92	List<ComputingResource> choosenResources = new ArrayList<ComputingResource>();
93		for (int i = 0; i < cores.size() ~~&& cpuRequest > 0~~; i++) {
	93	for (int i = 0; i < cores.size(); i++) {
94	94	if (cores.get(i).getStatus() == ResourceStatus.FREE) {
95		choosenResources.add(cores.get(i));
	95	//choosenResources.add(cores.get(i));
96	96	cpuRequest--;
97	97	}
98	98	}
99	99	if (cpuRequest > 0) {
100		return null;
	100	//return null;
101	101	}
	102	choosenResources.add(node);
102	103	ProcessingElements pe = new ProcessingElements();
103	104	pe.addAll(choosenResources);

r664	r734
10	10
11	11	import schedframe.events.scheduling.SchedulingEvent;
	12	import schedframe.resources.computing.ComputingNode;
12	13	import schedframe.resources.computing.Core;
13	14	import schedframe.resources.computing.Processor;
…	…
42	43	try {
43	44	execTime = TIME_FACTOR * (1 - completionPercentage/100) * getMeasuredTime(query);
	45	//System.out.println(task.getJobId()+": "+ execTime + "; "+ completionPercentage);
44	46	if (Double.compare(execTime, 0.001) < 0) {
45	47	execTime = 0.001;
46	48	}
47	49	execTime = Math.round(execTime);
	50	//System.out.println(task.getJobId()+": "+ execTime);
48	51	} catch (FileNotFoundException e) {
49	52	execTime = defaultEstimation(task, peUnit, completionPercentage);
…	…
71	74
72	75	ProcessingElements pe = (ProcessingElements) peUnit;
	76	if(pe.get(0) instanceof ComputingNode)
	77	return ((ComputingNode)pe.get(0)).getCategory();
73	78	Core core = (Core)pe.get(0);
74	79	return core.getParent().getParent().getCategory();
…	…
77	82	private int getFrequency(PEUnit peUnit){
78	83	ProcessingElements pe = (ProcessingElements) peUnit;
	84	if(pe.get(0) instanceof ComputingNode)
	85	return Double.valueOf(((ComputingNode)pe.get(0)).getProcessors().get(0).getPowerInterface().getFrequency()).intValue();
79	86	Core core = (Core)pe.get(0);
80	87	Processor proc = (Processor) core.getParent();

Note: See TracChangeset for help on using the changeset viewer.