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

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

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

Response.action介绍

暂无

代码示例

代码示例来源:origin: org.apache.geronimo.ext.tomcat/catalina

/** Signal that we're done with the headers, and body will follow.
 *  Any implementation needs to notify ContextManager, to allow
 *  interceptors to fix headers.
 */
public void sendHeaders() {
  action(ActionCode.COMMIT, this);
  commited = true;
}

代码示例来源:origin: com.ovea.tajin.server/tajin-server-tomcat7

/** Signal that we're done with the headers, and body will follow.
 *  Any implementation needs to notify ContextManager, to allow
 *  interceptors to fix headers.
 */
public void sendHeaders() {
  action(ActionCode.COMMIT, this);
  commited = true;
}

代码示例来源:origin: org.jboss.web/jbossweb

/** Signal that we're done with the headers, and body will follow.
 *  Any implementation needs to notify ContextManager, to allow
 *  interceptors to fix headers.
 */
public void sendHeaders() throws IOException {
  action(ActionCode.ACTION_COMMIT, this);
  commited = true;
}

代码示例来源:origin: jboss.web/jbossweb

/** Signal that we're done with the headers, and body will follow.
 *  Any implementation needs to notify ContextManager, to allow
 *  interceptors to fix headers.
 */
public void sendHeaders() throws IOException {
  action(ActionCode.ACTION_COMMIT, this);
  commited = true;
}

代码示例来源:origin: org.apache.coyote.springsource/com.springsource.org.apache.coyote.springsource

/** Signal that we're done with the headers, and body will follow.
 *  Any implementation needs to notify ContextManager, to allow
 *  interceptors to fix headers.
 */
public void sendHeaders() throws IOException {
  action(ActionCode.ACTION_COMMIT, this);
  commited = true;
}

代码示例来源:origin: org.apache.coyote/com.springsource.org.apache.coyote

/** Signal that we're done with the headers, and body will follow.
 *  Any implementation needs to notify ContextManager, to allow
 *  interceptors to fix headers.
 */
public void sendHeaders() {
  action(ActionCode.COMMIT, this);
  commited = true;
}

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

public void acknowledge() {
  action(ActionCode.ACK, this);
}

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

private void finish() {
  if (!response.isCommitted()) {
    response.action(ActionCode.COMMIT, response);
  }
  if (finished)
    return;
  finished = true;
  response.action(ActionCode.CLOSE, null);
}

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

public boolean checkRegisterForWrite(boolean internal) {
  AtomicBoolean ready = new AtomicBoolean(false);
  synchronized (nonBlockingStateLock) {
    if (!registeredForWrite || internal) {
      action(ActionCode.NB_WRITE_INTEREST, ready);
      registeredForWrite = !ready.get();
    }
  }
  return ready.get();
}

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

public boolean checkRegisterForWrite() {
  AtomicBoolean ready = new AtomicBoolean(false);
  synchronized (nonBlockingStateLock) {
    if (!registeredForWrite) {
      action(ActionCode.NB_WRITE_INTEREST, ready);
      registeredForWrite = !ready.get();
    }
  }
  return ready.get();
}

代码示例来源:origin: com.ovea.tajin.server/tajin-server-tomcat7

/**
   * Bytes written to socket - i.e. after compression, chunking, etc.
   */
  public long getBytesWritten(boolean flush) {
    if (flush) {
      action(ActionCode.CLIENT_FLUSH, this);
    }
    return outputBuffer.getBytesWritten();
  }
}

代码示例来源:origin: jboss.web/jbossweb

/**
 * Return the amount of bytes written by the lower layer.
 */
protected int lastWrite() {
  int res = coyoteResponse.getLastWrite();
  if (res == 0) {
    coyoteResponse.action(ActionCode.ACTION_EVENT_WRITE, null);
  }
  return res;
}

代码示例来源:origin: org.apache.geronimo.ext.tomcat/catalina

/**
   * Bytes written to socket - i.e. after compression, chunking, etc.
   */
  public long getBytesWritten(boolean flush) {
    if (flush) {
      action(ActionCode.CLIENT_FLUSH, this);
    }
    return outputBuffer.getBytesWritten();
  }
}

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

/** Signal that we're done with the headers, and body will follow.
 *  Any implementation needs to notify ContextManager, to allow
 *  interceptors to fix headers.
 */
public void sendHeaders() {
  action(ActionCode.COMMIT, this);
  setCommitted(true);
}

代码示例来源:origin: org.jboss.web/jbossweb

/**
 * Return the amount of bytes written by the lower layer.
 */
protected int lastWrite() {
  int res = coyoteResponse.getLastWrite();
  if (res == 0) {
    coyoteResponse.action(ActionCode.ACTION_EVENT_WRITE, null);
  }
  return res;
}

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

/**
 * Bytes written to socket - i.e. after compression, chunking, etc.
 */
public long getBytesWritten(boolean flush) {
  if (flush) {
    action(ActionCode.CLIENT_FLUSH, this);
  }
  return outputBuffer.getBytesWritten();
}

代码示例来源:origin: org.apache.coyote/com.springsource.org.apache.coyote

/**
   * Bytes written to socket - i.e. after compression, chunking, etc.
   */
  public long getBytesWritten(boolean flush) {
    if (flush) {
      action(ActionCode.CLIENT_FLUSH, this);
    }
    return outputBuffer.getBytesWritten();
  }
}

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

public void setTrailerFields(Supplier<Map<String, String>> supplier) {
  AtomicBoolean trailerFieldsSupported = new AtomicBoolean(false);
  action(ActionCode.IS_TRAILER_FIELDS_SUPPORTED, trailerFieldsSupported);
  if (!trailerFieldsSupported.get()) {
    throw new IllegalStateException(sm.getString("response.noTrailers.notSupported"));
  }
  this.trailerFieldsSupplier = supplier;
}

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

/** Signal that we're done with the headers, and body will follow.
 *  Any implementation needs to notify ContextManager, to allow
 *  interceptors to fix headers.
 */
public void sendHeaders() {
  action(ActionCode.COMMIT, this);
  setCommitted(true);
}

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

private void finish() {
  if (!response.isCommitted()) {
    response.action(ActionCode.COMMIT, response);
  }
  if (finished)
    return;
  finished = true;
  response.finish();
}

相关文章