private void doUploadHistoricalVideo()

in src/main/java/com/aws/iot/edgeconnectorforkvs/videouploader/VideoUploaderClient.java [152:182]

26 lines of code
7 McCabe index (conditional complexity)


    private void doUploadHistoricalVideo(Date videoUploadingStartTime, Date videoUploadingEndTime,
                                         Runnable statusChangedCallBack, UploadCallBack uploadCallBack)
            throws KvsStreamingException {
        if (dataEndpoint == null) {
            dataEndpoint = getDataEndpoint();
        }

        List<VideoFile> videoFiles = videoRecordVisitor.listFilesToUpload(videoUploadingStartTime,
                videoUploadingEndTime);
        if (uploadCallBack != null) {
            uploadCallBack.setVideoFiles(videoFiles);
        }

        ListIterator<VideoFile> filesToUpload = videoFiles.listIterator();

        while (filesToUpload.hasNext() && !isTaskTerminating) {
            final Date videoStartTime = filesToUpload.next().getVideoDate();
            if (dataEndpoint == null) {
                uploadCallBack.setDateBegin(videoStartTime);
            }
            MkvFilesInputStream mkvFilesInputStream = new MkvFilesInputStream(filesToUpload);
            filesToUpload.previous();
            doUploadStream(mkvFilesInputStream, videoStartTime, statusChangedCallBack, uploadCallBack);
        }

        if (isTaskTerminating) {
            log.info("Quit uploading historical video because task is terminating");
        }

        log.info("No more video files to upload");
    }