ConsumerNetworkClient

Source file "org/apache/kafka/clients/consumer/internals/ConsumerNetworkClient.java" was not found during generation of report.

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total777 of 7770%72 of 720%71711871873535
poll(Timer, ConsumerNetworkClient.PollCondition, boolean)830%100%66232311
checkDisconnects(long)650%60%44111111
ConsumerNetworkClient(LogContext, KafkaClient, Metadata, Time, long, int, int)610%n/a11151511
trySend(long)560%80%55131311
failExpiredRequests(long)370%20%226611
send(Node, AbstractRequest.Builder, int)320%n/a116611
failUnsentRequests(Node, RuntimeException)300%20%228811
isUnavailable(Node)270%40%333311
handlePendingDisconnects()250%20%229911
awaitMetadataUpdate(Timer)240%60%444411
transmitSends()240%n/a116611
hasPendingRequests(Node)210%20%225511
firePendingCompletedRequests()210%40%33101011
maybeTriggerWakeup()210%40%335511
awaitPendingRequests(Node, Timer)190%60%443311
pendingRequestCount(Node)190%n/a113311
ensureFreshMetadata(Timer)180%40%333311
hasPendingRequests()180%20%225511
pendingRequestCount()160%n/a113311
maybeThrowAuthFailure(Node)160%20%226611
leastLoadedNode()150%n/a113311
tryConnect(Node)150%n/a114411
hasReadyNodes(long)130%n/a113311
poll(RequestFuture, Timer)130%40%333311
wakeup()120%n/a114411
poll(RequestFuture)120%20%223311
maybeThrowInterruptException()100%20%223311
close()100%n/a114411
pollNoWakeup()90%n/a112211
disconnectAsync(Node)90%n/a113311
send(Node, AbstractRequest.Builder)70%n/a111111
poll(Timer, ConsumerNetworkClient.PollCondition)60%n/a112211
poll(Timer)50%n/a112211
disableWakeups()50%n/a112211
defaultRequestTimeoutMs()30%n/a111111