lib/src/main/java/edu/utexas/tacc/tapis/files/lib/services/ChildTaskTransferService.java
private TransferTaskChild chevronThree(@NotNull TransferTaskChild taskChild) throws ServiceException {
        // If it cancelled/failed somehow, just push it through unchanged.
        log.info("DOING chevron3 {}", taskChild);
        if (taskChild.isTerminal()) return taskChild;
        try {
            TransferTaskChild updated = dao.getChildTaskByUUID(taskChild.getUuid());
            updated.setStatus(TransferTaskStatus.COMPLETED);
            updated.setEndTime(Instant.now());
            updated = dao.updateTransferTaskChild(updated);
            dao.updateTransferTaskParentBytesTransferred(updated.getParentTaskId(), updated.getBytesTransferred());
            TransferTaskParent parent = dao.getTransferTaskParentById(updated.getParentTaskId());
            return updated;
        } catch (DAOException ex) {
            throw new ServiceException(Utils.getMsg("FILES_TXFR_SVC_ERR1", taskChild.getTenantId(), taskChild.getUsername(),
                "chevronThree", taskChild.getId(), taskChild.getUuid(), ex.getMessage()), ex);
        }
    }
/**
     * Book keeping and cleanup. Mark the child as COMPLETE. Update the parent task with the bytes sent
     *
     * @param taskChild The child transfer task
     * @return updated TransferTaskChild
     */
Book keeping and cleanup. Mark the child as COMPLETE. Update the parent task with the bytes sent
@param taskChild The child transfer task
@return updated TransferTaskChild
Book keeping and cleanup . Mark the child as COMPLETE . Update the parent task with the bytes sent @param taskChild The child transfer task @return updated TransferTaskChild
private TransferTaskChild chevronThree(@NotNull TransferTaskChild taskChild) throws ServiceException {
        log.info("DOING chevron3 {}", taskChild);
        if (taskChild.isTerminal()) return taskChild;
        try {
            TransferTaskChild updated = dao.getChildTaskByUUID(taskChild.getUuid());
            updated.setStatus(TransferTaskStatus.COMPLETED);
            updated.setEndTime(Instant.now());
            updated = dao.updateTransferTaskChild(updated);
            dao.updateTransferTaskParentBytesTransferred(updated.getParentTaskId(), updated.getBytesTransferred());
            TransferTaskParent parent = dao.getTransferTaskParentById(updated.getParentTaskId());
            return updated;
        } catch (DAOException ex) {
            throw new ServiceException(Utils.getMsg("FILES_TXFR_SVC_ERR1", taskChild.getTenantId(), taskChild.getUsername(),
                "chevronThree", taskChild.getId(), taskChild.getUuid(), ex.getMessage()), ex);
        }
    }
private TransferTaskChild chevronThree ( @ NotNull TransferTaskChild taskChild ) throws ServiceException { log . info ( "DOING chevron3 {}" , taskChild ) ; if ( taskChild . isTerminal ( ) ) return taskChild ; try { TransferTaskChild updated = dao . getChildTaskByUUID ( taskChild . getUuid ( ) ) ; updated . setStatus ( TransferTaskStatus . COMPLETED ) ; updated . setEndTime ( Instant . now ( ) ) ; updated = dao . updateTransferTaskChild ( updated ) ; dao . updateTransferTaskParentBytesTransferred ( updated . getParentTaskId ( ) , updated . getBytesTransferred ( ) ) ; TransferTaskParent parent = dao . getTransferTaskParentById ( updated . getParentTaskId ( ) ) ; return updated ; } catch ( DAOException ex ) { throw new ServiceException ( Utils . getMsg ( "FILES_TXFR_SVC_ERR1" , taskChild . getTenantId ( ) , taskChild . getUsername ( ) , "chevronThree" , taskChild . getId ( ) , taskChild . getUuid ( ) , ex . getMessage ( ) ) , ex ) ; } }
Book keeping and cleanup.
Book keeping and cleanup .
// If it cancelled/failed somehow, just push it through unchanged.