This is an automated email from the ASF dual-hosted git repository.
marcuse pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/cassandra.git
The following commit(s) were added to refs/heads/trunk by this push:
new 3f74990 Fix in-jvm dtest message serialization
3f74990 is described below
commit 3f749907f9f6845078aacb25c38a79e9a6fb8bed
Author: Marcus Eriksson <[email protected]>
AuthorDate: Tue Jan 21 08:58:18 2020 +0100
Fix in-jvm dtest message serialization
Patch by marcuse; reviewed by Alex Petrov for CASSANDRA-15515
---
test/distributed/org/apache/cassandra/distributed/impl/Instance.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
diff --git
a/test/distributed/org/apache/cassandra/distributed/impl/Instance.java
b/test/distributed/org/apache/cassandra/distributed/impl/Instance.java
index f39783d..03cc9b9 100644
--- a/test/distributed/org/apache/cassandra/distributed/impl/Instance.java
+++ b/test/distributed/org/apache/cassandra/distributed/impl/Instance.java
@@ -231,10 +231,11 @@ public class Instance extends IsolatedExecutor implements
IInvokableInstance
{
try (DataOutputBuffer out = new DataOutputBuffer(1024))
{
+ int version = MessagingService.instance().versions.get(to);
InetAddressAndPort from = broadcastAddressAndPort();
Tracing.instance.traceOutgoingMessage(messageOut, to);
- Message.serializer.serialize(messageOut, out,
MessagingService.current_version);
- deliver.accept(to, new MessageImpl(messageOut.verb().id,
out.toByteArray(), messageOut.id(), MessagingService.current_version, from));
+ Message.serializer.serialize(messageOut, out, version);
+ deliver.accept(to, new MessageImpl(messageOut.verb().id,
out.toByteArray(), messageOut.id(), version, from));
}
catch (IOException e)
{
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
