* The medium function called by the notification iterator
* function reached the end of the file.
*/
- BT_CTF_NOTIF_ITER_MEDIUM_STATUS_EOF = -4,
+ BT_CTF_NOTIF_ITER_MEDIUM_STATUS_EOF = 1,
/**
* There is no data available right now, try again later.
*/
- BT_CTF_NOTIF_ITER_MEDIUM_STATUS_AGAIN = -3,
+ BT_CTF_NOTIF_ITER_MEDIUM_STATUS_AGAIN = 11,
/** Invalid argument. */
BT_CTF_NOTIF_ITER_MEDIUM_STATUS_INVAL = -2,
BT_CTF_NOTIF_ITER_MEDIUM_STATUS_ERROR = -1,
/** Everything okay. */
- BT_CTF_NOTIF_ITER_MEDIUM_STATUS_OK = 0,
+ BT_CTF_NOTIF_ITER_MEDIUM_STATUS_OK = 0,
};
/**
* The medium function called by the notification iterator
* function reached the end of the file.
*/
- BT_CTF_NOTIF_ITER_STATUS_EOF = -4,
+ BT_CTF_NOTIF_ITER_STATUS_EOF = BT_CTF_NOTIF_ITER_MEDIUM_STATUS_EOF,
/**
* There is no data available right now, try again later.
* last called notification iterator function once the situation
* is resolved.
*/
- BT_CTF_NOTIF_ITER_STATUS_AGAIN = -3,
+ BT_CTF_NOTIF_ITER_STATUS_AGAIN = BT_CTF_NOTIF_ITER_MEDIUM_STATUS_AGAIN,
/** Invalid argument. */
- BT_CTF_NOTIF_ITER_STATUS_INVAL = -2,
+ BT_CTF_NOTIF_ITER_STATUS_INVAL = BT_CTF_NOTIF_ITER_MEDIUM_STATUS_INVAL,
/** General error. */
- BT_CTF_NOTIF_ITER_STATUS_ERROR = -1,
+ BT_CTF_NOTIF_ITER_STATUS_ERROR = BT_CTF_NOTIF_ITER_MEDIUM_STATUS_ERROR,
/** Everything okay. */
BT_CTF_NOTIF_ITER_STATUS_OK = 0,
* corresponding stream class is found by the notification
* iterator.
*
- * @param stream_class Stream class associated to the stream
+ * @param stream_class Stream class of the stream to get
+ * @param stream_id Stream (instance) ID of the stream
+ * to get (-1ULL if not available)
* @param data User data
* @returns Stream instance (weak reference) or
* \c NULL on error
*/
struct bt_ctf_stream * (* get_stream)(
- struct bt_ctf_stream_class *stream_class, void *data);
+ struct bt_ctf_stream_class *stream_class,
+ uint64_t stream_id, void *data);
};
/** CTF notification iterator. */
* incremented.
*
* @param trace Trace to read
- * @param cc_prio_map Clock class priority map to use when
- * creating the event notifications
* @param max_request_sz Maximum buffer size, in bytes, to
* request to
* bt_ctf_notif_iter_medium_ops::request_bytes()
* at a time
* @param medops Medium operations
* @param medops_data User data (passed to medium operations)
- * @param err_stream Error stream (can be \c NULL to disable)
* @returns New CTF notification iterator on
* success, or \c NULL on error
*/
BT_HIDDEN
struct bt_ctf_notif_iter *bt_ctf_notif_iter_create(struct bt_ctf_trace *trace,
- struct bt_clock_class_priority_map *cc_prio_map,
size_t max_request_sz, struct bt_ctf_notif_iter_medium_ops medops,
- void *medops_data, FILE *err_stream);
+ void *medops_data);
/**
* Destroys a CTF notification iterator, freeing all internal resources.
* call this function again, until another status is returned.
*
* @param notif_iter CTF notification iterator
+ * @param cc_prio_map Clock class priority map to use when
+ * creating an event notification
* @param notification Returned notification if the function's
* return value is #BT_CTF_NOTIF_ITER_STATUS_OK
* @returns One of #bt_ctf_notif_iter_status values
BT_HIDDEN
enum bt_ctf_notif_iter_status bt_ctf_notif_iter_get_next_notification(
struct bt_ctf_notif_iter *notit,
+ struct bt_clock_class_priority_map *cc_prio_map,
struct bt_notification **notification);
+/**
+ * Returns the first packet header and context fields. This function
+ * never needs to call the `get_stream()` medium operation because
+ * it does not create packet or event objects.
+ *
+ * @param notif_iter CTF notification iterator
+ * @param packet_header_field Packet header field (\c NULL if there's
+ * no packet header field)
+ * @param packet_context_field Packet context field (\c NULL if there's
+ * no packet context field)
+ * @returns One of #bt_ctf_notif_iter_status values
+ */
+BT_HIDDEN
+enum bt_ctf_notif_iter_status bt_ctf_notif_iter_get_packet_header_context_fields(
+ struct bt_ctf_notif_iter *notit,
+ struct bt_ctf_field **packet_header_field,
+ struct bt_ctf_field **packet_context_field);
+
+BT_HIDDEN
+void bt_ctf_notif_iter_set_medops_data(struct bt_ctf_notif_iter *notit,
+ void *medops_data);
+
+static inline
+const char *bt_ctf_notif_iter_medium_status_string(
+ enum bt_ctf_notif_iter_medium_status status)
+{
+ switch (status) {
+ case BT_CTF_NOTIF_ITER_MEDIUM_STATUS_EOF:
+ return "BT_CTF_NOTIF_ITER_MEDIUM_STATUS_EOF";
+ case BT_CTF_NOTIF_ITER_MEDIUM_STATUS_AGAIN:
+ return "BT_CTF_NOTIF_ITER_MEDIUM_STATUS_AGAIN";
+ case BT_CTF_NOTIF_ITER_MEDIUM_STATUS_INVAL:
+ return "BT_CTF_NOTIF_ITER_MEDIUM_STATUS_INVAL";
+ case BT_CTF_NOTIF_ITER_MEDIUM_STATUS_ERROR:
+ return "BT_CTF_NOTIF_ITER_MEDIUM_STATUS_ERROR";
+ case BT_CTF_NOTIF_ITER_MEDIUM_STATUS_OK:
+ return "BT_CTF_NOTIF_ITER_MEDIUM_STATUS_OK";
+ default:
+ return "(unknown)";
+ }
+}
+
+static inline
+const char *bt_ctf_notif_iter_status_string(
+ enum bt_ctf_notif_iter_status status)
+{
+ switch (status) {
+ case BT_CTF_NOTIF_ITER_STATUS_EOF:
+ return "BT_CTF_NOTIF_ITER_STATUS_EOF";
+ case BT_CTF_NOTIF_ITER_STATUS_AGAIN:
+ return "BT_CTF_NOTIF_ITER_STATUS_AGAIN";
+ case BT_CTF_NOTIF_ITER_STATUS_INVAL:
+ return "BT_CTF_NOTIF_ITER_STATUS_INVAL";
+ case BT_CTF_NOTIF_ITER_STATUS_ERROR:
+ return "BT_CTF_NOTIF_ITER_STATUS_ERROR";
+ case BT_CTF_NOTIF_ITER_STATUS_OK:
+ return "BT_CTF_NOTIF_ITER_STATUS_OK";
+ default:
+ return "(unknown)";
+ }
+}
+
#endif /* CTF_NOTIF_ITER_H */
projects / babeltrace.git / blobdiff