Skip to content

Commit

Permalink
Merge 3.3 into 3.4
Browse files Browse the repository at this point in the history
  • Loading branch information
MishaDemianenko committed Sep 25, 2017
2 parents 3550399 + 92bcd9b commit b303bf8
Showing 1 changed file with 16 additions and 8 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -40,8 +40,10 @@ public Lock exclusiveLock( Supplier<Statement> stmtSupplier, PropertyContainer c
{
if ( container instanceof Node )
{
statement.readOperations().acquireExclusive( ResourceTypes.NODE, ((Node) container).getId() );
return new CoreAPILock( stmtSupplier, ResourceTypes.NODE, ((Node) container).getId() )
long id = ((Node) container).getId();
ResourceTypes resourceType = ResourceTypes.NODE;
statement.readOperations().acquireExclusive( resourceType, id );
return new CoreAPILock( stmtSupplier, resourceType, id )
{
@Override
void release( Statement statement, ResourceType type, long resourceId )
Expand All @@ -52,8 +54,10 @@ void release( Statement statement, ResourceType type, long resourceId )
}
else if ( container instanceof Relationship )
{
statement.readOperations().acquireExclusive( ResourceTypes.RELATIONSHIP, ((Relationship) container).getId() );
return new CoreAPILock( stmtSupplier, ResourceTypes.RELATIONSHIP, ((Relationship) container).getId() )
long id = ((Relationship) container).getId();
ResourceTypes resourceType = ResourceTypes.RELATIONSHIP;
statement.readOperations().acquireExclusive( resourceType, id );
return new CoreAPILock( stmtSupplier, resourceType, id )
{
@Override
void release( Statement statement, ResourceType type, long resourceId )
Expand Down Expand Up @@ -105,8 +109,10 @@ public Lock sharedLock( Supplier<Statement> stmtProvider, PropertyContainer cont
{
if ( container instanceof Node )
{
statement.readOperations().acquireShared( ResourceTypes.NODE, ((Node) container).getId() );
return new CoreAPILock( stmtProvider, ResourceTypes.NODE, ((Node) container).getId() )
long id = ((Node) container).getId();
ResourceTypes resourceType = ResourceTypes.NODE;
statement.readOperations().acquireShared( resourceType, id );
return new CoreAPILock( stmtProvider, resourceType, id )
{
@Override
void release( Statement statement, ResourceType type, long resourceId )
Expand All @@ -117,8 +123,10 @@ void release( Statement statement, ResourceType type, long resourceId )
}
else if ( container instanceof Relationship )
{
statement.readOperations().acquireShared( ResourceTypes.RELATIONSHIP, ((Relationship) container).getId() );
return new CoreAPILock( stmtProvider, ResourceTypes.RELATIONSHIP, ((Relationship) container).getId() )
long id = ((Relationship) container).getId();
ResourceTypes resourceType = ResourceTypes.RELATIONSHIP;
statement.readOperations().acquireShared( resourceType, id );
return new CoreAPILock( stmtProvider, resourceType, id )
{
@Override
void release( Statement statement, ResourceType type, long resourceId )
Expand Down

0 comments on commit b303bf8

Please sign in to comment.