honeymoose/OpenSearch
1
0
Fork 0
mirror of https://github.com/honeymoose/OpenSearch.git synced 2025-02-17 10:25:15 +00:00
Code Issues Packages Projects Releases Wiki Activity

Internal: Fix serialization of PendingClusterTask.timeInQueue.

Browse Source 
This parameter is serialized as a vLong while it could sometimes be negative.

Close #8077
This commit is contained in:
Adrien Grand 2014-10-14 12:15:29 +02:00
parent 66cd3ad17e
commit cd8e02351b
1 changed files with 11 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/main/java/org/elasticsearch/cluster/service/PendingClusterTask.java
View File

@ -79,7 +79,11 @@ public class PendingClusterTask implements Streamable {
insertOrder = in.readVLong();
priority = Priority.readFrom(in);
source = in.readText();
timeInQueue = in.readVLong();
if (in.getVersion().onOrAfter(Version.V_1_4_0)) {
timeInQueue = in.readLong();
} else {
timeInQueue = in.readVLong();
}
if (in.getVersion().onOrAfter(Version.V_1_3_0)) {
executing = in.readBoolean();
}
@ -90,7 +94,12 @@ public class PendingClusterTask implements Streamable {
out.writeVLong(insertOrder);
Priority.writeTo(priority, out);
out.writeText(source);
out.writeVLong(timeInQueue);
if (out.getVersion().onOrAfter(Version.V_1_4_0)) {
// timeInQueue is set to -1 when unknown and can be negative if time goes backwards
out.writeLong(timeInQueue);
} else {
out.writeVLong(timeInQueue);
}
if (out.getVersion().onOrAfter(Version.V_1_3_0)) {
out.writeBoolean(executing);
}