Home
last modified time | relevance | path

Searched refs:active_call (Results 1 – 25 of 26) sorted by relevance

12

/dports/devel/grpc134/grpc-1.34.1/src/ruby/lib/grpc/generic/
H A Drpc_desc.rb51 req = active_call.read_unary_request
52 call = active_call.single_req_view
61 active_call.server_unary_response(
69 call = active_call.multi_req_view
77 active_call.server_unary_response(
85 req = active_call.read_unary_request
86 call = active_call.single_req_view
96 send_status(active_call, OK, 'OK', active_call.output_metadata)
106 active_call.run_server_bidi(mth, inter_ctx)
107 send_status(active_call, OK, 'OK', active_call.output_metadata)
[all …]
H A Drpc_server.rb454 active_call = new_active_server_call(an_rpc)
455 unless active_call.nil?
456 @pool.schedule(active_call) do |ac|
/dports/devel/grpc/grpc-1.42.0/src/ruby/lib/grpc/generic/
H A Drpc_desc.rb51 req = active_call.read_unary_request
52 call = active_call.single_req_view
61 active_call.server_unary_response(
69 call = active_call.multi_req_view
77 active_call.server_unary_response(
85 req = active_call.read_unary_request
86 call = active_call.single_req_view
96 send_status(active_call, OK, 'OK', active_call.output_metadata)
106 active_call.run_server_bidi(mth, inter_ctx)
107 send_status(active_call, OK, 'OK', active_call.output_metadata)
[all …]
H A Drpc_server.rb454 active_call = new_active_server_call(an_rpc)
455 unless active_call.nil?
456 @pool.schedule(active_call) do |ac|
/dports/devel/grpc130/grpc-1.30.2/src/ruby/lib/grpc/generic/
H A Drpc_desc.rb51 req = active_call.read_unary_request
52 call = active_call.single_req_view
61 active_call.server_unary_response(
69 call = active_call.multi_req_view
77 active_call.server_unary_response(
85 req = active_call.read_unary_request
86 call = active_call.single_req_view
96 send_status(active_call, OK, 'OK', active_call.output_metadata)
106 active_call.run_server_bidi(mth, inter_ctx)
107 send_status(active_call, OK, 'OK', active_call.output_metadata)
[all …]
H A Drpc_server.rb454 active_call = new_active_server_call(an_rpc)
455 unless active_call.nil?
456 @pool.schedule(active_call) do |ac|
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/src/ruby/lib/grpc/generic/
H A Drpc_desc.rb51 req = active_call.read_unary_request
52 call = active_call.single_req_view
61 active_call.server_unary_response(
69 call = active_call.multi_req_view
77 active_call.server_unary_response(
85 req = active_call.read_unary_request
86 call = active_call.single_req_view
96 send_status(active_call, OK, 'OK', active_call.output_metadata)
106 active_call.run_server_bidi(mth, inter_ctx)
107 send_status(active_call, OK, 'OK', active_call.output_metadata)
[all …]
H A Drpc_server.rb455 active_call = new_active_server_call(an_rpc)
456 unless active_call.nil?
457 @pool.schedule(active_call) do |ac|
/dports/devel/grpc/grpc-1.42.0/test/core/end2end/fuzzers/
H A Dapi_fuzzer.cc942 auto* active_call = ActiveCall(); in DEFINE_PROTO_FUZZER() local
943 if (active_call == nullptr || in DEFINE_PROTO_FUZZER()
945 active_call->call() == nullptr) { in DEFINE_PROTO_FUZZER()
981 auto* active_call = ActiveCall(); in DEFINE_PROTO_FUZZER() local
982 if (active_call != nullptr && active_call->call() != nullptr) { in DEFINE_PROTO_FUZZER()
983 grpc_call_cancel(active_call->call(), nullptr); in DEFINE_PROTO_FUZZER()
991 auto* active_call = ActiveCall(); in DEFINE_PROTO_FUZZER() local
992 if (active_call != nullptr && active_call->call() != nullptr) { in DEFINE_PROTO_FUZZER()
1040 auto* active_call = ActiveCall(); in DEFINE_PROTO_FUZZER() local
1041 if (active_call != nullptr && in DEFINE_PROTO_FUZZER()
[all …]
/dports/www/chromium-legacy/chromium-88.0.4324.182/content/browser/appcache/
H A Dappcache_disk_cache.cc125 scoped_refptr<ActiveCall> active_call = in CreateEntry() local
129 base::BindOnce(&ActiveCall::OnAsyncCompletion, active_call)); in CreateEntry()
130 return active_call->HandleImmediateReturnValue(std::move(result)); in CreateEntry()
137 scoped_refptr<ActiveCall> active_call = in OpenEntry() local
141 base::BindOnce(&ActiveCall::OnAsyncCompletion, active_call)); in OpenEntry()
142 return active_call->HandleImmediateReturnValue(std::move(result)); in OpenEntry()
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/content/browser/appcache/
H A Dappcache_disk_cache.cc126 scoped_refptr<ActiveCall> active_call = in CreateEntry() local
130 base::BindOnce(&ActiveCall::OnAsyncCompletion, active_call)); in CreateEntry()
131 return active_call->HandleImmediateReturnValue(std::move(result)); in CreateEntry()
138 scoped_refptr<ActiveCall> active_call = in OpenEntry() local
142 base::BindOnce(&ActiveCall::OnAsyncCompletion, active_call)); in OpenEntry()
143 return active_call->HandleImmediateReturnValue(std::move(result)); in OpenEntry()
/dports/net/samba412/samba-4.12.15/source4/ldap_server/
H A Dldap_server.c73 if (conn->active_call) {
74 tevent_req_cancel(conn->active_call);
75 conn->active_call = NULL;
627 conn->active_call = subreq;
642 conn->active_call = NULL;
664 conn->active_call = subreq;
679 conn->active_call = NULL;
961 if (conn->active_call != NULL) {
980 conn->active_call = subreq;
H A Dldap_server.h68 struct tevent_req *active_call;
/dports/net-im/uTox/uTox/src/
H A Dgroups.h35 bool active_call; member
H A Dutox.c704 g->active_call = true; in utox_message_dispatch()
720 g->active_call = false; in utox_message_dispatch()
/dports/devel/grpc130/grpc-1.30.2/src/ruby/spec/generic/
H A Dactive_call_spec.rb36 def inner_call_of_active_call(active_call) argument
37 active_call.instance_variable_get(:@call)
/dports/devel/grpc134/grpc-1.34.1/src/ruby/spec/generic/
H A Dactive_call_spec.rb36 def inner_call_of_active_call(active_call) argument
37 active_call.instance_variable_get(:@call)
/dports/devel/grpc/grpc-1.42.0/src/ruby/spec/generic/
H A Dactive_call_spec.rb36 def inner_call_of_active_call(active_call) argument
37 active_call.instance_variable_get(:@call)
/dports/net-im/uTox/uTox/src/layout/
H A Dgroup.c182 if (g->active_call) { in button_group_audio_on_mup()
199 if (g->active_call) { in button_group_audio_update()
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/src/ruby/spec/generic/
H A Dactive_call_spec.rb36 def inner_call_of_active_call(active_call) argument
37 active_call.instance_variable_get(:@call)
/dports/net-im/uTox/uTox/src/av/
H A Daudio.c895 if (get_group(i) && get_group(i)->active_call) { in utox_audio_thread()
937 if (!g->active_call) { in callback_av_group_audio()
/dports/devel/grpc134/grpc-1.34.1/src/ruby/
H A D.rubocop_todo.yml182 - 'lib/grpc/generic/active_call.rb'
/dports/devel/grpc/grpc-1.42.0/src/ruby/
H A D.rubocop_todo.yml182 - 'lib/grpc/generic/active_call.rb'
/dports/devel/grpc130/grpc-1.30.2/src/ruby/
H A D.rubocop_todo.yml182 - 'lib/grpc/generic/active_call.rb'
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/src/ruby/
H A D.rubocop_todo.yml182 - 'lib/grpc/generic/active_call.rb'

12