queryhandlermetric.java

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

    public long getAverageQueryProcessingTime() {
        return (numQueries == 0) ? 0 : (queryProcessingTime / numQueries);
    }

    /** Number of local errors while processing received Queries **/
    public int getNumQueryErrors() {
        return numQueryErrors;
    }

    /** Number of Queries sent in Group ***/
    public int getNumQueriesSentInGroup() {
        return numQueriesSentInGroup;
    }

    /** Number of Queries sent via Walker ***/
    public int getNumQueriesSentViaWalker() {
        return numQueriesSentViaWalker;
    }

    /** Number of Queries sent via Unicast ***/
    public int getNumQueriesSentViaUnicast() {
        return numQueriesSentViaUnicast;
    }

    /** Number of Errors while sending Queries ***/
    public int getNumErrorsSendingQueries() {
        return numErrorsSendingQueries;
    }

    /** Number of Errors while propagating Queries ***/
    public int getNumErrorsPropagatingQueries() {
        return numErrorsPropagatingQueries;
    }
	
    /** Number of Responses sent in Group ***/
    public int getNumResponsesSentInGroup() {
        return numResponsesSentInGroup;
    }

    /** Number of Responses sent via Walker ***/
    public int getNumResponsesSentViaWalker() {
        return numResponsesSentViaWalker;
    }

    /** Number of Responses sent via Unicast ***/
    public int getNumResponsesSentViaUnicast() {
        return numResponsesSentViaUnicast;
    }

    /** Number of Errors while sending Responses ***/
    public int getNumErrorsSendingResponses() {
        return numErrorsSendingResponses;
    }

    /** Number of Errors while propagating Responses ***/
    public int getNumErrorsPropagatingResponses() {
        return numErrorsPropagatingResponses;
    }

    public int getNumQueriesSent() {
        return (numQueriesSentInGroup + numQueriesSentViaWalker + numQueriesSentViaUnicast);
    }

    public int getNumQuerySendErrors() {
        return (numErrorsSendingQueries + numErrorsPropagatingQueries);
    }

    public int getNumResponsesSent() {
        return (numResponsesSentInGroup + numResponsesSentViaWalker + numResponsesSentViaUnicast);
    }

    public int getNumResponseSendErrors() {
        return (numErrorsSendingResponses + numErrorsPropagatingResponses);
    }
	
    public void addQueryDestinationMetric(QueryDestinationMetric queryDestinationMetric) {
        destinationMetrics.put(queryDestinationMetric.getPeerID(), queryDestinationMetric);
    }
	
    public QueryDestinationMetric getQueryDestinationMetric(PeerID peerID) {
        QueryDestinationMetric destinationMetric = (QueryDestinationMetric) destinationMetrics.get(peerID);
		
        if (destinationMetric == null) {
            destinationMetric = new QueryDestinationMetric(peerID);
            destinationMetrics.put(peerID, destinationMetric);
        }
        return destinationMetric;
    }

    public Iterator getDestinationMetrics() {

        return destinationMetrics.values().iterator();
    }
	
    public void serializeTo(Element element) throws DocumentSerializationException {
        if (handlerName != null) {
            DocumentSerializableUtilities.addString(element, "handlerName", handlerName);
        }
        if (registered != null) {
            DocumentSerializableUtilities.addString(element, "registered", registered);
        }
        if (numResponses != 0) {
            DocumentSerializableUtilities.addInt(element, "numResponses", numResponses);
        }
        if (responseProcessingTime != 0) {
            DocumentSerializableUtilities.addLong(element, "responseProcessingTime", responseProcessingTime);
        }
        if (responseTime != 0) {
            DocumentSerializableUtilities.addLong(element, "responseTime", responseTime);
        }
        if (numResponseErrors != 0) {
            DocumentSerializableUtilities.addInt(element, "numResponseErrors", numResponseErrors);
        }
        if (numQueries != 0) {
            DocumentSerializableUtilities.addInt(element, "numQueries", numQueries);
        }
        if (numQueriesRepropagated != 0) {
            DocumentSerializableUtilities.addInt(element, "numQueriesRepropagated", numQueriesRepropagated);
        }
        if (queryProcessingTime != 0) {
            DocumentSerializableUtilities.addLong(element, "queryProcessingTime", queryProcessingTime);
        }
        if (numQueryErrors != 0) {
            DocumentSerializableUtilities.addInt(element, "numQueryErrors", numQueryErrors);
        }
        if (numQueriesSentInGroup != 0) {
            DocumentSerializableUtilities.addInt(element, "numQueriesSentInGroup", numQueriesSentInGroup);
        }
        if (numQueriesSentViaWalker != 0) {
            DocumentSerializableUtilities.addInt(element, "numQueriesSentViaWalker", numQueriesSentViaWalker);
        }
        if (numQueriesSentViaUnicast != 0) {
            DocumentSerializableUtilities.addInt(element, "numQueriesSentViaUnicast", numQueriesSentViaUnicast);
        }
        if (numErrorsSendingQueries != 0) {
            DocumentSerializableUtilities.addInt(element, "numErrorsSendingQueries", numErrorsSendingQueries);
        }
        if (numErrorsPropagatingQueries != 0) {
            DocumentSerializableUtilities.addInt(element, "numErrorsPropagatingQueries", numErrorsPropagatingQueries);
        }
        if (numQueriesHopCountDropped != 0) {
            DocumentSerializableUtilities.addInt(element, "numQueriesHopCountDropped", numQueriesHopCountDropped);
        }
        if (numPropagationQueriesDropped != 0) {
            DocumentSerializableUtilities.addInt(element, "numPropagationQueriesDropped", numPropagationQueriesDropped);
        }
        if (numPropagatedInGroup != 0) {
            DocumentSerializableUtilities.addInt(element, "numPropagatedInGroup", numPropagatedInGroup);
        }
        if (numPropagatedViaWalker != 0) {
            DocumentSerializableUtilities.addInt(element, "numPropagatedViaWalker", numPropagatedViaWalker);
        }
        if (numUnableToPropagate != 0) {
            DocumentSerializableUtilities.addInt(element, "numUnableToPropagate", numUnableToPropagate);
        }
        if (numResponsesToUnregisteredHandler != 0) {
            DocumentSerializableUtilities.addInt(element, "numResponsesToUnregisteredHandler", numResponsesToUnregisteredHandler);
        }
        if (numQueriesToUnregisteredHandler != 0) {
            DocumentSerializableUtilities.addInt(element, "numQueriesToUnregisteredHandler", numQueriesToUnregisteredHandler);
        }
        if (numResponsesSentInGroup != 0) {
            DocumentSerializableUtilities.addInt(element, "numResponsesSentInGroup", numResponsesSentInGroup);
        }
        if (numResponsesSentViaWalker != 0) {
            DocumentSerializableUtilities.addInt(element, "numResponsesSentViaWalker", numResponsesSentViaWalker);
        }
        if (numResponsesSentViaUnicast != 0) {
            DocumentSerializableUtilities.addInt(element, "numResponsesSentViaUnicast", numResponsesSentViaUnicast);
        }
        if (numErrorsSendingResponses != 0) {
            DocumentSerializableUtilities.addInt(element, "numErrorsSendingResponses", numErrorsSendingResponses);
        }
        if (numErrorsPropagatingResponses != 0) {
            DocumentSerializableUtilities.addInt(element, "numErrorsPropagatingResponses", numErrorsPropagatingResponses);
        }
	
        for (Iterator i = destinationMetrics.values().iterator(); i.hasNext();) {
            Element queryDestinationElement = DocumentSerializableUtilities.createChildElement(element, "destination");
            QueryDestinationMetric queryDestinationMetric = (QueryDestinationMetric) i.next();

            queryDestinationMetric.serializeTo(queryDestinationElement);
        }
    }

    public void initializeFrom(Element element) throws DocumentSerializationException {
        for (Enumeration e = element.getChildren(); e.hasMoreElements();) {
            Element childElement = (TextElement) e.nextElement();
            String tagName = (String) childElement.getKey();

            if (tagName.equals("handlerName")) { 
                handlerName = DocumentSerializableUtilities.getString(childElement);
            } else if (tagName.equals("registered")) { 
                registered = DocumentSerializableUtilities.getString(childElement);
            } else if (tagName.equals("numResponses")) { 
                numResponses = DocumentSerializableUtilities.getInt(childElement);
            } else if (tagName.equals("responseProcessingTime")) { 
                responseProcessingTime = DocumentSerializableUtilities.getLong(childElement);
            } else if (tagName.equals("responseTime")) { 
                responseTime = DocumentSerializableUtilities.getLong(childElement);
            } else if (tagName.equals("numResponseErrors")) { 
                numResponseErrors = DocumentSerializableUtilities.getInt(childElement);
            } else if (tagName.equals("numQueries")) { 
                numQueries = DocumentSerializableUtilities.getInt(childElement);
            } else if (tagName.equals("numQueriesRepropagated")) { 
                numQueriesRepropagated = DocumentSerializableUtilities.getInt(childElement);
            } else if (tagName.equals("queryProcessingTime")) { 
                queryProcessingTime = DocumentSerializableUtilities.getLong(childElement);
            } else if (tagName.equals("numQueryErrors")) { 
                numQueryErrors = DocumentSerializableUtilities.getInt(childElement);
            } else if (tagName.equals("numQueriesSentInGroup")) { 
                numQueriesSentInGroup = DocumentSerializableUtilities.getInt(childElement);
            } else if (tagName.equals("numQueriesSentViaWalker")) { 
                numQueriesSentViaWalker = DocumentSerializableUtilities.getInt(childElement);
            } else if (tagName.equals("numQueriesSentViaUnicast")) { 
                numQueriesSentViaUnicast = DocumentSerializableUtilities.getInt(childElement);
            } else if (tagName.equals("numErrorsSendingQueries")) { 
                numErrorsSendingQueries = DocumentSerializableUtilities.getInt(childElement);
            } else if (tagName.equals("numErrorsPropagatingQueries")) { 
                numErrorsPropagatingQueries = DocumentSerializableUtilities.getInt(childElement);
            } else if (tagName.equals("numQueriesHopCountDropped")) { 
                numQueriesHopCountDropped = DocumentSerializableUtilities.getInt(childElement);
            } else if (tagName.equals("numPropagationQueriesDropped")) { 
                numPropagationQueriesDropped = DocumentSerializableUtilities.getInt(childElement);
            } else if (tagName.equals("numPropagatedInGroup")) { 
                numPropagatedInGroup = DocumentSerializableUtilities.getInt(childElement);
            } else if (tagName.equals("numPropagatedViaWalker")) { 
                numPropagatedViaWalker = DocumentSerializableUtilities.getInt(childElement);
            } else if (tagName.equals("numUnableToPropagate")) { 
                numUnableToPropagate = DocumentSerializableUtilities.getInt(childElement);
            } else if (tagName.equals("numResponsesToUnregisteredHandler")) { 
                numResponsesToUnregisteredHandler = DocumentSerializableUtilities.getInt(childElement);
            } else if (tagName.equals("numQueriesToUnregisteredHandler")) { 
                numQueriesToUnregisteredHandler = DocumentSerializableUtilities.getInt(childElement);
            } else if (tagName.equals("numResponsesSentInGroup")) { 
                numResponsesSentInGroup = DocumentSerializableUtilities.getInt(childElement);
            } else if (tagName.equals("numResponsesSentViaWalker")) { 
                numResponsesSentViaWalker = DocumentSerializableUtilities.getInt(childElement);
            } else if (tagName.equals("numResponsesSentViaUnicast")) { 
                numResponsesSentViaUnicast = DocumentSerializableUtilities.getInt(childElement);
            } else if (tagName.equals("numErrorsSendingResponses")) { 
                numErrorsSendingResponses = DocumentSerializableUtilities.getInt(childElement);
            } else if (tagName.equals("numErrorsPropagatingResponses")) { 
                numErrorsPropagatingResponses = DocumentSerializableUtilities.getInt(childElement);
            } else if (tagName.equals("destination")) {
                QueryDestinationMetric queryDestinationMetric = new QueryDestinationMetric();

                queryDestinationMetric.initializeFrom(childElement);
                addQueryDestinationMetric(queryDestinationMetric);
            }
        }
    }

    public void mergeMetrics(QueryHandlerMetric otherQueryHandlerMetric) {
        this.numResponses += otherQueryHandlerMetric.numResponses;
        this.responseProcessingTime += otherQueryHandlerMetric.responseProcessingTime;
        this.responseTime += otherQueryHandlerMetric.responseTime;
        this.numResponseErrors += otherQueryHandlerMetric.numResponseErrors;

        this.numQueries += otherQueryHandlerMetric.numQueries;
        this.numQueriesRepropagated += otherQueryHandlerMetric.numQueriesRepropagated;
        this.queryProcessingTime += otherQueryHandlerMetric.queryProcessingTime;
        this.numQueryErrors += otherQueryHandlerMetric.numQueryErrors;

        this.numQueriesSentInGroup += otherQueryHandlerMetric.numQueriesSentInGroup;
        this.numQueriesSentViaWalker += otherQueryHandlerMetric.numQueriesSentViaWalker;
        this.numQueriesSentViaUnicast += otherQueryHandlerMetric.numQueriesSentViaUnicast;
        this.numErrorsSendingQueries += otherQueryHandlerMetric.numErrorsSendingQueries;
        this.numErrorsPropagatingQueries += otherQueryHandlerMetric.numErrorsPropagatingQueries;
        this.numQueriesHopCountDropped += otherQueryHandlerMetric.numQueriesHopCountDropped;

        this.numResponsesSentInGroup += otherQueryHandlerMetric.numResponsesSentInGroup;
        this.numResponsesSentViaWalker += otherQueryHandlerMetric.numResponsesSentViaWalker;
        this.numResponsesSentViaUnicast += otherQueryHandlerMetric.numResponsesSentViaUnicast;
        this.numErrorsSendingResponses += otherQueryHandlerMetric.numErrorsSendingResponses;
        this.numErrorsPropagatingResponses += otherQueryHandlerMetric.numErrorsPropagatingResponses;	

        for (Iterator i = otherQueryHandlerMetric.getDestinationMetrics(); i.hasNext();) {
            QueryDestinationMetric otherQueryDestinationMetric = (QueryDestinationMetric) i.next();
            QueryDestinationMetric ourQueryDestinationMetric = getQueryDestinationMetric(otherQueryDestinationMetric.getPeerID());

            if (ourQueryDestinationMetric == null) {
                ourQueryDestinationMetric = new QueryDestinationMetric(otherQueryDestinationMetric);
                addQueryDestinationMetric(ourQueryDestinationMetric);
            }

            ourQueryDestinationMetric.mergeMetrics(otherQueryDestinationMetric);
        }
    }
}