StreamSession

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total247 of 2,52790%37 of 22883%3519428485076
logError(Throwable)404351%3350%244901
receive(IncomingStreamMessage)367667%3350%3431701
progress(String, ProgressInfo.Direction, long, long, long)322240%1150%122601
checkAvailableDiskSpaceAndCompactions(Collection)243961%1583%1431001
checkDiskSpace(Map, TimeUUID, Function)2117889%31178%3833101
addStreamRequest(String, RangesAtEndpoint, RangesAtEndpoint, Collection)152562%4450%350401
complete()131451%1150%121501
prepareAck(PrepareAckMessage)13735%1150%121401
messageReceived(StreamMessage)96187%3975%31122401
abort()83681%4100%0321101
abortTasks()71263%n/a012601
getOutgoingStreamsForRanges(RangesAtEndpoint, Collection, TimeUUID, PreviewKind)62882%2100%023901
getAggregator(TableId)61368%1150%120201
start()58094%1583%1402001
startStreamingFiles(StreamSession.PrepareDirection)35494%2675%2511401
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
prepareAsync(Collection, Collection)99100%14100%0801801
onError(Throwable)90100%1990%1601701
boundStackTrace(Throwable, int, int, Set, StringBuilder)84100%10100%0601401
StreamSession(StreamOperation, InetAddressAndPort, StreamingChannel.Factory, StreamingChannel, int, boolean, int, TimeUUID, PreviewKind)74100%n/a0101901
checkAvailableDiskSpaceAndCompactions(Collection, TimeUUID, String, boolean)70100%1990%1601201
lambda$closeSession$5(StreamSession.State, Object)59100%8100%050801
getSessionInfo()58100%4100%030701
addTransferRanges(String, RangesAtEndpoint, Collection, boolean)51100%1375%1301301
prepareSynAck(PrepareSynAckMessage)48100%10100%0601101
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
completePreview()31100%4100%030601
closeSession(StreamSession.State, String)30100%2100%020601
sessionFailed()28100%n/a010501
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
toString()20100%n/a010101
lambda$attachInbound$0(StreamingChannel)15100%1375%130301
sessionTimeout()14100%n/a010301
initiatorCompleteOrWait()13100%2100%020401
boundStackTrace(Throwable, int, StringBuilder)12100%n/a010201
lambda$prepare$6(Collection, Collection)11100%n/a010501
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