mirror of https://github.com/apache/cassandra
Merge branch 'cassandra-4.0' into cassandra-4.1
This commit is contained in:
commit
778f9f3ed5
|
|
@ -700,7 +700,7 @@
|
||||||
this that the new assertj's `assertj-parent-pom` depends on. -->
|
this that the new assertj's `assertj-parent-pom` depends on. -->
|
||||||
<dependency groupId="org.junit" artifactId="junit-bom" version="5.6.0" type="pom" scope="test"/>
|
<dependency groupId="org.junit" artifactId="junit-bom" version="5.6.0" type="pom" scope="test"/>
|
||||||
<!-- when updating assertj, make sure to also update the corresponding junit-bom dependency -->
|
<!-- when updating assertj, make sure to also update the corresponding junit-bom dependency -->
|
||||||
<dependency groupId="org.assertj" artifactId="assertj-core" version="3.15.0" scope="provided"/>
|
<dependency groupId="org.assertj" artifactId="assertj-core" version="3.15.0" scope="test"/>
|
||||||
<dependency groupId="org.awaitility" artifactId="awaitility" version="4.0.3" scope="test">
|
<dependency groupId="org.awaitility" artifactId="awaitility" version="4.0.3" scope="test">
|
||||||
<exclusion groupId="org.hamcrest" artifactId="hamcrest"/>
|
<exclusion groupId="org.hamcrest" artifactId="hamcrest"/>
|
||||||
</dependency>
|
</dependency>
|
||||||
|
|
@ -763,6 +763,7 @@
|
||||||
version="${version}"
|
version="${version}"
|
||||||
relativePath="${final.name}-parent.pom"/>
|
relativePath="${final.name}-parent.pom"/>
|
||||||
<dependency groupId="junit" artifactId="junit" scope="test"/>
|
<dependency groupId="junit" artifactId="junit" scope="test"/>
|
||||||
|
<dependency groupId="org.assertj" artifactId="assertj-core" scope="test"/>
|
||||||
<dependency groupId="commons-io" artifactId="commons-io" scope="test"/>
|
<dependency groupId="commons-io" artifactId="commons-io" scope="test"/>
|
||||||
<dependency groupId="org.mockito" artifactId="mockito-core" scope="test"/>
|
<dependency groupId="org.mockito" artifactId="mockito-core" scope="test"/>
|
||||||
<dependency groupId="org.ow2.asm" artifactId="asm" version="${asm.version}"/>
|
<dependency groupId="org.ow2.asm" artifactId="asm" version="${asm.version}"/>
|
||||||
|
|
|
||||||
|
|
@ -21,6 +21,7 @@ import java.io.IOException;
|
||||||
import java.nio.ByteBuffer;
|
import java.nio.ByteBuffer;
|
||||||
import java.util.concurrent.TimeUnit;
|
import java.util.concurrent.TimeUnit;
|
||||||
|
|
||||||
|
import com.google.common.annotations.VisibleForTesting;
|
||||||
import com.google.common.base.Throwables;
|
import com.google.common.base.Throwables;
|
||||||
|
|
||||||
import javax.annotation.Nullable;
|
import javax.annotation.Nullable;
|
||||||
|
|
@ -36,7 +37,6 @@ import org.apache.cassandra.schema.TableId;
|
||||||
import org.apache.cassandra.utils.concurrent.Future;
|
import org.apache.cassandra.utils.concurrent.Future;
|
||||||
import org.apache.cassandra.utils.concurrent.ImmediateFuture;
|
import org.apache.cassandra.utils.concurrent.ImmediateFuture;
|
||||||
import org.apache.cassandra.utils.vint.VIntCoding;
|
import org.apache.cassandra.utils.vint.VIntCoding;
|
||||||
import org.assertj.core.util.VisibleForTesting;
|
|
||||||
|
|
||||||
import static org.apache.cassandra.db.TypeSizes.sizeof;
|
import static org.apache.cassandra.db.TypeSizes.sizeof;
|
||||||
import static org.apache.cassandra.db.TypeSizes.sizeofUnsignedVInt;
|
import static org.apache.cassandra.db.TypeSizes.sizeofUnsignedVInt;
|
||||||
|
|
|
||||||
|
|
@ -19,6 +19,8 @@ package org.apache.cassandra.net;
|
||||||
|
|
||||||
import java.nio.ByteBuffer;
|
import java.nio.ByteBuffer;
|
||||||
|
|
||||||
|
import com.google.common.annotations.VisibleForTesting;
|
||||||
|
|
||||||
import io.netty.buffer.AbstractByteBufAllocator;
|
import io.netty.buffer.AbstractByteBufAllocator;
|
||||||
import io.netty.buffer.ByteBuf;
|
import io.netty.buffer.ByteBuf;
|
||||||
import io.netty.buffer.Unpooled;
|
import io.netty.buffer.Unpooled;
|
||||||
|
|
@ -26,7 +28,6 @@ import io.netty.buffer.UnpooledUnsafeDirectByteBuf;
|
||||||
import org.apache.cassandra.io.compress.BufferType;
|
import org.apache.cassandra.io.compress.BufferType;
|
||||||
import org.apache.cassandra.utils.memory.BufferPool;
|
import org.apache.cassandra.utils.memory.BufferPool;
|
||||||
import org.apache.cassandra.utils.memory.BufferPools;
|
import org.apache.cassandra.utils.memory.BufferPools;
|
||||||
import org.assertj.core.util.VisibleForTesting;
|
|
||||||
|
|
||||||
import static java.lang.Integer.max;
|
import static java.lang.Integer.max;
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -18,6 +18,7 @@
|
||||||
|
|
||||||
package org.apache.cassandra.service.reads.range;
|
package org.apache.cassandra.service.reads.range;
|
||||||
|
|
||||||
|
import com.google.common.annotations.VisibleForTesting;
|
||||||
import org.slf4j.Logger;
|
import org.slf4j.Logger;
|
||||||
import org.slf4j.LoggerFactory;
|
import org.slf4j.LoggerFactory;
|
||||||
|
|
||||||
|
|
@ -34,7 +35,6 @@ import org.apache.cassandra.locator.ReplicaPlans;
|
||||||
import org.apache.cassandra.schema.TableMetadata;
|
import org.apache.cassandra.schema.TableMetadata;
|
||||||
import org.apache.cassandra.tracing.Tracing;
|
import org.apache.cassandra.tracing.Tracing;
|
||||||
import org.apache.cassandra.utils.FBUtilities;
|
import org.apache.cassandra.utils.FBUtilities;
|
||||||
import org.assertj.core.util.VisibleForTesting;
|
|
||||||
|
|
||||||
public class RangeCommands
|
public class RangeCommands
|
||||||
{
|
{
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue