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 457293a renamed close to unregister in Result.Type enum.
457293a is described below
commit 457293a21ac270ae96e17dc7573ee372375d6232
Author: Marko A. Rodriguez <[email protected]>
AuthorDate: Tue Mar 26 17:46:45 2019 -0600
renamed close to unregister in Result.Type enum.
---
.../apache/tinkerpop/machine/species/remote/MachineServer.java | 2 +-
.../apache/tinkerpop/machine/species/remote/RemoteMachine.java | 8 ++++----
2 files changed, 5 insertions(+), 5 deletions(-)
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 28cf0bd..8931f40 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
@@ -103,7 +103,7 @@ public final class MachineServer implements AutoCloseable {
traverserOutput.writeObject(EmptyTraverser.instance()); // this tells a
TraverserServer that there are no more traversers
traverserOutput.flush();
}
- } else { // Request.Type.close == request.type
+ } else { // Request.Type.unregister == request.type
MachineServer.this.machine.unregister(request.bytecode);
}
}
diff --git
a/java/machine/machine-core/src/main/java/org/apache/tinkerpop/machine/species/remote/RemoteMachine.java
b/java/machine/machine-core/src/main/java/org/apache/tinkerpop/machine/species/remote/RemoteMachine.java
index a15d3b5..3eb5b89 100644
---
a/java/machine/machine-core/src/main/java/org/apache/tinkerpop/machine/species/remote/RemoteMachine.java
+++
b/java/machine/machine-core/src/main/java/org/apache/tinkerpop/machine/species/remote/RemoteMachine.java
@@ -80,7 +80,7 @@ public final class RemoteMachine implements Machine,
AutoCloseable {
@Override
public <C> void unregister(final Bytecode<C> sourceCode) {
try {
- this.outputStream.writeObject(Request.close(sourceCode));
+ this.outputStream.writeObject(Request.unregister(sourceCode));
this.outputStream.flush();
} catch (final IOException e) {
throw new RuntimeException(e.getMessage(), e);
@@ -108,7 +108,7 @@ public final class RemoteMachine implements Machine,
AutoCloseable {
static final class Request<C> implements Serializable {
public enum Type {
- register, submit, close;
+ register, submit, unregister;
}
public final Type type;
@@ -131,8 +131,8 @@ public final class RemoteMachine implements Machine,
AutoCloseable {
return new Request<>(Request.Type.submit, bytecode,
traverserServerLocation, traverserServerPort);
}
- static <C> Request<C> close(final Bytecode<C> bytecode) {
- return new Request<>(Request.Type.close, bytecode, null, -1);
+ static <C> Request<C> unregister(final Bytecode<C> bytecode) {
+ return new Request<>(Request.Type.unregister, bytecode, null, -1);
}
}
}