本文整理了Java中org.glassfish.grizzly.http.server.Response.isSuspended
方法的一些代码示例,展示了Response.isSuspended
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Response.isSuspended
方法的具体详情如下:
包路径:org.glassfish.grizzly.http.server.Response
类名称: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();
}
}
}
内容来源于网络,如有侵权,请联系作者删除!