StreamSession

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total524 of 2,52779%63 of 22872%6419472485876
checkDiskSpace(Map, TimeUUID, Function)6413567%41071%48103101
logError(Throwable)404351%3350%244901
checkAvailableDiskSpaceAndCompactions(Collection)402336%2466%2441001
receive(IncomingStreamMessage)367667%3350%3431701
progress(String, ProgressInfo.Direction, long, long, long)322240%1150%122601
abort()321227%3125%2381101
completePreview()310%40%336611
checkPendingCompactions(Map, Map, TimeUUID, String, boolean, long)3017085%1787%1533201
toString()200%n/a111111
failIfFinished()19520%1150%121301
boundStackTrace(Throwable, int, int, Set, StringBuilder)176779%1990%1611401
addStreamRequest(String, RangesAtEndpoint, RangesAtEndpoint, Collection)152562%4450%350401
streamOperation()14733%3125%232401
sessionTimeout()140%n/a113311
complete()131451%1150%121501
prepareAck(PrepareAckMessage)13735%1150%121401
start()127385%1583%1432001
messageReceived(StreamMessage)96187%3975%31122401
createLogTag(StreamSession, Channel)90%20%221111
abortTasks()71263%n/a012601
prepareAsync(Collection, Collection)69393%31178%3821801
getOutgoingStreamsForRanges(RangesAtEndpoint, Collection, TimeUUID, PreviewKind)62882%2100%023901
getAggregator(TableId)61368%1150%120201
lambda$checkDiskSpace$7(ColumnFamilyStore)60%n/a111111
closeSession(StreamSession.State, String)52583%1150%121601
lambda$prepare$6(Collection, Collection)5654%n/a012501
getNumRequests()40%n/a111111
getNumTransfers()40%n/a111111
startStreamingFiles(StreamSession.PrepareDirection)35494%2675%2511401
prepareSynAck(PrepareSynAckMessage)34593%2880%2611101
getChannel()30%n/a111111
maybeCompleted()23995%1787%1511101
createLogTag(StreamSession, StreamingChannel)2777%1150%120101
checkAvailableDiskSpaceAndCompactions(Collection, TimeUUID, String, boolean)6998%3770%3601201
attachOutbound(StreamingChannel)2195%2250%230501
onError(Throwable)90100%2880%2601701
StreamSession(StreamOperation, InetAddressAndPort, StreamingChannel.Factory, StreamingChannel, int, boolean, int, TimeUUID, PreviewKind)74100%n/a0101901
lambda$closeSession$5(StreamSession.State, Object)59100%1787%150801
getSessionInfo()58100%4100%030701
addTransferRanges(String, RangesAtEndpoint, Collection, boolean)51100%1375%1301301
addTransferStreams(Collection)45100%1583%1401201
streamSent(OutgoingStreamMessage)45100%1375%1301001
onInitializationComplete()39100%2100%020801
getColumnFamilyStores(String, Collection)34100%4100%030601
createLogTag(StreamSession, Object)33100%4100%030801
state(StreamSession.State)31100%2100%020501
sessionFailed()28100%n/a010501
flushSSTables(Iterable)25100%2100%020501
lambda$closeSession$2(StreamSession.State, String)25100%1150%120701
attachInbound(StreamingChannel)22100%4100%030501
prepareReceiving(StreamSummary)22100%1150%120401
lambda$attachInbound$0(StreamingChannel)15100%1375%130301
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$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
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
lambda$checkPendingCompactions$8(Integer)3100%n/a010101