blob: 64637f731c2314b126494a23e995b209b02da9a0 [file] [log] [blame]
#pragma once
#ifndef GEODE_REGIONCOMMIT_H_
#define GEODE_REGIONCOMMIT_H_
/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0
* (the "License"); you may not use this file except in compliance with
* the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
/*
* RegionCommit.hpp
*
* Created on: 23-Feb-2011
* Author: ankurs
*/
#include <vector>
#include <geode/Cache.hpp>
#include <geode/CacheableString.hpp>
#include <geode/DataInput.hpp>
#include "FarSideEntryOp.hpp"
namespace apache {
namespace geode {
namespace client {
class RegionCommit {
public:
explicit RegionCommit(MemberListForVersionStamp& memberListForVersionStamp)
: m_memberListForVersionStamp(memberListForVersionStamp){};
virtual ~RegionCommit(){};
void fromData(DataInput& input);
void apply(Cache* cache);
void fillEvents(std::vector<std::shared_ptr<FarSideEntryOp>>& ops);
std::shared_ptr<Region> getRegion(Cache* cache) {
return cache->getRegion(m_regionPath->value());
}
private:
std::shared_ptr<CacheableString> m_regionPath;
std::shared_ptr<CacheableString> m_parentRegionPath;
std::vector<std::shared_ptr<FarSideEntryOp>> m_farSideEntryOps;
MemberListForVersionStamp& m_memberListForVersionStamp;
};
} // namespace client
} // namespace geode
} // namespace apache
#endif // GEODE_REGIONCOMMIT_H_