Home
last modified time | relevance | path

Searched refs:g_atomic_int_get (Results 1 – 25 of 127) sorted by relevance

123456

/third_party/glib/gio/tests/
Dtask.c1036 while (!g_atomic_int_get (&thread_ran)) in test_run_in_thread()
1041 g_assert_false (g_atomic_int_get (&weak_notify_ran)); in test_run_in_thread()
1053 while (!g_atomic_int_get (&weak_notify_ran)) in test_run_in_thread()
1105 g_assert_true (g_atomic_int_get (&thread_ran)); in test_run_in_thread_sync()
1389 while (g_atomic_int_get (&overflow_completed) != NUM_OVERFLOW_TASKS) in test_run_in_thread_overflow()
1512 while (g_atomic_int_get (&thread_state) == THREAD_STARTING) in test_return_on_cancel()
1516 g_assert_cmpint (g_atomic_int_get (&thread_state), ==, THREAD_RUNNING); in test_return_on_cancel()
1523 g_assert_cmpint (g_atomic_int_get (&thread_state), ==, THREAD_COMPLETED); in test_return_on_cancel()
1545 while (g_atomic_int_get (&thread_state) == THREAD_STARTING) in test_return_on_cancel()
1549 g_assert_cmpint (g_atomic_int_get (&thread_state), ==, THREAD_RUNNING); in test_return_on_cancel()
[all …]
Dcontexts.c264 g_assert (g_atomic_int_get (&is_running)); in test_identity_thread()
273 g_assert (g_atomic_int_get (&is_running)); in test_identity_thread()
277 g_assert (g_atomic_int_get (&is_running)); in test_identity_thread()
287 g_assert (g_atomic_int_get (&is_running)); in test_identity_thread()
310 g_assert (!g_atomic_int_get (&is_running)); in test_context_specific_identity()
325 g_atomic_int_set (observed_value, g_atomic_int_get (&current_value)); in changed_emitted()
339 g_assert (g_atomic_int_get (&is_running)); in test_emit_thread()
344 g_atomic_int_set (observed_value, g_atomic_int_get (&current_value)); in test_emit_thread()
346 while (g_atomic_int_get (&current_value) != -1) in test_emit_thread()
383 while (g_atomic_int_get (&observed_values[i]) != n) in test_context_specific_emit()
Dgdbus-overflow.c158 g_assert_cmpint (g_atomic_int_get (&n_messages_sent), <, OVERFLOW_NUM_SIGNALS); in test_overflow()
181 …while (g_atomic_int_get (&n_messages_received) < OVERFLOW_NUM_SIGNALS && g_timer_elapsed (timer, N… in test_overflow()
184 g_assert_cmpint (g_atomic_int_get (&n_messages_sent), ==, OVERFLOW_NUM_SIGNALS); in test_overflow()
185 g_assert_cmpint (g_atomic_int_get (&n_messages_received), ==, OVERFLOW_NUM_SIGNALS); in test_overflow()
Dgdbus-connection-flush.c98 started = g_atomic_int_get (&self->started); in my_output_stream_flush()
99 finished = g_atomic_int_get (&self->finished); in my_output_stream_flush()
105 finished = g_atomic_int_get (&self->finished); in my_output_stream_flush()
119 return g_atomic_int_get (&self->started); in my_output_stream_get_bytes_started()
128 return g_atomic_int_get (&self->finished); in my_output_stream_get_bytes_finished()
137 return g_atomic_int_get (&self->flushed); in my_output_stream_get_bytes_flushed()
Dgdbus-connection.c253 if (g_atomic_int_get (&on_signal_registration_freed_called) && in test_connection_life_cycle()
254 g_atomic_int_get (&on_filter_freed_called) && in test_connection_life_cycle()
255 g_atomic_int_get (&on_register_object_freed_called)) in test_connection_life_cycle()
257 if (g_atomic_int_get (&quit_mainloop_fired)) in test_connection_life_cycle()
264 g_assert_true (g_atomic_int_get (&on_signal_registration_freed_called)); in test_connection_life_cycle()
265 g_assert_true (g_atomic_int_get (&on_filter_freed_called)); in test_connection_life_cycle()
266 g_assert_true (g_atomic_int_get (&on_register_object_freed_called)); in test_connection_life_cycle()
267 g_assert_false (g_atomic_int_get (&quit_mainloop_fired)); in test_connection_life_cycle()
1034 g_assert_cmpint (g_atomic_int_get (&data.num_outgoing), ==, 4); in test_connection_filter()
/third_party/gstreamer/gstreamer/gst/
Dgstatomicqueue.c233 head = g_atomic_int_get (&head_mem->head); in gst_atomic_queue_peek()
234 tail = g_atomic_int_get (&head_mem->tail_read); in gst_atomic_queue_peek()
289 head = g_atomic_int_get (&head_mem->head); in gst_atomic_queue_pop()
290 tail = g_atomic_int_get (&head_mem->tail_read); in gst_atomic_queue_pop()
350 head = g_atomic_int_get (&tail_mem->head); in gst_atomic_queue_push()
351 tail = g_atomic_int_get (&tail_mem->tail_write); in gst_atomic_queue_push()
412 head = g_atomic_int_get (&head_mem->head); in gst_atomic_queue_length()
415 tail = g_atomic_int_get (&tail_mem->tail_read); in gst_atomic_queue_length()
Dgstminiobject.c231 newstate = state = g_atomic_int_get (&object->lockstate); in gst_mini_object_lock()
291 newstate = state = g_atomic_int_get (&object->lockstate); in gst_mini_object_unlock()
323 gint priv_state = g_atomic_int_get ((gint *) & object->priv_uint); in lock_priv_pointer()
332 priv_state = g_atomic_int_get ((gint *) & object->priv_uint); in lock_priv_pointer()
369 result = !IS_SHARED (g_atomic_int_get (&mini_object->lockstate)); in gst_mini_object_is_writable()
492 gint priv_state = g_atomic_int_get ((gint *) & object->priv_uint); in find_notify()
514 gint priv_state = g_atomic_int_get ((gint *) & object->priv_uint); in remove_notify()
605 gint priv_state = g_atomic_int_get ((gint *) & obj->priv_uint); in free_priv_data()
677 g_return_if_fail ((g_atomic_int_get (&mini_object->lockstate) & LOCK_MASK) in gst_mini_object_unref()
/third_party/glib/glib/
Dgrefcount.c235 g_return_if_fail (g_atomic_int_get (arc) > 0);
237 if (g_atomic_int_get (arc) == G_MAXINT)
260 g_return_val_if_fail (g_atomic_int_get (arc) > 0, FALSE); in gboolean()
284 return g_atomic_int_get (arc) == val; in gboolean()
Dgthreadpool.c164 local_max_unused_threads = (guint) g_atomic_int_get (&max_unused_threads); in g_thread_pool_wait_for_new_pool()
165 local_max_idle_time = g_atomic_int_get (&max_idle_time); in g_thread_pool_wait_for_new_pool()
166 last_wakeup_thread_serial = g_atomic_int_get (&wakeup_thread_serial); in g_thread_pool_wait_for_new_pool()
172 if ((guint) g_atomic_int_get (&unused_threads) >= local_max_unused_threads) in g_thread_pool_wait_for_new_pool()
195 local_wakeup_thread_serial = g_atomic_int_get (&wakeup_thread_serial); in g_thread_pool_wait_for_new_pool()
228 local_max_unused_threads = (guint) g_atomic_int_get (&max_unused_threads); in g_thread_pool_wait_for_new_pool()
229 local_max_idle_time = g_atomic_int_get (&max_idle_time); in g_thread_pool_wait_for_new_pool()
981 max_threads -= g_atomic_int_get (&unused_threads); in g_thread_pool_set_max_unused_threads()
1011 return g_atomic_int_get (&max_unused_threads); in g_thread_pool_get_max_unused_threads()
1024 return (guint) g_atomic_int_get (&unused_threads); in g_thread_pool_get_num_unused_threads()
[all …]
Dgmain.c529 g_return_val_if_fail (g_atomic_int_get (&context->ref_count) > 0, NULL); in g_main_context_ref()
561 g_return_if_fail (g_atomic_int_get (&context->ref_count) > 0); in g_main_context_unref()
1008 g_return_if_fail (g_atomic_int_get (&source->ref_count) > 0); in g_source_set_dispose_function()
1282 g_return_val_if_fail (g_atomic_int_get (&source->ref_count) > 0, 0); in g_source_attach()
1380 g_return_if_fail (g_atomic_int_get (&source->ref_count) > 0); in g_source_destroy()
1412 g_return_val_if_fail (g_atomic_int_get (&source->ref_count) > 0, 0); in g_source_get_id()
1443 g_return_val_if_fail (g_atomic_int_get (&source->ref_count) > 0, NULL); in g_source_get_context()
1475 g_return_if_fail (g_atomic_int_get (&source->ref_count) > 0); in g_source_add_poll()
1512 g_return_if_fail (g_atomic_int_get (&source->ref_count) > 0); in g_source_remove_poll()
1563 g_return_if_fail (g_atomic_int_get (&source->ref_count) > 0); in g_source_add_child_source()
[all …]
Dgbitlock.c132 if G_LIKELY (g_atomic_int_get (address) == value) in g_futex_wait()
227 v = (guint) g_atomic_int_get (address); in g_bit_lock()
338 if (g_atomic_int_get (&g_bit_lock_contended[class])) in g_bit_unlock()
536 if (g_atomic_int_get (&g_bit_lock_contended[class]))
Dgrefcount.h102 (void) (g_atomic_int_get (rc) == G_MAXINT ? 0 : g_atomic_int_inc ((rc))); \
116 (gboolean) (g_atomic_int_get (rc) == (val)); \
Dgatomic.h37 gint g_atomic_int_get (const volatile gint *atomic);
101 #define g_atomic_int_get(atomic) \ macro
289 #define g_atomic_int_get(atomic) \
418 #define g_atomic_int_get(atomic) \
419 (g_atomic_int_get ((gint *) (atomic)))
Dgatomic.c116 (g_atomic_int_get) (const volatile gint *atomic) in gint() argument
118 return g_atomic_int_get (atomic); in gint()
576 (g_atomic_int_get) (const volatile gint *atomic) in gint() argument
731 (g_atomic_int_get) (const volatile gint *atomic) in gint() argument
/third_party/glib/gobject/tests/
Dclosure-refcount.c186 for (i = 1; !g_atomic_int_get (&data->stopping); i++) in thread1_main()
205 for (i = 1; !g_atomic_int_get (&data->stopping); i++) in thread2_main()
296 !g_atomic_int_get (&test_data.seen_thread1) || in test_closure_refcount()
297 !g_atomic_int_get (&test_data.seen_thread2); in test_closure_refcount()
320 g_assert_true (g_atomic_int_get (&test_data.seen_thread1)); in test_closure_refcount()
321 g_assert_true (g_atomic_int_get (&test_data.seen_thread2)); in test_closure_refcount()
Dthreadtests.c133 while (g_atomic_int_get (&mtsafe_call_counter) < (3 + 3 + 3 * 3) * NUM_COUNTER_INCREMENTS)
136 g_printerr ("Initializers counted: %u\n", g_atomic_int_get (&mtsafe_call_counter));
140 g_printerr ("Total initializers: %u\n", g_atomic_int_get (&mtsafe_call_counter));
142 g_assert_cmpint (g_atomic_int_get (&mtsafe_call_counter), ==, unsafe_call_counter);
/third_party/gstreamer/gstreamer/plugins/elements/
Dgstvalve.c202 g_value_set_boolean (value, g_atomic_int_get (&valve->drop)); in gst_valve_get_property()
238 if (g_atomic_int_get (&valve->drop)) { in gst_valve_chain()
263 if (g_atomic_int_get (&valve->drop)) in gst_valve_chain()
272 if (!g_atomic_int_get (&valve->drop)) in gst_valve_event_needs_dropping()
313 if (g_atomic_int_get (&valve->drop)) { in gst_valve_sink_event()
329 if (GST_QUERY_IS_SERIALIZED (query) && g_atomic_int_get (&valve->drop)) in gst_valve_query()
/third_party/glib/glib/tests/
Datomic.c38 u2 = (guint) g_atomic_int_get (&u); in test_types()
61 s2 = g_atomic_int_get (&s); in test_types()
131 g_assert_cmpint (g_atomic_int_get (csp), ==, s); in test_types()
136 #undef g_atomic_int_get in test_types()
153 u2 = (guint) g_atomic_int_get ((gint*)&u); in test_types()
175 s2 = g_atomic_int_get (&s); in test_types()
250 g_assert_cmpint (g_atomic_int_get (csp), ==, s); in test_types()
Dcond.c195 g_printerr ("thread %d starting, check %d\n", value, g_atomic_int_get (&check)); in cond2_func()
202 g_printerr ("thread %d reaching barrier, check %d\n", value, g_atomic_int_get (&check)); in cond2_func()
206 g_assert_cmpint (g_atomic_int_get (&check), ==, 10); in cond2_func()
209 … g_printerr ("thread %d leaving barrier (%d), check %d\n", value, ret, g_atomic_int_get (&check)); in cond2_func()
232 g_assert_cmpint (g_atomic_int_get (&check), ==, 10); in test_cond2()
/third_party/glib/gio/
Dgcancellable.c274 if (g_atomic_int_get (&priv->cancelled)) in g_cancellable_reset()
297 return cancellable != NULL && g_atomic_int_get (&cancellable->priv->cancelled); in g_cancellable_is_cancelled()
413 if (g_atomic_int_get (&cancellable->priv->cancelled)) in g_cancellable_make_pollfd()
498 if (g_atomic_int_get (&priv->cancelled)) in g_cancellable_cancel()
570 if (g_atomic_int_get (&cancellable->priv->cancelled)) in g_cancellable_connect()
Dgdbusintrospection.c108 if (g_atomic_int_get (&info->ref_count) == -1) in g_dbus_node_info_ref()
128 if (g_atomic_int_get (&info->ref_count) == -1) in g_dbus_interface_info_ref()
148 if (g_atomic_int_get (&info->ref_count) == -1) in g_dbus_method_info_ref()
168 if (g_atomic_int_get (&info->ref_count) == -1) in g_dbus_signal_info_ref()
188 if (g_atomic_int_get (&info->ref_count) == -1) in g_dbus_property_info_ref()
208 if (g_atomic_int_get (&info->ref_count) == -1) in g_dbus_arg_info_ref()
228 if (g_atomic_int_get (&info->ref_count) == -1) in g_dbus_annotation_info_ref()
261 if (g_atomic_int_get (&info->ref_count) == -1) in g_dbus_annotation_info_unref()
285 if (g_atomic_int_get (&info->ref_count) == -1) in g_dbus_arg_info_unref()
309 if (g_atomic_int_get (&info->ref_count) == -1) in g_dbus_method_info_unref()
[all …]
/third_party/gstreamer/gstreamer/tests/check/gst/
Dgsttagsetter.c228 while (g_atomic_int_get (&spin_and_wait)) in test_threads_thread_func1()
255 while (g_atomic_int_get (&spin_and_wait)) in test_threads_thread_func2()
282 while (g_atomic_int_get (&spin_and_wait)) in test_threads_thread_func3()
313 while (g_atomic_int_get (&threads_running) < 3) in GST_START_TEST()
Dgsttocsetter.c280 while (g_atomic_int_get (&spin_and_wait)) in test_threads_thread_func1()
307 while (g_atomic_int_get (&spin_and_wait)) in test_threads_thread_func2()
332 while (g_atomic_int_get (&spin_and_wait)) in test_threads_thread_func3()
363 while (g_atomic_int_get (&threads_running) < 3) in GST_START_TEST()
/third_party/gstreamer/gstplugins_base/gst-libs/gst/audio/
Dgstaudioringbuffer.c975 if (G_UNLIKELY (!g_atomic_int_get (&buf->may_start))) in gst_audio_ring_buffer_start()
1250 segdone = g_atomic_int_get (&buf->segdone); in gst_audio_ring_buffer_samples_done()
1345 if (G_UNLIKELY (g_atomic_int_get (&buf->state) != in wait_segment()
1348 if (G_UNLIKELY (!g_atomic_int_get (&buf->may_start))) in wait_segment()
1352 segments = g_atomic_int_get (&buf->segdone); in wait_segment()
1357 if (G_LIKELY (g_atomic_int_get (&buf->segdone) != segments)) in wait_segment()
1366 if (G_UNLIKELY (g_atomic_int_get (&buf->state) != in wait_segment()
1378 if (G_UNLIKELY (g_atomic_int_get (&buf->state) != in wait_segment()
1576 segdone = g_atomic_int_get (&buf->segdone) - buf->segbase; in default_commit()
1789 segdone = g_atomic_int_get (&buf->segdone) - buf->segbase; in gst_audio_ring_buffer_read()
[all …]
/third_party/gstreamer/gstplugins_bad/ext/musepack/
Dgstmusepackdec.c182 samplerate = g_atomic_int_get (&dec->rate); in gst_musepackdec_handle_seek_event()
287 samplerate = g_atomic_int_get (&musepackdec->rate); in gst_musepackdec_src_query()
509 samplerate = g_atomic_int_get (&musepackdec->rate); in gst_musepackdec_loop()
516 samplerate = g_atomic_int_get (&musepackdec->rate); in gst_musepackdec_loop()
519 bitspersample = g_atomic_int_get (&musepackdec->bps); in gst_musepackdec_loop()

123456