Properly handle protocol-version-based ser-des for SSI

This commit is contained in:
Bharadwaj V.R 2022-03-24 07:48:17 -07:00
parent faff94ed2b
commit abce71c146
1 changed files with 7 additions and 4 deletions

View File

@ -110,9 +110,13 @@ struct StorageServerInterface {
if (ar.protocolVersion().hasSmallEndpoints()) {
if (ar.protocolVersion().hasTSS()) {
serializer(ar, uniqueID, locality, getValue, tssPairID, acceptingRequests);
if (ar.protocolVersion().hasStorageInterfaceReadiness()) {
serializer(ar, uniqueID, locality, getValue, tssPairID, acceptingRequests);
} else {
serializer(ar, uniqueID, locality, getValue, tssPairID);
}
} else {
serializer(ar, uniqueID, locality, getValue, acceptingRequests);
serializer(ar, uniqueID, locality, getValue);
}
if (Ar::isDeserializing) {
getKey = RequestStream<struct GetKeyRequest>(getValue.getEndpoint().getAdjustedEndpoint(1));
@ -166,8 +170,7 @@ struct StorageServerInterface {
getStorageMetrics,
waitFailure,
getQueuingMetrics,
getKeyValueStoreType,
acceptingRequests);
getKeyValueStoreType);
if (ar.protocolVersion().hasWatches()) {
serializer(ar, watchValue);
}