本文整理了Java中org.apache.coyote.Request.action
方法的一些代码示例,展示了Request.action
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Request.action
方法的具体详情如下:
包路径:org.apache.coyote.Request
类名称:Request
方法名:action
暂无
代码示例来源:origin: jboss.web/jbossweb
/**
* Set connection timeout.
*/
public void setTimeout(int timeout) {
coyoteRequest.action(ActionCode.ACTION_EVENT_TIMEOUT, timeout);
}
public void setTimeout0(int timeout) {
代码示例来源:origin: org.apache.tomcat/tomcat-catalina
public boolean isAsyncCompleting() {
if (asyncContext == null) {
return false;
}
AtomicBoolean result = new AtomicBoolean(false);
coyoteRequest.action(ActionCode.ASYNC_IS_COMPLETING, result);
return result.get();
}
代码示例来源:origin: org.apache.tomcat/tomcat-catalina
public boolean isAsyncDispatching() {
if (asyncContext == null) {
return false;
}
AtomicBoolean result = new AtomicBoolean(false);
coyoteRequest.action(ActionCode.ASYNC_IS_DISPATCHING, result);
return result.get();
}
代码示例来源:origin: org.apache.tomcat/tomcat-catalina
public boolean isAsync() {
if (asyncContext == null) {
return false;
}
AtomicBoolean result = new AtomicBoolean(false);
coyoteRequest.action(ActionCode.ASYNC_IS_ASYNC, result);
return result.get();
}
代码示例来源:origin: org.ops4j.pax.tipi/org.ops4j.pax.tipi.tomcat-embed-core
public boolean isTrailerFieldsReady() {
AtomicBoolean result = new AtomicBoolean(false);
action(ActionCode.IS_TRAILER_FIELDS_READY, result);
return result.get();
}
代码示例来源:origin: org.apache.tomcat/tomcat-catalina
public boolean isStarted() {
AtomicBoolean result = new AtomicBoolean(false);
request.getCoyoteRequest().action(
ActionCode.ASYNC_IS_STARTED, result);
return result.get();
}
代码示例来源:origin: org.apache.tomcat/tomcat-catalina
public PushBuilder newPushBuilder(HttpServletRequest request) {
AtomicBoolean result = new AtomicBoolean();
coyoteRequest.action(ActionCode.IS_PUSH_SUPPORTED, result);
if (result.get()) {
return new ApplicationPushBuilder(this, request);
} else {
return null;
}
}
代码示例来源:origin: org.jboss.web/jbossweb
/**
* Returns the Internet Protocol (IP) source port of the client
* or last proxy that sent the request.
*/
public int getRemotePort(){
if (remotePort == -1) {
coyoteRequest.action
(ActionCode.ACTION_REQ_REMOTEPORT_ATTRIBUTE, coyoteRequest);
remotePort = coyoteRequest.getRemotePort();
}
return remotePort;
}
代码示例来源:origin: jboss.web/jbossweb
/**
* Returns the Internet Protocol (IP) source port of the client
* or last proxy that sent the request.
*/
public int getRemotePort(){
if (remotePort == -1) {
coyoteRequest.action
(ActionCode.ACTION_REQ_REMOTEPORT_ATTRIBUTE, coyoteRequest);
remotePort = coyoteRequest.getRemotePort();
}
return remotePort;
}
代码示例来源:origin: org.apache.tomcat/tomcat-catalina
@Override
public void setTimeout(long timeout) {
check();
this.timeout = timeout;
request.getCoyoteRequest().action(ActionCode.ASYNC_SETTIMEOUT,
Long.valueOf(timeout));
}
代码示例来源:origin: org.apache.tomcat/tomcat-catalina
/**
* @return the remote IP address making this Request.
*/
@Override
public String getRemoteAddr() {
if (remoteAddr == null) {
coyoteRequest.action
(ActionCode.REQ_HOST_ADDR_ATTRIBUTE, coyoteRequest);
remoteAddr = coyoteRequest.remoteAddr().toString();
}
return remoteAddr;
}
代码示例来源:origin: org.apache.tomcat/tomcat-catalina
/**
* Check the configuration for aborted uploads and if configured to do so,
* disable the swallowing of any remaining input and close the connection
* once the response has been written.
*/
protected void checkSwallowInput() {
Context context = getContext();
if (context != null && !context.getSwallowAbortedUploads()) {
coyoteRequest.action(ActionCode.DISABLE_SWALLOW_INPUT, null);
}
}
代码示例来源:origin: codefollower/Tomcat-Research
/**
* Return the remote IP address making this Request.
*/
@Override
public String getRemoteAddr() {
if (remoteAddr == null) {
coyoteRequest.action
(ActionCode.REQ_HOST_ADDR_ATTRIBUTE, coyoteRequest);
remoteAddr = coyoteRequest.remoteAddr().toString();
}
return remoteAddr;
}
代码示例来源:origin: org.ops4j.pax.tipi/org.ops4j.pax.tipi.tomcat-embed-core
/**
* @return the remote IP address making this Request.
*/
@Override
public String getRemoteAddr() {
if (remoteAddr == null) {
coyoteRequest.action
(ActionCode.REQ_HOST_ADDR_ATTRIBUTE, coyoteRequest);
remoteAddr = coyoteRequest.remoteAddr().toString();
}
return remoteAddr;
}
代码示例来源:origin: org.apache.tomcat/tomcat-catalina
@Override
public void run() {
request.getCoyoteRequest().action(ActionCode.ASYNC_DISPATCHED, null);
try {
applicationDispatcher.dispatch(servletRequest, servletResponse);
} catch (Exception e) {
throw new RuntimeException(sm.getString("asyncContextImpl.asyncDispachError"), e);
}
}
代码示例来源:origin: org.apache.tomcat/tomcat-catalina
public int available() {
int available = availableInThisBuffer();
if (available == 0) {
coyoteRequest.action(ActionCode.AVAILABLE,
Boolean.valueOf(coyoteRequest.getReadListener() != null));
available = (coyoteRequest.getAvailable() > 0) ? 1 : 0;
}
return available;
}
代码示例来源:origin: org.apache.tomcat/tomcat-catalina
@Override
public void complete() {
if (log.isDebugEnabled()) {
logDebug("complete ");
}
check();
request.getCoyoteRequest().action(ActionCode.ASYNC_COMPLETE, null);
}
代码示例来源:origin: org.ops4j.pax.tipi/org.ops4j.pax.tipi.tomcat-embed-core
@Override
public void complete() {
if (log.isDebugEnabled()) {
logDebug("complete ");
}
check();
request.getCoyoteRequest().action(ActionCode.ASYNC_COMPLETE, null);
}
代码示例来源:origin: org.apache.tomcat/tomcat-catalina
@Override
public void start(final Runnable run) {
if (log.isDebugEnabled()) {
logDebug("start ");
}
check();
Runnable wrapper = new RunnableWrapper(run, context, this.request.getCoyoteRequest());
this.request.getCoyoteRequest().action(ActionCode.ASYNC_RUN, wrapper);
}
代码示例来源:origin: codefollower/Tomcat-Research
@Override
public void start(final Runnable run) {
if (log.isDebugEnabled()) {
logDebug("start ");
}
check();
Runnable wrapper = new RunnableWrapper(run, context, this.request.getCoyoteRequest());
this.request.getCoyoteRequest().action(ActionCode.ASYNC_RUN, wrapper);
}
内容来源于网络,如有侵权,请联系作者删除!