#define BABELTRACE_GRAPH_GRAPH_INTERNAL_H
/*
+ * Copyright 2017-2018 Philippe Proulx <pproulx@efficios.com>
* Copyright 2017 Jérémie Galarneau <jeremie.galarneau@efficios.com>
*
- * Author: Jérémie Galarneau <jeremie.galarneau@efficios.com>
- *
* Permission is hereby granted, free of charge, to any person obtaining a copy
* of this software and associated documentation files (the "Software"), to deal
* in the Software without restriction, including without limitation the rights
#include <babeltrace/graph/graph.h>
#include <babeltrace/graph/connection-internal.h>
-#include <babeltrace/graph/notification-const.h>
+#include <babeltrace/graph/message-const.h>
#include <babeltrace/babeltrace-internal.h>
#include <babeltrace/object-internal.h>
#include <babeltrace/object-pool-internal.h>
* BT_GRAPH_STATUS_CANNOT_CONSUME. The internal "no check"
* functions always work.
*
- * In bt_port_output_notification_iterator_create(), on success,
+ * In bt_port_output_message_iterator_create(), on success,
* this flag is cleared so that the iterator remains the only
* consumer for the graph's lifetime.
*/
bool can_consume;
+ /*
+ * True if the graph is configured, that is, components are
+ * added and connected.
+ */
+ bool is_configured;
+
struct {
GArray *source_output_port_added;
GArray *filter_output_port_added;
GArray *filter_input_port_added;
GArray *sink_input_port_added;
- GArray *source_output_port_removed;
- GArray *filter_output_port_removed;
- GArray *filter_input_port_removed;
- GArray *sink_input_port_removed;
GArray *source_filter_ports_connected;
GArray *source_sink_ports_connected;
+ GArray *filter_filter_ports_connected;
GArray *filter_sink_ports_connected;
- GArray *source_filter_ports_disconnected;
- GArray *source_sink_ports_disconnected;
- GArray *filter_sink_ports_disconnected;
} listeners;
- /* Pool of `struct bt_notification_event *` */
- struct bt_object_pool event_notif_pool;
+ /* Pool of `struct bt_message_event *` */
+ struct bt_object_pool event_msg_pool;
- /* Pool of `struct bt_notification_packet_begin *` */
- struct bt_object_pool packet_begin_notif_pool;
+ /* Pool of `struct bt_message_packet_beginning *` */
+ struct bt_object_pool packet_begin_msg_pool;
- /* Pool of `struct bt_notification_packet_end *` */
- struct bt_object_pool packet_end_notif_pool;
+ /* Pool of `struct bt_message_packet_end *` */
+ struct bt_object_pool packet_end_msg_pool;
/*
- * Array of `struct bt_notification *` (weak).
+ * Array of `struct bt_message *` (weak).
*
- * This is an array of all the notifications ever created from
+ * This is an array of all the messages ever created from
* this graph. Some of them can be in one of the pools above,
- * some of them can be at large. Because each notification has a
+ * some of them can be at large. Because each message has a
* weak pointer to the graph containing its pool, we need to
- * notify each notification that the graph is gone on graph
+ * notify each message that the graph is gone on graph
* destruction.
*
* TODO: When we support a maximum size for object pools,
- * add a way for a notification to remove itself from this
+ * add a way for a message to remove itself from this
* array (on destruction).
*/
- GPtrArray *notifications;
+ GPtrArray *messages;
};
static inline
# define bt_graph_set_can_consume(_graph, _can_consume)
#endif
+static inline
+void _bt_graph_set_is_configured(struct bt_graph *graph, bool is_configured)
+{
+ BT_ASSERT(graph);
+ graph->is_configured = is_configured;
+}
+
+#ifdef BT_DEV_MODE
+# define bt_graph_set_is_configured _bt_graph_set_is_configured
+#else
+# define bt_graph_set_is_configured(_graph, _is_configured)
+#endif
+
BT_HIDDEN
enum bt_graph_status bt_graph_consume_sink_no_check(struct bt_graph *graph,
struct bt_component_sink *sink);
BT_HIDDEN
void bt_graph_notify_port_added(struct bt_graph *graph, struct bt_port *port);
-BT_HIDDEN
-void bt_graph_notify_port_removed(struct bt_graph *graph,
- struct bt_component *comp, struct bt_port *port);
-
BT_HIDDEN
void bt_graph_notify_ports_connected(struct bt_graph *graph,
struct bt_port *upstream_port, struct bt_port *downstream_port);
-BT_HIDDEN
-void bt_graph_notify_ports_disconnected(struct bt_graph *graph,
- struct bt_component *upstream_comp,
- struct bt_component *downstream_comp,
- struct bt_port *upstream_port,
- struct bt_port *downstream_port);
-
BT_HIDDEN
void bt_graph_remove_connection(struct bt_graph *graph,
struct bt_connection *connection);
struct bt_component *component);
BT_HIDDEN
-void bt_graph_add_notification(struct bt_graph *graph,
- struct bt_notification *notif);
+void bt_graph_add_message(struct bt_graph *graph,
+ struct bt_message *msg);
static inline
const char *bt_graph_status_string(enum bt_graph_status status)
projects / babeltrace.git / blobdiff