Project

General

Profile

« Previous | Next » 

Revision 7774

Added by Jing Tao about 11 years ago

Put the waiting mechanism for the hazelcast at the first place.

View differences:

metacat-index/src/main/java/edu/ucsb/nceas/metacat/index/DistributedMapsFactory.java
54 54 
    private static HazelcastClient hzClient = null;
55 55 
    private static String hzSystemMetadata = null;
56 56 
    private static String hzObjectPath = null;
57 
    private static int waitingTime = IndexGenerator.WAITTIME;
58 
    private static int maxAttempts = IndexGenerator.MAXWAITNUMBER;
57 59
58 60 
    /*
59 61 
     * Start the hazel cast client
60 62 
     */
61 63 
    private static void startHazelCastClient() throws FileNotFoundException, ServiceFailure{
64
65 
        try {
66 
            waitingTime = Settings.getConfiguration().getInt(IndexGenerator.WAITIMEPOPERTYNAME);
67 
            maxAttempts = Settings.getConfiguration().getInt(IndexGenerator.MAXATTEMPTSPROPERTYNAME);
68 
        } catch (Exception e) {
69 
            log.warn("DistributedMapFactory.startHazelCastClient - couldn't read the waiting time or maxattempts from the metacat.properties file since : "+e.getMessage()+". Default values will be used");
70 
            waitingTime = IndexGenerator.WAITTIME;
71 
            maxAttempts = IndexGenerator.MAXWAITNUMBER;
72 
        }
62 73 
     // get config values
63 74 
        hzSystemMetadata = Settings.getConfiguration().getString(
64 75 
                "dataone.hazelcast.storageCluster.systemMetadataMap");
......
90 101 
        cc.getGroupConfig().setName(hzGroupName);
91 102 
        cc.getGroupConfig().setPassword(hzGroupPassword);
92 103 
        cc.addAddress(hzAddress);
93 
        try {
94 
            hzClient = HazelcastClient.newHazelcastClient(cc);
95 
        } catch (Exception e) {
96 
            log.error("Unable to create hazelcast client: ", e);
97 
            throw new ServiceFailure("0000","DistributedMapsFactory.startHazelCastClient - can't start the hazel cast client since "+e.getMessage());
104
105 
        int times = 0;
106 
        while(true) {
107 
            //System.out.println("here ==================");
108 
            try {
109 
                hzClient = HazelcastClient.newHazelcastClient(cc);
110 
                break;
111 
            } catch (Exception e) {
112 
                    if(times <= maxAttempts) {
113 
                        log.warn("DistributedMapFactory.startHazelCastClient - the hazelcast service is not ready : "
114 
                                         +e.getMessage()+"\nWe will try to access it "+waitingTime/1000+" seconds later ");
115 
                        try {
116 
                            Thread.sleep(waitingTime);
117 
                        } catch (Exception ee) {
118 
                            log.warn("DistributedMapFactory.startHazelCastClient - the thread can't sleep for "+waitingTime/1000+" seconds to wait the hazelcast service");
119 
                        }
120
121 
                    } else {
122 
                        throw new ServiceFailure("0000", "DistributedMapFactory.startHazelCastClient - the hazelcast service is not ready even though Metacat-index wailted for "+
123 
                                        maxAttempts*waitingTime/1000+" seconds. We can't get the system metadata from it and the building index can't happen this time");
124 
                    }
125 
             }
126 
             times++;
127 
             //System.out.println("here ==================2");
98 128 
        }
129
130 

  		




  99
  131
  
    
    }


  		




  100
  132
  
    
    


  		




  101
  133
  
    
    /**


  		












  

    
      metacat-index/src/main/java/edu/ucsb/nceas/metacat/index/IndexGenerator.java
    
  





  66
  66
  
    
    


  		




  67
  67
  
    
    private static final int FIRST =0;


  		




  68
  68
  
    
    private static final int SECOND =1;


  		




  69
  
  
    
    private static final int WAITTIME = 10000;


  		




  70
  
  
    
    private static final int MAXWAITNUMBER = 180;


  		




  
  69
  
    
    public static final int WAITTIME = 10000;


  		




  
  70
  
    
    public static final int MAXWAITNUMBER = 180;


  		




  71
  71
  
    
    private static final String HTTP = "http://";


  		




  72
  72
  
    
    private static final String MNAPPENDIX = "/d1/mn";


  		




  73
  73
  
    
    private static final String RESOURCEMAPPROPERYNAME = "index.resourcemap.namespace";


  		




  74
  
  
    
    private static final String WAITIMEPOPERTYNAME = "index.regenerate.start.waitingtime";


  		




  75
  
  
    
    private static final String MAXATTEMPTSPROPERTYNAME = "index.regenerate.start.maxattempts";


  		




  
  74
  
    
    public static final String WAITIMEPOPERTYNAME = "index.regenerate.start.waitingtime";


  		




  
  75
  
    
    public static final String MAXATTEMPTSPROPERTYNAME = "index.regenerate.start.maxattempts";


  		




  76
  76
  
    
    


  		




  77
  77
  
    
    private static int waitingTime = WAITTIME;


  		




  78
  78
  
    
    private static int maxAttempts = MAXWAITNUMBER;


  		




  ......




  386
  386
  
    
    private void initSystemMetadataMap() throws FileNotFoundException, ServiceFailure{


  		




  387
  387
  
    
        int times = 0;


  		




  388
  388
  
    
        if(systemMetadataMap == null) {


  		




  389
  
  
    
            while(true) {


  		




  
  389
  
    
            systemMetadataMap = DistributedMapsFactory.getSystemMetadataMap();


  		




  
  390
  
    
            /*while(true) {


  		




  390
  391
  
    
                try {


  		




  391
  392
  
    
                    systemMetadataMap = DistributedMapsFactory.getSystemMetadataMap();


  		




  392
  393
  
    
                    break;


  		




  ......




  407
  408
  
    
                    }


  		




  408
  409
  
    
                }


  		




  409
  410
  
    
                times++;


  		




  410
  
  
    
            }


  		




  
  411
  
    
            }*/


  		




  411
  412
  
    
        }


  		




  412
  413
  
    
    }


  		




  413
  414
  
    
    


  		












Also available in:  Unified diff