* LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
* OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
* SOFTWARE.
- *
- * Depends on glibc 2.10 for getline().
*/
-#define _GNU_SOURCE
-#include <config.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <sys/mman.h>
-#include <dirent.h>
+#include <babeltrace/compat/dirent.h>
#include <stdio.h>
#include <stdlib.h>
#include <stdint.h>
#include <errno.h>
#include <string.h>
#include <inttypes.h>
+#include <glib.h>
+#include <glib/gstdio.h>
#include <babeltrace/babeltrace-internal.h>
#include <babeltrace/ctf/types.h>
#include <babeltrace/compat/uuid.h>
#include <babeltrace/compat/utc.h>
+#include <babeltrace/compat/stdio.h>
#include <babeltrace/endian.h>
#define NSEC_PER_USEC 1000UL
ret = sscanf(VERSION, "%u.%u", &major, &minor);
if (ret != 2)
fprintf(stderr, "[warning] Incorrect babeltrace version format\n.");
- babeltrace_uuid_unparse(s_uuid, uuid_str);
+ bt_uuid_unparse(s_uuid, uuid_str);
fprintf(fp, metadata_fmt,
major,
minor,
ti.tm_min = min;
ti.tm_sec = sec;
- ep_sec = babeltrace_timegm(&ti);
+ ep_sec = bt_timegm(&ti);
if (ep_sec != (time_t) -1) {
*ts = (uint64_t) ep_sec * NSEC_PER_SEC
+ (uint64_t) msec * NSEC_PER_MSEC;
printf_debug("read: %s\n", line);
for (;;) {
+ int packet_filled = 0;
+
ctf_dummy_pos(pos, &dummy);
write_event_header(&dummy, line, &tline, len, &tlen, &ts);
if (!ctf_align_pos(&dummy, sizeof(uint8_t) * CHAR_BIT))
- goto error;
+ packet_filled = 1;
if (!ctf_move_pos(&dummy, tlen * CHAR_BIT))
- goto error;
- if (ctf_pos_packet(&dummy)) {
+ packet_filled = 1;
+ if (packet_filled || ctf_pos_packet(&dummy)) {
ctf_pos_pad_packet(pos);
write_packet_header(pos, s_uuid);
write_packet_context(pos);
struct ctf_stream_pos pos;
ssize_t len;
char *line = NULL, *nl;
- size_t linesize;
+ size_t linesize = 0;
int ret;
memset(&pos, 0, sizeof(pos));
fprintf(stderr, "Error in ctf_init_pos\n");
return;
}
+ ctf_packet_seek(&pos.parent, 0, SEEK_CUR);
write_packet_header(&pos, s_uuid);
write_packet_context(&pos);
for (;;) {
- len = getline(&line, &linesize, input);
+ len = bt_getline(&line, &linesize, input);
if (len < 0)
break;
nl = strrchr(line, '\n');
exit(EXIT_SUCCESS);
}
- ret = mkdir(s_outputname, S_IRWXU|S_IRWXG);
+ ret = g_mkdir(s_outputname, S_IRWXU|S_IRWXG);
if (ret) {
- perror("mkdir");
+ perror("g_mkdir");
goto error;
}
perror("opendir");
goto error_rmdir;
}
- dir_fd = dirfd(dir);
+ dir_fd = bt_dirfd(dir);
if (dir_fd < 0) {
perror("dirfd");
goto error_closedir;
goto error_closemetadatafd;
}
- babeltrace_uuid_generate(s_uuid);
+ bt_uuid_generate(s_uuid);
print_metadata(metadata_fp);
trace_text(stdin, fd);