/*=========================================================================
 * Copyright (c) 2010-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
 * one or more patents listed at http://www.pivotal.io/patents.
 *=========================================================================
 */
#include "fw_dunit.hpp"
#include "ThinClientHelper.hpp"
#include <gfcpp/GemfireCppCache.hpp>
#include <ace/Task.h>
#include <ace/Recursive_Thread_Mutex.h>


using namespace gemfire;


class GetRegionThread : public ACE_Task_Base
{
  public:
    bool m_running;
    std::string m_path;
    std::string m_subPath;
    bool m_regionCreateDone;
    bool m_subRegionCreateDone;
    ACE_Recursive_Thread_Mutex  m_mutex;
    GetRegionThread(const char* path, const char* subPath):
       m_running(false),
       m_path(path),
       m_subPath(subPath),
       m_regionCreateDone(false),
       m_subRegionCreateDone(false),
       m_mutex(){
  }
  int svc(void)
  {
    while(m_running == true)
    {
         SLEEP(40);
	 try {
            RegionPtr rptr = cacheHelper->getRegion( m_path.c_str());
	    if (rptr != NULLPTR) {
               ACE_Guard< ACE_Recursive_Thread_Mutex > guard( m_mutex );
               ASSERT( m_regionCreateDone==true, "regionCreate Not Done" );
	    }
	 } catch( Exception& ex)
	 {
	   LOG(ex.getMessage());
	   continue;
	 } catch( std::exception& ex)
	 {
	   LOG(ex.what());
	   continue;
	 } catch( ... )
	 {
	   LOG("unknown exception");
	   continue;
	 }
	 try {
            RegionPtr rptr = cacheHelper->getRegion( m_subPath.c_str());
	    if (rptr != NULLPTR) {
               ACE_Guard< ACE_Recursive_Thread_Mutex > guard( m_mutex );
               ASSERT( m_subRegionCreateDone==true, "subRegionCreate Not Done" );
	       return 0;
	    }
	 } catch( Exception& ex)
	 {
	   LOG(ex.getMessage());
	 } catch( std::exception& ex)
	 {
	   LOG(ex.what());
	 } catch( ... )
	 {
	   LOG("getRegion: unknown exception");
	 }
    }
    return 0;
  }
  void setRegionFlag()
  {
     ACE_Guard< ACE_Recursive_Thread_Mutex > guard( m_mutex );
     m_regionCreateDone = true;
  }
  void setSubRegionFlag()
  {
     ACE_Guard< ACE_Recursive_Thread_Mutex > guard( m_mutex );
     m_subRegionCreateDone = true;
  }
  void start()
  {
      m_running = true;
      activate();
  }
  void stop()
  {
      m_running = false;
      wait();
  }
};
bool isLocalServer = false;
const char * endPoint = CacheHelper::getTcrEndpoints( isLocalServer, 1 );

GetRegionThread* getThread = NULL;
RegionPtr regionPtr;
DUNIT_TASK(s1p1,Setup)
{
  if ( isLocalServer )
    CacheHelper::initServer( 1 , "cacheserver_notify_subscription.xml");
  LOG("SERVER started");
}
ENDTASK

/* setup a normal region */
DUNIT_TASK(s2p2,CreateNormalRegion)
{
  initClient(true);
  LOG("create normal region");
  getThread = new GetRegionThread("DistRegionAck", "DistRegionAck/AuthSubregion");
  getThread->start();
  //getHelper()->createPlainRegion( "DistRegionAck", regionPtr );
  createRegion( "DistRegionAck", USE_ACK, endPoint, true);
  getThread->setRegionFlag();
  AttributesFactory af;
  af.setEndpoints(endPoint);
  RegionAttributesPtr rattrsPtr = af.createRegionAttributes( );
  regionPtr = getHelper()->getRegion( "DistRegionAck" );
  regionPtr->createSubregion( "AuthSubregion", rattrsPtr );
  getThread->setSubRegionFlag();
  LOG("create normal region successful");
}
END_TASK(CreateNormalRegion)


DUNIT_TASK(s2p2,CloseCache2)
{
  getThread->stop();
  delete getThread;
  cleanProc();
}
END_TASK(CloseCache2)

DUNIT_TASK(s1p1,CloseCache)
{
  CacheHelper::closeServer( 1 );
  LOG("SERVER closed");
}
ENDTASK