gemfire-core/src/test/java/com/gemstone/gemfire/internal/cache/RemoveDAckDUnitTest.java

/*=========================================================================
 * 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.
 *=========================================================================
 */
/*
 * RemoveDAckDUnitTest.java
 *
 * Created on September 15, 2005, 12:41 PM
 */

package com.gemstone.gemfire.internal.cache;
import com.gemstone.gemfire.cache.AttributesFactory;
import com.gemstone.gemfire.cache.Cache;
import com.gemstone.gemfire.cache.CacheException;
import com.gemstone.gemfire.cache.CacheFactory;
import com.gemstone.gemfire.cache.CacheTransactionManager;
import com.gemstone.gemfire.cache.Region;
import com.gemstone.gemfire.cache.RegionAttributes;
import com.gemstone.gemfire.cache.Scope;
import com.gemstone.gemfire.cache30.CacheSerializableRunnable;
import com.gemstone.gemfire.distributed.DistributedSystem;

import dunit.*;

import java.util.Properties;
/**
 *
 * @author vjadhav
 */
public class RemoveDAckDUnitTest extends DistributedTestCase {
    
    /** Creates a new instance of RemoveDAckDUnitTest */
    public RemoveDAckDUnitTest(String name) {
        super(name);
    }
    
    static Cache cache;
    static Properties props = new Properties();
    static Properties propsWork = new Properties();
    static DistributedSystem ds = null;
    static Region region;
    static CacheTransactionManager cacheTxnMgr;
    static volatile  boolean IsBeforeDestroy = false;
    static boolean flag = false;
    
    @Override
    public void setUp() throws Exception {
      super.setUp();
      Host host = Host.getHost(0);
      VM vm0 = host.getVM(0);
      VM vm1 = host.getVM(1);
      vm0.invoke(RemoveDAckDUnitTest.class, "createCacheVM0");
      vm1.invoke(RemoveDAckDUnitTest.class, "createCacheVM1");
      getLogWriter().fine("Cache created in successfully");
    }
    
    public void tearDown2(){
        Host host = Host.getHost(0);
        VM vm0 = host.getVM(0);
        VM vm1 = host.getVM(1);
        vm0.invoke(RemoveDAckDUnitTest.class, "closeCache");
        vm1.invoke(RemoveDAckDUnitTest.class, "closeCache");
        
    }
    
    public static void createCacheVM0(){
        try{            
            ds = (new RemoveDAckDUnitTest("temp")).getSystem(props);
            cache = CacheFactory.create(ds);            
            AttributesFactory factory  = new AttributesFactory();
            factory.setScope(Scope.DISTRIBUTED_ACK);            
            RegionAttributes attr = factory.create();
            
            region = cache.createRegion("map", attr);
        } catch (Exception ex){
            ex.printStackTrace();
        }
    } //end of create cache for VM0
    public static void createCacheVM1(){
        try{            
            ds = (new RemoveDAckDUnitTest("temp")).getSystem(props);
            AttributesFactory factory  = new AttributesFactory();
            cache = CacheFactory.create(ds);
            factory.setScope(Scope.DISTRIBUTED_ACK);            
            RegionAttributes attr = factory.create();            
            region = cache.createRegion("map", attr);
            
        } catch (Exception ex){
            ex.printStackTrace();
        }
    }
    
    public static void closeCache(){
        try{
            cache.close();
            ds.disconnect();
        } catch (Exception ex){
            ex.printStackTrace();
        }
    }
    
    
    public void testRemoveMultiVM(){
        //Commented the Test.As it is failing @ line no 133 : AssertionFailedError
        Host host = Host.getHost(0);
        VM vm0 = host.getVM(0);
        VM vm1 = host.getVM(1);
        
//        Object obj1;
        Object[] objArr = new Object[1];
        for (int i=1; i<5; i++){
            objArr[0] = new Integer(i);
            vm0.invoke(RemoveDAckDUnitTest.class, "putMethod", objArr);
        }
        
        vm1.invoke(new CacheSerializableRunnable("get object"){
                public void run2() throws CacheException{
                    for (int i=1; i<5; i++){
                        region.get(new Integer(i));
                    }
                }
            });
        
        
        int i=2;
        objArr[0] = new Integer(i);
        vm0.invoke(RemoveDAckDUnitTest.class,"removeMethod", objArr);
        
        int Regsize = vm1.invokeInt(RemoveDAckDUnitTest.class, "sizeMethod");
        assertEquals(3, Regsize);
        
    }//end of test case
    
    public static Object putMethod(Object ob){
        Object obj=null;
        try{
            if(ob != null){
                String str = "first";
                obj = region.put(ob, str);
            }
        }catch(Exception ex){
            ex.printStackTrace();
            fail("Failed while region.put");
        }
        return obj;
    }
    public static int sizeMethod(){
        int i=0;
        try{
            i = region.size();
        }catch(Exception ex){
            fail("Failed while region.size");
        }
        return i;
    }
    
    public static Object removeMethod(Object obR){
        Object objR=null;
        try{
            if(obR != null){
                objR = region.remove(obR);
            }
        }catch(Exception ex){
            ex.printStackTrace();
            fail("Failed while region.remove");
        }
        return objR;
        
    }
    

}// end of  class