parent
7d59fc894d
commit
415970a47b
|
@ -27,7 +27,7 @@
|
|||
|
||||
#include "flow/ThreadHelper.actor.h"
|
||||
|
||||
class VersionVector;
|
||||
struct VersionVector;
|
||||
|
||||
// An interface that represents a transaction created by a client
|
||||
class ITransaction {
|
||||
|
|
|
@ -237,12 +237,11 @@ struct TransactionState : ReferenceCounted<TransactionState> {
|
|||
Reference<TransactionLogInfo> trLogInfo;
|
||||
TransactionOptions options;
|
||||
|
||||
bool readVersionObtainedFromGrvProxy;
|
||||
|
||||
Optional<UID> debugID;
|
||||
TaskPriority taskID;
|
||||
SpanID spanID;
|
||||
UseProvisionalProxies useProvisionalProxies = UseProvisionalProxies::False;
|
||||
bool readVersionObtainedFromGrvProxy;
|
||||
|
||||
int numErrors = 0;
|
||||
double startTime = 0;
|
||||
|
|
|
@ -126,9 +126,9 @@ struct TagPartitionedLogSystem final : ILogSystem, ReferenceCounted<TagPartition
|
|||
LogEpoch e,
|
||||
Optional<PromiseStream<Future<Void>>> addActor = Optional<PromiseStream<Future<Void>>>())
|
||||
: dbgid(dbgid), logSystemType(LogSystemType::empty), expectedLogSets(0), logRouterTags(0), txsTags(0),
|
||||
repopulateRegionAntiQuorum(0), stopped(false), epoch(e), oldestBackupEpoch(0), maxRv(0),
|
||||
repopulateRegionAntiQuorum(0), stopped(false), epoch(e), oldestBackupEpoch(0),
|
||||
recoveryCompleteWrittenToCoreState(false), remoteLogsWrittenToCoreState(false), hasRemoteServers(false),
|
||||
locality(locality), addActor(addActor), popActors(false) {}
|
||||
maxRv(0), locality(locality), addActor(addActor), popActors(false) {}
|
||||
|
||||
void stopRejoins() final;
|
||||
|
||||
|
|
|
@ -115,7 +115,7 @@ struct MasterData : NonCopyable, ReferenceCounted<MasterData> {
|
|||
reportLiveCommittedVersionRequests("ReportLiveCommittedVersionRequests", cc),
|
||||
versionVectorTagUpdates("VersionVectorTagUpdates", cc),
|
||||
waitForPrevCommitRequests("WaitForPrevCommitRequests", cc),
|
||||
nonWaitForPrevCommitRequests("NonWaitForPrevCommitRequests", cc), addActor(addActor),
|
||||
nonWaitForPrevCommitRequests("NonWaitForPrevCommitRequests", cc),
|
||||
versionVectorSizeOnCVReply("VersionVectorSizeOnCVReply",
|
||||
dbgid,
|
||||
SERVER_KNOBS->LATENCY_METRICS_LOGGING_INTERVAL,
|
||||
|
@ -123,7 +123,8 @@ struct MasterData : NonCopyable, ReferenceCounted<MasterData> {
|
|||
waitForPrevLatencies("WaitForPrevLatencies",
|
||||
dbgid,
|
||||
SERVER_KNOBS->LATENCY_METRICS_LOGGING_INTERVAL,
|
||||
SERVER_KNOBS->LATENCY_SAMPLE_SIZE) {
|
||||
SERVER_KNOBS->LATENCY_SAMPLE_SIZE),
|
||||
addActor(addActor) {
|
||||
logger = traceCounters("MasterMetrics", dbgid, SERVER_KNOBS->WORKER_LOGGING_INTERVAL, &cc, "MasterMetrics");
|
||||
if (forceRecovery && !myInterface.locality.dcId().present()) {
|
||||
TraceEvent(SevError, "ForcedRecoveryRequiresDcID").log();
|
||||
|
|
Loading…
Reference in New Issue