sjero.net Git - linphone/blob - p2pproxy/dependencies-src/jxse-src-2.5/impl/src/net/jxta/impl/endpoint/transportMeter/TransportMetric.java

   1 /*
   2  * Copyright (c) 2001-2007 Sun Microsystems, Inc.  All rights reserved.
   3  *
   4  *  The Sun Project JXTA(TM) Software License
   5  *
   6  *  Redistribution and use in source and binary forms, with or without
   7  *  modification, are permitted provided that the following conditions are met:
   8  *
   9  *  1. Redistributions of source code must retain the above copyright notice,
  10  *     this list of conditions and the following disclaimer.
  11  *
  12  *  2. Redistributions in binary form must reproduce the above copyright notice,
  13  *     this list of conditions and the following disclaimer in the documentation
  14  *     and/or other materials provided with the distribution.
  15  *
  16  *  3. The end-user documentation included with the redistribution, if any, must
  17  *     include the following acknowledgment: "This product includes software
  18  *     developed by Sun Microsystems, Inc. for JXTA(TM) technology."
  19  *     Alternately, this acknowledgment may appear in the software itself, if
  20  *     and wherever such third-party acknowledgments normally appear.
  21  *
  22  *  4. The names "Sun", "Sun Microsystems, Inc.", "JXTA" and "Project JXTA" must
  23  *     not be used to endorse or promote products derived from this software
  24  *     without prior written permission. For written permission, please contact
  25  *     Project JXTA at http://www.jxta.org.
  26  *
  27  *  5. Products derived from this software may not be called "JXTA", nor may
  28  *     "JXTA" appear in their name, without prior written permission of Sun.
  29  *
  30  *  THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESSED OR IMPLIED WARRANTIES,
  31  *  INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND
  32  *  FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL SUN
  33  *  MICROSYSTEMS OR ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT,
  34  *  INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
  35  *  LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA,
  36  *  OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF
  37  *  LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
  38  *  NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE,
  39  *  EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
  40  *
  41  *  JXTA is a registered trademark of Sun Microsystems, Inc. in the United
  42  *  States and other countries.
  43  *
  44  *  Please see the license information page at :
  45  *  <http://www.jxta.org/project/www/license.html> for instructions on use of
  46  *  the license in source files.
  47  *
  48  *  ====================================================================
  49  *
  50  *  This software consists of voluntary contributions made by many individuals
  51  *  on behalf of Project JXTA. For more information on Project JXTA, please see
  52  *  http://www.jxta.org.
  53  *
  54  *  This license is based on the BSD license adopted by the Apache Foundation.
  55  */
  56
  57 package net.jxta.impl.endpoint.transportMeter;
  58
  59
  60 import net.jxta.endpoint.EndpointAddress;
  61
  62 import net.jxta.util.documentSerializable.DocumentSerializable;
  63 import net.jxta.util.documentSerializable.DocumentSerializableUtilities;
  64 import net.jxta.util.documentSerializable.DocumentSerializationException;
  65 import net.jxta.document.Element;
  66 import net.jxta.document.TextElement;
  67
  68 import java.util.Enumeration;
  69 import java.util.HashMap;
  70 import java.util.Iterator;
  71
  72
  73 /**
  74  * The Metric for a single Transport
  75  **/
  76 public class TransportMetric implements DocumentSerializable {
  77     private String protocol;
  78     private EndpointAddress endpointAddress;
  79     private HashMap<EndpointAddress, TransportBindingMetric> transportBindingMetrics = new HashMap<EndpointAddress, TransportBindingMetric>();
  80
  81     public TransportMetric(TransportMeter transportMeter) {
  82         this.endpointAddress = transportMeter.getEndpointAddress();
  83         this.protocol = transportMeter.getProtocol();
  84     }
  85
  86     public TransportMetric() {}
  87
  88     public TransportMetric(TransportMetric prototype) {
  89         this.endpointAddress = prototype.endpointAddress;
  90         this.protocol = prototype.protocol;
  91     }
  92
  93     @Override
  94     public boolean equals(Object obj) {
  95         if (obj instanceof TransportMetric) {
  96             TransportMetric other = (TransportMetric) obj;
  97
  98             return protocol.equals(other.protocol) && endpointAddress.equals(other.endpointAddress);
  99         } else {
 100             return false;
 101         }
 102     }
 103
 104     @Override
 105     public int hashCode() {
 106         return endpointAddress.hashCode();
 107     }
 108
 109     public EndpointAddress getEndpointAddress() {
 110         return endpointAddress;
 111     }
 112
 113     public String getProtocol() {
 114         return protocol;
 115     }
 116
 117     public synchronized void addTransportBindingMetric(TransportBindingMetric transportBindingMetric) {
 118         transportBindingMetrics.put(transportBindingMetric.getEndpointAddress(), transportBindingMetric);
 119     }
 120
 121     public TransportBindingMetric getTransportBindingMetric(EndpointAddress endpointAddress) {
 122         return transportBindingMetrics.get(endpointAddress);
 123     }
 124
 125     public TransportBindingMetric getTransportBindingMetric(TransportBindingMetric prototype) {
 126         return getTransportBindingMetric(prototype.getEndpointAddress());
 127     }
 128
 129     public Iterator<TransportBindingMetric> getTransportBindingMetrics() {
 130         return transportBindingMetrics.values().iterator();
 131     }
 132
 133     public int getTransportBindingMetricsCount() {
 134         return transportBindingMetrics.size();
 135     }
 136
 137     public void serializeTo(Element element) throws DocumentSerializationException {
 138         DocumentSerializableUtilities.addString(element, "endpointAddress", endpointAddress.toString());
 139         DocumentSerializableUtilities.addString(element, "protocol", protocol);
 140
 141         for (Iterator<TransportBindingMetric> i = getTransportBindingMetrics(); i.hasNext();) {
 142             TransportBindingMetric transportBindingMetric = i.next();
 143
 144             DocumentSerializableUtilities.addDocumentSerializable(element, "binding", transportBindingMetric);
 145         }
 146     }
 147
 148     public void initializeFrom(Element element) throws DocumentSerializationException {
 149         for (Enumeration e = element.getChildren(); e.hasMoreElements();) {
 150             Element childElement = (TextElement) e.nextElement();
 151             String tagName = (String) childElement.getKey();
 152
 153             if (tagName.equals("endpointAddress")) {
 154                 String endpointAddressString = DocumentSerializableUtilities.getString(childElement);
 155
 156                 endpointAddress = new EndpointAddress(endpointAddressString);
 157             } else if (tagName.equals("protocol")) {
 158                 protocol = DocumentSerializableUtilities.getString(childElement);
 159             } else if (tagName.equals("binding")) {
 160                 TransportBindingMetric transportBindingMetric = (TransportBindingMetric) DocumentSerializableUtilities.getDocumentSerializable(
 161                         childElement, TransportBindingMetric.class);
 162
 163                 transportBindingMetrics.put(transportBindingMetric.getEndpointAddress(), transportBindingMetric);
 164             }
 165         }
 166     }
 167
 168     void mergeMetrics(TransportMetric otherTransportMetric) {
 169         for (Iterator<TransportBindingMetric> i = otherTransportMetric.getTransportBindingMetrics(); i.hasNext();) {
 170             TransportBindingMetric otherTransportBindingMetric = i.next();
 171             TransportBindingMetric transportBindingMetric = getTransportBindingMetric(
 172                     otherTransportBindingMetric.getEndpointAddress());
 173
 174             if (transportBindingMetric == null) {
 175                 transportBindingMetric = new TransportBindingMetric(otherTransportBindingMetric);
 176                 addTransportBindingMetric(transportBindingMetric);
 177             }
 178
 179             transportBindingMetric.mergeMetrics(otherTransportBindingMetric);
 180         }
 181
 182     }
 183 }