java.net.ServerSocket.getReceiveBufferSize()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(6.2k)|赞(0)|评价(0)|浏览(207)

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

ServerSocket.getReceiveBufferSize介绍

[英]Returns this socket's SocketOptions#SO_RCVBUF.
[中]返回此套接字的SocketOptions#SO_RCVBUF。

代码示例

代码示例来源：origin: netty/netty

  1. @Override
  2. public int getReceiveBufferSize() {
  3.   try {
  4.     return javaSocket.getReceiveBufferSize();
  5.   } catch (SocketException e) {
  6.     throw new ChannelException(e);
  7.   }
  8. }

代码示例来源：origin: redisson/redisson

  1. @Override
  2. public int getReceiveBufferSize() {
  3.   try {
  4.     return javaSocket.getReceiveBufferSize();
  5.   } catch (SocketException e) {
  6.     throw new ChannelException(e);
  7.   }
  8. }

代码示例来源：origin: wildfly/wildfly

  1. @Override
  2. public int getReceiveBufferSize() {
  3.   try {
  4.     return javaSocket.getReceiveBufferSize();
  5.   } catch (SocketException e) {
  6.     throw new ChannelException(e);
  7.   }
  8. }

代码示例来源：origin: io.netty/netty

  1. public int getReceiveBufferSize() {
  2.   try {
  3.     return socket.getReceiveBufferSize();
  4.   } catch (SocketException e) {
  5.     throw new ChannelException(e);
  6.   }
  7. }

代码示例来源：origin: apache/geode

  1. int newSize = socket.getReceiveBufferSize();
  2. if (newSize != tcpBufferSize) {
  3.  logger.info("{} is {} instead of the requested {}",

代码示例来源：origin: wildfly/wildfly

  1. public <T> T getOption(final Option<T> option) throws UnsupportedOptionException, IOException {
  2.   if (option == Options.REUSE_ADDRESSES) {
  3.     return option.cast(Boolean.valueOf(socket.getReuseAddress()));
  4.   } else if (option == Options.RECEIVE_BUFFER) {
  5.     return option.cast(Integer.valueOf(socket.getReceiveBufferSize()));
  6.   } else if (option == Options.SEND_BUFFER) {
  7.     final int value = sendBuffer;
  8.     return value == -1 ? null : option.cast(Integer.valueOf(value));
  9.   } else if (option == Options.KEEP_ALIVE) {
  10.     return option.cast(Boolean.valueOf(keepAlive != 0));
  11.   } else if (option == Options.TCP_OOB_INLINE) {
  12.     return option.cast(Boolean.valueOf(oobInline != 0));
  13.   } else if (option == Options.TCP_NODELAY) {
  14.     return option.cast(Boolean.valueOf(tcpNoDelay != 0));
  15.   } else if (option == Options.READ_TIMEOUT) {
  16.     return option.cast(Integer.valueOf(readTimeout));
  17.   } else if (option == Options.WRITE_TIMEOUT) {
  18.     return option.cast(Integer.valueOf(writeTimeout));
  19.   } else if (option == Options.CONNECTION_HIGH_WATER) {
  20.     return option.cast(Integer.valueOf(getHighWater(connectionStatus)));
  21.   } else if (option == Options.CONNECTION_LOW_WATER) {
  22.     return option.cast(Integer.valueOf(getLowWater(connectionStatus)));
  23.   } else {
  24.     return null;
  25.   }
  26. }

代码示例来源：origin: wildfly/wildfly

  1. public <T> T getOption(final Option<T> option) throws UnsupportedOptionException, IOException {
  2.   if (option == Options.REUSE_ADDRESSES) {
  3.     return option.cast(Boolean.valueOf(socket.getReuseAddress()));
  4.   } else if (option == Options.RECEIVE_BUFFER) {
  5.     return option.cast(Integer.valueOf(socket.getReceiveBufferSize()));
  6.   } else if (option == Options.SEND_BUFFER) {
  7.     final int value = sendBuffer;
  8.     return value == -1 ? null : option.cast(Integer.valueOf(value));
  9.   } else if (option == Options.KEEP_ALIVE) {
  10.     return option.cast(Boolean.valueOf(keepAlive != 0));
  11.   } else if (option == Options.TCP_OOB_INLINE) {
  12.     return option.cast(Boolean.valueOf(oobInline != 0));
  13.   } else if (option == Options.TCP_NODELAY) {
  14.     return option.cast(Boolean.valueOf(tcpNoDelay != 0));
  15.   } else if (option == Options.READ_TIMEOUT) {
  16.     return option.cast(Integer.valueOf(readTimeout));
  17.   } else if (option == Options.WRITE_TIMEOUT) {
  18.     return option.cast(Integer.valueOf(writeTimeout));
  19.   } else if (option == Options.CONNECTION_HIGH_WATER) {
  20.     return option.cast(Integer.valueOf(getHighWater(connectionStatus)));
  21.   } else if (option == Options.CONNECTION_LOW_WATER) {
  22.     return option.cast(Integer.valueOf(getLowWater(connectionStatus)));
  23.   } else {
  24.     return null;
  25.   }
  26. }

代码示例来源：origin: wildfly/wildfly

  1. socket.setReuseAddress(Options.REUSE_ADDRESSES.cast(value, Boolean.FALSE).booleanValue());
  2. } else if (option == Options.RECEIVE_BUFFER) {
  3.   old = Integer.valueOf(socket.getReceiveBufferSize());
  4.   final int newValue = Options.RECEIVE_BUFFER.cast(value, Integer.valueOf(DEFAULT_BUFFER_SIZE)).intValue();
  5.   if (newValue < 1) {

代码示例来源：origin: wildfly/wildfly

  1. socket.setReuseAddress(Options.REUSE_ADDRESSES.cast(value, Boolean.FALSE).booleanValue());
  2. } else if (option == Options.RECEIVE_BUFFER) { 
  3.   old = Integer.valueOf(socket.getReceiveBufferSize());
  4.   final int newValue = Options.RECEIVE_BUFFER.cast(value, Integer.valueOf(DEFAULT_BUFFER_SIZE)).intValue();
  5.   if (newValue < 1) {

代码示例来源：origin: org.apache.hadoop/hadoop-hdfs

  1. @Override
  2. public int getReceiveBufferSize() throws IOException {
  3.  return this.serverSocket.getReceiveBufferSize();
  4. }

代码示例来源：origin: jitsi/ice4j

  1. /**
  2.  * {@inheritDoc}
  3.  *
  4.  * Forwards to {@link #delegate}.
  5.  */
  6. @Override
  7. public int getReceiveBufferSize()
  8.   throws SocketException
  9. {
  10.   return delegate.getReceiveBufferSize();
  11. }

代码示例来源：origin: jboss.remoting/jboss-remoting

  1. /**
  2. * See <code>java.net.ServerSocket</code> javadoc.
  3. */
  4. public int getReceiveBufferSize() throws SocketException
  5. {
  6.  return ss.getReceiveBufferSize();
  7. }

代码示例来源：origin: dcm4che/dcm4che

  1. void setReceiveBufferSize(ServerSocket ss) throws SocketException {
  2.   int size = ss.getReceiveBufferSize();
  3.   if (receiveBufferSize == 0) {
  4.     receiveBufferSize = size;
  5.   } else if (receiveBufferSize != size) {
  6.     ss.setReceiveBufferSize(receiveBufferSize);
  7.     receiveBufferSize = ss.getReceiveBufferSize();
  8.   }
  9. }

代码示例来源：origin: org.apache.hbase.thirdparty/hbase-shaded-netty

  1. @Override
  2. public int getReceiveBufferSize() {
  3.   try {
  4.     return javaSocket.getReceiveBufferSize();
  5.   } catch (SocketException e) {
  6.     throw new ChannelException(e);
  7.   }
  8. }

代码示例来源：origin: org.jboss.eap/wildfly-client-all

  1. @Override
  2. public int getReceiveBufferSize() {
  3.   try {
  4.     return javaSocket.getReceiveBufferSize();
  5.   } catch (SocketException e) {
  6.     throw new ChannelException(e);
  7.   }
  8. }

代码示例来源：origin: apache/activemq-artemis

  1. @Override
  2. public int getReceiveBufferSize() {
  3.   try {
  4.     return javaSocket.getReceiveBufferSize();
  5.   } catch (SocketException e) {
  6.     throw new ChannelException(e);
  7.   }
  8. }

代码示例来源：origin: apache/activemq-artemis

  1. @Override
  2. public int getReceiveBufferSize() {
  3.   try {
  4.     return javaSocket.getReceiveBufferSize();
  5.   } catch (SocketException e) {
  6.     throw new ChannelException(e);
  7.   }
  8. }

代码示例来源：origin: org.apache.ratis/ratis-proto-shaded

  1. @Override
  2. public int getReceiveBufferSize() {
  3.   try {
  4.     return javaSocket.getReceiveBufferSize();
  5.   } catch (SocketException e) {
  6.     throw new ChannelException(e);
  7.   }
  8. }

代码示例来源：origin: couchbase/couchbase-jvm-core

  1. @Override
  2. public int getReceiveBufferSize() {
  3.   try {
  4.     return javaSocket.getReceiveBufferSize();
  5.   } catch (SocketException e) {
  6.     throw new ChannelException(e);
  7.   }
  8. }

代码示例来源：origin: KostyaSha/yet-another-docker-plugin

  1. @Override
  2. public int getReceiveBufferSize() {
  3.   try {
  4.     return javaSocket.getReceiveBufferSize();
  5.   } catch (SocketException e) {
  6.     throw new ChannelException(e);
  7.   }
  8. }

内容来源于网络，如有侵权，请联系作者删除！

serversocket

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com