Home
last modified time | relevance | path

Searched refs:recv_status (Results 1 – 17 of 17) sorted by relevance

/external/grpc-grpc/test/cpp/end2end/
Dasync_end2end_test.cc309 Status recv_status; in SendRpc() local
322 response_reader->Finish(&recv_response, &recv_status, tag(4)); in SendRpc()
332 EXPECT_TRUE(recv_status.ok()); in SendRpc()
419 Status recv_status; in TEST_P() local
438 response_reader->Finish(&recv_response, &recv_status, tag(4)); in TEST_P()
449 EXPECT_TRUE(recv_status.ok()); in TEST_P()
460 Status recv_status; in TEST_P() local
482 response_reader->Finish(&recv_response, &recv_status, tag(4)); in TEST_P()
495 EXPECT_TRUE(recv_status.ok()); in TEST_P()
506 Status recv_status; in TEST_P() local
[all …]
Dgeneric_end2end_test.cc113 Status recv_status; in SendRpc() local
171 call->Finish(&recv_status, tag(9)); in SendRpc()
175 EXPECT_TRUE(recv_status.ok()); in SendRpc()
208 Status recv_status; in TEST_F() local
225 call->Finish(&cli_recv_buffer, &recv_status, tag(1)); in TEST_F()
252 EXPECT_TRUE(recv_status.ok()); in TEST_F()
266 Status recv_status; in TEST_F() local
317 cli_stream->Finish(&recv_status, tag(10)); in TEST_F()
321 EXPECT_TRUE(recv_status.ok()); in TEST_F()
Dfilter_end2end_test.cc168 Status recv_status; in SendRpc() local
215 call->Finish(&recv_status, tag(9)); in SendRpc()
219 EXPECT_TRUE(recv_status.ok()); in SendRpc()
263 Status recv_status; in TEST_F() local
314 cli_stream->Finish(&recv_status, tag(10)); in TEST_F()
318 EXPECT_TRUE(recv_status.ok()); in TEST_F()
Dnonblocking_test.cc120 Status recv_status; in SendRpc() local
131 response_reader->Finish(&recv_response, &recv_status, tag(4)); in SendRpc()
161 EXPECT_TRUE(recv_status.ok()); in SendRpc()
Dhybrid_end2end_test.cc297 Status recv_status = stub_->Echo(&cli_ctx, send_request, &recv_response); in SendEcho() local
299 EXPECT_TRUE(recv_status.ok()); in SendEcho()
311 Status recv_status = stub->Echo(&cli_ctx, send_request, &recv_response); in SendEchoToDupService() local
313 EXPECT_TRUE(recv_status.ok()); in SendEchoToDupService()
329 Status recv_status = stream->Finish(); in SendSimpleClientStreaming() local
331 EXPECT_TRUE(recv_status.ok()); in SendSimpleClientStreaming()
/external/tensorflow/tensorflow/core/common_runtime/
Dcollective_rma_local_test.cc68 Status recv_status; in TEST_F() local
73 [&recv_note, &recv_status](const Status& s) { in TEST_F()
74 recv_status = s; in TEST_F()
94 TF_EXPECT_OK(recv_status); in TEST_F()
111 Status recv_status; in TEST_F() local
116 [&recv_note, &recv_status](const Status& s) { in TEST_F()
117 recv_status = s; in TEST_F()
139 TF_EXPECT_OK(recv_status); in TEST_F()
/external/grpc-grpc/test/cpp/microbenchmarks/
Dfullstack_streaming_ping_pong.h119 Status recv_status; in BM_StreamingPingPong() local
120 request_rw->Finish(&recv_status, tag(2)); in BM_StreamingPingPong()
130 GPR_ASSERT(recv_status.ok()); in BM_StreamingPingPong()
207 Status recv_status; in BM_StreamingPingPongMsgs() local
208 request_rw->Finish(&recv_status, tag(2)); in BM_StreamingPingPongMsgs()
218 GPR_ASSERT(recv_status.ok()); in BM_StreamingPingPongMsgs()
383 Status recv_status; in BM_StreamingPingPongWithCoalescingApi() local
384 request_rw->Finish(&recv_status, tag(8)); in BM_StreamingPingPongWithCoalescingApi()
393 GPR_ASSERT(recv_status.ok()); in BM_StreamingPingPongWithCoalescingApi()
Dfullstack_unary_ping_pong.h53 Status recv_status; in BM_UnaryPingPong() local
81 response_reader->Finish(&recv_response, &recv_status, tag(4)); in BM_UnaryPingPong()
98 GPR_ASSERT(recv_status.ok()); in BM_UnaryPingPong()
Dfullstack_streaming_pump.h50 Status recv_status; in BM_PumpStreamClientToServer() local
119 Status recv_status; in BM_PumpStreamServerToClient() local
Dbm_fullstack_trickle.cc271 Status recv_status; in BM_PumpStreamServerToClient_Trickle() local
368 Status recv_status; in BM_PumpUnbalancedUnary_Trickle() local
397 response_reader->Finish(&recv_response, &recv_status, tag(4)); in BM_PumpUnbalancedUnary_Trickle()
412 GPR_ASSERT(recv_status.ok()); in BM_PumpUnbalancedUnary_Trickle()
Dbm_call_create.cc141 grpc::Status recv_status; in BM_LameChannelCallCreateCpp() local
146 reader->Finish(&recv_response, &recv_status, tag(0)); in BM_LameChannelCallCreateCpp()
/external/grpc-grpc/src/php/ext/grpc/
Dcall.c257 zval *recv_status; in PHP_METHOD() local
489 PHP_GRPC_MAKE_STD_ZVAL(recv_status); in PHP_METHOD()
490 object_init(recv_status); in PHP_METHOD()
493 add_property_zval(recv_status, "metadata", array); in PHP_METHOD()
496 add_property_zval(recv_status, "metadata", recv_md); in PHP_METHOD()
501 add_property_long(recv_status, "code", status); in PHP_METHOD()
503 php_grpc_add_property_string(recv_status, "details", status_details_text, in PHP_METHOD()
506 add_property_zval(result, "status", recv_status); in PHP_METHOD()
508 zval_ptr_dtor(recv_status); in PHP_METHOD()
510 PHP_GRPC_DELREF(recv_status); in PHP_METHOD()
[all …]
/external/tensorflow/tensorflow/contrib/mpi_collectives/
Dring.h194 MPI_Status recv_status; in RingAllreduce() local
218 MPI_REQUIRES_OK(MPI_Wait(&recv_req, &recv_status)); in RingAllreduce()
242 recv_from, TAG_TENSOR, MPI_COMM_WORLD, &recv_status)); in RingAllreduce()
296 MPI_Status recv_status; in RingAllgather() local
314 recv_from, TAG_TENSOR, MPI_COMM_WORLD, &recv_status)); in RingAllgather()
/external/tensorflow/tensorflow/contrib/mpi_collectives/kernels/
Dring.h194 MPI_Status recv_status; in RingAllreduce() local
218 MPI_REQUIRES_OK(MPI_Wait(&recv_req, &recv_status)); in RingAllreduce()
242 recv_from, TAG_TENSOR, MPI_COMM_WORLD, &recv_status)); in RingAllreduce()
296 MPI_Status recv_status; in RingAllgather() local
314 recv_from, TAG_TENSOR, MPI_COMM_WORLD, &recv_status)); in RingAllgather()
/external/grpc-grpc/test/cpp/performance/
Dwrites_per_rpc_test.cc182 Status recv_status; in UnaryPingPong() local
210 response_reader->Finish(&recv_response, &recv_status, tag(4)); in UnaryPingPong()
224 GPR_ASSERT(recv_status.ok()); in UnaryPingPong()
/external/grpc-grpc/test/cpp/cocoapods/generic/
Dgeneric.mm169 Status recv_status;
224 call->Finish(&recv_status, tag(9));
227 XCTAssertTrue(recv_status.ok());
/external/grpc-grpc/src/ruby/ext/grpc/
Drb_call.c621 grpc_status_code recv_status; member
729 &st->recv_status; in grpc_run_batch_stack_fill_ops()
779 grpc_rb_sStatus, UINT2NUM(st->recv_status), in grpc_run_batch_stack_build_result()