本文整理了Java中org.apache.coyote.Response.action
方法的一些代码示例,展示了Response.action
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Response.action
方法的具体详情如下:
包路径:org.apache.coyote.Response
类名称: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();
}
内容来源于网络,如有侵权,请联系作者删除!