wbtiger
/
foundationdb
mirror of https://github.com/apple/foundationdb.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

another attempt at changing serialization

This commit is contained in:
Evan Tschannen 2020-05-19 16:28:01 -07:00
parent 7dd226d264
commit ead17d6a7f
1 changed files with 1 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
fdbclient/StorageServerInterface.h
View File

@ -85,25 +85,7 @@ struct StorageServerInterface {
// versioned carefully!
if (ar.protocolVersion().hasSmallEndpoints()) {
serializer(ar, uniqueID, locality, getValue);
if( Ar::isDeserializing ) {
NetworkAddressList addresses = getValue.getEndpoint().addresses;
uint64_t first = getValue.getEndpoint().token.first();
uint64_t second = getValue.getEndpoint().token.second() & 0xffffffff00000000LL;
uint32_t newIndex = getValue.getEndpoint().token.second();
getKey = RequestStream<struct GetKeyRequest>( Endpoint( addresses, UID(first, second | ++newIndex) ) );
getKeyValues = RequestStream<struct GetKeyValuesRequest>( Endpoint( addresses, UID(first, second | ++newIndex) ) );
getShardState = RequestStream<struct GetShardStateRequest>( Endpoint( addresses, UID(first, second | ++newIndex) ) );
waitMetrics = RequestStream<struct WaitMetricsRequest>( Endpoint( addresses, UID(first, second | ++newIndex) ) );
splitMetrics = RequestStream<struct SplitMetricsRequest>( Endpoint( addresses, UID(first, second | ++newIndex) ) );
getStorageMetrics = RequestStream<struct GetStorageMetricsRequest>( Endpoint( addresses, UID(first, second | ++newIndex) ) );
waitFailure = RequestStream<ReplyPromise<Void>>( Endpoint( addresses, UID(first, second | ++newIndex) ) );
getQueuingMetrics = RequestStream<struct StorageQueuingMetricsRequest>( Endpoint( addresses, UID(first, second | ++newIndex) ) );
getKeyValueStoreType = RequestStream<ReplyPromise<KeyValueStoreType>>( Endpoint( addresses, UID(first, second | ++newIndex) ) );
watchValue = RequestStream<struct WatchValueRequest>( Endpoint( addresses, UID(first, second | ++newIndex) ) );
getReadHotRanges = RequestStream<struct ReadHotSubRangeRequest>( Endpoint( addresses, UID(first, second | ++newIndex) ) );
}
serializer(ar, uniqueID, locality, getValue, getKey, getKeyValues, getShardState, waitMetrics, splitMetrics, getStorageMetrics, waitFailure, getQueuingMetrics, getKeyValueStoreType, watchValue, getReadHotRanges);
} else {
ASSERT(Ar::isDeserializing);
if constexpr (is_fb_function<Ar>) {