Java 类io.grpc.Status.Code 实例源码

项目：beam 文件：BigtableServiceImpl.java

@Override
public boolean tableExists(String tableId) throws IOException {
  try (BigtableSession session = new BigtableSession(options)) {
    GetTableRequest getTable =
        GetTableRequest.newBuilder()
            .setName(options.getInstanceName().toTableNameStr(tableId))
            .build();
    session.getTableAdminClient().getTable(getTable);
    return true;
  } catch (StatusRuntimeException e) {
    if (e.getStatus().getCode() == Code.NOT_FOUND) {
      return false;
    }
    String message =
        String.format(
            "Error checking whether table %s (BigtableOptions %s) exists", tableId, options);
    LOG.error(message, e);
    throw new IOException(message, e);
  }
}

项目：dropwizard-grpc 文件：GrpcServerTests.java

@Test
public void grpcServerGetsStopped() {
    final DropwizardTestSupport<TestConfiguration> testSupport =
            new DropwizardTestSupport<>(TestApplication.class, resourceFilePath("grpc-test-config.yaml"));

    ManagedChannel channel = null;
    try {
        testSupport.before();
        channel = createPlaintextChannel(testSupport);
        final PersonServiceGrpc.PersonServiceBlockingStub client = PersonServiceGrpc.newBlockingStub(channel);

        testSupport.after();

        try {
            // this should fail as the server is now stopped
            client.getPerson(GetPersonRequest.newBuilder().setName("blah").build());
            fail("Request should have failed.");
        } catch (final Exception e) {
            assertEquals(StatusRuntimeException.class, e.getClass());
            assertEquals(Code.UNAVAILABLE, ((StatusRuntimeException) e).getStatus().getCode());
        }
    } finally {
        testSupport.after();
        shutdownChannel(channel);
    }
}

项目：armeria 文件：GrpcClientTest.java

@Test(timeout = 10000)
public void maxInboundSize_tooBig() {
    StreamingOutputCallRequest request =
            StreamingOutputCallRequest.newBuilder()
                                      .addResponseParameters(ResponseParameters.newBuilder().setSize(1))
                                      .build();
    int size = blockingStub.streamingOutputCall(request).next().getSerializedSize();

    TestServiceBlockingStub stub =
            Clients.newDerivedClient(
                    blockingStub,
                    GrpcClientOptions.MAX_INBOUND_MESSAGE_SIZE_BYTES.newValue(size - 1));
    Throwable t = catchThrowable(() -> stub.streamingOutputCall(request).next());
    assertThat(t).isInstanceOf(StatusRuntimeException.class);
    assertThat(((StatusRuntimeException) t).getStatus().getCode()).isEqualTo(Code.RESOURCE_EXHAUSTED);
    assertThat(Throwables.getStackTraceAsString(t)).contains("exceeds maximum");
}

项目：armeria 文件：GrpcClientTest.java

@Test(timeout = 10000)
public void maxOutboundSize_tooBig() {
    // set at least one field to ensure the size is non-zero.
    StreamingOutputCallRequest request =
            StreamingOutputCallRequest.newBuilder()
                                      .addResponseParameters(ResponseParameters.newBuilder().setSize(1))
                                      .build();
    TestServiceBlockingStub stub =
            Clients.newDerivedClient(
                    blockingStub,
                    GrpcClientOptions.MAX_OUTBOUND_MESSAGE_SIZE_BYTES.newValue(
                            request.getSerializedSize() - 1));
    Throwable t = catchThrowable(() -> stub.streamingOutputCall(request).next());
    assertThat(t).isInstanceOf(StatusRuntimeException.class);
    assertThat(((StatusRuntimeException) t).getStatus().getCode()).isEqualTo(Code.CANCELLED);
    assertThat(Throwables.getStackTraceAsString(t)).contains("message too large");
}

项目：armeria 文件：GrpcServiceServerTest.java

@Test
public void tooLargeRequest_uncompressed() throws Exception {
    SimpleRequest request = SimpleRequest.newBuilder()
                                         .setPayload(
                                                 Payload.newBuilder()
                                                        .setBody(ByteString.copyFrom(
                                                                LARGE_PAYLOAD.toByteArray())))
                                         .build();
    StatusRuntimeException t =
            (StatusRuntimeException) catchThrowable(
                    () -> blockingClient.staticUnaryCall(request));
    // NB: Since gRPC does not support HTTP/1, it just resets the stream with an HTTP/2 CANCEL error code,
    // which clients would interpret as Code.CANCELLED. Armeria supports HTTP/1, so more generically returns
    // an HTTP 500.
    assertThat(t.getStatus().getCode()).isEqualTo(Code.UNKNOWN);
}

项目：armeria 文件：GrpcServiceServerTest.java

@Test
public void tooLargeRequest_compressed() throws Exception {
    SimpleRequest request = SimpleRequest.newBuilder()
                                         .setPayload(
                                                 Payload.newBuilder()
                                                        .setBody(ByteString.copyFrom(
                                                                LARGE_PAYLOAD.toByteArray())))
                                         .build();
    StatusRuntimeException t =
            (StatusRuntimeException) catchThrowable(
                    () -> blockingClient.withCompression("gzip").staticUnaryCall(request));
    // NB: Since gRPC does not support HTTP/1, it just resets the stream with an HTTP/2 CANCEL error code,
    // which clients would interpret as Code.CANCELLED. Armeria supports HTTP/1, so more generically returns
    // an HTTP 500.
    assertThat(t.getStatus().getCode()).isEqualTo(Code.UNKNOWN);
}

项目：grpc-java 文件：OkHttpClientTransportTest.java

@Test
public void maxMessageSizeShouldBeEnforced() throws Exception {
  // Allow the response payloads of up to 1 byte.
  startTransport(3, null, true, 1, null);

  MockStreamListener listener = new MockStreamListener();
  OkHttpClientStream stream =
      clientTransport.newStream(method, new Metadata(), CallOptions.DEFAULT);
  stream.start(listener);
  stream.request(1);
  assertContainStream(3);
  frameHandler().headers(false, false, 3, 0, grpcResponseHeaders(), HeadersMode.HTTP_20_HEADERS);
  assertNotNull(listener.headers);

  // Receive the message.
  final String message = "Hello Client";
  Buffer buffer = createMessageFrame(message);
  frameHandler().data(false, 3, buffer, (int) buffer.size());

  listener.waitUntilStreamClosed();
  assertEquals(Code.RESOURCE_EXHAUSTED, listener.status.getCode());
  shutdownAndVerify();
}

项目：grpc-java 文件：OkHttpClientTransportTest.java

@Test
public void ping_failsIfTransportFails() throws Exception {
  initTransport();
  PingCallbackImpl callback = new PingCallbackImpl();
  clientTransport.ping(callback, MoreExecutors.directExecutor());
  assertEquals(1, clientTransport.getStats().get().keepAlivesSent);
  assertEquals(0, callback.invocationCount);

  clientTransport.onException(new IOException());
  // ping failed on error
  assertEquals(1, callback.invocationCount);
  assertTrue(callback.failureCause instanceof StatusException);
  assertEquals(Status.Code.UNAVAILABLE,
      ((StatusException) callback.failureCause).getStatus().getCode());

  // now that handler is in terminal state, all future pings fail immediately
  callback = new PingCallbackImpl();
  clientTransport.ping(callback, MoreExecutors.directExecutor());
  assertEquals(1, clientTransport.getStats().get().keepAlivesSent);
  assertEquals(1, callback.invocationCount);
  assertTrue(callback.failureCause instanceof StatusException);
  assertEquals(Status.Code.UNAVAILABLE,
      ((StatusException) callback.failureCause).getStatus().getCode());
  shutdownAndVerify();
}

项目：grpc-java 文件：NettyServerHandlerTest.java

@Test
public void streamErrorShouldNotCloseChannel() throws Exception {
  manualSetUp();
  createStream();
  stream.request(1);

  // When a DATA frame is read, throw an exception. It will be converted into an
  // Http2StreamException.
  RuntimeException e = new RuntimeException("Fake Exception");
  doThrow(e).when(streamListener).messagesAvailable(any(StreamListener.MessageProducer.class));

  // Read a DATA frame to trigger the exception.
  channelRead(emptyGrpcFrame(STREAM_ID, true));

  // Verify that the channel was NOT closed.
  assertTrue(channel().isOpen());

  // Verify the stream was closed.
  ArgumentCaptor<Status> captor = ArgumentCaptor.forClass(Status.class);
  verify(streamListener).closed(captor.capture());
  assertEquals(e, captor.getValue().asException().getCause());
  assertEquals(Code.UNKNOWN, captor.getValue().getCode());
}

项目：grpc-java 文件：NettyServerHandlerTest.java

@Test
public void headersWithInvalidContentTypeShouldFail() throws Exception {
  manualSetUp();
  Http2Headers headers = new DefaultHttp2Headers()
      .method(HTTP_METHOD)
      .set(CONTENT_TYPE_HEADER, new AsciiString("application/bad", UTF_8))
      .set(TE_HEADER, TE_TRAILERS)
      .path(new AsciiString("/foo/bar"));
  ByteBuf headersFrame = headersFrame(STREAM_ID, headers);
  channelRead(headersFrame);
  Http2Headers responseHeaders = new DefaultHttp2Headers()
      .set(InternalStatus.CODE_KEY.name(), String.valueOf(Code.INTERNAL.value()))
      .set(InternalStatus.MESSAGE_KEY.name(), "Content-Type 'application/bad' is not supported")
      .status("" + 415)
      .set(CONTENT_TYPE_HEADER, "text/plain; encoding=utf-8");

  verifyWrite().writeHeaders(eq(ctx()), eq(STREAM_ID), eq(responseHeaders), eq(0),
      eq(DEFAULT_PRIORITY_WEIGHT), eq(false), eq(0), eq(false), any(ChannelPromise.class));
}

项目：grpc-java 文件：NettyServerHandlerTest.java

@Test
public void headersWithInvalidMethodShouldFail() throws Exception {
  manualSetUp();
  Http2Headers headers = new DefaultHttp2Headers()
      .method(HTTP_FAKE_METHOD)
      .set(CONTENT_TYPE_HEADER, CONTENT_TYPE_GRPC)
      .path(new AsciiString("/foo/bar"));
  ByteBuf headersFrame = headersFrame(STREAM_ID, headers);
  channelRead(headersFrame);
  Http2Headers responseHeaders = new DefaultHttp2Headers()
      .set(InternalStatus.CODE_KEY.name(), String.valueOf(Code.INTERNAL.value()))
      .set(InternalStatus.MESSAGE_KEY.name(), "Method 'FAKE' is not supported")
      .status("" + 405)
      .set(CONTENT_TYPE_HEADER, "text/plain; encoding=utf-8");

  verifyWrite().writeHeaders(eq(ctx()), eq(STREAM_ID), eq(responseHeaders), eq(0),
      eq(DEFAULT_PRIORITY_WEIGHT), eq(false), eq(0), eq(false), any(ChannelPromise.class));
}

项目：grpc-java 文件：NettyServerHandlerTest.java

@Test
public void headersWithMissingPathShouldFail() throws Exception {
  manualSetUp();
  Http2Headers headers = new DefaultHttp2Headers()
      .method(HTTP_METHOD)
      .set(CONTENT_TYPE_HEADER, CONTENT_TYPE_GRPC);
  ByteBuf headersFrame = headersFrame(STREAM_ID, headers);
  channelRead(headersFrame);
  Http2Headers responseHeaders = new DefaultHttp2Headers()
      .set(InternalStatus.CODE_KEY.name(), String.valueOf(Code.UNIMPLEMENTED.value()))
      .set(InternalStatus.MESSAGE_KEY.name(), "Expected path but is missing")
      .status("" + 404)
      .set(CONTENT_TYPE_HEADER, "text/plain; encoding=utf-8");

  verifyWrite().writeHeaders(eq(ctx()), eq(STREAM_ID), eq(responseHeaders), eq(0),
      eq(DEFAULT_PRIORITY_WEIGHT), eq(false), eq(0), eq(false), any(ChannelPromise.class));
}

项目：grpc-java 文件：NettyServerHandlerTest.java

@Test
public void headersWithInvalidPathShouldFail() throws Exception {
  manualSetUp();
  Http2Headers headers = new DefaultHttp2Headers()
      .method(HTTP_METHOD)
      .set(CONTENT_TYPE_HEADER, CONTENT_TYPE_GRPC)
      .path(new AsciiString("foo/bar"));
  ByteBuf headersFrame = headersFrame(STREAM_ID, headers);
  channelRead(headersFrame);
  Http2Headers responseHeaders = new DefaultHttp2Headers()
      .set(InternalStatus.CODE_KEY.name(), String.valueOf(Code.UNIMPLEMENTED.value()))
      .set(InternalStatus.MESSAGE_KEY.name(), "Expected path to start with /: foo/bar")
      .status("" + 404)
      .set(CONTENT_TYPE_HEADER, "text/plain; encoding=utf-8");

  verifyWrite().writeHeaders(eq(ctx()), eq(STREAM_ID), eq(responseHeaders), eq(0),
      eq(DEFAULT_PRIORITY_WEIGHT), eq(false), eq(0), eq(false), any(ChannelPromise.class));
}

项目：grpc-java 文件：NettyClientTransportTest.java

@Test
public void maxMessageSizeShouldBeEnforced() throws Throwable {
  startServer();
  // Allow the response payloads of up to 1 byte.
  NettyClientTransport transport = newTransport(newNegotiator(),
      1, GrpcUtil.DEFAULT_MAX_HEADER_LIST_SIZE, null, true);
  callMeMaybe(transport.start(clientTransportListener));

  try {
    // Send a single RPC and wait for the response.
    new Rpc(transport).halfClose().waitForResponse();
    fail("Expected the stream to fail.");
  } catch (ExecutionException e) {
    Status status = Status.fromThrowable(e);
    assertEquals(Code.RESOURCE_EXHAUSTED, status.getCode());
    assertTrue("Missing exceeds maximum from: " + status.getDescription(),
        status.getDescription().contains("exceeds maximum"));
  }
}

项目：grpc-java 文件：NettyClientTransportTest.java

@Test
public void maxHeaderListSizeShouldBeEnforcedOnClient() throws Exception {
  startServer();

  NettyClientTransport transport =
      newTransport(newNegotiator(), DEFAULT_MAX_MESSAGE_SIZE, 1, null, true);
  callMeMaybe(transport.start(clientTransportListener));

  try {
    // Send a single RPC and wait for the response.
    new Rpc(transport, new Metadata()).halfClose().waitForResponse();
    fail("The stream should have been failed due to client received header exceeds header list"
        + " size limit!");
  } catch (Exception e) {
    Throwable rootCause = getRootCause(e);
    Status status = ((StatusException) rootCause).getStatus();
    assertEquals(Status.Code.INTERNAL, status.getCode());
    assertEquals("HTTP/2 error code: PROTOCOL_ERROR\nReceived Rst Stream",
        status.getDescription());
  }
}

项目：grpc-java 文件：NettyClientTransportTest.java

@Test
public void maxHeaderListSizeShouldBeEnforcedOnServer() throws Exception {
  startServer(100, 1);

  NettyClientTransport transport = newTransport(newNegotiator());
  callMeMaybe(transport.start(clientTransportListener));

  try {
    // Send a single RPC and wait for the response.
    new Rpc(transport, new Metadata()).halfClose().waitForResponse();
    fail("The stream should have been failed due to server received header exceeds header list"
        + " size limit!");
  } catch (Exception e) {
    Status status = Status.fromThrowable(e);
    assertEquals(status.toString(), Status.Code.INTERNAL, status.getCode());
  }
}

项目：grpc-java 文件：AbstractClientStreamTest.java

@Test
public void cancel_doNotAcceptOk() {
  for (Code code : Code.values()) {
    ClientStreamListener listener = new NoopClientStreamListener();
    AbstractClientStream stream =
        new BaseAbstractClientStream(allocator, statsTraceCtx, transportTracer);
    stream.start(listener);
    if (code != Code.OK) {
      stream.cancel(Status.fromCodeValue(code.value()));
    } else {
      try {
        stream.cancel(Status.fromCodeValue(code.value()));
        fail();
      } catch (IllegalArgumentException e) {
        // ignore
      }
    }
  }
}

项目：grpc-java 文件：Http2ClientStreamTransportStateTest.java

@Test
public void transportHeadersReceived_wrongContentType_401() {
  BaseTransportState state = new BaseTransportState(transportTracer);
  state.setListener(mockListener);
  Metadata headers = new Metadata();
  headers.put(testStatusMashaller, "401");
  headers.put(Metadata.Key.of("content-type", Metadata.ASCII_STRING_MARSHALLER), "text/html");
  state.transportHeadersReceived(headers);
  state.transportDataReceived(ReadableBuffers.empty(), true);

  verify(mockListener, never()).headersRead(any(Metadata.class));
  verify(mockListener).closed(statusCaptor.capture(), same(headers));
  assertEquals(Code.UNAUTHENTICATED, statusCaptor.getValue().getCode());
  assertTrue(statusCaptor.getValue().getDescription().contains("401"));
  assertTrue(statusCaptor.getValue().getDescription().contains("text/html"));
}

项目：grpc-java 文件：Http2ClientStreamTransportStateTest.java

@Test
public void transportHeadersReceived_twice() {
  BaseTransportState state = new BaseTransportState(transportTracer);
  state.setListener(mockListener);
  Metadata headers = new Metadata();
  headers.put(testStatusMashaller, "200");
  headers.put(Metadata.Key.of("content-type", Metadata.ASCII_STRING_MARSHALLER),
      "application/grpc");
  state.transportHeadersReceived(headers);
  Metadata headersAgain = new Metadata();
  state.transportHeadersReceived(headersAgain);
  state.transportDataReceived(ReadableBuffers.empty(), true);

  verify(mockListener).headersRead(headers);
  verify(mockListener).closed(statusCaptor.capture(), same(headersAgain));
  assertEquals(Code.INTERNAL, statusCaptor.getValue().getCode());
  assertTrue(statusCaptor.getValue().getDescription().contains("twice"));
}

项目：grpc-java 文件：Http2ClientStreamTransportStateTest.java

@Test
public void transportHeadersReceived_unknownAndTwiceLogsSecondHeaders() {
  BaseTransportState state = new BaseTransportState(transportTracer);
  state.setListener(mockListener);
  Metadata headers = new Metadata();
  headers.put(testStatusMashaller, "200");
  headers.put(Metadata.Key.of("content-type", Metadata.ASCII_STRING_MARSHALLER), "text/html");
  state.transportHeadersReceived(headers);
  Metadata headersAgain = new Metadata();
  String testString = "This is a test";
  headersAgain.put(Metadata.Key.of("key", Metadata.ASCII_STRING_MARSHALLER), testString);
  state.transportHeadersReceived(headersAgain);
  state.transportDataReceived(ReadableBuffers.empty(), true);

  verify(mockListener, never()).headersRead(any(Metadata.class));
  verify(mockListener).closed(statusCaptor.capture(), same(headers));
  assertEquals(Code.UNKNOWN, statusCaptor.getValue().getCode());
  assertTrue(statusCaptor.getValue().getDescription().contains(testString));
}

项目：grpc-java 文件：Http2ClientStreamTransportStateTest.java

@Test
public void transportTrailersReceived_missingStatusAfterHeadersIgnoresHttpStatus() {
  BaseTransportState state = new BaseTransportState(transportTracer);
  state.setListener(mockListener);
  Metadata headers = new Metadata();
  headers.put(testStatusMashaller, "200");
  headers.put(Metadata.Key.of("content-type", Metadata.ASCII_STRING_MARSHALLER),
      "application/grpc");
  state.transportHeadersReceived(headers);
  Metadata trailers = new Metadata();
  trailers.put(testStatusMashaller, "401");
  state.transportTrailersReceived(trailers);

  verify(mockListener).headersRead(headers);
  verify(mockListener).closed(statusCaptor.capture(), same(trailers));
  assertEquals(Code.UNKNOWN, statusCaptor.getValue().getCode());
}

项目：bazel-buildfarm 文件：RetryException.java

public boolean causedByStatusCode(Code code) {
  if (getCause() instanceof StatusRuntimeException) {
    return ((StatusRuntimeException) getCause()).getStatus().getCode() == code;
  } else if (getCause() instanceof StatusException) {
    return ((StatusException) getCause()).getStatus().getCode() == code;
  }
  return false;
}

项目：jetcd 文件：WatchImpl.java

private boolean isHaltError(Status status) {
  // Unavailable codes mean the system will be right back.
  // (e.g., can't connect, lost leader)
  // Treat Internal codes as if something failed, leaving the
  // system in an inconsistent state, but retrying could make progress.
  // (e.g., failed in middle of send, corrupted frame)
  return status.getCode() != Code.UNAVAILABLE && status.getCode() != Code.INTERNAL;
}

项目：dropwizard-grpc 文件：DropwizardPersonServiceGrpcImplTest.java

@Test
public void testExceptional() {
    try {
        client.exceptional(ExceptionalRequest.newBuilder().setName(TEST_PERSON_NAME).build());
        fail("Should have thrown an exception");
    } catch (final StatusRuntimeException sre) {
        assertEquals(Code.INTERNAL, sre.getStatus().getCode());
    }
}

项目：dgraph4j 文件：DgraphClient.java

private void checkAndThrowException(RuntimeException ex) {
  if (ex instanceof StatusRuntimeException) {
    StatusRuntimeException ex1 = (StatusRuntimeException) ex;
    Code code = ex1.getStatus().getCode();
    String desc = ex1.getStatus().getDescription();
    if (code.equals(Code.ABORTED) || code.equals(Code.FAILED_PRECONDITION)) {
      throw new TxnConflictException(desc);
    }
  }
  throw ex;
}

项目：armeria 文件：GrpcStatus.java

/**
 * Converts the {@link Throwable} to a {@link Status}, taking into account exceptions specific to Armeria as
 * well.
 */
public static Status fromThrowable(Throwable t) {
    requireNonNull(t, "t");
    Status s = Status.fromThrowable(t);
    if (s.getCode() != Code.UNKNOWN) {
        return s;
    }
    if (t instanceof StreamException) {
        StreamException streamException = (StreamException) t;
        if (streamException.getMessage() != null && streamException.getMessage().contains("RST_STREAM")) {
            return Status.CANCELLED;
        }
    }
    if (t instanceof ClosedChannelException) {
        // ClosedChannelException is used any time the Netty channel is closed. Proper error
        // processing requires remembering the error that occurred before this one and using it
        // instead.
        return Status.UNKNOWN.withCause(t);
    }
    if (t instanceof IOException) {
        return Status.UNAVAILABLE.withCause(t);
    }
    if (t instanceof Http2Exception) {
        return Status.INTERNAL.withCause(t);
    }
    if (t instanceof ResponseTimeoutException) {
        return Status.DEADLINE_EXCEEDED.withCause(t);
    }
    return s;
}

项目：armeria 文件：GrpcClientTest.java

@Test(timeout = 10000)
public void cancelAfterBegin() throws Exception {
    StreamRecorder<StreamingInputCallResponse> responseObserver = StreamRecorder.create();
    StreamObserver<StreamingInputCallRequest> requestObserver =
            asyncStub.streamingInputCall(responseObserver);
    requestObserver.onError(new RuntimeException());
    responseObserver.awaitCompletion();
    assertThat(responseObserver.getValues()).isEmpty();
    assertThat(Status.fromThrowable(responseObserver.getError()).getCode()).isEqualTo(Code.CANCELLED);
}

项目：armeria 文件：GrpcClientTest.java

@Test(timeout = 10000)
public void cancelAfterFirstResponse() throws Exception {
    final StreamingOutputCallRequest request =
            StreamingOutputCallRequest.newBuilder()
                                      .addResponseParameters(ResponseParameters.newBuilder()
                                                                               .setSize(31415))
                                      .setPayload(Payload.newBuilder()
                                                         .setBody(ByteString.copyFrom(new byte[27182])))
                                      .build();
    final StreamingOutputCallResponse goldenResponse =
            StreamingOutputCallResponse.newBuilder()
                                       .setPayload(Payload.newBuilder()
                                                          .setType(
                                                                  COMPRESSABLE)
                                                          .setBody(ByteString.copyFrom(new byte[31415])))
                                       .build();

    StreamRecorder<StreamingOutputCallResponse> responseObserver = StreamRecorder.create();
    StreamObserver<StreamingOutputCallRequest> requestObserver
            = asyncStub.fullDuplexCall(responseObserver);
    requestObserver.onNext(request);
    await().untilAsserted(() -> assertThat(responseObserver.firstValue().get()).isEqualTo(goldenResponse));
    requestObserver.onError(new RuntimeException());
    responseObserver.awaitCompletion(operationTimeoutMillis(), TimeUnit.MILLISECONDS);
    assertThat(responseObserver.getValues()).hasSize(1);
    assertThat(Status.fromThrowable(responseObserver.getError()).getCode()).isEqualTo(Code.CANCELLED);
}

项目：armeria 文件：GrpcServiceServerTest.java

@Test
public void error_noMessage() throws Exception {
    StatusRuntimeException t = (StatusRuntimeException) catchThrowable(
            () -> blockingClient.errorNoMessage(REQUEST_MESSAGE));
    assertThat(t.getStatus().getCode()).isEqualTo(Code.ABORTED);
    assertThat(t.getStatus().getDescription()).isNull();
}

项目：armeria 文件：GrpcServiceServerTest.java

@Test
public void error_withMessage() throws Exception {
    StatusRuntimeException t = (StatusRuntimeException) catchThrowable(
            () -> blockingClient.errorWithMessage(REQUEST_MESSAGE));
    assertThat(t.getStatus().getCode()).isEqualTo(Code.ABORTED);
    assertThat(t.getStatus().getDescription()).isEqualTo("aborted call");
}

项目：armeria 文件：GrpcServiceServerTest.java

@Test
public void error_thrown_unary() throws Exception {
    StatusRuntimeException t = (StatusRuntimeException) catchThrowable(
            () -> blockingClient.unaryThrowsError(REQUEST_MESSAGE));
    assertThat(t.getStatus().getCode()).isEqualTo(Code.ABORTED);
    assertThat(t.getStatus().getDescription()).isEqualTo("call aborted");
}

项目：armeria 文件：GrpcServiceServerTest.java

@Test
public void error_thrown_streamMessage() throws Exception {
    StreamRecorder<SimpleResponse> response = StreamRecorder.create();
    StreamObserver<SimpleRequest> request = streamingClient.streamThrowsError(response);
    request.onNext(REQUEST_MESSAGE);
    response.awaitCompletion();
    StatusRuntimeException t = (StatusRuntimeException) response.getError();
    assertThat(t.getStatus().getCode()).isEqualTo(Code.ABORTED);
    assertThat(t.getStatus().getDescription()).isEqualTo("bad streaming message");
}

项目：armeria 文件：GrpcServiceServerTest.java

@Test
public void error_thrown_streamStub() throws Exception {
    StreamRecorder<SimpleResponse> response = StreamRecorder.create();
    streamingClient.streamThrowsErrorInStub(response);
    response.awaitCompletion();
    StatusRuntimeException t = (StatusRuntimeException) response.getError();
    assertThat(t.getStatus().getCode()).isEqualTo(Code.ABORTED);
    assertThat(t.getStatus().getDescription()).isEqualTo("bad streaming stub");
}

项目：bazel 文件：GrpcRemoteExecutor.java

private void handleStatus(Status statusProto) throws IOException {
  StatusRuntimeException e = StatusProto.toStatusRuntimeException(statusProto);
  if (e.getStatus().getCode() == Code.OK) {
    return;
  }
  if (e.getStatus().getCode() == Code.DEADLINE_EXCEEDED) {
    // This was caused by the command itself exceeding the timeout,
    // therefore it is not retriable.
    throw new TimeoutException();
  }
  throw e;
}

项目：bazel 文件：RemoteSpawnRunner.java

private SpawnResult handleError(IOException exception, FileOutErr outErr) throws IOException,
    ExecException {
  final Throwable cause = exception.getCause();
  if (exception instanceof TimeoutException || cause instanceof TimeoutException) {
    // TODO(buchgr): provide stdout/stderr from the action that timed out.
    // Remove the unsuported message once remote execution tests no longer check for it.
    try (OutputStream out = outErr.getOutputStream()) {
      String msg = "Log output for timeouts is not yet supported in remote execution.\n";
      out.write(msg.getBytes(StandardCharsets.UTF_8));
    }
    return new SpawnResult.Builder()
        .setStatus(Status.TIMEOUT)
        .setExitCode(POSIX_TIMEOUT_EXIT_CODE)
        .build();
  }
  final Status status;
  if (exception instanceof RetryException
      && RemoteRetrierUtils.causedByStatus((RetryException) exception, Code.UNAVAILABLE)) {
    status = Status.EXECUTION_FAILED_CATASTROPHICALLY;
  } else if (cause instanceof CacheNotFoundException) {
    status = Status.REMOTE_CACHE_FAILED;
  } else {
    status = Status.EXECUTION_FAILED;
  }
  throw new SpawnExecException(
      Throwables.getStackTraceAsString(exception),
      new SpawnResult.Builder()
          .setStatus(status)
          .setExitCode(ExitCode.REMOTE_ERROR.getNumericExitCode())
          .build(),
      /* forciblyRunRemotely= */ false);
}

项目：grpc-java 文件：CronetClientTransport.java

void finishStream(CronetClientStream stream, Status status) {
  synchronized (lock) {
    if (streams.remove(stream)) {
      boolean isCancelled = (status.getCode() == Code.CANCELLED
          || status.getCode() == Code.DEADLINE_EXCEEDED);
      stream.transportState().transportReportStatus(status, isCancelled, new Metadata());
    } else {
      return;
    }
  }
  stopIfNecessary();
}

项目：grpc-java 文件：OkHttpClientTransport.java

@Override
public void rstStream(int streamId, ErrorCode errorCode) {
  Status status = toGrpcStatus(errorCode).augmentDescription("Rst Stream");
  boolean stopDelivery =
      (status.getCode() == Code.CANCELLED || status.getCode() == Code.DEADLINE_EXCEEDED);
  finishStream(streamId, status, stopDelivery, null, null);
}

项目：grpc-java 文件：OkHttpClientTransportTest.java

@Test
public void readStatus() throws Exception {
  initTransport();
  MockStreamListener listener = new MockStreamListener();
  OkHttpClientStream stream =
      clientTransport.newStream(method, new Metadata(), CallOptions.DEFAULT);
  stream.start(listener);
  assertContainStream(3);
  frameHandler().headers(true, true, 3, 0, grpcResponseTrailers(), HeadersMode.HTTP_20_HEADERS);
  listener.waitUntilStreamClosed();
  assertEquals(Status.Code.OK, listener.status.getCode());
  shutdownAndVerify();
}

项目：grpc-java 文件：OkHttpClientTransportTest.java

@Test
public void receiveReset() throws Exception {
  initTransport();
  MockStreamListener listener = new MockStreamListener();
  OkHttpClientStream stream =
      clientTransport.newStream(method, new Metadata(), CallOptions.DEFAULT);
  stream.start(listener);
  assertContainStream(3);
  frameHandler().rstStream(3, ErrorCode.PROTOCOL_ERROR);
  listener.waitUntilStreamClosed();

  assertThat(listener.status.getDescription()).contains("Rst Stream");
  assertThat(listener.status.getCode()).isEqualTo(Code.INTERNAL);
  shutdownAndVerify();
}

项目：grpc-java 文件：NettyServerHandlerTest.java

@Test
public void clientCancelShouldForwardToStreamListener() throws Exception {
  manualSetUp();
  createStream();

  channelRead(rstStreamFrame(STREAM_ID, (int) Http2Error.CANCEL.code()));

  ArgumentCaptor<Status> statusCap = ArgumentCaptor.forClass(Status.class);
  verify(streamListener).closed(statusCap.capture());
  assertEquals(Code.CANCELLED, statusCap.getValue().getCode());
  Truth.assertThat(statusCap.getValue().getDescription()).contains("RST_STREAM");
  verify(streamListener, atLeastOnce()).onReady();
  assertNull("no messages expected", streamListenerMessageQueue.poll());
}