/third_party/grpc/test/cpp/interop/ |
D | interop_client.cc | 158 gpr_log(GPR_DEBUG, "Sending an empty rpc..."); in DoEmpty() 170 gpr_log(GPR_DEBUG, "Empty rpc done."); in DoEmpty() 211 gpr_log(GPR_DEBUG, in DoComputeEngineCreds() 222 gpr_log(GPR_DEBUG, "Got username %s", response.username().c_str()); in DoComputeEngineCreds() 223 gpr_log(GPR_DEBUG, "Got oauth_scope %s", response.oauth_scope().c_str()); in DoComputeEngineCreds() 229 gpr_log(GPR_DEBUG, "Large unary with compute engine creds done."); in DoComputeEngineCreds() 235 gpr_log(GPR_DEBUG, in DoOauth2AuthToken() 255 gpr_log(GPR_DEBUG, "Unary with oauth2 access token credentials done."); in DoOauth2AuthToken() 260 gpr_log(GPR_DEBUG, "Sending a unary rpc with per-rpc JWT access token ..."); in DoPerRpcCreds() 280 gpr_log(GPR_DEBUG, "Unary with per-rpc JWT access token done."); in DoPerRpcCreds() [all …]
|
D | http2_client.cc | 81 gpr_log(GPR_DEBUG, "Sending RPC and expecting reset stream after header"); in DoRstAfterHeader() 87 gpr_log(GPR_DEBUG, "Done testing reset stream after header"); in DoRstAfterHeader() 92 gpr_log(GPR_DEBUG, "Sending RPC and expecting reset stream after data"); in DoRstAfterData() 98 gpr_log(GPR_DEBUG, "Done testing reset stream after data"); in DoRstAfterData() 103 gpr_log(GPR_DEBUG, "Sending RPC and expecting reset stream during data"); in DoRstDuringData() 109 gpr_log(GPR_DEBUG, "Done testing reset stream during data"); in DoRstDuringData() 114 gpr_log(GPR_DEBUG, "Sending two RPCs and expecting goaway"); in DoGoaway() 129 gpr_log(GPR_DEBUG, "Done testing goaway"); in DoGoaway() 134 gpr_log(GPR_DEBUG, "Sending RPC and expecting ping"); in DoPing() 139 gpr_log(GPR_DEBUG, "Done testing ping"); in DoPing() [all …]
|
/third_party/grpc/src/core/ext/transport/cronet/transport/ |
D | cronet_transport.cc | 304 CRONET_LOG(GPR_DEBUG, "bidirectional_stream_read(%p)", s->cbs); in read_grpc_header() 344 CRONET_LOG(GPR_DEBUG, "adding new op %p. %d in the queue.", new_op, in add_to_storage() 362 CRONET_LOG(GPR_DEBUG, "Freed %p. Now %d in the queue", oas, in remove_from_storage() 369 CRONET_LOG(GPR_DEBUG, "Freed %p. Now %d in the queue", oas, in remove_from_storage() 389 CRONET_LOG(GPR_DEBUG, "calling op at %p. done = %d", curr, curr->done); in execute_from_storage() 392 CRONET_LOG(GPR_DEBUG, "execute_stream_op[%p] returns %s", curr, in execute_from_storage() 413 CRONET_LOG(GPR_DEBUG, "header key=%s, value=%s", in convert_cronet_array_to_metadata() 464 CRONET_LOG(GPR_DEBUG, "on_canceled(%p)", stream); in on_canceled() 491 CRONET_LOG(GPR_DEBUG, "on_succeeded(%p)", stream); in on_succeeded() 510 CRONET_LOG(GPR_DEBUG, "W: on_stream_ready(%p)", stream); in on_stream_ready() [all …]
|
/third_party/grpc/test/cpp/naming/ |
D | dns_test_util.cc | 43 gpr_log(GPR_DEBUG, "Failed to create UDP ipv6 socket"); in FakeNonResponsiveDNSServer() 47 gpr_log(GPR_DEBUG, "Failed to create TCP ipv6 socket"); in FakeNonResponsiveDNSServer() 56 gpr_log(GPR_DEBUG, "Failed to bind UDP ipv6 socket to [::1]:%d", port); in FakeNonResponsiveDNSServer() 63 gpr_log(GPR_DEBUG, in FakeNonResponsiveDNSServer() 71 gpr_log(GPR_DEBUG, in FakeNonResponsiveDNSServer() 77 gpr_log(GPR_DEBUG, "Failed to bind TCP ipv6 socket to [::1]:%d", port); in FakeNonResponsiveDNSServer() 81 gpr_log(GPR_DEBUG, "Failed to listen on TCP ipv6 socket to [::1]:%d", port); in FakeNonResponsiveDNSServer()
|
D | resolver_component_test.cc | 260 gpr_log(GPR_DEBUG, "done=%d, time_left=%" PRId64 ".%09d", done, in PollPollsetUntilRequestDone() 321 gpr_log(GPR_DEBUG, "Opened socket: %d", s); in OpenAndCloseSocketsStressLoop() 341 gpr_log(GPR_DEBUG, "non-blocking accept then close on %d", sockets[i]); in OpenAndCloseSocketsStressLoop() 398 gpr_log(GPR_DEBUG, "Opened fd: %d", s); in OpenAndCloseSocketsStressLoop() 411 gpr_log(GPR_DEBUG, "non-blocking accept then close on %d", sockets[i]); in OpenAndCloseSocketsStressLoop() 492 gpr_log(GPR_DEBUG, in CheckResult() 548 gpr_log(GPR_DEBUG, in InjectBrokenNameServerList() 586 gpr_log(GPR_DEBUG, in RunResolvesRelevantRecordsTest() 604 gpr_log(GPR_DEBUG, "Invalid value for --inject_broken_nameserver_list."); in RunResolvesRelevantRecordsTest() 607 gpr_log(GPR_DEBUG, "resolver_component_test: --enable_srv_queries: %s", in RunResolvesRelevantRecordsTest() [all …]
|
/third_party/grpc/test/core/gpr/ |
D | log_test.cc | 65 gpr_log(GPR_DEBUG, "%s", "hello world"); in main() 82 test_log_function_unreached(GPR_DEBUG); in main() 89 test_log_function_unreached(GPR_DEBUG); in main() 94 test_log_function_reached(GPR_DEBUG); in main() 99 test_log_function_unreached(GPR_DEBUG); in main() 104 test_log_function_unreached(GPR_DEBUG); in main() 111 test_log_function_unreached(GPR_DEBUG); in main()
|
/third_party/grpc/test/core/iomgr/ |
D | mpmcqueue_test.cc | 102 gpr_log(GPR_DEBUG, "ConsumerThread: %d times of Get() called.", count); in Run() 170 gpr_log(GPR_DEBUG, "Done."); in test_space_efficiency() 183 gpr_log(GPR_DEBUG, "Fork ProducerThreads..."); in test_many_thread() 189 gpr_log(GPR_DEBUG, "ProducerThreads Started."); in test_many_thread() 190 gpr_log(GPR_DEBUG, "Fork ConsumerThreads..."); in test_many_thread() 195 gpr_log(GPR_DEBUG, "ConsumerThreads Started."); in test_many_thread() 196 gpr_log(GPR_DEBUG, "Waiting ProducerThreads to finish..."); in test_many_thread() 200 gpr_log(GPR_DEBUG, "All ProducerThreads Terminated."); in test_many_thread() 201 gpr_log(GPR_DEBUG, "Terminating ConsumerThreads..."); in test_many_thread() 208 gpr_log(GPR_DEBUG, "All ConsumerThreads Terminated."); in test_many_thread() [all …]
|
D | threadpool_test.cc | 81 gpr_log(GPR_DEBUG, "Done."); in test_add() 119 gpr_log(GPR_DEBUG, "Fork threads for adding..."); in test_multi_add() 125 gpr_log(GPR_DEBUG, "Waiting for all work threads finish..."); in test_multi_add() 131 gpr_log(GPR_DEBUG, "Done."); in test_multi_add() 132 gpr_log(GPR_DEBUG, "Waiting for all closures finish..."); in test_multi_add() 137 gpr_log(GPR_DEBUG, "Done."); in test_multi_add() 179 gpr_log(GPR_DEBUG, "Done."); in test_one_thread_FIFO()
|
D | combiner_test.cc | 30 gpr_log(GPR_DEBUG, "test_no_op"); in test_no_op() 40 gpr_log(GPR_DEBUG, "test_execute_one"); in test_execute_one() 94 gpr_log(GPR_DEBUG, "test_execute_many"); in test_execute_many() 127 gpr_log(GPR_DEBUG, "test_execute_finally"); in test_execute_finally()
|
/third_party/grpc/test/core/tsi/alts/handshaker/ |
D | alts_concurrent_connectivity_test.cc | 159 gpr_log(GPR_DEBUG, "Start TestServer %p. listen on %s", this, in TestServer() 166 gpr_log(GPR_DEBUG, "Begin dtor of TestServer %p", this); in ~TestServer() 182 gpr_log(GPR_DEBUG, "TestServer %p stop polling", self); in PollUntilShutdown() 222 gpr_log(GPR_DEBUG, "runner:%p connect_loop begin loop %ld", self, i); in ConnectLoop() 270 gpr_log(GPR_DEBUG, "runner:%p connect_loop finished loop %ld", self, i); in ConnectLoop() 310 gpr_log(GPR_DEBUG, in TEST() 321 gpr_log(GPR_DEBUG, in TEST() 324 gpr_log(GPR_DEBUG, "Test took longer than expected."); in TEST() 381 gpr_log(GPR_DEBUG, in ~FakeTcpServer() 386 gpr_log(GPR_DEBUG, in ~FakeTcpServer() [all …]
|
/third_party/grpc/test/core/end2end/tests/ |
D | connectivity.cc | 51 gpr_log(GPR_DEBUG, "verifying"); in child_thread() 92 gpr_log(GPR_DEBUG, "watching"); in test_connectivity() 124 gpr_log(GPR_DEBUG, "*** STARTING SERVER ***"); in test_connectivity() 129 gpr_log(GPR_DEBUG, "*** STARTED SERVER ***"); in test_connectivity() 146 gpr_log(GPR_DEBUG, "*** SHUTTING DOWN SERVER ***"); in test_connectivity() 164 gpr_log(GPR_DEBUG, "*** SHUTDOWN SERVER ***"); in test_connectivity() 181 gpr_log(GPR_DEBUG, "cb_watch_connectivity called, verifying"); in cb_watch_connectivity() 193 gpr_log(GPR_DEBUG, "cb_shutdown called, nothing to do"); in cb_shutdown()
|
D | retry_too_many_attempts.cc | 155 gpr_log(GPR_DEBUG, "client_peer_before_call=%s", peer); in test_retry_too_many_attempts() 197 gpr_log(GPR_DEBUG, "server_peer=%s", peer); in test_retry_too_many_attempts() 201 gpr_log(GPR_DEBUG, "client_peer=%s", peer); in test_retry_too_many_attempts() 238 gpr_log(GPR_DEBUG, "server_peer=%s", peer); in test_retry_too_many_attempts() 242 gpr_log(GPR_DEBUG, "client_peer=%s", peer); in test_retry_too_many_attempts()
|
/third_party/grpc/src/core/lib/iomgr/ |
D | is_epollexclusive_available.cc | 43 gpr_log(GPR_DEBUG, in grpc_is_epollexclusive_available() 54 gpr_log(GPR_DEBUG, in grpc_is_epollexclusive_available() 86 gpr_log(GPR_DEBUG, in grpc_is_epollexclusive_available() 100 gpr_log(GPR_DEBUG, in grpc_is_epollexclusive_available()
|
D | endpoint_cfstream.cc | 120 gpr_log(GPR_DEBUG, "CFStream endpoint:%p call_read_cb %p %p:%p", ep, in CallReadCb() 124 gpr_log(GPR_DEBUG, "read: error=%s", str); in CallReadCb() 129 gpr_log(GPR_DEBUG, "READ %p (peer=%s): %s", ep, ep->peer_string.c_str(), in CallReadCb() 142 gpr_log(GPR_DEBUG, "CFStream endpoint:%p call_write_cb %p %p:%p", ep, in CallWriteCb() 145 gpr_log(GPR_DEBUG, "write: error=%s", str); in CallWriteCb() 236 gpr_log(GPR_DEBUG, "WRITE %p (peer=%s): %s", ep, ep->peer_string.c_str(), in WriteAction() 260 gpr_log(GPR_DEBUG, "CFStream endpoint:%p read (%p, %p) length:%zu", ep_impl, in CFStreamRead() 279 gpr_log(GPR_DEBUG, "CFStream endpoint:%p write (%p, %p) length:%zu", in CFStreamWrite() 292 gpr_log(GPR_DEBUG, "CFStream endpoint:%p shutdown (%p)", ep_impl, why); in CFStreamShutdown() 299 gpr_log(GPR_DEBUG, "CFStream endpoint:%p shutdown DONE (%p)", ep_impl, why); in CFStreamShutdown() [all …]
|
D | iomgr.cc | 85 gpr_log(GPR_DEBUG, "%s OBJECT: %s %p", kind, obj->name, obj); in dump_objects() 106 gpr_log(GPR_DEBUG, in grpc_iomgr_shutdown() 122 gpr_log(GPR_DEBUG, in grpc_iomgr_shutdown() 137 gpr_log(GPR_DEBUG, in grpc_iomgr_shutdown()
|
D | lockfree_event.cc | 99 gpr_log(GPR_DEBUG, in NotifyOn() 168 gpr_log(GPR_DEBUG, in SetShutdown() 218 gpr_log(GPR_DEBUG, "LockfreeEvent::SetReady: %p curr=%" PRIxPTR, &state_, in SetReady()
|
D | udp_server.cc | 232 gpr_log(GPR_DEBUG, "shutdown fd %d", sp->fd_); in shutdown_fd() 252 gpr_log(GPR_DEBUG, "Destroy all listeners."); in finish_shutdown() 297 gpr_log(GPR_DEBUG, "Orphan fd %d, emfd %p", fd_, emfd_); in OrphanFd() 315 gpr_log(GPR_DEBUG, "start to destroy udp_server"); in grpc_udp_server_destroy() 340 gpr_log(GPR_DEBUG, "fd %d about to be orphaned", fd_); in OnFdAboutToOrphan() 558 gpr_log(GPR_DEBUG, "add socket %d to server", fd); in add_socket_to_server() 565 gpr_log(GPR_DEBUG, in add_socket_to_server() 583 gpr_log(GPR_DEBUG, "add address: %s to server", addr_str.c_str()); in grpc_udp_server_add_port() 706 gpr_log(GPR_DEBUG, "grpc_udp_server_start"); in grpc_udp_server_start()
|
/third_party/grpc/test/core/avl/ |
D | avl_test.cc | 69 gpr_log(GPR_DEBUG, "test_get"); in test_get() 83 gpr_log(GPR_DEBUG, "test_ll"); in test_ll() 96 gpr_log(GPR_DEBUG, "test_lr"); in test_lr() 109 gpr_log(GPR_DEBUG, "test_rr"); in test_rr() 122 gpr_log(GPR_DEBUG, "test_rl"); in test_rl() 135 gpr_log(GPR_DEBUG, "test_unbalanced"); in test_unbalanced() 152 gpr_log(GPR_DEBUG, "test_replace"); in test_replace() 164 gpr_log(GPR_DEBUG, "test_remove"); in test_remove() 201 gpr_log(GPR_DEBUG, "test_badcase1"); in test_badcase1() 252 gpr_log(GPR_DEBUG, "test_stress amount=%d seed=%u", amount_of_stress, seed); in test_stress()
|
/third_party/grpc/src/core/ext/filters/client_channel/resolver/dns/native/ |
D | dns_resolver.cc | 215 gpr_log(GPR_DEBUG, "retrying in %" PRId64 " milliseconds", timeout); in OnResolvedLocked() 217 gpr_log(GPR_DEBUG, "retrying immediately"); in OnResolvedLocked() 239 gpr_log(GPR_DEBUG, in MaybeStartResolvingLocked() 261 gpr_log(GPR_DEBUG, "Start resolving."); in StartResolvingLocked() 306 gpr_log(GPR_DEBUG, "Using native dns resolver"); in grpc_resolver_dns_native_init() 314 gpr_log(GPR_DEBUG, "Using native dns resolver"); in grpc_resolver_dns_native_init()
|
/third_party/grpc/test/core/gprpp/ |
D | mpscq_test.cc | 48 gpr_log(GPR_DEBUG, "test_serial"); in test_serial() 78 gpr_log(GPR_DEBUG, "test_mt"); in test_mt() 105 gpr_log(GPR_DEBUG, "spins: %" PRIdPTR, spins); in test_mt() 145 gpr_log(GPR_DEBUG, "test_mt_multipop"); in test_mt_multipop() 175 gpr_log(GPR_DEBUG, "spins: %" PRIdPTR, pa.spins); in test_mt_multipop()
|
/third_party/grpc/test/core/slice/ |
D | percent_encoding_test.cc | 42 gpr_log(GPR_DEBUG, "Trial:\nraw = %s\nencoded = %s", raw_msg, encoded_msg); in test_vector() 62 gpr_log(GPR_DEBUG, in test_vector() 91 gpr_log(GPR_DEBUG, "Trial:\nraw = %s\nencoded = %s", permissive_unencoded_msg, in test_nonconformant_vector() 108 gpr_log(GPR_DEBUG, "Result:\nencoded2raw_permissive = %s", in test_nonconformant_vector()
|
/third_party/grpc/test/cpp/end2end/ |
D | cfstream_test.cc | 104 gpr_log(GPR_DEBUG, "Bringing network up"); in NetworkUp() 110 gpr_log(GPR_DEBUG, "Bringing network down"); in NetworkDown() 171 gpr_log(GPR_DEBUG, "RPC with stream_id %d succeeded", stream_id); in SendRpc() 174 gpr_log(GPR_DEBUG, "RPC with stream_id %d failed: %s", stream_id, in SendRpc() 397 gpr_log(GPR_DEBUG, "RPC with stream_id %d failed with error: %s", in TEST_P() 405 gpr_log(GPR_DEBUG, "RPC with stream_id %d succeeded", stream_id); in TEST_P() 445 gpr_log(GPR_DEBUG, "RPC with stream_id %d failed with error: %s", in TEST_P() 449 gpr_log(GPR_DEBUG, "RPC with stream_id %d succeeded", stream_id); in TEST_P()
|
/third_party/grpc/test/core/util/ |
D | grpc_profiler.cc | 33 gpr_log(GPR_DEBUG, in grpc_profiler_start() 37 gpr_log(GPR_DEBUG, in grpc_profiler_start()
|
/third_party/grpc/src/cpp/server/load_reporter/ |
D | load_data_store.cc | 146 gpr_log(GPR_DEBUG, in MergeRow() 150 gpr_log(GPR_DEBUG, in MergeRow() 166 gpr_log(GPR_DEBUG, "[PerBalancerStore %p] Suspended.", this); in Suspend() 171 gpr_log(GPR_DEBUG, "[PerBalancerStore %p] Resumed.", this); in Resume() 303 GPR_DEBUG, in MergeRow() 310 gpr_log(GPR_DEBUG, in MergeRow()
|
/third_party/grpc/test/cpp/common/ |
D | time_jump_test.cc | 102 gpr_log(GPR_DEBUG, "wakeups: %" PRId64 "", wakeups); in TEST_P() 123 gpr_log(GPR_DEBUG, "After wait, timedout = %d elapsed_ms = %d", timedout, in TEST_P() 135 gpr_log(GPR_DEBUG, "wakeups: %" PRId64 "", wakeups); in TEST_P()
|