本文整理了Java中org.eclipse.jetty.server.Response.getContentCount
方法的一些代码示例,展示了Response.getContentCount
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Response.getContentCount
方法的具体详情如下:
包路径:org.eclipse.jetty.server.Response
类名称:Response
方法名:getContentCount
暂无
代码示例来源:origin: gocd/gocd
@Override
public long getContentCount() {
return ((Response) servletResponse).getContentCount();
}
}
代码示例来源:origin: gocd/gocd
@Test
public void shouldGetResponseContentCount() {
when(response.getContentCount()).thenReturn(2000l);
assertThat(jetty9Response.getContentCount(), is(2000l));
}
}
代码示例来源:origin: i2p/i2p.i2p
long responseLength=response.getContentCount();
代码示例来源:origin: ch.qos.logback/logback-access
@Override
public long getContentLength() {
return response.getContentCount();
}
代码示例来源:origin: theonedev/onedev
@Override
public void setBufferSize(int size)
{
if (isCommitted())
throw new IllegalStateException("cannot set buffer size after response is in committed state");
if (getContentCount() > 0)
throw new IllegalStateException("cannot set buffer size after response has " + getContentCount() + " bytes already written");
if (size < __MIN_BUFFER_SIZE)
size = __MIN_BUFFER_SIZE;
_out.setBufferSize(size);
}
代码示例来源:origin: jenkinsci/winstone
@Override
public void setBufferSize(int size)
{
if (isCommitted())
throw new IllegalStateException("cannot set buffer size after response is in committed state");
if (getContentCount() > 0)
throw new IllegalStateException("cannot set buffer size after response has " + getContentCount() + " bytes already written");
if (size < __MIN_BUFFER_SIZE)
size = __MIN_BUFFER_SIZE;
_out.setBufferSize(size);
}
代码示例来源:origin: cdapio/cdap
@Override
public void handle(String target, Request baseRequest, HttpServletRequest request,
HttpServletResponse response) throws IOException, ServletException {
String requestLine = request.getMethod() + " " + request.getRequestURI() + " " + request.getProtocol();
AuditLogEntry logEntry = new AuditLogEntry(requestLine, request.getRemoteUser(),
InetAddress.getByName(request.getRemoteAddr()).getHostAddress(),
Collections.<String, String>emptyMap());
logEntry.setResponse(response.getStatus(), ((Response) response).getContentCount());
logger.trace(logEntry.toString());
}
}
代码示例来源:origin: at.bestsolution.efxclipse.eclipse/org.eclipse.jetty.server
@Override
public void setBufferSize(int size)
{
if (isCommitted() || getContentCount() > 0)
throw new IllegalStateException("cannot set buffer size on committed response");
if (size <= 0)
size = __MIN_BUFFER_SIZE;
_out.setBufferSize(size);
}
代码示例来源:origin: com.ovea.tajin.server/tajin-server-jetty9
@Override
public void setBufferSize(int size)
{
if (isCommitted() || getContentCount() > 0)
throw new IllegalStateException("Committed or content written");
_out.setBufferSize(size);
}
代码示例来源:origin: com.ovea.tajin.servers/tajin-server-jetty9
@Override
public void setBufferSize(int size)
{
if (isCommitted() || getContentCount() > 0)
throw new IllegalStateException("Committed or content written");
_out.setBufferSize(size);
}
代码示例来源:origin: Nextdoor/bender
@Override
public void setBufferSize(int size)
{
if (isCommitted() || getContentCount() > 0)
throw new IllegalStateException("Committed or content written");
if (size <= 0)
size = __MIN_BUFFER_SIZE;
_out.setBufferSize(size);
}
代码示例来源:origin: org.eclipse.jetty.aggregate/jetty-all-server
public void setBufferSize(int size)
{
if (isCommitted() || getContentCount()>0)
throw new IllegalStateException("Committed or content written");
if (size <= 0)
size = __MIN_BUFFER_SIZE;
_connection.getGenerator().increaseContentBufferSize(size);
}
代码示例来源:origin: org.eclipse.jetty.aggregate/jetty-plus
public void setBufferSize(int size)
{
if (isCommitted() || getContentCount()>0)
throw new IllegalStateException("Committed or content written");
if (size <= 0)
size = __MIN_BUFFER_SIZE;
_connection.getGenerator().increaseContentBufferSize(size);
}
代码示例来源:origin: org.eclipse.jetty/server
public void setBufferSize(int size)
{
if (isCommitted() || getContentCount()>0)
throw new IllegalStateException("Committed or content written");
_connection.getGenerator().increaseContentBufferSize(size);
}
代码示例来源:origin: org.apache.knox/gateway-server
@Override
public void log( Request request, Response response ) {
if( log.isTraceEnabled() ) {
StringBuilder sb = new StringBuilder();
TraceUtil.appendCorrelationContext( sb );
sb.append( "|" );
sb.append( request.getRemoteAddr() );
sb.append( "|" );
sb.append( request.getMethod() );
sb.append( "|" );
sb.append( request.getHttpURI() );
sb.append( "|" );
sb.append( request.getContentLength() );
sb.append( "|" );
sb.append( response.getStatus() );
sb.append( "|" );
sb.append( response.getContentCount() );
sb.append( "|" );
sb.append( System.currentTimeMillis() - request.getTimeStamp() );
log.trace( sb );
}
}
代码示例来源:origin: org.eclipse.jetty.aggregate/jetty-webapp
public void setBufferSize(int size)
{
if (isCommitted() || getContentCount()>0)
throw new IllegalStateException("Committed or content written");
if (size <= 0)
size = __MIN_BUFFER_SIZE;
_connection.getGenerator().increaseContentBufferSize(size);
}
代码示例来源:origin: io.airlift/http-server
@Override
public void log(Request request, Response response)
{
Duration requestTime = new Duration(max(0, System.currentTimeMillis() - request.getTimeStamp()), TimeUnit.MILLISECONDS);
stats.record(request.getContentRead(), response.getContentCount(), requestTime);
}
}
代码示例来源:origin: org.eclipse.jetty.aggregate/jetty-server
public void setBufferSize(int size)
{
if (isCommitted() || getContentCount()>0)
throw new IllegalStateException("Committed or content written");
if (size <= 0)
size = __MIN_BUFFER_SIZE;
_connection.getGenerator().increaseContentBufferSize(size);
}
代码示例来源:origin: com.teradata.airlift/http-server
@Override
public void log(Request request, Response response)
{
Duration requestTime = new Duration(max(0, System.currentTimeMillis() - request.getTimeStamp()), TimeUnit.MILLISECONDS);
long dispatchTime = request.getTimeStamp();
Duration schedulingDelay = new Duration(max(0, dispatchTime - request.getTimeStamp()), TimeUnit.MILLISECONDS);
stats.record(request.getMethod(), response.getStatus(), request.getContentRead(), response.getContentCount(), schedulingDelay, requestTime);
}
}
代码示例来源:origin: com.proofpoint.platform/http-server
@Override
public void log(Request request, Response response)
{
Duration requestTime = new Duration(max(0, System.currentTimeMillis() - request.getTimeStamp()), TimeUnit.MILLISECONDS);
SSLSession sslSession = (SSLSession) request.getAttribute(REQUEST_SSL_SESSION_ATTRIBUTE);
stats.record(request.getContentRead(), response.getContentCount(), requestTime);
detailedRequestStats.requestTimeByCode(response.getStatus(), response.getStatus() / 100).add(requestTime);
if (sslSession != null) {
detailedRequestStats.tlsRequest(sslSession.getProtocol(), sslSession.getCipherSuite()).add(1);
}
}
}
内容来源于网络,如有侵权,请联系作者删除!