yoko-core/src/main/java/org/apache/yoko/orb/OCI/IIOP/ConnectorInfo_impl.java

/*
 *  Licensed to the Apache Software Foundation (ASF) under one or more
*  contributor license agreements.  See the NOTICE file distributed with
*  this work for additional information regarding copyright ownership.
*  The ASF licenses this file to You under the Apache License, Version 2.0
*  (the "License"); you may not use this file except in compliance with
*  the License.  You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 *  Unless required by applicable law or agreed to in writing, software
 *  distributed under the License is distributed on an "AS IS" BASIS,
 *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 *  See the License for the specific language governing permissions and
 *  limitations under the License.
 */

package org.apache.yoko.orb.OCI.IIOP;

import static org.apache.yoko.orb.OCI.IIOP.Exceptions.*;

import org.apache.yoko.orb.OCI.ConnectCB;
import org.omg.CORBA.LocalObject;
import org.omg.IOP.TAG_INTERNET_IOP;

import java.net.InetAddress;
import java.net.UnknownHostException;
import java.util.*;

/**
 * Immutable memo of the endpoint details for a connection. The InetAddress
 * is looked up when first needed but never changed again. It is used in
 * hashcode() and equals().
 */
public final class ConnectorInfo_impl extends LocalObject implements ConnectorInfo {
    private final String host;
    private final short port;
    private volatile InetAddress addr; // initialised lazily

    //
    // All connect callback objects
    //
    private final List<ConnectCB> callbacks;

    // ------------------------------------------------------------------
    // Standard IDL to Java Mapping
    // ------------------------------------------------------------------

    public String id() {return PLUGIN_ID.value;}

    public int tag() {return TAG_INTERNET_IOP.value;}

    public String describe() {return String.format("id: %s%nremote address: %s:%d", PLUGIN_ID.value, remote_addr(), port);}

    public String remote_addr() {return getInetAddress().getHostAddress();}

    public short remote_port() {return port;}

    // ------------------------------------------------------------------
    // Yoko internal functions
    // Application programs must not use these functions directly
    // ------------------------------------------------------------------

    ConnectorInfo_impl(String host, int port, ConnectCB...cb) {
        this.host = host;
        this.port = (short)port;
        if (cb == null || cb.length == 0)
            callbacks = Collections.emptyList();
        else
            callbacks = Collections.unmodifiableList(new ArrayList<ConnectCB>(Arrays.asList(cb)));
    }

    String getHost() { return host; }

    int getPort() { return (char)port; }

    private InetAddress getInetAddress() {
        if (addr == null) synchronized (this) {
            if (addr == null) try {
                addr = InetAddress.getByName(host);
            } catch (UnknownHostException ex) {
                throw asCommFailure(ex);
            }
        }
        return addr;
    }

    synchronized void _OB_callConnectCB(org.apache.yoko.orb.OCI.TransportInfo info) {
        for (ConnectCB cb : callbacks) cb.connect_cb(info);
    }

    @Override
    public boolean equals(Object other) {
        if (this == other) return true;
        if (!!! (other instanceof ConnectorInfo_impl)) return false;

        ConnectorInfo_impl that = (ConnectorInfo_impl) other;

        return (this.port == that.port) && this.getInetAddress().equals(that.getInetAddress());
    }

    @Override
    public int hashCode() {return 31*port + getInetAddress().hashCode();}
}