X-Git-Url: https://git.kernel.dk/?p=fio.git;a=blobdiff_plain;f=time.c;h=4f1c13a08a5c6a77d07bb1fe9cc26bb4f84ba868;hp=6d79ecdca3036515f89aa0df5bd9a38b4b7085f8;hb=e417fd6643cb9451441065d5767099062d51205d;hpb=10927316a4bd0e2ceba98e62c062e352c0e312fe

diff --git a/time.c b/time.c
index 6d79ecdc..4f1c13a0 100644
--- a/time.c
+++ b/time.c
@@ -10,7 +10,7 @@ unsigned long long utime_since(struct timeval *s, struct timeval *e)
 {
 	long sec, usec;
 	unsigned long long ret;
-	
+
 	sec = e->tv_sec - s->tv_sec;
 	usec = e->tv_usec - s->tv_usec;
 	if (sec > 0 && usec < 0) {
@@ -23,9 +23,9 @@ unsigned long long utime_since(struct timeval *s, struct timeval *e)
 	 */
 	if (sec < 0 || (sec == 0 && usec < 0))
 		return 0;
-	
+
 	ret = sec * 1000000ULL + usec;
-	
+
 	return ret;
 }
 
@@ -164,6 +164,23 @@ unsigned long mtime_since_genesis(void)
 	return mtime_since_now(&genesis);
 }
 
+int ramp_time_over(struct thread_data *td)
+{
+	struct timeval tv;
+
+	if (!td->o.ramp_time || td->ramp_time_over)
+		return 1;
+
+	fio_gettime(&tv, NULL);
+	if (mtime_since(&td->epoch, &tv) >= td->o.ramp_time * 1000) {
+		td->ramp_time_over = 1;
+		memcpy(&td->start, &tv, sizeof(tv));
+		return 1;
+	}
+
+	return 0;
+}
+
 static void fio_init time_init(void)
 {
 	int i;