Package org.ovirt.vdsm.jsonrpc.client.internal

Class ResponseTracker

java.lang.Object

org.ovirt.vdsm.jsonrpc.client.internal.ResponseTracker

All Implemented Interfaces:

Runnable

public class ResponseTracker
extends Object
implements Runnable

Response tracker thread is responsible for tracking and retrying requests. For each connection there is single instance of the thread.

Field Summary

Fields

Modifier and Type	Field	Description
private ScheduledExecutorService	executorService
private final ConcurrentMap<String,List<com.fasterxml.jackson.databind.JsonNode>>	hostToId
private final AtomicBoolean	isTracking
private final Lock	lock
private static final org.slf4j.Logger	log
private final ConcurrentMap<com.fasterxml.jackson.databind.JsonNode,ResponseTracking>	map
private final Queue<com.fasterxml.jackson.databind.JsonNode>	queue
private final ConcurrentMap<com.fasterxml.jackson.databind.JsonNode,JsonRpcCall>	runningCalls
private static final int	TRACKING_TIMEOUT

Constructor Summary

Constructors

Constructor	Description
ResponseTracker()

Method Summary

Modifier and Type	Method	Description
void	close()
protected Map<String,List<com.fasterxml.jackson.databind.JsonNode>>	getHostMap()
private void	handleFailure(ResponseTracking tracking, com.fasterxml.jackson.databind.JsonNode id, String failureDetails)
protected void	loop()
void	processIssue(JsonRpcResponse response)
void	registerCall(JsonRpcRequest req, JsonRpcCall call)
void	registerTrackingRequest(JsonRpcRequest req, ResponseTracking tracking)
private void	remove(ResponseTracking tracking, com.fasterxml.jackson.databind.JsonNode id, JsonRpcResponse response)
JsonRpcCall	removeCall(com.fasterxml.jackson.databind.JsonNode id)
private void	removeNodes(List<com.fasterxml.jackson.databind.JsonNode> nodes, JsonRpcResponse errorResponse)
private void	removeRequestFromTracking(com.fasterxml.jackson.databind.JsonNode id)
void	run()
void	setExecutorService(ScheduledExecutorService executorService)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

log

private static final org.slf4j.Logger log

TRACKING_TIMEOUT

private static final int TRACKING_TIMEOUT

See Also:

• Constant Field Values

isTracking

private final AtomicBoolean isTracking

runningCalls

private final ConcurrentMap<com.fasterxml.jackson.databind.JsonNode,JsonRpcCall> runningCalls

map

private final ConcurrentMap<com.fasterxml.jackson.databind.JsonNode,ResponseTracking> map

hostToId

private final ConcurrentMap<String,List<com.fasterxml.jackson.databind.JsonNode>> hostToId

queue

private final Queue<com.fasterxml.jackson.databind.JsonNode> queue

lock

private final Lock lock

executorService

private ScheduledExecutorService executorService

Constructor Details

ResponseTracker

public ResponseTracker()

Method Details

removeRequestFromTracking

private void removeRequestFromTracking(com.fasterxml.jackson.databind.JsonNode id)

registerCall

public void registerCall(JsonRpcRequest req,
 JsonRpcCall call)

removeCall

public JsonRpcCall removeCall(com.fasterxml.jackson.databind.JsonNode id)

registerTrackingRequest

public void registerTrackingRequest(JsonRpcRequest req,
 ResponseTracking tracking)

run

public void run()

Specified by:

run in interface Runnable

loop

protected void loop()

close

public void close()

handleFailure

private void handleFailure(ResponseTracking tracking,
 com.fasterxml.jackson.databind.JsonNode id,
 String failureDetails)

setExecutorService

public void setExecutorService(ScheduledExecutorService executorService)

remove

private void remove(ResponseTracking tracking,
 com.fasterxml.jackson.databind.JsonNode id,
 JsonRpcResponse response)

processIssue

public void processIssue(JsonRpcResponse response)

removeNodes

private void removeNodes(List<com.fasterxml.jackson.databind.JsonNode> nodes,
 JsonRpcResponse errorResponse)

getHostMap

protected Map<String,List<com.fasterxml.jackson.databind.JsonNode>> getHostMap()