You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@ratis.apache.org by "Tsz Wo Nicholas Sze (JIRA)" <ji...@apache.org> on 2017/11/09 22:59:00 UTC
[jira] [Commented] (RATIS-140) Server may see out-of-order gRPC
messages sent from the same client
[ https://issues.apache.org/jira/browse/RATIS-140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16246725#comment-16246725 ]
Tsz Wo Nicholas Sze commented on RATIS-140:
-------------------------------------------
We changed testBasicAppendEntries() in RATIS-113. Below is the log.
{code}
2017-11-09 14:54:23,238 DEBUG client.RaftClient (RaftClientImpl.java:sendRequestAsync(187)) - client-715601A0-E641-4574-AA74-635D4CF920A9: sendAsync RaftClientRequest(client-715601A0-E641-4574-AA74-635D4CF920A9->s0) in group-8D63500B-5922-474B-BB6A-954D02D2F0D3, callId: 0, RW, m0
2017-11-09 14:54:23,253 INFO client.GrpcClientRpc (GrpcClientRpc.java:sendRequestAsync(99)) - sendRequestAsync m0
2017-11-09 14:54:23,332 DEBUG client.RaftClient (RaftClientImpl.java:sendRequestAsync(187)) - client-715601A0-E641-4574-AA74-635D4CF920A9: sendAsync RaftClientRequest(client-715601A0-E641-4574-AA74-635D4CF920A9->s0) in group-8D63500B-5922-474B-BB6A-954D02D2F0D3, callId: 1, RW, m1
2017-11-09 14:54:23,332 INFO client.GrpcClientRpc (GrpcClientRpc.java:sendRequestAsync(99)) - sendRequestAsync m1
2017-11-09 14:54:23,332 DEBUG client.RaftClient (RaftClientImpl.java:sendRequestAsync(187)) - client-715601A0-E641-4574-AA74-635D4CF920A9: sendAsync RaftClientRequest(client-715601A0-E641-4574-AA74-635D4CF920A9->s0) in group-8D63500B-5922-474B-BB6A-954D02D2F0D3, callId: 2, RW, m2
2017-11-09 14:54:23,332 INFO client.GrpcClientRpc (GrpcClientRpc.java:sendRequestAsync(99)) - sendRequestAsync m2
2017-11-09 14:54:23,332 DEBUG client.RaftClient (RaftClientImpl.java:sendRequestAsync(187)) - client-715601A0-E641-4574-AA74-635D4CF920A9: sendAsync RaftClientRequest(client-715601A0-E641-4574-AA74-635D4CF920A9->s0) in group-8D63500B-5922-474B-BB6A-954D02D2F0D3, callId: 3, RW, m3
2017-11-09 14:54:23,333 INFO client.GrpcClientRpc (GrpcClientRpc.java:sendRequestAsync(99)) - sendRequestAsync m3
2017-11-09 14:54:23,333 DEBUG client.RaftClient (RaftClientImpl.java:sendRequestAsync(187)) - client-715601A0-E641-4574-AA74-635D4CF920A9: sendAsync RaftClientRequest(client-715601A0-E641-4574-AA74-635D4CF920A9->s0) in group-8D63500B-5922-474B-BB6A-954D02D2F0D3, callId: 4, RW, m4
2017-11-09 14:54:23,333 INFO client.GrpcClientRpc (GrpcClientRpc.java:sendRequestAsync(99)) - sendRequestAsync m4
2017-11-09 14:54:23,333 DEBUG client.RaftClient (RaftClientImpl.java:sendRequestAsync(187)) - client-715601A0-E641-4574-AA74-635D4CF920A9: sendAsync RaftClientRequest(client-715601A0-E641-4574-AA74-635D4CF920A9->s0) in group-8D63500B-5922-474B-BB6A-954D02D2F0D3, callId: 5, RW, m5
2017-11-09 14:54:23,334 INFO client.GrpcClientRpc (GrpcClientRpc.java:sendRequestAsync(99)) - sendRequestAsync m5
2017-11-09 14:54:23,334 DEBUG client.RaftClient (RaftClientImpl.java:sendRequestAsync(187)) - client-715601A0-E641-4574-AA74-635D4CF920A9: sendAsync RaftClientRequest(client-715601A0-E641-4574-AA74-635D4CF920A9->s0) in group-8D63500B-5922-474B-BB6A-954D02D2F0D3, callId: 6, RW, m6
2017-11-09 14:54:23,334 INFO client.GrpcClientRpc (GrpcClientRpc.java:sendRequestAsync(99)) - sendRequestAsync m6
2017-11-09 14:54:23,334 DEBUG client.RaftClient (RaftClientImpl.java:sendRequestAsync(187)) - client-715601A0-E641-4574-AA74-635D4CF920A9: sendAsync RaftClientRequest(client-715601A0-E641-4574-AA74-635D4CF920A9->s0) in group-8D63500B-5922-474B-BB6A-954D02D2F0D3, callId: 7, RW, m7
2017-11-09 14:54:23,335 INFO client.GrpcClientRpc (GrpcClientRpc.java:sendRequestAsync(99)) - sendRequestAsync m7
2017-11-09 14:54:23,335 DEBUG client.RaftClient (RaftClientImpl.java:sendRequestAsync(187)) - client-715601A0-E641-4574-AA74-635D4CF920A9: sendAsync RaftClientRequest(client-715601A0-E641-4574-AA74-635D4CF920A9->s0) in group-8D63500B-5922-474B-BB6A-954D02D2F0D3, callId: 8, RW, m8
2017-11-09 14:54:23,335 INFO client.GrpcClientRpc (GrpcClientRpc.java:sendRequestAsync(99)) - sendRequestAsync m8
2017-11-09 14:54:23,336 DEBUG client.RaftClient (RaftClientImpl.java:sendRequestAsync(187)) - client-715601A0-E641-4574-AA74-635D4CF920A9: sendAsync RaftClientRequest(client-715601A0-E641-4574-AA74-635D4CF920A9->s0) in group-8D63500B-5922-474B-BB6A-954D02D2F0D3, callId: 9, RW, m9
2017-11-09 14:54:23,336 INFO client.GrpcClientRpc (GrpcClientRpc.java:sendRequestAsync(99)) - sendRequestAsync m9
2017-11-09 14:54:23,344 INFO client.RaftClientProtocolService (RaftClientProtocolService.java:onNext(107)) - s0: callId=1, request=m1
2017-11-09 14:54:23,344 INFO client.RaftClientProtocolService (RaftClientProtocolService.java:onNext(107)) - s0: callId=8, request=m8
2017-11-09 14:54:23,344 INFO client.RaftClientProtocolService (RaftClientProtocolService.java:onNext(107)) - s0: callId=9, request=m9
2017-11-09 14:54:23,344 INFO client.RaftClientProtocolService (RaftClientProtocolService.java:onNext(112)) - s0: callId=1, add m1
2017-11-09 14:54:23,344 INFO client.RaftClientProtocolService (RaftClientProtocolService.java:onNext(107)) - s0: callId=3, request=m3
2017-11-09 14:54:23,344 INFO client.RaftClientProtocolService (RaftClientProtocolService.java:onNext(107)) - s0: callId=2, request=m2
2017-11-09 14:54:23,344 INFO client.RaftClientProtocolService (RaftClientProtocolService.java:onNext(107)) - s0: callId=5, request=m5
2017-11-09 14:54:23,344 INFO client.RaftClientProtocolService (RaftClientProtocolService.java:onNext(107)) - s0: callId=6, request=m6
2017-11-09 14:54:23,344 INFO client.RaftClientProtocolService (RaftClientProtocolService.java:onNext(107)) - s0: callId=7, request=m7
2017-11-09 14:54:23,344 INFO client.RaftClientProtocolService (RaftClientProtocolService.java:onNext(107)) - s0: callId=4, request=m4
2017-11-09 14:54:23,344 INFO client.RaftClientProtocolService (RaftClientProtocolService.java:onNext(107)) - s0: callId=0, request=m0
2017-11-09 14:54:23,345 INFO client.RaftClientProtocolService (RaftClientProtocolService.java:onNext(112)) - s0: callId=4, add m4
2017-11-09 14:54:23,345 INFO client.RaftClientProtocolService (RaftClientProtocolService.java:onNext(112)) - s0: callId=7, add m7
2017-11-09 14:54:23,344 INFO client.RaftClientProtocolService (RaftClientProtocolService.java:onNext(112)) - s0: callId=6, add m6
2017-11-09 14:54:23,344 INFO client.RaftClientProtocolService (RaftClientProtocolService.java:onNext(112)) - s0: callId=5, add m5
2017-11-09 14:54:23,344 INFO client.RaftClientProtocolService (RaftClientProtocolService.java:onNext(112)) - s0: callId=2, add m2
2017-11-09 14:54:23,344 INFO client.RaftClientProtocolService (RaftClientProtocolService.java:onNext(112)) - s0: callId=3, add m3
2017-11-09 14:54:23,344 INFO client.RaftClientProtocolService (RaftClientProtocolService.java:onNext(112)) - s0: callId=9, add m9
2017-11-09 14:54:23,344 INFO client.RaftClientProtocolService (RaftClientProtocolService.java:onNext(112)) - s0: callId=8, add m8
2017-11-09 14:54:23,345 DEBUG impl.RaftServerImpl (RaftServerImpl.java:submitClientRequestAsync(446)) - s0: receive client request(m9)
2017-11-09 14:54:23,345 DEBUG impl.RaftServerImpl (RaftServerImpl.java:submitClientRequestAsync(446)) - s0: receive client request(m3)
2017-11-09 14:54:23,345 DEBUG impl.RaftServerImpl (RaftServerImpl.java:submitClientRequestAsync(446)) - s0: receive client request(m2)
2017-11-09 14:54:23,345 DEBUG impl.RaftServerImpl (RaftServerImpl.java:submitClientRequestAsync(446)) - s0: receive client request(m5)
2017-11-09 14:54:23,345 DEBUG impl.RaftServerImpl (RaftServerImpl.java:submitClientRequestAsync(446)) - s0: receive client request(m6)
2017-11-09 14:54:23,345 DEBUG impl.RaftServerImpl (RaftServerImpl.java:submitClientRequestAsync(446)) - s0: receive client request(m7)
2017-11-09 14:54:23,345 DEBUG impl.RaftServerImpl (RaftServerImpl.java:submitClientRequestAsync(446)) - s0: receive client request(m1)
2017-11-09 14:54:23,345 DEBUG impl.RaftServerImpl (RaftServerImpl.java:submitClientRequestAsync(446)) - s0: receive client request(m4)
2017-11-09 14:54:23,345 INFO client.RaftClientProtocolService (RaftClientProtocolService.java:onNext(112)) - s0: callId=0, add m0
2017-11-09 14:54:23,345 DEBUG impl.RaftServerImpl (RaftServerImpl.java:submitClientRequestAsync(446)) - s0: receive client request(m8)
2017-11-09 14:54:23,346 DEBUG impl.RaftServerImpl (RaftServerImpl.java:submitClientRequestAsync(446)) - s0: receive client request(m0)
{code}
> Server may see out-of-order gRPC messages sent from the same client
> -------------------------------------------------------------------
>
> Key: RATIS-140
> URL: https://issues.apache.org/jira/browse/RATIS-140
> Project: Ratis
> Issue Type: Bug
> Reporter: Tsz Wo Nicholas Sze
> Assignee: Tsz Wo Nicholas Sze
>
> Async client is being added in RATIS-113. However, we found that the server side (RaftClientProtocolService) may see out-of-order grpc messages even if all messages are sent by the same client.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)