Context Navigation

Changeset 531 for DCWoRMS/trunk/src

Timestamp:

10/30/12 11:11:14 (12 years ago)

Author:

wojtekp

Message:

Location:

DCWoRMS/trunk/src/example/localplugin

Files:

r525	r531
43	43	case TASK_FINISHED:
44	44	//case TIMER:
45		// our tasks are placed only in first queue (see BaseLocalPlugin.placeJobsInQueues() method)
	45	// our tasks are placed only in first queue (see BaseLocalSchedulingPlugin.placeJobsInQueues() method)
46	46	TaskQueue q = queues.get(0);
47	47	// check all tasks in queue
…	…
87	87	cpuRequest = Double.valueOf(task.getCpuCntRequest()).intValue();
88	88	} catch (NoSuchFieldException e) {
89		cpuRequest = 1;
	89	cpuRequest = 0;
90	90	}
91	91

r525	r531
45	45	case TASK_FINISHED:
46	46	// our tasks are placed only in first queue (see
47		// BaseLocalPlugin.placeJobsInQueues() method)
	47	// BaseLocalSchedulingPlugin.placeJobsInQueues() method)
48	48	TaskQueue q = queues.get(0);
49	49	// check all tasks in queue
…	…
90	90	cpuRequest = Double.valueOf(task.getCpuCntRequest()).intValue();
91	91	} catch (NoSuchFieldException e) {
92		cpuRequest = 1;
	92	cpuRequest = 0;
93	93	}
94	94	for (int i = 0; i < node.getProcessors().size() && cpuRequest > 0; i++) {

r525	r531
28	28	public class FCFSBF_DFSClusterPlugin extends BaseLocalSchedulingPlugin {
29	29
30		~~List<Processor> allocatedCPUs;~~
31		~~public FCFSBF_DFSClusterPlugin () {~~
32		~~allocatedCPUs = new ArrayList<Processor>();~~
33		}
34
35	30	public SchedulingPlanInterface<?> schedule(SchedulingEvent event, TaskQueueList queues, JobRegistry jobRegistry,
36	31	ResourceManager resManager, ModuleList modules) {
…	…
39	34	SchedulingPlan plan = new SchedulingPlan();
40	35	// our tasks are placed only in first queue (see
41		// BaseLocalPlugin.placeJobsInQueues() method)
	36	// BaseLocalSchedulingPlugin.placeJobsInQueues() method)
42	37	TaskQueue q = queues.get(0);
43	38	// chose the events types to serve.
…	…
73	68	cpuRequest = Double.valueOf(task.getCpuCntRequest()).intValue();
74	69	} catch (NoSuchFieldException e) {
75		cpuRequest = 1;
	70	cpuRequest = 0;
76	71	}
77	72
…	…
79	74	List<ComputingResource> choosenResources = null;
80	75	List<Processor> processors = resourceManager.getProcessors();
81		~~processors.removeAll(allocatedCPUs);~~
82	76	if (processors.size() < cpuRequest) {
83	77	// log.warn("Task requires more cpus than is availiable in this resource.");
…	…
117	111	cpu.getPowerInterface().setPState("P0");
118	112	}
119
120	113	}
121
122	114	}
123	115
124
125	116	}

r525	r531
22	22	case TASK_FINISHED:
23	23
24		// our tasks are placed only in first queue (see BaseLocalPlugin.placeJobsInQueues() method)
	24	// our tasks are placed only in first queue (see BaseLocalSchedulingPlugin.placeJobsInQueues() method)
25	25	TaskQueue q = queues.get(0);
26	26

r525	r531
82	82	cpuRequest = Double.valueOf(task.getCpuCntRequest()).intValue();
83	83	} catch (NoSuchFieldException e) {
84		cpuRequest = 1;
	84	cpuRequest = 0;
85	85	}
86	86	for (int i = 0; i < nodes.get(0).getProcessors().size() && cpuRequest > 0; i++) {

r525	r531
30	30	//case TIMER:
31	31	// our tasks are placed only in first queue (see
32		// BaseLocalPlugin.placeJobsInQueues() method)
	32	// BaseLocalSchedulingPlugin.placeJobsInQueues() method)
33	33	TaskQueue q = queues.get(0);
34	34	// check all tasks in queue

r525	r531
38	38	//case TIMER:
39	39	// our tasks are placed only in first queue (see
40		// BaseLocalPlugin.placeJobsInQueues() method)
	40	// BaseLocalSchedulingPlugin.placeJobsInQueues() method)
41	41	TaskQueue q = queues.get(0);
42	42

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