org.eclipse.jetty.client.api.Request.getAbortCause()方法的使用及代码示例

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

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

Request.getAbortCause介绍

暂无

代码示例

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

@Override
  public void onBegin(Request redirect)
  {
    Throwable cause = request.getAbortCause();
    if (cause != null)
      redirect.abort(cause);
  }
});

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

@Override
  public void onBegin(Request redirect)
  {
    Throwable cause = request.getAbortCause();
    if (cause != null)
      redirect.abort(cause);
  }
});

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

public void send(HttpExchange exchange)
{
  if (!updateState(State.IDLE, State.BEGIN))
    throw new IllegalStateException();
  Request request = exchange.getRequest();
  Throwable cause = request.getAbortCause();
  if (cause != null)
  {
    exchange.abort(cause);
  }
  else
  {
    LOG.debug("Sending {}", request);
    RequestNotifier notifier = connection.getDestination().getRequestNotifier();
    notifier.notifyBegin(request);
    ContentProvider content = request.getContent();
    this.contentIterator = content == null ? Collections.<ByteBuffer>emptyIterator() : content.iterator();
    boolean updated = updateSendState(SendState.IDLE, SendState.EXECUTE);
    assert updated;
    // Setting the listener may trigger calls to onContent() by other
    // threads so we must set it only after the state has been updated
    if (content instanceof AsyncContentProvider)
      ((AsyncContentProvider)content).setListener(this);
    send();
  }
}

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

public void send(HttpExchange exchange)
{
  if (!updateState(State.IDLE, State.BEGIN))
    throw new IllegalStateException();
  Request request = exchange.getRequest();
  Throwable cause = request.getAbortCause();
  if (cause != null)
  {
    exchange.abort(cause);
  }
  else
  {
    LOG.debug("Sending {}", request);
    RequestNotifier notifier = connection.getDestination().getRequestNotifier();
    notifier.notifyBegin(request);
    ContentProvider content = request.getContent();
    this.contentIterator = content == null ? Collections.<ByteBuffer>emptyIterator() : content.iterator();
    boolean updated = updateSendState(SendState.IDLE, SendState.EXECUTE);
    assert updated;
    // Setting the listener may trigger calls to onContent() by other
    // threads so we must set it only after the state has been updated
    if (content instanceof AsyncContentProvider)
      ((AsyncContentProvider)content).setListener(this);
    send();
  }
}

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

Throwable cause = request.getAbortCause();
if (cause != null)

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

Throwable cause = request.getAbortCause();
if (cause != null)

代码示例来源:origin: org.eclipse.jetty/jetty-client

Throwable cause = request.getAbortCause();
if (cause != null)

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

if (result == null && notCommitted && request.getAbortCause() == null)

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

if (result == null && notCommitted && request.getAbortCause() == null)

相关文章