Skip to content
This repository has been archived by the owner on Nov 14, 2024. It is now read-only.

Rip out multi-leader paxos and timestamp paxos batching #7431

Draft
wants to merge 1 commit into
base: develop
Choose a base branch
from
Draft
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view

This file was deleted.

This file was deleted.

Original file line number Diff line number Diff line change
Expand Up @@ -59,7 +59,6 @@
import com.palantir.timelock.config.ImmutableSqlitePaxosPersistenceConfiguration;
import com.palantir.timelock.config.ImmutableTimeLockRuntimeConfiguration;
import com.palantir.timelock.config.PaxosInstallConfiguration;
import com.palantir.timelock.config.PaxosInstallConfiguration.PaxosLeaderMode;
import com.palantir.timelock.config.TimeLockInstallConfiguration;
import com.palantir.timelock.config.TimeLockRuntimeConfiguration;
import com.palantir.timestamp.ManagedTimestampService;
Expand Down Expand Up @@ -106,7 +105,6 @@ void setClient(String client) {
public void setup() {
PaxosInstallConfiguration paxos = PaxosInstallConfiguration.builder()
.dataDirectory(tryCreateSubFolder())
.leaderMode(PaxosLeaderMode.SINGLE_LEADER)
.sqlitePersistence(ImmutableSqlitePaxosPersistenceConfiguration.builder()
.dataDirectory(tryCreateSubFolder())
.build())
Expand Down

This file was deleted.

Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,6 @@

package com.palantir.atlasdb.timelock.paxos;

import com.google.common.collect.ImmutableList;
import com.palantir.paxos.LeaderPinger;
import com.palantir.paxos.PaxosAcceptorNetworkClient;
import com.palantir.paxos.PaxosConstants;
Expand Down Expand Up @@ -49,39 +48,13 @@ interface PaxosLatestRoundVerifierFactory {
PaxosLatestRoundVerifier create(PaxosAcceptorNetworkClient acceptorNetworkClient);
}

@Value.Immutable
abstract class BatchingLeaderPingerFactory implements LeaderPingerFactoryContainer, Dependencies.LeaderPinger {

@Value.Derived
AutobatchingPingableLeaderFactory pingableLeaderFactory() {
return AutobatchingPingableLeaderFactory.create(
WithDedicatedExecutor.convert(remoteClients().batchPingableLeadersWithContext()),
leaderPingRate(),
leaderPingResponseWait(),
leaderUuid());
}

@Override
public NetworkClientFactories.Factory<LeaderPinger> get() {
return pingableLeaderFactory()::leaderPingerFor;
}

@Override
@Value.Derived
public List<Closeable> closeables() {
return ImmutableList.of(pingableLeaderFactory());
}

public abstract static class Builder implements LeaderPingerFactoryContainer.Builder {}
}

@Value.Immutable
abstract class SingleLeaderPingerFactory implements LeaderPingerFactoryContainer, Dependencies.LeaderPinger {

@Value.Derived
SingleLeaderPinger pinger() {
return SingleLeaderPinger.create(
WithDedicatedExecutor.convert(remoteClients().nonBatchPingableLeadersWithContext()),
WithDedicatedExecutor.convert(remoteClients().pingableLeadersWithContext()),
dataSource(),
leaderPingResponseWait(),
greenNodeLeadershipBackoff(),
Expand Down

This file was deleted.

Loading