ResultCollector.hpp

Go to the documentation of this file.

#ifndef __GEMFIRE_RESULTCOLLECTOR_H__
#define __GEMFIRE_RESULTCOLLECTOR_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.
 *========================================================================
 */

#include "gfcpp_globals.hpp"
#include "gf_types.hpp"
#include "SharedPtr.hpp"
#include "VectorT.hpp"
#include "CacheableBuiltins.hpp"

namespace gemfire {
class CPPCACHE_EXPORT ResultCollector
: public SharedBase
{
public:
  ResultCollector();
  virtual ~ResultCollector();
  virtual CacheableVectorPtr getResult(uint32_t timeout =  DEFAULT_QUERY_RESPONSE_TIMEOUT);
  virtual void addResult(CacheablePtr& resultOfSingleExecution);
  virtual void endResults();
  virtual void clearResults();

private:
  CacheableVectorPtr m_resultList;
  volatile bool m_isResultReady;
};

} //namespace gemfire
#endif //ifndef __GEMFIRE_RESULTCOLLECTOR_H__