StreamSession

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total514 of 2,52779%71 of 22868%6519478485576
checkAvailableDiskSpaceAndCompactions(Collection)630%60%44101011
logError(Throwable)404351%3350%244901
receive(IncomingStreamMessage)367667%3350%3431701
prepareSynAck(PrepareSynAckMessage)331531%7330%5661101
progress(String, ProgressInfo.Direction, long, long, long)322240%1150%122601
completePreview()310%40%336611
onError(Throwable)306066%2880%2641701
prepareAsync(Collection, Collection)287171%6857%5851801
sessionFailed()280%n/a115511
checkDiskSpace(Map, TimeUUID, Function)2117889%31178%3833101
prepareAck(PrepareAckMessage)200%20%224411
toString()200%n/a111111
boundStackTrace(Throwable, int, int, Set, StringBuilder)176779%2880%2611401
messageReceived(StreamMessage)175375%5758%51162401
start()157082%2466%2432001
addStreamRequest(String, RangesAtEndpoint, RangesAtEndpoint, Collection)152562%4450%350401
complete()131451%1150%121501
streamSent(OutgoingStreamMessage)93680%2250%2321001
abort()83681%4100%0321101
abortTasks()71263%n/a012601
getOutgoingStreamsForRanges(RangesAtEndpoint, Collection, TimeUUID, PreviewKind)62882%2100%023901
getAggregator(TableId)61368%1150%120201
lambda$prepare$6(Collection, Collection)5654%n/a012501
startStreamingFiles(StreamSession.PrepareDirection)35494%2675%2511401
checkAvailableDiskSpaceAndCompactions(Collection, TimeUUID, String, boolean)26897%3770%3611201
maybeCompleted()23995%1787%1511101
streamOperation()21990%1375%130401
createLogTag(StreamSession, StreamingChannel)2777%1150%120101
createLogTag(StreamSession, Channel)2777%1150%120101
attachOutbound(StreamingChannel)2195%2250%230501
checkPendingCompactions(Map, Map, TimeUUID, String, boolean, long)200100%8100%0503201
StreamSession(StreamOperation, InetAddressAndPort, StreamingChannel.Factory, StreamingChannel, int, boolean, int, TimeUUID, PreviewKind)74100%n/a0101901
lambda$closeSession$5(StreamSession.State, Object)59100%8100%050801
getSessionInfo()58100%4100%030701
addTransferRanges(String, RangesAtEndpoint, Collection, boolean)51100%1375%1301301
addTransferStreams(Collection)45100%1583%1401201
onInitializationComplete()39100%2100%020801
getColumnFamilyStores(String, Collection)34100%4100%030601
createLogTag(StreamSession, Object)33100%1375%130801
state(StreamSession.State)31100%1150%120501
closeSession(StreamSession.State, String)30100%2100%020601
flushSSTables(Iterable)25100%2100%020501
lambda$closeSession$2(StreamSession.State, String)25100%2100%020701
failIfFinished()24100%2100%020301
attachInbound(StreamingChannel)22100%4100%030501
prepareReceiving(StreamSummary)22100%1150%120401
lambda$attachInbound$0(StreamingChannel)15100%1375%130301
sessionTimeout()14100%n/a010301
initiatorCompleteOrWait()13100%2100%020401
boundStackTrace(Throwable, int, StringBuilder)12100%n/a010201
prepare(Collection, Collection)10100%n/a010301
taskCompleted(StreamReceiveTask)10100%n/a010301
taskCompleted(StreamTransferTask)10100%n/a010301
planId()9100%2100%020101
static {...}9100%n/a010301
init(StreamResultFuture)8100%n/a010301
isSuccess()8100%2100%020101
received(TableId, int)8100%n/a010201
lambda$attachOutbound$1(StreamingChannel)7100%n/a010101
lambda$checkDiskSpace$7(ColumnFamilyStore)6100%n/a010101
lambda$closeSession$4(List, StreamingChannel)6100%n/a010101
lambda$closeSession$3(List, StreamingChannel)6100%n/a010101
closeSession(StreamSession.State)5100%n/a010101
countStreamedIn(boolean)5100%n/a010201
isPreview()4100%n/a010101
getNumRequests()4100%n/a010101
getNumTransfers()4100%n/a010101
createLogTag(StreamSession)4100%n/a010101
isFollower()3100%n/a010101
sessionIndex()3100%n/a010101
getStreamOperation()3100%n/a010101
getPendingRepair()3100%n/a010101
getPreviewKind()3100%n/a010101
state()3100%n/a010101
getChannel()3100%n/a010101
lambda$checkPendingCompactions$8(Integer)3100%n/a010101