String message = "Got eviction notice but anti-caching is not enabled";
LOG.warn(message);
throw new ServerFaultException(message, orig_error, orig_ts.getTransactionId());
}
EvictedTupleAccessException error = (EvictedTupleAccessException)orig_error;
short block_ids[] = error.getBlockIds();
int tuple_offsets[] = error.getTupleOffsets();
Table evicted_table = error.getTable(this.catalogContext.database);
new_ts.setPendingError(error, false);
if (debug.val)
LOG.debug(String.format("Added aborted txn to %s queue. Unevicting %d blocks from %s (%d).",
AntiCacheManager.class.getSimpleName(), block_ids.length, evicted_table.getName(), evicted_table.getRelativeIndex()));
if (orig_ts.getBasePartition() != error.getPartitionId() && !this.isLocalPartition(error.getPartitionId())) {
new_ts.setOldTransactionId(orig_ts.getTransactionId());
}
this.anticacheManager.queue(new_ts, error.getPartitionId(), evicted_table, block_ids, tuple_offsets);
}
// -------------------------------