| /dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/storage/ndb/memcache/src/schedulers/ |
| H A D | Trondheim.cc | 185 pending_ops(0), in WorkerConnection()
252 assert(pending_ops > 0); in close()
253 pending_ops--; in close()
256 thread, item->id, pending_ops); in close()
285 if(n_current_ops == 0 && pending_ops == 0) { in runNdbThread()
290 if(pending_ops) { in runNdbThread()
292 int min_complete = (pending_ops > 3 ? pending_ops / 2 : 1); in runNdbThread()
307 pending_ops++; // This will be decremented by close() in runNdbThread()
323 for(int n = 10; pending_ops && n; n--) { in runNdbThread()
324 ndb->sendPollNdb(10, pending_ops, 1); in runNdbThread()
|
| /dports/databases/percona57-server/percona-server-5.7.36-39/storage/ndb/memcache/src/schedulers/ |
| H A D | Trondheim.cc | 188 pending_ops(0), in WorkerConnection()
255 assert(pending_ops > 0); in close()
256 pending_ops--; in close()
259 thread, item->id, pending_ops); in close()
288 if(n_current_ops == 0 && pending_ops == 0) { in runNdbThread()
293 if(pending_ops) { in runNdbThread()
295 int min_complete = (pending_ops > 3 ? pending_ops / 2 : 1); in runNdbThread()
310 pending_ops++; // This will be decremented by close() in runNdbThread()
326 for(int n = 10; pending_ops && n; n--) { in runNdbThread()
327 ndb->sendPollNdb(10, pending_ops, 1); in runNdbThread()
|
| /dports/databases/percona57-client/percona-server-5.7.36-39/storage/ndb/memcache/src/schedulers/ |
| H A D | Trondheim.cc | 188 pending_ops(0), in WorkerConnection()
255 assert(pending_ops > 0); in close()
256 pending_ops--; in close()
259 thread, item->id, pending_ops); in close()
288 if(n_current_ops == 0 && pending_ops == 0) { in runNdbThread()
293 if(pending_ops) { in runNdbThread()
295 int min_complete = (pending_ops > 3 ? pending_ops / 2 : 1); in runNdbThread()
310 pending_ops++; // This will be decremented by close() in runNdbThread()
326 for(int n = 10; pending_ops && n; n--) { in runNdbThread()
327 ndb->sendPollNdb(10, pending_ops, 1); in runNdbThread()
|
| /dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/storage/ndb/memcache/src/schedulers/ |
| H A D | Trondheim.cc | 188 pending_ops(0), in WorkerConnection()
255 assert(pending_ops > 0); in close()
256 pending_ops--; in close()
259 thread, item->id, pending_ops); in close()
288 if(n_current_ops == 0 && pending_ops == 0) { in runNdbThread()
293 if(pending_ops) { in runNdbThread()
295 int min_complete = (pending_ops > 3 ? pending_ops / 2 : 1); in runNdbThread()
310 pending_ops++; // This will be decremented by close() in runNdbThread()
326 for(int n = 10; pending_ops && n; n--) { in runNdbThread()
327 ndb->sendPollNdb(10, pending_ops, 1); in runNdbThread()
|
| /dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/storage/ndb/memcache/src/schedulers/ |
| H A D | Trondheim.cc | 188 pending_ops(0), in WorkerConnection()
255 assert(pending_ops > 0); in close()
256 pending_ops--; in close()
259 thread, item->id, pending_ops); in close()
288 if(n_current_ops == 0 && pending_ops == 0) { in runNdbThread()
293 if(pending_ops) { in runNdbThread()
295 int min_complete = (pending_ops > 3 ? pending_ops / 2 : 1); in runNdbThread()
310 pending_ops++; // This will be decremented by close() in runNdbThread()
326 for(int n = 10; pending_ops && n; n--) { in runNdbThread()
327 ndb->sendPollNdb(10, pending_ops, 1); in runNdbThread()
|
| /dports/databases/xtrabackup/percona-xtrabackup-2.4.21/storage/ndb/memcache/src/schedulers/ |
| H A D | Trondheim.cc | 188 pending_ops(0), in WorkerConnection()
255 assert(pending_ops > 0); in close()
256 pending_ops--; in close()
259 thread, item->id, pending_ops); in close()
288 if(n_current_ops == 0 && pending_ops == 0) { in runNdbThread()
293 if(pending_ops) { in runNdbThread()
295 int min_complete = (pending_ops > 3 ? pending_ops / 2 : 1); in runNdbThread()
310 pending_ops++; // This will be decremented by close() in runNdbThread()
326 for(int n = 10; pending_ops && n; n--) { in runNdbThread()
327 ndb->sendPollNdb(10, pending_ops, 1); in runNdbThread()
|
| /dports/multimedia/libv4l/linux-5.13-rc2/fs/fscache/ |
| H A D | operation.c | 135 if (!list_empty(&object->pending_ops)) { in fscache_report_unexpected_submission()
194 list_add_tail(&op->pend_link, &object->pending_ops); in fscache_submit_exclusive_op()
196 } else if (!list_empty(&object->pending_ops)) { in fscache_submit_exclusive_op()
198 list_add_tail(&op->pend_link, &object->pending_ops); in fscache_submit_exclusive_op()
214 list_add_tail(&op->pend_link, &object->pending_ops); in fscache_submit_exclusive_op()
282 } else if (!list_empty(&object->pending_ops)) { in fscache_submit_op()
296 list_add_tail(&op->pend_link, &object->pending_ops); in fscache_submit_op()
335 while (!list_empty(&object->pending_ops) && !stop) { in fscache_start_operations()
336 op = list_entry(object->pending_ops.next, in fscache_start_operations()
427 while (!list_empty(&object->pending_ops)) { in fscache_cancel_all_ops()
[all …]
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/fs/fscache/ |
| H A D | operation.c | 135 if (!list_empty(&object->pending_ops)) { in fscache_report_unexpected_submission()
194 list_add_tail(&op->pend_link, &object->pending_ops); in fscache_submit_exclusive_op()
196 } else if (!list_empty(&object->pending_ops)) { in fscache_submit_exclusive_op()
198 list_add_tail(&op->pend_link, &object->pending_ops); in fscache_submit_exclusive_op()
214 list_add_tail(&op->pend_link, &object->pending_ops); in fscache_submit_exclusive_op()
282 } else if (!list_empty(&object->pending_ops)) { in fscache_submit_op()
296 list_add_tail(&op->pend_link, &object->pending_ops); in fscache_submit_op()
335 while (!list_empty(&object->pending_ops) && !stop) { in fscache_start_operations()
336 op = list_entry(object->pending_ops.next, in fscache_start_operations()
427 while (!list_empty(&object->pending_ops)) { in fscache_cancel_all_ops()
[all …]
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/fs/fscache/ |
| H A D | operation.c | 135 if (!list_empty(&object->pending_ops)) { in fscache_report_unexpected_submission()
194 list_add_tail(&op->pend_link, &object->pending_ops); in fscache_submit_exclusive_op()
196 } else if (!list_empty(&object->pending_ops)) { in fscache_submit_exclusive_op()
198 list_add_tail(&op->pend_link, &object->pending_ops); in fscache_submit_exclusive_op()
214 list_add_tail(&op->pend_link, &object->pending_ops); in fscache_submit_exclusive_op()
282 } else if (!list_empty(&object->pending_ops)) { in fscache_submit_op()
296 list_add_tail(&op->pend_link, &object->pending_ops); in fscache_submit_op()
335 while (!list_empty(&object->pending_ops) && !stop) { in fscache_start_operations()
336 op = list_entry(object->pending_ops.next, in fscache_start_operations()
427 while (!list_empty(&object->pending_ops)) { in fscache_cancel_all_ops()
[all …]
|
| /dports/x11-fm/nautilus/nautilus-41.1/src/ |
| H A D | nautilus-bookmark-list.c | 46 GQueue *pending_ops; member
174 g_queue_free (self->pending_ops); in do_finalize()
218 bookmarks->pending_ops = g_queue_new (); in nautilus_bookmark_list_init()
322 g_queue_pop_tail (self->pending_ops); in op_processed_cb()
324 if (!g_queue_is_empty (self->pending_ops)) in op_processed_cb()
562 op = GPOINTER_TO_INT (g_queue_peek_tail (bookmarks->pending_ops)); in process_next_op()
583 g_queue_push_head (bookmarks->pending_ops, GINT_TO_POINTER (LOAD_JOB)); in nautilus_bookmark_list_load_file()
585 if (g_queue_get_length (bookmarks->pending_ops) == 1) in nautilus_bookmark_list_load_file()
602 g_queue_push_head (bookmarks->pending_ops, GINT_TO_POINTER (SAVE_JOB)); in nautilus_bookmark_list_save_file()
604 if (g_queue_get_length (bookmarks->pending_ops) == 1) in nautilus_bookmark_list_save_file()
|
| /dports/audio/sweep/sweep-0.9.3/src/ |
| H A D | sweep_undo.c | 69 (gl = sample->pending_ops) != NULL) { in op_main()
80 sample->pending_ops); in op_main()
91 sample->pending_ops = g_list_remove_link (sample->pending_ops, gl); in op_main()
124 sample->pending_ops); in op_main()
204 if (sample->pending_ops == NULL) in update_edit_progress()
208 if (sample->pending_ops != NULL) { in update_edit_progress()
209 inst = (sw_op_instance *)sample->pending_ops->data; in update_edit_progress()
290 sample->pending_ops = g_list_append (sample->pending_ops, inst); in schedule_operation_do()
678 if (s->pending_ops) { in cancel_active_op()
679 GList * gltmp = s->pending_ops; in cancel_active_op()
[all …]
|
| /dports/x11/mate-panel/mate-panel-1.26.1/mate-panel/libmate-panel-applet-private/ |
| H A D | panel-applet-container.c | 49 GHashTable *pending_ops; member
99 container->priv->pending_ops = g_hash_table_new_full (g_direct_hash, in mate_panel_applet_container_init()
140 if (!container->priv->pending_ops) in mate_panel_applet_container_cancel_pending_operations()
143 keys = g_hash_table_get_keys (container->priv->pending_ops); in mate_panel_applet_container_cancel_pending_operations()
158 if (container->priv->pending_ops) { in mate_panel_applet_container_dispose()
160 g_hash_table_destroy (container->priv->pending_ops); in mate_panel_applet_container_dispose()
161 container->priv->pending_ops = NULL; in mate_panel_applet_container_dispose()
606 g_hash_table_remove (container->priv->pending_ops, task); in set_applet_property_cb()
650 g_hash_table_insert (container->priv->pending_ops, task, cancellable); in mate_panel_applet_container_child_set()
706 g_hash_table_remove (container->priv->pending_ops, task); in get_applet_property_cb()
[all …]
|
| /dports/x11-fm/caja/caja-1.26.0/src/ |
| H A D | caja-bookmark-list.c | 202 g_queue_free (CAJA_BOOKMARK_LIST (object)->pending_ops); in do_finalize()
270 bookmarks->pending_ops = g_queue_new (); in caja_bookmark_list_init()
700 op = GPOINTER_TO_INT (g_queue_pop_tail (self->pending_ops)); in op_processed_cb()
711 if (!g_queue_is_empty (self->pending_ops)) in op_processed_cb()
725 op = GPOINTER_TO_INT (g_queue_peek_tail (bookmarks->pending_ops)); in process_next_op()
746 g_queue_push_head (bookmarks->pending_ops, GINT_TO_POINTER (LOAD_JOB)); in caja_bookmark_list_load_file()
748 if (g_queue_get_length (bookmarks->pending_ops) == 1) in caja_bookmark_list_load_file()
765 g_queue_push_head (bookmarks->pending_ops, GINT_TO_POINTER (SAVE_JOB)); in caja_bookmark_list_save_file()
767 if (g_queue_get_length (bookmarks->pending_ops) == 1) in caja_bookmark_list_save_file()
|
| /dports/devel/opendht/opendht-1.10.1/src/ |
| H A D | dhtrunner.cpp | 263 pending_ops = decltype(pending_ops)(); in join()
491 decltype(pending_ops) ops {}; in loop_()
634 pending_ops.emplace([=](SecureDht&) { in cancelListen()
644 pending_ops.emplace([=](SecureDht& dht) { in cancelListen()
658 pending_ops.emplace([=](SecureDht&) { in cancelListen()
668 pending_ops.emplace([=](SecureDht& dht) { in cancelListen()
682 pending_ops.emplace([=](SecureDht& dht) { in put()
694 pending_ops.emplace([=](SecureDht& dht) { in put()
712 pending_ops.emplace([=](SecureDht& dht) { in cancelPut()
724 pending_ops.emplace([=](SecureDht& dht) { in putSigned()
[all …]
|
| /dports/devel/py-opendht/opendht-1.10.1/src/ |
| H A D | dhtrunner.cpp | 263 pending_ops = decltype(pending_ops)(); in join()
491 decltype(pending_ops) ops {}; in loop_()
634 pending_ops.emplace([=](SecureDht&) { in cancelListen()
644 pending_ops.emplace([=](SecureDht& dht) { in cancelListen()
658 pending_ops.emplace([=](SecureDht&) { in cancelListen()
668 pending_ops.emplace([=](SecureDht& dht) { in cancelListen()
682 pending_ops.emplace([=](SecureDht& dht) { in put()
694 pending_ops.emplace([=](SecureDht& dht) { in put()
712 pending_ops.emplace([=](SecureDht& dht) { in cancelPut()
724 pending_ops.emplace([=](SecureDht& dht) { in putSigned()
[all …]
|
| /dports/net/pacemaker2/pacemaker-Pacemaker-2.1.1/daemons/execd/ |
| H A D | execd_commands.c | 361 rsc->pending_ops = g_list_append(rsc->pending_ops, cmd); in stonith_recurring_op_helper()
497 rsc->pending_ops = g_list_append(rsc->pending_ops, cmd); in schedule_lrmd_cmd()
714 rsc->pending_ops = g_list_remove(rsc->pending_ops, cmd); in cmd_finalize()
719 rsc->pending_ops = g_list_remove(rsc->pending_ops, cmd); in cmd_finalize()
1201 if (rsc->pending_ops) { in stonith_connection_failed()
1436 if (rsc->pending_ops) { in lrmd_rsc_execute()
1437 GList *first = rsc->pending_ops; in lrmd_rsc_execute()
1446 rsc->pending_ops = g_list_remove_link(rsc->pending_ops, first); in lrmd_rsc_execute()
1490 gIter = rsc->pending_ops; in free_rsc()
1502 g_list_free(rsc->pending_ops); in free_rsc()
[all …]
|
| /dports/net/pacemaker1/pacemaker-Pacemaker-1.1.24/lrmd/ |
| H A D | lrmd.c | 251 rsc->pending_ops = g_list_append(rsc->pending_ops, cmd); in stonith_recurring_op_helper()
362 rsc->pending_ops = g_list_append(rsc->pending_ops, cmd); in schedule_lrmd_cmd()
612 rsc->pending_ops = g_list_remove(rsc->pending_ops, cmd); in cmd_finalize()
617 rsc->pending_ops = g_list_remove(rsc->pending_ops, cmd); in cmd_finalize()
1098 if (rsc->pending_ops) { in stonith_connection_failed()
1286 if (rsc->pending_ops) { in lrmd_rsc_execute()
1287 GList *first = rsc->pending_ops; in lrmd_rsc_execute()
1296 rsc->pending_ops = g_list_remove_link(rsc->pending_ops, first); in lrmd_rsc_execute()
1341 gIter = rsc->pending_ops; in free_rsc()
1353 g_list_free(rsc->pending_ops); in free_rsc()
[all …]
|
| /dports/net/openldap25-client/openldap-2.5.9/servers/slapd/back-asyncmeta/ |
| H A D | message_queue.c | 183 mc, mc->pending_ops, max_pending_ops ); in asyncmeta_add_message_queue()
186 if (mc->pending_ops >= max_pending_ops) { in asyncmeta_add_message_queue()
193 mc->pending_ops++; in asyncmeta_add_message_queue()
205 mc->pending_ops--; in asyncmeta_drop_bc()
|
| /dports/net/openldap25-server/openldap-2.5.9/servers/slapd/back-asyncmeta/ |
| H A D | message_queue.c | 183 mc, mc->pending_ops, max_pending_ops ); in asyncmeta_add_message_queue()
186 if (mc->pending_ops >= max_pending_ops) { in asyncmeta_add_message_queue()
193 mc->pending_ops++; in asyncmeta_add_message_queue()
205 mc->pending_ops--; in asyncmeta_drop_bc()
|
| /dports/net/openldap26-client/openldap-2.6.0/servers/slapd/back-asyncmeta/ |
| H A D | message_queue.c | 183 mc, mc->pending_ops, max_pending_ops ); in asyncmeta_add_message_queue()
186 if (mc->pending_ops >= max_pending_ops) { in asyncmeta_add_message_queue()
193 mc->pending_ops++; in asyncmeta_add_message_queue()
205 mc->pending_ops--; in asyncmeta_drop_bc()
|
| /dports/net/openldap26-server/openldap-2.6.0/servers/slapd/back-asyncmeta/ |
| H A D | message_queue.c | 183 mc, mc->pending_ops, max_pending_ops ); in asyncmeta_add_message_queue()
186 if (mc->pending_ops >= max_pending_ops) { in asyncmeta_add_message_queue()
193 mc->pending_ops++; in asyncmeta_add_message_queue()
205 mc->pending_ops--; in asyncmeta_drop_bc()
|
| /dports/lang/erlang-runtime23/otp-OTP-23.3.4.10/lib/common_test/src/ |
| H A D | test_server_io.erl | 53 pending_ops % Perform when process idle
198 pending_ops=[]}}.
259 handle_call(reset_state, From, #st{phase=stopping,pending_ops=Ops}=St) ->
265 {noreply,St#st{pending_ops=[{From,Op}|Ops]}};
299 pending_ops=[]}};
352 pending_ops=Ops}=St) ->
364 end, St#st{phase=idle,pending_ops=[]}, Ops),
|
| /dports/lang/erlang-runtime24/otp-OTP-24.1.7/lib/common_test/src/ |
| H A D | test_server_io.erl | 53 pending_ops % Perform when process idle
198 pending_ops=[]}}.
259 handle_call(reset_state, From, #st{phase=stopping,pending_ops=Ops}=St) ->
265 {noreply,St#st{pending_ops=[{From,Op}|Ops]}};
299 pending_ops=[]}};
352 pending_ops=Ops}=St) ->
364 end, St#st{phase=idle,pending_ops=[]}, Ops),
|
| /dports/lang/erlang-runtime22/otp-OTP-22.3.4.24/lib/common_test/src/ |
| H A D | test_server_io.erl | 53 pending_ops % Perform when process idle
198 pending_ops=[]}}.
259 handle_call(reset_state, From, #st{phase=stopping,pending_ops=Ops}=St) ->
265 {noreply,St#st{pending_ops=[{From,Op}|Ops]}};
299 pending_ops=[]}};
352 pending_ops=Ops}=St) ->
364 end, St#st{phase=idle,pending_ops=[]}, Ops),
|
| /dports/lang/erlang-wx/otp-OTP-24.1.7/lib/common_test/src/ |
| H A D | test_server_io.erl | 53 pending_ops % Perform when process idle
198 pending_ops=[]}}.
259 handle_call(reset_state, From, #st{phase=stopping,pending_ops=Ops}=St) ->
265 {noreply,St#st{pending_ops=[{From,Op}|Ops]}};
299 pending_ops=[]}};
352 pending_ops=Ops}=St) ->
364 end, St#st{phase=idle,pending_ops=[]}, Ops),
|