Home
last modified time | relevance | path

Searched refs:pending_operations (Results 1 – 25 of 29) sorted by relevance

12

/dports/devel/onetbb/oneTBB-2021.4.0/include/oneapi/tbb/detail/
H A D_aggregator.h53 aggregator_generic() : pending_operations(nullptr), handler_busy(false) {} in aggregator_generic()
78 OperationType* res = pending_operations.load(std::memory_order_relaxed);
81 } while (!pending_operations.compare_exchange_strong(res, op));
86 call_itt_notify(acquired, &pending_operations);
124 call_itt_notify(releasing, &pending_operations); in start_handle_operations()
126 op_list = pending_operations.exchange(nullptr); in start_handle_operations()
136 std::atomic<OperationType*> pending_operations; variable
/dports/math/stanmath/math-4.2.0/lib/tbb_2020.3/include/tbb/internal/
H A D_aggregator_impl.h51 aggregator_generic() : handler_busy(false) { pending_operations = NULL; } in aggregator_generic()
81 op->next = res = pending_operations; // NOT A RACE
82 } while (pending_operations.compare_and_swap(op, res) != res);
87 call_itt_notify(acquired, &pending_operations);
104 atomic<operation_type *> pending_operations;
131 call_itt_notify(releasing, &pending_operations); in start_handle_operations()
133 op_list = pending_operations.fetch_and_store(NULL); in start_handle_operations()
/dports/math/deal.ii/dealii-803d21ff957e349b3799cd3ef2c840bc78734305/bundled/tbb-2018_U2/include/tbb/internal/
H A D_aggregator_impl.h55 aggregator_generic() : handler_busy(false) { pending_operations = NULL; } in aggregator_generic()
85 op->next = res = pending_operations; // NOT A RACE
86 } while (pending_operations.compare_and_swap(op, res) != res);
91 call_itt_notify(acquired, &pending_operations);
108 atomic<operation_type *> pending_operations;
135 call_itt_notify(releasing, &pending_operations); in start_handle_operations()
137 op_list = pending_operations.fetch_and_store(NULL); in start_handle_operations()
/dports/devel/concurrentqueue/concurrentqueue-1.0.3-15-g0753496/benchmarks/tbb/internal/
H A D_aggregator_impl.h53 aggregator_generic() : handler_busy(false) { pending_operations = NULL; } in aggregator_generic()
81 op->next = res = pending_operations; // NOT A RACE
82 } while (pending_operations.compare_and_swap(op, res) != res);
87 call_itt_notify(acquired, &pending_operations);
104 atomic<operation_type *> pending_operations;
131 call_itt_notify(releasing, &pending_operations); in start_handle_operations()
133 op_list = pending_operations.fetch_and_store(NULL); in start_handle_operations()
/dports/devel/tbb/oneTBB-2020.3/include/tbb/internal/
H A D_aggregator_impl.h51 aggregator_generic() : handler_busy(false) { pending_operations = NULL; } in aggregator_generic()
81 op->next = res = pending_operations; // NOT A RACE
82 } while (pending_operations.compare_and_swap(op, res) != res);
87 call_itt_notify(acquired, &pending_operations);
104 atomic<operation_type *> pending_operations;
131 call_itt_notify(releasing, &pending_operations); in start_handle_operations()
133 op_list = pending_operations.fetch_and_store(NULL); in start_handle_operations()
/dports/devel/taskflow/taskflow-3.2.0/3rd-party/tbb/include/tbb/internal/
H A D_aggregator_impl.h51 aggregator_generic() : handler_busy(false) { pending_operations = NULL; } in aggregator_generic()
81 op->next = res = pending_operations; // NOT A RACE
82 } while (pending_operations.compare_and_swap(op, res) != res);
87 call_itt_notify(acquired, &pending_operations);
104 atomic<operation_type *> pending_operations;
131 call_itt_notify(releasing, &pending_operations); in start_handle_operations()
133 op_list = pending_operations.fetch_and_store(NULL); in start_handle_operations()
/dports/net/mpich2/mpich2-1.5/src/pm/smpd/sock/iocp/
H A Dsmpd_util_sock.c51 int pending_operations; member
388 p->pending_operations = 0; in init_state_struct()
1390 connect_state->pending_operations++; in SMPDU_Sock_post_connect()
1475 if (sock->pending_operations != 0){ in SMPDU_Sock_post_close()
1514 sock->pending_operations = 0; in SMPDU_Sock_post_close()
1534 sock->pending_operations = 0; in SMPDU_Sock_post_close()
1544 sock->pending_operations = 0; in SMPDU_Sock_post_close()
1672 sock->pending_operations++; in SMPDU_Sock_post_readv()
1759 sock->pending_operations++; in SMPDU_Sock_post_writev()
1824 sock->pending_operations--; in SMPDU_Sock_wait()
[all …]
/dports/math/stanmath/math-4.2.0/lib/tbb_2020.3/include/tbb/
H A Daggregator.h149 aggregator_operation *pending_operations; in start_handle_operations() local
169 pending_operations = mailbox.fetch_and_store(NULL); in start_handle_operations()
172 handle_operations(pending_operations); in start_handle_operations()
/dports/math/deal.ii/dealii-803d21ff957e349b3799cd3ef2c840bc78734305/bundled/tbb-2018_U2/include/tbb/
H A Daggregator.h150 aggregator_operation *pending_operations; in start_handle_operations() local
170 pending_operations = mailbox.fetch_and_store(NULL); in start_handle_operations()
173 handle_operations(pending_operations); in start_handle_operations()
/dports/devel/concurrentqueue/concurrentqueue-1.0.3-15-g0753496/benchmarks/tbb/
H A Daggregator.h150 aggregator_operation *pending_operations; in start_handle_operations() local
170 pending_operations = mailbox.fetch_and_store(NULL); in start_handle_operations()
173 handle_operations(pending_operations); in start_handle_operations()
/dports/devel/tbb/oneTBB-2020.3/include/tbb/
H A Daggregator.h149 aggregator_operation *pending_operations; in start_handle_operations() local
169 pending_operations = mailbox.fetch_and_store(NULL); in start_handle_operations()
172 handle_operations(pending_operations); in start_handle_operations()
/dports/devel/taskflow/taskflow-3.2.0/3rd-party/tbb/include/tbb/
H A Daggregator.h149 aggregator_operation *pending_operations; in start_handle_operations() local
169 pending_operations = mailbox.fetch_and_store(NULL); in start_handle_operations()
172 handle_operations(pending_operations); in start_handle_operations()
/dports/net/mpich2/mpich2-1.5/src/mpid/common/sock/iocp/
H A Dsock.c48 int pending_operations; member
334 p->pending_operations = 0; in init_state_struct()
1451 sock->pending_operations = 0; in MPIDU_Sock_post_close()
1472 sock->pending_operations = 0; in MPIDU_Sock_post_close()
1643 sock->pending_operations++; in MPIDU_Sock_post_readv()
1755 sock->pending_operations++; in MPIDU_Sock_post_writev()
1862 sock->pending_operations--; in MPIDU_Sock_wait()
1915 sock->pending_operations--; in MPIDU_Sock_wait()
2056 sock->pending_operations--; in MPIDU_Sock_wait()
2198 sock->pending_operations--; in MPIDU_Sock_wait()
[all …]
/dports/www/chromium-legacy/chromium-88.0.4324.182/chrome/browser/chromeos/arc/fileapi/
H A Darc_documents_provider_file_stream_reader.cc122 std::vector<base::OnceClosure> pending_operations; in OnResolveToContentUrl() local
123 pending_operations.swap(pending_operations_); in OnResolveToContentUrl()
124 for (base::OnceClosure& callback : pending_operations) { in OnResolveToContentUrl()
H A Darc_documents_provider_file_stream_writer.cc141 std::vector<base::OnceClosure> pending_operations; in OnResolveToContentUrl() local
142 pending_operations.swap(pending_operations_); in OnResolveToContentUrl()
143 for (base::OnceClosure& callback : pending_operations) in OnResolveToContentUrl()
/dports/net/openmpi3/openmpi-3.1.6/ompi/mca/osc/pt2pt/
H A Dosc_pt2pt_component.c156 int pending_count = opal_list_get_size (&mca_osc_pt2pt_component.pending_operations); in component_progress()
176 …OPAL_LIST_FOREACH_SAFE(pending, next, &mca_osc_pt2pt_component.pending_operations, ompi_osc_pt2pt_… in component_progress()
195 … opal_list_remove_item (&mca_osc_pt2pt_component.pending_operations, &pending->super); in component_progress()
216 OBJ_CONSTRUCT(&mca_osc_pt2pt_component.pending_operations, opal_list_t); in component_init()
278 OBJ_DESTRUCT(&mca_osc_pt2pt_component.pending_operations); in component_finalize()
H A Dosc_pt2pt.h82 opal_list_t pending_operations; member
700 … opal_list_append (&mca_osc_pt2pt_component.pending_operations, &pending->super)); in osc_pt2pt_add_pending()
/dports/net/openmpi/openmpi-4.1.1/ompi/mca/osc/pt2pt/
H A Dosc_pt2pt_component.c157 int pending_count = opal_list_get_size (&mca_osc_pt2pt_component.pending_operations); in component_progress()
178 …OPAL_LIST_FOREACH_SAFE(pending, next, &mca_osc_pt2pt_component.pending_operations, ompi_osc_pt2pt_… in component_progress()
197 … opal_list_remove_item (&mca_osc_pt2pt_component.pending_operations, &pending->super); in component_progress()
219 OBJ_CONSTRUCT(&mca_osc_pt2pt_component.pending_operations, opal_list_t); in component_init()
281 OBJ_DESTRUCT(&mca_osc_pt2pt_component.pending_operations); in component_finalize()
H A Dosc_pt2pt.h82 opal_list_t pending_operations; member
696 … opal_list_append (&mca_osc_pt2pt_component.pending_operations, &pending->super)); in osc_pt2pt_add_pending()
/dports/net-im/telepathy-salut/telepathy-salut-0.8.1/lib/ext/wocky/wocky/
H A Dwocky-roster.c251 GHashTable *pending_operations; member
543 priv->pending_operations = g_hash_table_new_full (g_str_hash, g_str_equal, in wocky_roster_constructed()
596 g_hash_table_unref (priv->pending_operations); in wocky_roster_finalize()
955 g_hash_table_remove (priv->pending_operations, pending->jid); in flying_operation_completed()
965 g_hash_table_remove (priv->pending_operations, pending->jid); in flying_operation_completed()
1018 return g_hash_table_lookup (priv->pending_operations, jid); in get_pending_operation()
1035 g_hash_table_insert (priv->pending_operations, g_strdup (jid), pending); in add_pending_operation()
/dports/net-im/telepathy-gabble/telepathy-gabble-0.18.4/lib/ext/wocky/wocky/
H A Dwocky-roster.c255 GHashTable *pending_operations; member
547 priv->pending_operations = g_hash_table_new_full (g_str_hash, g_str_equal, in wocky_roster_constructed()
600 g_hash_table_unref (priv->pending_operations); in wocky_roster_finalize()
959 g_hash_table_remove (priv->pending_operations, pending->jid); in flying_operation_completed()
969 g_hash_table_remove (priv->pending_operations, pending->jid); in flying_operation_completed()
1022 return g_hash_table_lookup (priv->pending_operations, jid); in get_pending_operation()
1039 g_hash_table_insert (priv->pending_operations, g_strdup (jid), pending); in add_pending_operation()
/dports/devel/py-jedi/jedi-0.18.0/jedi/third_party/typeshed/third_party/2and3/pynamodb/
H A Dmodels.pyi97 pending_operations: List[Dict[Text, Any]]
106 pending_operations: Any
/dports/mail/thunderbird/thunderbird-91.8.0/comm/ldap/xpcom/src/
H A DnsLDAPConnection.cpp224 nsTArray<nsLDAPOperation*> pending_operations; in Observe() local
229 pending_operations.AppendElement(op); in Observe()
232 for (auto op : pending_operations) { in Observe()
/dports/databases/evolution-data-server/evolution-data-server-3.42.1/src/addressbook/libedata-book/
H A De-book-backend.c63 GQueue pending_operations; member
179 g_queue_push_tail (&backend->priv->pending_operations, node); in book_backend_push_operation()
244 node = g_queue_pop_head (&backend->priv->pending_operations); in book_backend_dispatch_next_operation()
523 while (!g_queue_is_empty (&priv->pending_operations)) in book_backend_dispose()
524 dispatch_node_free (g_queue_pop_head (&priv->pending_operations)); in book_backend_dispose()
546 g_warn_if_fail (g_queue_is_empty (&priv->pending_operations)); in book_backend_finalize()
3346 g_queue_push_tail (&book_backend->priv->pending_operations, node); in e_book_backend_schedule_custom_operation()
/dports/databases/evolution-data-server/evolution-data-server-3.42.1/src/calendar/libedata-cal/
H A De-cal-backend.c68 GQueue pending_operations; member
427 g_queue_push_tail (&backend->priv->pending_operations, node); in cal_backend_push_operation()
492 node = g_queue_pop_head (&backend->priv->pending_operations); in cal_backend_dispatch_next_operation()
873 while (!g_queue_is_empty (&priv->pending_operations)) in cal_backend_dispose()
874 dispatch_node_free (g_queue_pop_head (&priv->pending_operations)); in cal_backend_dispose()
904 g_warn_if_fail (g_queue_is_empty (&priv->pending_operations)); in cal_backend_finalize()
4920 g_queue_push_tail (&cal_backend->priv->pending_operations, node); in e_cal_backend_schedule_custom_operation()

12