Home
last modified time | relevance | path

Searched refs:pending_call (Results 1 – 25 of 35) sorted by relevance

12

/dports/devel/p5-Net-DBus/Net-DBus-1.2.0/lib/Net/DBus/
H A DASyncReply.pm67 …$self->{pending_call} = $params{pending_call} ? $params{pending_call} : die "pending_call paramete…
87 my $pending_call = delete $self->{pending_call};
89 $pending_call->cancel;
104 $self->{pending_call}->block;
119 return $self->{pending_call}->get_completed;
135 $self->{pending_call}->set_notify(sub {
136 my $pending_call = shift;
155 my $pending_call = delete $self->{pending_call};
157 my $reply = $pending_call->get_reply;
H A DRemoteObject.pm519 my $pending_call = $self->{service}->
523 my $reply = Net::DBus::ASyncReply->_new(pending_call => $pending_call,
/dports/audio/musicpd/mpd-0.23.6/src/lib/dbus/
H A DAsyncRequest.hxx49 PendingCall pending_call; member in ODBus::AsyncRequest
55 return pending_call; in operator bool()
73 assert(!pending_call); in Send()
76 pending_call = PendingCall::SendWithReply(&connection, in Send()
79 pending_call.SetNotify(Notify, this); in Send()
90 pending_call.Cancel(); in Cancel()
95 assert(pending_call.Get() == pending); in Notify()
96 pending_call = {}; in Notify()
/dports/devel/p5-Net-DBus/Net-DBus-1.2.0/lib/Net/DBus/Binding/
H A DPendingCall.pm76 …$self->{pending_call} = exists $params{pending_call} ? $params{pending_call} : die "pending_call p…
93 $self->{pending_call}->dbus_pending_call_cancel();
107 $self->{pending_call}->dbus_pending_call_get_completed();
120 $self->{pending_call}->dbus_pending_call_block();
133 my $reply = $self->{pending_call}->_steal_reply();
156 $self->{pending_call}->_set_notify($cb);
/dports/net-im/telepathy-glib/telepathy-glib-0.24.1/telepathy-glib/
H A Dproxy-methods.c97 DBusGProxyCall *pending_call; member
275 pc->pending_call = NULL; in tp_proxy_pending_call_v0_new()
338 if (!pc->dbus_completed && pc->pending_call != NULL) in tp_proxy_pending_call_cancel()
343 dbus_g_proxy_cancel_call (iface_proxy, pc->pending_call); in tp_proxy_pending_call_cancel()
452 DBusGProxyCall *pending_call) in tp_proxy_pending_call_v0_take_pending_call() argument
455 g_return_if_fail (pc->pending_call == NULL); in tp_proxy_pending_call_v0_take_pending_call()
458 pc->pending_call = pending_call; in tp_proxy_pending_call_v0_take_pending_call()
H A Dproxy-subclass.h43 DBusGProxyCall *pending_call);
/dports/www/chromium-legacy/chromium-88.0.4324.182/dbus/
H A Dobject_proxy.cc304 for (auto* pending_call : pending_calls_) { in Detach() local
308 dbus_pending_call_cancel(pending_call); in Detach()
309 dbus_pending_call_unref(pending_call); in Detach()
338 base::OnceCallback<void(DBusPendingCall * pending_call)>; in StartAsyncMethodCall()
342 [](DBusPendingCall* pending_call, void* user_data) { in StartAsyncMethodCall() argument
343 std::move(*static_cast<PendingCallback*>(user_data)).Run(pending_call); in StartAsyncMethodCall()
359 DBusPendingCall* pending_call) { in OnPendingCallIsComplete() argument
364 DBusMessage* response_message = dbus_pending_call_steal_reply(pending_call); in OnPendingCallIsComplete()
408 pending_calls_.erase(pending_call); in OnPendingCallIsComplete()
409 dbus_pending_call_unref(pending_call); in OnPendingCallIsComplete()
H A Dmock_bus.h48 DBusPendingCall** pending_call,
H A Dobject_proxy.h257 DBusPendingCall* pending_call);
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/dbus/
H A Dobject_proxy.cc309 for (auto* pending_call : pending_calls_) { in Detach() local
313 dbus_pending_call_cancel(pending_call); in Detach()
314 dbus_pending_call_unref(pending_call); in Detach()
343 base::OnceCallback<void(DBusPendingCall * pending_call)>; in StartAsyncMethodCall()
347 [](DBusPendingCall* pending_call, void* user_data) { in StartAsyncMethodCall() argument
348 std::move(*static_cast<PendingCallback*>(user_data)).Run(pending_call); in StartAsyncMethodCall()
364 DBusPendingCall* pending_call) { in OnPendingCallIsComplete() argument
369 DBusMessage* response_message = dbus_pending_call_steal_reply(pending_call); in OnPendingCallIsComplete()
413 pending_calls_.erase(pending_call); in OnPendingCallIsComplete()
414 dbus_pending_call_unref(pending_call); in OnPendingCallIsComplete()
H A Dmock_bus.h48 DBusPendingCall** pending_call,
H A Dobject_proxy.h257 DBusPendingCall* pending_call);
/dports/devel/dbus/dbus-1.12.20/test/internals/
H A Drefs.c518 DBusPendingCall *pending_call; in test_pending_call() local
521 pending_call = _dbus_pending_call_new_unlocked (f->connection, in test_pending_call()
523 g_assert (pending_call != NULL); in test_pending_call()
526 public_api.thing = pending_call; in test_pending_call()
527 internal_api.thing = pending_call; in test_pending_call()
528 unref_and_unlock_api.thing = pending_call; in test_pending_call()
530 if (!dbus_pending_call_set_data (pending_call, pending_call_slot, f, in test_pending_call()
588 dbus_pending_call_unref (pending_call); in test_pending_call()
/dports/devel/efl/efl-1.25.1/src/lib/ethumb_client/
H A Dethumb_client.c138 Eldbus_Pending *pending_call; member
148 Eldbus_Pending *pending_call; member
217 if (pending->pending_call) in _ethumb_client_free()
246 if (pending->pending_call) in _ethumb_client_free()
983 pending->pending_call = NULL; in _ethumb_client_queue_add_cb()
1069 pending->pending_call = NULL; in _ethumb_client_queue_remove_cb()
1129 pending->pending_call = in ethumb_client_generate_cancel()
1150 if (pending_add->pending_call) in ethumb_client_generate_cancel()
1154 pending_add->pending_call = NULL; in ethumb_client_generate_cancel()
1203 if (pending->pending_call) in ethumb_client_generate_cancel_all()
[all …]
/dports/www/chromium-legacy/chromium-88.0.4324.182/chrome/browser/chromeos/wilco_dtc_supportd/
H A Dwilco_dtc_supportd_bridge_unittest.cc98 PendingGetServiceCall pending_call = std::move(*pending_get_service_call_); in RespondToGetServiceCall() local
101 std::move(pending_call.service)); in RespondToGetServiceCall()
102 std::move(pending_call.callback).Run(); in RespondToGetServiceCall()
103 return std::move(pending_call.client); in RespondToGetServiceCall()
/dports/lang/erlang-runtime23/otp-OTP-23.3.4.10/lib/stdlib/src/
H A Ddets_server.erl305 pending_call(Tab, Pid, make_ref(), From, Args,
325 pending_call(Tab, Pid, Ref, From, Args, internal_open, State);
349 pending_call(Tab, Pid, make_ref(), From, [],
356 pending_call(Tab, Pid, make_ref(), From, [],
386 pending_call(Tab, Pid, Ref, {FromPid, _Tag}=From, Args, ReqT, State) -> function
/dports/lang/erlang-runtime22/otp-OTP-22.3.4.24/lib/stdlib/src/
H A Ddets_server.erl305 pending_call(Tab, Pid, make_ref(), From, Args,
325 pending_call(Tab, Pid, Ref, From, Args, internal_open, State);
349 pending_call(Tab, Pid, make_ref(), From, [],
356 pending_call(Tab, Pid, make_ref(), From, [],
386 pending_call(Tab, Pid, Ref, {FromPid, _Tag}=From, Args, ReqT, State) -> function
/dports/lang/erlang-runtime21/otp-OTP-21.3.8.24/lib/stdlib/src/
H A Ddets_server.erl305 pending_call(Tab, Pid, make_ref(), From, Args,
325 pending_call(Tab, Pid, Ref, From, Args, internal_open, State);
349 pending_call(Tab, Pid, make_ref(), From, [],
356 pending_call(Tab, Pid, make_ref(), From, [],
386 pending_call(Tab, Pid, Ref, {FromPid, _Tag}=From, Args, ReqT, State) -> function
/dports/lang/erlang-runtime24/otp-OTP-24.1.7/lib/stdlib/src/
H A Ddets_server.erl305 pending_call(Tab, Pid, make_ref(), From, Args,
325 pending_call(Tab, Pid, Ref, From, Args, internal_open, State);
349 pending_call(Tab, Pid, make_ref(), From, [],
356 pending_call(Tab, Pid, make_ref(), From, [],
386 pending_call(Tab, Pid, Ref, {FromPid, _Tag}=From, Args, ReqT, State) -> function
/dports/lang/erlang-wx/otp-OTP-24.1.7/lib/stdlib/src/
H A Ddets_server.erl305 pending_call(Tab, Pid, make_ref(), From, Args,
325 pending_call(Tab, Pid, Ref, From, Args, internal_open, State);
349 pending_call(Tab, Pid, make_ref(), From, [],
356 pending_call(Tab, Pid, make_ref(), From, [],
386 pending_call(Tab, Pid, Ref, {FromPid, _Tag}=From, Args, ReqT, State) -> function
/dports/lang/erlang/otp-OTP-24.1.7/lib/stdlib/src/
H A Ddets_server.erl305 pending_call(Tab, Pid, make_ref(), From, Args,
325 pending_call(Tab, Pid, Ref, From, Args, internal_open, State);
349 pending_call(Tab, Pid, make_ref(), From, [],
356 pending_call(Tab, Pid, make_ref(), From, [],
386 pending_call(Tab, Pid, Ref, {FromPid, _Tag}=From, Args, ReqT, State) -> function
/dports/lang/erlang-java/otp-OTP-24.1.7/lib/stdlib/src/
H A Ddets_server.erl305 pending_call(Tab, Pid, make_ref(), From, Args,
325 pending_call(Tab, Pid, Ref, From, Args, internal_open, State);
349 pending_call(Tab, Pid, make_ref(), From, [],
356 pending_call(Tab, Pid, make_ref(), From, [],
386 pending_call(Tab, Pid, Ref, {FromPid, _Tag}=From, Args, ReqT, State) -> function
/dports/devel/dbus/dbus-1.12.20/dbus/
H A Ddbus-pending-call.c91 _dbus_pending_call_trace_ref (DBusPendingCall *pending_call, in _dbus_pending_call_trace_ref() argument
99 _dbus_trace_ref ("DBusPendingCall", pending_call, old_refcount, in _dbus_pending_call_trace_ref()
/dports/games/libretro-paralleln64/parallel-n64-6e26fbb/mupen64plus-rsp-paraLLEl/
H A Ddebug_rsp.cpp299 bool pending_call = false; in jit_region() local
343 pending_call = pipe_pending_call; \ in jit_region()
382 …if (pending_call && !pipe_pending_local_branch_delay && !pipe_pending_branch_delay) … in jit_region()
428 …pending_call = false; … in jit_region()
/dports/devel/grpc/grpc-1.42.0/src/core/lib/surface/
H A Dserver.cc239 PendingCall pending_call; in RequestCallWithPossiblePublish() local
243 pending_call.rc = reinterpret_cast<RequestedCall*>( in RequestCallWithPossiblePublish()
245 if (pending_call.rc != nullptr) { in RequestCallWithPossiblePublish()
246 pending_call.calld = pending_.front(); in RequestCallWithPossiblePublish()
251 return pending_call; in RequestCallWithPossiblePublish()

12