You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@marmotta.apache.org by ss...@apache.org on 2016/11/19 12:44:22 UTC
marmotta git commit: Ostrich Client: minor fix to conform to new gRPC
API
Repository: marmotta
Updated Branches:
refs/heads/develop 7275a000e -> 8c130aef7
Ostrich Client: minor fix to conform to new gRPC API
Project: http://git-wip-us.apache.org/repos/asf/marmotta/repo
Commit: http://git-wip-us.apache.org/repos/asf/marmotta/commit/8c130aef
Tree: http://git-wip-us.apache.org/repos/asf/marmotta/tree/8c130aef
Diff: http://git-wip-us.apache.org/repos/asf/marmotta/diff/8c130aef
Branch: refs/heads/develop
Commit: 8c130aef76136b1a8329ccbedf097fbc0581de71
Parents: 7275a00
Author: Sebastian Schaffert <ss...@apache.org>
Authored: Sat Nov 19 13:44:10 2016 +0100
Committer: Sebastian Schaffert <ss...@apache.org>
Committed: Sat Nov 19 13:44:10 2016 +0100
----------------------------------------------------------------------
.../org/apache/marmotta/ostrich/sail/ClosableResponseStream.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/marmotta/blob/8c130aef/libraries/ostrich/client/src/main/java/org/apache/marmotta/ostrich/sail/ClosableResponseStream.java
----------------------------------------------------------------------
diff --git a/libraries/ostrich/client/src/main/java/org/apache/marmotta/ostrich/sail/ClosableResponseStream.java b/libraries/ostrich/client/src/main/java/org/apache/marmotta/ostrich/sail/ClosableResponseStream.java
index 35d8ada..e9ec41e 100644
--- a/libraries/ostrich/client/src/main/java/org/apache/marmotta/ostrich/sail/ClosableResponseStream.java
+++ b/libraries/ostrich/client/src/main/java/org/apache/marmotta/ostrich/sail/ClosableResponseStream.java
@@ -57,7 +57,7 @@ public class ClosableResponseStream<Svc extends AbstractStub<Svc>, ReqT, T> impl
call.sendMessage(req);
call.halfClose();
} catch (Throwable t) {
- call.cancel();
+ call.cancel("Error", t);
throw new SailException(t);
}
}
@@ -72,7 +72,7 @@ public class ClosableResponseStream<Svc extends AbstractStub<Svc>, ReqT, T> impl
*/
@Override
public void close() throws SailException {
- call.cancel();
+ call.cancel("Closed by client", null);
}
/**