X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fceph%2Fqa%2Fworkunits%2Fdirect_io%2Ftest_sync_io.c;fp=src%2Fceph%2Fqa%2Fworkunits%2Fdirect_io%2Ftest_sync_io.c;h=0000000000000000000000000000000000000000;hb=7da45d65be36d36b880cc55c5036e96c24b53f00;hp=f393fa6e8ffd79072468e4a7878bad1655bd3a29;hpb=691462d09d0987b47e112d6ee8740375df3c51b2;p=stor4nfv.git

diff --git a/src/ceph/qa/workunits/direct_io/test_sync_io.c b/src/ceph/qa/workunits/direct_io/test_sync_io.c
deleted file mode 100644
index f393fa6..0000000
--- a/src/ceph/qa/workunits/direct_io/test_sync_io.c
+++ /dev/null
@@ -1,250 +0,0 @@
-#include <sys/types.h>
-#include <sys/stat.h>
-#include <fcntl.h>
-#include <unistd.h>
-#include <stdio.h>
-#include <inttypes.h>
-#include <linux/types.h>
-#include <stdlib.h>
-#include <string.h>
-#include <sys/ioctl.h>
-#include <errno.h>
-
-//#include "../client/ioctl.h"
-
-#include <linux/ioctl.h>
-#define CEPH_IOCTL_MAGIC 0x97
-#define CEPH_IOC_SYNCIO _IO(CEPH_IOCTL_MAGIC, 5)
-
-void write_pattern()
-{
-	printf("writing pattern\n");
-
-	uint64_t i;
-	int r;
-
-	int fd = open("foo", O_CREAT|O_WRONLY, 0644);
-	if (fd < 0) {
-	   r = errno;
-	   printf("write_pattern: error: open() failed with: %d (%s)\n", r, strerror(r));
-	   exit(r);
-	}
-	for (i=0; i<1048576 * sizeof(i); i += sizeof(i)) {
-		r = write(fd, &i, sizeof(i));
-		if (r == -1) {
-			r = errno;
-			printf("write_pattern: error: write() failed with: %d (%s)\n", r, strerror(r));
-			break;
-		}
-	}
-
-	close(fd);
-}
-
-int verify_pattern(char *buf, size_t len, uint64_t off)
-{
-	size_t i;
-
-	for (i = 0; i < len; i += sizeof(uint64_t)) {
-		uint64_t expected = i + off;
-		uint64_t actual = *(uint64_t*)(buf + i);
-		if (expected != actual) {
-			printf("error: offset %llu had %llu\n", (unsigned long long)expected,
-			       (unsigned long long)actual);
-			exit(1);
-		}
-	}
-	return 0;
-}
-
-void generate_pattern(void *buf, size_t len, uint64_t offset)
-{
-	uint64_t *v = buf;
-	size_t i;
-
-	for (i=0; i<len / sizeof(v); i++)
-		v[i] = i * sizeof(v) + offset;
-	verify_pattern(buf, len, offset);
-}
-
-int read_file(int buf_align, uint64_t offset, int len, int direct) {
-
-	printf("read_file buf_align %d offset %llu len %d\n", buf_align,
-	       (unsigned long long)offset, len);
-	void *rawbuf;
-	int r;
-        int flags;
-	int err = 0;
-
-	if(direct)
-	   flags = O_RDONLY|O_DIRECT;
-	else
-	   flags = O_RDONLY;
-
-	int fd = open("foo", flags);
-	if (fd < 0) {
-	   err = errno;
-	   printf("read_file: error: open() failed with: %d (%s)\n", err, strerror(err));
-	   exit(err);
-	}
-
-	if (!direct)
-	   ioctl(fd, CEPH_IOC_SYNCIO);
-
-	if ((r = posix_memalign(&rawbuf, 4096, len + buf_align)) != 0) {
-	   printf("read_file: error: posix_memalign failed with %d", r);
-	   close(fd);
-	   exit (r);
-	}
-
-	void *buf = (char *)rawbuf + buf_align;
-	memset(buf, 0, len);
-	r = pread(fd, buf, len, offset);
-	if (r == -1) {
-	   err = errno;
-	   printf("read_file: error: pread() failed with: %d (%s)\n", err, strerror(err));
-	   goto out;
-	}
-	r = verify_pattern(buf, len, offset);
-
-out:
-	close(fd);
-	free(rawbuf);
-	return r;
-}
-
-int read_direct(int buf_align, uint64_t offset, int len)
-{
-	printf("read_direct buf_align %d offset %llu len %d\n", buf_align,
-	       (unsigned long long)offset, len);
-	return read_file(buf_align, offset, len, 1);
-}
-
-int read_sync(int buf_align, uint64_t offset, int len)
-{
-	printf("read_sync buf_align %d offset %llu len %d\n", buf_align,
-	       (unsigned long long)offset, len);
-	return read_file(buf_align, offset, len, 0);
-}
-
-int write_file(int buf_align, uint64_t offset, int len, int direct)
-{
-	printf("write_file buf_align %d offset %llu len %d\n", buf_align,
-	       (unsigned long long)offset, len);
-	void *rawbuf;
-	int r;
-        int err = 0;
-	int flags;
-	if (direct)
-	   flags = O_WRONLY|O_DIRECT|O_CREAT;
-        else
-	   flags = O_WRONLY|O_CREAT;
-
-	int fd = open("foo", flags, 0644);
-	if (fd < 0) {
-	   int err = errno;
-	   printf("write_file: error: open() failed with: %d (%s)\n", err, strerror(err));
-	   exit(err);
-	}
-
-	if ((r = posix_memalign(&rawbuf, 4096, len + buf_align)) != 0) {
-	   printf("write_file: error: posix_memalign failed with %d", r);
-	   err = r;
-	   goto out_close;
-	}
-
-	if (!direct)
-	   ioctl(fd, CEPH_IOC_SYNCIO);
-
-	void *buf = (char *)rawbuf + buf_align;
-
-	generate_pattern(buf, len, offset);
-
-	r = pwrite(fd, buf, len, offset);
-	close(fd);
-
-	fd = open("foo", O_RDONLY);
-	if (fd < 0) {
-	   err = errno;
-	   printf("write_file: error: open() failed with: %d (%s)\n", err, strerror(err));
-	   free(rawbuf);
-	   goto out_unlink;
-	}
-	void *buf2 = malloc(len);
-	if (!buf2) {
-	   err = -ENOMEM;
-	   printf("write_file: error: malloc failed\n");
-	   goto out_free;
-	}
-
-	memset(buf2, 0, len);
-	r = pread(fd, buf2, len, offset);
-	if (r == -1) {
-	   err = errno;
-	   printf("write_file: error: pread() failed with: %d (%s)\n", err, strerror(err));
-	   goto out_free_buf;
-	}
-	r = verify_pattern(buf2, len, offset);
-
-out_free_buf:
-	free(buf2);
-out_free:
-	free(rawbuf);
-out_close:
-	close(fd);
-out_unlink:
-	unlink("foo");
-	if (err)
-	   exit(err);
-	return r;
-}
-
-int write_direct(int buf_align, uint64_t offset, int len)
-{
-	printf("write_direct buf_align %d offset %llu len %d\n", buf_align,
-	       (unsigned long long)offset, len);
-	return write_file (buf_align, offset, len, 1);
-}
-
-int write_sync(int buf_align, uint64_t offset, int len)
-{
-	printf("write_sync buf_align %d offset %llu len %d\n", buf_align,
-	       (unsigned long long)offset, len);
-	return write_file (buf_align, offset, len, 0);
-}
-
-int main(int argc, char **argv)
-{
-	uint64_t i, j, k;
-	int read = 1;
-	int write = 1;
-
-	if (argc >= 2 && strcmp(argv[1], "read") == 0)
-		write = 0;
-	if (argc >= 2 && strcmp(argv[1], "write") == 0)
-		read = 0;
-
-	if (read) {
-		write_pattern();
-		
-		for (i = 0; i < 4096; i += 512)
-			for (j = 4*1024*1024 - 4096; j < 4*1024*1024 + 4096; j += 512)
-				for (k = 1024; k <= 16384; k *= 2) {
-					read_direct(i, j, k);
-					read_sync(i, j, k);
-				}
-		
-	}
-	unlink("foo");
-	if (write) {
-		for (i = 0; i < 4096; i += 512)
-			for (j = 4*1024*1024 - 4096 + 512; j < 4*1024*1024 + 4096; j += 512)
-				for (k = 1024; k <= 16384; k *= 2) {
-					write_direct(i, j, k);
-					write_sync(i, j, k);
-				}
-	}
-	
-
-	return 0;
-}