summary |
shortlog |
log |
commit | commitdiff |
review |
tree
raw |
patch |
inline | side by side (from parent 1:
bce8bc8)
Added thread interrupts
Change-Id: Ic5b7eef71354efd02736e88a1e6716aa84169898
Issue-ID: AAI-1367
Signed-off-by: Wiktor Garbarek <wiktor.garbarek@nokia.com>
try {
publisherPool.awaitTermination(1000, TimeUnit.MILLISECONDS);
try {
publisherPool.awaitTermination(1000, TimeUnit.MILLISECONDS);
- } catch (InterruptedException e) {}
+ } catch (InterruptedException e) {
+ logger.warn("Termination interrupted");
+ Thread.currentThread().interrupt();
+ }
} catch (InterruptedException ie) {
LOGGER.info("Interrupted while backing off on transaction commit");
} catch (InterruptedException ie) {
LOGGER.info("Interrupted while backing off on transaction commit");
+ Thread.currentThread().interrupt();
} catch (InterruptedException ie) {
LOGGER.info("Interrupted while backing off on transaction rollback");
} catch (InterruptedException ie) {
LOGGER.info("Interrupted while backing off on transaction rollback");
+ Thread.currentThread().interrupt();
}
} catch (InterruptedException e) {
LOGGER.warn("Interrupted while waiting for object index creation status");
}
} catch (InterruptedException e) {
LOGGER.warn("Interrupted while waiting for object index creation status");
+ Thread.currentThread().interrupt();
updateIndexMgmt.commit();
} catch (InterruptedException e) {
LOGGER.warn("Interrupted while reindexing for object index");
updateIndexMgmt.commit();
} catch (InterruptedException e) {
LOGGER.warn("Interrupted while reindexing for object index");
+ Thread.currentThread().interrupt();
return;
} catch (ExecutionException e) {
LOGGER.warn("Exception occurred during reindexing procedure for creating object index " + indexName, e);
return;
} catch (ExecutionException e) {
LOGGER.warn("Exception occurred during reindexing procedure for creating object index " + indexName, e);
.call();
} catch (InterruptedException e) {
LOGGER.warn("Interrupted while waiting for index to transition to ENABLED state");
.call();
} catch (InterruptedException e) {
LOGGER.warn("Interrupted while waiting for index to transition to ENABLED state");
+ Thread.currentThread().interrupt();
}
} catch (InterruptedException e) {
LOGGER.warn("Interrupted while waiting for object index creation status");
}
} catch (InterruptedException e) {
LOGGER.warn("Interrupted while waiting for object index creation status");
+ Thread.currentThread().interrupt();
updateIndexMgmt.commit();
} catch (InterruptedException e) {
LOGGER.warn("Interrupted while reindexing for object index");
updateIndexMgmt.commit();
} catch (InterruptedException e) {
LOGGER.warn("Interrupted while reindexing for object index");
+ Thread.currentThread().interrupt();
return;
} catch (ExecutionException e) {
LOGGER.warn("Exception occurred during reindexing procedure for creating object index " + indexName, e);
return;
} catch (ExecutionException e) {
LOGGER.warn("Exception occurred during reindexing procedure for creating object index " + indexName, e);
.call();
} catch (InterruptedException e) {
LOGGER.warn("Interrupted while waiting for index to transition to ENABLED state");
.call();
} catch (InterruptedException e) {
LOGGER.warn("Interrupted while waiting for index to transition to ENABLED state");
+ Thread.currentThread().interrupt();