1 /* 2 * CDDL HEADER START 3 * 4 * The contents of this file are subject to the terms of the 5 * Common Development and Distribution License (the "License"). 6 * You may not use this file except in compliance with the License. 7 * 8 * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE 9 * or http://opensource.org/licenses/CDDL-1.0. 10 * See the License for the specific language governing permissions 11 * and limitations under the License. 12 * 13 * When distributing Covered Code, include this CDDL HEADER in each 14 * file and include the License file at usr/src/OPENSOLARIS.LICENSE. 15 * If applicable, add the following below this CDDL HEADER, with the 16 * fields enclosed by brackets "[]" replaced with your own identifying 17 * information: Portions Copyright [yyyy] [name of copyright owner] 18 * 19 * CDDL HEADER END 20 */ 21 22 #include <stdlib.h> 23 #include <stdio.h> 24 #include <string.h> 25 #include <sys/mman.h> 26 #include <sys/stat.h> 27 #include <sys/time.h> 28 #include <fcntl.h> 29 #include <unistd.h> 30 #include <time.h> 31 32 static void 33 cleanup(char *file) 34 { 35 (void) remove(file); 36 } 37 38 int 39 main(int argc, char *argv[]) 40 { 41 char *testdir = getenv("TESTDIR"); 42 if (!testdir) { 43 fprintf(stderr, "environment variable TESTDIR not set\n"); 44 return (1); 45 } 46 47 struct stat st; 48 umask(0); 49 if (stat(testdir, &st) != 0 && 50 mkdir(testdir, 0777) != 0) { 51 perror("mkdir"); 52 return (1); 53 } 54 55 if (argc > 3) { 56 fprintf(stderr, "usage: %s " 57 "[run time in mins] " 58 "[max msync time in ms]\n", argv[0]); 59 return (1); 60 } 61 62 int run_time_mins = 1; 63 if (argc >= 2) { 64 run_time_mins = atoi(argv[1]); 65 } 66 67 int max_msync_time_ms = 1000; 68 if (argc >= 3) { 69 max_msync_time_ms = atoi(argv[2]); 70 } 71 72 char filepath[512]; 73 filepath[0] = '\0'; 74 char *file = &filepath[0]; 75 76 (void) snprintf(file, 512, "%s/msync_file", testdir); 77 78 const int LEN = 8; 79 cleanup(file); 80 81 int fd = open(file, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR | 82 S_IRGRP | S_IROTH); 83 84 if (fd == -1) { 85 (void) fprintf(stderr, "%s: %s: ", argv[0], file); 86 perror("open"); 87 return (1); 88 } 89 90 if (ftruncate(fd, LEN) != 0) { 91 perror("ftruncate"); 92 cleanup(file); 93 return (1); 94 } 95 96 void *ptr = mmap(NULL, LEN, PROT_READ | PROT_WRITE, MAP_SHARED, fd, 0); 97 98 if (ptr == MAP_FAILED) { 99 perror("mmap"); 100 cleanup(file); 101 return (1); 102 } 103 104 struct timeval tstart; 105 gettimeofday(&tstart, NULL); 106 107 long long x = 0LL; 108 109 for (;;) { 110 *((long long *)ptr) = x; 111 x++; 112 113 struct timeval t1, t2; 114 gettimeofday(&t1, NULL); 115 if (msync(ptr, LEN, MS_SYNC|MS_INVALIDATE) != 0) { 116 perror("msync"); 117 cleanup(file); 118 return (1); 119 } 120 121 gettimeofday(&t2, NULL); 122 123 double elapsed = (t2.tv_sec - t1.tv_sec) * 1000.0; 124 elapsed += ((t2.tv_usec - t1.tv_usec) / 1000.0); 125 if (elapsed > max_msync_time_ms) { 126 fprintf(stderr, "slow msync: %f ms\n", elapsed); 127 if (munmap(ptr, LEN) != 0) 128 perror("munmap"); 129 cleanup(file); 130 return (1); 131 } 132 133 double elapsed_start = (t2.tv_sec - tstart.tv_sec) * 1000.0; 134 elapsed_start += ((t2.tv_usec - tstart.tv_usec) / 1000.0); 135 if (elapsed_start > run_time_mins * 60 * 1000) { 136 break; 137 } 138 } 139 140 if (munmap(ptr, LEN) != 0) { 141 perror("munmap"); 142 cleanup(file); 143 return (1); 144 } 145 146 if (close(fd) != 0) { 147 perror("close"); 148 } 149 150 cleanup(file); 151 return (0); 152 } 153