io_u->engine_data = NULL;
free(io);
}
- fprintf(stderr, "issued %lu finished %lu\n", issued, cb_count);
+ log_err("issued %lu finished %lu\n", issued, cb_count);
}
static int fio_gf_io_u_init(struct thread_data *td, struct io_u *io_u)
{
int r = 0;
struct gf_data *g = NULL;
+
#if defined(NOT_YET)
- fprintf(stderr, "the async interface is still very experimental...\n");
+ log_err("the async interface is still very experimental...\n");
#endif
r = fio_gf_setup(td);
if (r) {
} else if (io_u->ddir == DDIR_WRITE) {
open_flags = O_WRONLY;
} else {
- printf("Invalid I/O Operation\n");
+ log_err("hdfs: Invalid I/O Operation\n");
}
hd->curr_file_id = f_id;
hdfsWrite(hd->fs, hd->fp, io_u->xfer_buf,
io_u->xfer_buflen);
} else {
- printf("Invalid I/O Operation\n");
+ log_err("hdfs: Invalid I/O Operation\n");
}
return fio_io_end(td, io_u, ret);
hd->fscount = atol(getenv("FIO_HDFS_FCOUNT"));
hd->fsbs = atol(getenv("FIO_HDFS_BS"));
} else {
- fprintf(stderr,
- "FIO_HDFS_FCOUNT and/or FIO_HDFS_BS not set.\n");
+ log_err("FIO_HDFS_FCOUNT and/or FIO_HDFS_BS not set.\n");
return 1;
}
#endif