本文整理了Java中org.apache.coyote.Request.<init>
方法的一些代码示例,展示了Request.<init>
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Request.<init>
方法的具体详情如下:
包路径:org.apache.coyote.Request
类名称:Request
方法名:<init>
暂无
代码示例来源:origin: line/armeria
@Nullable
private Request convertRequest(ServiceRequestContext ctx, AggregatedHttpMessage req) throws Throwable {
final String mappedPath = ctx.mappedPath();
final Request coyoteReq = new Request();
代码示例来源:origin: org.ops4j.pax.tipi/org.ops4j.pax.tipi.tomcat-embed-core
public AbstractProcessor(Adapter adapter) {
this(adapter, new Request(), new Response());
}
代码示例来源:origin: org.apache.coyote/com.springsource.org.apache.coyote
public AbstractProcessor(AbstractEndpoint endpoint) {
this.endpoint = endpoint;
asyncStateMachine = new AsyncStateMachine(this);
request = new Request();
response = new Response();
response.setHook(this);
request.setResponse(response);
}
代码示例来源:origin: org.apache.geronimo.ext.tomcat/catalina
public AbstractProcessor(AbstractEndpoint endpoint) {
this.endpoint = endpoint;
asyncStateMachine = new AsyncStateMachine<S>(this);
request = new Request();
response = new Response();
response.setHook(this);
request.setResponse(response);
}
代码示例来源:origin: codefollower/Tomcat-Research
public AbstractProcessor(AbstractEndpoint<S> endpoint) {
this.endpoint = endpoint;
asyncStateMachine = new AsyncStateMachine<>(this);
request = new Request();
response = new Response();
response.setHook(this);
request.setResponse(response);
}
代码示例来源:origin: org.apache.coyote.springsource/com.springsource.org.apache.coyote.springsource
private Request checkRequest(MsgContext ep) {
Request req=ep.getRequest();
if( req==null ) {
req=new Request();
Response res=new Response();
req.setResponse(res);
ep.setRequest( req );
if( registerRequests ) {
synchronized(lock) {
ep.getSource().registerRequest(req, ep, count++);
}
}
}
return req;
}
代码示例来源:origin: org.apache.coyote.springsource/com.springsource.org.apache.coyote.springsource
public Http11Processor(int headerBufferSize, JIoEndpoint endpoint) {
this.endpoint = endpoint;
request = new Request();
inputBuffer = new InternalInputBuffer(request, headerBufferSize);
request.setInputBuffer(inputBuffer);
response = new Response();
response.setHook(this);
outputBuffer = new InternalOutputBuffer(response, headerBufferSize);
response.setOutputBuffer(outputBuffer);
request.setResponse(response);
initializeFilters();
// Cause loading of HexUtils
int foo = HexUtils.DEC[0];
}
代码示例来源:origin: org.glassfish.metro/webservices-extra
/**
* Initialize the stream and the buffer used to parse the request.
*/
@Override
public void initialize(){
started = true;
request = new Request();
response = new Response();
response.setHook(this);
inputBuffer = new InternalInputBuffer(request,requestBufferSize);
outputBuffer = new SSLAsyncOutputBuffer(response,maxHttpHeaderSize,
bufferResponse);
request.setInputBuffer(inputBuffer);
response.setOutputBuffer(outputBuffer);
request.setResponse(response);
initializeFilters();
}
代码示例来源:origin: org.glassfish.metro/webservices-extra
/**
* Initialize the stream and the buffer used to parse the request.
*/
@Override
public void initialize(){
started = true;
request = new Request();
response = new Response();
response.setHook(this);
inputBuffer = new InternalInputBuffer(request,requestBufferSize);
outputBuffer = new InternalOutputBuffer(response,
maxHttpHeaderSize , true);
request.setInputBuffer(inputBuffer);
response.setOutputBuffer(outputBuffer);
request.setResponse(response);
initializeFilters();
}
代码示例来源:origin: org.glassfish.metro/webservices-extra
/**
* Initialize the stream and the buffer used to parse the request.
*/
@Override
public void initialize(){
started = true;
request = new Request();
response = new Response();
response.setHook(this);
inputBuffer = new InternalInputBuffer(request,requestBufferSize);
outputBuffer = new SSLOutputBuffer(response,maxHttpHeaderSize,
bufferResponse);
request.setInputBuffer(inputBuffer);
response.setOutputBuffer(outputBuffer);
request.setResponse(response);
initializeFilters();
}
代码示例来源:origin: com.ovea.tajin.server/tajin-server-tomcat7
public Http11Processor(int headerBufferSize, JIoEndpoint endpoint,
int maxTrailerSize) {
this.endpoint = endpoint;
request = new Request();
inputBuffer = new InternalInputBuffer(request, headerBufferSize);
request.setInputBuffer(inputBuffer);
response = new Response();
response.setHook(this);
outputBuffer = new InternalOutputBuffer(response, headerBufferSize);
response.setOutputBuffer(outputBuffer);
request.setResponse(response);
initializeFilters(maxTrailerSize);
// Cause loading of HexUtils
HexUtils.load();
}
代码示例来源:origin: org.apache.coyote.springsource/com.springsource.org.apache.coyote.springsource
public Http11AprProcessor(int headerBufferSize, AprEndpoint endpoint) {
this.endpoint = endpoint;
request = new Request();
inputBuffer = new InternalAprInputBuffer(request, headerBufferSize);
request.setInputBuffer(inputBuffer);
response = new Response();
response.setHook(this);
outputBuffer = new InternalAprOutputBuffer(response, headerBufferSize);
response.setOutputBuffer(outputBuffer);
request.setResponse(response);
ssl = endpoint.isSSLEnabled();
initializeFilters();
// Cause loading of HexUtils
int foo = HexUtils.DEC[0];
}
代码示例来源:origin: org.jboss.web/jbossweb
public Http11Processor(int headerBufferSize, JIoEndpoint endpoint) {
this.endpoint = endpoint;
request = new Request();
inputBuffer = new InternalInputBuffer(request, headerBufferSize);
request.setInputBuffer(inputBuffer);
response = new Response();
response.setHook(this);
outputBuffer = new InternalOutputBuffer(response, headerBufferSize);
response.setOutputBuffer(outputBuffer);
request.setResponse(response);
initializeFilters();
// Cause loading of HexUtils
int foo = HexUtils.DEC[0];
// Cause loading of FastHttpDateFormat
FastHttpDateFormat.getCurrentDate();
}
代码示例来源:origin: jboss.web/jbossweb
public Http11Processor(int headerBufferSize, JIoEndpoint endpoint) {
this.endpoint = endpoint;
request = new Request();
inputBuffer = new InternalInputBuffer(request, headerBufferSize);
request.setInputBuffer(inputBuffer);
response = new Response();
response.setHook(this);
outputBuffer = new InternalOutputBuffer(response, headerBufferSize);
response.setOutputBuffer(outputBuffer);
request.setResponse(response);
initializeFilters();
// Cause loading of HexUtils
int foo = HexUtils.DEC[0];
// Cause loading of FastHttpDateFormat
FastHttpDateFormat.getCurrentDate();
}
代码示例来源:origin: org.apache.coyote.springsource/com.springsource.org.apache.coyote.springsource
public Http11NioProcessor(int rxBufSize, int txBufSize, int maxHttpHeaderSize, NioEndpoint endpoint) {
this.endpoint = endpoint;
request = new Request();
int readTimeout = endpoint.getSoTimeout();
inputBuffer = new InternalNioInputBuffer(request, maxHttpHeaderSize);
request.setInputBuffer(inputBuffer);
response = new Response();
response.setHook(this);
outputBuffer = new InternalNioOutputBuffer(response, maxHttpHeaderSize);
response.setOutputBuffer(outputBuffer);
request.setResponse(response);
ssl = endpoint.isSSLEnabled();
initializeFilters();
// Cause loading of HexUtils
int foo = HexUtils.DEC[0];
}
代码示例来源:origin: org.jboss.web/jbossweb
public Http11AprProcessor(int headerBufferSize, AprEndpoint endpoint) {
this.endpoint = endpoint;
request = new Request();
inputBuffer = new InternalAprInputBuffer(request, headerBufferSize, endpoint);
request.setInputBuffer(inputBuffer);
if (endpoint.getUseSendfile()) {
request.setSendfile(true);
}
response = new Response();
response.setHook(this);
outputBuffer = new InternalAprOutputBuffer(response, headerBufferSize, endpoint);
response.setOutputBuffer(outputBuffer);
request.setResponse(response);
ssl = endpoint.isSSLEnabled();
initializeFilters();
Http11AbstractProcessor.containerThread.set(Boolean.FALSE);
// Cause loading of HexUtils
int foo = HexUtils.DEC[0];
// Cause loading of FastHttpDateFormat
FastHttpDateFormat.getCurrentDate();
}
代码示例来源:origin: org.ops4j.pax.tipi/org.ops4j.pax.tipi.tomcat-embed-core
private Request cloneRequest(Request source) throws IOException {
Request dest = new Request();
// Transfer the minimal information required for the copy of the Request
// that is passed to the HTTP upgrade process
dest.decodedURI().duplicate(source.decodedURI());
dest.method().duplicate(source.method());
dest.getMimeHeaders().duplicate(source.getMimeHeaders());
dest.requestURI().duplicate(source.requestURI());
return dest;
}
private boolean handleIncompleteRequestLineRead() {
代码示例来源:origin: com.ovea.tajin.server/tajin-server-tomcat7
public Http11NioProcessor(int maxHttpHeaderSize, NioEndpoint endpoint,
int maxTrailerSize) {
this.endpoint = endpoint;
request = new Request();
inputBuffer = new InternalNioInputBuffer(request, maxHttpHeaderSize);
request.setInputBuffer(inputBuffer);
response = new Response();
response.setHook(this);
outputBuffer = new InternalNioOutputBuffer(response, maxHttpHeaderSize);
response.setOutputBuffer(outputBuffer);
request.setResponse(response);
ssl = endpoint.isSSLEnabled();
initializeFilters(maxTrailerSize);
// Cause loading of HexUtils
HexUtils.load();
}
代码示例来源:origin: com.ovea.tajin.server/tajin-server-tomcat7
public Http11AprProcessor(int headerBufferSize, AprEndpoint endpoint,
int maxTrailerSize) {
this.endpoint = endpoint;
request = new Request();
inputBuffer = new InternalAprInputBuffer(request, headerBufferSize);
request.setInputBuffer(inputBuffer);
response = new Response();
response.setHook(this);
outputBuffer = new InternalAprOutputBuffer(response, headerBufferSize);
response.setOutputBuffer(outputBuffer);
request.setResponse(response);
ssl = endpoint.isSSLEnabled();
initializeFilters(maxTrailerSize);
// Cause loading of HexUtils
HexUtils.load();
}
代码示例来源:origin: jboss.web/jbossweb
public Http11AprProcessor(int headerBufferSize, AprEndpoint endpoint) {
this.endpoint = endpoint;
request = new Request();
inputBuffer = new InternalAprInputBuffer(request, headerBufferSize, endpoint);
request.setInputBuffer(inputBuffer);
response = new Response();
response.setHook(this);
outputBuffer = new InternalAprOutputBuffer(response, headerBufferSize, endpoint);
response.setOutputBuffer(outputBuffer);
request.setResponse(response);
ssl = endpoint.isSSLEnabled();
initializeFilters();
// Cause loading of HexUtils
int foo = HexUtils.DEC[0];
// Cause loading of FastHttpDateFormat
FastHttpDateFormat.getCurrentDate();
}
内容来源于网络,如有侵权,请联系作者删除!