X-Git-Url: https://git.kernel.dk/?p=fio.git;a=blobdiff_plain;f=engines%2Flibhdfs.c;h=658cd6aed3ed840d507e5bc42e2ee220623948b9;hp=773d46b47bfc28bd6dba373b27fed13a8b7c0324;hb=7d4a8e7e2b16b900891b886295d1e8493f853b0c;hpb=e411c3014c9635bd5bd56d64c87e8094874ddffe

diff --git a/engines/libhdfs.c b/engines/libhdfs.c
index 773d46b4..658cd6ae 100644
--- a/engines/libhdfs.c
+++ b/engines/libhdfs.c
@@ -87,7 +87,7 @@ static int fio_hdfsio_prep(struct thread_data *td, struct io_u *io_u)
 	} 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;
@@ -142,7 +142,7 @@ static int fio_hdfsio_queue(struct thread_data *td, struct io_u *io_u)
 		    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);
@@ -202,8 +202,7 @@ static int fio_hdfsio_setup(struct thread_data *td)
 			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