Skip to content

Commit

Permalink
Post merge checkstyle and 3.2 adaptations
Browse files Browse the repository at this point in the history
  • Loading branch information
MishaDemianenko committed Aug 13, 2017
1 parent 31c7877 commit f58668e
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 3 deletions.
Expand Up @@ -257,7 +257,7 @@ public class GraphDatabaseSettings implements LoadableConfig


@Description("Configures the time interval between transaction monitor checks. Determines how often " + @Description("Configures the time interval between transaction monitor checks. Determines how often " +
"monitor thread will check transaction for timeout.") "monitor thread will check transaction for timeout.")
public static final Setting<Long> transaction_monitor_check_interval = setting( "dbms.transaction.monitor.check.interval", DURATION, "5s" ); public static final Setting<Duration> transaction_monitor_check_interval = setting( "dbms.transaction.monitor.check.interval", DURATION, "5s" );


@Description( "The maximum amount of time to wait for running transactions to complete before allowing " @Description( "The maximum amount of time to wait for running transactions to complete before allowing "
+ "initiated database shutdown to continue" ) + "initiated database shutdown to continue" )
Expand Down
Expand Up @@ -755,7 +755,7 @@ private void buildTransactionMonitor( KernelTransactions kernelTransactions, Clo
new KernelTransactionTimeoutMonitor( kernelTransactions, clock, logService ); new KernelTransactionTimeoutMonitor( kernelTransactions, clock, logService );
KernelTransactionMonitorScheduler transactionMonitorScheduler = KernelTransactionMonitorScheduler transactionMonitorScheduler =
new KernelTransactionMonitorScheduler( kernelTransactionTimeoutMonitor, scheduler, new KernelTransactionMonitorScheduler( kernelTransactionTimeoutMonitor, scheduler,
config.get( GraphDatabaseSettings.transaction_monitor_check_interval ) ); config.get( GraphDatabaseSettings.transaction_monitor_check_interval ).toMillis() );
life.add( transactionMonitorScheduler ); life.add( transactionMonitorScheduler );
} }


Expand Down
Expand Up @@ -82,7 +82,8 @@ public void terminateExpiredTransaction() throws Exception


private Runnable startAnotherTransaction() private Runnable startAnotherTransaction()
{ {
return () -> { return () ->
{
try ( InternalTransaction transaction = database try ( InternalTransaction transaction = database
.beginTransaction( KernelTransaction.Type.implicit, SecurityContext.AUTH_DISABLED, 1, .beginTransaction( KernelTransaction.Type.implicit, SecurityContext.AUTH_DISABLED, 1,
TimeUnit.SECONDS ) ) TimeUnit.SECONDS ) )
Expand Down

0 comments on commit f58668e

Please sign in to comment.