ctf.fs: bt_ctf_notif_iter_create(): assert() that all medops exist
[babeltrace.git] / ctf-reader-proto / ctf-fs.c
CommitLineData
e98a2d6e
PP
1/*
2 * Copyright 2016 - Philippe Proulx <pproulx@efficios.com>
3 *
4 * Permission is hereby granted, free of charge, to any person obtaining a copy
5 * of this software and associated documentation files (the "Software"), to deal
6 * in the Software without restriction, including without limitation the rights
7 * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
8 * copies of the Software, and to permit persons to whom the Software is
9 * furnished to do so, subject to the following conditions:
10 *
11 * The above copyright notice and this permission notice shall be included in
12 * all copies or substantial portions of the Software.
13 *
14 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
15 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
16 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
17 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
18 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
19 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
20 * SOFTWARE.
21 */
22
23#include <stdio.h>
24#include <stdbool.h>
25#include <assert.h>
26#include <stdlib.h>
27#include <unistd.h>
28#include <glib.h>
29
30#define PRINT_ERR_STREAM ctf_fs->error_fp
31#define PRINT_PREFIX "ctf-fs"
32#include "print.h"
33
34#include "ctf-fs.h"
35#include "ctf-fs-file.h"
36#include "ctf-fs-metadata.h"
37#include "ctf-fs-data-stream.h"
38
39bool ctf_fs_debug = false;
40
41static void ctf_fs_destroy(struct ctf_fs *ctf_fs)
42{
43 if (!ctf_fs) {
44 return;
45 }
46
47 if (ctf_fs->trace_path) {
48 g_string_free(ctf_fs->trace_path, TRUE);
49 }
50
51 ctf_fs_metadata_deinit(&ctf_fs->metadata);
52 ctf_fs_data_stream_deinit(&ctf_fs->data_stream);
53 g_free(ctf_fs);
54}
55
56static struct ctf_fs *ctf_fs_create(const char *trace_path)
57{
58 struct ctf_fs *ctf_fs = g_new0(struct ctf_fs, 1);
59
60 if (!ctf_fs) {
61 goto error;
62 }
63
64 ctf_fs->trace_path = g_string_new(trace_path);
65 if (!ctf_fs->trace_path) {
66 goto error;
67 }
68
69 ctf_fs->error_fp = stderr;
70 ctf_fs->page_size = getpagesize();
71
72 if (ctf_fs_metadata_init(&ctf_fs->metadata)) {
73 PERR("Cannot initialize metadata structure\n");
74 goto error;
75 }
76
77 if (ctf_fs_data_stream_init(ctf_fs, &ctf_fs->data_stream)) {
78 PERR("Cannot initialize data stream structure\n");
79 goto error;
80 }
81
82 goto end;
83
84error:
85 ctf_fs_destroy(ctf_fs);
86 ctf_fs = NULL;
87
88end:
89 return ctf_fs;
90}
91
92void ctf_fs_init(void)
93{
94 if (g_strcmp0(getenv("CTF_FS_DEBUG"), "1") == 0) {
95 ctf_fs_debug = true;
96 }
97}
98
99void ctf_fs_test(const char *trace_path)
100{
101 ctf_fs_init();
102
103 struct ctf_fs *ctf_fs = ctf_fs_create(trace_path);
104 struct bt_ctf_notif_iter_notif *notification;
105
106 if (!ctf_fs) {
107 return;
108 }
109
110 /* Set trace from metadata file */
111 ctf_fs_metadata_set_trace(ctf_fs);
112 ctf_fs_data_stream_open_streams(ctf_fs);
113
114 while (true) {
115 int ret = ctf_fs_data_stream_get_next_notification(ctf_fs, &notification);
116 assert(ret == 0);
117
118 if (!notification) {
119 goto end;
120 }
121
122 switch (notification->type) {
123 case BT_CTF_NOTIF_ITER_NOTIF_NEW_PACKET:
124 {
125 struct bt_ctf_notif_iter_notif_new_packet *notif =
126 (struct bt_ctf_notif_iter_notif_new_packet *) notification;
127 break;
128 }
129 case BT_CTF_NOTIF_ITER_NOTIF_EVENT:
130 {
131 struct bt_ctf_notif_iter_notif_event *notif =
132 (struct bt_ctf_notif_iter_notif_event *) notification;
133 break;
134 }
135 case BT_CTF_NOTIF_ITER_NOTIF_END_OF_PACKET:
136 {
137 struct bt_ctf_notif_iter_notif_end_of_packet *notif =
138 (struct bt_ctf_notif_iter_notif_end_of_packet *) notification;
139 break;
140 }
141 default:
142 break;
143 }
144
145 bt_ctf_notif_iter_notif_destroy(notification);
146 }
147
148end:
149 ctf_fs_destroy(ctf_fs);
150}
This page took 0.030784 seconds and 4 git commands to generate.