NetworkClient

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

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total1,742 of 1,7420%146 of 1460%1241243403405050
doSend(ClientRequest, boolean, long)1540%140%88262611
leastLoadedNode(long)1460%240%1313383811
handleApiVersionsResponse(List, NetworkClient.InFlightRequest, long, ApiVersionsResponse)1330%100%66212111
handleCompletedReceives(List, long)1130%140%88171711
NetworkClient(MetadataUpdater, Metadata, Selectable, String, int, long, long, int, int, int, long, long, Time, boolean, ApiVersions, Sensor, LogContext, HostResolver)990%40%33252511
poll(long, long)850%20%22222211
processDisconnection(List, String, long, ChannelState)800%40%44171711
doSend(ClientRequest, boolean, long, AbstractRequest)690%20%22101011
cancelInFlightRequests(String, long, Collection)680%80%55111111
handleInitiateApiVersionRequests(long)550%60%44131311
initiateConnect(Node, long)550%n/a11121211
parseResponse(ByteBuffer, RequestHeader)520%40%339911
maybeThrottle(AbstractResponse, short, String, long)410%40%336611
handleConnections()400%40%338811
disconnect(String)370%40%339911
handleTimedOutConnections(List, long)370%20%228811
handleCompletedSends(List, long)360%40%337711
ready(Node, long)350%60%447711
handleTimedOutRequests(List, long)320%20%227711
handleDisconnections(List, long)320%20%226611
close()240%20%226611
NetworkClient(Selectable, Metadata, String, int, long, long, int, int, int, long, long, Time, boolean, ApiVersions, Sensor, LogContext)230%n/a112211
NetworkClient(Selectable, MetadataUpdater, String, int, long, long, int, int, int, long, long, Time, boolean, ApiVersions, LogContext)230%n/a112211
completeResponses(List)210%20%227711
canSendRequest(String, long)200%60%442211
NetworkClient(Selectable, Metadata, String, int, long, long, int, int, int, long, long, Time, boolean, ApiVersions, LogContext)190%n/a112211
close(String)180%n/a115511
ensureActive()170%20%223311
isReady(Node, long)150%40%331111
nextCorrelationId()150%20%223311
newClientRequest(String, AbstractRequest.Builder, long, boolean, int, RequestCompletionHandler)140%n/a111111
sendInternalMetadataRequest(MetadataRequest.Builder, String, long)130%n/a113311
newClientRequest(String, AbstractRequest.Builder, long, boolean)100%n/a111111
hasInFlightRequests(String)90%20%221111
initiateClose()90%20%223311
active()90%20%221111
handleAbortedSends(List)90%n/a113311
hasInFlightRequests()80%20%221111
canConnect(Node, long)70%n/a111111
connectionDelay(Node, long)70%n/a111111
throttleDelayMs(Node, long)70%n/a111111
pollDelayMs(Node, long)70%n/a111111
connectionFailed(Node)60%n/a111111
authenticationException(Node)60%n/a111111
send(ClientRequest, long)60%n/a112211
inFlightRequestCount(String)50%n/a111111
hasReadyNodes(long)50%n/a111111
inFlightRequestCount()40%n/a111111
wakeup()40%n/a112211
discoverBrokerVersions()30%n/a111111