PoolFactory.hpp

Go to the documentation of this file.

#ifndef __GEMFIRE_POOL_FACTORY_HPP__
#define __GEMFIRE_POOL_FACTORY_HPP__
/*=========================================================================
 * Copyright (c) 2002-2014 Pivotal Software, Inc. All Rights Reserved.
 * This product is protected by U.S. and international copyright
 * and intellectual property laws. Pivotal products are covered by
 * more patents listed at http://www.pivotal.io/patents.
 *========================================================================
 */

#include "gfcpp_globals.hpp"
#include "SharedBase.hpp"
#include "gf_types.hpp"
#include "Pool.hpp"

namespace gemfire {

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 gemfire
#endif //ifndef __GEMFIRE_POOL_FACTORY_HPP__