| 95 | } |
| 96 | |
| 97 | inline ::grpc::Status ToGrpcStatus(const ::tensorflow::Status& s) { |
| 98 | if (s.ok()) { |
| 99 | return ::grpc::Status::OK; |
| 100 | } else { |
| 101 | if (s.error_message().size() > 3072 /* 3k bytes */) { |
| 102 | // TODO(b/62947679): Remove truncation once the gRPC issue is resolved. |
| 103 | string scratch = |
| 104 | strings::Printf("%.3072s ... [truncated]", s.error_message().c_str()); |
| 105 | LOG(ERROR) << "Truncated error message: " << s; |
| 106 | return ::grpc::Status(static_cast<::grpc::StatusCode>(s.code()), scratch); |
| 107 | } |
| 108 | return ::grpc::Status(static_cast<::grpc::StatusCode>(s.code()), |
| 109 | s.error_message()); |
| 110 | } |
| 111 | } |
| 112 | |
| 113 | typedef std::shared_ptr<::grpc::Channel> SharedGrpcChannelPtr; |
| 114 |
no test coverage detected