in src/org/apache/kandula/coordinator/at/ATCoordinator.java [447:469]
public void timeout(AbstractContext context){
ATActivityContext atContext = (ATActivityContext) context;
atContext.lock();
switch (atContext.getStatus()) {
case CoordinatorStatus.STATUS_ABORTING:
case CoordinatorStatus.STATUS_COMMITTING:
case CoordinatorStatus.STATUS_PREPARED_SUCCESS:
atContext.unlock();
break;
case CoordinatorStatus.STATUS_ACTIVE:
case CoordinatorStatus.STATUS_PREPARING_VOLATILE:
case CoordinatorStatus.STATUS_PREPARING_DURABLE:
try {
abortActivity(context);
} catch (AbstractKandulaException e) {
e.printStackTrace();
}
break;
default:
atContext.unlock();
}
}