queryhandlermeter.java

JXTA&#8482 is a set of open, generalized peer-to-peer (P2P) protocols that allow any networked devi

                queryMetricsTable.put(key, queryMetric);
            }
	
            return queryMetric;	
        }
    }
	
    // Sent Queries

	
    public void querySentInGroup(ResolverQueryMsg query) {
        if (deltaMetrics == null) {	
            createDeltaMetric();
        }

        getQueryMetric(query.getQueryId()); // register the query

        deltaMetrics.querySentInGroup();
        cumulativeMetrics.querySentInGroup();		
    }

    public void querySentViaWalker(ResolverQueryMsg query) {
        if (deltaMetrics == null) {	
            createDeltaMetric();
        }

        getQueryMetric(query.getQueryId()); // register the query

        deltaMetrics.querySentViaWalker();
        cumulativeMetrics.querySentViaWalker();		
    }

    public void querySentViaUnicast(String peer, ResolverQueryMsg query) {
        if (deltaMetrics == null) {	
            createDeltaMetric();
        }

        getQueryMetric(query.getQueryId()); // register the query
		
        deltaMetrics.querySentViaUnicast(peer);
        cumulativeMetrics.querySentViaUnicast(peer);

        QueryDestinationMeter destinationMeter = getQueryDestinationMeter(peer);

        destinationMeter.querySentViaUnicast();
    }

    public void querySendError() {
        if (deltaMetrics == null) {	
            createDeltaMetric();
        }

        deltaMetrics.querySendError();
        cumulativeMetrics.querySendError();		
    }

    public void queryPropagateError() {
        if (deltaMetrics == null) {	
            createDeltaMetric();
        }

        deltaMetrics.queryPropagateError();
        cumulativeMetrics.queryPropagateError();		
    }

    public void queryHopCountDropped() {
        if (deltaMetrics == null) {	
            createDeltaMetric();
        }

        deltaMetrics.queryHopCountDropped();
        cumulativeMetrics.queryHopCountDropped();		
    }

    public void unableToPropagate() {
        if (deltaMetrics == null) {	
            createDeltaMetric();
        }

        deltaMetrics.unableToPropagate();
        cumulativeMetrics.unableToPropagate();		
    }

    // Propagate Query

    public void queryPropagatedInGroup() {
        if (deltaMetrics == null) {	
            createDeltaMetric();
        }

        deltaMetrics.queryPropagatedInGroup();
        cumulativeMetrics.queryPropagatedInGroup();		
    }

    public void queryPropagatedViaWalker() {
        if (deltaMetrics == null) {	
            createDeltaMetric();
        }

        deltaMetrics.queryPropagatedViaWalker();
        cumulativeMetrics.queryPropagatedViaWalker();		
    }

    public void propagationQueryDropped() {
        if (deltaMetrics == null) {	
            createDeltaMetric();
        }

        deltaMetrics.propagationQueryDropped();
        cumulativeMetrics.propagationQueryDropped();		
    }
	
    // Sent Responses

    public void responseSentViaUnicast(String peer, ResolverResponseMsg response) {
        if (deltaMetrics == null) {	
            createDeltaMetric();
        }

        deltaMetrics.responseSentViaUnicast();
        cumulativeMetrics.responseSentViaUnicast();	

        QueryDestinationMeter destinationMeter = getQueryDestinationMeter(peer);

        destinationMeter.responseSentViaUnicast();
    }

    public void responseSentViaWalker(ResolverResponseMsg response) {
        if (deltaMetrics == null) {	
            createDeltaMetric();
        }

        deltaMetrics.responseSentViaWalker();
        cumulativeMetrics.responseSentViaWalker();		
    }

    public void responseSentInGroup(ResolverResponseMsg response) {
        if (deltaMetrics == null) {	
            createDeltaMetric();
        }

        deltaMetrics.responseSentInGroup();
        cumulativeMetrics.responseSentInGroup();		
    }		

    public void responseSendError() {
        if (deltaMetrics == null) {	
            createDeltaMetric();
        }

        deltaMetrics.responseSendError();
        cumulativeMetrics.responseSendError();		
    }

    public void responsePropagateError() {
        if (deltaMetrics == null) {	
            createDeltaMetric();
        }

        deltaMetrics.responsePropagateError();
        cumulativeMetrics.responsePropagateError();		
    }

    // Received Responses

    public void responseProcessed(ResolverResponseMsg response, long processTime, EndpointAddress srcAddr) {
        if (deltaMetrics == null) {	
            createDeltaMetric();
        }

        QueryMetric queryMetric = getQueryMetric(response.getQueryId());
        long now = System.currentTimeMillis();
        long responseTime = now - queryMetric.querySentTime;
	
        queryMetric.lastResponseTime = now;
        queryMetric.numResponsesReceived++;
		
        deltaMetrics.responseProcessed(responseTime, processTime);
        cumulativeMetrics.responseProcessed(responseTime, processTime);

        QueryDestinationMeter destinationMeter = getQueryDestinationMeter(srcAddr);

        destinationMeter.responseProcessed();
    }

    public void responseToUnregisteredHandler(EndpointAddress src) {
        if (deltaMetrics == null) {	
            createDeltaMetric();
        }

        deltaMetrics.responseToUnregisteredHandler();
        cumulativeMetrics.responseToUnregisteredHandler();

        QueryDestinationMeter destinationMeter = getQueryDestinationMeter(src);

        destinationMeter.responseToUnregisteredHandler();
    }

    public void errorWhileProcessingResponse(EndpointAddress srcAddr) {
        if (deltaMetrics == null) {	
            createDeltaMetric();
        }

        deltaMetrics.errorWhileProcessingResponse();
        cumulativeMetrics.errorWhileProcessingResponse();

        QueryDestinationMeter destinationMeter = getQueryDestinationMeter(srcAddr);

        destinationMeter.errorWhileProcessingResponse();
    }	
	
    // Received Queries	

    public void queryProcessed(ResolverQueryMsg query, int result, long processTime) {
        if (deltaMetrics == null) {	
            createDeltaMetric();
        }

        deltaMetrics.queryProcessed(result, processTime);
        cumulativeMetrics.queryProcessed(result, processTime);

        QueryDestinationMeter destinationMeter = getQueryDestinationMeter(query.getSrc());

        destinationMeter.queryProcessed();
    }

    public void queryToUnregisteredHandler(ResolverQueryMsg query) {
        if (deltaMetrics == null) {	
            createDeltaMetric();
        }

        deltaMetrics.queryToUnregisteredHandler();
        cumulativeMetrics.queryToUnregisteredHandler();

        QueryDestinationMeter destinationMeter = getQueryDestinationMeter(query.getSrc());

        destinationMeter.queryToUnregisteredHandler();
    }

    public void errorWhileProcessingQuery(ResolverQueryMsg query) {
        if (deltaMetrics == null) {	
            createDeltaMetric();
        }

        deltaMetrics.errorWhileProcessingQuery();
        cumulativeMetrics.errorWhileProcessingQuery();

        QueryDestinationMeter destinationMeter = getQueryDestinationMeter(query.getSrc());

        destinationMeter.errorWhileProcessingQuery();
    }

    public Enumeration getQueryDestinationMeters() {
        return queryDestinationMeters.elements();
    }

    public int getQueryDestinationCount() {
        return queryDestinationMeters.size();
    }
}