mirror of
https://github.com/Alfresco/alfresco-community-repo.git
synced 2025-08-07 17:49:17 +00:00
Bug fix for case where commit failed.
git-svn-id: https://svn.alfresco.com/repos/alfresco-enterprise/alfresco/HEAD/root@23127 c4b6b30b-aa2e-2d43-bbcb-ca4b014f7261
This commit is contained in:
@@ -631,8 +631,10 @@ public class TransferServiceImpl2 implements TransferService2
|
||||
|
||||
case Commit:
|
||||
{
|
||||
logger.debug("about to start committing transferId:" + transfer.getTransferId());
|
||||
eventProcessor.commit();
|
||||
transmitter.commit(transfer);
|
||||
|
||||
logger.debug("committing transferId:" + transfer.getTransferId());
|
||||
checkCancel(transfer.getTransferId());
|
||||
|
||||
@@ -828,9 +830,17 @@ public class TransferServiceImpl2 implements TransferService2
|
||||
catch(Exception e)
|
||||
{
|
||||
logger.debug("Exception - unable to transfer", e);
|
||||
failureException = e;
|
||||
|
||||
if (transfer != null && (clientState == ClientTransferState.Begin || clientState == ClientTransferState.Prepare))
|
||||
/**
|
||||
* Save the first exception that we encounter.
|
||||
*/
|
||||
if(failureException == null)
|
||||
{
|
||||
failureException = e;
|
||||
}
|
||||
if (transfer != null && (clientState == ClientTransferState.Begin ||
|
||||
clientState == ClientTransferState.Prepare ||
|
||||
clientState == ClientTransferState.Commit))
|
||||
{
|
||||
// we must first inform the target repository that a client failure has occurred to allow it to
|
||||
// clean up appropriately, too
|
||||
|
Reference in New Issue
Block a user