This is an automated email from the ASF dual-hosted git repository.

okram pushed a commit to branch tp4
in repository https://gitbox.apache.org/repos/asf/tinkerpop.git


The following commit(s) were added to refs/heads/tp4 by this push:
     new a9dde82  more random cleanups. taking a break to do some yardwork. its 
sunny out.
a9dde82 is described below

commit a9dde82afe8ee5107b0a880db572712eec949db2
Author: Marko A. Rodriguez <[email protected]>
AuthorDate: Tue Mar 26 14:44:29 2019 -0600

    more random cleanups. taking a break to do some yardwork. its sunny out.
---
 .../apache/tinkerpop/machine/species/LocalMachine.java   |  2 +-
 .../tinkerpop/machine/species/remote/MachineServer.java  | 16 +++++++++-------
 .../machine/species/remote/TraverserServer.java          |  2 --
 3 files changed, 10 insertions(+), 10 deletions(-)

diff --git 
a/java/machine/machine-core/src/main/java/org/apache/tinkerpop/machine/species/LocalMachine.java
 
b/java/machine/machine-core/src/main/java/org/apache/tinkerpop/machine/species/LocalMachine.java
index b29298a..79b958d 100644
--- 
a/java/machine/machine-core/src/main/java/org/apache/tinkerpop/machine/species/LocalMachine.java
+++ 
b/java/machine/machine-core/src/main/java/org/apache/tinkerpop/machine/species/LocalMachine.java
@@ -84,7 +84,7 @@ public final class LocalMachine implements Machine {
         return new LocalMachine();
     }
 
-    private static final <C> Optional<UUID> getSourceId(final Bytecode<C> 
bytecode) {
+    private static <C> Optional<UUID> getSourceId(final Bytecode<C> bytecode) {
         for (final SourceInstruction sourceInstruction : 
bytecode.getSourceInstructions()) {
             if (sourceInstruction.op().equals(WITH_SOURCE_CODE))
                 return Optional.of(UUID.fromString((String) 
sourceInstruction.args()[0]));
diff --git 
a/java/machine/machine-core/src/main/java/org/apache/tinkerpop/machine/species/remote/MachineServer.java
 
b/java/machine/machine-core/src/main/java/org/apache/tinkerpop/machine/species/remote/MachineServer.java
index 8c01808..18acf8e 100644
--- 
a/java/machine/machine-core/src/main/java/org/apache/tinkerpop/machine/species/remote/MachineServer.java
+++ 
b/java/machine/machine-core/src/main/java/org/apache/tinkerpop/machine/species/remote/MachineServer.java
@@ -66,13 +66,15 @@ public final class MachineServer implements AutoCloseable {
         return this.serverAlive.get();
     }
 
-    public synchronized void close() {
-        try {
-            this.serverAlive.set(Boolean.FALSE);
-            this.machineServerSocket.close();
-            this.machine.close();
-        } catch (final IOException e) {
-            throw new RuntimeException(e.getMessage(), e);
+    public void close() {
+        if (this.serverAlive.get()) {
+            try {
+                this.serverAlive.set(Boolean.FALSE);
+                this.machineServerSocket.close();
+                this.machine.close();
+            } catch (final IOException e) {
+                throw new RuntimeException(e.getMessage(), e);
+            }
         }
     }
 
diff --git 
a/java/machine/machine-core/src/main/java/org/apache/tinkerpop/machine/species/remote/TraverserServer.java
 
b/java/machine/machine-core/src/main/java/org/apache/tinkerpop/machine/species/remote/TraverserServer.java
index 9c45994..c8c4c14 100644
--- 
a/java/machine/machine-core/src/main/java/org/apache/tinkerpop/machine/species/remote/TraverserServer.java
+++ 
b/java/machine/machine-core/src/main/java/org/apache/tinkerpop/machine/species/remote/TraverserServer.java
@@ -115,6 +115,4 @@ public final class TraverserServer<C, S> implements 
AutoCloseable, Iterator<Trav
             }
         }
     }
-
-
 }

Reply via email to