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

XnioByteBufferPool.<init>介绍

暂无

代码示例

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

public AlpnOpenListener(Pool<ByteBuffer> bufferPool, OptionMap undertowOptions, String fallbackProtocol, DelegateOpenListener fallbackListener) {
  this(new XnioByteBufferPool(bufferPool), undertowOptions, fallbackProtocol, fallbackListener);
}

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

public AjpOpenListener(final Pool<ByteBuffer> pool, final OptionMap undertowOptions) {
  this(new XnioByteBufferPool(pool), undertowOptions);
}

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

@Deprecated
public Http2OpenListener(final Pool<ByteBuffer> pool, final OptionMap undertowOptions, String protocol) {
  this(new XnioByteBufferPool(pool), undertowOptions, protocol);
}

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

@Deprecated
public HttpOpenListener(final Pool<ByteBuffer> pool, final OptionMap undertowOptions) {
  this(new XnioByteBufferPool(pool), undertowOptions);
}

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

@Deprecated
public StringReadChannelListener(final Pool<ByteBuffer> bufferPool) {
  this.bufferPool = new XnioByteBufferPool(bufferPool);
}

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

public AlpnOpenListener(Pool<ByteBuffer> bufferPool, OptionMap undertowOptions, String fallbackProtocol, DelegateOpenListener fallbackListener) {
  this(new XnioByteBufferPool(bufferPool), undertowOptions, fallbackProtocol, fallbackListener);
}

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

public AjpOpenListener(final Pool<ByteBuffer> pool, final OptionMap undertowOptions) {
  this(new XnioByteBufferPool(pool), undertowOptions);
}

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

public AlpnOpenListener(Pool<ByteBuffer> bufferPool, OptionMap undertowOptions, String fallbackProtocol, DelegateOpenListener fallbackListener) {
  this(new XnioByteBufferPool(bufferPool), undertowOptions, fallbackProtocol, fallbackListener);
}

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

public AjpOpenListener(final Pool<ByteBuffer> pool, final OptionMap undertowOptions) {
  this(new XnioByteBufferPool(pool), undertowOptions);
}

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

@Deprecated
public StringReadChannelListener(final Pool<ByteBuffer> bufferPool) {
  this.bufferPool = new XnioByteBufferPool(bufferPool);
}

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

@Deprecated
public HttpOpenListener(final Pool<ByteBuffer> pool, final OptionMap undertowOptions) {
  this(new XnioByteBufferPool(pool), undertowOptions);
}

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

@Deprecated
public Http2OpenListener(final Pool<ByteBuffer> pool, final OptionMap undertowOptions, String protocol) {
  this(new XnioByteBufferPool(pool), undertowOptions, protocol);
}

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

@Deprecated
public HttpOpenListener(final Pool<ByteBuffer> pool, final OptionMap undertowOptions) {
  this(new XnioByteBufferPool(pool), undertowOptions);
}

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

@Deprecated
public Http2OpenListener(final Pool<ByteBuffer> pool, final OptionMap undertowOptions, String protocol) {
  this(new XnioByteBufferPool(pool), undertowOptions, protocol);
}

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

@Deprecated
public StringReadChannelListener(final Pool<ByteBuffer> bufferPool) {
  this.bufferPool = new XnioByteBufferPool(bufferPool);
}

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

@Override
public void start(StartContext startContext) throws StartException {
  byteBufferPool = new XnioByteBufferPool(bufferPool.getValue());
}

代码示例来源：origin: org.wildfly.core/wildfly-io

@Override
public void start(StartContext startContext) throws StartException {
  byteBufferPool = new XnioByteBufferPool(bufferPool.getValue());
}

代码示例来源：origin: arquillian/arquillian-cube

public PortForwardOpenListener(ClientConnection masterPortForwardConnection, final String urlPath,
  final int targetPort, final AtomicInteger requestId, final Pool<ByteBuffer> pool,
  final OptionMap undertowOptions) {
  this.masterPortForwardConnection = masterPortForwardConnection;
  this.urlPath = urlPath;
  this.targetPort = targetPort;
  this.requestId = requestId;
  this.undertowOptions = undertowOptions;
  this.bufferPool = new XnioByteBufferPool(pool);
  Pooled<ByteBuffer> buf = pool.allocate();
  this.bufferSize = buf.getResource().remaining();
  buf.free();
}

代码示例来源：origin: org.arquillian.cube/arquillian-cube-kubernetes

public PortForwardOpenListener(ClientConnection masterPortForwardConnection, final String urlPath,
  final int targetPort, final AtomicInteger requestId, final Pool<ByteBuffer> pool,
  final OptionMap undertowOptions) {
  this.masterPortForwardConnection = masterPortForwardConnection;
  this.urlPath = urlPath;
  this.targetPort = targetPort;
  this.requestId = requestId;
  this.undertowOptions = undertowOptions;
  this.bufferPool = new XnioByteBufferPool(pool);
  Pooled<ByteBuffer> buf = pool.allocate();
  this.bufferSize = buf.getResource().remaining();
  buf.free();
}

代码示例来源：origin: org.arquillian.cube/arquillian-cube-kubernetes

private void upgradeConnection(ClientExchange result) throws IOException {
  if (result.getResponse().getResponseCode() == 101) {
    // flush response
    new StringReadChannelListener(bufferPool) {
      @Override
      protected void stringDone(String string) {
      }
      @Override
      protected void error(IOException e) {
      }
    }.setup(result.getResponseChannel());
    // Create the upgraded SPDY connection
    ByteBufferPool heapBufferPool =
      new XnioByteBufferPool(new ByteBufferSlicePool(BufferAllocator.BYTE_BUFFER_ALLOCATOR, 8196, 8196));
    SpdyChannel spdyChannel =
      new SpdyChannelWithoutFlowControl(connection.performUpgrade(), bufferPool, null, heapBufferPool, true,
        OptionMap.EMPTY);
    Integer idleTimeout = DEFAULT_OPTIONS.get(UndertowOptions.IDLE_TIMEOUT);
    if (idleTimeout != null && idleTimeout > 0) {
      spdyChannel.setIdleTimeout(idleTimeout);
    }
    connection = new SpdyClientConnection(spdyChannel, null);
  } else {
    throw new IOException("Failed to upgrade connection");
  }
}