Home
last modified time | relevance | path

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

123456789

/dports/devel/grpc130/grpc-1.30.2/test/core/transport/
H A Dconnectivity_state_test.cc75 tracker.AddWatcher(GRPC_CHANNEL_IDLE, in TEST()
85 tracker.AddWatcher(GRPC_CHANNEL_IDLE, in TEST()
88 EXPECT_EQ(state, GRPC_CHANNEL_IDLE); in TEST()
101 tracker.AddWatcher(GRPC_CHANNEL_IDLE, in TEST()
106 EXPECT_EQ(state, GRPC_CHANNEL_IDLE); in TEST()
111 EXPECT_EQ(state, GRPC_CHANNEL_IDLE); in TEST()
121 tracker.AddWatcher(GRPC_CHANNEL_IDLE, in TEST()
126 EXPECT_EQ(state, GRPC_CHANNEL_IDLE); in TEST()
141 tracker.AddWatcher(GRPC_CHANNEL_IDLE, in TEST()
153 tracker.AddWatcher(GRPC_CHANNEL_IDLE, in TEST()
[all …]
/dports/devel/grpc134/grpc-1.34.1/test/core/transport/
H A Dconnectivity_state_test.cc91 tracker.AddWatcher(GRPC_CHANNEL_IDLE, in TEST()
106 tracker.AddWatcher(GRPC_CHANNEL_IDLE, in TEST()
118 tracker.AddWatcher(GRPC_CHANNEL_IDLE, in TEST()
121 EXPECT_EQ(state, GRPC_CHANNEL_IDLE); in TEST()
140 tracker.AddWatcher(GRPC_CHANNEL_IDLE, in TEST()
145 EXPECT_EQ(state, GRPC_CHANNEL_IDLE); in TEST()
151 EXPECT_EQ(state, GRPC_CHANNEL_IDLE); in TEST()
163 tracker.AddWatcher(GRPC_CHANNEL_IDLE, in TEST()
168 EXPECT_EQ(state, GRPC_CHANNEL_IDLE); in TEST()
187 tracker.AddWatcher(GRPC_CHANNEL_IDLE, in TEST()
[all …]
/dports/devel/grpc/grpc-1.42.0/test/core/transport/
H A Dconnectivity_state_test.cc91 tracker.AddWatcher(GRPC_CHANNEL_IDLE, in TEST()
106 tracker.AddWatcher(GRPC_CHANNEL_IDLE, in TEST()
118 tracker.AddWatcher(GRPC_CHANNEL_IDLE, in TEST()
121 EXPECT_EQ(state, GRPC_CHANNEL_IDLE); in TEST()
140 tracker.AddWatcher(GRPC_CHANNEL_IDLE, in TEST()
145 EXPECT_EQ(state, GRPC_CHANNEL_IDLE); in TEST()
151 EXPECT_EQ(state, GRPC_CHANNEL_IDLE); in TEST()
163 tracker.AddWatcher(GRPC_CHANNEL_IDLE, in TEST()
168 EXPECT_EQ(state, GRPC_CHANNEL_IDLE); in TEST()
187 tracker.AddWatcher(GRPC_CHANNEL_IDLE, in TEST()
[all …]
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/test/core/transport/
H A Dconnectivity_state_test.cc48 strcmp(grpc_connectivity_state_name(GRPC_CHANNEL_IDLE), "IDLE")); in test_connectivity_state_name()
64 grpc_connectivity_state_init(&tracker, GRPC_CHANNEL_IDLE, "xxx"); in test_check()
65 GPR_ASSERT(grpc_connectivity_state_check(&tracker) == GRPC_CHANNEL_IDLE); in test_check()
73 grpc_connectivity_state state = GRPC_CHANNEL_IDLE; in test_subscribe_then_unsubscribe()
77 grpc_connectivity_state_init(&tracker, GRPC_CHANNEL_IDLE, "xxx"); in test_subscribe_then_unsubscribe()
81 GPR_ASSERT(state == GRPC_CHANNEL_IDLE); in test_subscribe_then_unsubscribe()
85 GPR_ASSERT(state == GRPC_CHANNEL_IDLE); in test_subscribe_then_unsubscribe()
95 grpc_connectivity_state state = GRPC_CHANNEL_IDLE; in test_subscribe_then_destroy()
99 grpc_connectivity_state_init(&tracker, GRPC_CHANNEL_IDLE, "xxx"); in test_subscribe_then_destroy()
103 GPR_ASSERT(state == GRPC_CHANNEL_IDLE); in test_subscribe_then_destroy()
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/test/core/end2end/tests/
H A 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()
H A Dping.cc36 grpc_connectivity_state state = GRPC_CHANNEL_IDLE; in test_ping()
69 GRPC_CHANNEL_IDLE); in test_ping()
H A 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()
/dports/devel/grpc134/grpc-1.34.1/test/core/end2end/tests/
H A Dconnectivity.cc86 GRPC_CHANNEL_IDLE); in test_connectivity()
89 GRPC_CHANNEL_IDLE); in test_connectivity()
94 f.client, GRPC_CHANNEL_IDLE, gpr_now(GPR_CLOCK_MONOTONIC), f.cq, tag(1)); in test_connectivity()
101 GRPC_CHANNEL_IDLE); in test_connectivity()
103 grpc_channel_watch_connectivity_state(f.client, GRPC_CHANNEL_IDLE, in test_connectivity()
159 state == GRPC_CHANNEL_CONNECTING || state == GRPC_CHANNEL_IDLE); in test_connectivity()
215 grpc_channel_watch_connectivity_state(f.client, GRPC_CHANNEL_IDLE, in test_watch_connectivity_cq_callback()
H A Dping.cc38 grpc_connectivity_state state = GRPC_CHANNEL_IDLE; in test_ping()
64 GRPC_CHANNEL_IDLE); in test_ping()
H A 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()
/dports/devel/grpc/grpc-1.42.0/test/core/end2end/tests/
H A Dconnectivity.cc85 GRPC_CHANNEL_IDLE); in test_connectivity()
88 GRPC_CHANNEL_IDLE); in test_connectivity()
93 f.client, GRPC_CHANNEL_IDLE, gpr_now(GPR_CLOCK_MONOTONIC), f.cq, tag(1)); in test_connectivity()
100 GRPC_CHANNEL_IDLE); in test_connectivity()
102 grpc_channel_watch_connectivity_state(f.client, GRPC_CHANNEL_IDLE, in test_connectivity()
158 state == GRPC_CHANNEL_CONNECTING || state == GRPC_CHANNEL_IDLE); in test_connectivity()
214 grpc_channel_watch_connectivity_state(f.client, GRPC_CHANNEL_IDLE, in test_watch_connectivity_cq_callback()
H A Dping.cc37 grpc_connectivity_state state = GRPC_CHANNEL_IDLE; in test_ping()
63 GRPC_CHANNEL_IDLE); in test_ping()
H A Dmax_connection_idle.cc168 grpc_connectivity_state state = GRPC_CHANNEL_IDLE; in test_max_connection_idle()
191 GRPC_CHANNEL_IDLE); in test_max_connection_idle()
217 state == GRPC_CHANNEL_CONNECTING || state == GRPC_CHANNEL_IDLE); in test_max_connection_idle()
/dports/devel/grpc130/grpc-1.30.2/test/core/end2end/tests/
H A Dconnectivity.cc86 GRPC_CHANNEL_IDLE); in test_connectivity()
89 GRPC_CHANNEL_IDLE); in test_connectivity()
94 f.client, GRPC_CHANNEL_IDLE, gpr_now(GPR_CLOCK_MONOTONIC), f.cq, tag(1)); in test_connectivity()
101 GRPC_CHANNEL_IDLE); in test_connectivity()
103 grpc_channel_watch_connectivity_state(f.client, GRPC_CHANNEL_IDLE, in test_connectivity()
159 state == GRPC_CHANNEL_CONNECTING || state == GRPC_CHANNEL_IDLE); in test_connectivity()
215 grpc_channel_watch_connectivity_state(f.client, GRPC_CHANNEL_IDLE, in test_watch_connectivity_cq_callback()
H A Dping.cc36 grpc_connectivity_state state = GRPC_CHANNEL_IDLE; in test_ping()
69 GRPC_CHANNEL_IDLE); in test_ping()
H A 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()
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/test/core/surface/
H A Dnum_external_connectivity_watchers_test.cc44 GRPC_CHANNEL_IDLE); in channel_idle_start_watch()
47 channel, GRPC_CHANNEL_IDLE, connect_deadline, cq, (void*)(next_tag++)); in channel_idle_start_watch()
61 GRPC_CHANNEL_IDLE); in channel_idle_poll_for_timeout()
134 GRPC_CHANNEL_IDLE); in run_channel_shutdown_before_timeout_test()
136 grpc_channel_watch_connectivity_state(channel, GRPC_CHANNEL_IDLE, in run_channel_shutdown_before_timeout_test()
/dports/devel/grpc134/grpc-1.34.1/test/core/surface/
H A Dnum_external_connectivity_watchers_test.cc46 GRPC_CHANNEL_IDLE); in channel_idle_start_watch()
49 channel, GRPC_CHANNEL_IDLE, connect_deadline, cq, (void*)(next_tag++)); in channel_idle_start_watch()
63 GRPC_CHANNEL_IDLE); in channel_idle_poll_for_timeout()
136 GRPC_CHANNEL_IDLE); in run_channel_shutdown_before_timeout_test()
138 grpc_channel_watch_connectivity_state(channel, GRPC_CHANNEL_IDLE, in run_channel_shutdown_before_timeout_test()
/dports/devel/grpc130/grpc-1.30.2/test/core/surface/
H A Dnum_external_connectivity_watchers_test.cc46 GRPC_CHANNEL_IDLE); in channel_idle_start_watch()
49 channel, GRPC_CHANNEL_IDLE, connect_deadline, cq, (void*)(next_tag++)); in channel_idle_start_watch()
63 GRPC_CHANNEL_IDLE); in channel_idle_poll_for_timeout()
136 GRPC_CHANNEL_IDLE); in run_channel_shutdown_before_timeout_test()
138 grpc_channel_watch_connectivity_state(channel, GRPC_CHANNEL_IDLE, in run_channel_shutdown_before_timeout_test()
/dports/devel/grpc/grpc-1.42.0/test/core/surface/
H A Dnum_external_connectivity_watchers_test.cc46 GRPC_CHANNEL_IDLE); in channel_idle_start_watch()
48 grpc_channel_watch_connectivity_state(channel, GRPC_CHANNEL_IDLE, in channel_idle_start_watch()
64 GRPC_CHANNEL_IDLE); in channel_idle_poll_for_timeout()
137 GRPC_CHANNEL_IDLE); in run_channel_shutdown_before_timeout_test()
139 grpc_channel_watch_connectivity_state(channel, GRPC_CHANNEL_IDLE, in run_channel_shutdown_before_timeout_test()
/dports/devel/grpc/grpc-1.42.0/src/core/ext/filters/client_channel/lb_policy/ring_hash/
H A Dring_hash.cc429 case GRPC_CHANNEL_IDLE: in Pick()
453 case GRPC_CHANNEL_IDLE: in Pick()
467 if (entry.connectivity_state == GRPC_CHANNEL_IDLE) { in Pick()
507 if (old_state == GRPC_CHANNEL_IDLE) { in UpdateStateCountersLocked()
520 if (new_state == GRPC_CHANNEL_IDLE) { in UpdateStateCountersLocked()
561 GRPC_CHANNEL_IDLE, absl::Status(), in UpdateRingHashConnectivityStateLocked()
/dports/devel/pecl-grpc/grpc-1.42.0/src/core/ext/filters/client_channel/lb_policy/ring_hash/
H A Dring_hash.cc429 case GRPC_CHANNEL_IDLE:
453 case GRPC_CHANNEL_IDLE:
467 if (entry.connectivity_state == GRPC_CHANNEL_IDLE) {
507 if (old_state == GRPC_CHANNEL_IDLE) {
520 if (new_state == GRPC_CHANNEL_IDLE) {
561 GRPC_CHANNEL_IDLE, absl::Status(),
/dports/devel/py-grpcio/grpcio-1.43.0/src/core/ext/filters/client_channel/lb_policy/ring_hash/
H A Dring_hash.cc429 case GRPC_CHANNEL_IDLE: in Pick()
453 case GRPC_CHANNEL_IDLE: in Pick()
467 if (entry.connectivity_state == GRPC_CHANNEL_IDLE) { in Pick()
507 if (old_state == GRPC_CHANNEL_IDLE) { in UpdateStateCountersLocked()
520 if (new_state == GRPC_CHANNEL_IDLE) { in UpdateStateCountersLocked()
561 GRPC_CHANNEL_IDLE, absl::Status(), in UpdateRingHashConnectivityStateLocked()
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/src/core/lib/transport/
H A Dconnectivity_state.cc33 case GRPC_CHANNEL_IDLE: in grpc_connectivity_state_name()
136 return cur == GRPC_CHANNEL_IDLE; in grpc_connectivity_state_notify_on_state_change()
/dports/devel/grpc130/grpc-1.30.2/include/grpc/impl/codegen/
H A Dconnectivity_state.h29 GRPC_CHANNEL_IDLE, enumerator

123456789