org.apache.mina.transport.socket.SocketSessionConfig.getReceiveBufferSize()方法的使用及代码示例

x33g5p2x  于2022-01-30 转载在 其他  
字(4.1k)|赞(0)|评价(0)|浏览(77)

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

SocketSessionConfig.getReceiveBufferSize介绍

暂无

代码示例

代码示例来源:origin: Red5/red5-server

log.info("Send buffer size: {} recv buffer size: {} so linger: {} traffic class: {}", new Object[] { sessionConf.getSendBufferSize(), sessionConf.getReceiveBufferSize(), sessionConf.getSoLinger(), sessionConf.getTrafficClass() });

代码示例来源:origin: kaazing/gateway

/**
 * {@inheritDoc}
 */
@Override
protected SocketChannel newHandle(SocketAddress localAddress)
    throws Exception {
  SocketChannel ch = SocketChannel.open();
  int receiveBufferSize =
    (getSessionConfig()).getReceiveBufferSize();
  if (receiveBufferSize > 65535) {
    if (AbstractIoSessionConfig.ENABLE_BUFFER_SIZE) {
      System.out.println("NioSocketConnector.newHandle("+receiveBufferSize+")");
      ch.socket().setReceiveBufferSize(receiveBufferSize);
    }
  }
  if (localAddress != null) {
    ch.socket().bind(localAddress);
  }
  ch.configureBlocking(false);
  return ch;
}

代码示例来源:origin: org.apache.mina/mina-core

/**
 * {@inheritDoc}
 */
@Override
protected SocketChannel newHandle(SocketAddress localAddress) throws Exception {
  SocketChannel ch = SocketChannel.open();
  int receiveBufferSize = (getSessionConfig()).getReceiveBufferSize();
  if (receiveBufferSize > 65535) {
    ch.socket().setReceiveBufferSize(receiveBufferSize);
  }
  if (localAddress != null) {
    try {
      ch.socket().bind(localAddress);
    } catch (IOException ioe) {
      // Add some info regarding the address we try to bind to the
      // message
      String newMessage = "Error while binding on " + localAddress + "\n" + "original message : "
          + ioe.getMessage();
      Exception e = new IOException(newMessage);
      e.initCause(ioe.getCause());
      // Preemptively close the channel
      ch.close();
      throw e;
    }
  }
  ch.configureBlocking(false);
  return ch;
}

代码示例来源:origin: org.apache.directory.api/api-ldap-client-all

/**
 * {@inheritDoc}
 */
@Override
protected SocketChannel newHandle(SocketAddress localAddress) throws Exception {
  SocketChannel ch = SocketChannel.open();
  int receiveBufferSize = (getSessionConfig()).getReceiveBufferSize();
  if (receiveBufferSize > 65535) {
    ch.socket().setReceiveBufferSize(receiveBufferSize);
  }
  if (localAddress != null) {
    try {
      ch.socket().bind(localAddress);
    } catch (IOException ioe) {
      // Add some info regarding the address we try to bind to the
      // message
      String newMessage = "Error while binding on " + localAddress + "\n" + "original message : "
          + ioe.getMessage();
      Exception e = new IOException(newMessage);
      e.initCause(ioe.getCause());
      // Preemptively close the channel
      ch.close();
      throw e;
    }
  }
  ch.configureBlocking(false);
  return ch;
}

代码示例来源:origin: kaazing/gateway

System.out.println("NioSocketAcceptor.open(): setReceiveBufferSize:"+getSessionConfig().getReceiveBufferSize());
socket.setReceiveBufferSize(getSessionConfig().getReceiveBufferSize());

代码示例来源:origin: kaazing/gateway

setKeepAlive(cfg.isKeepAlive());
setOobInline(cfg.isOobInline());
setReceiveBufferSize(cfg.getReceiveBufferSize());
setReuseAddress(cfg.isReuseAddress());
setSendBufferSize(cfg.getSendBufferSize());

代码示例来源:origin: kaazing/gateway

setKeepAlive(cfg.isKeepAlive());
setOobInline(cfg.isOobInline());
setReceiveBufferSize(cfg.getReceiveBufferSize());
setReuseAddress(cfg.isReuseAddress());
setSendBufferSize(cfg.getSendBufferSize());

代码示例来源:origin: org.apache.mina/mina-core

setKeepAlive(cfg.isKeepAlive());
setOobInline(cfg.isOobInline());
setReceiveBufferSize(cfg.getReceiveBufferSize());
setReuseAddress(cfg.isReuseAddress());
setSendBufferSize(cfg.getSendBufferSize());

代码示例来源:origin: kaazing/gateway

setKeepAlive(cfg.isKeepAlive());
setOobInline(cfg.isOobInline());
setReceiveBufferSize(cfg.getReceiveBufferSize());
setReuseAddress(cfg.isReuseAddress());
setSendBufferSize(cfg.getSendBufferSize());

代码示例来源:origin: org.apache.directory.api/api-ldap-client-all

setKeepAlive(cfg.isKeepAlive());
setOobInline(cfg.isOobInline());
setReceiveBufferSize(cfg.getReceiveBufferSize());
setReuseAddress(cfg.isReuseAddress());
setSendBufferSize(cfg.getSendBufferSize());

相关文章