Skip to content

Commit

Permalink
Improved naming and some clean up.
Browse files Browse the repository at this point in the history
  • Loading branch information
eebus committed Feb 15, 2017
1 parent e8cf5d1 commit d0a256c
Show file tree
Hide file tree
Showing 4 changed files with 3 additions and 10 deletions.
Expand Up @@ -21,7 +21,6 @@


import org.neo4j.kernel.api.KernelTransaction; import org.neo4j.kernel.api.KernelTransaction;
import org.neo4j.kernel.api.exceptions.ProcedureException; import org.neo4j.kernel.api.exceptions.ProcedureException;
import org.neo4j.kernel.api.security.AuthSubject;
import org.neo4j.kernel.api.security.SecurityContext; import org.neo4j.kernel.api.security.SecurityContext;


/** /**
Expand Down
Expand Up @@ -371,8 +371,6 @@ private Procedures setupProcedures( PlatformModule platform, EditionModule editi
Guard guard = platform.dependencies.resolveDependency( Guard.class ); Guard guard = platform.dependencies.resolveDependency( Guard.class );
procedures.registerComponent( TerminationGuard.class, new TerminationGuardProvider( guard ), true ); procedures.registerComponent( TerminationGuard.class, new TerminationGuardProvider( guard ), true );


// Register injected private API components: useful to have available in procedures to access the kernel etc.

// Below components are not public API, but are made available for internal // Below components are not public API, but are made available for internal
// procedures to call, and to provide temporary workarounds for the following // procedures to call, and to provide temporary workarounds for the following
// patterns: // patterns:
Expand Down
Expand Up @@ -182,7 +182,7 @@ public void shutdown()
} }


@Override @Override
public KernelTransaction beginTransaction( KernelTransaction.Type type, SecurityContext securityContext, long timeout ) public KernelTransaction beginTransaction( KernelTransaction.Type type, SecurityContext ignoredSecurityContext, long timeout )
{ {
try try
{ {
Expand Down
Expand Up @@ -37,12 +37,10 @@
import java.util.Map; import java.util.Map;
import java.util.concurrent.Executors; import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
import java.util.stream.Collectors; import java.util.stream.Collectors;
import java.util.stream.IntStream; import java.util.stream.IntStream;
import java.util.stream.Stream; import java.util.stream.Stream;


import org.neo4j.function.Predicates;
import org.neo4j.graphdb.GraphDatabaseService; import org.neo4j.graphdb.GraphDatabaseService;
import org.neo4j.graphdb.Label; import org.neo4j.graphdb.Label;
import org.neo4j.graphdb.Node; import org.neo4j.graphdb.Node;
Expand All @@ -53,7 +51,6 @@
import org.neo4j.graphdb.Result; import org.neo4j.graphdb.Result;
import org.neo4j.graphdb.Transaction; import org.neo4j.graphdb.Transaction;
import org.neo4j.graphdb.security.AuthorizationViolationException; import org.neo4j.graphdb.security.AuthorizationViolationException;
import org.neo4j.helpers.Exceptions;
import org.neo4j.helpers.collection.Iterators; import org.neo4j.helpers.collection.Iterators;
import org.neo4j.io.fs.FileUtils; import org.neo4j.io.fs.FileUtils;
import org.neo4j.kernel.api.KernelTransaction; import org.neo4j.kernel.api.KernelTransaction;
Expand All @@ -68,7 +65,6 @@


import static java.util.Collections.singletonList; import static java.util.Collections.singletonList;
import static org.hamcrest.MatcherAssert.assertThat; import static org.hamcrest.MatcherAssert.assertThat;
import static org.hamcrest.Matchers.instanceOf;
import static org.hamcrest.core.IsEqual.equalTo; import static org.hamcrest.core.IsEqual.equalTo;
import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertFalse; import static org.junit.Assert.assertFalse;
Expand Down Expand Up @@ -824,7 +820,7 @@ public void shouldBeAbleToSpawnThreadsCreatingTransactionInProcedures() throws T
{ {
// given // given
Runnable doIt = () -> { Runnable doIt = () -> {
Result result = db.execute( "CALL org.neo4j.procedure.unsupportedProcedure()" ); Result result = db.execute( "CALL org.neo4j.procedure.supportedProcedure()" );
while ( result.hasNext() ) while ( result.hasNext() )
{ {
result.next(); result.next();
Expand Down Expand Up @@ -1539,7 +1535,7 @@ public void delegatingSideEffect( @Name( "value" ) String value )
} }


@Procedure( mode = WRITE ) @Procedure( mode = WRITE )
public void unsupportedProcedure() public void supportedProcedure()
{ {
jobs.submit( () -> { jobs.submit( () -> {
try ( Transaction tx = db.beginTx() ) try ( Transaction tx = db.beginTx() )
Expand Down

0 comments on commit d0a256c

Please sign in to comment.