queryhandlermetric.java

jxta_src_2.41b jxta 2.41b 最新版源码 from www.jxta.org

	public long getAverageResponseProcessingTime() { return (numResponses == 0) ? 0 : (responseProcessingTime/numResponses) ; }
	/** The total time to receive all responses to queries sent by this Handler **/
	public long getResponseTime() { return responseTime; }
	/** The average time to receive responses to queries sent by this Handler **/
	public long getAverageResponseTime() { return (numResponses == 0) ? 0 : (responseTime/numResponses) ; }
	/** Number of local errors while processing received responses **/
	public int getNumResponseErrors() { return numResponseErrors; }
	
	/** The number of queries received by this Handler **/
	public int getNumQueries() { return numQueries; }
	/** The number of queries received and repropagated by this Handler **/
	public int getNumQueriesRepropagated() { return numQueriesRepropagated; }
	/** The total clock time to process all Queries received by this Handler **/
	public long getQueryProcessingTime() { return queryProcessingTime; }
	/** The average clock time to process Queries received by this Handler **/
	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);
		}
	}
}