org.eclipse.jetty.server.Response.getContentCount()方法的使用及代码示例

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

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

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);
    }
  }
}

相关文章

微信公众号

最新文章

更多