transport.java

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

    /**
     * Adds a {@link net.jxta.ext.config.Address}.
     *
     * @param       address     specified {@link net.jxta.ext.config.Address} value
     */
    
    public void addAddress(Address address) {
        addAddresses(Collections.singletonList(address));
    }

    /**
     * Adds a {@link java.util.List} of {@link net.jxta.ext.config.Address}.
     *
     * @param       addresses       {@link java.util.List} of {@link net.jxta.ext.config.Address}
     */
    
    public void addAddresses(List addresses) {
        if (addresses == null) {
            addresses = Collections.EMPTY_LIST;
        }

        if (this.addresses == null) {
            this.addresses = new ArrayList();
        }

        for (Iterator i = addresses.iterator(); i.hasNext(); ) {
            Address a = (Address)i.next();

            if (a != null &&
                ! this.addresses.contains(a)) {
                this.addresses.add(a);
            }
        }
    }

    /**
     * Removes the specified {@link net.jxta.ext.config.Address}
     *
     * @param       address     specified {@link net.jxta.ext.config.Address} value
     * @return                  removed {@link net.jxta.ext.config.Address}
     */
    
    public Address removeAddress(Address address) {
        Address a = null;

        if (this.addresses != null) {
            int i = this.addresses.indexOf(address);

            if (i > -1) {
                a = (Address)this.addresses.remove(i);

                if (this.addresses.size() == 0) {
                    this.addresses = null;
                }
            }
        }

        return a;
    }
    
    /**
     * Clears the {@link net.jxta.ext.config.Address}
     */

    public void clearAddresses() {
        if (this.addresses != null) {
            this.addresses.clear();

            this.addresses = null;
        }
    }

    /**
     * Accessor to the {@link net.jxta.ext.config.PublicAddress} as a {@link java.util.List}
     *
     * @return              {@link java.util.List} of {@link net.jxta.ext.config.PublicAddress}
     */
    
    public List getPublicAddresses() {
        return this.publicAddresses != null ?
               this.publicAddresses : Collections.EMPTY_LIST;
    }

    /**
     * Add a {@link net.jxta.ext.config.PublicAddress}.
     *
     * @param       address     specified {@link net.jxta.ext.config.PublicAddress} value
     */
    
    public void addPublicAddress(PublicAddress address) {
        addPublicAddresses(Collections.singletonList(address));
    }

    /**
     * Adds a {@link java.util.List} of {@link net.jxta.ext.config.PublicAddress}.
     *
     * @param       addresses       {@link java.util.List} of {@link net.jxta.ext.config.PublicAddress}
     */
    
    public void addPublicAddresses(List addresses) {
        if (addresses == null) {
            addresses = Collections.EMPTY_LIST;
        }

        if (this.publicAddresses == null) {
            this.publicAddresses = new ArrayList();
        }

        for (Iterator i = addresses.iterator(); i.hasNext(); ) {
            PublicAddress pa = (PublicAddress)i.next();

            if (pa != null &&
                ! this.publicAddresses.contains(pa)) {
                this.publicAddresses.add(pa);
            }
        }
    }

    /**
     * Clears and specifies a {@link net.jxta.ext.config.PublicAddress}
     *
     * @param       address     the specified {@link net.jxta.ext.config.PublicAddress}
     */
    
    public void setPublicAddress(PublicAddress address) {
        setPublicAddresses(Collections.singletonList(address));
    }

    /**
     * Clears and specifies a {@link java.util.List} of {@link net.jxta.ext.config.PublicAddress}
     *
     * @param       addresses       {@link java.util.List} of {@link net.jxta.ext.config.PublicAddress}
     */
    
    public void setPublicAddresses(List addresses) {
        clearPublicAddresses();
        addPublicAddresses(addresses);
    }

    /**
     * Removes the specified {@link net.jxta.ext.config.PublicAddress}
     *
     * @param       address     specified {@link net.jxta.ext.config.PublicAddress} value
     * @return                  removed {@link net.jxta.ext.config.PublicAddress} value
     */
    
    public Address removePublicAddress(PublicAddress address) {
        Address a = null;

        if (this.publicAddresses != null) {
            int i = this.publicAddresses.indexOf(address);

            if (i > -1) {
                a = (Address)this.publicAddresses.remove(i);
            }

            if (this.publicAddresses.size() == 0) {
                this.publicAddresses = null;
            }
        }

        return a;
    }

    /**
     * Clears the {@link net.jxta.ext.config.PublicAddress}
     */
    
    public void clearPublicAddresses() {
        if (this.publicAddresses != null) {
            this.publicAddresses.clear();

            this.publicAddresses = null;
        }
    }

    /**
     * Accessor to the enabled attribute.
     *
     * @return          enabled value
     */
    
    public boolean isProxy() {
        return this.isProxyEnabled;
    }

    /**
     * Specifies the enabled attribute.
     *
     * @param       isProxyEnabled      specified proxy enabled value
     */
    
    public void setProxy(boolean isProxyEnabled) {
        this.isProxyEnabled = isProxyEnabled;
    }

    /**
     * Accessor to the {@link net.jxta.ext.config.ProxyAddress}
     *
     * @return              returns the {@link net.jxta.ext.config.ProxyAddress}
     */
    
    public ProxyAddress getProxyAddress() {
        return this.proxy;
    }

    /**
     * Specifies the {@link net.jxta.ext.config.ProxyAddress}.
     *
     * @param       proxy       specified {@link net.jxta.ext.config.ProxyAddress}
     */
    
    public void setProxyAddress(ProxyAddress proxy) {
        this.proxy = proxy;
    }

    /**
     * String representation of this Transport.
     *
     * @return      String  String representation of this Transport
     */
    
    public boolean equals(Object o) {
        boolean b = true;
        
        if (o instanceof Transport) {
            Transport t = (Transport)o;
            
            b = b && (isEnabled() == t.isEnabled());
            b = b && (isIncoming() == t.isIncoming());
            b = b && (isOutgoing() == t.isOutgoing());
            
            boolean ab = false;
            
            for (Iterator ai = getAddresses().iterator(); ai.hasNext(); ) {
                Address a = (Address)ai.next();
                boolean abb = false;
                
                for (Iterator oai = t.getAddresses().iterator();
                    ! abb && oai.hasNext(); ) {
                    abb = a.equals((Address)oai.next());
                }
                
                ab = ab && abb;
            }
            
            b = b && ab;
            
            ab = false;
            
            for (Iterator ai = getPublicAddresses().iterator(); ai.hasNext(); ) {
                Address a = (Address)ai.next();
                boolean abb = false;
                
                for (Iterator oai = t.getPublicAddresses().iterator();
                    ! abb && oai.hasNext(); ) {
                    abb = a.equals((Address)oai.next());
                }
                
                ab = ab && abb;
            }
            
            b = b && ab;
            b = b && (isProxyEnabled == t.isProxy());
            b = b && (getProxyAddress() == t.getProxyAddress());
        }
        
        return b;
    }
}