Skip to content

Commit 59f1992

Browse files
authored
RATIS-2022. Replace some Guava usage with builtins (#1231)
1 parent a477d6d commit 59f1992

File tree

3 files changed

+9
-8
lines changed

3 files changed

+9
-8
lines changed

ratis-common/src/main/java/org/apache/ratis/conf/ConfUtils.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,6 @@
1818
package org.apache.ratis.conf;
1919

2020
import org.apache.ratis.security.TlsConf;
21-
import org.apache.ratis.thirdparty.com.google.common.base.Objects;
2221
import org.apache.ratis.util.NetUtils;
2322
import org.apache.ratis.util.SizeInBytes;
2423
import org.apache.ratis.util.TimeDuration;
@@ -33,6 +32,7 @@
3332
import java.net.InetSocketAddress;
3433
import java.util.Arrays;
3534
import java.util.List;
35+
import java.util.Objects;
3636
import java.util.concurrent.ConcurrentHashMap;
3737
import java.util.concurrent.ConcurrentMap;
3838
import java.util.function.BiConsumer;
@@ -60,7 +60,7 @@ private static <T> boolean isNew(String key, T value) {
6060
static <T> void logGet(String key, T value, T defaultValue, Consumer<String> logger) {
6161
if (logger != null && Utils.isNew(key, value)) {
6262
logger.accept(String.format("%s = %s (%s)", key, value,
63-
Objects.equal(value, defaultValue)? "default": "custom"));
63+
Objects.equals(value, defaultValue)? "default": "custom"));
6464
}
6565
}
6666

ratis-common/src/test/java/org/apache/ratis/util/TestRefCountingMap.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -22,10 +22,10 @@
2222
import static org.junit.jupiter.api.Assertions.assertNull;
2323
import static org.junit.jupiter.api.Assertions.assertTrue;
2424

25+
import java.util.Arrays;
2526
import java.util.Collection;
2627
import java.util.Set;
2728

28-
import org.apache.ratis.thirdparty.com.google.common.collect.Lists;
2929
import org.junit.jupiter.api.BeforeEach;
3030
import org.junit.jupiter.api.Test;
3131

@@ -128,7 +128,7 @@ public void testKeySet() {
128128
Set<String> keys = map.keySet();
129129
assertEquals(3, keys.size());
130130

131-
Lists.newArrayList("foo", "bar", "baz").forEach(v -> assertTrue(keys.contains(v)));
131+
Arrays.asList("foo", "bar", "baz").forEach(v -> assertTrue(keys.contains(v)));
132132
}
133133

134134
@Test
@@ -141,7 +141,7 @@ public void testValues() {
141141
Collection<String> values = map.values();
142142
assertEquals(3, values.size());
143143

144-
Lists.newArrayList("foovalue", "foovalue3", "foovalue4")
144+
Arrays.asList("foovalue", "foovalue3", "foovalue4")
145145
.forEach(v -> assertTrue(values.contains(v)));
146146
}
147147
}

ratis-server/src/test/java/org/apache/ratis/RaftTestUtil.java

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -37,11 +37,11 @@
3737
import org.apache.ratis.server.raftlog.LogProtoUtils;
3838
import org.apache.ratis.server.raftlog.RaftLog;
3939
import org.apache.ratis.server.raftlog.RaftLogBase;
40-
import org.apache.ratis.thirdparty.com.google.common.base.Preconditions;
4140
import org.apache.ratis.thirdparty.com.google.protobuf.ByteString;
4241
import org.apache.ratis.util.AutoCloseableLock;
4342
import org.apache.ratis.util.CollectionUtils;
4443
import org.apache.ratis.util.JavaUtils;
44+
import org.apache.ratis.util.Preconditions;
4545
import org.apache.ratis.util.ProtoUtils;
4646
import org.apache.ratis.util.TimeDuration;
4747
import org.junit.Assert;
@@ -152,8 +152,9 @@ static RaftPeerId waitAndKillLeader(MiniRaftCluster cluster) throws InterruptedE
152152

153153
static void waitFor(Supplier<Boolean> check, int checkEveryMillis,
154154
int waitForMillis) throws TimeoutException, InterruptedException {
155-
Preconditions.checkNotNull(check);
156-
Preconditions.checkArgument(waitForMillis >= checkEveryMillis);
155+
Preconditions.assertNotNull(check, "check");
156+
Preconditions.assertTrue(waitForMillis >= checkEveryMillis,
157+
() -> "waitFor: " + waitForMillis + " < checkEvery: " + checkEveryMillis);
157158

158159
long st = System.currentTimeMillis();
159160
boolean result = check.get();

0 commit comments

Comments
 (0)