lib/src/main/java/edu/utexas/tacc/tapis/files/lib/services/ChildTaskTransferService.java
private Mono<Long> updateProgress(Long bytesSent, TransferTaskChild taskChild) {
        // Be careful here if any other updates need to be done, this method (probably) runs in a different
        // thread than the main thread. It is possible for the TransferTaskChild passed in above to have been updated
        // on a different thread.
        try {
            dao.updateTransferTaskChildBytesTransferred(taskChild, bytesSent);
            return Mono.just(bytesSent);
        } catch (DAOException ex) {
            log.error(Utils.getMsg("FILES_TXFR_SVC_ERR1", taskChild.getTenantId(), taskChild.getUsername(),
                "updateProgress", taskChild.getId(), taskChild.getUuid(), ex.getMessage()));
            return Mono.empty();
        }
    }
/**
     * This method is called during the actual transfer of bytes. As the stream is read, events on
     * the number of bytes transferred are passed here to be written to the datastore.
     * @param bytesSent total bytes sent in latest update
     * @param taskChild The transfer task that is being worked on currently
     * @return Mono with number of bytes sent
     */
This method is called during the actual transfer of bytes. As the stream is read, events on
the number of bytes transferred are passed here to be written to the datastore.
@param bytesSent total bytes sent in latest update
@param taskChild The transfer task that is being worked on currently
@return Mono with number of bytes sent
This method is called during the actual transfer of bytes . As the stream is read events on the number of bytes transferred are passed here to be written to the datastore . @param bytesSent total bytes sent in latest update @param taskChild The transfer task that is being worked on currently @return Mono with number of bytes sent
private Mono<Long> updateProgress(Long bytesSent, TransferTaskChild taskChild) {
        try {
            dao.updateTransferTaskChildBytesTransferred(taskChild, bytesSent);
            return Mono.just(bytesSent);
        } catch (DAOException ex) {
            log.error(Utils.getMsg("FILES_TXFR_SVC_ERR1", taskChild.getTenantId(), taskChild.getUsername(),
                "updateProgress", taskChild.getId(), taskChild.getUuid(), ex.getMessage()));
            return Mono.empty();
        }
    }
private Mono < Long > updateProgress ( Long bytesSent , TransferTaskChild taskChild ) { try { dao . updateTransferTaskChildBytesTransferred ( taskChild , bytesSent ) ; return Mono . just ( bytesSent ) ; } catch ( DAOException ex ) { log . error ( Utils . getMsg ( "FILES_TXFR_SVC_ERR1" , taskChild . getTenantId ( ) , taskChild . getUsername ( ) , "updateProgress" , taskChild . getId ( ) , taskChild . getUuid ( ) , ex . getMessage ( ) ) ) ; return Mono . empty ( ) ; } }
This method is called during the actual transfer of bytes.
This method is called during the actual transfer of bytes .
// Be careful here if any other updates need to be done, this method (probably) runs in a different // thread than the main thread. It is possible for the TransferTaskChild passed in above to have been updated // on a different thread.