• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号

Java SctpSocketOption类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中com.sun.nio.sctp.SctpSocketOption的典型用法代码示例。如果您正苦于以下问题:Java SctpSocketOption类的具体用法?Java SctpSocketOption怎么用?Java SctpSocketOption使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



SctpSocketOption类属于com.sun.nio.sctp包,在下文中一共展示了SctpSocketOption类的17个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: setOption

import com.sun.nio.sctp.SctpSocketOption; //导入依赖的package包/类
@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;
}
 
开发者ID:SunburstApps,项目名称:OpenJSharp,代码行数:24,代码来源:SctpMultiChannelImpl.java


示例2: getOption

import com.sun.nio.sctp.SctpSocketOption; //导入依赖的package包/类
@Override
@SuppressWarnings("unchecked")
public <T> T getOption(SctpSocketOption<T> name, 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();
        return (T)SctpNet.getSocketOption(fdVal, name, assocId);
    }
}
 
开发者ID:SunburstApps,项目名称:OpenJSharp,代码行数:22,代码来源:SctpMultiChannelImpl.java


示例3: getSocketOption

import com.sun.nio.sctp.SctpSocketOption; //导入依赖的package包/类
static Object getSocketOption(int fd, SctpSocketOption<?> name, int assocId)
         throws IOException {
     if (name.equals(SCTP_SET_PEER_PRIMARY_ADDR)) {
        throw new IllegalArgumentException(
                "SCTP_SET_PEER_PRIMARY_ADDR cannot be retrieved");
    } else if (name.equals(SCTP_INIT_MAXSTREAMS)) {
        /* container for holding maxIn/Out streams */
        int[] values = new int[2];
        SctpNet.getInitMsgOption0(fd, values);
        return InitMaxStreams.create(values[0], values[1]);
    } else if (name.equals(SCTP_PRIMARY_ADDR)) {
        return getPrimAddrOption0(fd, assocId);
    } else if (name.equals(SCTP_DISABLE_FRAGMENTS) ||
        name.equals(SCTP_EXPLICIT_COMPLETE) ||
        name.equals(SCTP_FRAGMENT_INTERLEAVE) ||
        name.equals(SCTP_NODELAY) ||
        name.equals(SO_SNDBUF) ||
        name.equals(SO_RCVBUF) ||
        name.equals(SO_LINGER)) {
        return getIntOption(fd, name);
    } else {
        throw new AssertionError("Unknown socket option");
    }
}
 
开发者ID:SunburstApps,项目名称:OpenJSharp,代码行数:25,代码来源:SctpNet.java


示例4: getIntOption

import com.sun.nio.sctp.SctpSocketOption; //导入依赖的package包/类
static Object getIntOption(int fd, SctpSocketOption<?> name)
        throws IOException {
    Class<?> type = name.type();

    if (type != Integer.class && type != Boolean.class)
        throw new AssertionError("Should not reach here");

    if (!(name instanceof SctpStdSocketOption))
        throw new AssertionError("Should not reach here");

    int value = getIntOption0(fd,
            ((SctpStdSocketOption)name).constValue());

    if (type == Integer.class) {
        return Integer.valueOf(value);
    } else {
        return (value == 0) ? Boolean.FALSE : Boolean.TRUE;
    }
}
 
开发者ID:SunburstApps,项目名称:OpenJSharp,代码行数:20,代码来源:SctpNet.java


示例5: setOption

import com.sun.nio.sctp.SctpSocketOption; //导入依赖的package包/类
@Override
public <T> SctpChannel setOption(SctpSocketOption<T> name, T value)
        throws IOException {
    if (name == null)
        throw new NullPointerException();
    if (!supportedOptions().contains(name))
        throw new UnsupportedOperationException("'" + name + "' not supported");

    synchronized (stateLock) {
        if (!isOpen())
            throw new ClosedChannelException();

        SctpNet.setSocketOption(fdVal, name, value, 0 /*oneToOne*/);
    }
    return this;
}
 
开发者ID:SunburstApps,项目名称:OpenJSharp,代码行数:17,代码来源:SctpChannelImpl.java


示例6: setOption

import com.sun.nio.sctp.SctpSocketOption; //导入依赖的package包/类
@Override
public <T> SctpServerChannel setOption(SctpSocketOption<T> name, T value)
        throws IOException {
    if (name == null)
        throw new NullPointerException();
    if (!supportedOptions().contains(name))
        throw new UnsupportedOperationException("'" + name + "' not supported");

    synchronized (stateLock) {
        if (!isOpen())
            throw new ClosedChannelException();

        SctpNet.setSocketOption(fdVal, name, value, 0 /*oneToOne*/);
        return this;
    }
}
 
开发者ID:lambdalab-mirror,项目名称:jdk8u-jdk,代码行数:17,代码来源:SctpServerChannelImpl.java


示例7: defaultOptions

import com.sun.nio.sctp.SctpSocketOption; //导入依赖的package包/类
private static Set<SctpSocketOption<?>> defaultOptions() {
    HashSet<SctpSocketOption<?>> set = new HashSet<SctpSocketOption<?>>(10);
    set.add(SCTP_DISABLE_FRAGMENTS);
    set.add(SCTP_EXPLICIT_COMPLETE);
    set.add(SCTP_FRAGMENT_INTERLEAVE);
    set.add(SCTP_INIT_MAXSTREAMS);
    set.add(SCTP_NODELAY);
    set.add(SCTP_PRIMARY_ADDR);
    set.add(SCTP_SET_PEER_PRIMARY_ADDR);
    set.add(SO_SNDBUF);
    set.add(SO_RCVBUF);
    set.add(SO_LINGER);
    return Collections.unmodifiableSet(set);
}
 
开发者ID:SunburstApps,项目名称:OpenJSharp,代码行数:15,代码来源:SctpMultiChannelImpl.java


示例8: getOption

import com.sun.nio.sctp.SctpSocketOption; //导入依赖的package包/类
@Override
@SuppressWarnings("unchecked")
public <T> T getOption(SctpSocketOption<T> name) throws IOException {
    if (name == null)
        throw new NullPointerException();
    if (!supportedOptions().contains(name))
        throw new UnsupportedOperationException("'" + name + "' not supported");

    synchronized (stateLock) {
        if (!isOpen())
            throw new ClosedChannelException();

        return (T) SctpNet.getSocketOption(fdVal, name, 0 /*oneToOne*/);
    }
}
 
开发者ID:SunburstApps,项目名称:OpenJSharp,代码行数:16,代码来源:SctpServerChannelImpl.java


示例9: getOption

import com.sun.nio.sctp.SctpSocketOption; //导入依赖的package包/类
@Override
@SuppressWarnings("unchecked")
public <T> T getOption(SctpSocketOption<T> name) throws IOException {
    if (name == null)
        throw new NullPointerException();
    if (!supportedOptions().contains(name))
        throw new UnsupportedOperationException("'" + name + "' not supported");

    synchronized (stateLock) {
        if (!isOpen())
            throw new ClosedChannelException();

        return (T)SctpNet.getSocketOption(fdVal, name, 0 /*oneToOne*/);
    }
}
 
开发者ID:SunburstApps,项目名称:OpenJSharp,代码行数:16,代码来源:SctpChannelImpl.java


示例10: optionalSupport

import com.sun.nio.sctp.SctpSocketOption; //导入依赖的package包/类
<T> void optionalSupport(SctpChannel sc, SctpSocketOption<T> name,
        T value) {
    try {
        sc.setOption(name, value);
        checkOption(sc, name, value);
    } catch (IOException e) {
        /* Informational only, not all options have native support */
        out.println(name + " not supported. " + e);
    }
}
 
开发者ID:lambdalab-mirror,项目名称:jdk8u-jdk,代码行数:11,代码来源:SocketOptionTests.java


示例11: optionalSupport

import com.sun.nio.sctp.SctpSocketOption; //导入依赖的package包/类
<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);
    }
}
 
开发者ID:lambdalab-mirror,项目名称:jdk8u-jdk,代码行数:11,代码来源:SocketOptionTests.java


示例12: getOption

import com.sun.nio.sctp.SctpSocketOption; //导入依赖的package包/类
@Override
public <T> T getOption(SctpSocketOption<T> name,
        Association association) throws IOException {
    throw new UnsupportedOperationException(message);
}
 
开发者ID:SunburstApps,项目名称:OpenJSharp,代码行数:6,代码来源:SctpMultiChannelImpl.java


示例13: setOption

import com.sun.nio.sctp.SctpSocketOption; //导入依赖的package包/类
@Override
public <T> SctpMultiChannel setOption(SctpSocketOption<T> name,
        T value, Association association) throws IOException {
    throw new UnsupportedOperationException(message);
}
 
开发者ID:SunburstApps,项目名称:OpenJSharp,代码行数:6,代码来源:SctpMultiChannelImpl.java


示例14: supportedOptions

import com.sun.nio.sctp.SctpSocketOption; //导入依赖的package包/类
@Override
public Set<SctpSocketOption<?>> supportedOptions() {
    throw new UnsupportedOperationException(message);
}
 
开发者ID:SunburstApps,项目名称:OpenJSharp,代码行数:5,代码来源:SctpMultiChannelImpl.java


示例15: setOption

import com.sun.nio.sctp.SctpSocketOption; //导入依赖的package包/类
@Override
public <T> SctpServerChannel setOption(SctpSocketOption<T> name,
        T value) throws IOException {
    throw new UnsupportedOperationException(message);
}
 
开发者ID:SunburstApps,项目名称:OpenJSharp,代码行数:6,代码来源:SctpServerChannelImpl.java


示例16: getOption

import com.sun.nio.sctp.SctpSocketOption; //导入依赖的package包/类
@Override
public <T> T getOption(SctpSocketOption<T> name)
        throws IOException {
    throw new UnsupportedOperationException(message);
}
 
开发者ID:AdoptOpenJDK,项目名称:openjdk-jdk10,代码行数:6,代码来源:SctpChannelImpl.java


示例17: getOption

import com.sun.nio.sctp.SctpSocketOption; //导入依赖的package包/类
@Override
public <T> T getOption(SctpSocketOption<T> name) throws IOException {
    throw new UnsupportedOperationException(message);
}
 
开发者ID:SunburstApps,项目名称:OpenJSharp,代码行数:5,代码来源:SctpServerChannelImpl.java



注:本文中的com.sun.nio.sctp.SctpSocketOption类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java Session类代码示例发布时间:2022-05-21
下一篇:
Java ConcurrentSet类代码示例发布时间:2022-05-21
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap