Selector

Source file "org/apache/kafka/common/network/Selector.java" was not found during generation of report.

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total1,871 of 1,8710%226 of 2260%1761764294296363
pollSelectionKeys(Set, boolean, long)3420%660%3434727211
poll(long)1670%280%1515363611
Selector(int, long, int, Metrics, Time, String, Map, boolean, boolean, ChannelBuilder, MemoryPool, LogContext)1330%40%33292911
clear()760%100%66191911
connect(String, InetSocketAddress, int, int)580%40%33181811
close(KafkaChannel, Selector.CloseMode)580%80%55121211
close()510%40%33111111
maybeCloseOldestConnection(long)510%80%55131311
doClose(KafkaChannel, boolean)490%20%22131311
lowestPriorityChannel()480%80%559911
send(NetworkSend)470%40%33141411
write(KafkaChannel)440%80%55111111
attemptRead(KafkaChannel)440%60%44131311
buildAndAttachKafkaChannel(SocketChannel, String, SelectionKey)380%n/a117711
maybeReadFromClosingChannel(KafkaChannel)380%60%44111111
ensureNotRegistered(String)370%40%335511
openOrClosingChannelOrFail(String)360%40%336611
addToCompletedReceives(KafkaChannel, NetworkReceive, long)340%20%225511
registerChannel(String, SocketChannel, int)310%20%226611
close(String)290%40%338811
configureSocketChannel(SocketChannel, int, int)260%40%339911
register(String, SocketChannel)250%20%227711
completeDelayedChannelClose(long)220%60%448811
select(long)220%40%335511
maybeDelayCloseOnAuthenticationFailure(KafkaChannel)220%20%225511
determineHandlingOrder(Set)210%40%335511
doConnect(SocketChannel, InetSocketAddress)180%n/a113311
attemptWrite(SelectionKey, KafkaChannel, long)180%80%556611
unmute(KafkaChannel)180%40%335511
muteAll()170%20%223311
unmuteAll()170%20%223311
Selector(int, long, Metrics, Time, String, Map, boolean, boolean, ChannelBuilder, MemoryPool, LogContext)150%n/a112211
Selector(int, long, int, Metrics, Time, String, Map, boolean, ChannelBuilder, LogContext)150%n/a112211
handleCloseOnAuthenticationFailure(KafkaChannel)150%n/a115511
isChannelReady(String)150%40%332211
mute(KafkaChannel)140%n/a114411
Selector(int, long, Metrics, Time, String, Map, boolean, ChannelBuilder, LogContext)130%n/a112211
Selector(long, int, Metrics, Time, String, ChannelBuilder, LogContext)130%n/a112211
Selector(long, Metrics, Time, String, ChannelBuilder, LogContext)120%n/a112211
maybeRecordTimePerConnection(KafkaChannel, long)110%20%223311
lambda$pollSelectionKeys$3(KafkaChannel, NetworkReceive)100%n/a113311
mute(String)80%n/a113311
unmute(String)80%n/a113311
channels()70%n/a111111
keys()70%n/a111111
channel(String)60%n/a111111
closingChannel(String)60%n/a111111
hasCompletedReceive(KafkaChannel)60%n/a111111
wakeup()50%n/a112211
completedReceives()40%n/a111111
clearCompletedReceives()40%n/a112211
clearCompletedSends()40%n/a112211
channel(SelectionKey)40%n/a111111
lambda$close$1(String)40%n/a111111
lambda$null$0(String)40%n/a111111
completedSends()30%n/a111111
disconnected()30%n/a111111
connected()30%n/a111111
isOutOfMemory()30%n/a111111
isMadeReadProgressLastPoll()30%n/a111111
delayedClosingChannels()30%n/a111111
lambda$attemptWrite$4(long)30%n/a111111
lambda$close$2(int)30%n/a111111