Revision 59425
Added by Claudio Atzori over 3 years ago
modules/cnr-modular-mdstore-service/trunk/src/main/java/eu/dnetlib/data/mdstore/modular/MDStoreFeeder.java | ||
---|---|---|
66 | 66 |
//means the process was cancelled, so we must not commit |
67 | 67 |
log.warn(String.format("The feeding process on mdstore %s has been cancelled. Records will not be committed. Transaction %s set as invalid.", mdId, transactionId)); |
68 | 68 |
dao.invalidTransaction(transactionId, mdId); |
69 |
failCallback.call(new MDStoreServiceException(String.format("Feeding cancelled for mdstore %s on transaction %s", mdId, transactionId)), buildParams(mdstore.getSize(), writeOps)); |
|
69 |
final Map<String, String> params = buildParams(dao.getMDStore(mdId).getSize(), writeOps); |
|
70 |
failCallback.call(new MDStoreServiceException(String.format("Feeding cancelled for mdstore %s on transaction %s", mdId, transactionId)), params); |
|
70 | 71 |
} else { |
71 | 72 |
dao.commit(mdstore.getId(), mdId); |
72 | 73 |
int size = dao.refreshSize(mdId); |
Also available in: Unified diff
in case of feeding canceled report the effective mdstore size rather than the size of the transaction