fix serilizer issue

This commit is contained in:
Chaoguang Lin 2020-05-18 10:56:10 -07:00
parent bf62ef7c3e
commit 4bb90cb038
1 changed files with 3 additions and 2 deletions

View File

@ -66,7 +66,7 @@ struct MasterProxyInterface {
template <class Archive>
void serialize(Archive& ar) {
serializer(ar, processId, provisional, base, getDDMetrics); // TODO : solve this
serializer(ar, processId, provisional, base);
if( Archive::isDeserializing ) {
commit = RequestStream< struct CommitTransactionRequest >( base.getAdjustedEndpoint(0) );
getConsistentReadVersion = RequestStream< struct GetReadVersionRequest >( base.getAdjustedEndpoint(1) );
@ -78,7 +78,7 @@ struct MasterProxyInterface {
getHealthMetrics = RequestStream< struct GetHealthMetricsRequest >( base.getAdjustedEndpoint(7) );
proxySnapReq = RequestStream< struct ProxySnapRequest >( base.getAdjustedEndpoint(8) );
exclusionSafetyCheckReq = RequestStream< struct ExclusionSafetyCheckRequest >( base.getAdjustedEndpoint(9) );
// getDDMetrics = RequestStream< struct GetDDMetricsRequest >( base.getAdjustedEndpoint(10) );
getDDMetrics = RequestStream< struct GetDDMetricsRequest >( base.getAdjustedEndpoint(10) );
}
}
@ -94,6 +94,7 @@ struct MasterProxyInterface {
streams.push_back(getHealthMetrics.getReceiver());
streams.push_back(proxySnapReq.getReceiver());
streams.push_back(exclusionSafetyCheckReq.getReceiver());
streams.push_back(getDDMetrics.getReceiver());
base = FlowTransport::transport().addEndpoints(streams);
}
};