Toggle navigation
Home
boolean to java.util.concurrent.atomic.AtomicBoolean
No. of Instances - 3
No. of Commits - 3
No. of Projects - {'ignite'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Jdk -> Jdk
Mapping:
Update Class Instacne Creation
new OSessionStoragePerformanceStatistic(intervalBetweenSnapshots,enabled ? cleanUpInterval : -1)
to
new OSessionStoragePerformanceStatistic(intervalBetweenSnapshots,enabled.get() ? cleanUpInterval : -1)
new Thread(new Runnable(){ @Override public void run(){ try { executeWhen(new Callable<Boolean>(){ @Override public Boolean call() throws Exception { return server3inDeadlock; } } ,new Callable(){ @Override public Object call() throws Exception { banner("STARTING BACKUP SERVER " + (2)); ODatabaseDocumentTx g=new ODatabaseDocumentTx("plocal:target/server2/databases/" + getDatabaseName()); if (g.exists()) { g.open("admin","admin"); } else { g.create(); } backupInProgress=true; File file=null; try { file=File.createTempFile("orientdb_test_backup",".zip"); if (file.exists()) Assert.assertTrue(file.delete()); g.backup(new FileOutputStream(file),null,new Callable<Object>(){ @Override public Object call() throws Exception { while (server3inDeadlock) { Thread.sleep(1000); } return null; } } ,null,9,1000000); } catch ( IOException e) { e.printStackTrace(); } finally { banner("COMPLETED BACKUP SERVER " + (2)); backupInProgress=false; g.close(); if (file != null) file.delete(); } return null; } } ); } catch ( Exception e) { e.printStackTrace(); fail("Error on execution flow"); } } } )
to
new Thread(new Runnable(){ @Override public void run(){ try { executeWhen(new Callable<Boolean>(){ @Override public Boolean call() throws Exception { return server3inDeadlock.get(); } } ,new Callable(){ @Override public Object call() throws Exception { banner("STARTING BACKUP SERVER " + (2)); ODatabaseDocumentTx g=new ODatabaseDocumentTx("plocal:target/server2/databases/" + getDatabaseName()); if (g.exists()) { g.open("admin","admin"); } else { g.create(); } backupInProgress=true; File file=null; try { file=File.createTempFile("orientdb_test_backup",".zip"); if (file.exists()) Assert.assertTrue(file.delete()); g.backup(new FileOutputStream(file),null,new Callable<Object>(){ @Override public Object call() throws Exception { while (server3inDeadlock.get()) { Thread.sleep(1000); } return null; } } ,null,9,1000000); } catch ( IOException e) { e.printStackTrace(); } finally { banner("COMPLETED BACKUP SERVER " + (2)); backupInProgress=false; g.close(); if (file != null) file.delete(); } return null; } } ); } catch ( Exception e) { e.printStackTrace(); fail("Error on execution flow"); } } } )
Add or Remove Method invocation
exceptionOccurred
to
exceptionOccurred.get()
notifyEnabled
to
notifyEnabled.get()
Update argument list (Method invocation)
getConnection
to
getConnection
Other
IgniteSystemProperties.getBoolean(IGNITE_UPDATE_NOTIFIER,Boolean.parseBoolean(IgniteProperties.get("ignite.update.notifier.enabled.by.default")))
to
IgniteSystemProperties.getBoolean(IGNITE_UPDATE_NOTIFIER,Boolean.parseBoolean(IgniteProperties.get("ignite.update.notifier.enabled.by.default")))
Rename Variable
sndStoppedEvnt
to
stoppedEvtSent