StreamManager

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total110 of 41173%8 of 2060%14442899934
putStreamingState(StreamingState)310%20%227711
putInitiatorStream(StreamResultFuture)190%20%223311
putFollowerStream(StreamResultFuture)190%20%223311
addNotificationListener(NotificationListener, NotificationFilter, Object)70%n/a112211
removeNotificationListener(NotificationListener, NotificationFilter, Object)70%n/a112211
getInitiatorStream(TimeUUID)60%n/a111111
notifySafeOnRegister(StreamResultFuture)51777%2100%022701
clearStates()50%n/a112211
removeNotificationListener(NotificationListener)50%n/a112211
setStreamingSlowEventsLogTimeout(String)30%n/a112211
registerFollower(StreamResultFuture)22492%1150%121701
addStreamingStateAgain(StreamingState)1990%1150%121401
StreamManager()55100%n/a0101501
getTotalRemainingOngoingBytes()42100%4100%030601
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
getStreamingState(TimeUUID)6100%n/a010101
addListener(StreamManager.StreamListener)6100%n/a010201
removeListener(StreamManager.StreamListener)6100%n/a010201
getReceivingStream(TimeUUID)6100%n/a010101
start()5100%n/a010201
stop()5100%n/a010201
getStreamingStates()5100%n/a010101
getNotificationInfo()4100%n/a010101
setStreamingStatsEnabled(boolean)3100%n/a010201
getStreamingSlowEventsLogTimeout()3100%n/a010101
getStreamingStatsEnabled()2100%n/a010101