StorageProxy

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total409 of 4,19590%62 of 37483%7936611599925179
describeSchemaVersions(boolean)3713678%71365%61163401
legacyReadWithPaxos(SinglePartitionReadCommand.Group, ConsistencyLevel, long)3314181%2466%2494901
mutateMV(ByteBuffer, Collection, boolean, AtomicLong, long)3215682%51777%41274201
findSuitableReplica(String, DecoratedKey, String, ConsistencyLevel)276370%4660%3651801
setIdealConsistencyLevel(String)230%n/a114411
legacyCas(String, String, DecoratedKey, CASRequest, ConsistencyLevel, ConsistencyLevel, ClientState, long, long)208781%n/a0183001
checkHintOverload(Replica)20725%5116%343501
systemKeyspaceQuery(List)200%40%334411
read(SinglePartitionReadCommand.Group, ConsistencyLevel, long)177080%21083%2751601
truncateBlocking(String, String)165577%1375%1331801
mutate(List, ConsistencyLevel, long)1218393%16100%0954501
mutateAtomically(Collection, ConsistencyLevel, boolean, long)913793%3770%3623901
asyncWriteBatchedMutations(List, String, Stage)73583%2100%022901
updateCoordinatorWriteLatencyTableMetric(Collection, long)61368%1150%1231001
getHintsInProgressFor(InetAddressAndPort)6545%n/a012301
shouldHint(Replica, boolean)514896%52784%51723501
asyncRemoveFromBatchlog(ReplicaPlan.ForWrite, TimeUUID)53687%1583%141901
lambda$proposePaxos$5(Message, Commit, ProposeCallback)51066%n/a012601
lambda$preparePaxos$4(PrepareCallback, Message, Commit)5861%n/a012501
doPaxos(TableMetadata, DecoratedKey, ConsistencyLevel, ConsistencyLevel, ConsistencyLevel, long, CASClientRequestMetrics, Function)414597%1990%1613701
isKeyDenylisted(String, String, String)42887%2466%242701
removeDenylistKey(String, String, String)42485%2250%232701
lambda$static$0(IMutation, ReplicaPlan.ForWrite, AbstractWriteResponseHandler, String)41275%1150%120301
isSafeToPerformRead(List)4555%3125%230101
setRpcTimeout(Long)40%n/a111111
setReadRpcTimeout(Long)40%n/a111111
setWriteRpcTimeout(Long)40%n/a111111
setCounterWriteRpcTimeout(Long)40%n/a111111
setCasContentionTimeout(Long)40%n/a111111
setRangeRpcTimeout(Long)40%n/a111111
setTruncateRpcTimeout(Long)40%n/a111111
setNativeTransportMaxConcurrentConnections(Long)40%n/a111111
setNativeTransportMaxConcurrentConnectionsPerIp(Long)40%n/a111111
verifyNoHintsInProgress()3457%1150%121301
setMaxHintsSizePerHostInMiB(int)30%n/a112211
setMaxHintsInProgress(int)30%n/a112211
getNativeTransportMaxConcurrentConnectionsPerIp()30%n/a111111
setEnablePartitionDenylist(boolean)30%n/a112211
setEnableDenylistWrites(boolean)30%n/a112211
setEnableDenylistReads(boolean)30%n/a112211
setEnableDenylistRangeReads(boolean)30%n/a112211
setUseStatementsEnabled(boolean)30%n/a112211
setPaxosContentionStrategy(String)30%n/a112211
setPaxosCoordinatorLockingDisabled(boolean)30%n/a112211
setDumpHeapOnUncaughtException(boolean)30%n/a112211
setSStableReadRatePersistenceEnabled(boolean)30%n/a112211
pickReplica(EndpointsForToken)21890%1150%120301
concatAndBlockOnRepair(List, List)21285%1150%121401
isAnyStorageHostDown()2675%1150%120101
lambda$legacyReadWithPaxos$20(Ballot)20%n/a111111
setOtcBacklogExpirationInterval(int)0%n/a111111
sendToHintedReplicas(Mutation, ReplicaPlan.ForWrite, AbstractWriteResponseHandler, String, Stage)196100%34100%01804901
beginAndRepairPaxos(long, DecoratedKey, TableMetadata, ReplicaPlan.ForPaxosWrite, ConsistencyLevel, ConsistencyLevel, CASClientRequestMetrics)149100%16100%0903501
fetchRows(List, ConsistencyLevel, long)129100%16100%0902401
mutateWithTriggers(List, ConsistencyLevel, boolean, long)114100%21487%2902201
commitPaxos(Commit, ConsistencyLevel, boolean, long)110100%31785%31102601
readRegular(SinglePartitionReadCommand.Group, ConsistencyLevel, long)110100%4100%0302801
sendMessagesToNonlocalDC(Message, EndpointsForToken, AbstractWriteResponseHandler)77100%4100%0301601
proposePaxos(Commit, ReplicaPlan.ForPaxosWrite, boolean, long)76100%12100%0701301
syncWriteToBatchlog(Collection, ReplicaPlan.ForWrite, TimeUUID, long)69100%4100%0301101
lambda$legacyCas$3(CASRequest, long, ConsistencyLevel, long, TableMetadata, DecoratedKey, ClientState, Ballot)67100%4100%0301601
preparePaxos(Commit, ReplicaPlan.ForPaxosWrite, long)66100%6100%0401401
mutateCounter(CounterMutation, String, long)63100%2100%0201301
cas(String, String, DecoratedKey, CASRequest, ConsistencyLevel, ConsistencyLevel, ClientState, long, long)54100%2675%250701
getRangeSlice(PartitionRangeReadCommand, ConsistencyLevel, long)54100%1583%140801
wrapBatchResponseHandler(Mutation, ConsistencyLevel, ConsistencyLevel, WriteType, BatchlogResponseHandler.BatchlogCleanup, long)52100%2100%0201001
syncWriteBatchedMutations(List, Stage)48100%4100%030901
performWrite(IMutation, ConsistencyLevel, String, StorageProxy.WritePerformer, Runnable, WriteType, long)47100%2100%0201101
static {...}46100%2100%0201701
wrapViewBatchResponseHandler(Mutation, ConsistencyLevel, ConsistencyLevel, ReplicaLayout.ForTokenWrite, AtomicLong, WriteType, BatchlogResponseHandler.BatchlogCleanup, long)38100%n/a010601
denylistKey(String, String, String)28100%4100%030701
submitHint(StorageProxy.HintRunnable)27100%2100%020401
hintMutation(Mutation)23100%n/a010701
recordCasContention(TableMetadata, DecoratedKey, CASClientRequestMetrics, int)20100%2100%020701
sendCommit(Commit, Iterable)20100%2100%020401
hintMutations(Collection)20100%1375%130501
appliesLocally(Mutation)19100%n/a010501
lambda$static$2(IMutation, ReplicaPlan.ForWrite, AbstractWriteResponseHandler, String)19100%n/a010501
lambda$logRequestException$24(Exception, Collection)18100%n/a010301
logRequestException(Exception, Collection)17100%n/a010301
lambda$static$1(IMutation, ReplicaPlan.ForWrite, AbstractWriteResponseHandler, String)17100%n/a010401
setHintedHandoffEnabled(boolean)15100%2100%020601
lambda$wrapViewBatchResponseHandler$14(AtomicLong)13100%n/a010301
submitHint(Mutation, EndpointsForToken, AbstractWriteResponseHandler)12100%n/a010301
readWithPaxos(SinglePartitionReadCommand.Group, ConsistencyLevel, long)11100%2100%020301
lambda$describeSchemaVersions$22(Map, CountDownLatch, Message)11100%n/a010301
commitPaxosLocal(Replica, Message, AbstractWriteResponseHandler)10100%n/a010201
performLocally(Stage, Replica, Runnable, RequestCallback, Object)10100%n/a010201
applyCounterMutationOnLeader(CounterMutation, String, Runnable, long)10100%n/a010101
applyCounterMutationOnCoordinator(CounterMutation, String, long)10100%n/a010101
submitHint(Mutation, Replica, AbstractWriteResponseHandler)10100%n/a010101
lambda$pickReplica$17(Replica)10100%2100%020101
performLocally(Stage, Replica, Runnable, String)9100%n/a010201
counterWriteTask(IMutation, ReplicaPlan.ForWrite, AbstractWriteResponseHandler, String)9100%n/a010101
logBlockingReadRepairAttemptsForNSeconds(int)9100%n/a010201
isLoggingReadRepairs()9100%2100%020101
readOne(SinglePartitionReadCommand, ConsistencyLevel, long)8100%n/a010101
recordReadRegularAbort(ConsistencyLevel, Throwable)8100%n/a010301
isSafeToPerformRead()7100%2100%020101
setPaxosVariant(String)7100%n/a010301
lambda$sendMessagesToNonlocalDC$16(Replica, Replica)7100%2100%020101
lambda$updateCoordinatorWriteLatencyTableMetric$11(long, ColumnFamilyStore)7100%n/a010101
lambda$updateCoordinatorWriteLatencyTableMetric$10(IMutation)7100%n/a010101
StorageProxy()6100%n/a010301
lambda$legacyReadWithPaxos$21(TableMetadata, DecoratedKey, Ballot)6100%n/a010101
lambda$updateCoordinatorWriteLatencyTableMetric$9(IMutation, TableId)6100%n/a010101
lambda$mutateAtomically$7(Mutation)6100%n/a010101
lambda$findSuitableReplica$19(Replica)5100%n/a010101
lambda$findSuitableReplica$18(Replica)5100%n/a010101
lambda$sendToHintedReplicas$15(String)5100%n/a010101
shouldHint(Replica)4100%n/a010101
getHintsInProgress()4100%n/a010101
getRpcTimeout()4100%n/a010101
getReadRpcTimeout()4100%n/a010101
getWriteRpcTimeout()4100%n/a010101
getCounterWriteRpcTimeout()4100%n/a010101
getCasContentionTimeout()4100%n/a010101
getRangeRpcTimeout()4100%n/a010101
getTruncateRpcTimeout()4100%n/a010101
getIdealConsistencyLevel()4100%n/a010101
lambda$logRequestException$23(Object)4100%n/a010101
lambda$mutateAtomically$8(ReplicaPlan.ForWrite, TimeUUID)4100%n/a010101
lambda$mutateMV$6(ReplicaPlan.ForWrite, TimeUUID)4100%n/a010101
getSchemaVersions()3100%n/a010101
getSchemaVersionsWithPort()3100%n/a010101
enableHintsForDC(String)3100%n/a010201
disableHintsForDC(String)3100%n/a010201
setMaxHintWindow(int)3100%n/a010201
getTotalHints()3100%n/a010101
getNativeTransportMaxConcurrentConnections()3100%n/a010101
reloadTriggerClasses()3100%n/a010101
getReadRepairAttempted()3100%n/a010101
getReadRepairRepairedBlocking()3100%n/a010101
getReadRepairRepairedBackground()3100%n/a010101
getReadRepairRepairTimedOut()3100%n/a010101
getNumberOfTables()3100%n/a010101
enableRepairedDataTrackingForRangeReads()3100%n/a010201
disableRepairedDataTrackingForRangeReads()3100%n/a010201
enableRepairedDataTrackingForPartitionReads()3100%n/a010201
disableRepairedDataTrackingForPartitionReads()3100%n/a010201
enableReportingUnconfirmedRepairedDataMismatches()3100%n/a010201
disableReportingUnconfirmedRepairedDataMismatches()3100%n/a010201
enableSnapshotOnRepairedDataMismatch()3100%n/a010201
disableSnapshotOnRepairedDataMismatch()3100%n/a010201
enableSnapshotOnDuplicateRowDetection()3100%n/a010201
disableSnapshotOnDuplicateRowDetection()3100%n/a010201
enableCheckForDuplicateRowsDuringReads()3100%n/a010201
disableCheckForDuplicateRowsDuringReads()3100%n/a010201
enableCheckForDuplicateRowsDuringCompaction()3100%n/a010201
disableCheckForDuplicateRowsDuringCompaction()3100%n/a010201
initialLoadPartitionDenylist()3100%n/a010201
loadPartitionDenylist()3100%n/a010201
getPartitionDenylistLoadAttempts()3100%n/a010101
getPartitionDenylistLoadSuccesses()3100%n/a010101
setDenylistMaxKeysPerTable(int)3100%n/a010201
setDenylistMaxKeysTotal(int)3100%n/a010201
getPaxosVariant()3100%n/a010101
setClientRequestSizeMetricsEnabled(boolean)3100%n/a010201
lambda$asyncRemoveFromBatchlog$13(TimeUUID)3100%n/a010101
lambda$syncWriteToBatchlog$12(Batch)3100%n/a010101
getHintedHandoffEnabled()2100%n/a010101
getHintedHandoffDisabledDCs()2100%n/a010101
getMaxHintWindow()2100%n/a010101
getMaxHintsSizePerHostInMiB()2100%n/a010101
getMaxHintsInProgress()2100%n/a010101
getOtcBacklogExpirationInterval()2100%n/a010101
getRepairedDataTrackingEnabledForRangeReads()2100%n/a010101
getRepairedDataTrackingEnabledForPartitionReads()2100%n/a010101
getReportingUnconfirmedRepairedDataMismatchesEnabled()2100%n/a010101
getSnapshotOnRepairedDataMismatchEnabled()2100%n/a010101
getSnapshotOnDuplicateRowDetectionEnabled()2100%n/a010101
getCheckForDuplicateRowsDuringReads()2100%n/a010101
getCheckForDuplicateRowsDuringCompaction()2100%n/a010101
getUseStatementsEnabled()2100%n/a010101
getPaxosContentionStrategy()2100%n/a010101
getPaxosCoordinatorLockingDisabled()2100%n/a010101
getDumpHeapOnUncaughtException()2100%n/a010101
getSStableReadRatePersistenceEnabled()2100%n/a010101
getClientRequestSizeMetricsEnabled()2100%n/a010101