StreamSession

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total2,527 of 2,5270%228 of 2280%1941944854857676
checkPendingCompactions(Map, Map, TimeUUID, String, boolean, long)2000%80%55323211
checkDiskSpace(Map, TimeUUID, Function)1990%140%88313111
receive(IncomingStreamMessage)1120%60%44171711
prepareAsync(Collection, Collection)990%140%88181811
onError(Throwable)900%100%66171711
start()850%60%44202011
boundStackTrace(Throwable, int, int, Set, StringBuilder)840%100%66141411
logError(Throwable)830%60%449911
StreamSession(StreamOperation, InetAddressAndPort, StreamingChannel.Factory, StreamingChannel, int, boolean, int, TimeUUID, PreviewKind)740%n/a11191911
messageReceived(StreamMessage)700%120%1111242411
checkAvailableDiskSpaceAndCompactions(Collection, TimeUUID, String, boolean)700%100%66121211
checkAvailableDiskSpaceAndCompactions(Collection)630%60%44101011
lambda$closeSession$5(StreamSession.State, Object)590%80%558811
getSessionInfo()580%40%337711
startStreamingFiles(StreamSession.PrepareDirection)570%80%55141411
progress(String, ProgressInfo.Direction, long, long, long)540%20%226611
addTransferRanges(String, RangesAtEndpoint, Collection, boolean)510%40%33131311
prepareSynAck(PrepareSynAckMessage)480%100%66111111
addTransferStreams(Collection)450%60%44121211
streamSent(OutgoingStreamMessage)450%40%33101011
abort()440%40%33111111
maybeCompleted()410%80%55111111
addStreamRequest(String, RangesAtEndpoint, RangesAtEndpoint, Collection)400%80%554411
onInitializationComplete()390%20%228811
getColumnFamilyStores(String, Collection)340%40%336611
getOutgoingStreamsForRanges(RangesAtEndpoint, Collection, TimeUUID, PreviewKind)340%20%229911
createLogTag(StreamSession, Object)330%40%338811
state(StreamSession.State)310%20%225511
completePreview()310%40%336611
closeSession(StreamSession.State, String)300%20%226611
sessionFailed()280%n/a115511
complete()270%20%225511
flushSSTables(Iterable)250%20%225511
lambda$closeSession$2(StreamSession.State, String)250%20%227711
failIfFinished()240%20%223311
attachInbound(StreamingChannel)220%40%335511
attachOutbound(StreamingChannel)220%40%335511
prepareReceiving(StreamSummary)220%20%224411
streamOperation()210%40%334411
prepareAck(PrepareAckMessage)200%20%224411
toString()200%n/a111111
getAggregator(TableId)190%20%222211
abortTasks()190%n/a116611
lambda$attachInbound$0(StreamingChannel)150%40%333311
sessionTimeout()140%n/a113311
initiatorCompleteOrWait()130%20%224411
boundStackTrace(Throwable, int, StringBuilder)120%n/a112211
lambda$prepare$6(Collection, Collection)110%n/a115511
prepare(Collection, Collection)100%n/a113311
taskCompleted(StreamReceiveTask)100%n/a113311
taskCompleted(StreamTransferTask)100%n/a113311
planId()90%20%221111
createLogTag(StreamSession, StreamingChannel)90%20%221111
createLogTag(StreamSession, Channel)90%20%221111
static {...}90%n/a113311
init(StreamResultFuture)80%n/a113311
isSuccess()80%20%221111
received(TableId, int)80%n/a112211
lambda$attachOutbound$1(StreamingChannel)70%n/a111111
lambda$checkDiskSpace$7(ColumnFamilyStore)60%n/a111111
lambda$closeSession$4(List, StreamingChannel)60%n/a111111
lambda$closeSession$3(List, StreamingChannel)60%n/a111111
closeSession(StreamSession.State)50%n/a111111
countStreamedIn(boolean)50%n/a112211
isPreview()40%n/a111111
getNumRequests()40%n/a111111
getNumTransfers()40%n/a111111
createLogTag(StreamSession)40%n/a111111
isFollower()30%n/a111111
sessionIndex()30%n/a111111
getStreamOperation()30%n/a111111
getPendingRepair()30%n/a111111
getPreviewKind()30%n/a111111
state()30%n/a111111
getChannel()30%n/a111111
lambda$checkPendingCompactions$8(Integer)30%n/a111111