FunctionService.hpp

Go to the documentation of this file.

#ifndef __GEMFIRE_FUNCTION_SERVICE_H__
#define __GEMFIRE_FUNCTION_SERVICE_H__

/*=========================================================================
  * 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.
  *
  * The specification of function behaviors is found in the corresponding
  * .cpp file.
  *
  *========================================================================
  */

#include "gfcpp_globals.hpp"
#include "gf_types.hpp"
#include "Execution.hpp"

// macros to resolve ambiguity between PoolPtr and RegionServicePtr
#define GF_TYPE_IS_POOL(T) \
  gemfire::TypeHelper::SuperSubclass<gemfire::Pool, T>::result
#define GF_TYPE_IS_POOL_TYPE(T) \
  gemfire::TypeHelper::YesNoType<GF_TYPE_IS_POOL(T)>::value

namespace gemfire {
  class CPPCACHE_EXPORT FunctionService : public SharedBase
{
  public:
  static ExecutionPtr onRegion(RegionPtr region);

  inline static ExecutionPtr onServer(const PoolPtr& pool)
  {
    return onServerWithPool(pool);
  }

  inline static ExecutionPtr onServer(const RegionServicePtr& cache)
  {
    return onServerWithCache(cache);
  }

  template <typename T>
  static ExecutionPtr onServer(const SharedPtr<T>& poolOrCache)
  {
    return onServer(poolOrCache, GF_TYPE_IS_POOL_TYPE(T));
  }
  
  inline static ExecutionPtr onServers(const PoolPtr& pool)
  {
    return onServersWithPool(pool);
  }

  inline static ExecutionPtr onServers(const RegionServicePtr& cache)
  {
    return onServersWithCache(cache);
  }

  template <typename T>
  static ExecutionPtr onServers(const SharedPtr<T>& poolOrCache)
  {
    return onServers(poolOrCache, GF_TYPE_IS_POOL_TYPE(T));
  }

  virtual ~FunctionService()
  {
  }

private:

  static ExecutionPtr onServerWithPool(const PoolPtr& pool);

  static ExecutionPtr onServerWithCache(const RegionServicePtr& cache);

  static ExecutionPtr onServersWithPool(const PoolPtr& pool);

  static ExecutionPtr onServersWithCache(const RegionServicePtr& cache);

  template <typename T>
  static ExecutionPtr onServer(const SharedPtr<T>& pool,
      TypeHelper::yes_type isPool)
  {
    return onServerWithPool(pool);
  }

  template <typename T>
  static ExecutionPtr onServer(const SharedPtr<T>& cache,
      TypeHelper::no_type isPool)
  {
    return onServerWithCache(cache);
  }

  template <typename T>
  static ExecutionPtr onServers(const SharedPtr<T>& pool,
      TypeHelper::yes_type isPool)
  {
    return onServersWithPool(pool);
  }

  template <typename T>
  static ExecutionPtr onServers(const SharedPtr<T>& cache,
      TypeHelper::no_type isPool)
  {
    return onServersWithCache(cache);
  }
};

} //namespace gemfire

#endif //__GEMFIRE_FUNCTION_SERVICE_H__