#include <stdbool.h>
#include <glib.h>
#include "writer.h"
-#include <assert.h>
+#include <babeltrace/assert-internal.h>
static
gboolean empty_trace_map(gpointer key, gpointer value, gpointer user_data)
switch (bt_notification_get_type(notification)) {
case BT_NOTIFICATION_TYPE_PACKET_BEGIN:
{
- struct bt_ctf_packet *packet =
+ struct bt_packet *packet =
bt_notification_packet_begin_get_packet(notification);
if (!packet) {
}
case BT_NOTIFICATION_TYPE_PACKET_END:
{
- struct bt_ctf_packet *packet =
+ struct bt_packet *packet =
bt_notification_packet_end_get_packet(notification);
if (!packet) {
}
case BT_NOTIFICATION_TYPE_EVENT:
{
- struct bt_ctf_event *event = bt_notification_event_get_event(
+ struct bt_event *event = bt_notification_event_get_event(
notification);
if (!event) {
}
case BT_NOTIFICATION_TYPE_STREAM_BEGIN:
{
- struct bt_ctf_stream *stream =
+ struct bt_stream *stream =
bt_notification_stream_begin_get_stream(notification);
if (!stream) {
}
case BT_NOTIFICATION_TYPE_STREAM_END:
{
- struct bt_ctf_stream *stream =
+ struct bt_stream *stream =
bt_notification_stream_end_get_stream(notification);
if (!stream) {
break;
}
default:
- puts("Unhandled notification type");
+ break;
}
end:
return ret;
struct bt_private_connection *connection;
struct writer_component *writer;
enum bt_connection_status conn_status;
- static const enum bt_notification_type notif_types[] = {
- BT_NOTIFICATION_TYPE_EVENT,
- BT_NOTIFICATION_TYPE_PACKET_BEGIN,
- BT_NOTIFICATION_TYPE_PACKET_END,
- BT_NOTIFICATION_TYPE_STREAM_BEGIN,
- BT_NOTIFICATION_TYPE_STREAM_END,
- BT_NOTIFICATION_TYPE_SENTINEL,
- };
writer = bt_private_component_get_user_data(component);
- assert(writer);
- assert(!writer->input_iterator);
+ BT_ASSERT(writer);
+ BT_ASSERT(!writer->input_iterator);
connection = bt_private_port_get_private_connection(self_port);
- assert(connection);
+ BT_ASSERT(connection);
conn_status = bt_private_connection_create_notification_iterator(
- connection, notif_types, &writer->input_iterator);
+ connection, &writer->input_iterator);
if (conn_status != BT_CONNECTION_STATUS_OK) {
writer->error = true;
}
}
it = writer_component->input_iterator;
- assert(it);
+ BT_ASSERT(it);
it_ret = bt_notification_iterator_next(it);
switch (it_ret) {
}
notification = bt_notification_iterator_get_notification(it);
- assert(notification);
+ BT_ASSERT(notification);
ret = handle_notification(writer_component, notification);
end:
bt_put(notification);