This is an automated email from the ASF dual-hosted git repository.
echobravo pushed a commit to branch fakeDev2
in repository https://gitbox.apache.org/repos/asf/geode-native.git
The following commit(s) were added to refs/heads/fakeDev2 by this push:
new 0d5e607 another breaker for the ragin-stagin-pr test
0d5e607 is described below
commit 0d5e6075888ce9663dcce2b88fc9ef96b7d716c3
Author: Ernest Burghardt <eburgha...@pivotal.io>
AuthorDate: Wed Feb 14 12:57:28 2018 -0700
another breaker for the ragin-stagin-pr test
---
cppcache/src/CacheFactory.cpp | 188 ------------------------------------------
1 file changed, 188 deletions(-)
diff --git a/cppcache/src/CacheFactory.cpp b/cppcache/src/CacheFactory.cpp
deleted file mode 100644
index b254604..0000000
--- a/cppcache/src/CacheFactory.cpp
+++ /dev/null
@@ -1,188 +0,0 @@
-/*
- * 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.
- */
-
-#include <functional>
-#include <map>
-#include <string>
-
-#include <ace/Recursive_Thread_Mutex.h>
-#include <ace/Guard_T.h>
-
-#include <geode/CacheFactory.hpp>
-#include <geode/Cache.hpp>
-#include <geode/SystemProperties.hpp>
-#include <geode/PoolManager.hpp>
-
-#include "config.h"
-#include "version.h"
-
-#include "CacheImpl.hpp"
-#include "CppCacheLibrary.hpp"
-#include "PoolAttributes.hpp"
-#include "CacheConfig.hpp"
-#include "DistributedSystemImpl.hpp"
-#include "SerializationRegistry.hpp"
-#include "PdxType.hpp"
-#include "PdxTypeRegistry.hpp"
-#include "DiskVersionTag.hpp"
-#include "TXCommitMessage.hpp"
-#include "PdxHelper.hpp"
-
-#define DEFAULT_CACHE_NAME "default_GeodeCache"
-
-namespace apache {
-namespace geode {
-namespace client {
-
-const std::string& CacheFactory::getVersion() {
- static std::string version{PRODUCT_VERSION};
- return version;
-}
-
-const std::string& CacheFactory::getProductDescription() {
- static std::string description{PRODUCT_VENDOR
- " " PRODUCT_NAME " " PRODUCT_VERSION
- " (" PRODUCT_BITS ") " PRODUCT_BUILDDATE};
- return description;
-}
-
-CacheFactory::CacheFactory() noexcept
- : ignorePdxUnreadFields(false), pdxReadSerialized(false), dsProp(nullptr)
{}
-
-CacheFactory::CacheFactory(
- const std::shared_ptr<Properties>& properties) noexcept
- : ignorePdxUnreadFields(false),
- pdxReadSerialized(false),
- dsProp(properties) {}
-
-Cache CacheFactory::create() const {
- auto cache =
- Cache(dsProp, ignorePdxUnreadFields, pdxReadSerialized, authInitialize);
-
- try {
- auto&& cacheXml =
- cache.getDistributedSystem().getSystemProperties().cacheXMLFile();
- if (!cacheXml.empty()) {
- cache.initializeDeclarativeCache(cacheXml);
- } else {
- cache.m_cacheImpl->initServices();
- }
- } catch (const apache::geode::client::RegionExistsException&) {
- LOGWARN("Attempt to create existing regions declaratively");
- } catch (const apache::geode::client::Exception&) {
- if (!cache.isClosed()) {
- cache.close();
- }
- throw;
- } catch (...) {
- if (!cache.isClosed()) {
- cache.close();
- }
- throw apache::geode::client::UnknownException(
- "Exception thrown in CacheFactory::create");
- }
-
- auto& cacheImpl = cache.m_cacheImpl;
- const auto& serializationRegistry = cacheImpl->getSerializationRegistry();
- const auto& pdxTypeRegistry = cacheImpl->getPdxTypeRegistry();
- const auto& memberListForVersionStamp =
- std::ref(*(cacheImpl->getMemberListForVersionStamp()));
-
- serializationRegistry->addType2(
- std::bind(TXCommitMessage::create, memberListForVersionStamp));
-
- serializationRegistry->addType(
- GeodeTypeIds::PdxType,
- std::bind(PdxType::CreateDeserializable, pdxTypeRegistry));
-
- serializationRegistry->addType(
- std::bind(VersionTag::createDeserializable, memberListForVersionStamp));
-
- serializationRegistry->addType2(
- GeodeTypeIdsImpl::DiskVersionTag,
- std::bind(DiskVersionTag::createDeserializable,
- memberListForVersionStamp));
-
- serializationRegistry->setPdxTypeHandler([](DataInput& dataInput) {
- return PdxHelper::deserializePdx(dataInput, false);
- });
-
- pdxTypeRegistry->setPdxIgnoreUnreadFields(cache.getPdxIgnoreUnreadFields());
- pdxTypeRegistry->setPdxReadSerialized(cache.getPdxReadSerialized());
-
- return cache;
-}
-
-Cache CacheFactory::create(
- const std::shared_ptr<CacheAttributes>& attrs) const {
- auto cache =
- Cache(dsProp, ignorePdxUnreadFields, pdxReadSerialized, authInitialize);
- cache.m_cacheImpl->setAttributes(attrs);
-
- try {
- auto&& cacheXml =
- cache.getDistributedSystem().getSystemProperties().cacheXMLFile();
- if (!cacheXml.empty()) {
- cache.initializeDeclarativeCache(cacheXml);
- } else {
- cache.m_cacheImpl->initServices();
- }
- } catch (const apache::geode::client::RegionExistsException&) {
- LOGWARN("Attempt to create existing regions declaratively");
- } catch (const apache::geode::client::Exception&) {
- if (!cache.isClosed()) {
- cache.close();
- }
- throw;
- } catch (...) {
- if (!cache.isClosed()) {
- cache.close();
- }
- throw apache::geode::client::UnknownException(
- "Exception thrown in CacheFactory::create");
- }
-
- return cache;
-}
-
-CacheFactory& CacheFactory::set(std::string name, std::string value) {
- if (this->dsProp == nullptr) {
- this->dsProp = Properties::create();
- }
- this->dsProp->insert(std::move(name), std::move(value));
- return *this;
-}
-
-CacheFactory& CacheFactory::setAuthInitialize(
- const std::shared_ptr<AuthInitialize>& handler) {
- this->authInitialize = handler;
- return *this;
-}
-
-CacheFactory& CacheFactory::setPdxIgnoreUnreadFields(bool ignore) {
- ignorePdxUnreadFields = ignore;
- return *this;
-}
-
-CacheFactory& CacheFactory::setPdxReadSerialized(bool prs) {
- pdxReadSerialized = prs;
- return *this;
-}
-
-} // namespace client
-} // namespace geode
-} // namespace apache
--
To stop receiving notification emails like this one, please contact
echobr...@apache.org.
