StorageProxy

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total1,862 of 4,19555%174 of 37453%228366486999102179
describeSchemaVersions(boolean)1730%200%1111343411
sendToHintedReplicas(Mutation, ReplicaPlan.ForWrite, AbstractWriteResponseHandler, String, Stage)1296734%25926%1518274901
legacyReadWithPaxos(SinglePartitionReadCommand.Group, ConsistencyLevel, long)918347%3350%34294901
mutate(List, ConsistencyLevel, long)8810754%41275%29254501
beginAndRepairPaxos(long, DecoratedKey, TableMetadata, ReplicaPlan.ForPaxosWrite, ConsistencyLevel, ConsistencyLevel, CASClientRequestMetrics)846543%9743%79193501
sendMessagesToNonlocalDC(Message, EndpointsForToken, AbstractWriteResponseHandler)770%40%33161611
legacyCas(String, String, DecoratedKey, CASRequest, ConsistencyLevel, ConsistencyLevel, ClientState, long, long)683936%n/a01233001
mutateMV(ByteBuffer, Collection, boolean, AtomicLong, long)6312566%101254%912124201
mutateAtomically(Collection, ConsistencyLevel, boolean, long)578960%3770%36173901
doPaxos(TableMetadata, DecoratedKey, ConsistencyLevel, ConsistencyLevel, ConsistencyLevel, long, CASClientRequestMetrics, Function)4710268%3770%36113701
mutateCounter(CounterMutation, String, long)461726%1150%12101301
readRegular(SinglePartitionReadCommand.Group, ConsistencyLevel, long)446660%4100%03172801
asyncWriteBatchedMutations(List, String, Stage)420%20%229911
shouldHint(Replica, boolean)3811575%102268%91773501
wrapViewBatchResponseHandler(Mutation, ConsistencyLevel, ConsistencyLevel, ReplicaLayout.ForTokenWrite, AtomicLong, WriteType, BatchlogResponseHandler.BatchlogCleanup, long)380%n/a116611
commitPaxos(Commit, ConsistencyLevel, boolean, long)278375%12840%91162601
findSuitableReplica(String, DecoratedKey, String, ConsistencyLevel)276370%5550%4651801
submitHint(StorageProxy.HintRunnable)270%20%224411
proposePaxos(Commit, ReplicaPlan.ForPaxosWrite, boolean, long)255167%7541%5741301
hintMutation(Mutation)230%n/a117711
setIdealConsistencyLevel(String)230%n/a114411
truncateBlocking(String, String)215070%1375%1361801
checkHintOverload(Replica)20725%5116%343501
sendCommit(Commit, Iterable)200%20%224411
hintMutations(Collection)200%40%335511
pickReplica(EndpointsForToken)200%20%223311
systemKeyspaceQuery(List)200%40%334411
lambda$logRequestException$24(Exception, Collection)180%n/a113311
read(SinglePartitionReadCommand.Group, ConsistencyLevel, long)177080%21083%2751601
recordCasContention(TableMetadata, DecoratedKey, CASClientRequestMetrics, int)17315%1150%125701
logRequestException(Exception, Collection)170%n/a113311
lambda$static$1(IMutation, ReplicaPlan.ForWrite, AbstractWriteResponseHandler, String)170%n/a114411
setHintedHandoffEnabled(boolean)150%20%226611
lambda$wrapViewBatchResponseHandler$14(AtomicLong)130%n/a113311
submitHint(Mutation, EndpointsForToken, AbstractWriteResponseHandler)120%n/a113311
getHintsInProgressFor(InetAddressAndPort)110%n/a113311
lambda$describeSchemaVersions$22(Map, CountDownLatch, Message)110%n/a113311
asyncRemoveFromBatchlog(ReplicaPlan.ForWrite, TimeUUID)103175%2466%242901
applyCounterMutationOnLeader(CounterMutation, String, Runnable, long)100%n/a111111
submitHint(Mutation, Replica, AbstractWriteResponseHandler)100%n/a111111
lambda$pickReplica$17(Replica)100%20%221111
preparePaxos(Commit, ReplicaPlan.ForPaxosWrite, long)95786%2466%2421401
recordReadRegularAbort(ConsistencyLevel, Throwable)80%n/a113311
lambda$sendMessagesToNonlocalDC$16(Replica, Replica)70%20%221111
syncWriteToBatchlog(Collection, ReplicaPlan.ForWrite, TimeUUID, long)66391%1375%1311101
updateCoordinatorWriteLatencyTableMetric(Collection, long)61368%1150%1231001
lambda$proposePaxos$5(Message, Commit, ProposeCallback)51066%n/a012601
lambda$preparePaxos$4(PrepareCallback, Message, Commit)5861%n/a012501
lambda$sendToHintedReplicas$15(String)50%n/a111111
static {...}44291%1150%1221701
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
getRpcTimeout()40%n/a111111
setRpcTimeout(Long)40%n/a111111
getReadRpcTimeout()40%n/a111111
setReadRpcTimeout(Long)40%n/a111111
getWriteRpcTimeout()40%n/a111111
setWriteRpcTimeout(Long)40%n/a111111
getCounterWriteRpcTimeout()40%n/a111111
setCounterWriteRpcTimeout(Long)40%n/a111111
getCasContentionTimeout()40%n/a111111
setCasContentionTimeout(Long)40%n/a111111
getRangeRpcTimeout()40%n/a111111
setRangeRpcTimeout(Long)40%n/a111111
getTruncateRpcTimeout()40%n/a111111
setTruncateRpcTimeout(Long)40%n/a111111
setNativeTransportMaxConcurrentConnections(Long)40%n/a111111
setNativeTransportMaxConcurrentConnectionsPerIp(Long)40%n/a111111
getIdealConsistencyLevel()40%n/a111111
lambda$logRequestException$23(Object)40%n/a111111
lambda$mutateMV$6(ReplicaPlan.ForWrite, TimeUUID)40%n/a111111
fetchRows(List, ConsistencyLevel, long)312697%11593%1912401
wrapBatchResponseHandler(Mutation, ConsistencyLevel, ConsistencyLevel, WriteType, BatchlogResponseHandler.BatchlogCleanup, long)34994%1150%1211001
performWrite(IMutation, ConsistencyLevel, String, StorageProxy.WritePerformer, Runnable, WriteType, long)34493%1150%1211101
verifyNoHintsInProgress()3457%1150%121301
getSchemaVersions()30%n/a111111
getSchemaVersionsWithPort()30%n/a111111
enableHintsForDC(String)30%n/a112211
disableHintsForDC(String)30%n/a112211
setMaxHintWindow(int)30%n/a112211
setMaxHintsSizePerHostInMiB(int)30%n/a112211
setMaxHintsInProgress(int)30%n/a112211
getNativeTransportMaxConcurrentConnections()30%n/a111111
getNativeTransportMaxConcurrentConnectionsPerIp()30%n/a111111
reloadTriggerClasses()30%n/a111111
getReadRepairRepairTimedOut()30%n/a111111
getNumberOfTables()30%n/a111111
enableRepairedDataTrackingForRangeReads()30%n/a112211
disableRepairedDataTrackingForRangeReads()30%n/a112211
enableRepairedDataTrackingForPartitionReads()30%n/a112211
disableRepairedDataTrackingForPartitionReads()30%n/a112211
enableReportingUnconfirmedRepairedDataMismatches()30%n/a112211
disableReportingUnconfirmedRepairedDataMismatches()30%n/a112211
enableSnapshotOnRepairedDataMismatch()30%n/a112211
disableSnapshotOnRepairedDataMismatch()30%n/a112211
enableSnapshotOnDuplicateRowDetection()30%n/a112211
disableSnapshotOnDuplicateRowDetection()30%n/a112211
enableCheckForDuplicateRowsDuringReads()30%n/a112211
disableCheckForDuplicateRowsDuringReads()30%n/a112211
enableCheckForDuplicateRowsDuringCompaction()30%n/a112211
disableCheckForDuplicateRowsDuringCompaction()30%n/a112211
getPartitionDenylistLoadAttempts()30%n/a111111
getPartitionDenylistLoadSuccesses()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
concatAndBlockOnRepair(List, List)21285%1150%121401
isAnyStorageHostDown()2675%1150%120101
getHintedHandoffEnabled()20%n/a111111
getHintedHandoffDisabledDCs()20%n/a111111
getMaxHintWindow()20%n/a111111
getMaxHintsSizePerHostInMiB()20%n/a111111
getMaxHintsInProgress()20%n/a111111
getOtcBacklogExpirationInterval()20%n/a111111
getRepairedDataTrackingEnabledForRangeReads()20%n/a111111
getRepairedDataTrackingEnabledForPartitionReads()20%n/a111111
getReportingUnconfirmedRepairedDataMismatchesEnabled()20%n/a111111
getSnapshotOnRepairedDataMismatchEnabled()20%n/a111111
getSnapshotOnDuplicateRowDetectionEnabled()20%n/a111111
getCheckForDuplicateRowsDuringReads()20%n/a111111
getCheckForDuplicateRowsDuringCompaction()20%n/a111111
getUseStatementsEnabled()20%n/a111111
getPaxosContentionStrategy()20%n/a111111
getPaxosCoordinatorLockingDisabled()20%n/a111111
getDumpHeapOnUncaughtException()20%n/a111111
getSStableReadRatePersistenceEnabled()20%n/a111111
getClientRequestSizeMetricsEnabled()20%n/a111111
lambda$legacyReadWithPaxos$20(Ballot)20%n/a111111
isSafeToPerformRead()685%1150%120101
setOtcBacklogExpirationInterval(int)0%n/a111111
mutateWithTriggers(List, ConsistencyLevel, boolean, long)114100%21487%2902201
lambda$legacyCas$3(CASRequest, long, ConsistencyLevel, long, TableMetadata, DecoratedKey, ClientState, Ballot)67100%4100%0301601
cas(String, String, DecoratedKey, CASRequest, ConsistencyLevel, ConsistencyLevel, ClientState, long, long)54100%2675%250701
getRangeSlice(PartitionRangeReadCommand, ConsistencyLevel, long)54100%1583%140801
syncWriteBatchedMutations(List, Stage)48100%4100%030901
denylistKey(String, String, String)28100%4100%030701
appliesLocally(Mutation)19100%n/a010501
lambda$static$2(IMutation, ReplicaPlan.ForWrite, AbstractWriteResponseHandler, String)19100%n/a010501
readWithPaxos(SinglePartitionReadCommand.Group, ConsistencyLevel, long)11100%2100%020301
commitPaxosLocal(Replica, Message, AbstractWriteResponseHandler)10100%n/a010201
performLocally(Stage, Replica, Runnable, RequestCallback, Object)10100%n/a010201
applyCounterMutationOnCoordinator(CounterMutation, String, long)10100%n/a010101
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
setPaxosVariant(String)7100%n/a010301
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
shouldHint(Replica)4100%n/a010101
getHintsInProgress()4100%n/a010101
lambda$mutateAtomically$8(ReplicaPlan.ForWrite, TimeUUID)4100%n/a010101
getTotalHints()3100%n/a010101
getReadRepairAttempted()3100%n/a010101
getReadRepairRepairedBlocking()3100%n/a010101
getReadRepairRepairedBackground()3100%n/a010101
initialLoadPartitionDenylist()3100%n/a010201
loadPartitionDenylist()3100%n/a010201
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