#include <babeltrace/babeltrace.h>
#include <babeltrace/babeltrace-internal.h>
#include <plugins-common.h>
-#include <assert.h>
+#include <babeltrace/assert-internal.h>
#include "dummy.h"
void destroy_private_dummy_data(struct dummy *dummy)
{
struct dummy *dummy;
- assert(component);
+ BT_ASSERT(component);
dummy = bt_private_component_get_user_data(component);
- assert(dummy);
+ BT_ASSERT(dummy);
destroy_private_dummy_data(dummy);
}
enum bt_connection_status conn_status;
dummy = bt_private_component_get_user_data(component);
- assert(dummy);
+ BT_ASSERT(dummy);
connection = bt_private_port_get_private_connection(self_port);
- assert(connection);
+ BT_ASSERT(connection);
conn_status = bt_private_connection_create_notification_iterator(
- connection, NULL, &iterator);
+ connection, &iterator);
if (conn_status != BT_CONNECTION_STATUS_OK) {
dummy->error = true;
goto end;
enum bt_notification_iterator_status it_ret;
dummy = bt_private_component_get_user_data(component);
- assert(dummy);
+ BT_ASSERT(dummy);
if (unlikely(dummy->error)) {
ret = BT_COMPONENT_STATUS_ERROR;
}
/* Consume one notification */
- it_ret = bt_notification_iterator_next(dummy->notif_iter);
+ it_ret = bt_private_connection_notification_iterator_next(
+ dummy->notif_iter, ¬if);
switch (it_ret) {
case BT_NOTIFICATION_ITERATOR_STATUS_ERROR:
ret = BT_COMPONENT_STATUS_ERROR;