Class TDataHolder

library/cpp/par/par_wb.h:24–64

    class TLocalDataBuffer: public TThrRefBase {
        TMutex Lock;
        class TDataHolder { // Handles ptr to an object or it's serialized copy
            TVector<TVector<char>> BinData;
            TObj<IObjectBase> LocalObject;

        public:
            TDataHolder() {
            }
            TDataHolder(TVector<TVector<char>>& binData) {
                BinData.swap(binData);
            }
            TDataHolder(const IObjectBase* localObject) {
                LocalObject = const_cast<IObjectBase*>(localObject);
            }
            void SetData(TVector<TVector<char>>& binData) {
                TVector<TVector<char>>().swap(BinData);
                BinData.swap(binData);
                if (LocalObject) {
                    LocalObject = nullptr;
                }
            }
            void SetObject(const IObjectBase* localObject) {
                LocalObject = const_cast<IObjectBase*>(localObject);
                TVector<TVector<char>>().swap(BinData);
            }
            TVector<TVector<char>>& GetData() {
                if (LocalObject) {
                    if (!BinData.size()) {
                        SerializeToMem(&BinData, LocalObject);
                    }
                }
                return BinData;
            }
            TObj<IObjectBase> GetObject() {
                if (!LocalObject) {
                    TObj<IObjectBase> obj;
                    SerializeFromMem(&BinData, obj);
                    return obj;
                }
                return LocalObject;
            }
        };
        // can not use smarter pointers due to non thread safe ref counters in IObjectBase
        typedef THashMap<i64, TDataHolder> TDataHash;
        TDataHash Data;