54 bool VerifyReturnSuccess(CompletionQueue* cq, int i) {  in VerifyReturnSuccess()  argument
57   EXPECT_TRUE(cq->Next(&got_tag, &ok));  in VerifyReturnSuccess()
62 void Verify(CompletionQueue* cq, int i, bool expect_ok) {  in Verify()  argument
63   EXPECT_EQ(expect_ok, VerifyReturnSuccess(cq, i));  in Verify()
68 void HandleEcho(Service* service, ServerCompletionQueue* cq, bool dup_service) {  in HandleEcho()  argument
73   service->RequestEcho(&srv_ctx, &recv_request, &response_writer, cq, cq,  in HandleEcho()
75   Verify(cq, 1, true);  in HandleEcho()
81   Verify(cq, 2, true);  in HandleEcho()
88 void HandleRawEcho(Service* service, ServerCompletionQueue* cq,  in HandleRawEcho()  argument
93   service->RequestEcho(&srv_ctx, &recv_buffer, &response_writer, cq, cq,  in HandleRawEcho()
95   Verify(cq, 1, true);  in HandleRawEcho()
102   Verify(cq, 2, true);  in HandleRawEcho()
106 void HandleClientStreaming(Service* service, ServerCompletionQueue* cq) {  in HandleClientStreaming()  argument
111   service->RequestRequestStream(&srv_ctx, &srv_stream, cq, cq, tag(1));  in HandleClientStreaming()
112   Verify(cq, 1, true);  in HandleClientStreaming()
118   } while (VerifyReturnSuccess(cq, i));  in HandleClientStreaming()
120   Verify(cq, 100, true);  in HandleClientStreaming()
124 void HandleRawClientStreaming(Service* service, ServerCompletionQueue* cq) {  in HandleRawClientStreaming()  argument
130   service->RequestRequestStream(&srv_ctx, &srv_stream, cq, cq, tag(1));  in HandleRawClientStreaming()
131   Verify(cq, 1, true);  in HandleRawClientStreaming()
136     if (!VerifyReturnSuccess(cq, i)) {  in HandleRawClientStreaming()
144   Verify(cq, 100, true);  in HandleRawClientStreaming()
148 void HandleServerStreaming(Service* service, ServerCompletionQueue* cq) {  in HandleServerStreaming()  argument
153   service->RequestResponseStream(&srv_ctx, &recv_request, &srv_stream, cq, cq,  in HandleServerStreaming()
155   Verify(cq, 1, true);  in HandleServerStreaming()
158   Verify(cq, 2, true);  in HandleServerStreaming()
161   Verify(cq, 3, true);  in HandleServerStreaming()
164   Verify(cq, 4, true);  in HandleServerStreaming()
166   Verify(cq, 5, true);  in HandleServerStreaming()
170                        CompletionQueue* cq) {  in HandleGenericEcho()  argument
173   Verify(cq, 2, true);  in HandleGenericEcho()
180   Verify(cq, 3, true);  in HandleGenericEcho()
182   Verify(cq, 4, true);  in HandleGenericEcho()
186                                 CompletionQueue* cq) {  in HandleGenericRequestStream()  argument
194     if (!VerifyReturnSuccess(cq, i)) {  in HandleGenericRequestStream()
202   Verify(cq, 99, true);  in HandleGenericRequestStream()
204   Verify(cq, 100, true);  in HandleGenericRequestStream()
209                        ServerCompletionQueue* cq) {  in HandleGenericCall()  argument
212   service->RequestCall(&srv_ctx, &stream, cq, cq, tag(1));  in HandleGenericCall()
213   Verify(cq, 1, true);  in HandleGenericCall()
215     HandleGenericEcho(&stream, cq);  in HandleGenericCall()
218     HandleGenericRequestStream(&stream, cq);  in HandleGenericCall()