PoolFactory.hpp

Go to the documentation of this file.

#pragma once

#ifndef GEODE_POOLFACTORY_H_
#define GEODE_POOLFACTORY_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.
 */

#include "geode_globals.hpp"
#include "SharedBase.hpp"
#include "geode_types.hpp"
#include "Pool.hpp"

namespace apache {
namespace geode {
namespace client {

class CacheImpl;
class PoolAttributes;

class CPPCACHE_EXPORT PoolFactory : public SharedBase {
 public:
  static const int DEFAULT_FREE_CONNECTION_TIMEOUT = 10000;

  static const int DEFAULT_LOAD_CONDITIONING_INTERVAL = 1000 * 60 * 5;

  static const int DEFAULT_SOCKET_BUFFER_SIZE = 32768;

  static const int DEFAULT_READ_TIMEOUT = 10000;

  static const int DEFAULT_MIN_CONNECTIONS = 1;

  static const int DEFAULT_MAX_CONNECTIONS = -1;

  static const long DEFAULT_IDLE_TIMEOUT = 5000;

  static const int DEFAULT_RETRY_ATTEMPTS = -1;

  static const long DEFAULT_PING_INTERVAL = 10000;

  static const long DEFAULT_UPDATE_LOCATOR_LIST_INTERVAL = 5000;

  static const int DEFAULT_STATISTIC_INTERVAL = -1;

  // static const bool DEFAULT_THREAD_LOCAL_CONNECTIONS = false;

  static const bool DEFAULT_SUBSCRIPTION_ENABLED = false;

  static const int DEFAULT_SUBSCRIPTION_REDUNDANCY = 0;

  static const int DEFAULT_SUBSCRIPTION_MESSAGE_TRACKING_TIMEOUT = 900000;

  static const int DEFAULT_SUBSCRIPTION_ACK_INTERVAL = 100;

  static const char* DEFAULT_SERVER_GROUP;
  static const bool DEFAULT_THREAD_LOCAL_CONN = false;

  static const bool DEFAULT_MULTIUSER_SECURE_MODE = false;

  static const bool DEFAULT_PR_SINGLE_HOP_ENABLED = true;

  void setFreeConnectionTimeout(int connectionTimeout);
  void setLoadConditioningInterval(int loadConditioningInterval);
  void setSocketBufferSize(int bufferSize);

  void setThreadLocalConnections(bool threadLocalConnections);

  void setReadTimeout(int timeout);

  void setMinConnections(int minConnections);

  void setMaxConnections(int maxConnections);

  void setIdleTimeout(long idleTimeout);

  void setRetryAttempts(int retryAttempts);

  void setPingInterval(long pingInterval);

  void setUpdateLocatorListInterval(long updateLocatorListInterval);

  void setStatisticInterval(int statisticInterval);

  void setServerGroup(const char* group);

  void addLocator(const char* host, int port);

  void addServer(const char* host, int port);

  void setSubscriptionEnabled(bool enabled);
  void setSubscriptionRedundancy(int redundancy);
  void setSubscriptionMessageTrackingTimeout(int messageTrackingTimeout);

  void setSubscriptionAckInterval(int ackInterval);

  void setMultiuserAuthentication(bool multiuserAuthentication);

  void reset();

  PoolPtr create(const char* name);

  void setPRSingleHopEnabled(bool enabled);

  ~PoolFactory();

 private:
  PoolFactory();
  PoolFactory(const PoolFactory&);
  void addCheck(const char* host, int port);
  PoolAttributesPtr m_attrs;
  bool m_isSubscriptionRedundancy;
  bool m_addedServerOrLocator;
  friend class Cache;
  friend class PoolManager;
  friend class CacheFactory;
  friend class CacheXmlCreation;
};
}  // namespace client
}  // namespace geode
}  // namespace apache

#endif  // GEODE_POOLFACTORY_H_