java.nio.channels.NotYetBoundException#com.sun.nio.sctp.SctpMultiChannel源码实例Demo

下面列出了java.nio.channels.NotYetBoundException#com.sun.nio.sctp.SctpMultiChannel 实例代码，或者点击链接到github查看源代码，也可以在右侧发表评论。

源代码1 项目： jdk8u_jdk 文件： SctpMultiChannelImpl.java

@Override
public <T> SctpMultiChannel setOption(SctpSocketOption<T> name,
                                      T value,
                                      Association association)
        throws IOException {
    if (name == null)
        throw new NullPointerException();
    if (!(supportedOptions().contains(name)))
        throw new UnsupportedOperationException("'" + name + "' not supported");

    synchronized (stateLock) {
        if (association != null && (name.equals(SCTP_PRIMARY_ADDR) ||
                name.equals(SCTP_SET_PEER_PRIMARY_ADDR))) {
            checkAssociation(association);
        }
        if (!isOpen())
            throw new ClosedChannelException();

        int assocId = association == null ? 0 : association.associationID();
        SctpNet.setSocketOption(fdVal, name, value, assocId);
    }
    return this;
}

源代码2 项目： openjdk-jdk8u-backup 文件： SctpMultiChannelImpl.java

@Override
public <T> SctpMultiChannel setOption(SctpSocketOption<T> name,
                                      T value,
                                      Association association)
        throws IOException {
    if (name == null)
        throw new NullPointerException();
    if (!(supportedOptions().contains(name)))
        throw new UnsupportedOperationException("'" + name + "' not supported");

    synchronized (stateLock) {
        if (association != null && (name.equals(SCTP_PRIMARY_ADDR) ||
                name.equals(SCTP_SET_PEER_PRIMARY_ADDR))) {
            checkAssociation(association);
        }
        if (!isOpen())
            throw new ClosedChannelException();

        int assocId = association == null ? 0 : association.associationID();
        SctpNet.setSocketOption(fdVal, name, value, assocId);
    }
    return this;
}

源代码3 项目： TencentKona-8 文件： SctpMultiChannelImpl.java

@Override
public <T> SctpMultiChannel setOption(SctpSocketOption<T> name,
                                      T value,
                                      Association association)
        throws IOException {
    if (name == null)
        throw new NullPointerException();
    if (!(supportedOptions().contains(name)))
        throw new UnsupportedOperationException("'" + name + "' not supported");

    synchronized (stateLock) {
        if (association != null && (name.equals(SCTP_PRIMARY_ADDR) ||
                name.equals(SCTP_SET_PEER_PRIMARY_ADDR))) {
            checkAssociation(association);
        }
        if (!isOpen())
            throw new ClosedChannelException();

        int assocId = association == null ? 0 : association.associationID();
        SctpNet.setSocketOption(fdVal, name, value, assocId);
    }
    return this;
}

源代码4 项目： openjdk-jdk9 文件： SctpMultiChannelImpl.java

@Override
public <T> SctpMultiChannel setOption(SctpSocketOption<T> name,
                                      T value,
                                      Association association)
        throws IOException {
    if (name == null)
        throw new NullPointerException();
    if (!(supportedOptions().contains(name)))
        throw new UnsupportedOperationException("'" + name + "' not supported");

    synchronized (stateLock) {
        if (association != null && (name.equals(SCTP_PRIMARY_ADDR) ||
                name.equals(SCTP_SET_PEER_PRIMARY_ADDR))) {
            checkAssociation(association);
        }
        if (!isOpen())
            throw new ClosedChannelException();

        int assocId = association == null ? 0 : association.associationID();
        SctpNet.setSocketOption(fdVal, name, value, assocId);
    }
    return this;
}

源代码5 项目： jdk8u-dev-jdk 文件： SctpMultiChannelImpl.java

@Override
public <T> SctpMultiChannel setOption(SctpSocketOption<T> name,
                                      T value,
                                      Association association)
        throws IOException {
    if (name == null)
        throw new NullPointerException();
    if (!(supportedOptions().contains(name)))
        throw new UnsupportedOperationException("'" + name + "' not supported");

    synchronized (stateLock) {
        if (association != null && (name.equals(SCTP_PRIMARY_ADDR) ||
                name.equals(SCTP_SET_PEER_PRIMARY_ADDR))) {
            checkAssociation(association);
        }
        if (!isOpen())
            throw new ClosedChannelException();

        int assocId = association == null ? 0 : association.associationID();
        SctpNet.setSocketOption(fdVal, name, value, assocId);
    }
    return this;
}

源代码6 项目： openjdk-jdk8u 文件： SctpMultiChannelImpl.java

@Override
public <T> SctpMultiChannel setOption(SctpSocketOption<T> name,
                                      T value,
                                      Association association)
        throws IOException {
    if (name == null)
        throw new NullPointerException();
    if (!(supportedOptions().contains(name)))
        throw new UnsupportedOperationException("'" + name + "' not supported");

    synchronized (stateLock) {
        if (association != null && (name.equals(SCTP_PRIMARY_ADDR) ||
                name.equals(SCTP_SET_PEER_PRIMARY_ADDR))) {
            checkAssociation(association);
        }
        if (!isOpen())
            throw new ClosedChannelException();

        int assocId = association == null ? 0 : association.associationID();
        SctpNet.setSocketOption(fdVal, name, value, assocId);
    }
    return this;
}

源代码7 项目： hottub 文件： SctpMultiChannelImpl.java

@Override
public <T> SctpMultiChannel setOption(SctpSocketOption<T> name,
                                      T value,
                                      Association association)
        throws IOException {
    if (name == null)
        throw new NullPointerException();
    if (!(supportedOptions().contains(name)))
        throw new UnsupportedOperationException("'" + name + "' not supported");

    synchronized (stateLock) {
        if (association != null && (name.equals(SCTP_PRIMARY_ADDR) ||
                name.equals(SCTP_SET_PEER_PRIMARY_ADDR))) {
            checkAssociation(association);
        }
        if (!isOpen())
            throw new ClosedChannelException();

        int assocId = association == null ? 0 : association.associationID();
        SctpNet.setSocketOption(fdVal, name, value, assocId);
    }
    return this;
}

源代码8 项目： jdk8u-dev-jdk 文件： SctpMultiChannelImpl.java

@Override
public SctpMultiChannel bind(SocketAddress local, int backlog)
        throws IOException {
    synchronized (receiveLock) {
        synchronized (sendLock) {
            synchronized (stateLock) {
                ensureOpen();
                if (isBound())
                    SctpNet.throwAlreadyBoundException();
                InetSocketAddress isa = (local == null) ?
                    new InetSocketAddress(0) : Net.checkAddress(local);

                SecurityManager sm = System.getSecurityManager();
                if (sm != null)
                    sm.checkListen(isa.getPort());
                Net.bind(fd, isa.getAddress(), isa.getPort());

                InetSocketAddress boundIsa = Net.localAddress(fd);
                port = boundIsa.getPort();
                localAddresses.add(isa);
                if (isa.getAddress().isAnyLocalAddress())
                    wildcard = true;

                SctpNet.listen(fdVal, backlog < 1 ? 50 : backlog);
            }
        }
    }
    return this;
}

源代码9 项目： dragonwell8_jdk 文件： Send.java

public Server() throws IOException {
    serverChannel = SctpMultiChannel.open().bind(null);
    java.util.Set<SocketAddress> addrs = serverChannel.getAllLocalAddresses();
    if (addrs.isEmpty())
        debug("addrs should not be empty");

    serverAddr = (InetSocketAddress) addrs.iterator().next();
}

源代码10 项目： dragonwell8_jdk 文件： SocketOptionTests.java

<T> void optionalSupport(SctpMultiChannel smc, SctpSocketOption<T> name,
        T value) {
    try {
        smc.setOption(name, value, null);
        checkOption(smc, name, value);
    } catch (IOException e) {
        /* Informational only, not all options have native support */
        out.println(name + " not supported. " + e);
    }
}

源代码11 项目： jdk8u-dev-jdk 文件： SocketOptionTests.java

<T> void optionalSupport(SctpMultiChannel smc, SctpSocketOption<T> name,
        T value) {
    try {
        smc.setOption(name, value, null);
        checkOption(smc, name, value);
    } catch (IOException e) {
        /* Informational only, not all options have native support */
        out.println(name + " not supported. " + e);
    }
}

源代码12 项目： openjdk-jdk8u 文件： Send.java

public Server() throws IOException {
    serverChannel = SctpMultiChannel.open().bind(null);
    java.util.Set<SocketAddress> addrs = serverChannel.getAllLocalAddresses();
    if (addrs.isEmpty())
        debug("addrs should not be empty");

    serverAddr = (InetSocketAddress) addrs.iterator().next();
}

源代码13 项目： openjdk-8-source 文件： SctpMultiChannelImpl.java

@Override
public SctpMultiChannel bind(SocketAddress local, int backlog)
        throws IOException {
    synchronized (receiveLock) {
        synchronized (sendLock) {
            synchronized (stateLock) {
                ensureOpen();
                if (isBound())
                    SctpNet.throwAlreadyBoundException();
                InetSocketAddress isa = (local == null) ?
                    new InetSocketAddress(0) : Net.checkAddress(local);

                SecurityManager sm = System.getSecurityManager();
                if (sm != null)
                    sm.checkListen(isa.getPort());
                Net.bind(fd, isa.getAddress(), isa.getPort());

                InetSocketAddress boundIsa = Net.localAddress(fd);
                port = boundIsa.getPort();
                localAddresses.add(isa);
                if (isa.getAddress().isAnyLocalAddress())
                    wildcard = true;

                SctpNet.listen(fdVal, backlog < 1 ? 50 : backlog);
            }
        }
    }
    return this;
}

源代码14 项目： openjdk-8 文件： SocketOptionTests.java

<T> void optionalSupport(SctpMultiChannel smc, SctpSocketOption<T> name,
        T value) {
    try {
        smc.setOption(name, value, null);
        checkOption(smc, name, value);
    } catch (IOException e) {
        /* Informational only, not all options have native support */
        out.println(name + " not supported. " + e);
    }
}

源代码15 项目： openjdk-jdk9 文件： SctpMultiChannelImpl.java

@Override
public SctpMultiChannel bind(SocketAddress local, int backlog)
        throws IOException {
    synchronized (receiveLock) {
        synchronized (sendLock) {
            synchronized (stateLock) {
                ensureOpen();
                if (isBound())
                    SctpNet.throwAlreadyBoundException();
                InetSocketAddress isa = (local == null) ?
                    new InetSocketAddress(0) : Net.checkAddress(local);

                SecurityManager sm = System.getSecurityManager();
                if (sm != null)
                    sm.checkListen(isa.getPort());
                Net.bind(fd, isa.getAddress(), isa.getPort());

                InetSocketAddress boundIsa = Net.localAddress(fd);
                port = boundIsa.getPort();
                localAddresses.add(isa);
                if (isa.getAddress().isAnyLocalAddress())
                    wildcard = true;

                SctpNet.listen(fdVal, backlog < 1 ? 50 : backlog);
            }
        }
    }
    return this;
}

源代码16 项目： hottub 文件： SctpMultiChannelImpl.java

@Override
public SctpMultiChannel bind(SocketAddress local, int backlog)
        throws IOException {
    synchronized (receiveLock) {
        synchronized (sendLock) {
            synchronized (stateLock) {
                ensureOpen();
                if (isBound())
                    SctpNet.throwAlreadyBoundException();
                InetSocketAddress isa = (local == null) ?
                    new InetSocketAddress(0) : Net.checkAddress(local);

                SecurityManager sm = System.getSecurityManager();
                if (sm != null)
                    sm.checkListen(isa.getPort());
                Net.bind(fd, isa.getAddress(), isa.getPort());

                InetSocketAddress boundIsa = Net.localAddress(fd);
                port = boundIsa.getPort();
                localAddresses.add(isa);
                if (isa.getAddress().isAnyLocalAddress())
                    wildcard = true;

                SctpNet.listen(fdVal, backlog < 1 ? 50 : backlog);
            }
        }
    }
    return this;
}

源代码17 项目： openjdk-jdk8u-backup 文件： SctpMultiChannelImpl.java

@Override
public SctpMultiChannel shutdown(Association association)
        throws IOException {
    synchronized (stateLock) {
        checkAssociation(association);
        if (!isOpen())
            throw new ClosedChannelException();

        SctpNet.shutdown(fdVal, association.associationID());
    }
    return this;
}

源代码18 项目： openjdk-8 文件： SctpMultiChannelImpl.java

@Override
public SctpMultiChannel shutdown(Association association)
        throws IOException {
    synchronized (stateLock) {
        checkAssociation(association);
        if (!isOpen())
            throw new ClosedChannelException();

        SctpNet.shutdown(fdVal, association.associationID());
    }
    return this;
}

源代码19 项目： jdk8u_jdk 文件： SctpMultiChannelImpl.java

@Override
public SctpMultiChannel bind(SocketAddress local, int backlog)
        throws IOException {
    synchronized (receiveLock) {
        synchronized (sendLock) {
            synchronized (stateLock) {
                ensureOpen();
                if (isBound())
                    SctpNet.throwAlreadyBoundException();
                InetSocketAddress isa = (local == null) ?
                    new InetSocketAddress(0) : Net.checkAddress(local);

                SecurityManager sm = System.getSecurityManager();
                if (sm != null)
                    sm.checkListen(isa.getPort());
                Net.bind(fd, isa.getAddress(), isa.getPort());

                InetSocketAddress boundIsa = Net.localAddress(fd);
                port = boundIsa.getPort();
                localAddresses.add(isa);
                if (isa.getAddress().isAnyLocalAddress())
                    wildcard = true;

                SctpNet.listen(fdVal, backlog < 1 ? 50 : backlog);
            }
        }
    }
    return this;
}

源代码20 项目： jdk8u60 文件： Send.java

public Server() throws IOException {
    serverChannel = SctpMultiChannel.open().bind(null);
    java.util.Set<SocketAddress> addrs = serverChannel.getAllLocalAddresses();
    if (addrs.isEmpty())
        debug("addrs should not be empty");

    serverAddr = (InetSocketAddress) addrs.iterator().next();
}

源代码21 项目： openjdk-jdk9 文件： Branch.java

public Server() throws IOException {
    serverChannel = SctpMultiChannel.open().bind(null);
    java.util.Set<SocketAddress> addrs = serverChannel.getAllLocalAddresses();
    if (addrs.isEmpty())
        debug("addrs should not be empty");

    serverAddr = (InetSocketAddress) addrs.iterator().next();
}

源代码22 项目： jdk8u60 文件： Branch.java

public Server() throws IOException {
    serverChannel = SctpMultiChannel.open().bind(null);
    java.util.Set<SocketAddress> addrs = serverChannel.getAllLocalAddresses();
    if (addrs.isEmpty())
        debug("addrs should not be empty");

    serverAddr = (InetSocketAddress) addrs.iterator().next();
}

源代码23 项目： openjdk-jdk8u 文件： Branch.java

public Server() throws IOException {
    serverChannel = SctpMultiChannel.open().bind(null);
    java.util.Set<SocketAddress> addrs = serverChannel.getAllLocalAddresses();
    if (addrs.isEmpty())
        debug("addrs should not be empty");

    serverAddr = (InetSocketAddress) addrs.iterator().next();
}

源代码24 项目： dragonwell8_jdk 文件： SctpMultiChannelImpl.java

@Override
public SctpMultiChannel bind(SocketAddress local,
        int backlog) throws IOException {
    throw new UnsupportedOperationException(message);
}

源代码25 项目： dragonwell8_jdk 文件： SctpMultiChannelImpl.java

@Override
public SctpMultiChannel bindAddress(InetAddress address)
     throws IOException {
    throw new UnsupportedOperationException(message);
}

源代码26 项目： dragonwell8_jdk 文件： SctpMultiChannelImpl.java

@Override
public SctpMultiChannel unbindAddress(InetAddress address)
     throws IOException {
    throw new UnsupportedOperationException(message);
}

源代码27 项目： dragonwell8_jdk 文件： SctpMultiChannelImpl.java

@Override
public SctpMultiChannel shutdown(Association association)
        throws IOException {
    throw new UnsupportedOperationException(message);
}

源代码28 项目： jdk8u-jdk 文件： SctpMultiChannelImpl.java

@Override
public SctpMultiChannel bind(SocketAddress local,
        int backlog) throws IOException {
    throw new UnsupportedOperationException(message);
}

源代码29 项目： dragonwell8_jdk 文件： SctpMultiChannelImpl.java

@Override
public SctpMultiChannel bind(SocketAddress local,
        int backlog) throws IOException {
    throw new UnsupportedOperationException(message);
}

源代码30 项目： dragonwell8_jdk 文件： SctpMultiChannelImpl.java

@Override
public SctpMultiChannel bindAddress(InetAddress address)
     throws IOException {
    throw new UnsupportedOperationException(message);
}

方法所在类

java.nio.channels.NotYetBoundException