Revision 46885
Added by Michele Artini almost 7 years ago
| ProcessRegistry.java | ||
|---|---|---|
| 17 | 17 |
import com.google.common.collect.BiMap; |
| 18 | 18 |
import com.google.common.collect.HashBiMap; |
| 19 | 19 |
|
| 20 |
import eu.dnetlib.WorkerProperties; |
|
| 20 | 21 |
import eu.dnetlib.miscutils.datetime.DateUtils; |
| 21 |
import eu.dnetlib.WorkerProperties; |
|
| 22 | 22 |
import eu.dnetlib.msro.exceptions.MSROException; |
| 23 | 23 |
import eu.dnetlib.msro.workflows.WorkflowsConstants; |
| 24 | 24 |
|
| ... | ... | |
| 71 | 71 |
} |
| 72 | 72 |
} |
| 73 | 73 |
|
| 74 |
public String registerProcess(final WorkflowProcess process) throws MSROException {
|
|
| 74 |
public void registerProcess(final WorkflowProcess process) throws MSROException {
|
|
| 75 | 75 |
if (procs.containsValue(process) || procs.containsKey(process.getId())) {
|
| 76 | 76 |
log.error("Already registerd process: " + process);
|
| 77 | 77 |
throw new MSROException("Already registerd process: " + process);
|
| ... | ... | |
| 99 | 99 |
|
| 100 | 100 |
log.info("WorkflowProcess [" + process + "] in queue, priority=" + process.getPriority());
|
| 101 | 101 |
} |
| 102 |
|
|
| 103 |
return process.getId(); |
|
| 104 | 102 |
} |
| 105 | 103 |
|
| 106 | 104 |
private void removeOldestProcess() {
|
Also available in: Unified diff
Partial response of async methods