StreamManager

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total109 of 41173%8 of 2060%174427991034
getTotalRemainingOngoingBytes()261638%3125%233601
notifySafeOnRegister(StreamResultFuture)14836%1150%125701
putStreamingState(StreamingState)72477%1150%121701
putInitiatorStream(StreamResultFuture)71263%1150%120301
putFollowerStream(StreamResultFuture)71263%1150%120301
addNotificationListener(NotificationListener, NotificationFilter, Object)70%n/a112211
removeNotificationListener(NotificationListener, NotificationFilter, Object)70%n/a112211
getStreamingState(TimeUUID)60%n/a111111
removeListener(StreamManager.StreamListener)60%n/a112211
stop()50%n/a112211
removeNotificationListener(NotificationListener)50%n/a112211
setStreamingStatsEnabled(boolean)30%n/a112211
getStreamingSlowEventsLogTimeout()30%n/a111111
setStreamingSlowEventsLogTimeout(String)30%n/a112211
getStreamingStatsEnabled()20%n/a111111
addStreamingStateAgain(StreamingState)1990%1150%121401
StreamManager()55100%n/a0101501
registerFollower(StreamResultFuture)26100%2100%020701
registerInitiator(StreamResultFuture)20100%n/a010501
findSession(InetAddressAndPort, TimeUUID, int, boolean)15100%2100%020201
getCurrentStreams()14100%n/a010101
findSession(Map, InetAddressAndPort, TimeUUID, int)14100%2100%020401
getRateLimiter(InetAddressAndPort)9100%n/a010301
getEntireSSTableRateLimiter(InetAddressAndPort)9100%n/a010301
static {...}8100%n/a010201
lambda$registerFollower$1(StreamResultFuture)7100%n/a010101
lambda$registerInitiator$0(StreamResultFuture)7100%n/a010101
addListener(StreamManager.StreamListener)6100%n/a010201
getReceivingStream(TimeUUID)6100%n/a010101
getInitiatorStream(TimeUUID)6100%n/a010101
start()5100%n/a010201
getStreamingStates()5100%n/a010101
clearStates()5100%n/a010201
getNotificationInfo()4100%n/a010101