while ((message = gst_atomic_queue_pop (bus->queue))) {
if (bus->priv->poll)
gst_poll_read_control (bus->priv->poll);
+
GST_DEBUG_OBJECT (bus, "got message %p, %s from %s, type mask is %u",
message, GST_MESSAGE_TYPE_NAME (message),
- GST_OBJECT_NAME (GST_MESSAGE_SRC (message)), (guint) types);
+ GST_MESSAGE_SRC (message) ?
+ GST_OBJECT_NAME (GST_MESSAGE_SRC (message)) : "NULL", (guint) types);
+
if ((GST_MESSAGE_TYPE (message) & types) != 0) {
/* exit the loop, we have a message */
goto beach;