projects / babeltrace.git / blame
? search:
summary | shortlog | log | commit | commitdiff | tree
blob | blame (incremental) | history | HEAD
fs-sink: move stream and stream_class maps in fs_writer struct
[babeltrace.git] / plugins / ctf / fs-sink / write.c
CommitLineData
bc506aa5
JD		 1/*
2 * writer.c
3 *
4 * Babeltrace CTF Writer Output Plugin Event Handling
5 *
6 * Copyright 2016 Jérémie Galarneau <jeremie.galarneau@efficios.com>
7 *
8 * Author: Jérémie Galarneau <jeremie.galarneau@efficios.com>
9 *
10 * Permission is hereby granted, free of charge, to any person obtaining a copy
11 * of this software and associated documentation files (the "Software"), to deal
12 * in the Software without restriction, including without limitation the rights
13 * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
14 * copies of the Software, and to permit persons to whom the Software is
15 * furnished to do so, subject to the following conditions:
16 *
17 * The above copyright notice and this permission notice shall be included in
18 * all copies or substantial portions of the Software.
19 *
20 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
21 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
22 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
23 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
24 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
25 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
26 * SOFTWARE.
27 */
28
29#include <babeltrace/ctf-ir/event.h>
30#include <babeltrace/ctf-ir/packet.h>
31#include <babeltrace/ctf-ir/event-class.h>
32#include <babeltrace/ctf-ir/stream.h>
33#include <babeltrace/ctf-ir/stream-class.h>
ac0c6bdd 34#include <babeltrace/ctf-ir/clock-class.h>
bc506aa5
JD		 35#include <babeltrace/ctf-ir/fields.h>
36#include <babeltrace/ctf-writer/stream-class.h>
37#include <babeltrace/ctf-writer/stream.h>
f3168545 38#include <assert.h>
bc506aa5 39
91b73004
JD		 40#include <ctfcopytrace.h>
41
bc506aa5
JD		 42#include "writer.h"
43
a619fcb7
JD		 44static
45void unref_stream_class(struct bt_ctf_stream_class *writer_stream_class)
46{
47 bt_put(writer_stream_class);
48}
49
50static
51void unref_stream(struct bt_ctf_stream_class *writer_stream)
52{
53 bt_put(writer_stream);
54}
55
56gboolean empty_ht(gpointer key, gpointer value, gpointer user_data)
57{
58 return TRUE;
59}
60
f3168545
JD		 61static
62void trace_is_static_listener(struct bt_ctf_trace *trace, void *data)
63{
64 *((int *) data) = 1;
65}
66
bc506aa5 67static
91b73004
JD		 68struct bt_ctf_stream_class *insert_new_stream_class(
69 struct writer_component *writer_component,
a619fcb7 70 struct fs_writer *fs_writer,
91b73004 71 struct bt_ctf_stream_class *stream_class)
bc506aa5 72{
b2f1f465 73 struct bt_ctf_stream_class *writer_stream_class = NULL;
9ae49d3d 74 struct bt_ctf_trace *trace = NULL, *writer_trace = NULL;
a619fcb7 75 struct bt_ctf_writer *ctf_writer = fs_writer->writer;
3241bc18 76 enum bt_component_status ret;
bc506aa5 77
3241bc18
JD		 78 trace = bt_ctf_stream_class_get_trace(stream_class);
79 if (!trace) {
91b73004
JD		 80 fprintf(writer_component->err,
81 "[error] %s in %s:%d\n", __func__, __FILE__,
bc506aa5 82 __LINE__);
9ae49d3d 83 goto error;
bc506aa5
JD		 84 }
85
91b73004
JD		 86 writer_trace = bt_ctf_writer_get_trace(ctf_writer);
87 if (!writer_trace) {
91b73004
JD		 88 fprintf(writer_component->err,
89 "[error] %s in %s:%d\n", __func__, __FILE__,
d00b90bf 90 __LINE__);
9ae49d3d 91 goto error;
bc506aa5
JD		 92 }
93
91b73004
JD		 94 ret = ctf_copy_clock_classes(writer_component->err, writer_trace,
95 writer_stream_class, trace);
bc506aa5 96 if (ret != BT_COMPONENT_STATUS_OK) {
91b73004
JD		 97 fprintf(writer_component->err,
98 "[error] %s in %s:%d\n", __func__, __FILE__,
bc506aa5 99 __LINE__);
9ae49d3d 100 goto error;
b2f1f465
JD		 101 }
102
103 writer_stream_class = ctf_copy_stream_class(writer_component->err,
104 stream_class, writer_trace, true);
105 if (!writer_stream_class) {
106 fprintf(writer_component->err, "[error] Failed to copy stream class\n");
107 fprintf(writer_component->err, "[error] %s in %s:%d\n",
108 __func__, __FILE__, __LINE__);
9ae49d3d 109 goto error;
bc506aa5 110 }
bc506aa5 111
a619fcb7 112 g_hash_table_insert(fs_writer->stream_class_map,
bc506aa5
JD		 113 (gpointer) stream_class, writer_stream_class);
114
9ae49d3d
JD		 115 goto end;
116
117error:
118 BT_PUT(writer_stream_class);
119end:
b2f1f465 120 bt_put(writer_trace);
b2f1f465 121 bt_put(trace);
bc506aa5
JD		 122 return writer_stream_class;
123}
124
125static
f3168545 126struct fs_writer *insert_new_writer(
bc506aa5
JD		 127 struct writer_component *writer_component,
128 struct bt_ctf_trace *trace)
129{
9ae49d3d
JD		 130 struct bt_ctf_writer *ctf_writer = NULL;
131 struct bt_ctf_trace *writer_trace = NULL;
bc506aa5
JD		 132 char trace_name[PATH_MAX];
133 enum bt_component_status ret;
f3168545 134 struct fs_writer *fs_writer;
bc506aa5 135
9ae49d3d 136 /* FIXME: replace with trace name when it will work. */
bc506aa5 137 snprintf(trace_name, PATH_MAX, "%s/%s_%03d",
9057f037
JD		 138 writer_component->base_path->str,
139 writer_component->trace_name_base->str,
bc506aa5
JD		 140 writer_component->trace_id++);
141 printf_verbose("CTF-Writer creating trace in %s\n", trace_name);
9057f037 142
bc506aa5
JD		 143 ctf_writer = bt_ctf_writer_create(trace_name);
144 if (!ctf_writer) {
145 fprintf(writer_component->err, "[error] %s in %s:%d\n",
146 __func__, __FILE__, __LINE__);
9ae49d3d 147 goto error;
bc506aa5
JD		 148 }
149
91b73004
JD		 150 writer_trace = bt_ctf_writer_get_trace(ctf_writer);
151 if (!writer_trace) {
91b73004
JD		 152 fprintf(writer_component->err,
153 "[error] %s in %s:%d\n", __func__, __FILE__,
154 __LINE__);
9ae49d3d 155 goto error;
91b73004
JD		 156 }
157
158 ret = ctf_copy_trace(writer_component->err, trace, writer_trace);
bc506aa5
JD		 159 if (ret != BT_COMPONENT_STATUS_OK) {
160 fprintf(writer_component->err, "[error] Failed to copy trace\n");
161 fprintf(writer_component->err, "[error] %s in %s:%d\n",
162 __func__, __FILE__, __LINE__);
163 BT_PUT(ctf_writer);
f3168545 164 goto error;
bc506aa5 165 }
f3168545
JD		 166
167 fs_writer = g_new0(struct fs_writer, 1);
168 if (!fs_writer) {
169 fprintf(writer_component->err,
170 "[error] %s in %s:%d\n", __func__, __FILE__,
171 __LINE__);
172 goto error;
173 }
174 fs_writer->writer = ctf_writer;
a619fcb7
JD		 175 fs_writer->stream_class_map = g_hash_table_new_full(g_direct_hash,
176 g_direct_equal, NULL, (GDestroyNotify) unref_stream_class);
177 fs_writer->stream_map = g_hash_table_new_full(g_direct_hash,
178 g_direct_equal, NULL, (GDestroyNotify) unref_stream);
179 fs_writer->trace = trace;
f3168545 180 fs_writer->writer_trace = writer_trace;
9ae49d3d 181 BT_PUT(writer_trace);
f3168545
JD		 182 if (bt_ctf_trace_is_static(trace)) {
183 fs_writer->trace_static = 1;
184 fs_writer->static_listener_id = -1;
185 } else {
186 ret = bt_ctf_trace_add_is_static_listener(trace,
187 trace_is_static_listener, &fs_writer->trace_static);
188 if (ret < 0) {
189 fprintf(writer_component->err,
190 "[error] %s in %s:%d\n", __func__, __FILE__,
191 __LINE__);
192 g_free(fs_writer);
193 fs_writer = NULL;
194 goto error;
195 }
196 fs_writer->static_listener_id = ret;
197 }
bc506aa5
JD		 198
199 g_hash_table_insert(writer_component->trace_map, (gpointer) trace,
f3168545 200 fs_writer);
bc506aa5 201
9ae49d3d
JD		 202 goto end;
203
204error:
205 bt_put(writer_trace);
206 BT_PUT(ctf_writer);
bc506aa5 207end:
f3168545 208 return fs_writer;
bc506aa5
JD		 209}
210
211static
f3168545 212struct fs_writer *get_fs_writer(struct writer_component *writer_component,
bc506aa5
JD		 213 struct bt_ctf_stream_class *stream_class)
214{
9ae49d3d 215 struct bt_ctf_trace *trace = NULL;
f3168545 216 struct fs_writer *fs_writer;
bc506aa5
JD		 217
218 trace = bt_ctf_stream_class_get_trace(stream_class);
219 if (!trace) {
bc506aa5
JD		 220 fprintf(writer_component->err, "[error] %s in %s:%d\n",
221 __func__, __FILE__, __LINE__);
9ae49d3d 222 goto error;
bc506aa5
JD		 223 }
224
f3168545 225 fs_writer = g_hash_table_lookup(writer_component->trace_map,
bc506aa5 226 (gpointer) trace);
f3168545
JD		 227 if (!fs_writer) {
228 fs_writer = insert_new_writer(writer_component, trace);
bc506aa5 229 }
9ae49d3d
JD		 230 BT_PUT(trace);
231 goto end;
bc506aa5 232
9ae49d3d 233error:
f3168545 234 fs_writer = NULL;
bc506aa5 235end:
f3168545 236 return fs_writer;
bc506aa5
JD		 237}
238
a619fcb7
JD		 239static
240struct fs_writer *get_fs_writer_from_stream(
241 struct writer_component *writer_component,
242 struct bt_ctf_stream *stream)
243{
244 struct bt_ctf_stream_class *stream_class = NULL;
245 struct fs_writer *fs_writer;
246
247 stream_class = bt_ctf_stream_get_class(stream);
248 if (!stream_class) {
249 fprintf(writer_component->err, "[error] %s in %s:%d\n",
250 __func__, __FILE__, __LINE__);
251 goto error;
252 }
253
254 fs_writer = get_fs_writer(writer_component, stream_class);
255 goto end;
256
257error:
258 fs_writer = NULL;
259
260end:
261 bt_put(stream_class);
262 return fs_writer;
263}
264
265static
266struct bt_ctf_stream_class *lookup_stream_class(
267 struct writer_component *writer_component,
268 struct bt_ctf_stream_class *stream_class)
269{
270 struct fs_writer *fs_writer = get_fs_writer(
271 writer_component, stream_class);
272 assert(fs_writer);
273 return (struct bt_ctf_stream_class *) g_hash_table_lookup(
274 fs_writer->stream_class_map, (gpointer) stream_class);
275}
276
277static
278struct bt_ctf_stream *lookup_stream(struct writer_component *writer_component,
279 struct bt_ctf_stream *stream)
280{
281 struct fs_writer *fs_writer = get_fs_writer_from_stream(
282 writer_component, stream);
283 assert(fs_writer);
284 return (struct bt_ctf_stream *) g_hash_table_lookup(
285 fs_writer->stream_map, (gpointer) stream);
286}
287
288static
289struct bt_ctf_stream *insert_new_stream(
290 struct writer_component *writer_component,
291 struct fs_writer *fs_writer,
292 struct bt_ctf_stream_class *stream_class,
293 struct bt_ctf_stream *stream)
294{
295 struct bt_ctf_stream *writer_stream = NULL;
296 struct bt_ctf_stream_class *writer_stream_class = NULL;
297 struct bt_ctf_writer *ctf_writer = bt_get(fs_writer->writer);
298
299 writer_stream_class = lookup_stream_class(writer_component,
300 stream_class);
301 if (!writer_stream_class) {
302 writer_stream_class = insert_new_stream_class(
303 writer_component, fs_writer, stream_class);
304 if (!writer_stream_class) {
305 fprintf(writer_component->err, "[error] %s in %s:%d\n",
306 __func__, __FILE__, __LINE__);
307 goto error;
308 }
309 }
310 bt_get(writer_stream_class);
311
312 writer_stream = bt_ctf_writer_create_stream(ctf_writer,
313 writer_stream_class);
314 if (!writer_stream) {
315 fprintf(writer_component->err, "[error] %s in %s:%d\n",
316 __func__, __FILE__, __LINE__);
317 goto error;
318 }
319
320 g_hash_table_insert(fs_writer->stream_map, (gpointer) stream,
321 writer_stream);
322
323 goto end;
324
325error:
326 BT_PUT(writer_stream);
327end:
328 bt_put(ctf_writer);
329 bt_put(writer_stream_class);
330 return writer_stream;
331}
332
333static
334struct bt_ctf_event_class *get_event_class(struct writer_component *writer_component,
335 struct bt_ctf_stream_class *writer_stream_class,
336 struct bt_ctf_event_class *event_class)
337{
338 return bt_ctf_stream_class_get_event_class_by_id(writer_stream_class,
339 bt_ctf_event_class_get_id(event_class));
340}
341
bc506aa5
JD		 342static
343struct bt_ctf_stream *get_writer_stream(
344 struct writer_component *writer_component,
345 struct bt_ctf_packet *packet, struct bt_ctf_stream *stream)
346{
9ae49d3d 347 struct bt_ctf_stream *writer_stream = NULL;
bc506aa5 348
f384901f
JD		 349 writer_stream = lookup_stream(writer_component, stream);
350 if (!writer_stream) {
bc506aa5
JD		 351 fprintf(writer_component->err, "[error] %s in %s:%d\n",
352 __func__, __FILE__, __LINE__);
9ae49d3d 353 goto error;
bc506aa5 354 }
9ae49d3d
JD		 355 bt_get(writer_stream);
356
357 goto end;
bc506aa5 358
9ae49d3d
JD		 359error:
360 BT_PUT(writer_stream);
361end:
bc506aa5
JD		 362 return writer_stream;
363}
364
f3168545 365BT_HIDDEN
a619fcb7
JD		 366void writer_close(struct writer_component *writer_component,
367 struct fs_writer *fs_writer)
f3168545 368{
f3168545 369 if (fs_writer->static_listener_id > 0) {
a619fcb7 370 bt_ctf_trace_remove_is_static_listener(fs_writer->trace,
f3168545
JD		 371 fs_writer->static_listener_id);
372 }
a619fcb7
JD		 373
374 /* Empty the stream class HT. */
375 g_hash_table_foreach_remove(fs_writer->stream_class_map,
376 empty_ht, NULL);
377 g_hash_table_destroy(fs_writer->stream_class_map);
378
379 /* Empty the stream HT. */
380 g_hash_table_foreach_remove(fs_writer->stream_map,
381 empty_ht, NULL);
382 g_hash_table_destroy(fs_writer->stream_map);
f3168545
JD		 383}
384
f384901f
JD		 385BT_HIDDEN
386enum bt_component_status writer_stream_begin(
387 struct writer_component *writer_component,
388 struct bt_ctf_stream *stream)
389{
390 struct bt_ctf_stream_class *stream_class = NULL;
391 struct fs_writer *fs_writer;
f384901f
JD		 392 struct bt_ctf_stream *writer_stream = NULL;
393 enum bt_component_status ret = BT_COMPONENT_STATUS_OK;
394
395 stream_class = bt_ctf_stream_get_class(stream);
396 if (!stream_class) {
397 fprintf(writer_component->err, "[error] %s in %s:%d\n",
398 __func__, __FILE__, __LINE__);
399 goto error;
400 }
401
402 fs_writer = get_fs_writer(writer_component, stream_class);
403 if (!fs_writer) {
404 fprintf(writer_component->err, "[error] %s in %s:%d\n",
405 __func__, __FILE__, __LINE__);
406 goto error;
407 }
a619fcb7 408 writer_stream = insert_new_stream(writer_component, fs_writer,
f384901f
JD		 409 stream_class, stream);
410 if (!writer_stream) {
411 fprintf(writer_component->err, "[error] %s in %s:%d\n",
412 __func__, __FILE__, __LINE__);
413 goto error;
414 }
415 fs_writer->active_streams++;
416
417 goto end;
418
419error:
420 ret = BT_COMPONENT_STATUS_ERROR;
421end:
f384901f
JD		 422 bt_put(stream_class);
423 return ret;
424}
425
f3168545
JD		 426BT_HIDDEN
427enum bt_component_status writer_stream_end(
428 struct writer_component *writer_component,
429 struct bt_ctf_stream *stream)
430{
431 struct bt_ctf_stream_class *stream_class = NULL;
432 struct fs_writer *fs_writer;
433 struct bt_ctf_trace *trace = NULL;
434 enum bt_component_status ret = BT_COMPONENT_STATUS_OK;
435
f3168545
JD		 436 stream_class = bt_ctf_stream_get_class(stream);
437 if (!stream_class) {
438 fprintf(writer_component->err, "[error] %s in %s:%d\n",
439 __func__, __FILE__, __LINE__);
440 goto error;
441 }
442
443 fs_writer = get_fs_writer(writer_component, stream_class);
444 if (!fs_writer) {
445 fprintf(writer_component->err, "[error] %s in %s:%d\n",
446 __func__, __FILE__, __LINE__);
447 goto error;
448 }
a619fcb7 449 g_hash_table_remove(fs_writer->stream_map, stream);
f3168545
JD		 450
451 assert(fs_writer->active_streams > 0);
452 fs_writer->active_streams--;
453 if (fs_writer->active_streams == 0 && fs_writer->trace_static) {
a619fcb7
JD		 454 writer_close(writer_component, fs_writer);
455 g_hash_table_remove(writer_component->trace_map,
456 fs_writer->trace);
f3168545
JD		 457 }
458
459 goto end;
460
461error:
462 ret = BT_COMPONENT_STATUS_ERROR;
463end:
464 BT_PUT(trace);
465 BT_PUT(stream_class);
466 return ret;
467}
468
bc506aa5
JD		 469BT_HIDDEN
470enum bt_component_status writer_new_packet(
471 struct writer_component *writer_component,
472 struct bt_ctf_packet *packet)
473{
9ae49d3d
JD		 474 struct bt_ctf_stream *stream = NULL, *writer_stream = NULL;
475 struct bt_ctf_field *writer_packet_context = NULL;
bc506aa5 476 enum bt_component_status ret = BT_COMPONENT_STATUS_OK;
b2f1f465 477 int int_ret;
bc506aa5
JD		 478
479 stream = bt_ctf_packet_get_stream(packet);
480 if (!stream) {
bc506aa5
JD		 481 fprintf(writer_component->err, "[error] %s in %s:%d\n",
482 __func__, __FILE__, __LINE__);
9ae49d3d 483 goto error;
bc506aa5
JD		 484 }
485
bc506aa5
JD		 486 writer_stream = get_writer_stream(writer_component, packet, stream);
487 if (!writer_stream) {
bc506aa5
JD		 488 fprintf(writer_component->err, "[error] %s in %s:%d\n",
489 __func__, __FILE__, __LINE__);
9ae49d3d 490 goto error;
bc506aa5 491 }
9ae49d3d 492 BT_PUT(stream);
bc506aa5 493
b2f1f465 494 writer_packet_context = ctf_copy_packet_context(writer_component->err,
ab80adac 495 packet, writer_stream, 1);
b2f1f465 496 if (!writer_packet_context) {
91b73004
JD		 497 fprintf(writer_component->err, "[error] %s in %s:%d\n",
498 __func__, __FILE__, __LINE__);
9ae49d3d 499 goto error;
bc506aa5
JD		 500 }
501
b2f1f465
JD		 502 int_ret = bt_ctf_stream_set_packet_context(writer_stream,
503 writer_packet_context);
504 if (int_ret < 0) {
b2f1f465
JD		 505 fprintf(writer_component->err, "[error] %s in %s:%d\n", __func__,
506 __FILE__, __LINE__);
9ae49d3d 507 goto error;
b2f1f465 508 }
9ae49d3d
JD		 509 BT_PUT(writer_stream);
510 BT_PUT(writer_packet_context);
b2f1f465 511
9ae49d3d 512 goto end;
bc506aa5 513
9ae49d3d
JD		 514error:
515 ret = BT_COMPONENT_STATUS_ERROR;
516end:
517 bt_put(writer_stream);
b2f1f465 518 bt_put(writer_packet_context);
91b73004 519 bt_put(stream);
bc506aa5
JD		 520 return ret;
521}
522
523BT_HIDDEN
524enum bt_component_status writer_close_packet(
525 struct writer_component *writer_component,
526 struct bt_ctf_packet *packet)
527{
9ae49d3d 528 struct bt_ctf_stream *stream = NULL, *writer_stream = NULL;
bc506aa5
JD		 529 enum bt_component_status ret;
530
531 stream = bt_ctf_packet_get_stream(packet);
532 if (!stream) {
bc506aa5
JD		 533 fprintf(writer_component->err, "[error] %s in %s:%d\n",
534 __func__, __FILE__, __LINE__);
9ae49d3d 535 goto error;
bc506aa5
JD		 536 }
537
538 writer_stream = lookup_stream(writer_component, stream);
539 if (!writer_stream) {
bc506aa5
JD		 540 fprintf(writer_component->err, "[error] %s in %s:%d\n",
541 __func__, __FILE__, __LINE__);
9ae49d3d 542 goto error;
bc506aa5 543 }
9ae49d3d 544 BT_PUT(stream);
bc506aa5 545
9ae49d3d 546 bt_get(writer_stream);
bc506aa5 547
bc506aa5
JD		 548 ret = bt_ctf_stream_flush(writer_stream);
549 if (ret < 0) {
550 fprintf(writer_component->err,
551 "[error] Failed to flush packet\n");
9ae49d3d 552 goto error;
bc506aa5 553 }
9ae49d3d 554 BT_PUT(writer_stream);
bc506aa5
JD		 555
556 ret = BT_COMPONENT_STATUS_OK;
9ae49d3d 557 goto end;
bc506aa5 558
9ae49d3d
JD		 559error:
560 ret = BT_COMPONENT_STATUS_ERROR;
561end:
bc506aa5 562 bt_put(writer_stream);
bc506aa5 563 bt_put(stream);
bc506aa5
JD		 564 return ret;
565}
566
bc506aa5
JD		 567BT_HIDDEN
568enum bt_component_status writer_output_event(
569 struct writer_component *writer_component,
570 struct bt_ctf_event *event)
571{
572 enum bt_component_status ret;
9ae49d3d
JD		 573 struct bt_ctf_event_class *event_class = NULL, *writer_event_class = NULL;
574 struct bt_ctf_stream *stream = NULL, *writer_stream = NULL;
575 struct bt_ctf_stream_class *stream_class = NULL, *writer_stream_class = NULL;
576 struct bt_ctf_event *writer_event = NULL;
bc506aa5
JD		 577 const char *event_name;
578 int int_ret;
579
580 event_class = bt_ctf_event_get_class(event);
581 if (!event_class) {
bc506aa5
JD		 582 fprintf(writer_component->err, "[error] %s in %s:%d\n", __func__,
583 __FILE__, __LINE__);
9ae49d3d 584 goto error;
bc506aa5
JD		 585 }
586
587 event_name = bt_ctf_event_class_get_name(event_class);
588 if (!event_name) {
bc506aa5
JD		 589 fprintf(writer_component->err, "[error] %s in %s:%d\n", __func__,
590 __FILE__, __LINE__);
9ae49d3d 591 goto error;
bc506aa5 592 }
bc506aa5
JD		 593
594 stream = bt_ctf_event_get_stream(event);
595 if (!stream) {
bc506aa5
JD		 596 fprintf(writer_component->err, "[error] %s in %s:%d\n", __func__,
597 __FILE__, __LINE__);
9ae49d3d 598 goto error;
bc506aa5
JD		 599 }
600
601 writer_stream = lookup_stream(writer_component, stream);
602 if (!writer_stream || !bt_get(writer_stream)) {
bc506aa5
JD		 603 fprintf(writer_component->err, "[error] %s in %s:%d\n", __func__,
604 __FILE__, __LINE__);
9ae49d3d 605 goto error;
bc506aa5
JD		 606 }
607
608 stream_class = bt_ctf_event_class_get_stream_class(event_class);
609 if (!stream_class) {
bc506aa5
JD		 610 fprintf(writer_component->err, "[error] %s in %s:%d\n", __func__,
611 __FILE__, __LINE__);
9ae49d3d 612 goto error;
bc506aa5
JD		 613 }
614
a619fcb7 615 writer_stream_class = lookup_stream_class(writer_component, stream_class);
bc506aa5 616 if (!writer_stream_class || !bt_get(writer_stream_class)) {
bc506aa5
JD		 617 fprintf(writer_component->err, "[error] %s in %s:%d\n", __func__,
618 __FILE__, __LINE__);
9ae49d3d 619 goto error;
bc506aa5
JD		 620 }
621
622 writer_event_class = get_event_class(writer_component,
623 writer_stream_class, event_class);
624 if (!writer_event_class) {
af34e875
JD		 625 writer_event_class = ctf_copy_event_class(writer_component->err,
626 event_class);
627 if (!writer_event_class) {
af34e875
JD		 628 fprintf(writer_component->err, "[error] %s in %s:%d\n",
629 __func__, __FILE__, __LINE__);
9ae49d3d 630 goto error;
af34e875
JD		 631 }
632 int_ret = bt_ctf_stream_class_add_event_class(
633 writer_stream_class, writer_event_class);
634 if (int_ret) {
af34e875
JD		 635 fprintf(writer_component->err, "[error] %s in %s:%d\n",
636 __func__, __FILE__, __LINE__);
9ae49d3d 637 goto error;
af34e875 638 }
bc506aa5
JD		 639 }
640
b2f1f465
JD		 641 writer_event = ctf_copy_event(writer_component->err, event,
642 writer_event_class, true);
bc506aa5 643 if (!writer_event) {
bc506aa5
JD		 644 fprintf(writer_component->err, "[error] %s in %s:%d\n", __func__,
645 __FILE__, __LINE__);
646 fprintf(writer_component->err, "[error] Failed to copy event %s\n",
647 bt_ctf_event_class_get_name(writer_event_class));
9ae49d3d 648 goto error;
bc506aa5
JD		 649 }
650
651 int_ret = bt_ctf_stream_append_event(writer_stream, writer_event);
652 if (int_ret < 0) {
bc506aa5
JD		 653 fprintf(writer_component->err, "[error] %s in %s:%d\n", __func__,
654 __FILE__, __LINE__);
655 fprintf(writer_component->err, "[error] Failed to append event %s\n",
656 bt_ctf_event_class_get_name(writer_event_class));
9ae49d3d 657 goto error;
bc506aa5
JD		 658 }
659
660 ret = BT_COMPONENT_STATUS_OK;
9ae49d3d 661 goto end;
bc506aa5 662
9ae49d3d
JD		 663error:
664 ret = BT_COMPONENT_STATUS_ERROR;
665end:
bc506aa5 666 bt_put(writer_event);
bc506aa5 667 bt_put(writer_event_class);
bc506aa5 668 bt_put(writer_stream_class);
bc506aa5 669 bt_put(stream_class);
bc506aa5 670 bt_put(writer_stream);
bc506aa5 671 bt_put(stream);
bc506aa5 672 bt_put(event_class);
bc506aa5
JD		 673 return ret;
674}
BabelTrace - Trace Format Babel Tower
This page took 0.060945 seconds and 4 git commands to generate.