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

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

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

Response.setCommitted介绍

暂无

代码示例

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

/**
 * Commit the response.
 *
 * @throws IOException an underlying I/O error occurred
 */
@Override
protected void commit() throws IOException {
  // The response is now committed
  committed = true;
  response.setCommitted(true);
  if (pos > 0) {
    // Sending the response header buffer
    bbuf.put(headerBuffer, 0, pos);
  }
}

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

/**
 * Commit the response.
 * 
 * @throws IOException an undelying I/O error occured
 */
protected void commit()
  throws IOException {
  // The response is now committed
  committed = true;
  response.setCommitted(true);
  if (pos > 0) {
    // Sending the response header buffer
    bbuf.put(buf, 0, pos);
  }
}

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

/**
 * Commit the response.
 * 
 * @throws IOException an underlying I/O error occurred
 */
@Override
protected void commit() throws IOException {
  // The response is now committed
  committed = true;
  response.setCommitted(true);
  if (pos > 0) {
    // Sending the response header buffer
    bbuf.put(buf, 0, pos);
  }
}

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

/**
 * Commit the response.
 * 
 * @throws IOException an undelying I/O error occured
 */
protected void commit()
  throws IOException {
  // The response is now committed
  committed = true;
  response.setCommitted(true);
  if (pos > 0) {
    // Sending the response header buffer
    bbuf.put(buf, 0, pos);
  }
}

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

/**
 * Commit the response.
 * 
 * @throws IOException an underlying I/O error occurred
 */
@Override
protected void commit() throws IOException {
  // The response is now committed
  committed = true;
  response.setCommitted(true);
  if (pos > 0) {
    // Sending the response header buffer
    bbuf.put(buf, 0, pos);
  }
}

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

/**
 * Commit the response.
 * 
 * @throws IOException an underlying I/O error occurred
 */
@Override
protected void commit() throws IOException {
  // The response is now committed
  committed = true;
  response.setCommitted(true);
  if (pos > 0) {
    // Sending the response header buffer
    bbuf.put(buf, 0, pos);
  }
}

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

/**
 * Commit the response.
 * 
 * @throws IOException
 *             an undelying I/O error occured
 */
protected void commit() throws IOException {
  // The response is now committed
  committed = true;
  response.setCommitted(true);
  if (pos > 0) {
    // Sending the response header buffer
    bbuf.clear();
    bbuf.put(buf, 0, pos);
  }
}

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

/**
 * Commit the response.
 * 
 * @throws IOException an undelying I/O error occured
 */
protected void commit()
  throws IOException {
  // The response is now committed
  committed = true;
  response.setCommitted(true);
  if (pos > 0) {
    // Sending the response header buffer
    bbuf.clear();
    bbuf.put(buf, 0, pos);
  }
}

代码示例来源: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.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: com.ovea.tajin.server/tajin-server-tomcat7

/**
 * Commit the response.
 * 
 * @throws IOException an underlying I/O error occurred
 */
@Override
protected void commit()
  throws IOException {
  // The response is now committed
  committed = true;
  response.setCommitted(true);
  if (pos > 0) {
    // Sending the response header buffer
    addToBB(buf, 0, pos);
  }
}

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

/**
 * Commit the response.
 *
 * @throws IOException an underlying I/O error occurred
 */
@Override
protected void commit() throws IOException {
  // The response is now committed
  committed = true;
  response.setCommitted(true);
  if (pos > 0) {
    // Sending the response header buffer
    addToBB(headerBuffer, 0, pos);
  }
}

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

/**
 * Commit the response.
 * 
 * @throws IOException an undelying I/O error occured
 */
protected void commit()
  throws IOException {
  // The response is now committed
  committed = true;
  response.setCommitted(true);
  if (pos > 0) {
    // Sending the response header buffer
    addToBB(buf, 0, pos);
  }
}

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

/**
 * Commit the response.
 * 
 * @throws IOException an underlying I/O error occurred
 */
@Override
protected void commit()
  throws IOException {
  // The response is now committed
  committed = true;
  response.setCommitted(true);
  if (pos > 0) {
    // Sending the response header buffer
    addToBB(buf, 0, pos);
  }
}

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

/**
 * Commit the response.
 * 
 * @throws IOException an underlying I/O error occurred
 */
@Override
protected void commit()
  throws IOException {
  // The response is now committed
  committed = true;
  response.setCommitted(true);
  if (pos > 0) {
    // Sending the response header buffer
    addToBB(buf, 0, pos);
  }
}

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

/**
 * Commit the response.
 * 
 * @throws IOException an undelying I/O error occured
 */
protected void commit()
  throws IOException {
  // The response is now committed
  committed = true;
  response.setCommitted(true);
  if (pos > 0) {
    // Sending the response header buffer
    if (useSocketBuffer) {
      socketBuffer.append(buf, 0, pos);
    } else {
      outputStream.write(buf, 0, pos);
    }
  }
}

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

/**
 * Commit the response.
 *
 * @throws IOException an underlying I/O error occurred
 */
@Override
protected void commit()
  throws IOException {
  // The response is now committed
  committed = true;
  response.setCommitted(true);
  if (pos > 0) {
    // Sending the response header buffer
    if (useSocketBuffer) {
      socketBuffer.append(headerBuffer, 0, pos);
    } else {
      outputStream.write(headerBuffer, 0, pos);
    }
  }
}

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

/**
 * Commit the response.
 * 
 * @throws IOException an undelying I/O error occured
 */
protected void commit()
  throws IOException {
  // The response is now committed
  committed = true;
  response.setCommitted(true);
  if (pos > 0) {
    // Sending the response header buffer
    if (useSocketBuffer) {
      socketBuffer.append(buf, 0, pos);
    } else {
      outputStream.write(buf, 0, pos);
    }
  }
}

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

/**
 * Commit the response.
 *
 * @throws IOException an underlying I/O error occurred
 */
protected void commit() throws IOException {
  response.setCommitted(true);
  if (headerBuffer.position() > 0) {
    // Sending the response header buffer
    headerBuffer.flip();
    try {
      socketWrapper.write(isBlocking(), headerBuffer);
    } finally {
      headerBuffer.position(0).limit(headerBuffer.capacity());
    }
  }
}

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

@Override
protected final void prepareResponse() throws IOException {
  response.setCommitted(true);
  if (handler.hasAsyncIO() && handler.getProtocol().getUseSendfile()) {
    prepareSendfile();
  }
  prepareHeaders(request, response, sendfileData == null, handler.getProtocol(), stream);
  stream.writeHeaders();
}

相关文章

微信公众号

最新文章

更多