Toggle navigation
Home
boolean to java.util.concurrent.atomic.AtomicBoolean
No. of Instances - 46
No. of Commits - 45
No. of Projects - {'JGroups', 'Lealone', 'cryptomator', 'hadoop', 'speedment', 'pulsar', 'spark', 'redisson', 'camel', 'jersey', 'pentaho-kettle', 'nd4j', 'alluxio', 'datumbox-framework', 'jgit', 'hbase', 'ignite', 'spring-cloud-netflix', 'atomix', 'infinispan', 'vert.x', 'orientdb', 'HikariCP', 'neo4j', 'flink', 'hibernate-orm'}
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