io.netty.channel.epoll.Epoll.unavailabilityCause()方法的使用及代码示例

x33g5p2x  于2022-01-19 转载在 其他  
字(3.8k)|赞(0)|评价(0)|浏览(221)

本文整理了Java中io.netty.channel.epoll.Epoll.unavailabilityCause()方法的一些代码示例,展示了Epoll.unavailabilityCause()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Epoll.unavailabilityCause()方法的具体详情如下:
包路径:io.netty.channel.epoll.Epoll
类名称:Epoll
方法名:unavailabilityCause

Epoll.unavailabilityCause介绍

[英]Returns the cause of unavailability of netty-transport-native-epoll.
[中]返回netty-transport-native-epoll不可用的原因。

代码示例

代码示例来源:origin: eclipse-vertx/vert.x

  1. @Override
  2. public Throwable unavailabilityCause() {
  3. return Epoll.unavailabilityCause();
  4. }

代码示例来源:origin: io.vertx/vertx-core

  1. @Override
  2. public Throwable unavailabilityCause() {
  3. return Epoll.unavailabilityCause();
  4. }

代码示例来源:origin: org.opendaylight.bgpcep/pcep-pcc-mock

  1. private void setChannelFactory(final Bootstrap bootstrap, final Optional<KeyMapping> keys) {
  2. if(Epoll.isAvailable()) {
  3. bootstrap.channel(EpollSocketChannel.class);
  4. bootstrap.option(EpollChannelOption.EPOLL_MODE, EpollMode.LEVEL_TRIGGERED);
  5. } else {
  6. bootstrap.channel(NioSocketChannel.class);
  7. }
  8. if (keys.isPresent()) {
  9. if (Epoll.isAvailable()) {
  10. bootstrap.option(EpollChannelOption.TCP_MD5SIG, keys.get());
  11. } else {
  12. throw new UnsupportedOperationException(Epoll.unavailabilityCause().getCause());
  13. }
  14. }
  15. }

代码示例来源:origin: org.opendaylight.bgpcep/bgp-rib-impl

  1. protected Bootstrap createClientBootStrap(final Optional<KeyMapping> keys, final EventLoopGroup workerGroup) {
  2. final Bootstrap bootstrap = new Bootstrap();
  3. if (Epoll.isAvailable()) {
  4. bootstrap.channel(EpollSocketChannel.class);
  5. bootstrap.option(EpollChannelOption.EPOLL_MODE, EpollMode.LEVEL_TRIGGERED);
  6. } else {
  7. bootstrap.channel(NioSocketChannel.class);
  8. }
  9. if (keys.isPresent()) {
  10. if (Epoll.isAvailable()) {
  11. bootstrap.option(EpollChannelOption.TCP_MD5SIG, keys.get());
  12. } else {
  13. throw new UnsupportedOperationException(Epoll.unavailabilityCause().getCause());
  14. }
  15. }
  16. // Make sure we are doing round-robin processing
  17. bootstrap.option(ChannelOption.MAX_MESSAGES_PER_READ, 1);
  18. bootstrap.option(ChannelOption.SO_KEEPALIVE, Boolean.TRUE);
  19. bootstrap.option(ChannelOption.WRITE_BUFFER_HIGH_WATER_MARK, HIGH_WATER_MARK);
  20. bootstrap.option(ChannelOption.WRITE_BUFFER_LOW_WATER_MARK, LOW_WATER_MARK);
  21. if (bootstrap.group() == null) {
  22. bootstrap.group(workerGroup);
  23. }
  24. return bootstrap;
  25. }

代码示例来源:origin: org.opendaylight.bgpcep/bgp-bmp-impl

  1. b.option(EpollChannelOption.TCP_MD5SIG, keys.get());
  2. } else {
  3. throw new UnsupportedOperationException (Epoll.unavailabilityCause().getCause());

代码示例来源:origin: org.opendaylight.bgpcep/pcep-impl

  1. protected ServerBootstrap createServerBootstrap(final ChannelPipelineInitializer initializer) {
  2. final ServerBootstrap b = new ServerBootstrap();
  3. b.childHandler(new ChannelInitializer<SocketChannel>() {
  4. @Override
  5. protected void initChannel(final SocketChannel ch) {
  6. initializer.initializeChannel(ch, new DefaultPromise(PCEPDispatcherImpl.this.executor));
  7. }
  8. });
  9. b.option(ChannelOption.SO_BACKLOG, SOCKET_BACKLOG_SIZE);
  10. b.childOption(ChannelOption.ALLOCATOR, PooledByteBufAllocator.DEFAULT);
  11. if (Epoll.isAvailable()) {
  12. b.channel(EpollServerSocketChannel.class);
  13. b.childOption(EpollChannelOption.EPOLL_MODE, EpollMode.LEVEL_TRIGGERED);
  14. } else {
  15. b.channel(NioServerSocketChannel.class);
  16. }
  17. if (this.keys.isPresent()) {
  18. if (Epoll.isAvailable()) {
  19. b.option(EpollChannelOption.TCP_MD5SIG, this.keys.get());
  20. } else {
  21. throw new UnsupportedOperationException(Epoll.unavailabilityCause().getCause());
  22. }
  23. }
  24. // Make sure we are doing round-robin processing
  25. b.childOption(ChannelOption.MAX_MESSAGES_PER_READ, 1);
  26. if (b.group() == null) {
  27. b.group(this.bossGroup, this.workerGroup);
  28. }
  29. return b;
  30. }

代码示例来源:origin: org.opendaylight.bgpcep/bgp-bmp-impl

  1. b.option(EpollChannelOption.TCP_MD5SIG, keys.get());
  2. } else {
  3. throw new UnsupportedOperationException (Epoll.unavailabilityCause().getCause());

代码示例来源:origin: org.restcomm.imscf/imscf-common

  1. if (config.getListenerMode() == Configuration.ListenerMode.EPOLL) {
  2. LOGGER.warn("EPOLL listener mode is configured but it is unavailable. Cause follows.",
  3. Epoll.unavailabilityCause());

相关文章