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

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

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

Response.getStatus介绍

暂无

代码示例

代码示例来源:origin: gocd/gocd

@Override
public int getStatus() {
  return ((Response) servletResponse).getStatus();
}

代码示例来源:origin: neo4j/neo4j

@Override
public void log( Request request, Response response )
{
  // Trying to replicate this logback pattern:
  // %h %l %user [%t{dd/MMM/yyyy:HH:mm:ss Z}] "%r" %s %b "%i{Referer}" "%i{User-Agent}" %D
  String remoteHost = swallowExceptions( request, HttpServletRequest::getRemoteHost );
  String user = swallowExceptions( request, HttpServletRequest::getRemoteUser );
  String requestURL = swallowExceptions( request, HttpServletRequest::getRequestURI ) + "?" +
      swallowExceptions( request, HttpServletRequest::getQueryString );
  int statusCode = response.getStatus();
  long length = response.getContentLength();
  String referer = swallowExceptions( request, r -> r.getHeader( "Referer" ) );
  String userAgent = swallowExceptions( request, r -> r.getHeader( "User-Agent" ) );
  long requestTimeStamp = request != null ? request.getTimeStamp() : -1;
  long now = System.currentTimeMillis();
  long serviceTime = requestTimeStamp < 0 ? -1 : now - requestTimeStamp;
  log.info( "%s - %s [%tc] \"%s\" %s %s \"%s\" \"%s\" %s",
      defaultString( remoteHost ),
      defaultString( user ),
      now,
      defaultString( requestURL ),
      statusCode,
      length,
      defaultString( referer ),
      defaultString( userAgent ),
      serviceTime );
}

代码示例来源:origin: gocd/gocd

@Test
public void shouldGetResponseStatus() {
  when(response.getStatus()).thenReturn(200);
  assertThat(jetty9Response.getStatus(), is(200));
}

代码示例来源:origin: rnewson/couchdb-lucene

public void handle(String target,
          Request baseRequest,
          HttpServletRequest request,
          HttpServletResponse response) throws IOException {
  final String reason = baseRequest.getResponse().getReason();
  try {
    if (reason != null && reason.startsWith("{")) {
      ServletUtils.sendJsonError(request, response, baseRequest.getResponse().getStatus(),
          new JSONObject(reason));
    } else {
      ServletUtils.sendJsonError(request, response, baseRequest.getResponse().getStatus(),
          reason);
    }
  } catch (final JSONException e) {
    response.sendError(500);
  }
}

代码示例来源:origin: i2p/i2p.i2p

buf.append(request.getProtocol());
buf.append("\" ");
int status = response.getStatus();
if (status<=0)
  status=404;

代码示例来源:origin: ch.qos.logback/logback-access

@Override
public int getStatusCode() {
  return response.getStatus();
}

代码示例来源:origin: com.codahale.metrics/metrics-jetty8

private void updateResponses(Request request) {
    final int response = request.getResponse().getStatus() / 100;
    if (response >= 1 && response <= 5) {
      responses[response - 1].mark();
    }
    activeRequests.dec();
    requests.mark();
  }
}

代码示例来源:origin: org.apache.maven.wagon/wagon-provider-test

@Override
  public void handle( String target, Request baseRequest, HttpServletRequest request,
    HttpServletResponse response ) throws IOException, ServletException
  {
    String method = request.getMethod();
    super.handle( target, baseRequest, request, response );
    handlerRequestResponses.add(
      new HandlerRequestResponse( method, ( (Response) response ).getStatus(), request.getRequestURI() ) );
  }
}

代码示例来源: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);
    }
  }
}

代码示例来源:origin: com.yammer.metrics/metrics-jetty8

private void updateResponses(Request request) {
    final int response = request.getResponse().getStatus() / 100;
    if (response >= 1 && response <= 5) {
      responses[response - 1].mark();
    }
    activeRequests.dec();
    requests.mark();
  }
}

代码示例来源: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.nitorcreations/willow-logging-jetty

@Override
public void log(Request request, Response response) {
 if (_ignorePathMap != null
   && _ignorePathMap.getMatch(request.getRequestURI()) != null)
  return;
 int status = response.getStatus();
 long written = response.getContentLength();
 transmitter.queue(new AccessLogJettyAdapter(request, status, written,
   _preferProxiedForAddress));
}

代码示例来源:origin: theonedev/onedev

protected MetaData.Response newResponseMetaData()
{
  return new MetaData.Response(_channel.getRequest().getHttpVersion(), getStatus(), getReason(), _fields, getLongContentLength());
}

代码示例来源:origin: org.eclipse.jgit/org.eclipse.jgit.junit.http

AccessEvent(Request req, Response rsp) {
  method = req.getMethod();
  uri = req.getRequestURI();
  requestHeaders = cloneHeaders(req);
  parameters = clone(req.getParameterMap());
  status = rsp.getStatus();
  responseHeaders = cloneHeaders(rsp);
}

代码示例来源:origin: com.madgag/org.eclipse.jgit.junit.http

AccessEvent(final Request req, final Response rsp) {
  method = req.getMethod();
  uri = req.getRequestURI();
  requestHeaders = cloneHeaders(req);
  parameters = clone(req.getParameterMap());
  status = rsp.getStatus();
  responseHeaders = cloneHeaders(rsp);
}

代码示例来源:origin: com.ovea.tajin.servers/tajin-server-jetty9

protected ResponseInfo newResponseInfo()
{
  if (_status == HttpStatus.NOT_SET_000)
    _status = HttpStatus.OK_200;
  return new ResponseInfo(_channel.getRequest().getHttpVersion(), _fields, getLongContentLength(), getStatus(), getReason(), _channel.getRequest().isHead());
}

代码示例来源:origin: jenkinsci/winstone

protected MetaData.Response newResponseMetaData()
{
  MetaData.Response info = new MetaData.Response(_channel.getRequest().getHttpVersion(), getStatus(), getReason(), _fields, getLongContentLength());
  info.setTrailerSupplier(getTrailers());
  return info;
}

代码示例来源:origin: com.ovea.tajin.server/tajin-server-jetty9

protected ResponseInfo newResponseInfo()
{
  if (_status == HttpStatus.NOT_SET_000)
    _status = HttpStatus.OK_200;
  return new ResponseInfo(_channel.getRequest().getHttpVersion(), _fields, getLongContentLength(), getStatus(), getReason(), _channel.getRequest().isHead());
}

代码示例来源:origin: at.bestsolution.efxclipse.eclipse/org.eclipse.jetty.server

@Override
  public void onComplete(AsyncEvent event) throws IOException
  {
    AsyncContextEvent ace=(AsyncContextEvent)event;
    String cname=findContextName(ace.getServletContext());
    String rname=findRequestName(ace.getAsyncContext().getRequest());
    
    Request br=Request.getBaseRequest(ace.getAsyncContext().getRequest());
    Response response = br.getResponse();
    String headers=_showHeaders?("\n"+response.getHttpFields().toString()):"";
    
    log("!  ctx=%s r=%s onComplete %s %d%s",cname,rname,ace.getHttpChannelState(),response.getStatus(),headers);
  }
};

代码示例来源:origin: jenkinsci/winstone

@Override
  public void onComplete(AsyncEvent event) throws IOException
  {
    AsyncContextEvent ace=(AsyncContextEvent)event;
    String cname=findContextName(ace.getServletContext());
    String rname=findRequestName(ace.getAsyncContext().getRequest());
    
    Request br=Request.getBaseRequest(ace.getAsyncContext().getRequest());
    Response response = br.getResponse();
    String headers=_showHeaders?("\n"+response.getHttpFields().toString()):"";
    
    log("!  ctx=%s r=%s onComplete %s %d%s",cname,rname,ace.getHttpChannelState(),response.getStatus(),headers);
  }
};

相关文章

微信公众号

最新文章

更多