org.apache.coyote.Request.getReadListener()方法的使用及代码示例

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

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

Request.getReadListener介绍

暂无

代码示例

代码示例来源：origin: org.apache.tomcat/tomcat-catalina

  1. boolean isBlocking() {
  2.   return coyoteRequest.getReadListener() == null;
  3. }

代码示例来源：origin: org.ops4j.pax.tipi/org.ops4j.pax.tipi.tomcat-embed-core

  1. boolean isBlocking() {
  2.   return coyoteRequest.getReadListener() == null;
  3. }

代码示例来源：origin: codefollower/Tomcat-Research

  1. boolean isBlocking() {
  2.   return coyoteRequest.getReadListener() != null;
  3. }

代码示例来源：origin: codefollower/Tomcat-Research

  1. public boolean isReady() {
  2.   if (coyoteRequest.getReadListener() == null) {
  3.     throw new IllegalStateException("not in non blocking mode.");
  4.   }
  5.   int available = available();
  6.   boolean result = available > 0;
  7.   if (!result) {
  8.     coyoteRequest.action(ActionCode.NB_READ_INTEREST, null);
  9.   }
  10.   return result;
  11. }

代码示例来源：origin: org.ops4j.pax.tipi/org.ops4j.pax.tipi.tomcat-embed-core

  1. public int available() {
  2.   int available = 0;
  3.   if (state == BYTE_STATE) {
  4.     available = bb.remaining();
  5.   } else if (state == CHAR_STATE) {
  6.     available = cb.remaining();
  7.   }
  8.   if (available == 0) {
  9.     coyoteRequest.action(ActionCode.AVAILABLE,
  10.         Boolean.valueOf(coyoteRequest.getReadListener() != null));
  11.     available = (coyoteRequest.getAvailable() > 0) ? 1 : 0;
  12.   }
  13.   return available;
  14. }

代码示例来源：origin: org.apache.tomcat/tomcat-catalina

  1. public int available() {
  2.   int available = availableInThisBuffer();
  3.   if (available == 0) {
  4.     coyoteRequest.action(ActionCode.AVAILABLE,
  5.         Boolean.valueOf(coyoteRequest.getReadListener() != null));
  6.     available = (coyoteRequest.getAvailable() > 0) ? 1 : 0;
  7.   }
  8.   return available;
  9. }

代码示例来源：origin: org.ops4j.pax.tipi/org.ops4j.pax.tipi.tomcat-embed-core

  1. public void setReadListener(ReadListener listener) {
  2.   if (listener == null) {
  3.     throw new NullPointerException(
  4.         sm.getString("request.nullReadListener"));
  5.   }
  6.   if (getReadListener() != null) {
  7.     throw new IllegalStateException(
  8.         sm.getString("request.readListenerSet"));
  9.   }
  10.   // Note: This class is not used for HTTP upgrade so only need to test
  11.   //       for async
  12.   AtomicBoolean result = new AtomicBoolean(false);
  13.   action(ActionCode.ASYNC_IS_ASYNC, result);
  14.   if (!result.get()) {
  15.     throw new IllegalStateException(
  16.         sm.getString("request.notAsync"));
  17.   }
  18.   this.listener = listener;
  19. }

代码示例来源：origin: codefollower/Tomcat-Research

  1. public void setReadListener(ReadListener listener) {
  2.   if (listener == null) {
  3.     throw new NullPointerException(
  4.         sm.getString("request.nullReadListener"));
  5.   }
  6.   if (getReadListener() != null) {
  7.     throw new IllegalStateException(
  8.         sm.getString("request.readListenerSet"));
  9.   }
  10.   // Note: This class is not used for HTTP upgrade so only need to test
  11.   //       for async
  12.   AtomicBoolean result = new AtomicBoolean(false);
  13.   action(ActionCode.ASYNC_IS_ASYNC, result);
  14.   if (!result.get()) {
  15.     throw new IllegalStateException(
  16.         sm.getString("request.notAsync"));
  17.   }
  18.   this.listener = listener;
  19. }

代码示例来源：origin: org.apache.tomcat/tomcat-catalina

  1. public boolean isReady() {
  2.   if (coyoteRequest.getReadListener() == null) {
  3.     if (log.isDebugEnabled()) {
  4.       log.debug(sm.getString("inputBuffer.requiresNonBlocking"));

代码示例来源：origin: org.ops4j.pax.tipi/org.ops4j.pax.tipi.tomcat-embed-core

  1. public boolean isReady() {
  2.   if (coyoteRequest.getReadListener() == null) {
  3.     if (log.isDebugEnabled()) {
  4.       log.debug(sm.getString("inputBuffer.requiresNonBlocking"));
  5.     }
  6.     return false;
  7.   }
  8.   if (isFinished()) {
  9.     // If this is a non-container thread, need to trigger a read
  10.     // which will eventually lead to a call to onAllDataRead() via a
  11.     // container thread.
  12.     if (!ContainerThreadMarker.isContainerThread()) {
  13.       coyoteRequest.action(ActionCode.DISPATCH_READ, null);
  14.       coyoteRequest.action(ActionCode.DISPATCH_EXECUTE, null);
  15.     }
  16.     return false;
  17.   }
  18.   boolean result = available() > 0;
  19.   if (!result) {
  20.     coyoteRequest.action(ActionCode.NB_READ_INTEREST, null);
  21.   }
  22.   return result;
  23. }

代码示例来源：origin: codefollower/Tomcat-Research

  1. RequestDispatcher.ERROR_EXCEPTION);
  2. req.getAttributes().remove(RequestDispatcher.ERROR_EXCEPTION);
  3. ReadListener readListener = req.getReadListener();
  4. if (readListener != null) {
  5.   ClassLoader oldCL =
  6. ReadListener readListener = req.getReadListener();
  7. if (writeListener != null && status == SocketStatus.OPEN_WRITE) {
  8.   ClassLoader oldCL =

代码示例来源：origin: codefollower/Tomcat-Research

  1. if (asyncConImpl != null) {
  2.   async = true;
  3.   ReadListener readListener = req.getReadListener();
  4.   if (readListener != null && request.isFinished()) {
  5.       Thread.currentThread().setContextClassLoader(newCL);
  6.       if (req.sendAllDataReadEvent()) {
  7.         req.getReadListener().onAllDataRead();

代码示例来源：origin: org.ops4j.pax.tipi/org.ops4j.pax.tipi.tomcat-embed-core

  1. request.setAttribute(RequestDispatcher.ERROR_EXCEPTION, ioe);
  2. } else if (status == SocketEvent.OPEN_READ && request.getReadListener() != null) {
  3.   dispatchNonBlockingRead();
  4. } else if (status == SocketEvent.ERROR) {
  5.   if (request.getReadListener() != null || response.getWriteListener() != null) {

代码示例来源：origin: org.apache.tomcat/tomcat-catalina

  1. ReadListener readListener = req.getReadListener();
  2. if (readListener != null && request.isFinished()) {
  3.     oldCL = request.getContext().bind(false, null);
  4.     if (req.sendAllDataReadEvent()) {
  5.       req.getReadListener().onAllDataRead();

代码示例来源：origin: org.apache.tomcat/tomcat-catalina

  1. try {
  2.   oldCL = request.getContext().bind(false, null);
  3.   if (req.getReadListener() != null) {
  4.     req.getReadListener().onError(t);
  5. ReadListener readListener = req.getReadListener();
  6. if (writeListener != null && status == SocketEvent.OPEN_WRITE) {
  7.   ClassLoader oldCL = null;

代码示例来源：origin: org.ops4j.pax.tipi/org.ops4j.pax.tipi.tomcat-embed-core

  1. try {
  2.   oldCL = request.getContext().bind(false, null);
  3.   if (req.getReadListener() != null) {
  4.     req.getReadListener().onError(t);
  5. ReadListener readListener = req.getReadListener();
  6. if (writeListener != null && status == SocketEvent.OPEN_WRITE) {
  7.   ClassLoader oldCL = null;

代码示例来源：origin: org.ops4j.pax.tipi/org.ops4j.pax.tipi.tomcat-embed-core

  1. ReadListener readListener = req.getReadListener();
  2. if (readListener != null && request.isFinished()) {
  3.     oldCL = request.getContext().bind(false, null);
  4.     if (req.sendAllDataReadEvent()) {
  5.       req.getReadListener().onAllDataRead();

代码示例来源：origin: codefollower/Tomcat-Research

  1. request.getReadListener() != null) {
  2. try {
  3.   if (available()) {

代码示例来源：origin: codefollower/Tomcat-Research

  1. request.getReadListener() != null) {
  2. try {
  3.   if (inputBuffer.available() > 0) {

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

request

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Request类方法

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