@class NSMutableDictionary, CPLEngineScope, CPLRecordTargetMapping, NSDate, NSObject, CPLEngineScheduler, CPLEngineTransport, NSMutableArray, NSString, CPLBatchExtractionStrategy, CPLDerivativesFilter, CPLEngineStoreTransaction, CPLTransportScopeMapping, NSArray, CPLChangeBatch, CPLEngineScopeStorage, CPLEnginePushRepository, CPLBeforeUploadCheckItems;
@protocol CPLEngineTransportFetchRecordsTask, CPLEngineTransportUploadBatchTask, CPLEngineTransportGroup, CPLUploadPushedChangesTaskDelegate, OS_dispatch_queue, CPLBatchExtractionStrategyStorage;

@interface CPLUploadPushedChangesTask : CPLEngineScopedTask <CPLBeforeUploadCheckItemsProvider> {
    NSObject<OS_dispatch_queue> *_lock;
    NSString *_scopeIdentifier;
    CPLEngineScopeStorage *_scopes;
    CPLEngineTransport *_transport;
    CPLEngineScheduler *_scheduler;
    id<CPLBatchExtractionStrategyStorage> _batchStorage;
    CPLBatchExtractionStrategy *_currentStrategy;
    CPLChangeBatch *_diffedBatch;
    CPLChangeBatch *_batchToCommit;
    BOOL _mustConsiderOtherPriorities;
    CPLDerivativesFilter *_derivativesFilter;
    NSArray *_uploadResourceTasks;
    NSMutableDictionary *_cloudScopedIdentifiersToUploadResourceTaskErrors;
    CPLBeforeUploadCheckItems *_checkItems;
    CPLEngineStoreTransaction *_transactionDuringItemsPreparation;
    NSMutableArray *_preparedUploadResourceTasks;
    CPLRecordTargetMapping *_targetMapping;
    NSMutableDictionary *_invalidTransportScopes;
    id<CPLEngineTransportFetchRecordsTask> _fetchRecordsTask;
    id<CPLEngineTransportUploadBatchTask> _uploadTask;
    unsigned long long _lastReportedProgress;
    unsigned long long _countOfPushedChanges;
    double _startOfIteration;
    double _startOfDerivativesGeneration;
    BOOL _deferredCancel;
    BOOL _hasCachedShouldCheckResourcesAhead;
    BOOL _shouldCheckResourcesAhead;
    BOOL _shouldSetupEstimatedSize;
    id<CPLEngineTransportGroup> _transportGroup;
    long long _taskItem;
    BOOL _hasPushedSomeChanges;
    BOOL _isUsingOverQuotaStrategy;
    BOOL _resetStrategy;
    double _latestApproximativeUploadRate;
    NSString *_currentTaskKey;
    NSDate *_taskStartDate;
    unsigned long long _recordCount;
    BOOL _didExtractOneBatch;
    BOOL _wasBusy;
    BOOL _hasUploadedOneBatch;
}

@property (class, nonatomic) BOOL disableOverQuotaRule;

@property (retain) id<CPLUploadPushedChangesTaskDelegate> delegate;
@property (readonly, nonatomic) id<CPLEngineTransportGroup> storedTransportGroup;
@property (readonly, nonatomic) CPLEngineScope *sharedScope;
@property (readonly, nonatomic) CPLTransportScopeMapping *transportScopeMapping;
@property (readonly, nonatomic) long long ruleGroup;
@property (readonly, nonatomic) BOOL highPriority;
@property (readonly, nonatomic) unsigned long long maxBatchSize;
@property (readonly, nonatomic) unsigned long long pushRepositoryPriority;
@property (readonly, nonatomic) CPLEnginePushRepository *pushRepository;
@property (readonly, nonatomic) BOOL didUseOverQuotaStrategy;
@property (readonly) unsigned long long hash;
@property (readonly) Class superclass;
@property (readonly, copy) NSString *description;
@property (readonly, copy) NSString *debugDescription;

+ (void)resetDisabledOverQuotaRule;

- (id)taskIdentifier;
- (void)launch;
- (void).cxx_destruct;
- (void)cancel;
- (BOOL)isResourceDynamic:(id)a0;
- (void)cancel:(BOOL)a0;
- (void)_checkPrioritiesWithFetchCache:(id)a0;
- (BOOL)checkScopeIsValidInTransaction:(id)a0;
- (BOOL)_canUseOverQuotaRule;
- (void)_checkForRecordExistence;
- (void)_clearUploadBatch;
- (void)_deleteGeneratedResourcesAfterError:(id)a0;
- (void)_didFinishTaskWithKey:(id)a0 error:(BOOL)a1 cancelled:(BOOL)a2;
- (void)_didStartTaskWithKey:(id)a0 recordCount:(unsigned long long)a1;
- (BOOL)_discardUploadedExtractedBatch:(id)a0 error:(id *)a1;
- (void)_excludeScopeFromMingling;
- (void)_extractAndUploadOneBatch;
- (void)_extractBatchWithTransaction:(id)a0 andStore:(id)a1;
- (void)_generateDerivativesForNextRecord:(id)a0 usingDerivativesCache:(id)a1 fetchCache:(id)a2;
- (void)_generateNeededDerivativesWithFetchCache:(id)a0;
- (BOOL)_markUploadedTasksDidFinishWithError:(id)a0 transaction:(id)a1 error:(id *)a2;
- (void)_noteSuccessfulUpdateInTransaction:(id)a0;
- (void)_popNextBatchAndContinue;
- (void)_prepareTransportGroupForOneBatch;
- (void)_prepareUploadBatch;
- (BOOL)_reenqueueExtractedBatchWithRejectedRecords:(id)a0 extractedBatch:(id)a1 error:(id *)a2;
- (BOOL)_shouldNotTrustCloudCacheAfterError:(id)a0;
- (BOOL)_shouldUploadBatchesWithDropReason:(id *)a0 shouldQuarantineRecords:(BOOL *)a1 inTransaction:(id)a2;
- (void)_updateQuotaStrategyAfterSuccessInTransaction:(id)a0;
- (void)_uploadBatchWithFetchCache:(id)a0;
- (void)_uploadTaskDidFinishWithError:(id)a0;
- (BOOL)_willNeedToAccessScopeWithIdentifier:(id)a0 primaryScope:(BOOL)a1 error:(id *)a2;
- (id)availableResourceTypesToUploadForChange:(id)a0;
- (id)initWithEngineLibrary:(id)a0 session:(id)a1 clientCacheIdentifier:(id)a2 scope:(id)a3 transportScope:(id)a4 storedTransportGroup:(id)a5 sharedScope:(id)a6 transportScopeMapping:(id)a7 ruleGroup:(long long)a8 highPriority:(BOOL)a9 maxBatchSize:(unsigned long long)a10 pushRepositoryPriority:(unsigned long long)a11 pushRepository:(id)a12;
- (BOOL)isCloudRecordWithScopedIdentifierShared:(id)a0;
- (id)knownCloudRecordWithScopedIdentifier:(id)a0;
- (BOOL)willNeedToAccessRecordWithScopedIdentifier:(id)a0 error:(id *)a1;
- (id)willUploadCloudResource:(id)a0 localResource:(id)a1 error:(id *)a2;

@end