transportbindingmetric.java

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

/*
 * Copyright (c) 2001 Sun Microsystems, Inc.  All rights
 * reserved.
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions
 * are met:
 *
 * 1. Redistributions of source code must retain the above copyright
 *    notice, this list of conditions and the following disclaimer.
 *
 * 2. Redistributions in binary form must reproduce the above copyright
 *    notice, this list of conditions and the following disclaimer in
 *    the documentation and/or other materials provided with the
 *    distribution.
 *
 * 3. The end-user documentation included with the redistribution,
 *    if any, must include the following acknowledgment:
 *       "This product includes software developed by the
 *       Sun Microsystems, Inc. for Project JXTA."
 *    Alternately, this acknowledgment may appear in the software itself,
 *    if and wherever such third-party acknowledgments normally appear.
 *
 * 4. The names "Sun", "Sun Microsystems, Inc.", "JXTA" and "Project JXTA" must
 *    not be used to endorse or promote products derived from this
 *    software without prior written permission. For written
 *    permission, please contact Project JXTA at http://www.jxta.org.
 *
 * 5. Products derived from this software may not be called "JXTA",
 *    nor may "JXTA" appear in their name, without prior written
 *    permission of Sun.
 *
 * THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESSED OR IMPLIED
 * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
 * DISCLAIMED.  IN NO EVENT SHALL SUN MICROSYSTEMS OR
 * ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
 * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
 * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
 * USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
 * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
 * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT
 * OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
 * SUCH DAMAGE.
 * ====================================================================
 *
 * This software consists of voluntary contributions made by many
 * individuals on behalf of Project JXTA.  For more
 * information on Project JXTA, please see
 * <http://www.jxta.org/>.
 *
 * This license is based on the BSD license adopted by the Apache Foundation.
 *
 * $Id: TransportBindingMetric.java,v 1.8 2006/01/05 21:48:39 bondolo Exp $
 */

 package net.jxta.impl.endpoint.transportMeter;

import net.jxta.endpoint.*;
import net.jxta.impl.endpoint.*;
import net.jxta.util.documentSerializable.*;
import net.jxta.document.*;
import net.jxta.peer.*;
import net.jxta.impl.meter.*;

import java.util.*;

public class TransportBindingMetric implements DocumentSerializable {
	public static final String CONNECTED = "connected";
	public static final String CLOSED = "closed";
	public static final String DROPPED = "dropped"; 
	public static final String FAILED = "failed"; 

	private PeerID peerID;
	private EndpointAddress endpointAddress;

	private String initiatorState = null;;
	private String acceptorState = null;;
	private long initiatorTransitionTime;
	private long acceptorTransitionTime;
	
	private int acceptorBytesReceived;
	private int acceptorBytesSent;
	private int acceptorConnections;
	private int acceptorConnectionsClosed;
	private int acceptorConnectionsDropped;
	private int acceptorConnectionsFailed;
	private int acceptorMessagesReceived;
	private int acceptorMessagesSent;
	private long acceptorReceiveFailureProcessingTime;
	private int acceptorReceiveFailures;
	private long acceptorReceiveProcessingTime;
	private long acceptorSendFailureProcessingTime;
	private int acceptorSendFailures;
	private long acceptorSendProcessingTime;
	private long acceptorTotalTimeConnected;
	private long acceptorTimeToConnect;
	private long acceptorTimeToFail;
	private int initiatorBytesReceived;
	private int initiatorBytesSent;
	private long initiatorTotalTimeConnected;
	private int initiatorConnections;
	private int initiatorConnectionsClosed;
	private int initiatorConnectionsDropped;
	private int initiatorConnectionsFailed;
	private int initiatorMessagesReceived;
	private int initiatorMessagesSent;
	private long initiatorReceiveFailureProcessingTime;
	private int initiatorReceiveFailures;
	private long initiatorReceiveProcessingTime;
	private long initiatorSendFailureProcessingTime;
	private int initiatorSendFailures;
	private long initiatorSendProcessingTime;
	private long initiatorTimeToConnect;
	private long initiatorTimeToFail;

	private int numPings;
	private int numFailedPings;
	private long pingTime;
	private long pingFailedTime;
	private int numPingsReceived;


	public TransportBindingMetric(TransportBindingMeter transportBindingMeter, boolean initiatorConnected, boolean acceptorConnected) {
		this.peerID = transportBindingMeter.getPeerID();
		this.endpointAddress = transportBindingMeter.getEndpointAddress();
		this.initiatorState = initiatorConnected ? CONNECTED : CLOSED;
		this.acceptorState = acceptorConnected ? CONNECTED : CLOSED;
	}


	public TransportBindingMetric() { 
	} 

	public TransportBindingMetric(TransportBindingMetric prototype) {
		this.peerID = prototype.peerID;
		this.endpointAddress = prototype.endpointAddress;		
		this.initiatorState = prototype.initiatorState;
		this.acceptorState = prototype.acceptorState;
		this.initiatorTransitionTime = prototype.initiatorTransitionTime;
		this.acceptorTransitionTime = prototype.acceptorTransitionTime;
	}
	
	public boolean equals(Object obj) {
		if (obj instanceof TransportBindingMetric) {
			TransportBindingMetric other = (TransportBindingMetric) obj;
			return endpointAddress.equals(other.endpointAddress);
		} else
			return false;
	}


	public int hashCode() { return peerID.hashCode() + endpointAddress.hashCode(); }

	public PeerID getPeerID() { return peerID; }	
	public void setPeerID(PeerID peerID) { this.peerID = peerID; }
	public EndpointAddress getEndpointAddress() { return endpointAddress; }

	/** 
	  * State of this Initiator Binding
	  * @return TransportBindingMetric.CONNECTED, TransportBindingMetric.DISCONNECTED or TransportBindingMetric.FAILED
	  **/
	public String getInitiatorState() { return initiatorState; }
	/** 
	  * State of this Acceptor Binding
	  * @return TransportBindingMetric.CONNECTED, TransportBindingMetric.DISCONNECTED or TransportBindingMetric.FAILED
	  **/
	public String getAcceptorState() { return acceptorState; }
	/** Get the time that it entered the current state 
	  * @return transition time in ms since January 1, 1970, 00:00:00 GMT
	**/
	public long getInitiatorTransitionTime() { return initiatorTransitionTime; }
	/** Get the time that it entered the current state 
	  * @return transition time in ms since January 1, 1970, 00:00:00 GMT
	**/
	public long getAcceptorTransitionTime() { return acceptorTransitionTime; }

	public boolean isAcceptorConnected() { return (acceptorState != null) && acceptorState.equals(CONNECTED); }
	public boolean isInitiatorConnected() { return (initiatorState != null) && initiatorState.equals(CONNECTED); }

	public long getTimeAcceptorConnectionEstablished() { return isAcceptorConnected() ? acceptorTransitionTime : 0; }
	public long getTimeInitiatorConnectionEstablished() { return isInitiatorConnected() ? initiatorTransitionTime : 0; }
	
			 
	public int getAcceptorBytesReceived() { return acceptorBytesReceived; }
	public int getAcceptorBytesSent() { return acceptorBytesSent; }
	public int getAcceptorConnections() { return acceptorConnections; }
	public int getAcceptorConnectionsClosed() { return acceptorConnectionsClosed; }
	public int getAcceptorConnectionsDropped() { return acceptorConnectionsDropped; }
	public int getAcceptorConnectionsFailed() { return acceptorConnectionsFailed; }
	public int getAcceptorMessagesReceived() { return acceptorMessagesReceived; }
	public int getAcceptorMessagesSent() { return acceptorMessagesSent; }
	public long getAcceptorReceiveFailureProcessingTime() { return acceptorReceiveFailureProcessingTime; }
	public int getAcceptorReceiveFailures() { return acceptorReceiveFailures; }
	public long getAcceptorReceiveProcessingTime() { return acceptorReceiveProcessingTime; }
	public long getAcceptorSendFailureProcessingTime() { return acceptorSendFailureProcessingTime; }
	public int getAcceptorSendFailures() { return acceptorSendFailures; }
	public long getAcceptorSendProcessingTime() { return acceptorSendProcessingTime; }
	public long getAcceptorTimeToConnect() { return acceptorTimeToConnect; }
	public long getAcceptorTimeToFail() { return acceptorTimeToFail; }
	public int getInitiatorBytesReceived() { return initiatorBytesReceived; }
	public int getInitiatorBytesSent() { return initiatorBytesSent; }
	public int getInitiatorConnections() { return initiatorConnections; }
	public int getInitiatorConnectionsClosed() { return initiatorConnectionsClosed; }
	public int getInitiatorConnectionsDropped() { return initiatorConnectionsDropped; }
	public int getInitiatorConnectionsFailed() { return initiatorConnectionsFailed; }
	public int getInitiatorMessagesReceived() { return initiatorMessagesReceived; }
	public int getInitiatorMessagesSent() { return initiatorMessagesSent; }
	public long getInitiatorReceiveFailureProcessingTime() { return initiatorReceiveFailureProcessingTime; }
	public int getInitiatorReceiveFailures() { return initiatorReceiveFailures; }
	public long getInitiatorReceiveProcessingTime() { return initiatorReceiveProcessingTime; }
	public long getInitiatorSendFailureProcessingTime() { return initiatorSendFailureProcessingTime; }
	public int getInitiatorSendFailures() { return initiatorSendFailures; }
	public long getInitiatorSendProcessingTime() { return initiatorSendProcessingTime; }
	public long getInitiatorTimeToConnect() { return initiatorTimeToConnect; }
	public long getInitiatorTimeToFail() { return initiatorTimeToFail; }
	public int getNumPings() { return numPings; }
	public int getNumFailedPings() { return numFailedPings; }
	public long getPingTime() { return pingTime; }
	public long getPingFailedTime() { return pingFailedTime; }
	public int getNumPingsReceived() { return numPingsReceived; }

	public int getBytesReceived() { return acceptorBytesReceived + initiatorBytesReceived; }
	public int getBytesSent() { return acceptorBytesSent + initiatorBytesSent; }
	public int getConnections() { return acceptorConnections + initiatorConnections; }
	public int getConnectionsClosed() { return acceptorConnectionsClosed + initiatorConnectionsClosed; }
	public int getConnectionsDropped() { return acceptorConnectionsDropped + initiatorConnectionsDropped; }
	public int getConnectionsFailed() { return acceptorConnectionsFailed + initiatorConnectionsFailed; }
	public int getMessagesReceived() { return acceptorMessagesReceived + initiatorMessagesReceived; }
	public int getMessagesSent() { return acceptorMessagesSent + initiatorMessagesSent; }
	public long getReceiveFailureProcessingTime() { return acceptorReceiveFailureProcessingTime + initiatorReceiveFailureProcessingTime; }
	public int getReceiveFailures() { return acceptorReceiveFailures + initiatorReceiveFailures; }
	public long getReceiveProcessingTime() { return acceptorReceiveProcessingTime + initiatorReceiveProcessingTime; }
	public long getSendFailureProcessingTime() { return acceptorSendFailureProcessingTime + initiatorSendFailureProcessingTime; }
	public int getSendFailures() { return acceptorSendFailures + initiatorSendFailures; }
	public long getSendProcessingTime() { return acceptorSendProcessingTime + initiatorSendProcessingTime; }
	public long getTotalTimeConnected() { return acceptorTotalTimeConnected + initiatorTotalTimeConnected; }
	public long getTimeToConnect() { return acceptorTimeToConnect + initiatorTimeToConnect; }
	public long getTimeToFail() { return acceptorTimeToFail + initiatorTimeToFail; }


	public int getAveragePingTime() { return (int) ( (numPings != 0) ? (pingTime / numPings) : 0); }
	public int getAveragePingFailedTime() { return (int) ( (numFailedPings != 0) ? (pingFailedTime / numFailedPings) : 0); }

	public int getAverageAcceptorReceiveFailureProcessingTime() { return (int) ( (acceptorReceiveFailures != 0) ? (acceptorReceiveFailureProcessingTime / acceptorReceiveFailures) : 0); }
	public int getAverageAcceptorReceiveProcessingTime() { return (int) ( (acceptorMessagesReceived != 0) ? (acceptorReceiveProcessingTime / acceptorMessagesReceived) : 0); }
	public int getAverageAcceptorSendFailureProcessingTime() { return (int) ( (acceptorSendFailures != 0) ? (acceptorSendFailureProcessingTime / acceptorSendFailures) : 0); }
	public int getAverageAcceptorSendProcessingTime() { return (int) ( (acceptorMessagesSent != 0) ? (acceptorSendProcessingTime / acceptorMessagesSent) : 0); }
	public int getAverageAcceptorTimeToConnect() { return (int) ( (acceptorConnections != 0) ? (acceptorTimeToConnect / acceptorConnections) : 0); }
	public int getAverageAcceptorTimeToFail() { return (int) ( (acceptorConnectionsFailed != 0) ? (acceptorTimeToFail / acceptorConnectionsFailed) : 0); }

	public int getAverageInitiatorReceiveFailureProcessingTime() { return (int) ( (initiatorReceiveFailures != 0) ? (initiatorReceiveFailureProcessingTime / initiatorReceiveFailures) : 0); }
	public int getAverageInitiatorReceiveProcessingTime() { return (int) ( (initiatorMessagesReceived != 0) ? (initiatorReceiveProcessingTime / initiatorMessagesReceived) : 0); }
	public int getAverageInitiatorSendFailureProcessingTime() { return (int) ( (initiatorSendFailures != 0) ? (initiatorSendFailureProcessingTime / initiatorSendFailures) : 0); }
	public int getAverageInitiatorSendProcessingTime() { return (int) ( (initiatorMessagesSent != 0) ? (initiatorSendProcessingTime / initiatorMessagesSent) : 0); }
	public int getAverageInitiatorTimeToConnect() { return (int) ( (initiatorConnections != 0) ? (initiatorTimeToConnect / initiatorConnections) : 0); }
	public int getAverageInitiatorTimeToFail() { return (int) ( (initiatorConnectionsFailed != 0) ? (initiatorTimeToFail / initiatorConnectionsFailed) : 0); }

	public int getAverageReceiveFailureProcessingTime() { return (int) ( ((initiatorReceiveFailures + acceptorReceiveFailures) != 0) ? ((initiatorReceiveFailureProcessingTime + acceptorReceiveFailureProcessingTime) / (initiatorReceiveFailures + acceptorReceiveFailures)) : 0); }
	public int getAverageReceiveProcessingTime() { return (int) ( ((initiatorMessagesReceived + acceptorMessagesReceived) != 0) ? ((initiatorReceiveProcessingTime + acceptorReceiveProcessingTime) / (initiatorMessagesReceived + acceptorMessagesReceived)) : 0); }
	public int getAverageSendFailureProcessingTime() { return (int) ( ((initiatorSendFailures + acceptorSendFailures) != 0) ? ((initiatorSendFailureProcessingTime + acceptorSendFailureProcessingTime) / (initiatorSendFailures + acceptorSendFailures)) : 0); }