transportbindingmetric.java

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

            acceptorReceiveFailureProcessingTime += time;
            acceptorBytesReceived += size;
        }
    }

    void dataSent(boolean initiator, long size) {
        if (initiator) {
            initiatorBytesSent += size;
        } else {
            acceptorBytesSent += size;
        }
    }

    void sendFailure(boolean initiator, Message message, long time, long size) {
        if (initiator) {
            initiatorSendFailures++;
            initiatorSendFailureProcessingTime += time;
            initiatorBytesSent += size;
        } else {
            acceptorSendFailures++;
            acceptorSendFailureProcessingTime += time;
            acceptorBytesSent += size;
        }
    }

    void messageSent(boolean initiator, Message message, long time, long size) {
        if (initiator) {
            initiatorMessagesSent++;
            initiatorSendProcessingTime += time;
            initiatorBytesSent += size;
        } else {
            acceptorMessagesSent++;
            acceptorSendProcessingTime += time;
            acceptorBytesSent += size;
        }
    }

    public void mergeMetrics(TransportBindingMetric other) {
        peerID = other.peerID;

        if (other.initiatorState != null) {
            initiatorState = other.initiatorState;
        }

        if (other.initiatorTransitionTime != 0) {
            initiatorTransitionTime = other.initiatorTransitionTime;
        }

        if (other.acceptorState != null) {
            acceptorState = other.acceptorState;
        }

        if (other.initiatorTransitionTime != 0) {
            acceptorTransitionTime = other.acceptorTransitionTime;
        }

        acceptorBytesReceived += other.acceptorBytesReceived;
        acceptorBytesSent += other.acceptorBytesSent;
        acceptorConnections += other.acceptorConnections;
        acceptorConnectionsClosed += other.acceptorConnectionsClosed;
        acceptorConnectionsDropped += other.acceptorConnectionsDropped;
        acceptorConnectionsFailed += other.acceptorConnectionsFailed;
        acceptorMessagesReceived += other.acceptorMessagesReceived;
        acceptorMessagesSent += other.acceptorMessagesSent;
        acceptorReceiveFailureProcessingTime += other.acceptorReceiveFailureProcessingTime;
        acceptorReceiveFailures += other.acceptorReceiveFailures;
        acceptorReceiveProcessingTime += other.acceptorReceiveProcessingTime;
        acceptorSendFailureProcessingTime += other.acceptorSendFailureProcessingTime;
        acceptorSendFailures += other.acceptorSendFailures;
        acceptorSendProcessingTime += other.acceptorSendProcessingTime;
        acceptorTotalTimeConnected += other.acceptorTotalTimeConnected;
        acceptorTimeToConnect += other.acceptorTimeToConnect;
        acceptorTimeToFail += other.acceptorTimeToFail;
        initiatorBytesReceived += other.initiatorBytesReceived;
        initiatorBytesSent += other.initiatorBytesSent;
        initiatorTotalTimeConnected += other.initiatorTotalTimeConnected;
        initiatorConnections += other.initiatorConnections;
        initiatorConnectionsClosed += other.initiatorConnectionsClosed;
        initiatorConnectionsDropped += other.initiatorConnectionsDropped;
        initiatorConnectionsFailed += other.initiatorConnectionsFailed;
        initiatorMessagesReceived += other.initiatorMessagesReceived;
        initiatorMessagesSent += other.initiatorMessagesSent;
        initiatorReceiveFailureProcessingTime += other.initiatorReceiveFailureProcessingTime;
        initiatorReceiveFailures += other.initiatorReceiveFailures;
        initiatorReceiveProcessingTime += other.initiatorReceiveProcessingTime;
        initiatorSendFailureProcessingTime += other.initiatorSendFailureProcessingTime;
        initiatorSendFailures += other.initiatorSendFailures;
        initiatorSendProcessingTime += other.initiatorSendProcessingTime;
        initiatorTimeToConnect += other.initiatorTimeToConnect;
        initiatorTimeToFail += other.initiatorTimeToFail;
        numPings += other.numPings;
        numFailedPings += other.numFailedPings;
        pingTime += other.pingTime;
        pingFailedTime += other.pingFailedTime;
        numPingsReceived += other.numPingsReceived;

    }

    public void serializeTo(Element element) throws DocumentSerializationException {

        DocumentSerializableUtilities.addString(element, "peerID", peerID.toString());
        DocumentSerializableUtilities.addString(element, "endpointAddress", endpointAddress.toString());

        if (initiatorState != null) {
            DocumentSerializableUtilities.addString(element, "initiatorState", initiatorState);
        }
        if (initiatorTransitionTime != 0) {
            DocumentSerializableUtilities.addLong(element, "initiatorTransitionTime", initiatorTransitionTime);
        }

        if (acceptorState != null) {
            DocumentSerializableUtilities.addString(element, "acceptorState", acceptorState);
        }
        if (acceptorTransitionTime != 0) {
            DocumentSerializableUtilities.addLong(element, "acceptorTransitionTime", acceptorTransitionTime);
        }

        if (acceptorBytesReceived != 0) {
            DocumentSerializableUtilities.addInt(element, "acceptorBytesReceived", acceptorBytesReceived);
        }

        if (acceptorBytesSent != 0) {
            DocumentSerializableUtilities.addInt(element, "acceptorBytesSent", acceptorBytesSent);
        }

        if (acceptorConnections != 0) {
            DocumentSerializableUtilities.addInt(element, "acceptorConnections", acceptorConnections);
        }

        if (acceptorConnectionsClosed != 0) {
            DocumentSerializableUtilities.addInt(element, "acceptorConnectionsClosed", acceptorConnectionsClosed);
        }

        if (acceptorConnectionsDropped != 0) {
            DocumentSerializableUtilities.addInt(element, "acceptorConnectionsDropped", acceptorConnectionsDropped);
        }

        if (acceptorConnectionsFailed != 0) {
            DocumentSerializableUtilities.addInt(element, "acceptorConnectionsFailed", acceptorConnectionsFailed);
        }

        if (acceptorMessagesReceived != 0) {
            DocumentSerializableUtilities.addInt(element, "acceptorMessagesReceived", acceptorMessagesReceived);
        }

        if (acceptorMessagesSent != 0) {
            DocumentSerializableUtilities.addInt(element, "acceptorMessagesSent", acceptorMessagesSent);
        }

        if (acceptorReceiveFailureProcessingTime != 0) {
            DocumentSerializableUtilities.addLong(element, "acceptorReceiveFailureProcessingTime"
                    ,
                    acceptorReceiveFailureProcessingTime);
        }

        if (acceptorReceiveFailures != 0) {
            DocumentSerializableUtilities.addInt(element, "acceptorReceiveFailures", acceptorReceiveFailures);
        }

        if (acceptorReceiveProcessingTime != 0) {
            DocumentSerializableUtilities.addLong(element, "acceptorReceiveProcessingTime", acceptorReceiveProcessingTime);
        }

        if (acceptorSendFailureProcessingTime != 0) {
            DocumentSerializableUtilities.addLong(element, "acceptorSendFailureProcessingTime", acceptorSendFailureProcessingTime);
        }

        if (acceptorSendFailures != 0) {
            DocumentSerializableUtilities.addInt(element, "acceptorSendFailures", acceptorSendFailures);
        }

        if (acceptorSendProcessingTime != 0) {
            DocumentSerializableUtilities.addLong(element, "acceptorSendProcessingTime", acceptorSendProcessingTime);
        }

        if (acceptorTotalTimeConnected != 0) {
            DocumentSerializableUtilities.addLong(element, "acceptorTotalTimeConnected", acceptorTotalTimeConnected);
        }

        if (acceptorTimeToConnect != 0) {
            DocumentSerializableUtilities.addLong(element, "acceptorTimeToConnect", acceptorTimeToConnect);
        }

        if (acceptorTimeToFail != 0) {
            DocumentSerializableUtilities.addLong(element, "acceptorTimeToFail", acceptorTimeToFail);
        }

        if (initiatorBytesReceived != 0) {
            DocumentSerializableUtilities.addInt(element, "initiatorBytesReceived", initiatorBytesReceived);
        }

        if (initiatorBytesSent != 0) {
            DocumentSerializableUtilities.addInt(element, "initiatorBytesSent", initiatorBytesSent);
        }

        if (initiatorTotalTimeConnected != 0) {
            DocumentSerializableUtilities.addLong(element, "initiatorTotalTimeConnected", initiatorTotalTimeConnected);
        }

        if (initiatorConnections != 0) {
            DocumentSerializableUtilities.addInt(element, "initiatorConnections", initiatorConnections);
        }

        if (initiatorConnectionsClosed != 0) {
            DocumentSerializableUtilities.addInt(element, "initiatorConnectionsClosed", initiatorConnectionsClosed);
        }

        if (initiatorConnectionsDropped != 0) {
            DocumentSerializableUtilities.addInt(element, "initiatorConnectionsDropped", initiatorConnectionsDropped);
        }

        if (initiatorConnectionsFailed != 0) {
            DocumentSerializableUtilities.addInt(element, "initiatorConnectionsFailed", initiatorConnectionsFailed);
        }

        if (initiatorMessagesReceived != 0) {
            DocumentSerializableUtilities.addInt(element, "initiatorMessagesReceived", initiatorMessagesReceived);
        }

        if (initiatorMessagesSent != 0) {
            DocumentSerializableUtilities.addInt(element, "initiatorMessagesSent", initiatorMessagesSent);
        }

        if (initiatorReceiveFailureProcessingTime != 0) {
            DocumentSerializableUtilities.addLong(element, "initiatorReceiveFailureProcessingTime"
                    ,
                    initiatorReceiveFailureProcessingTime);
        }

        if (initiatorReceiveFailures != 0) {
            DocumentSerializableUtilities.addInt(element, "initiatorReceiveFailures", initiatorReceiveFailures);
        }

        if (initiatorReceiveProcessingTime != 0) {
            DocumentSerializableUtilities.addLong(element, "initiatorReceiveProcessingTime", initiatorReceiveProcessingTime);
        }

        if (initiatorSendFailureProcessingTime != 0) {
            DocumentSerializableUtilities.addLong(element, "initiatorSendFailureProcessingTime"
                    ,
                    initiatorSendFailureProcessingTime);
        }

        if (initiatorSendFailures != 0) {
            DocumentSerializableUtilities.addInt(element, "initiatorSendFailures", initiatorSendFailures);
        }

        if (initiatorSendProcessingTime != 0) {
            DocumentSerializableUtilities.addLong(element, "initiatorSendProcessingTime", initiatorSendProcessingTime);
        }

        if (initiatorTimeToConnect != 0) {
            DocumentSerializableUtilities.addLong(element, "initiatorTimeToConnect", initiatorTimeToConnect);
        }

        if (initiatorTimeToFail != 0) {
            DocumentSerializableUtilities.addLong(element, "initiatorTimeToFail", initiatorTimeToFail);
        }

        if (numPings != 0) {
            DocumentSerializableUtilities.addInt(element, "numPings", numPings);
        }

        if (numFailedPings != 0) {
            DocumentSerializableUtilities.addInt(element, "numFailedPings", numFailedPings);
        }

        if (pingTime != 0) {
            DocumentSerializableUtilities.addLong(element, "pingTime", pingTime);
        }

        if (pingFailedTime != 0) {
            DocumentSerializableUtilities.addLong(element, "pingFailedTime", pingFailedTime);
        }

        if (initiatorTimeToFail != 0) {
            DocumentSerializableUtilities.addInt(element, "numPingsReceived", numPingsReceived);
        }

    }

    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("peerID")) {
                String peerIdString = DocumentSerializableUtilities.getString(childElement);

                peerID = MetricUtilities.getPeerIdFromString(peerIdString);
            }
            if (tagName.equals("endpointAddress")) {
                String endpointAddressString = DocumentSerializableUtilities.getString(childElement);

                endpointAddress = new EndpointAddress(endpointAddressString);
            } else if (tagName.equals("acceptorBytesReceived")) {
                acceptorBytesReceived = DocumentSerializableUtilities.getInt(childElement);
            } else if (tagName.equals("acceptorBytesSent")) {
                acceptorBytesSent = DocumentSerializableUtilities.getInt(childElement);
            } else if (tagName.equals("acceptorConnections")) {
                acceptorConnections = DocumentSerializableUtilities.getInt(childElement);
            } else if (tagName.equals("acceptorConnectionsClosed")) {
                acceptorConnectionsClosed = DocumentSerializableUtilities.getInt(childElement);
            } else if (tagName.equals("acceptorConnectionsDropped")) {
                acceptorConnectionsDropped = DocumentSerializableUtilities.getInt(childElement);
            } else if (tagName.equals("acceptorConnectionsFailed")) {
                acceptorConnectionsFailed = DocumentSerializableUtilities.getInt(childElement);
            } else if (tagName.equals("acceptorMessagesReceived")) {
                acceptorMessagesReceived = DocumentSerializableUtilities.getInt(childElement);
            } else if (tagName.equals("acceptorMessagesSent")) {
                acceptorMessagesSent = DocumentSerializableUtilities.getInt(childElement);
            } else if (tagName.equals("acceptorReceiveFailureProcessingTime")) {
                acceptorReceiveFailureProcessingTime = DocumentSerializableUtilities.getLong(childElement);
            } else if (tagName.equals("acceptorReceiveFailures")) {
                acceptorReceiveFailures = DocumentSerializableUtilities.getInt(childElement);
            } else if (tagName.equals("acceptorReceiveProcessingTime")) {
                acceptorReceiveProcessingTime = DocumentSerializableUtilities.getLong(childElement);
            } else if (tagName.equals("acceptorSendFailureProcessingTime")) {
                acceptorSendFailureProcessingTime = DocumentSerializableUtilities.getLong(childElement);
            } else if (tagName.equals("acceptorSendFailures")) {
                acceptorSendFailures = DocumentSerializableUtilities.getInt(childElement);
            } else if (tagName.equals("acceptorSendProcessingTime")) {
                acceptorSendProcessingTime = DocumentSerializableUtilities.getLong(childElement);
            } else if (tagName.equals("acceptorTotalTimeConnected")) {
                acceptorTotalTimeConnected = DocumentSerializableUtilities.getLong(childElement);
            } else if (tagName.equals("acceptorTimeToConnect")) {
                acceptorTimeToConnect = DocumentSerializableUtilities.getLong(childElement);
            } else if (tagName.equals("acceptorTimeToFail")) {
                acceptorTimeToFail = DocumentSerializableUtilities.getLong(childElement);
            } else if (tagName.equals("initiatorBytesReceived")) {
                initiatorBytesReceived = DocumentSerializableUtilities.getInt(childElement);
            } else if (tagName.equals("initiatorBytesSent")) {
                initiatorBytesSent = DocumentSerializableUtilities.getInt(childElement);
            } else if (tagName.equals("initiatorTotalTimeConnected")) {
                initiatorTotalTimeConnected = DocumentSerializableUtilities.getLong(childElement);
            } else if (tagName.equals("initiatorConnections")) {
                initiatorConnections = DocumentSerializableUtilities.getInt(childElement);
            } else if (tagName.equals("initiatorConnectionsClosed")) {
                initiatorConnectionsClosed = DocumentSerializableUtilities.getInt(childElement);
            } else if (tagName.equals("initiatorConnectionsDropped")) {
                initiatorConnectionsDropped = DocumentSerializableUtilities.getInt(childElement);
            } else if (tagName.equals("initiatorConnectionsFailed")) {
                initiatorConnectionsFailed = DocumentSerializableUtilities.getInt(childElement);
            } else if (tagName.equals("initiatorMessagesReceived")) {
                initiatorMessagesReceived = DocumentSerializableUtilities.getInt(childElement);
            } else if (tagName.equals("initiatorMessagesSent")) {
                initiatorMessagesSent = DocumentSerializableUtilities.getInt(childElement);
            } else if (tagName.equals("initiatorReceiveFailureProcessingTime")) {
                initiatorReceiveFailureProcessingTime = DocumentSerializableUtilities.getLong(childElement);
            } else if (tagName.equals("initiatorReceiveFailures")) {
                initiatorReceiveFailures = DocumentSerializableUtilities.getInt(childElement);
            } else if (tagName.equals("initiatorReceiveProcessingTime")) {
                initiatorReceiveProcessingTime = DocumentSerializableUtilities.getLong(childElement);
            } else if (tagName.equals("initiatorSendFailureProcessingTime")) {
                initiatorSendFailureProcessingTime = DocumentSerializableUtilities.getLong(childElement);
            } else if (tagName.equals("initiatorSendFailures")) {
                initiatorSendFailures = DocumentSerializableUtilities.getInt(childElement);
            } else if (tagName.equals("initiatorSendProcessingTime")) {
                initiatorSendProcessingTime = DocumentSerializableUtilities.getLong(childElement);
            } else if (tagName.equals("initiatorTimeToConnect")) {
                initiatorTimeToConnect = DocumentSerializableUtilities.getLong(childElement);
            } else if (tagName.equals("initiatorTimeToFail")) {
                initiatorTimeToFail = DocumentSerializableUtilities.getLong(childElement);
            } else if (tagName.equals("numPingsReceived")) {
                numPingsReceived = DocumentSerializableUtilities.getInt(childElement);
            } else if (tagName.equals("numPings")) {
                numPings = DocumentSerializableUtilities.getInt(childElement);
            } else if (tagName.equals("numFailedPings")) {
                numFailedPings = DocumentSerializableUtilities.getInt(childElement);
            } else if (tagName.equals("pingTime")) {
                pingTime = DocumentSerializableUtilities.getLong(childElement);
            } else if (tagName.equals("pingFailedTime")) {
                pingFailedTime = DocumentSerializableUtilities.getLong(childElement);
            }
        }
    }
}