int ret;
uint32_t major, minor;
char *index_subpath = NULL;
+ enum lttng_trace_chunk_status status;
ASSERT_LOCKED(stream->lock);
goto end;
}
- ret = lttng_trace_chunk_create_subdirectory(chunk,
+ status = lttng_trace_chunk_create_subdirectory(chunk,
index_subpath);
free(index_subpath);
- if (ret) {
+ if (status != LTTNG_TRACE_CHUNK_STATUS_OK) {
+ ret = -1;
goto end;
}
stream->index_file = lttng_index_file_create_from_trace_chunk(
}
DBG("New stream packet causes stream file rotation: stream_id = %" PRIu64
", current_file_size = %" PRIu64
- ", packet_size = %" PRIu64 ", current_file_index = %" PRIu64
+ ", packet_size = %zu, current_file_index = %" PRIu64
" new_file_index = %" PRIu64,
stream->stream_handle,
stream->tracefile_size_current, packet_size,
stream->metadata_received += packet->size + padding_len;
}
- DBG("Wrote to %sstream %" PRIu64 ": data_length = %" PRIu64 ", padding_length = %" PRIu64,
+ DBG("Wrote to %sstream %" PRIu64 ": data_length = %zu, padding_length = %zu",
stream->is_metadata ? "metadata " : "",
stream->stream_handle,
- packet ? packet->size : 0, padding_len);
+ packet ? packet->size : (size_t) 0, padding_len);
end:
return ret;
}