| /dports/devel/gvfs/gvfs-1.46.2/client/ |
| H A D | gvfsdaemondbus.c | 172 if (async_call->callback) in async_call_finish()
173 async_call->callback (async_call->io_error ? NULL : async_call->connection, in async_call_finish()
174 async_call->io_error, in async_call_finish()
175 async_call->callback_data); in async_call_finish()
180 g_free (async_call->dbus_id); in async_call_finish()
181 g_free (async_call); in async_call_finish()
224 if (g_cancellable_set_error_if_cancelled (async_call->cancellable, &async_call->io_error)) in async_got_private_connection_cb()
230 async_call_finish (async_call); in async_got_private_connection_cb()
309 AsyncDBusCall *async_call; in _g_dbus_connection_get_for_async() local
315 async_call->callback = callback; in _g_dbus_connection_get_for_async()
[all …]
|
| /dports/net-p2p/libtorrent-rasterbar/libtorrent-rasterbar-1.2.14/src/ |
| H A D | torrent_handle.cpp | 340 async_call(&torrent::flush_cache); in flush_cache()
385 async_call(&torrent::force_recheck); in force_recheck()
390 async_call(&torrent::resume); in resume()
401 async_call(&torrent::queue_up); in queue_position_up()
406 async_call(&torrent::queue_down); in queue_position_down()
428 async_call(&torrent::clear_error); in clear_error()
434 async_call(&torrent::set_priority, p); in set_priority()
475 async_call(&torrent::prioritize_pieces in prioritize_pieces()
537 async_call(&torrent::prioritize_files in prioritize_files()
751 async_call(&torrent::clear_peers); in clear_peers()
[all …]
|
| H A D | session_handle.cpp | 214 async_call(&session_impl::post_session_stats); in post_session_stats()
219 async_call(&session_impl::post_dht_stats); in post_dht_stats()
440 async_call(&session_impl::async_add_torrent, p); in async_add_torrent()
503 async_call(&session_impl::pause); in pause()
508 async_call(&session_impl::resume); in resume()
595 async_call(&session_impl::set_dht_storage, sc); in set_dht_storage()
614 async_call(&session_impl::add_dht_router, node); in add_dht_router()
693 async_call(&session_impl::dht_live_nodes, nid); in dht_live_nodes()
744 async_call(&session_impl::add_extension, ext); in add_extension()
820 async_call(&session_impl::set_ip_filter, copy); in set_ip_filter()
[all …]
|
| /dports/net-p2p/py-libtorrent-rasterbar/libtorrent-1.2.13/src/ |
| H A D | torrent_handle.cpp | 340 async_call(&torrent::flush_cache); in flush_cache()
385 async_call(&torrent::force_recheck); in force_recheck()
390 async_call(&torrent::resume); in resume()
401 async_call(&torrent::queue_up); in queue_position_up()
406 async_call(&torrent::queue_down); in queue_position_down()
428 async_call(&torrent::clear_error); in clear_error()
434 async_call(&torrent::set_priority, p); in set_priority()
475 async_call(&torrent::prioritize_pieces in prioritize_pieces()
537 async_call(&torrent::prioritize_files in prioritize_files()
751 async_call(&torrent::clear_peers); in clear_peers()
[all …]
|
| H A D | session_handle.cpp | 214 async_call(&session_impl::post_session_stats); in post_session_stats()
219 async_call(&session_impl::post_dht_stats); in post_dht_stats()
440 async_call(&session_impl::async_add_torrent, p); in async_add_torrent()
503 async_call(&session_impl::pause); in pause()
508 async_call(&session_impl::resume); in resume()
595 async_call(&session_impl::set_dht_storage, sc); in set_dht_storage()
614 async_call(&session_impl::add_dht_router, node); in add_dht_router()
693 async_call(&session_impl::dht_live_nodes, nid); in dht_live_nodes()
744 async_call(&session_impl::add_extension, ext); in add_extension()
820 async_call(&session_impl::set_ip_filter, copy); in set_ip_filter()
[all …]
|
| /dports/devel/silc-toolkit/silc-toolkit-1.1.12/lib/silcutil/ |
| H A D | silcfsm_i.h | 72 unsigned int async_call : 1; /* Set if called real async call */ member
89 SilcBool silc_fsm_set_call(struct SilcFSMObject *fsm, SilcBool async_call) in silc_fsm_set_call() argument
91 SilcBool old = fsm->async_call; in silc_fsm_set_call()
92 fsm->async_call = async_call; in silc_fsm_set_call()
|
| /dports/devel/erlang-sbroker/sbroker-1.0.0/src/ |
| H A D | sbroker_gen.erl | 25 -export([async_call/3]).
26 -export([async_call/4]).
90 -spec async_call(Process, Label, Msg) -> {await, Tag, NProcess} | {drop, 0} when
96 async_call(Process, Label, Msg) -> function
99 exit({noproc, {?MODULE, async_call, [Process, Label, Msg]}});
109 -spec async_call(Process, Label, Msg, To) ->
118 async_call(Process, Label, Msg, {Pid, Tag} = To) when is_pid(Pid) -> function
121 exit({noproc, {?MODULE, async_call, [Process, Label, Msg, Tag]}});
|
| /dports/editors/py-pynvim/pynvim-0.4.3/test/ |
| H A D | test_concurrency.py | 5 timer = Timer(0.5, lambda: vim.async_call(lambda: vim.stop_loop()))
13 vim.async_call(lambda: [vim.eval("3"), undefined_variable]) # noqa: F821
14 timer = Timer(0.5, lambda: vim.async_call(lambda: vim.stop_loop()))
|
| /dports/devel/google-cloud-cpp/google-cloud-cpp-1.21.0/google/cloud/internal/ |
| H A D | async_retry_unary_rpc.h | 86 Idempotency idempotency, AsyncCallType async_call, Request request) { in Start() argument
89 idempotency, std::move(async_call), std::move(request))); in Start()
102 Idempotency idempotency, AsyncCallType async_call, in RetryAsyncUnaryRpc() argument
108 async_call_(std::move(async_call)), in RetryAsyncUnaryRpc()
211 Idempotency idempotency, AsyncCallType&& async_call, in StartRetryAsyncUnaryRpc() argument
219 async_call), in StartRetryAsyncUnaryRpc()
|
| H A D | async_rpc_details.h | 58 void Start(AsyncFunctionType async_call, in Start() argument
64 auto rpc = async_call(context.get(), request, cq); in Start()
|
| /dports/devel/google-cloud-cpp117/google-cloud-cpp-1.17.0/google/cloud/internal/ |
| H A D | async_retry_unary_rpc.h | 86 AsyncCallType async_call, Request request) { in Start() argument
89 is_idempotent, std::move(async_call), std::move(request))); in Start()
102 bool is_idempotent, AsyncCallType async_call, in RetryAsyncUnaryRpc() argument
108 async_call_(std::move(async_call)), in RetryAsyncUnaryRpc()
211 bool is_idempotent, AsyncCallType&& async_call, in StartRetryAsyncUnaryRpc() argument
219 async_call), in StartRetryAsyncUnaryRpc()
|
| /dports/devel/google-cloud-cpp/google-cloud-cpp-1.21.0/google/cloud/bigtable/internal/ |
| H A D | async_retry_unary_rpc_and_poll.h | 66 AsyncCallType async_call, RequestType request, CompletionQueue cq) { in AsyncStartPollAfterRetryUnaryRpc() argument
74 AsyncCallType async_call; in AsyncStartPollAfterRetryUnaryRpc() member
82 return async_call(context, request, cq); in AsyncStartPollAfterRetryUnaryRpc()
85 CallWrapper wrapper{std::move(metadata_update_policy), std::move(async_call)}; in AsyncStartPollAfterRetryUnaryRpc()
|
| H A D | async_retry_multi_page.h | 36 MetadataUpdatePolicy metadata_update_policy, AsyncCallType async_call,
81 MetadataUpdatePolicy metadata_update_policy, AsyncCallType async_call, in AsyncRetryMultiPageFuture() argument
89 async_call_(std::move(async_call)), in AsyncRetryMultiPageFuture()
176 MetadataUpdatePolicy metadata_update_policy, AsyncCallType async_call,
209 MetadataUpdatePolicy metadata_update_policy, AsyncCallType async_call, in StartAsyncRetryMultiPage() argument
218 std::move(metadata_update_policy), async_call, std::move(request), in StartAsyncRetryMultiPage()
|
| /dports/devel/google-cloud-cpp117/google-cloud-cpp-1.17.0/google/cloud/bigtable/internal/ |
| H A D | async_retry_unary_rpc_and_poll.h | 66 AsyncCallType async_call, RequestType request, CompletionQueue cq) { in AsyncStartPollAfterRetryUnaryRpc() argument
74 AsyncCallType async_call; in AsyncStartPollAfterRetryUnaryRpc() member
82 return async_call(context, request, cq); in AsyncStartPollAfterRetryUnaryRpc()
85 CallWrapper wrapper{std::move(metadata_update_policy), std::move(async_call)}; in AsyncStartPollAfterRetryUnaryRpc()
|
| H A D | async_retry_multi_page.h | 36 MetadataUpdatePolicy metadata_update_policy, AsyncCallType async_call,
81 MetadataUpdatePolicy metadata_update_policy, AsyncCallType async_call, in AsyncRetryMultiPageFuture() argument
89 async_call_(std::move(async_call)), in AsyncRetryMultiPageFuture()
176 MetadataUpdatePolicy metadata_update_policy, AsyncCallType async_call,
209 MetadataUpdatePolicy metadata_update_policy, AsyncCallType async_call, in StartAsyncRetryMultiPage() argument
218 std::move(metadata_update_policy), async_call, std::move(request), in StartAsyncRetryMultiPage()
|
| /dports/devel/rpclib/rpclib-2.2.1/tests/rpc/ |
| H A D | server_test.cc | 39 auto ft_long = c.async_call("long_func"); in TEST_F()
40 auto ft_short = c.async_call("short_func"); in TEST_F()
55 auto ft_long = c.async_call("long_func"); in TEST_F()
56 auto ft_short = c.async_call("short_func"); in TEST_F()
|
| H A D | this_session_test.cc | 32 auto f = c.async_call("exit"); in TEST_F()
50 auto f = c.async_call("exit"); in TEST_F()
|
| H A D | this_handler_test.cc | 86 auto f = c.async_call("noresp"); in TEST_F()
95 auto f = c.async_call("noresp"); in TEST_F()
|
| /dports/devel/google-cloud-cpp117/google-cloud-cpp-1.17.0/google/cloud/ |
| H A D | completion_queue.h | 123 AsyncCallType async_call, Request const& request, in MakeUnaryRpc() argument
128 op->Start(async_call, std::move(context), request, &impl_->cq(), tag); in MakeUnaryRpc()
166 AsyncCallType&& async_call, Request const& request, in MakeStreamingReadRpc() argument
172 stream->Start(std::forward<AsyncCallType>(async_call), request, in MakeStreamingReadRpc()
|
| /dports/devel/google-cloud-cpp/google-cloud-cpp-1.21.0/google/cloud/ |
| H A D | completion_queue.h | 126 AsyncCallType async_call, Request const& request, in MakeUnaryRpc() argument
131 op->Start(async_call, std::move(context), request, &impl_->cq(), tag); in MakeUnaryRpc()
169 AsyncCallType&& async_call, Request const& request, in MakeStreamingReadRpc() argument
175 stream->Start(std::forward<AsyncCallType>(async_call), request, in MakeStreamingReadRpc()
|
| /dports/lang/mono/mono-5.10.1.57/mono/metadata/ |
| H A D | threadpool.c | 426 MonoAsyncCall *async_call; in mono_threadpool_begin_invoke() local
438 async_call = (MonoAsyncCall*) mono_object_new_checked (domain, async_call_klass, error); in mono_threadpool_begin_invoke()
441 MONO_OBJECT_SETREF (async_call, msg, message); in mono_threadpool_begin_invoke()
442 MONO_OBJECT_SETREF (async_call, state, state); in mono_threadpool_begin_invoke()
445 …MONO_OBJECT_SETREF (async_call, cb_method, mono_get_delegate_invoke (((MonoObject*) async_callback… in mono_threadpool_begin_invoke()
446 MONO_OBJECT_SETREF (async_call, cb_target, async_callback); in mono_threadpool_begin_invoke()
449 …async_result = mono_async_result_new (domain, NULL, async_call->state, NULL, (MonoObject*) async_c… in mono_threadpool_begin_invoke()
|
| /dports/devel/silc-toolkit/silc-toolkit-1.1.12/lib/silcutil/tests/ |
| H A D | test_silcasync.c | 41 static SilcAsyncOperation async_call(Callback cb, void *context) in async_call() function
77 SILC_FSM_CALL((f->op = async_call(async_call_cb, f))); in SILC_FSM_STATE()
|
| /dports/devel/rpclib/rpclib-2.2.1/include/rpc/ |
| H A D | client.inl | 7 auto future = async_call(func_name, std::forward<Args>(args)...);
20 client::async_call(std::string const &func_name, Args... args) { function in rpc::client
|
| /dports/comms/uhd/uhd-90ce6062b6b5df2eddeee723777be85108e4e7c7/host/lib/deps/rpclib/include/rpc/ |
| H A D | client.inl | 7 auto future = async_call(func_name, std::forward<Args>(args)...);
19 client::async_call(std::string const &func_name, Args... args) { function in rpc::client
|
| /dports/lang/erlang-runtime22/otp-OTP-22.3.4.24/lib/kernel/test/ |
| H A D | rpc_SUITE.erl | 28 called_throws/1, call_benchmark/1, async_call/1]).
42 async_call].
452 async_call(Config) when is_list(Config) -> function
459 Promise1 = rpc:async_call(Node1, ?MODULE, f, []),
460 Promise2 = rpc:async_call(Node2, ?MODULE, f, []),
461 Promise3 = rpc:async_call(Node3, ?MODULE, f, []),
|