[679] | 1 | package test.article.recs.plugins.scheduling; |
---|
| 2 | |
---|
[705] | 3 | import java.io.FileInputStream; |
---|
| 4 | import java.io.FileNotFoundException; |
---|
| 5 | import java.io.IOException; |
---|
| 6 | import java.util.PropertyResourceBundle; |
---|
| 7 | import java.util.ResourceBundle; |
---|
| 8 | |
---|
| 9 | import schedframe.resources.computing.ComputingNode; |
---|
[679] | 10 | import schedframe.scheduling.tasks.TaskInterface; |
---|
[705] | 11 | import test.article.recs.utils.AppType; |
---|
[679] | 12 | import test.article.recs.utils.TaskToApp; |
---|
[705] | 13 | import dcworms.schedframe.scheduling.ExecTask; |
---|
| 14 | import dcworms.schedframe.scheduling.Executable; |
---|
[679] | 15 | import example.localplugin.BaseLocalSchedulingPlugin; |
---|
| 16 | |
---|
| 17 | public abstract class RecsSP extends BaseLocalSchedulingPlugin { |
---|
| 18 | |
---|
[705] | 19 | private static String EXEC_DATA_FILE_NAME = "src/test/article/recs/data/executiveness_data.properties"; |
---|
| 20 | |
---|
| 21 | private ResourceBundle execBundle; |
---|
| 22 | |
---|
[680] | 23 | protected TaskToApp taskToApp = new TaskToApp(); |
---|
[679] | 24 | |
---|
| 25 | protected void initApplicationType(TaskInterface<?> task){ |
---|
| 26 | taskToApp.getAppType(task); |
---|
| 27 | } |
---|
[705] | 28 | |
---|
[708] | 29 | protected String createExecutivenessQuery(TaskInterface<?> task, ComputingNode node) { |
---|
[705] | 30 | Executable exec = (Executable)task; |
---|
| 31 | String query = getApplicationType(exec) + "." + getNodeCategory(node); |
---|
| 32 | return query; |
---|
| 33 | } |
---|
| 34 | |
---|
| 35 | private String getApplicationType(ExecTask task){ |
---|
| 36 | AppType appType = taskToApp.getAppType(task); |
---|
| 37 | return appType.toString(); |
---|
| 38 | } |
---|
| 39 | |
---|
| 40 | private String getNodeCategory(ComputingNode node){ |
---|
| 41 | return node.getCategory(); |
---|
| 42 | } |
---|
| 43 | |
---|
| 44 | protected boolean getExecutiveness(String query) throws FileNotFoundException, IOException{ |
---|
| 45 | ResourceBundle execBundle = getExecBundle(); |
---|
| 46 | return Boolean.valueOf(execBundle.getString(query)).booleanValue(); |
---|
| 47 | } |
---|
| 48 | |
---|
| 49 | private ResourceBundle getExecBundle() throws FileNotFoundException, IOException{ |
---|
| 50 | if(execBundle == null){ |
---|
| 51 | execBundle = new PropertyResourceBundle(new FileInputStream(EXEC_DATA_FILE_NAME)); |
---|
| 52 | } |
---|
| 53 | return execBundle; |
---|
| 54 | } |
---|
[679] | 55 | } |
---|