You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@ratis.apache.org by "kaiyangzhang (JIRA)" <ji...@apache.org> on 2017/04/21 09:34:04 UTC
[jira] [Updated] (RATIS-77) "RaftServerProtocolService" and "
GRpc.proto" inconsistent
[ https://issues.apache.org/jira/browse/RATIS-77?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
kaiyangzhang updated RATIS-77:
------------------------------
Summary: "RaftServerProtocolService" and " GRpc.proto" inconsistent (was: "RaftServerProtocolService" and " GRpc.proto" not inconsistent)
> "RaftServerProtocolService" and " GRpc.proto" inconsistent
> ----------------------------------------------------------
>
> Key: RATIS-77
> URL: https://issues.apache.org/jira/browse/RATIS-77
> Project: Ratis
> Issue Type: Bug
> Reporter: kaiyangzhang
> Assignee: Jing Zhao
>
> *Maybe a bug, look at the comments in the code and GRpc.proto*
> {code:title=GRpc.proto|borderStyle=solid}
> ......
> ......
> //Executes a client-streaming call , return only one response.
> rpc installSnapshot(stream ratis.common.InstallSnapshotRequestProto)
> returns(ratis.common.InstallSnapshotReplyProto) {}
> .......
> .......
> {code}
> {code:title=RaftServerProtocolService.java |borderStyle=solid}
> ........
> ........
> @Override
> public StreamObserver<InstallSnapshotRequestProto> installSnapshot(
> StreamObserver<InstallSnapshotReplyProto> responseObserver) {
> return new StreamObserver<InstallSnapshotRequestProto>() {
> @Override
> public void onNext(InstallSnapshotRequestProto request) {
> try {
> //receive a client-streaming call, return a response stream
> //code and GRpc.proto inconsistent
> final InstallSnapshotReplyProto reply = server.installSnapshot(request);
> responseObserver.onNext(reply);
> } catch (Throwable e) {
> LOG.info("{} got exception when handling installSnapshot {}: {}",
> id, request.getServerRequest(), e);
> responseObserver.onError(RaftGrpcUtil.wrapException(e));
> }
> }
> ..........
> ..........
> {code}
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)