serverscanning/capnproto-java-rpc
16
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

oops, ensure bootstrap uses the questionRef promise

Browse source
This commit is contained in:
Vaci Koblizek 2020-11-17 14:17:56 +00:00
parent 9f13f29bf6
commit 224bc3a3ad
1 changed files with 2 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
runtime-rpc/src/main/java/org/capnproto/RpcState.java
View file

@ -376,8 +376,7 @@ final class RpcState<VatId> {
var question = questions.next(); var question = questions.next();
question.isAwaitingReturn = true; question.isAwaitingReturn = true;
var questionRef = question.selfRef; var questionRef = question.selfRef;
var promise = new CompletableFuture<RpcResponse>(); var pipeline = new RpcPipeline(questionRef, questionRef.response);
var pipeline = new RpcPipeline(questionRef, promise);
int sizeHint = messageSizeHint(RpcProtocol.Bootstrap.factory); int sizeHint = messageSizeHint(RpcProtocol.Bootstrap.factory);
var message = connection.newOutgoingMessage(sizeHint); var message = connection.newOutgoingMessage(sizeHint);
@ -507,7 +506,7 @@ final class RpcState<VatId> {
return; return;
} }
final var answerId = bootstrap.getQuestionId(); var answerId = bootstrap.getQuestionId();
var answer = answers.put(answerId); var answer = answers.put(answerId);
if (answer.active) { if (answer.active) {
assert false: "bootstrap questionId is already in use: " + answerId; assert false: "bootstrap questionId is already in use: " + answerId;