Index: src/libchcore/TSubTaskDelete.h =================================================================== diff -u -ra5f396da5ed5ffb3fcd9fdf22afb5a7fd07e1ab8 -r081055369d6b332ef1651877756657973b1b2d9c --- src/libchcore/TSubTaskDelete.h (.../TSubTaskDelete.h) (revision a5f396da5ed5ffb3fcd9fdf22afb5a7fd07e1ab8) +++ src/libchcore/TSubTaskDelete.h (.../TSubTaskDelete.h) (revision 081055369d6b332ef1651877756657973b1b2d9c) @@ -42,17 +42,20 @@ TDeleteProgressInfo(); virtual ~TDeleteProgressInfo(); - virtual void Serialize(TReadBinarySerializer& rSerializer); - virtual void Serialize(TWriteBinarySerializer& rSerializer) const; - virtual void ResetProgress(); void SetCurrentIndex(size_t stIndex); void IncreaseCurrentIndex(); size_t GetCurrentIndex() const; + void Store(const ISerializerRowDataPtr& spRowData) const; + static void InitLoader(IColumnsDefinition& rColumns); + void Load(const ISerializerRowReaderPtr& spRowReader); + bool WasSerialized() const; + private: size_t m_stCurrentIndex; + mutable size_t m_stLastStoredIndex; mutable boost::shared_mutex m_lock; }; } @@ -70,6 +73,9 @@ virtual ESubOperationResult Exec(); virtual ESubOperationType GetSubOperationType() const { return eSubOperation_Deleting; } + virtual void Store(const ISerializerPtr& spSerializer) const; + virtual void Load(const ISerializerPtr& spSerializer); + virtual TSubTaskProgressInfo& GetProgressInfo() { return m_tProgressInfo; } virtual void GetStatsSnapshot(TSubTaskStatsSnapshotPtr& spStats) const;