goto err_open;
}
}
- printf("%d: Requests(+): %d\n", (int)mypid, ++requests);
+ printf("%d: Requests(+): %d\r", (int)mypid, ++requests);
if (sendflush) {
long long int j = i ^ (1LL<<63);
req.type = htonl(NBD_CMD_FLUSH);
retval=-1;
goto err_open;
}
- printf("%d: Requests(+): %d\n", (int)mypid, ++requests);
+ printf("%d: Requests(+): %d\r", (int)mypid, ++requests);
}
}
do {
retval=-1;
goto err_open;
}
- printf("%d: Requests(-): %d\n", (int)mypid, --requests);
+ printf("%d: Requests(-): %d\r", (int)mypid, --requests);
}
} while FD_ISSET(sock, &set);
/* Now wait until we can write again or until a second have
/* Okay, there's something ready for
* reading here */
read_packet_check_header(sock, (testflags & TEST_WRITE)?0:1024, i);
- printf("%d: Requests(-): %d\n", (int)mypid, --requests);
+ printf("%d: Requests(-): %d\r", (int)mypid, --requests);
}
} while (requests);
+ printf("\n");
if(gettimeofday(&stop, NULL)<0) {
retval=-1;
snprintf(errstr, errstr_len, "Could not measure end time: %s", strerror(errno));
}
if (!(printer++ % 1000) || !(readtransactionfile || txqueue.numitems || inflight.numitems) )
- printf("%d: Seq %08lld Queued: %08d Inflight: %08d Done: %08lld\n",
+ printf("%d: Seq %08lld Queued: %08d Inflight: %08d Done: %08lld\r",
(int)mypid,
(long long int) seq,
txqueue.numitems,
}
+ printf("\n");
+
if (gettimeofday(&stop, NULL)<0) {
retval=-1;
snprintf(errstr, errstr_len, "Could not measure end time: %s", strerror(errno));