123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629 |
- G_BEGIN_DECLS
- GST_DEBUG_CATEGORY_EXTERN (check_debug);
- extern gboolean _gst_check_threads_running;
- extern gboolean _gst_check_raised_critical;
- extern gboolean _gst_check_raised_warning;
- extern gboolean _gst_check_expecting_log;
- extern GList * buffers;
- extern GMutex check_mutex;
- extern GCond check_cond;
- typedef struct
- {
- const char *name;
- int size;
- int abi_size;
- }
- GstCheckABIStruct;
- void gst_check_init (int *argc, char **argv[]);
- GstFlowReturn gst_check_chain_func (GstPad * pad, GstObject * parent, GstBuffer * buffer);
- void gst_check_message_error (GstMessage * message, GstMessageType type,
- GQuark domain, gint code);
- GstElement *gst_check_setup_element (const gchar * factory);
- void gst_check_teardown_element (GstElement * element);
- GstPad *gst_check_setup_src_pad (GstElement * element,
- GstStaticPadTemplate * tmpl);
- GstPad *gst_check_setup_src_pad_from_template (GstElement * element,
- GstPadTemplate * tmpl);
- GstPad * gst_check_setup_src_pad_by_name (GstElement * element,
- GstStaticPadTemplate * tmpl, const gchar *name);
- GstPad * gst_check_setup_src_pad_by_name_from_template (GstElement * element,
- GstPadTemplate * tmpl, const gchar *name);
- GstPad *gst_check_setup_sink_pad (GstElement * element,
- GstStaticPadTemplate * tmpl);
- GstPad *gst_check_setup_sink_pad_from_template (GstElement * element,
- GstPadTemplate * tmpl);
- GstPad * gst_check_setup_sink_pad_by_name (GstElement * element,
- GstStaticPadTemplate * tmpl, const gchar *name);
- GstPad * gst_check_setup_sink_pad_by_name_from_template (GstElement * element,
- GstPadTemplate * tmpl, const gchar *name);
- void gst_check_teardown_pad_by_name (GstElement * element, const gchar *name);
- void gst_check_teardown_src_pad (GstElement * element);
- void gst_check_drop_buffers (void);
- void gst_check_caps_equal (GstCaps * caps1, GstCaps * caps2);
- void gst_check_buffer_data (GstBuffer * buffer, gconstpointer data, gsize size);
- void gst_check_element_push_buffer_list (const gchar * element_name,
- GList * buffer_in, GstCaps * caps_in, GList * buffer_out,
- GstCaps * caps_out, GstFlowReturn last_flow_return);
- void gst_check_element_push_buffer (const gchar * element_name,
- GstBuffer * buffer_in, GstCaps * caps_in, GstBuffer * buffer_out,
- GstCaps *caps_out);
- void gst_check_teardown_sink_pad (GstElement * element);
- void gst_check_abi_list (GstCheckABIStruct list[], gboolean have_abi_sizes);
- gint gst_check_run_suite (Suite * suite, const gchar * name,
- const gchar * fname);
- void gst_check_setup_events (GstPad * srcpad, GstElement * element,
- GstCaps * caps, GstFormat format);
- void gst_check_setup_events_with_stream_id (GstPad * srcpad,
- GstElement * element, GstCaps * caps, GstFormat format,
- const gchar * stream_id);
- void gst_check_objects_destroyed_on_unref (gpointer object_to_unref, gpointer first_object, ...)
- G_GNUC_NULL_TERMINATED;
- void gst_check_object_destroyed_on_unref (gpointer object_to_unref);
- gst_check_message_error (msg, GST_MESSAGE_ERROR, \
- GST_
- G_STMT_START { \
- if (g_getenv (GST_CHECK_TEST_ENVIRONMENT_BEACON) == NULL) \
- fail ("Test environment not set up correctly! Expected environment " \
- "variable '%s' to be set.", GST_CHECK_TEST_ENVIRONMENT_BEACON); \
- } G_STMT_END
- static void __testname (int G_GNUC_UNUSED __i__) \
- {\
- GST_DEBUG ("test start"); \
- GST_DO_CHECK_TEST_ENVIRONMENT; \
- tcase_fn_start (""
- gst_task_cleanup_all (); \
- END_TEST
- G_STMT_START { \
- int first = a; \
- int second = b; \
- fail_unless(first == second, \
- "'"
- } G_STMT_END;
- G_STMT_START { \
- int first = a; \
- int second = b; \
- fail_unless(first == second, \
- "'"
- } G_STMT_END;
- G_STMT_START { \
- gint64 first = a; \
- gint64 second = b; \
- fail_unless(first == second, \
- "'"
- G_GINT64_FORMAT")", first, second); \
- } G_STMT_END;
- G_STMT_START { \
- gint64 first = a; \
- gint64 second = b; \
- fail_unless(first == second, \
- "'"
- } G_STMT_END;
- G_STMT_START { \
- guint64 first = a; \
- guint64 second = b; \
- fail_unless(first == second, \
- "'"
- G_GUINT64_FORMAT ")", first, second); \
- } G_STMT_END;
- G_STMT_START { \
- guint64 first = a; \
- guint64 second = b; \
- fail_unless(first == second, \
- "'"
- } G_STMT_END;
- G_STMT_START { \
- const gchar * first = a; \
- const gchar * second = b; \
- fail_unless(g_strcmp0 (first, second) == 0, \
- "'"
- } G_STMT_END;
- G_STMT_START { \
- double first = a; \
- double second = b; \
-
- \
- fail_unless(fabs (first - second) < 0.0000001, \
- "'"
- } G_STMT_END;
- G_STMT_START { \
- gpointer first = a; \
- gpointer second = b; \
- fail_unless(first == second, \
- "'"
- } G_STMT_END;
- extern GList *thread_list;
- extern GMutex mutex;
- extern GCond start_cond;
- extern GCond sync_cond;
- MAIN_INIT(); \
- MAIN_START_THREAD_FUNCTIONS(count, function, data); \
- MAIN_SYNCHRONIZE();
- G_STMT_START { \
- g_mutex_init (&mutex); \
- g_cond_init (&start_cond); \
- g_cond_init (&sync_cond); \
- _gst_check_threads_running = TRUE; \
- } G_STMT_END;
- G_STMT_START { \
- int i; \
- for (i = 0; i < count; ++i) { \
- MAIN_START_THREAD_FUNCTION (i, function, data); \
- } \
- } G_STMT_END;
- G_STMT_START { \
- GThread *thread = NULL; \
- GST_DEBUG ("MAIN: creating thread %d", i); \
- g_mutex_lock (&mutex); \
- thread = g_thread_try_new ("gst-check", \
- (GThreadFunc) function, data, NULL); \
- \
- GST_DEBUG ("MAIN: waiting for thread %d", i); \
- g_cond_wait (&start_cond, &mutex); \
- g_mutex_unlock (&mutex); \
- \
- thread_list = g_list_append (thread_list, thread); \
- } G_STMT_END;
- G_STMT_START { \
- GST_DEBUG ("MAIN: synchronizing"); \
- g_cond_broadcast (&sync_cond); \
- GST_DEBUG ("MAIN: synchronized"); \
- } G_STMT_END;
- G_STMT_START { \
- _gst_check_threads_running = FALSE; \
- \
- \
- GST_DEBUG ("MAIN: joining"); \
- g_list_foreach (thread_list, (GFunc) g_thread_join, NULL); \
- g_list_free (thread_list); \
- thread_list = NULL; \
- g_mutex_clear (&mutex); \
- g_cond_clear (&start_cond); \
- g_cond_clear (&sync_cond); \
- GST_DEBUG ("MAIN: joined"); \
- } G_STMT_END;
- THREAD_STARTED(); \
- THREAD_SYNCHRONIZE();
- G_STMT_START { \
- \
- GST_DEBUG ("THREAD %p: started", g_thread_self ()); \
- g_mutex_lock (&mutex); \
- g_cond_signal (&start_cond); \
- } G_STMT_END;
- G_STMT_START { \
- \
- GST_DEBUG ("THREAD %p: syncing", g_thread_self ()); \
- fail_if (g_mutex_trylock (&mutex), \
- "bug in unit test, mutex should be locked at this point");\
- g_cond_wait (&sync_cond, &mutex); \
- GST_DEBUG ("THREAD %p: synced", g_thread_self ()); \
- g_mutex_unlock (&mutex); \
- } G_STMT_END;
- G_STMT_START { \
- \
- g_usleep (1); \
- } G_STMT_END;
- G_STMT_START { \
- _gst_check_expecting_log = TRUE; \
- _gst_check_raised_critical = FALSE; \
- code; \
- if (!_gst_check_raised_critical) \
- _ck_assert_failed (__FILE__, __LINE__, \
- "Expected g_critical, got nothing", NULL); \
- _gst_check_expecting_log = FALSE; \
- } G_STMT_END
- G_STMT_START { \
- _gst_check_expecting_log = TRUE; \
- _gst_check_raised_warning = FALSE; \
- code; \
- if (!_gst_check_raised_warning) \
- _ck_assert_failed (__FILE__, __LINE__, \
- "Expected g_warning, got nothing", NULL); \
- _gst_check_expecting_log = FALSE; \
- } G_STMT_END
- G_STMT_START { \
- int rc; \
- rc = GST_OBJECT_REFCOUNT_VALUE (object); \
- fail_unless (rc == value, \
- "%s (%p) refcount is %d instead of %d", \
- name, object, rc, value); \
- } G_STMT_END
- G_STMT_START { \
- int rc = GST_OBJECT_REFCOUNT_VALUE (object); \
- int lo = lower; \
- int hi = upper; \
- \
- fail_unless (rc >= lo, \
- "%s (%p) refcount %d is smaller than %d", \
- name, object, rc, lo); \
- fail_unless (rc <= hi, \
- "%s (%p) refcount %d is bigger than %d", \
- name, object, rc, hi); \
- } G_STMT_END
- ASSERT_MINI_OBJECT_REFCOUNT(caps, name, value)
- ASSERT_MINI_OBJECT_REFCOUNT(buffer, name, value)
- G_STMT_START { \
- int rc; \
- rc = GST_MINI_OBJECT_REFCOUNT_VALUE (miniobj); \
- fail_unless (rc == value, \
- name " (%p) refcount is %d instead of %d", miniobj, rc, value); \
- } G_STMT_END
- fail_unless (gst_element_set_state (GST_ELEMENT(element), \
- state) == ret, \
- "could not change state to "
- int main (int argc, char **argv) \
- { \
- Suite *s; \
- gst_check_init (&argc, &argv); \
- s = name
- return gst_check_run_suite (s,
- }
- gboolean _gst_check_run_test_func (const gchar * func_name);
- static inline void
- __gst_tcase_add_test (TCase * tc, TFun tf, const char * fname, int signal,
- int allowed_exit_value, int start, int end)
- {
- if (_gst_check_run_test_func (fname)) {
- _tcase_add_test (tc, tf, fname, signal, allowed_exit_value, start, end);
- }
- }
- G_STMT_START { \
- const char *env = g_getenv ("GST_CHECKS"); \
- \
- if (env != NULL && g_pattern_match_simple (env, G_STRINGIFY (test_func))) { \
- tcase_add_test(chain,test_func); \
- } else { \
- g_printerr ("FIXME: skipping test %s because it's broken\n", G_STRINGIFY (test_func)); \
- } \
- } G_STMT_END
- tcase_skip_broken_test (chain, test_func)
- G_END_DECLS
|