1 //
2 //
3 // Copyright 2015 gRPC authors.
4 //
5 // Licensed under the Apache License, Version 2.0 (the "License");
6 // you may not use this file except in compliance with the License.
7 // You may obtain a copy of the License at
8 //
9 // http://www.apache.org/licenses/LICENSE-2.0
10 //
11 // Unless required by applicable law or agreed to in writing, software
12 // distributed under the License is distributed on an "AS IS" BASIS,
13 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14 // See the License for the specific language governing permissions and
15 // limitations under the License.
16 //
17 //
18
19 #include "src/core/lib/transport/status_conversion.h"
20
21 #include <memory>
22
23 #include "gtest/gtest.h"
24
25 #include <grpc/support/time.h>
26
27 #include "src/core/lib/iomgr/exec_ctx.h"
28 #include "test/core/util/test_config.h"
29
30 #define GRPC_STATUS_TO_HTTP2_ERROR(a, b) \
31 ASSERT_EQ(grpc_status_to_http2_error(a), (b))
32 #define HTTP2_ERROR_TO_GRPC_STATUS(a, deadline, b) \
33 do { \
34 grpc_core::ExecCtx exec_ctx; \
35 ASSERT_EQ(grpc_http2_error_to_grpc_status(a, deadline), (b)); \
36 \
37 } while (0)
38 #define GRPC_STATUS_TO_HTTP2_STATUS(a, b) \
39 ASSERT_EQ(grpc_status_to_http2_status(a), (b))
40 #define HTTP2_STATUS_TO_GRPC_STATUS(a, b) \
41 ASSERT_EQ(grpc_http2_status_to_grpc_status(a), (b))
42
TEST(StatusConversionTest,TestGrpcStatusToHttp2Error)43 TEST(StatusConversionTest, TestGrpcStatusToHttp2Error) {
44 GRPC_STATUS_TO_HTTP2_ERROR(GRPC_STATUS_OK, GRPC_HTTP2_NO_ERROR);
45 GRPC_STATUS_TO_HTTP2_ERROR(GRPC_STATUS_CANCELLED, GRPC_HTTP2_CANCEL);
46 GRPC_STATUS_TO_HTTP2_ERROR(GRPC_STATUS_UNKNOWN, GRPC_HTTP2_INTERNAL_ERROR);
47 GRPC_STATUS_TO_HTTP2_ERROR(GRPC_STATUS_INVALID_ARGUMENT,
48 GRPC_HTTP2_INTERNAL_ERROR);
49 GRPC_STATUS_TO_HTTP2_ERROR(GRPC_STATUS_DEADLINE_EXCEEDED, GRPC_HTTP2_CANCEL);
50 GRPC_STATUS_TO_HTTP2_ERROR(GRPC_STATUS_NOT_FOUND, GRPC_HTTP2_INTERNAL_ERROR);
51 GRPC_STATUS_TO_HTTP2_ERROR(GRPC_STATUS_ALREADY_EXISTS,
52 GRPC_HTTP2_INTERNAL_ERROR);
53 GRPC_STATUS_TO_HTTP2_ERROR(GRPC_STATUS_PERMISSION_DENIED,
54 GRPC_HTTP2_INADEQUATE_SECURITY);
55 GRPC_STATUS_TO_HTTP2_ERROR(GRPC_STATUS_UNAUTHENTICATED,
56 GRPC_HTTP2_INTERNAL_ERROR);
57 GRPC_STATUS_TO_HTTP2_ERROR(GRPC_STATUS_RESOURCE_EXHAUSTED,
58 GRPC_HTTP2_ENHANCE_YOUR_CALM);
59 GRPC_STATUS_TO_HTTP2_ERROR(GRPC_STATUS_FAILED_PRECONDITION,
60 GRPC_HTTP2_INTERNAL_ERROR);
61 GRPC_STATUS_TO_HTTP2_ERROR(GRPC_STATUS_ABORTED, GRPC_HTTP2_INTERNAL_ERROR);
62 GRPC_STATUS_TO_HTTP2_ERROR(GRPC_STATUS_OUT_OF_RANGE,
63 GRPC_HTTP2_INTERNAL_ERROR);
64 GRPC_STATUS_TO_HTTP2_ERROR(GRPC_STATUS_UNIMPLEMENTED,
65 GRPC_HTTP2_INTERNAL_ERROR);
66 GRPC_STATUS_TO_HTTP2_ERROR(GRPC_STATUS_INTERNAL, GRPC_HTTP2_INTERNAL_ERROR);
67 GRPC_STATUS_TO_HTTP2_ERROR(GRPC_STATUS_UNAVAILABLE,
68 GRPC_HTTP2_REFUSED_STREAM);
69 GRPC_STATUS_TO_HTTP2_ERROR(GRPC_STATUS_DATA_LOSS, GRPC_HTTP2_INTERNAL_ERROR);
70 }
71
TEST(StatusConversionTest,TestGrpcStatusToHttp2Status)72 TEST(StatusConversionTest, TestGrpcStatusToHttp2Status) {
73 GRPC_STATUS_TO_HTTP2_STATUS(GRPC_STATUS_OK, 200);
74 GRPC_STATUS_TO_HTTP2_STATUS(GRPC_STATUS_CANCELLED, 200);
75 GRPC_STATUS_TO_HTTP2_STATUS(GRPC_STATUS_UNKNOWN, 200);
76 GRPC_STATUS_TO_HTTP2_STATUS(GRPC_STATUS_INVALID_ARGUMENT, 200);
77 GRPC_STATUS_TO_HTTP2_STATUS(GRPC_STATUS_DEADLINE_EXCEEDED, 200);
78 GRPC_STATUS_TO_HTTP2_STATUS(GRPC_STATUS_NOT_FOUND, 200);
79 GRPC_STATUS_TO_HTTP2_STATUS(GRPC_STATUS_ALREADY_EXISTS, 200);
80 GRPC_STATUS_TO_HTTP2_STATUS(GRPC_STATUS_PERMISSION_DENIED, 200);
81 GRPC_STATUS_TO_HTTP2_STATUS(GRPC_STATUS_UNAUTHENTICATED, 200);
82 GRPC_STATUS_TO_HTTP2_STATUS(GRPC_STATUS_RESOURCE_EXHAUSTED, 200);
83 GRPC_STATUS_TO_HTTP2_STATUS(GRPC_STATUS_FAILED_PRECONDITION, 200);
84 GRPC_STATUS_TO_HTTP2_STATUS(GRPC_STATUS_ABORTED, 200);
85 GRPC_STATUS_TO_HTTP2_STATUS(GRPC_STATUS_OUT_OF_RANGE, 200);
86 GRPC_STATUS_TO_HTTP2_STATUS(GRPC_STATUS_UNIMPLEMENTED, 200);
87 GRPC_STATUS_TO_HTTP2_STATUS(GRPC_STATUS_INTERNAL, 200);
88 GRPC_STATUS_TO_HTTP2_STATUS(GRPC_STATUS_UNAVAILABLE, 200);
89 GRPC_STATUS_TO_HTTP2_STATUS(GRPC_STATUS_DATA_LOSS, 200);
90 }
91
TEST(StatusConversionTest,TestHttp2ErrorToGrpcStatus)92 TEST(StatusConversionTest, TestHttp2ErrorToGrpcStatus) {
93 const grpc_core::Timestamp before_deadline =
94 grpc_core::Timestamp::InfFuture();
95 HTTP2_ERROR_TO_GRPC_STATUS(GRPC_HTTP2_NO_ERROR, before_deadline,
96 GRPC_STATUS_INTERNAL);
97 HTTP2_ERROR_TO_GRPC_STATUS(GRPC_HTTP2_PROTOCOL_ERROR, before_deadline,
98 GRPC_STATUS_INTERNAL);
99 HTTP2_ERROR_TO_GRPC_STATUS(GRPC_HTTP2_INTERNAL_ERROR, before_deadline,
100 GRPC_STATUS_INTERNAL);
101 HTTP2_ERROR_TO_GRPC_STATUS(GRPC_HTTP2_FLOW_CONTROL_ERROR, before_deadline,
102 GRPC_STATUS_INTERNAL);
103 HTTP2_ERROR_TO_GRPC_STATUS(GRPC_HTTP2_SETTINGS_TIMEOUT, before_deadline,
104 GRPC_STATUS_INTERNAL);
105 HTTP2_ERROR_TO_GRPC_STATUS(GRPC_HTTP2_STREAM_CLOSED, before_deadline,
106 GRPC_STATUS_INTERNAL);
107 HTTP2_ERROR_TO_GRPC_STATUS(GRPC_HTTP2_FRAME_SIZE_ERROR, before_deadline,
108 GRPC_STATUS_INTERNAL);
109 HTTP2_ERROR_TO_GRPC_STATUS(GRPC_HTTP2_REFUSED_STREAM, before_deadline,
110 GRPC_STATUS_UNAVAILABLE);
111 HTTP2_ERROR_TO_GRPC_STATUS(GRPC_HTTP2_CANCEL, before_deadline,
112 GRPC_STATUS_CANCELLED);
113 HTTP2_ERROR_TO_GRPC_STATUS(GRPC_HTTP2_COMPRESSION_ERROR, before_deadline,
114 GRPC_STATUS_INTERNAL);
115 HTTP2_ERROR_TO_GRPC_STATUS(GRPC_HTTP2_CONNECT_ERROR, before_deadline,
116 GRPC_STATUS_INTERNAL);
117 HTTP2_ERROR_TO_GRPC_STATUS(GRPC_HTTP2_ENHANCE_YOUR_CALM, before_deadline,
118 GRPC_STATUS_RESOURCE_EXHAUSTED);
119 HTTP2_ERROR_TO_GRPC_STATUS(GRPC_HTTP2_INADEQUATE_SECURITY, before_deadline,
120 GRPC_STATUS_PERMISSION_DENIED);
121
122 const grpc_core::Timestamp after_deadline;
123 HTTP2_ERROR_TO_GRPC_STATUS(GRPC_HTTP2_NO_ERROR, after_deadline,
124 GRPC_STATUS_INTERNAL);
125 HTTP2_ERROR_TO_GRPC_STATUS(GRPC_HTTP2_PROTOCOL_ERROR, after_deadline,
126 GRPC_STATUS_INTERNAL);
127 HTTP2_ERROR_TO_GRPC_STATUS(GRPC_HTTP2_INTERNAL_ERROR, after_deadline,
128 GRPC_STATUS_INTERNAL);
129 HTTP2_ERROR_TO_GRPC_STATUS(GRPC_HTTP2_FLOW_CONTROL_ERROR, after_deadline,
130 GRPC_STATUS_INTERNAL);
131 HTTP2_ERROR_TO_GRPC_STATUS(GRPC_HTTP2_SETTINGS_TIMEOUT, after_deadline,
132 GRPC_STATUS_INTERNAL);
133 HTTP2_ERROR_TO_GRPC_STATUS(GRPC_HTTP2_STREAM_CLOSED, after_deadline,
134 GRPC_STATUS_INTERNAL);
135 HTTP2_ERROR_TO_GRPC_STATUS(GRPC_HTTP2_FRAME_SIZE_ERROR, after_deadline,
136 GRPC_STATUS_INTERNAL);
137 HTTP2_ERROR_TO_GRPC_STATUS(GRPC_HTTP2_REFUSED_STREAM, after_deadline,
138 GRPC_STATUS_UNAVAILABLE);
139 // We only have millisecond granularity in our timing code. This sleeps for 5
140 // millis to ensure that the status conversion code will pick up the fact
141 // that the deadline has expired.
142 gpr_sleep_until(gpr_time_add(gpr_now(GPR_CLOCK_REALTIME),
143 gpr_time_from_millis(5, GPR_TIMESPAN)));
144 HTTP2_ERROR_TO_GRPC_STATUS(GRPC_HTTP2_CANCEL, after_deadline,
145 GRPC_STATUS_DEADLINE_EXCEEDED);
146 HTTP2_ERROR_TO_GRPC_STATUS(GRPC_HTTP2_COMPRESSION_ERROR, after_deadline,
147 GRPC_STATUS_INTERNAL);
148 HTTP2_ERROR_TO_GRPC_STATUS(GRPC_HTTP2_CONNECT_ERROR, after_deadline,
149 GRPC_STATUS_INTERNAL);
150 HTTP2_ERROR_TO_GRPC_STATUS(GRPC_HTTP2_ENHANCE_YOUR_CALM, after_deadline,
151 GRPC_STATUS_RESOURCE_EXHAUSTED);
152 HTTP2_ERROR_TO_GRPC_STATUS(GRPC_HTTP2_INADEQUATE_SECURITY, after_deadline,
153 GRPC_STATUS_PERMISSION_DENIED);
154 }
155
TEST(StatusConversionTest,TestHttp2StatusToGrpcStatus)156 TEST(StatusConversionTest, TestHttp2StatusToGrpcStatus) {
157 HTTP2_STATUS_TO_GRPC_STATUS(200, GRPC_STATUS_OK);
158 HTTP2_STATUS_TO_GRPC_STATUS(400, GRPC_STATUS_INTERNAL);
159 HTTP2_STATUS_TO_GRPC_STATUS(401, GRPC_STATUS_UNAUTHENTICATED);
160 HTTP2_STATUS_TO_GRPC_STATUS(403, GRPC_STATUS_PERMISSION_DENIED);
161 HTTP2_STATUS_TO_GRPC_STATUS(404, GRPC_STATUS_UNIMPLEMENTED);
162 HTTP2_STATUS_TO_GRPC_STATUS(409, GRPC_STATUS_UNKNOWN);
163 HTTP2_STATUS_TO_GRPC_STATUS(412, GRPC_STATUS_UNKNOWN);
164 HTTP2_STATUS_TO_GRPC_STATUS(429, GRPC_STATUS_UNAVAILABLE);
165 HTTP2_STATUS_TO_GRPC_STATUS(499, GRPC_STATUS_UNKNOWN);
166 HTTP2_STATUS_TO_GRPC_STATUS(500, GRPC_STATUS_UNKNOWN);
167 HTTP2_STATUS_TO_GRPC_STATUS(502, GRPC_STATUS_UNAVAILABLE);
168 HTTP2_STATUS_TO_GRPC_STATUS(503, GRPC_STATUS_UNAVAILABLE);
169 HTTP2_STATUS_TO_GRPC_STATUS(504, GRPC_STATUS_UNAVAILABLE);
170 }
171
TEST(StatusConversionTest,TestGrpcHttp2StatusToGrpcStatusAll)172 TEST(StatusConversionTest, TestGrpcHttp2StatusToGrpcStatusAll) {
173 // check all status values can be converted
174 for (int i = 0; i <= 999; i++) {
175 grpc_http2_status_to_grpc_status(i);
176 }
177 }
178
main(int argc,char ** argv)179 int main(int argc, char** argv) {
180 grpc::testing::TestEnvironment env(&argc, argv);
181 ::testing::InitGoogleTest(&argc, argv);
182 grpc::testing::TestGrpcScope grpc_scope;
183 return RUN_ALL_TESTS();
184 }
185