diff options
Diffstat (limited to 'src/test/old/test_short_seek_read.c')
-rw-r--r-- | src/test/old/test_short_seek_read.c | 70 |
1 files changed, 70 insertions, 0 deletions
diff --git a/src/test/old/test_short_seek_read.c b/src/test/old/test_short_seek_read.c new file mode 100644 index 00000000..9737025a --- /dev/null +++ b/src/test/old/test_short_seek_read.c @@ -0,0 +1,70 @@ +#include "include/types.h" +#include "common/Clock.h" + +#include <linux/fs.h> +#include <unistd.h> +#include <sys/ioctl.h> +#include <sys/types.h> +#include <sys/stat.h> +#include <fcntl.h> +#include <string.h> +#include <errno.h> + +int main(int argc, char **argv) +{ + char *fn = argv[1]; + + int fd = ::open(fn, O_RDWR|O_DIRECT);//|O_SYNC|O_DIRECT); + if (fd < 0) return 1; + + uint64_t bytes = 0; + int r = ioctl(fd, BLKGETSIZE64, &bytes); + uint64_t numblocks = bytes / 4096; + + //uint64_t numblocks = atoll(argv[2]) * 4;// / 4096; + int count = 1000; + + cout << "fn " << fn << endl; + cout << "numblocks " << numblocks << endl; + + int blocks = 1; + while (blocks <= 1024) { + //cout << "fd is " << fd << endl; + + void *buf; + ::posix_memalign(&buf, 4096, 4096*blocks); + + int s = blocks*4096; + + double timeper = 0.0; + for (int i=0; i<count; i++) { + off64_t so, o = (lrand48() % numblocks) * 4096; + //cout << "s = " << s << " o = " << o << endl; + //::lseek(fd, o, SEEK_SET); + lseek64(fd, o, SEEK_SET); + int r = ::read(fd, buf, 4096); + //int r = ::read(fd, buf, s); + if (r < 0) cout << "r = " << r << " " << strerror(errno) << endl; + + int range = 1000000/4096; + so = o + 4096*((rand() % range) );//- range/2); + //cout << o << " " << so << " " << (so-o) << endl; + + utime_t start = ceph_clock_now(); + lseek64(fd, so, SEEK_SET); + r = ::read(fd, buf, blocks*4096); + utime_t end = ceph_clock_now(); + timeper += (end-start); + } + + timeper /= count; + cout << blocks << "\t" << s << "\t" << (double)timeper << endl; + + blocks *= 2; + free(buf); + } + + close(fd); + +} + |