Skip to content

Commit

Permalink
Update job in list by index
Browse files Browse the repository at this point in the history
  • Loading branch information
Willem Elbers committed Mar 29, 2022
1 parent 6bba21c commit a887a42
Showing 1 changed file with 16 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -336,6 +336,9 @@ public CustomDataUpdateEvent(AjaxRequestTarget target) {
public void onBeforeRender() {
super.onBeforeRender();
listview.setModelObject(references);
for(ReferenceJob job : references) {
logger.info("onBeforeRender job ref={}, state={}", job.getReference().getRef(), job.state);
}
}

@Override
Expand Down Expand Up @@ -515,19 +518,26 @@ public void run() {

synchronized(this) {
for(int i = 0; i < references.size(); i++) {
ReferenceJob job = references.get(i);
//for(ReferenceJob job : references) {
//references.get(i)
if(references.get(i).getState() == State.INITIALIZED) {
references.get(i).setState(State.ANALYZING);
if(job.getState() == State.INITIALIZED) {
job.setState(State.ANALYZING);
references.set(i, job);

logger.debug("Starting. Job ref={}, state = {}",references.get(i).getReference().getRef(), references.get(i).getState());
//fireEvent(new DataUpdatedEvent(null));
try {
analyze(references.get(i));
references.get(i).setState(State.DONE);
analyze(job);

job.setState(State.DONE);
references.set(i, job);

//fireEvent(new DataUpdatedEvent(null));
} catch(Exception ex) {
references.get(i).setState(State.FAILED);

job.setState(State.FAILED);
references.set(i, job);

//fireEvent(new DataUpdatedEvent(null));
}
logger.debug("Finished. Job ref={}, state = {}",references.get(i).getReference().getRef(), references.get(i).getState());
Expand Down

0 comments on commit a887a42

Please sign in to comment.