Home
last modified time | relevance | path

Searched refs:GRPC_CHANNEL_IDLE (Results 1 – 24 of 24) sorted by relevance

/external/grpc-grpc/test/core/transport/
Dconnectivity_state_test.cc48 strcmp(grpc_connectivity_state_name(GRPC_CHANNEL_IDLE), "IDLE")); in test_connectivity_state_name()
65 grpc_connectivity_state_init(&tracker, GRPC_CHANNEL_IDLE, "xxx"); in test_check()
67 GRPC_CHANNEL_IDLE); in test_check()
68 GPR_ASSERT(grpc_connectivity_state_check(&tracker) == GRPC_CHANNEL_IDLE); in test_check()
77 grpc_connectivity_state state = GRPC_CHANNEL_IDLE; in test_subscribe_then_unsubscribe()
81 grpc_connectivity_state_init(&tracker, GRPC_CHANNEL_IDLE, "xxx"); in test_subscribe_then_unsubscribe()
85 GPR_ASSERT(state == GRPC_CHANNEL_IDLE); in test_subscribe_then_unsubscribe()
89 GPR_ASSERT(state == GRPC_CHANNEL_IDLE); in test_subscribe_then_unsubscribe()
99 grpc_connectivity_state state = GRPC_CHANNEL_IDLE; in test_subscribe_then_destroy()
103 grpc_connectivity_state_init(&tracker, GRPC_CHANNEL_IDLE, "xxx"); in test_subscribe_then_destroy()
[all …]
/external/grpc-grpc/test/core/end2end/tests/
Dconnectivity.cc75 GRPC_CHANNEL_IDLE); in test_connectivity()
78 GRPC_CHANNEL_IDLE); in test_connectivity()
83 f.client, GRPC_CHANNEL_IDLE, gpr_now(GPR_CLOCK_MONOTONIC), f.cq, tag(1)); in test_connectivity()
90 GRPC_CHANNEL_IDLE); in test_connectivity()
92 grpc_channel_watch_connectivity_state(f.client, GRPC_CHANNEL_IDLE, in test_connectivity()
148 state == GRPC_CHANNEL_CONNECTING || state == GRPC_CHANNEL_IDLE); in test_connectivity()
Dping.cc36 grpc_connectivity_state state = GRPC_CHANNEL_IDLE; in test_ping()
69 GRPC_CHANNEL_IDLE); in test_ping()
Dmax_connection_idle.cc169 grpc_connectivity_state state = GRPC_CHANNEL_IDLE; in test_max_connection_idle()
192 GRPC_CHANNEL_IDLE); in test_max_connection_idle()
218 state == GRPC_CHANNEL_CONNECTING || state == GRPC_CHANNEL_IDLE); in test_max_connection_idle()
/external/grpc-grpc/test/core/surface/
Dnum_external_connectivity_watchers_test.cc43 GRPC_CHANNEL_IDLE); in channel_idle_start_watch()
46 channel, GRPC_CHANNEL_IDLE, connect_deadline, cq, (void*)(next_tag++)); in channel_idle_start_watch()
60 GRPC_CHANNEL_IDLE); in channel_idle_poll_for_timeout()
138 GRPC_CHANNEL_IDLE); in run_channel_shutdown_before_timeout_test()
140 grpc_channel_watch_connectivity_state(channel, GRPC_CHANNEL_IDLE, in run_channel_shutdown_before_timeout_test()
Dlame_client_test.cc46 grpc_connectivity_state state = GRPC_CHANNEL_IDLE; in test_transport_op()
Dconcurrent_connectivity_test.cc262 GPR_ASSERT(state == GRPC_CHANNEL_IDLE); in watches_with_short_timeouts()
/external/grpc-grpc/src/core/lib/transport/
Dconnectivity_state.cc33 case GRPC_CHANNEL_IDLE: in grpc_connectivity_state_name()
152 return cur == GRPC_CHANNEL_IDLE; in grpc_connectivity_state_notify_on_state_change()
170 case GRPC_CHANNEL_IDLE: in grpc_connectivity_state_set()
/external/grpc-grpc/include/grpc/impl/codegen/
Dconnectivity_state.h29 GRPC_CHANNEL_IDLE, enumerator
/external/grpc-grpc/test/core/handshake/
Dverify_peer_options.cc164 channel, 1 /* try_to_connect */) == GRPC_CHANNEL_IDLE); in verify_peer_options_test()
171 grpc_connectivity_state state = GRPC_CHANNEL_IDLE; in verify_peer_options_test()
Dclient_ssl.cc276 channel, 1 /* try_to_connect */) == GRPC_CHANNEL_IDLE); in client_ssl_test()
282 grpc_connectivity_state state = GRPC_CHANNEL_IDLE; in client_ssl_test()
/external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/pick_first/
Dpick_first.cc157 grpc_connectivity_state_init(&state_tracker_, GRPC_CHANNEL_IDLE, in PickFirst()
485 grpc_connectivity_state_set(&p->state_tracker_, GRPC_CHANNEL_IDLE, in ProcessConnectivityChangeLocked()
537 case GRPC_CHANNEL_IDLE: { in ProcessConnectivityChangeLocked()
/external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/round_robin/
Dround_robin.cc129 grpc_connectivity_state last_connectivity_state_ = GRPC_CHANNEL_IDLE;
233 grpc_connectivity_state_init(&state_tracker_, GRPC_CHANNEL_IDLE, in RoundRobin()
446 if (state != GRPC_CHANNEL_IDLE) { in StartWatchingLocked()
/external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/
Dsubchannel_list.h286 pending_connectivity_state_unsafe_(GRPC_CHANNEL_IDLE) { in SubchannelData()
425 pending_connectivity_state_unsafe_ = GRPC_CHANNEL_IDLE; in UpdateConnectedSubchannelLocked()
/external/grpc-grpc/src/php/ext/grpc/
Dphp_grpc.c202 GRPC_CHANNEL_IDLE, in PHP_MINIT_FUNCTION()
Dchannel.c597 case GRPC_CHANNEL_IDLE: in grpc_connectivity_state_name()
/external/grpc-grpc/test/cpp/end2end/
Dend2end_test.cc1122 EXPECT_EQ(GRPC_CHANNEL_IDLE, channel_->GetState(false)); in TEST_P()
1128 channel_->NotifyOnStateChange(GRPC_CHANNEL_IDLE, deadline, &cq, nullptr); in TEST_P()
1134 EXPECT_EQ(GRPC_CHANNEL_IDLE, channel_->GetState(true)); in TEST_P()
1135 EXPECT_TRUE(channel_->WaitForStateChange(GRPC_CHANNEL_IDLE, in TEST_P()
1154 EXPECT_EQ(GRPC_CHANNEL_IDLE, channel->GetState(true)); in TEST_P()
1156 auto state = GRPC_CHANNEL_IDLE; in TEST_P()
/external/grpc-grpc/src/python/grpcio/grpc/_cython/_cygrpc/
Drecords.pyx.pxi38 idle = GRPC_CHANNEL_IDLE
Dgrpc.pxi229 GRPC_CHANNEL_IDLE
/external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/
Dgrpclb.cc1047 grpc_connectivity_state_init(&state_tracker_, GRPC_CHANNEL_IDLE, "grpclb"); in GrpcLb()
1480 case GRPC_CHANNEL_IDLE: in OnBalancerChannelConnectivityChangedLocked()
1802 case GRPC_CHANNEL_IDLE: in UpdateConnectivityStateFromRoundRobinPolicyLocked()
/external/grpc-grpc/src/ruby/ext/grpc/
Drb_channel.c776 LONG2NUM(GRPC_CHANNEL_IDLE)); in Init_grpc_connectivity_states()
/external/grpc-grpc/src/core/ext/filters/client_channel/
Dsubchannel.cc381 grpc_connectivity_state_init(&c->state_tracker, GRPC_CHANNEL_IDLE, in grpc_subchannel_create()
Dclient_channel.cc691 grpc_connectivity_state_init(&chand->state_tracker, GRPC_CHANNEL_IDLE, in cc_init_channel_elem()
3306 if (out == GRPC_CHANNEL_IDLE && try_to_connect) { in grpc_client_channel_check_connectivity_state()
/external/grpc-grpc/src/core/lib/surface/
Dserver.cc888 chand->connectivity_state = GRPC_CHANNEL_IDLE; in init_channel_elem()