src/test/java/org/onap/aai/sparky/synchronizer/TestSyncController.java

   1 package org.onap.aai.sparky.synchronizer;
   2
   3 import java.util.Calendar;
   4 import java.util.Date;
   5 import java.util.concurrent.Semaphore;
   6
   7 import org.onap.aai.sparky.sync.IndexCleaner;
   8 import org.onap.aai.sparky.sync.IndexSynchronizer;
   9 import org.onap.aai.sparky.sync.IndexValidator;
  10 import org.onap.aai.sparky.sync.SyncController;
  11 import org.onap.aai.sparky.sync.SyncControllerImpl.SyncActions;
  12 import org.onap.aai.sparky.sync.enumeration.OperationState;
  13 import org.onap.aai.sparky.sync.enumeration.SynchronizerState;
  14
  15 public class TestSyncController implements SyncController {
  16
  17   private String controllerName;
  18   private boolean periodic;
  19   private SynchronizerState internalState;
  20   private Semaphore gate;
  21
  22   public TestSyncController(String name) {
  23     this.controllerName = name;
  24     this.internalState = SynchronizerState.IDLE;
  25     this.gate = new Semaphore(1);
  26   }
  27
  28
  29   @Override
  30   public String getControllerName() {
  31     return this.controllerName;
  32   }
  33
  34   @Override
  35   public OperationState performAction(SyncActions requestedAction) {
  36
  37     if (gate.tryAcquire()) {
  38
  39       internalState = SynchronizerState.PERFORMING_SYNCHRONIZATION;
  40
  41       // System.out.println("performaAction = " + requestedAction);
  42
  43       System.out.println("Sync started with thread = " + Thread.currentThread().getName()
  44           + " at date = " + new Date(Calendar.getInstance().getTimeInMillis()));
  45
  46       try {
  47         Thread.sleep(10000L);
  48       } catch (InterruptedException e) {
  49         // TODO Auto-generated catch block
  50         e.printStackTrace();
  51       }
  52
  53       System.out.println("Sync done with thread = " + Thread.currentThread().getName()
  54           + " at date = " + new Date(Calendar.getInstance().getTimeInMillis()));
  55       internalState = SynchronizerState.IDLE;
  56
  57       System.out.println("Next Sync at = " + Thread.currentThread().getName() + " at date = "
  58           + new Date(Calendar.getInstance().getTimeInMillis() + 30000L));
  59
  60
  61       gate.release();
  62
  63       return OperationState.OK;
  64     } else {
  65       return OperationState.IGNORED_SYNC_NOT_IDLE;
  66     }
  67   }
  68
  69   @Override
  70   public void registerEntitySynchronizer(IndexSynchronizer entitySynchronizer) {
  71     // TODO Auto-generated method stub
  72
  73   }
  74
  75   @Override
  76   public void registerIndexValidator(IndexValidator indexValidator) {
  77     // TODO Auto-generated method stub
  78
  79   }
  80
  81   @Override
  82   public void registerIndexCleaner(IndexCleaner indexCleaner) {
  83     // TODO Auto-generated method stub
  84
  85   }
  86
  87   @Override
  88   public void shutdown() {
  89     // TODO Auto-generated method stub
  90     // System.out.println("shutdown");
  91   }
  92
  93   @Override
  94   public SynchronizerState getState() {
  95     // System.out.println("getState()");
  96     return SynchronizerState.IDLE;
  97   }
  98
  99   @Override
 100   public long getDelayInMs() {
 101     // TODO Auto-generated method stub
 102     return 1000L;
 103   }
 104
 105   @Override
 106   public void setDelayInMs(long delayInMs) {
 107     // TODO Auto-generated method stub
 108
 109   }
 110
 111   @Override
 112   public long getSyncFrequencyInMs() {
 113     // TODO Auto-generated method stub
 114     return 30000L;
 115   }
 116
 117   @Override
 118   public void setSyncFrequencyInMs(long syncFrequencyInMs) {
 119     // TODO Auto-generated method stub
 120
 121   }
 122
 123   @Override
 124   public Date getSyncStartTime() {
 125     // System.out.println("getSyncStateTime()");
 126     // TODO Auto-generated method stub
 127     return null;
 128   }
 129
 130   @Override
 131   public void setSyncStartTime(Date syncStartTime) {
 132     // TODO Auto-generated method stub
 133
 134   }
 135
 136   @Override
 137   public Date getLastExecutionDate() {
 138     // TODO Auto-generated method stub
 139     return null;
 140   }
 141
 142   @Override
 143   public void setLastExecutionDate(Date lastExecutionDate) {
 144     // TODO Auto-generated method stub
 145
 146   }
 147
 148
 149   @Override
 150   public Calendar getCreationTime() {
 151     // TODO Auto-generated method stub
 152     return null;
 153   }
 154
 155   @Override
 156   public String getNextSyncTime() {
 157     // TODO Auto-generated method stub
 158     return null;
 159   }
 160
 161
 162   @Override
 163   public boolean isPeriodicSyncEnabled() {
 164     // TODO Auto-generated method stub
 165     return false;
 166   }
 167
 168
 169   @Override
 170   public boolean isRunOnceSyncEnabled() {
 171     // TODO Auto-generated method stub
 172     return false;
 173   }
 174
 175
 176
 177 }