org.glassfish.grizzly.http.server.Response.isSuspended()方法的使用及代码示例

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

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

Response.isSuspended介绍

[英]Return true if that Response#suspend() has been invoked and set to true
[中]如果已调用响应#suspend()并将其设置为true,则返回true

代码示例

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

@Override
public void commit() {
  try {
    if (grizzlyResponse.isSuspended()) {
      grizzlyResponse.resume();
    }
  } finally {
    logger.debugLog("{0} - commit() called", name);
  }
}

代码示例来源:origin: javaee/grizzly

@Override
public boolean isSuspended() {
  return Response.this.isSuspended();
}

代码示例来源:origin: org.glassfish.grizzly/grizzly-http-server-core

@Override
public boolean isSuspended() {
  return Response.this.isSuspended();
}

代码示例来源:origin: javaee/grizzly

@Override
public boolean isSuspended() {
  return Response.this.isSuspended();
}

代码示例来源:origin: org.glassfish.grizzly/grizzly-http-server

@Override
public boolean isSuspended() {
  return Response.this.isSuspended();
}

代码示例来源:origin: javaee/grizzly

@Override
public boolean isSuspended() {
  return Response.this.isSuspended();
}

代码示例来源:origin: javaee/grizzly

@Override
public boolean isSuspended() {
  return Response.this.isSuspended();
}

代码示例来源:origin: javaee/grizzly

@Override
public boolean isSuspended() {
  return Response.this.isSuspended();
}

代码示例来源:origin: org.mule.glassfish.grizzly/grizzly-http-server

@Override
public boolean isSuspended() {
  return Response.this.isSuspended();
}

代码示例来源:origin: org.glassfish.grizzly/grizzly-websockets-server

@Override
public boolean isSuspended() {
  return Response.this.isSuspended();
}

代码示例来源:origin: javaee/grizzly

@Override
public boolean isSuspended() {
  return Response.this.isSuspended();
}

代码示例来源:origin: javaee/grizzly

@Override
public boolean isSuspended() {
  return Response.this.isSuspended();
}

代码示例来源:origin: org.glassfish.jersey.containers/jersey-container-grizzly2-http

@Override
public void commit() {
  try {
    if (grizzlyResponse.isSuspended()) {
      grizzlyResponse.resume();
    }
  } finally {
    logger.debugLog("{0} - commit() called", name);
  }
}

代码示例来源:origin: javaee/grizzly

@Override
public void onError(Throwable t) {
  LOGGER.log(Level.WARNING, "[onError]", t);
  response.setStatus(500, t.getMessage());
  complete(true);
  
  if (response.isSuspended()) {
    response.resume();
  } else {
    response.finish();                    
  }
}

代码示例来源:origin: javaee/grizzly

@Override
public void sendfile(final File file, final long offset, final long length,
    final CompletionHandler<WriteResult> handler) {
  if (!sendfileEnabled) {
        throw new IllegalStateException("sendfile support isn't available.");
  }
  // check the suspend status at the time this method was invoked
  // and take action based on this value
  final boolean suspendedAtStart = serverResponse.isSuspended();
  final CompletionHandler<WriteResult> ch;
  if (suspendedAtStart && handler != null) {
    // provided CompletionHandler assumed to manage suspend/resume
    ch = handler;
  } else if (!suspendedAtStart && handler != null) {
    // provided CompletionHandler assumed to not managed suspend/resume
    ch = suspendAndCreateHandler(handler);
  } else {
    // create internal CompletionHandler that will take the
    // appropriate action depending on the current suspend status
    ch = createInternalCompletionHandler(file, suspendedAtStart);
  }
  super.sendfile(file, offset, length, ch);
}

代码示例来源:origin: javaee/grizzly

@Override
public void sendfile(final File file, final long offset, final long length,
    final CompletionHandler<WriteResult> handler) {
  if (!sendfileEnabled) {
        throw new IllegalStateException("sendfile support isn't available.");
  }
  // check the suspend status at the time this method was invoked
  // and take action based on this value
  final boolean suspendedAtStart = serverResponse.isSuspended();
  final CompletionHandler<WriteResult> ch;
  if (suspendedAtStart && handler != null) {
    // provided CompletionHandler assumed to manage suspend/resume
    ch = handler;
  } else if (!suspendedAtStart && handler != null) {
    // provided CompletionHandler assumed to not managed suspend/resume
    ch = suspendAndCreateHandler(handler);
  } else {
    // create internal CompletionHandler that will take the
    // appropriate action depending on the current suspend status
    ch = createInternalCompletionHandler(file, suspendedAtStart);
  }
  super.sendfile(file, offset, length, ch);
}

代码示例来源:origin: org.glassfish.grizzly/grizzly-websockets-server

@Override
public void sendfile(final File file, final long offset, final long length,
    final CompletionHandler<WriteResult> handler) {
  if (!sendfileEnabled) {
        throw new IllegalStateException("sendfile support isn't available.");
  }
  // check the suspend status at the time this method was invoked
  // and take action based on this value
  final boolean suspendedAtStart = serverResponse.isSuspended();
  final CompletionHandler<WriteResult> ch;
  if (suspendedAtStart && handler != null) {
    // provided CompletionHandler assumed to manage suspend/resume
    ch = handler;
  } else if (!suspendedAtStart && handler != null) {
    // provided CompletionHandler assumed to not managed suspend/resume
    ch = suspendAndCreateHandler(handler);
  } else {
    // create internal CompletionHandler that will take the
    // appropriate action depending on the current suspend status
    ch = createInternalCompletionHandler(file, suspendedAtStart);
  }
  super.sendfile(file, offset, length, ch);
}

代码示例来源:origin: javaee/grizzly

@Override
public void sendfile(final File file, final long offset, final long length,
    final CompletionHandler<WriteResult> handler) {
  if (!sendfileEnabled) {
        throw new IllegalStateException("sendfile support isn't available.");
  }
  // check the suspend status at the time this method was invoked
  // and take action based on this value
  final boolean suspendedAtStart = serverResponse.isSuspended();
  final CompletionHandler<WriteResult> ch;
  if (suspendedAtStart && handler != null) {
    // provided CompletionHandler assumed to manage suspend/resume
    ch = handler;
  } else if (!suspendedAtStart && handler != null) {
    // provided CompletionHandler assumed to not managed suspend/resume
    ch = suspendAndCreateHandler(handler);
  } else {
    // create internal CompletionHandler that will take the
    // appropriate action depending on the current suspend status
    ch = createInternalCompletionHandler(file, suspendedAtStart);
  }
  super.sendfile(file, offset, length, ch);
}

代码示例来源:origin: org.glassfish.grizzly/grizzly-http-server-core

@Override
public void sendfile(final File file, final long offset, final long length,
    final CompletionHandler<WriteResult> handler) {
  if (!sendfileEnabled) {
        throw new IllegalStateException("sendfile support isn't available.");
  }
  // check the suspend status at the time this method was invoked
  // and take action based on this value
  final boolean suspendedAtStart = serverResponse.isSuspended();
  final CompletionHandler<WriteResult> ch;
  if (suspendedAtStart && handler != null) {
    // provided CompletionHandler assumed to manage suspend/resume
    ch = handler;
  } else if (!suspendedAtStart && handler != null) {
    // provided CompletionHandler assumed to not managed suspend/resume
    ch = suspendAndCreateHandler(handler);
  } else {
    // create internal CompletionHandler that will take the
    // appropriate action depending on the current suspend status
    ch = createInternalCompletionHandler(file, suspendedAtStart);
  }
  super.sendfile(file, offset, length, ch);
}

代码示例来源:origin: org.glassfish.grizzly/grizzly-http-server

/**
   * Complete the download
   */
  private void complete(final boolean isError) {
    try {
      fileChannel.close();
    } catch (IOException e) {
      if (!isError) {
        response.setStatus(500, e.getMessage());
      }
    }
    try {
      outputStream.close();
    } catch (IOException e) {
      if (!isError) {
        response.setStatus(500, e.getMessage());
      }
    }
    if (response.isSuspended()) {
      response.resume();
    } else {
      response.finish();
    }
  }
}

相关文章

微信公众号

最新文章

更多

Response类方法