* [PATCH 1/2] makedumpfile: Use monotonic clock to calculate ETA and stats
@ 2018-06-20 9:50 Petr Tesarik
2018-06-20 9:50 ` [PATCH 2/2] makedumpfile: Check if clock_gettime() requires -lrt Petr Tesarik
` (2 more replies)
0 siblings, 3 replies; 5+ messages in thread
From: Petr Tesarik @ 2018-06-20 9:50 UTC (permalink / raw)
To: lijiang, kexec-ml; +Cc: Petr Tesarik
Execution time should be always measured by a monotonic clock,
because the system clock may be affected by discontinuous jumps,
e.g. when time is set manually by an admin.
Signed-off-by: Petr Tesarik <ptesarik@suse.com>
---
makedumpfile.c | 84 +++++++++++++++++++++++++++++-----------------------------
print_info.c | 30 +++++++++++----------
print_info.h | 6 ++---
3 files changed, 61 insertions(+), 59 deletions(-)
diff --git a/makedumpfile.c b/makedumpfile.c
index 450825b..5908b5a 100644
--- a/makedumpfile.c
+++ b/makedumpfile.c
@@ -5364,7 +5364,7 @@ _exclude_free_page(struct cycle *cycle)
{
int i, nr_zones, num_nodes, node;
unsigned long node_zones, zone, spanned_pages, pgdat;
- struct timeval tv_start;
+ struct timespec ts_start;
if ((node = next_online_node(0)) < 0) {
ERRMSG("Can't get next online node.\n");
@@ -5374,7 +5374,7 @@ _exclude_free_page(struct cycle *cycle)
ERRMSG("Can't get pgdat list.\n");
return FALSE;
}
- gettimeofday(&tv_start, NULL);
+ clock_gettime(CLOCK_MONOTONIC, &ts_start);
for (num_nodes = 1; num_nodes <= vt.numnodes; num_nodes++) {
@@ -5420,7 +5420,7 @@ _exclude_free_page(struct cycle *cycle)
* print [100 %]
*/
print_progress(PROGRESS_FREE_PAGES, vt.numnodes, vt.numnodes, NULL);
- print_execution_time(PROGRESS_FREE_PAGES, &tv_start);
+ print_execution_time(PROGRESS_FREE_PAGES, &ts_start);
return TRUE;
}
@@ -5567,7 +5567,7 @@ create_1st_bitmap_file(void)
char buf[info->page_size];
mdf_pfn_t pfn, pfn_start, pfn_end, pfn_bitmap1;
unsigned long long phys_start, phys_end;
- struct timeval tv_start;
+ struct timespec ts_start;
off_t offset_page;
if (info->flag_refiltering)
@@ -5597,7 +5597,7 @@ create_1st_bitmap_file(void)
offset_page += info->page_size;
}
- gettimeofday(&tv_start, NULL);
+ clock_gettime(CLOCK_MONOTONIC, &ts_start);
/*
* If page is on memory hole, set bit on the 1st-bitmap.
@@ -5629,7 +5629,7 @@ create_1st_bitmap_file(void)
*/
if (!info->flag_mem_usage) {
print_progress(PROGRESS_HOLES, info->max_mapnr, info->max_mapnr, NULL);
- print_execution_time(PROGRESS_HOLES, &tv_start);
+ print_execution_time(PROGRESS_HOLES, &ts_start);
}
if (!sync_1st_bitmap())
@@ -5731,7 +5731,7 @@ create_bitmap_from_memhole(struct cycle *cycle, struct dump_bitmap *bitmap, int
mdf_pfn_t pfn_start_roundup, pfn_end_round;
unsigned long pfn_start_byte, pfn_end_byte;
unsigned int num_pt_loads = get_num_pt_loads();
- struct timeval tv_start;
+ struct timespec ts_start;
/*
* At first, clear all the bits on the bitmap.
@@ -5741,7 +5741,7 @@ create_bitmap_from_memhole(struct cycle *cycle, struct dump_bitmap *bitmap, int
/*
* If page is on memory hole, set bit on the bitmap.
*/
- gettimeofday(&tv_start, NULL);
+ clock_gettime(CLOCK_MONOTONIC, &ts_start);
for (i = 0; get_pt_load(i, &phys_start, &phys_end, NULL, NULL); i++) {
pfn_start = MAX(paddr_to_pfn(phys_start), cycle->start_pfn);
pfn_end = MIN(paddr_to_pfn(phys_end), cycle->end_pfn);
@@ -5786,7 +5786,7 @@ create_bitmap_from_memhole(struct cycle *cycle, struct dump_bitmap *bitmap, int
* print 100 %
*/
print_progress(PROGRESS_HOLES, info->max_mapnr, info->max_mapnr, NULL);
- print_execution_time(PROGRESS_HOLES, &tv_start);
+ print_execution_time(PROGRESS_HOLES, &ts_start);
return TRUE;
}
@@ -6046,14 +6046,14 @@ exclude_unnecessary_pages(struct cycle *cycle)
{
unsigned int mm;
struct mem_map_data *mmd;
- struct timeval tv_start;
+ struct timespec ts_start;
if (is_xen_memory() && !info->dom0_mapnr) {
ERRMSG("Can't get max domain-0 PFN for excluding pages.\n");
return FALSE;
}
- gettimeofday(&tv_start, NULL);
+ clock_gettime(CLOCK_MONOTONIC, &ts_start);
for (mm = 0; mm < info->num_mem_map; mm++) {
@@ -6077,7 +6077,7 @@ exclude_unnecessary_pages(struct cycle *cycle)
*/
if (!info->flag_mem_usage) {
print_progress(PROGRESS_UNN_PAGES, info->num_mem_map, info->num_mem_map, NULL);
- print_execution_time(PROGRESS_UNN_PAGES, &tv_start);
+ print_execution_time(PROGRESS_UNN_PAGES, &ts_start);
}
return TRUE;
@@ -7475,7 +7475,7 @@ write_elf_pages_cyclic(struct cache_data *cd_header, struct cache_data *cd_page)
unsigned long frac_head, frac_tail;
off_t off_seg_load, off_memory;
Elf64_Phdr load;
- struct timeval tv_start;
+ struct timespec ts_start;
struct cycle cycle = {0};
if (!info->flag_elf_dumpfile)
@@ -7500,7 +7500,7 @@ write_elf_pages_cyclic(struct cache_data *cd_header, struct cache_data *cd_page)
if (!(phnum = get_phnum_memory()))
return FALSE;
- gettimeofday(&tv_start, NULL);
+ clock_gettime(CLOCK_MONOTONIC, &ts_start);
for (i = 0; i < phnum; i++) {
if (!get_phdr_memory(i, &load))
@@ -7548,7 +7548,7 @@ write_elf_pages_cyclic(struct cache_data *cd_header, struct cache_data *cd_page)
}
if ((num_dumped % per) == 0)
- print_progress(PROGRESS_COPY, num_dumped, num_dumpable, &tv_start);
+ print_progress(PROGRESS_COPY, num_dumped, num_dumpable, &ts_start);
num_dumped++;
@@ -7667,8 +7667,8 @@ write_elf_pages_cyclic(struct cache_data *cd_header, struct cache_data *cd_page)
/*
* print [100 %]
*/
- print_progress(PROGRESS_COPY, num_dumpable, num_dumpable, &tv_start);
- print_execution_time(PROGRESS_COPY, &tv_start);
+ print_progress(PROGRESS_COPY, num_dumpable, num_dumpable, &ts_start);
+ print_execution_time(PROGRESS_COPY, &ts_start);
PROGRESS_MSG("\n");
return TRUE;
@@ -8004,8 +8004,8 @@ write_kdump_pages_parallel_cyclic(struct cache_data *cd_header,
mdf_pfn_t per;
mdf_pfn_t start_pfn, end_pfn;
struct page_desc pd;
- struct timeval tv_start;
- struct timeval last, new;
+ struct timespec ts_start;
+ struct timespec last, new;
pthread_t **threads = NULL;
struct thread_args *kdump_thread_args = NULL;
void *thread_result;
@@ -8043,7 +8043,7 @@ write_kdump_pages_parallel_cyclic(struct cache_data *cd_header,
per = info->num_dumpable / 10000;
per = per ? per : 1;
- gettimeofday(&tv_start, NULL);
+ clock_gettime(CLOCK_MONOTONIC, &ts_start);
start_pfn = cycle->start_pfn;
end_pfn = cycle->end_pfn;
@@ -8091,7 +8091,7 @@ write_kdump_pages_parallel_cyclic(struct cache_data *cd_header,
* The next pfn is smallest pfn in all page_flag_buf.
*/
sem_wait(&info->page_flag_buf_sem);
- gettimeofday(&last, NULL);
+ clock_gettime(CLOCK_MONOTONIC, &last);
while (1) {
current_pfn = end_pfn;
@@ -8134,7 +8134,7 @@ write_kdump_pages_parallel_cyclic(struct cache_data *cd_header,
* So we should recheck.
*/
if (info->page_flag_buf[consuming]->ready != FLAG_READY) {
- gettimeofday(&new, NULL);
+ clock_gettime(CLOCK_MONOTONIC, &new);
if (new.tv_sec - last.tv_sec > WAIT_TIME) {
ERRMSG("Can't get data of pfn.\n");
goto out;
@@ -8147,7 +8147,7 @@ write_kdump_pages_parallel_cyclic(struct cache_data *cd_header,
}
if ((num_dumped % per) == 0)
- print_progress(PROGRESS_COPY, num_dumped, info->num_dumpable, &tv_start);
+ print_progress(PROGRESS_COPY, num_dumped, info->num_dumpable, &ts_start);
num_dumped++;
@@ -8183,8 +8183,8 @@ finish:
/*
* print [100 %]
*/
- print_progress(PROGRESS_COPY, num_dumped, info->num_dumpable, &tv_start);
- print_execution_time(PROGRESS_COPY, &tv_start);
+ print_progress(PROGRESS_COPY, num_dumped, info->num_dumpable, &ts_start);
+ print_execution_time(PROGRESS_COPY, &ts_start);
PROGRESS_MSG("\n");
out:
@@ -8234,7 +8234,7 @@ write_kdump_pages_cyclic(struct cache_data *cd_header, struct cache_data *cd_pag
struct page_desc pd;
unsigned char buf[info->page_size], *buf_out = NULL;
unsigned long len_buf_out;
- struct timeval tv_start;
+ struct timespec ts_start;
const off_t failed = (off_t)-1;
unsigned long len_buf_out_zlib, len_buf_out_lzo, len_buf_out_snappy;
@@ -8295,12 +8295,12 @@ write_kdump_pages_cyclic(struct cache_data *cd_header, struct cache_data *cd_pag
end_pfn = info->split_end_pfn;
}
- gettimeofday(&tv_start, NULL);
+ clock_gettime(CLOCK_MONOTONIC, &ts_start);
for (pfn = start_pfn; pfn < end_pfn; pfn++) {
if ((num_dumped % per) == 0)
- print_progress(PROGRESS_COPY, num_dumped, info->num_dumpable, &tv_start);
+ print_progress(PROGRESS_COPY, num_dumped, info->num_dumpable, &ts_start);
/*
* Check the excluded page.
@@ -8380,8 +8380,8 @@ out:
free(wrkmem);
#endif
- print_progress(PROGRESS_COPY, num_dumped, info->num_dumpable, &tv_start);
- print_execution_time(PROGRESS_COPY, &tv_start);
+ print_progress(PROGRESS_COPY, num_dumped, info->num_dumpable, &ts_start);
+ print_execution_time(PROGRESS_COPY, &ts_start);
return ret;
}
@@ -8743,7 +8743,7 @@ write_kdump_pages_and_bitmap_cyclic(struct cache_data *cd_header, struct cache_d
off_t offset_data=0;
struct disk_dump_header *dh = info->dump_header;
unsigned char buf[info->page_size];
- struct timeval tv_start;
+ struct timespec ts_start;
cd_header->offset
= (DISKDUMP_HEADER_BLOCKS + dh->sub_hdr_size + dh->bitmap_blocks)
@@ -8825,7 +8825,7 @@ write_kdump_pages_and_bitmap_cyclic(struct cache_data *cd_header, struct cache_d
}
free_bitmap2_buffer();
- gettimeofday(&tv_start, NULL);
+ clock_gettime(CLOCK_MONOTONIC, &ts_start);
/*
* Write the remainder.
@@ -8838,8 +8838,8 @@ write_kdump_pages_and_bitmap_cyclic(struct cache_data *cd_header, struct cache_d
/*
* print [100 %]
*/
- print_progress(PROGRESS_COPY, num_dumped, info->num_dumpable, &tv_start);
- print_execution_time(PROGRESS_COPY, &tv_start);
+ print_progress(PROGRESS_COPY, num_dumped, info->num_dumpable, &ts_start);
+ print_execution_time(PROGRESS_COPY, &ts_start);
PROGRESS_MSG("\n");
return TRUE;
@@ -9559,10 +9559,10 @@ exclude_xen4_user_domain(void)
int
exclude_xen_user_domain(void)
{
- struct timeval tv_start;
+ struct timespec ts_start;
int ret;
- gettimeofday(&tv_start, NULL);
+ clock_gettime(CLOCK_MONOTONIC, &ts_start);
if (info->xen_crash_info.com &&
info->xen_crash_info.com->xen_major_version >= 4)
@@ -9574,7 +9574,7 @@ exclude_xen_user_domain(void)
* print [100 %]
*/
print_progress(PROGRESS_XEN_DOMAIN, 1, 1, NULL);
- print_execution_time(PROGRESS_XEN_DOMAIN, &tv_start);
+ print_execution_time(PROGRESS_XEN_DOMAIN, &ts_start);
return ret;
}
@@ -10498,7 +10498,7 @@ reassemble_kdump_pages(void)
struct disk_dump_header dh;
struct page_desc pd, pd_zero;
struct cache_data cd_pd, cd_data;
- struct timeval tv_start;
+ struct timespec ts_start;
char *data = NULL;
unsigned long data_buf_size = info->page_size;
@@ -10534,7 +10534,7 @@ reassemble_kdump_pages(void)
/*
* Write page header of zero-filled page.
*/
- gettimeofday(&tv_start, NULL);
+ clock_gettime(CLOCK_MONOTONIC, &ts_start);
if (info->dump_level & DL_EXCLUDE_ZERO) {
/*
* makedumpfile outputs the data of zero-filled page at first
@@ -10569,7 +10569,7 @@ reassemble_kdump_pages(void)
num_dumped++;
- print_progress(PROGRESS_COPY, num_dumped, num_dumpable, &tv_start);
+ print_progress(PROGRESS_COPY, num_dumped, num_dumpable, &ts_start);
if (lseek(fd, offset_ph_org, SEEK_SET) < 0) {
ERRMSG("Can't seek a file(%s). %s\n",
@@ -10666,8 +10666,8 @@ reassemble_kdump_pages(void)
size_eraseinfo))
goto out;
}
- print_progress(PROGRESS_COPY, num_dumpable, num_dumpable, &tv_start);
- print_execution_time(PROGRESS_COPY, &tv_start);
+ print_progress(PROGRESS_COPY, num_dumpable, num_dumpable, &ts_start);
+ print_execution_time(PROGRESS_COPY, &ts_start);
ret = TRUE;
out:
diff --git a/print_info.c b/print_info.c
index 6bfcd11..732d5b8 100644
--- a/print_info.c
+++ b/print_info.c
@@ -19,6 +19,8 @@
#define PROGRESS_MAXLEN "50"
+#define NSEC_PER_SEC 1000000000L
+
int message_level;
int flag_strerr_message;
int flag_ignore_r_char; /* 0: '\r' is effective. 1: not effective. */
@@ -338,16 +340,16 @@ print_usage(void)
MSG("\n");
}
-static void calc_delta(struct timeval *tv_start, struct timeval *delta)
+static void calc_delta(struct timespec *ts_start, struct timespec *delta)
{
- struct timeval tv_end;
+ struct timespec ts_end;
- gettimeofday(&tv_end, NULL);
- delta->tv_sec = tv_end.tv_sec - tv_start->tv_sec;
- delta->tv_usec = tv_end.tv_usec - tv_start->tv_usec;
- if (delta->tv_usec < 0) {
+ clock_gettime(CLOCK_MONOTONIC, &ts_end);
+ delta->tv_sec = ts_end.tv_sec - ts_start->tv_sec;
+ delta->tv_nsec = ts_end.tv_nsec - ts_start->tv_nsec;
+ if (delta->tv_nsec < 0) {
delta->tv_sec--;
- delta->tv_usec += 1000000;
+ delta->tv_nsec += NSEC_PER_SEC;
}
}
@@ -371,14 +373,14 @@ static int eta_to_human_short (unsigned long secs, char* msg)
void
-print_progress(const char *msg, unsigned long current, unsigned long end, struct timeval *start)
+print_progress(const char *msg, unsigned long current, unsigned long end, struct timespec *start)
{
unsigned progress; /* in promilles (tenths of a percent) */
time_t tm;
static time_t last_time = 0;
static unsigned int lapse = 0;
static const char *spinner = "/|\\-";
- struct timeval delta;
+ struct timespec delta;
unsigned long eta;
char eta_msg[16] = " ";
@@ -393,7 +395,7 @@ print_progress(const char *msg, unsigned long current, unsigned long end, struct
if (start != NULL && progress != 0) {
calc_delta(start, &delta);
- eta = 1000 * delta.tv_sec + delta.tv_usec / 1000;
+ eta = 1000 * delta.tv_sec + delta.tv_nsec / (NSEC_PER_SEC / 1000);
eta = eta / progress - delta.tv_sec;
eta_to_human_short(eta, eta_msg);
}
@@ -411,12 +413,12 @@ print_progress(const char *msg, unsigned long current, unsigned long end, struct
}
void
-print_execution_time(char *step_name, struct timeval *tv_start)
+print_execution_time(char *step_name, struct timespec *ts_start)
{
- struct timeval delta;
+ struct timespec delta;
- calc_delta(tv_start, &delta);
+ calc_delta(ts_start, &delta);
REPORT_MSG("STEP [%s] : %ld.%06ld seconds\n",
- step_name, delta.tv_sec, delta.tv_usec);
+ step_name, delta.tv_sec, delta.tv_nsec / 1000);
}
diff --git a/print_info.h b/print_info.h
index 1ce3593..49b70f4 100644
--- a/print_info.h
+++ b/print_info.h
@@ -17,7 +17,7 @@
#define _PRINT_INFO_H
#include <stdio.h>
-#include <sys/time.h>
+#include <time.h>
extern int message_level;
extern int flag_strerr_message;
@@ -25,9 +25,9 @@ extern int flag_ignore_r_char;
void show_version(void);
void print_usage(void);
-void print_progress(const char *msg, unsigned long current, unsigned long end, struct timeval *start);
+void print_progress(const char *msg, unsigned long current, unsigned long end, struct timespec *start);
-void print_execution_time(char *step_name, struct timeval *tv_start);
+void print_execution_time(char *step_name, struct timespec *ts_start);
/*
* Message texts
--
2.16.4
_______________________________________________
kexec mailing list
kexec@lists.infradead.org
http://lists.infradead.org/mailman/listinfo/kexec
^ permalink raw reply related [flat|nested] 5+ messages in thread
* [PATCH 2/2] makedumpfile: Check if clock_gettime() requires -lrt
2018-06-20 9:50 [PATCH 1/2] makedumpfile: Use monotonic clock to calculate ETA and stats Petr Tesarik
@ 2018-06-20 9:50 ` Petr Tesarik
2018-06-29 7:26 ` [PATCH 1/2] makedumpfile: Use monotonic clock to calculate ETA and stats lijiang
2018-07-06 13:40 ` Kazuhito Hagio
2 siblings, 0 replies; 5+ messages in thread
From: Petr Tesarik @ 2018-06-20 9:50 UTC (permalink / raw)
To: lijiang, kexec-ml; +Cc: Petr Tesarik
For glibc versions before 2.17, clock_gettime() was contained in a
separate library and required linking with -lrt.
Signed-off-by: Petr Tesarik <ptesarik@suse.com>
---
Makefile | 12 ++++++++++++
1 file changed, 12 insertions(+)
diff --git a/Makefile b/Makefile
index e870b13..9c24387 100644
--- a/Makefile
+++ b/Makefile
@@ -68,6 +68,18 @@ endif
LIBS := -lpthread $(LIBS)
+try-run = $(shell set -e; \
+ TMP=".$$$$.tmp"; \
+ if ($(1)) >/dev/null 2>&1; \
+ then echo "$(2)"; \
+ else echo "$(3)"; \
+ fi; \
+ rm -f "$$TMP")
+
+LINK_TEST_PROG="int clock_gettime(); int main(){ return clock_gettime(); }"
+LIBS := $(LIBS) $(call try-run,\
+ echo $(LINK_TEST_PROG) | $(CC) $(CFLAGS) -o "$$TMP" -x c -,,-lrt)
+
all: makedumpfile
$(OBJ_PART): $(SRC_PART)
--
2.16.4
_______________________________________________
kexec mailing list
kexec@lists.infradead.org
http://lists.infradead.org/mailman/listinfo/kexec
^ permalink raw reply related [flat|nested] 5+ messages in thread
* Re: [PATCH 1/2] makedumpfile: Use monotonic clock to calculate ETA and stats
2018-06-20 9:50 [PATCH 1/2] makedumpfile: Use monotonic clock to calculate ETA and stats Petr Tesarik
2018-06-20 9:50 ` [PATCH 2/2] makedumpfile: Check if clock_gettime() requires -lrt Petr Tesarik
@ 2018-06-29 7:26 ` lijiang
2018-06-29 13:49 ` Kazuhito Hagio
2018-07-06 13:40 ` Kazuhito Hagio
2 siblings, 1 reply; 5+ messages in thread
From: lijiang @ 2018-06-29 7:26 UTC (permalink / raw)
To: Petr Tesarik, kexec-ml; +Cc: mas-tachibana
在 2018年06月20日 17:50, Petr Tesarik 写道:
> Execution time should be always measured by a monotonic clock,
> because the system clock may be affected by discontinuous jumps,
> e.g. when time is set manually by an admin.
>
> Signed-off-by: Petr Tesarik <ptesarik@suse.com>
> ---
That might be better if CC Masaki.
Thanks.
Lianbo
> makedumpfile.c | 84 +++++++++++++++++++++++++++++-----------------------------
> print_info.c | 30 +++++++++++----------
> print_info.h | 6 ++---
> 3 files changed, 61 insertions(+), 59 deletions(-)
>
> diff --git a/makedumpfile.c b/makedumpfile.c
> index 450825b..5908b5a 100644
> --- a/makedumpfile.c
> +++ b/makedumpfile.c
> @@ -5364,7 +5364,7 @@ _exclude_free_page(struct cycle *cycle)
> {
> int i, nr_zones, num_nodes, node;
> unsigned long node_zones, zone, spanned_pages, pgdat;
> - struct timeval tv_start;
> + struct timespec ts_start;
>
> if ((node = next_online_node(0)) < 0) {
> ERRMSG("Can't get next online node.\n");
> @@ -5374,7 +5374,7 @@ _exclude_free_page(struct cycle *cycle)
> ERRMSG("Can't get pgdat list.\n");
> return FALSE;
> }
> - gettimeofday(&tv_start, NULL);
> + clock_gettime(CLOCK_MONOTONIC, &ts_start);
>
> for (num_nodes = 1; num_nodes <= vt.numnodes; num_nodes++) {
>
> @@ -5420,7 +5420,7 @@ _exclude_free_page(struct cycle *cycle)
> * print [100 %]
> */
> print_progress(PROGRESS_FREE_PAGES, vt.numnodes, vt.numnodes, NULL);
> - print_execution_time(PROGRESS_FREE_PAGES, &tv_start);
> + print_execution_time(PROGRESS_FREE_PAGES, &ts_start);
>
> return TRUE;
> }
> @@ -5567,7 +5567,7 @@ create_1st_bitmap_file(void)
> char buf[info->page_size];
> mdf_pfn_t pfn, pfn_start, pfn_end, pfn_bitmap1;
> unsigned long long phys_start, phys_end;
> - struct timeval tv_start;
> + struct timespec ts_start;
> off_t offset_page;
>
> if (info->flag_refiltering)
> @@ -5597,7 +5597,7 @@ create_1st_bitmap_file(void)
> offset_page += info->page_size;
> }
>
> - gettimeofday(&tv_start, NULL);
> + clock_gettime(CLOCK_MONOTONIC, &ts_start);
>
> /*
> * If page is on memory hole, set bit on the 1st-bitmap.
> @@ -5629,7 +5629,7 @@ create_1st_bitmap_file(void)
> */
> if (!info->flag_mem_usage) {
> print_progress(PROGRESS_HOLES, info->max_mapnr, info->max_mapnr, NULL);
> - print_execution_time(PROGRESS_HOLES, &tv_start);
> + print_execution_time(PROGRESS_HOLES, &ts_start);
> }
>
> if (!sync_1st_bitmap())
> @@ -5731,7 +5731,7 @@ create_bitmap_from_memhole(struct cycle *cycle, struct dump_bitmap *bitmap, int
> mdf_pfn_t pfn_start_roundup, pfn_end_round;
> unsigned long pfn_start_byte, pfn_end_byte;
> unsigned int num_pt_loads = get_num_pt_loads();
> - struct timeval tv_start;
> + struct timespec ts_start;
>
> /*
> * At first, clear all the bits on the bitmap.
> @@ -5741,7 +5741,7 @@ create_bitmap_from_memhole(struct cycle *cycle, struct dump_bitmap *bitmap, int
> /*
> * If page is on memory hole, set bit on the bitmap.
> */
> - gettimeofday(&tv_start, NULL);
> + clock_gettime(CLOCK_MONOTONIC, &ts_start);
> for (i = 0; get_pt_load(i, &phys_start, &phys_end, NULL, NULL); i++) {
> pfn_start = MAX(paddr_to_pfn(phys_start), cycle->start_pfn);
> pfn_end = MIN(paddr_to_pfn(phys_end), cycle->end_pfn);
> @@ -5786,7 +5786,7 @@ create_bitmap_from_memhole(struct cycle *cycle, struct dump_bitmap *bitmap, int
> * print 100 %
> */
> print_progress(PROGRESS_HOLES, info->max_mapnr, info->max_mapnr, NULL);
> - print_execution_time(PROGRESS_HOLES, &tv_start);
> + print_execution_time(PROGRESS_HOLES, &ts_start);
>
> return TRUE;
> }
> @@ -6046,14 +6046,14 @@ exclude_unnecessary_pages(struct cycle *cycle)
> {
> unsigned int mm;
> struct mem_map_data *mmd;
> - struct timeval tv_start;
> + struct timespec ts_start;
>
> if (is_xen_memory() && !info->dom0_mapnr) {
> ERRMSG("Can't get max domain-0 PFN for excluding pages.\n");
> return FALSE;
> }
>
> - gettimeofday(&tv_start, NULL);
> + clock_gettime(CLOCK_MONOTONIC, &ts_start);
>
> for (mm = 0; mm < info->num_mem_map; mm++) {
>
> @@ -6077,7 +6077,7 @@ exclude_unnecessary_pages(struct cycle *cycle)
> */
> if (!info->flag_mem_usage) {
> print_progress(PROGRESS_UNN_PAGES, info->num_mem_map, info->num_mem_map, NULL);
> - print_execution_time(PROGRESS_UNN_PAGES, &tv_start);
> + print_execution_time(PROGRESS_UNN_PAGES, &ts_start);
> }
>
> return TRUE;
> @@ -7475,7 +7475,7 @@ write_elf_pages_cyclic(struct cache_data *cd_header, struct cache_data *cd_page)
> unsigned long frac_head, frac_tail;
> off_t off_seg_load, off_memory;
> Elf64_Phdr load;
> - struct timeval tv_start;
> + struct timespec ts_start;
> struct cycle cycle = {0};
>
> if (!info->flag_elf_dumpfile)
> @@ -7500,7 +7500,7 @@ write_elf_pages_cyclic(struct cache_data *cd_header, struct cache_data *cd_page)
> if (!(phnum = get_phnum_memory()))
> return FALSE;
>
> - gettimeofday(&tv_start, NULL);
> + clock_gettime(CLOCK_MONOTONIC, &ts_start);
>
> for (i = 0; i < phnum; i++) {
> if (!get_phdr_memory(i, &load))
> @@ -7548,7 +7548,7 @@ write_elf_pages_cyclic(struct cache_data *cd_header, struct cache_data *cd_page)
> }
>
> if ((num_dumped % per) == 0)
> - print_progress(PROGRESS_COPY, num_dumped, num_dumpable, &tv_start);
> + print_progress(PROGRESS_COPY, num_dumped, num_dumpable, &ts_start);
>
> num_dumped++;
>
> @@ -7667,8 +7667,8 @@ write_elf_pages_cyclic(struct cache_data *cd_header, struct cache_data *cd_page)
> /*
> * print [100 %]
> */
> - print_progress(PROGRESS_COPY, num_dumpable, num_dumpable, &tv_start);
> - print_execution_time(PROGRESS_COPY, &tv_start);
> + print_progress(PROGRESS_COPY, num_dumpable, num_dumpable, &ts_start);
> + print_execution_time(PROGRESS_COPY, &ts_start);
> PROGRESS_MSG("\n");
>
> return TRUE;
> @@ -8004,8 +8004,8 @@ write_kdump_pages_parallel_cyclic(struct cache_data *cd_header,
> mdf_pfn_t per;
> mdf_pfn_t start_pfn, end_pfn;
> struct page_desc pd;
> - struct timeval tv_start;
> - struct timeval last, new;
> + struct timespec ts_start;
> + struct timespec last, new;
> pthread_t **threads = NULL;
> struct thread_args *kdump_thread_args = NULL;
> void *thread_result;
> @@ -8043,7 +8043,7 @@ write_kdump_pages_parallel_cyclic(struct cache_data *cd_header,
> per = info->num_dumpable / 10000;
> per = per ? per : 1;
>
> - gettimeofday(&tv_start, NULL);
> + clock_gettime(CLOCK_MONOTONIC, &ts_start);
>
> start_pfn = cycle->start_pfn;
> end_pfn = cycle->end_pfn;
> @@ -8091,7 +8091,7 @@ write_kdump_pages_parallel_cyclic(struct cache_data *cd_header,
> * The next pfn is smallest pfn in all page_flag_buf.
> */
> sem_wait(&info->page_flag_buf_sem);
> - gettimeofday(&last, NULL);
> + clock_gettime(CLOCK_MONOTONIC, &last);
> while (1) {
> current_pfn = end_pfn;
>
> @@ -8134,7 +8134,7 @@ write_kdump_pages_parallel_cyclic(struct cache_data *cd_header,
> * So we should recheck.
> */
> if (info->page_flag_buf[consuming]->ready != FLAG_READY) {
> - gettimeofday(&new, NULL);
> + clock_gettime(CLOCK_MONOTONIC, &new);
> if (new.tv_sec - last.tv_sec > WAIT_TIME) {
> ERRMSG("Can't get data of pfn.\n");
> goto out;
> @@ -8147,7 +8147,7 @@ write_kdump_pages_parallel_cyclic(struct cache_data *cd_header,
> }
>
> if ((num_dumped % per) == 0)
> - print_progress(PROGRESS_COPY, num_dumped, info->num_dumpable, &tv_start);
> + print_progress(PROGRESS_COPY, num_dumped, info->num_dumpable, &ts_start);
>
> num_dumped++;
>
> @@ -8183,8 +8183,8 @@ finish:
> /*
> * print [100 %]
> */
> - print_progress(PROGRESS_COPY, num_dumped, info->num_dumpable, &tv_start);
> - print_execution_time(PROGRESS_COPY, &tv_start);
> + print_progress(PROGRESS_COPY, num_dumped, info->num_dumpable, &ts_start);
> + print_execution_time(PROGRESS_COPY, &ts_start);
> PROGRESS_MSG("\n");
>
> out:
> @@ -8234,7 +8234,7 @@ write_kdump_pages_cyclic(struct cache_data *cd_header, struct cache_data *cd_pag
> struct page_desc pd;
> unsigned char buf[info->page_size], *buf_out = NULL;
> unsigned long len_buf_out;
> - struct timeval tv_start;
> + struct timespec ts_start;
> const off_t failed = (off_t)-1;
> unsigned long len_buf_out_zlib, len_buf_out_lzo, len_buf_out_snappy;
>
> @@ -8295,12 +8295,12 @@ write_kdump_pages_cyclic(struct cache_data *cd_header, struct cache_data *cd_pag
> end_pfn = info->split_end_pfn;
> }
>
> - gettimeofday(&tv_start, NULL);
> + clock_gettime(CLOCK_MONOTONIC, &ts_start);
>
> for (pfn = start_pfn; pfn < end_pfn; pfn++) {
>
> if ((num_dumped % per) == 0)
> - print_progress(PROGRESS_COPY, num_dumped, info->num_dumpable, &tv_start);
> + print_progress(PROGRESS_COPY, num_dumped, info->num_dumpable, &ts_start);
>
> /*
> * Check the excluded page.
> @@ -8380,8 +8380,8 @@ out:
> free(wrkmem);
> #endif
>
> - print_progress(PROGRESS_COPY, num_dumped, info->num_dumpable, &tv_start);
> - print_execution_time(PROGRESS_COPY, &tv_start);
> + print_progress(PROGRESS_COPY, num_dumped, info->num_dumpable, &ts_start);
> + print_execution_time(PROGRESS_COPY, &ts_start);
>
> return ret;
> }
> @@ -8743,7 +8743,7 @@ write_kdump_pages_and_bitmap_cyclic(struct cache_data *cd_header, struct cache_d
> off_t offset_data=0;
> struct disk_dump_header *dh = info->dump_header;
> unsigned char buf[info->page_size];
> - struct timeval tv_start;
> + struct timespec ts_start;
>
> cd_header->offset
> = (DISKDUMP_HEADER_BLOCKS + dh->sub_hdr_size + dh->bitmap_blocks)
> @@ -8825,7 +8825,7 @@ write_kdump_pages_and_bitmap_cyclic(struct cache_data *cd_header, struct cache_d
> }
> free_bitmap2_buffer();
>
> - gettimeofday(&tv_start, NULL);
> + clock_gettime(CLOCK_MONOTONIC, &ts_start);
>
> /*
> * Write the remainder.
> @@ -8838,8 +8838,8 @@ write_kdump_pages_and_bitmap_cyclic(struct cache_data *cd_header, struct cache_d
> /*
> * print [100 %]
> */
> - print_progress(PROGRESS_COPY, num_dumped, info->num_dumpable, &tv_start);
> - print_execution_time(PROGRESS_COPY, &tv_start);
> + print_progress(PROGRESS_COPY, num_dumped, info->num_dumpable, &ts_start);
> + print_execution_time(PROGRESS_COPY, &ts_start);
> PROGRESS_MSG("\n");
>
> return TRUE;
> @@ -9559,10 +9559,10 @@ exclude_xen4_user_domain(void)
> int
> exclude_xen_user_domain(void)
> {
> - struct timeval tv_start;
> + struct timespec ts_start;
> int ret;
>
> - gettimeofday(&tv_start, NULL);
> + clock_gettime(CLOCK_MONOTONIC, &ts_start);
>
> if (info->xen_crash_info.com &&
> info->xen_crash_info.com->xen_major_version >= 4)
> @@ -9574,7 +9574,7 @@ exclude_xen_user_domain(void)
> * print [100 %]
> */
> print_progress(PROGRESS_XEN_DOMAIN, 1, 1, NULL);
> - print_execution_time(PROGRESS_XEN_DOMAIN, &tv_start);
> + print_execution_time(PROGRESS_XEN_DOMAIN, &ts_start);
>
> return ret;
> }
> @@ -10498,7 +10498,7 @@ reassemble_kdump_pages(void)
> struct disk_dump_header dh;
> struct page_desc pd, pd_zero;
> struct cache_data cd_pd, cd_data;
> - struct timeval tv_start;
> + struct timespec ts_start;
> char *data = NULL;
> unsigned long data_buf_size = info->page_size;
>
> @@ -10534,7 +10534,7 @@ reassemble_kdump_pages(void)
> /*
> * Write page header of zero-filled page.
> */
> - gettimeofday(&tv_start, NULL);
> + clock_gettime(CLOCK_MONOTONIC, &ts_start);
> if (info->dump_level & DL_EXCLUDE_ZERO) {
> /*
> * makedumpfile outputs the data of zero-filled page at first
> @@ -10569,7 +10569,7 @@ reassemble_kdump_pages(void)
>
> num_dumped++;
>
> - print_progress(PROGRESS_COPY, num_dumped, num_dumpable, &tv_start);
> + print_progress(PROGRESS_COPY, num_dumped, num_dumpable, &ts_start);
>
> if (lseek(fd, offset_ph_org, SEEK_SET) < 0) {
> ERRMSG("Can't seek a file(%s). %s\n",
> @@ -10666,8 +10666,8 @@ reassemble_kdump_pages(void)
> size_eraseinfo))
> goto out;
> }
> - print_progress(PROGRESS_COPY, num_dumpable, num_dumpable, &tv_start);
> - print_execution_time(PROGRESS_COPY, &tv_start);
> + print_progress(PROGRESS_COPY, num_dumpable, num_dumpable, &ts_start);
> + print_execution_time(PROGRESS_COPY, &ts_start);
>
> ret = TRUE;
> out:
> diff --git a/print_info.c b/print_info.c
> index 6bfcd11..732d5b8 100644
> --- a/print_info.c
> +++ b/print_info.c
> @@ -19,6 +19,8 @@
>
> #define PROGRESS_MAXLEN "50"
>
> +#define NSEC_PER_SEC 1000000000L
> +
> int message_level;
> int flag_strerr_message;
> int flag_ignore_r_char; /* 0: '\r' is effective. 1: not effective. */
> @@ -338,16 +340,16 @@ print_usage(void)
> MSG("\n");
> }
>
> -static void calc_delta(struct timeval *tv_start, struct timeval *delta)
> +static void calc_delta(struct timespec *ts_start, struct timespec *delta)
> {
> - struct timeval tv_end;
> + struct timespec ts_end;
>
> - gettimeofday(&tv_end, NULL);
> - delta->tv_sec = tv_end.tv_sec - tv_start->tv_sec;
> - delta->tv_usec = tv_end.tv_usec - tv_start->tv_usec;
> - if (delta->tv_usec < 0) {
> + clock_gettime(CLOCK_MONOTONIC, &ts_end);
> + delta->tv_sec = ts_end.tv_sec - ts_start->tv_sec;
> + delta->tv_nsec = ts_end.tv_nsec - ts_start->tv_nsec;
> + if (delta->tv_nsec < 0) {
> delta->tv_sec--;
> - delta->tv_usec += 1000000;
> + delta->tv_nsec += NSEC_PER_SEC;
> }
> }
>
> @@ -371,14 +373,14 @@ static int eta_to_human_short (unsigned long secs, char* msg)
>
>
> void
> -print_progress(const char *msg, unsigned long current, unsigned long end, struct timeval *start)
> +print_progress(const char *msg, unsigned long current, unsigned long end, struct timespec *start)
> {
> unsigned progress; /* in promilles (tenths of a percent) */
> time_t tm;
> static time_t last_time = 0;
> static unsigned int lapse = 0;
> static const char *spinner = "/|\\-";
> - struct timeval delta;
> + struct timespec delta;
> unsigned long eta;
> char eta_msg[16] = " ";
>
> @@ -393,7 +395,7 @@ print_progress(const char *msg, unsigned long current, unsigned long end, struct
>
> if (start != NULL && progress != 0) {
> calc_delta(start, &delta);
> - eta = 1000 * delta.tv_sec + delta.tv_usec / 1000;
> + eta = 1000 * delta.tv_sec + delta.tv_nsec / (NSEC_PER_SEC / 1000);
> eta = eta / progress - delta.tv_sec;
> eta_to_human_short(eta, eta_msg);
> }
> @@ -411,12 +413,12 @@ print_progress(const char *msg, unsigned long current, unsigned long end, struct
> }
>
> void
> -print_execution_time(char *step_name, struct timeval *tv_start)
> +print_execution_time(char *step_name, struct timespec *ts_start)
> {
> - struct timeval delta;
> + struct timespec delta;
>
> - calc_delta(tv_start, &delta);
> + calc_delta(ts_start, &delta);
> REPORT_MSG("STEP [%s] : %ld.%06ld seconds\n",
> - step_name, delta.tv_sec, delta.tv_usec);
> + step_name, delta.tv_sec, delta.tv_nsec / 1000);
> }
>
> diff --git a/print_info.h b/print_info.h
> index 1ce3593..49b70f4 100644
> --- a/print_info.h
> +++ b/print_info.h
> @@ -17,7 +17,7 @@
> #define _PRINT_INFO_H
>
> #include <stdio.h>
> -#include <sys/time.h>
> +#include <time.h>
>
> extern int message_level;
> extern int flag_strerr_message;
> @@ -25,9 +25,9 @@ extern int flag_ignore_r_char;
>
> void show_version(void);
> void print_usage(void);
> -void print_progress(const char *msg, unsigned long current, unsigned long end, struct timeval *start);
> +void print_progress(const char *msg, unsigned long current, unsigned long end, struct timespec *start);
>
> -void print_execution_time(char *step_name, struct timeval *tv_start);
> +void print_execution_time(char *step_name, struct timespec *ts_start);
>
> /*
> * Message texts
>
_______________________________________________
kexec mailing list
kexec@lists.infradead.org
http://lists.infradead.org/mailman/listinfo/kexec
^ permalink raw reply [flat|nested] 5+ messages in thread
* Re: [PATCH 1/2] makedumpfile: Use monotonic clock to calculate ETA and stats
2018-06-29 7:26 ` [PATCH 1/2] makedumpfile: Use monotonic clock to calculate ETA and stats lijiang
@ 2018-06-29 13:49 ` Kazuhito Hagio
0 siblings, 0 replies; 5+ messages in thread
From: Kazuhito Hagio @ 2018-06-29 13:49 UTC (permalink / raw)
To: lijiang, Petr Tesarik, kexec-ml; +Cc: mas-tachibana
Hi Petr, Lianbo,
I'm sorry for the late reply.
makedumpfile is now under v1.6.4 release process, so unfortunately,
your patches will be deferred to the next v1.6.5 release.
I'll let you know when they get reviewed.
Thanks,
Kazu
On 6/29/2018 3:26 AM, lijiang wrote:
> 在 2018年06月20日 17:50, Petr Tesarik 写道:
>> Execution time should be always measured by a monotonic clock,
>> because the system clock may be affected by discontinuous jumps,
>> e.g. when time is set manually by an admin.
>>
>> Signed-off-by: Petr Tesarik <ptesarik@suse.com>
>> ---
> That might be better if CC Masaki.
>
> Thanks.
> Lianbo
>> makedumpfile.c | 84 +++++++++++++++++++++++++++++-----------------------------
>> print_info.c | 30 +++++++++++----------
>> print_info.h | 6 ++---
>> 3 files changed, 61 insertions(+), 59 deletions(-)
>>
>> diff --git a/makedumpfile.c b/makedumpfile.c
>> index 450825b..5908b5a 100644
>> --- a/makedumpfile.c
>> +++ b/makedumpfile.c
>> @@ -5364,7 +5364,7 @@ _exclude_free_page(struct cycle *cycle)
>> {
>> int i, nr_zones, num_nodes, node;
>> unsigned long node_zones, zone, spanned_pages, pgdat;
>> - struct timeval tv_start;
>> + struct timespec ts_start;
>>
>> if ((node = next_online_node(0)) < 0) {
>> ERRMSG("Can't get next online node.\n");
>> @@ -5374,7 +5374,7 @@ _exclude_free_page(struct cycle *cycle)
>> ERRMSG("Can't get pgdat list.\n");
>> return FALSE;
>> }
>> - gettimeofday(&tv_start, NULL);
>> + clock_gettime(CLOCK_MONOTONIC, &ts_start);
>>
>> for (num_nodes = 1; num_nodes <= vt.numnodes; num_nodes++) {
>>
>> @@ -5420,7 +5420,7 @@ _exclude_free_page(struct cycle *cycle)
>> * print [100 %]
>> */
>> print_progress(PROGRESS_FREE_PAGES, vt.numnodes, vt.numnodes, NULL);
>> - print_execution_time(PROGRESS_FREE_PAGES, &tv_start);
>> + print_execution_time(PROGRESS_FREE_PAGES, &ts_start);
>>
>> return TRUE;
>> }
>> @@ -5567,7 +5567,7 @@ create_1st_bitmap_file(void)
>> char buf[info->page_size];
>> mdf_pfn_t pfn, pfn_start, pfn_end, pfn_bitmap1;
>> unsigned long long phys_start, phys_end;
>> - struct timeval tv_start;
>> + struct timespec ts_start;
>> off_t offset_page;
>>
>> if (info->flag_refiltering)
>> @@ -5597,7 +5597,7 @@ create_1st_bitmap_file(void)
>> offset_page += info->page_size;
>> }
>>
>> - gettimeofday(&tv_start, NULL);
>> + clock_gettime(CLOCK_MONOTONIC, &ts_start);
>>
>> /*
>> * If page is on memory hole, set bit on the 1st-bitmap.
>> @@ -5629,7 +5629,7 @@ create_1st_bitmap_file(void)
>> */
>> if (!info->flag_mem_usage) {
>> print_progress(PROGRESS_HOLES, info->max_mapnr, info->max_mapnr, NULL);
>> - print_execution_time(PROGRESS_HOLES, &tv_start);
>> + print_execution_time(PROGRESS_HOLES, &ts_start);
>> }
>>
>> if (!sync_1st_bitmap())
>> @@ -5731,7 +5731,7 @@ create_bitmap_from_memhole(struct cycle *cycle, struct dump_bitmap *bitmap, int
>> mdf_pfn_t pfn_start_roundup, pfn_end_round;
>> unsigned long pfn_start_byte, pfn_end_byte;
>> unsigned int num_pt_loads = get_num_pt_loads();
>> - struct timeval tv_start;
>> + struct timespec ts_start;
>>
>> /*
>> * At first, clear all the bits on the bitmap.
>> @@ -5741,7 +5741,7 @@ create_bitmap_from_memhole(struct cycle *cycle, struct dump_bitmap *bitmap, int
>> /*
>> * If page is on memory hole, set bit on the bitmap.
>> */
>> - gettimeofday(&tv_start, NULL);
>> + clock_gettime(CLOCK_MONOTONIC, &ts_start);
>> for (i = 0; get_pt_load(i, &phys_start, &phys_end, NULL, NULL); i++) {
>> pfn_start = MAX(paddr_to_pfn(phys_start), cycle->start_pfn);
>> pfn_end = MIN(paddr_to_pfn(phys_end), cycle->end_pfn);
>> @@ -5786,7 +5786,7 @@ create_bitmap_from_memhole(struct cycle *cycle, struct dump_bitmap *bitmap, int
>> * print 100 %
>> */
>> print_progress(PROGRESS_HOLES, info->max_mapnr, info->max_mapnr, NULL);
>> - print_execution_time(PROGRESS_HOLES, &tv_start);
>> + print_execution_time(PROGRESS_HOLES, &ts_start);
>>
>> return TRUE;
>> }
>> @@ -6046,14 +6046,14 @@ exclude_unnecessary_pages(struct cycle *cycle)
>> {
>> unsigned int mm;
>> struct mem_map_data *mmd;
>> - struct timeval tv_start;
>> + struct timespec ts_start;
>>
>> if (is_xen_memory() && !info->dom0_mapnr) {
>> ERRMSG("Can't get max domain-0 PFN for excluding pages.\n");
>> return FALSE;
>> }
>>
>> - gettimeofday(&tv_start, NULL);
>> + clock_gettime(CLOCK_MONOTONIC, &ts_start);
>>
>> for (mm = 0; mm < info->num_mem_map; mm++) {
>>
>> @@ -6077,7 +6077,7 @@ exclude_unnecessary_pages(struct cycle *cycle)
>> */
>> if (!info->flag_mem_usage) {
>> print_progress(PROGRESS_UNN_PAGES, info->num_mem_map, info->num_mem_map, NULL);
>> - print_execution_time(PROGRESS_UNN_PAGES, &tv_start);
>> + print_execution_time(PROGRESS_UNN_PAGES, &ts_start);
>> }
>>
>> return TRUE;
>> @@ -7475,7 +7475,7 @@ write_elf_pages_cyclic(struct cache_data *cd_header, struct cache_data *cd_page)
>> unsigned long frac_head, frac_tail;
>> off_t off_seg_load, off_memory;
>> Elf64_Phdr load;
>> - struct timeval tv_start;
>> + struct timespec ts_start;
>> struct cycle cycle = {0};
>>
>> if (!info->flag_elf_dumpfile)
>> @@ -7500,7 +7500,7 @@ write_elf_pages_cyclic(struct cache_data *cd_header, struct cache_data *cd_page)
>> if (!(phnum = get_phnum_memory()))
>> return FALSE;
>>
>> - gettimeofday(&tv_start, NULL);
>> + clock_gettime(CLOCK_MONOTONIC, &ts_start);
>>
>> for (i = 0; i < phnum; i++) {
>> if (!get_phdr_memory(i, &load))
>> @@ -7548,7 +7548,7 @@ write_elf_pages_cyclic(struct cache_data *cd_header, struct cache_data *cd_page)
>> }
>>
>> if ((num_dumped % per) == 0)
>> - print_progress(PROGRESS_COPY, num_dumped, num_dumpable, &tv_start);
>> + print_progress(PROGRESS_COPY, num_dumped, num_dumpable, &ts_start);
>>
>> num_dumped++;
>>
>> @@ -7667,8 +7667,8 @@ write_elf_pages_cyclic(struct cache_data *cd_header, struct cache_data *cd_page)
>> /*
>> * print [100 %]
>> */
>> - print_progress(PROGRESS_COPY, num_dumpable, num_dumpable, &tv_start);
>> - print_execution_time(PROGRESS_COPY, &tv_start);
>> + print_progress(PROGRESS_COPY, num_dumpable, num_dumpable, &ts_start);
>> + print_execution_time(PROGRESS_COPY, &ts_start);
>> PROGRESS_MSG("\n");
>>
>> return TRUE;
>> @@ -8004,8 +8004,8 @@ write_kdump_pages_parallel_cyclic(struct cache_data *cd_header,
>> mdf_pfn_t per;
>> mdf_pfn_t start_pfn, end_pfn;
>> struct page_desc pd;
>> - struct timeval tv_start;
>> - struct timeval last, new;
>> + struct timespec ts_start;
>> + struct timespec last, new;
>> pthread_t **threads = NULL;
>> struct thread_args *kdump_thread_args = NULL;
>> void *thread_result;
>> @@ -8043,7 +8043,7 @@ write_kdump_pages_parallel_cyclic(struct cache_data *cd_header,
>> per = info->num_dumpable / 10000;
>> per = per ? per : 1;
>>
>> - gettimeofday(&tv_start, NULL);
>> + clock_gettime(CLOCK_MONOTONIC, &ts_start);
>>
>> start_pfn = cycle->start_pfn;
>> end_pfn = cycle->end_pfn;
>> @@ -8091,7 +8091,7 @@ write_kdump_pages_parallel_cyclic(struct cache_data *cd_header,
>> * The next pfn is smallest pfn in all page_flag_buf.
>> */
>> sem_wait(&info->page_flag_buf_sem);
>> - gettimeofday(&last, NULL);
>> + clock_gettime(CLOCK_MONOTONIC, &last);
>> while (1) {
>> current_pfn = end_pfn;
>>
>> @@ -8134,7 +8134,7 @@ write_kdump_pages_parallel_cyclic(struct cache_data *cd_header,
>> * So we should recheck.
>> */
>> if (info->page_flag_buf[consuming]->ready != FLAG_READY) {
>> - gettimeofday(&new, NULL);
>> + clock_gettime(CLOCK_MONOTONIC, &new);
>> if (new.tv_sec - last.tv_sec > WAIT_TIME) {
>> ERRMSG("Can't get data of pfn.\n");
>> goto out;
>> @@ -8147,7 +8147,7 @@ write_kdump_pages_parallel_cyclic(struct cache_data *cd_header,
>> }
>>
>> if ((num_dumped % per) == 0)
>> - print_progress(PROGRESS_COPY, num_dumped, info->num_dumpable, &tv_start);
>> + print_progress(PROGRESS_COPY, num_dumped, info->num_dumpable, &ts_start);
>>
>> num_dumped++;
>>
>> @@ -8183,8 +8183,8 @@ finish:
>> /*
>> * print [100 %]
>> */
>> - print_progress(PROGRESS_COPY, num_dumped, info->num_dumpable, &tv_start);
>> - print_execution_time(PROGRESS_COPY, &tv_start);
>> + print_progress(PROGRESS_COPY, num_dumped, info->num_dumpable, &ts_start);
>> + print_execution_time(PROGRESS_COPY, &ts_start);
>> PROGRESS_MSG("\n");
>>
>> out:
>> @@ -8234,7 +8234,7 @@ write_kdump_pages_cyclic(struct cache_data *cd_header, struct cache_data *cd_pag
>> struct page_desc pd;
>> unsigned char buf[info->page_size], *buf_out = NULL;
>> unsigned long len_buf_out;
>> - struct timeval tv_start;
>> + struct timespec ts_start;
>> const off_t failed = (off_t)-1;
>> unsigned long len_buf_out_zlib, len_buf_out_lzo, len_buf_out_snappy;
>>
>> @@ -8295,12 +8295,12 @@ write_kdump_pages_cyclic(struct cache_data *cd_header, struct cache_data *cd_pag
>> end_pfn = info->split_end_pfn;
>> }
>>
>> - gettimeofday(&tv_start, NULL);
>> + clock_gettime(CLOCK_MONOTONIC, &ts_start);
>>
>> for (pfn = start_pfn; pfn < end_pfn; pfn++) {
>>
>> if ((num_dumped % per) == 0)
>> - print_progress(PROGRESS_COPY, num_dumped, info->num_dumpable, &tv_start);
>> + print_progress(PROGRESS_COPY, num_dumped, info->num_dumpable, &ts_start);
>>
>> /*
>> * Check the excluded page.
>> @@ -8380,8 +8380,8 @@ out:
>> free(wrkmem);
>> #endif
>>
>> - print_progress(PROGRESS_COPY, num_dumped, info->num_dumpable, &tv_start);
>> - print_execution_time(PROGRESS_COPY, &tv_start);
>> + print_progress(PROGRESS_COPY, num_dumped, info->num_dumpable, &ts_start);
>> + print_execution_time(PROGRESS_COPY, &ts_start);
>>
>> return ret;
>> }
>> @@ -8743,7 +8743,7 @@ write_kdump_pages_and_bitmap_cyclic(struct cache_data *cd_header, struct cache_d
>> off_t offset_data=0;
>> struct disk_dump_header *dh = info->dump_header;
>> unsigned char buf[info->page_size];
>> - struct timeval tv_start;
>> + struct timespec ts_start;
>>
>> cd_header->offset
>> = (DISKDUMP_HEADER_BLOCKS + dh->sub_hdr_size + dh->bitmap_blocks)
>> @@ -8825,7 +8825,7 @@ write_kdump_pages_and_bitmap_cyclic(struct cache_data *cd_header, struct cache_d
>> }
>> free_bitmap2_buffer();
>>
>> - gettimeofday(&tv_start, NULL);
>> + clock_gettime(CLOCK_MONOTONIC, &ts_start);
>>
>> /*
>> * Write the remainder.
>> @@ -8838,8 +8838,8 @@ write_kdump_pages_and_bitmap_cyclic(struct cache_data *cd_header, struct cache_d
>> /*
>> * print [100 %]
>> */
>> - print_progress(PROGRESS_COPY, num_dumped, info->num_dumpable, &tv_start);
>> - print_execution_time(PROGRESS_COPY, &tv_start);
>> + print_progress(PROGRESS_COPY, num_dumped, info->num_dumpable, &ts_start);
>> + print_execution_time(PROGRESS_COPY, &ts_start);
>> PROGRESS_MSG("\n");
>>
>> return TRUE;
>> @@ -9559,10 +9559,10 @@ exclude_xen4_user_domain(void)
>> int
>> exclude_xen_user_domain(void)
>> {
>> - struct timeval tv_start;
>> + struct timespec ts_start;
>> int ret;
>>
>> - gettimeofday(&tv_start, NULL);
>> + clock_gettime(CLOCK_MONOTONIC, &ts_start);
>>
>> if (info->xen_crash_info.com &&
>> info->xen_crash_info.com->xen_major_version >= 4)
>> @@ -9574,7 +9574,7 @@ exclude_xen_user_domain(void)
>> * print [100 %]
>> */
>> print_progress(PROGRESS_XEN_DOMAIN, 1, 1, NULL);
>> - print_execution_time(PROGRESS_XEN_DOMAIN, &tv_start);
>> + print_execution_time(PROGRESS_XEN_DOMAIN, &ts_start);
>>
>> return ret;
>> }
>> @@ -10498,7 +10498,7 @@ reassemble_kdump_pages(void)
>> struct disk_dump_header dh;
>> struct page_desc pd, pd_zero;
>> struct cache_data cd_pd, cd_data;
>> - struct timeval tv_start;
>> + struct timespec ts_start;
>> char *data = NULL;
>> unsigned long data_buf_size = info->page_size;
>>
>> @@ -10534,7 +10534,7 @@ reassemble_kdump_pages(void)
>> /*
>> * Write page header of zero-filled page.
>> */
>> - gettimeofday(&tv_start, NULL);
>> + clock_gettime(CLOCK_MONOTONIC, &ts_start);
>> if (info->dump_level & DL_EXCLUDE_ZERO) {
>> /*
>> * makedumpfile outputs the data of zero-filled page at first
>> @@ -10569,7 +10569,7 @@ reassemble_kdump_pages(void)
>>
>> num_dumped++;
>>
>> - print_progress(PROGRESS_COPY, num_dumped, num_dumpable, &tv_start);
>> + print_progress(PROGRESS_COPY, num_dumped, num_dumpable, &ts_start);
>>
>> if (lseek(fd, offset_ph_org, SEEK_SET) < 0) {
>> ERRMSG("Can't seek a file(%s). %s\n",
>> @@ -10666,8 +10666,8 @@ reassemble_kdump_pages(void)
>> size_eraseinfo))
>> goto out;
>> }
>> - print_progress(PROGRESS_COPY, num_dumpable, num_dumpable, &tv_start);
>> - print_execution_time(PROGRESS_COPY, &tv_start);
>> + print_progress(PROGRESS_COPY, num_dumpable, num_dumpable, &ts_start);
>> + print_execution_time(PROGRESS_COPY, &ts_start);
>>
>> ret = TRUE;
>> out:
>> diff --git a/print_info.c b/print_info.c
>> index 6bfcd11..732d5b8 100644
>> --- a/print_info.c
>> +++ b/print_info.c
>> @@ -19,6 +19,8 @@
>>
>> #define PROGRESS_MAXLEN "50"
>>
>> +#define NSEC_PER_SEC 1000000000L
>> +
>> int message_level;
>> int flag_strerr_message;
>> int flag_ignore_r_char; /* 0: '\r' is effective. 1: not effective. */
>> @@ -338,16 +340,16 @@ print_usage(void)
>> MSG("\n");
>> }
>>
>> -static void calc_delta(struct timeval *tv_start, struct timeval *delta)
>> +static void calc_delta(struct timespec *ts_start, struct timespec *delta)
>> {
>> - struct timeval tv_end;
>> + struct timespec ts_end;
>>
>> - gettimeofday(&tv_end, NULL);
>> - delta->tv_sec = tv_end.tv_sec - tv_start->tv_sec;
>> - delta->tv_usec = tv_end.tv_usec - tv_start->tv_usec;
>> - if (delta->tv_usec < 0) {
>> + clock_gettime(CLOCK_MONOTONIC, &ts_end);
>> + delta->tv_sec = ts_end.tv_sec - ts_start->tv_sec;
>> + delta->tv_nsec = ts_end.tv_nsec - ts_start->tv_nsec;
>> + if (delta->tv_nsec < 0) {
>> delta->tv_sec--;
>> - delta->tv_usec += 1000000;
>> + delta->tv_nsec += NSEC_PER_SEC;
>> }
>> }
>>
>> @@ -371,14 +373,14 @@ static int eta_to_human_short (unsigned long secs, char* msg)
>>
>>
>> void
>> -print_progress(const char *msg, unsigned long current, unsigned long end, struct timeval *start)
>> +print_progress(const char *msg, unsigned long current, unsigned long end, struct timespec *start)
>> {
>> unsigned progress; /* in promilles (tenths of a percent) */
>> time_t tm;
>> static time_t last_time = 0;
>> static unsigned int lapse = 0;
>> static const char *spinner = "/|\\-";
>> - struct timeval delta;
>> + struct timespec delta;
>> unsigned long eta;
>> char eta_msg[16] = " ";
>>
>> @@ -393,7 +395,7 @@ print_progress(const char *msg, unsigned long current, unsigned long end, struct
>>
>> if (start != NULL && progress != 0) {
>> calc_delta(start, &delta);
>> - eta = 1000 * delta.tv_sec + delta.tv_usec / 1000;
>> + eta = 1000 * delta.tv_sec + delta.tv_nsec / (NSEC_PER_SEC / 1000);
>> eta = eta / progress - delta.tv_sec;
>> eta_to_human_short(eta, eta_msg);
>> }
>> @@ -411,12 +413,12 @@ print_progress(const char *msg, unsigned long current, unsigned long end, struct
>> }
>>
>> void
>> -print_execution_time(char *step_name, struct timeval *tv_start)
>> +print_execution_time(char *step_name, struct timespec *ts_start)
>> {
>> - struct timeval delta;
>> + struct timespec delta;
>>
>> - calc_delta(tv_start, &delta);
>> + calc_delta(ts_start, &delta);
>> REPORT_MSG("STEP [%s] : %ld.%06ld seconds\n",
>> - step_name, delta.tv_sec, delta.tv_usec);
>> + step_name, delta.tv_sec, delta.tv_nsec / 1000);
>> }
>>
>> diff --git a/print_info.h b/print_info.h
>> index 1ce3593..49b70f4 100644
>> --- a/print_info.h
>> +++ b/print_info.h
>> @@ -17,7 +17,7 @@
>> #define _PRINT_INFO_H
>>
>> #include <stdio.h>
>> -#include <sys/time.h>
>> +#include <time.h>
>>
>> extern int message_level;
>> extern int flag_strerr_message;
>> @@ -25,9 +25,9 @@ extern int flag_ignore_r_char;
>>
>> void show_version(void);
>> void print_usage(void);
>> -void print_progress(const char *msg, unsigned long current, unsigned long end, struct timeval *start);
>> +void print_progress(const char *msg, unsigned long current, unsigned long end, struct timespec *start);
>>
>> -void print_execution_time(char *step_name, struct timeval *tv_start);
>> +void print_execution_time(char *step_name, struct timespec *ts_start);
>>
>> /*
>> * Message texts
>>
>
> _______________________________________________
> kexec mailing list
> kexec@lists.infradead.org
> http://lists.infradead.org/mailman/listinfo/kexec
>
_______________________________________________
kexec mailing list
kexec@lists.infradead.org
http://lists.infradead.org/mailman/listinfo/kexec
^ permalink raw reply [flat|nested] 5+ messages in thread
* Re: [PATCH 1/2] makedumpfile: Use monotonic clock to calculate ETA and stats
2018-06-20 9:50 [PATCH 1/2] makedumpfile: Use monotonic clock to calculate ETA and stats Petr Tesarik
2018-06-20 9:50 ` [PATCH 2/2] makedumpfile: Check if clock_gettime() requires -lrt Petr Tesarik
2018-06-29 7:26 ` [PATCH 1/2] makedumpfile: Use monotonic clock to calculate ETA and stats lijiang
@ 2018-07-06 13:40 ` Kazuhito Hagio
2 siblings, 0 replies; 5+ messages in thread
From: Kazuhito Hagio @ 2018-07-06 13:40 UTC (permalink / raw)
To: Petr Tesarik; +Cc: kexec-ml, lijiang
On 6/20/2018 5:50 AM, Petr Tesarik wrote:
> Execution time should be always measured by a monotonic clock,
> because the system clock may be affected by discontinuous jumps,
> e.g. when time is set manually by an admin.
Hi Petr,
Please excuse me for my late response.
Your patches look good to me, tested and applied.
Thanks,
Kazu
>
> Signed-off-by: Petr Tesarik <ptesarik@suse.com>
> ---
> makedumpfile.c | 84 +++++++++++++++++++++++++++++-----------------------------
> print_info.c | 30 +++++++++++----------
> print_info.h | 6 ++---
> 3 files changed, 61 insertions(+), 59 deletions(-)
>
> diff --git a/makedumpfile.c b/makedumpfile.c
> index 450825b..5908b5a 100644
> --- a/makedumpfile.c
> +++ b/makedumpfile.c
> @@ -5364,7 +5364,7 @@ _exclude_free_page(struct cycle *cycle)
> {
> int i, nr_zones, num_nodes, node;
> unsigned long node_zones, zone, spanned_pages, pgdat;
> - struct timeval tv_start;
> + struct timespec ts_start;
>
> if ((node = next_online_node(0)) < 0) {
> ERRMSG("Can't get next online node.\n");
> @@ -5374,7 +5374,7 @@ _exclude_free_page(struct cycle *cycle)
> ERRMSG("Can't get pgdat list.\n");
> return FALSE;
> }
> - gettimeofday(&tv_start, NULL);
> + clock_gettime(CLOCK_MONOTONIC, &ts_start);
>
> for (num_nodes = 1; num_nodes <= vt.numnodes; num_nodes++) {
>
> @@ -5420,7 +5420,7 @@ _exclude_free_page(struct cycle *cycle)
> * print [100 %]
> */
> print_progress(PROGRESS_FREE_PAGES, vt.numnodes, vt.numnodes, NULL);
> - print_execution_time(PROGRESS_FREE_PAGES, &tv_start);
> + print_execution_time(PROGRESS_FREE_PAGES, &ts_start);
>
> return TRUE;
> }
> @@ -5567,7 +5567,7 @@ create_1st_bitmap_file(void)
> char buf[info->page_size];
> mdf_pfn_t pfn, pfn_start, pfn_end, pfn_bitmap1;
> unsigned long long phys_start, phys_end;
> - struct timeval tv_start;
> + struct timespec ts_start;
> off_t offset_page;
>
> if (info->flag_refiltering)
> @@ -5597,7 +5597,7 @@ create_1st_bitmap_file(void)
> offset_page += info->page_size;
> }
>
> - gettimeofday(&tv_start, NULL);
> + clock_gettime(CLOCK_MONOTONIC, &ts_start);
>
> /*
> * If page is on memory hole, set bit on the 1st-bitmap.
> @@ -5629,7 +5629,7 @@ create_1st_bitmap_file(void)
> */
> if (!info->flag_mem_usage) {
> print_progress(PROGRESS_HOLES, info->max_mapnr, info->max_mapnr, NULL);
> - print_execution_time(PROGRESS_HOLES, &tv_start);
> + print_execution_time(PROGRESS_HOLES, &ts_start);
> }
>
> if (!sync_1st_bitmap())
> @@ -5731,7 +5731,7 @@ create_bitmap_from_memhole(struct cycle *cycle, struct dump_bitmap *bitmap, int
> mdf_pfn_t pfn_start_roundup, pfn_end_round;
> unsigned long pfn_start_byte, pfn_end_byte;
> unsigned int num_pt_loads = get_num_pt_loads();
> - struct timeval tv_start;
> + struct timespec ts_start;
>
> /*
> * At first, clear all the bits on the bitmap.
> @@ -5741,7 +5741,7 @@ create_bitmap_from_memhole(struct cycle *cycle, struct dump_bitmap *bitmap, int
> /*
> * If page is on memory hole, set bit on the bitmap.
> */
> - gettimeofday(&tv_start, NULL);
> + clock_gettime(CLOCK_MONOTONIC, &ts_start);
> for (i = 0; get_pt_load(i, &phys_start, &phys_end, NULL, NULL); i++) {
> pfn_start = MAX(paddr_to_pfn(phys_start), cycle->start_pfn);
> pfn_end = MIN(paddr_to_pfn(phys_end), cycle->end_pfn);
> @@ -5786,7 +5786,7 @@ create_bitmap_from_memhole(struct cycle *cycle, struct dump_bitmap *bitmap, int
> * print 100 %
> */
> print_progress(PROGRESS_HOLES, info->max_mapnr, info->max_mapnr, NULL);
> - print_execution_time(PROGRESS_HOLES, &tv_start);
> + print_execution_time(PROGRESS_HOLES, &ts_start);
>
> return TRUE;
> }
> @@ -6046,14 +6046,14 @@ exclude_unnecessary_pages(struct cycle *cycle)
> {
> unsigned int mm;
> struct mem_map_data *mmd;
> - struct timeval tv_start;
> + struct timespec ts_start;
>
> if (is_xen_memory() && !info->dom0_mapnr) {
> ERRMSG("Can't get max domain-0 PFN for excluding pages.\n");
> return FALSE;
> }
>
> - gettimeofday(&tv_start, NULL);
> + clock_gettime(CLOCK_MONOTONIC, &ts_start);
>
> for (mm = 0; mm < info->num_mem_map; mm++) {
>
> @@ -6077,7 +6077,7 @@ exclude_unnecessary_pages(struct cycle *cycle)
> */
> if (!info->flag_mem_usage) {
> print_progress(PROGRESS_UNN_PAGES, info->num_mem_map, info->num_mem_map, NULL);
> - print_execution_time(PROGRESS_UNN_PAGES, &tv_start);
> + print_execution_time(PROGRESS_UNN_PAGES, &ts_start);
> }
>
> return TRUE;
> @@ -7475,7 +7475,7 @@ write_elf_pages_cyclic(struct cache_data *cd_header, struct cache_data *cd_page)
> unsigned long frac_head, frac_tail;
> off_t off_seg_load, off_memory;
> Elf64_Phdr load;
> - struct timeval tv_start;
> + struct timespec ts_start;
> struct cycle cycle = {0};
>
> if (!info->flag_elf_dumpfile)
> @@ -7500,7 +7500,7 @@ write_elf_pages_cyclic(struct cache_data *cd_header, struct cache_data *cd_page)
> if (!(phnum = get_phnum_memory()))
> return FALSE;
>
> - gettimeofday(&tv_start, NULL);
> + clock_gettime(CLOCK_MONOTONIC, &ts_start);
>
> for (i = 0; i < phnum; i++) {
> if (!get_phdr_memory(i, &load))
> @@ -7548,7 +7548,7 @@ write_elf_pages_cyclic(struct cache_data *cd_header, struct cache_data *cd_page)
> }
>
> if ((num_dumped % per) == 0)
> - print_progress(PROGRESS_COPY, num_dumped, num_dumpable, &tv_start);
> + print_progress(PROGRESS_COPY, num_dumped, num_dumpable, &ts_start);
>
> num_dumped++;
>
> @@ -7667,8 +7667,8 @@ write_elf_pages_cyclic(struct cache_data *cd_header, struct cache_data *cd_page)
> /*
> * print [100 %]
> */
> - print_progress(PROGRESS_COPY, num_dumpable, num_dumpable, &tv_start);
> - print_execution_time(PROGRESS_COPY, &tv_start);
> + print_progress(PROGRESS_COPY, num_dumpable, num_dumpable, &ts_start);
> + print_execution_time(PROGRESS_COPY, &ts_start);
> PROGRESS_MSG("\n");
>
> return TRUE;
> @@ -8004,8 +8004,8 @@ write_kdump_pages_parallel_cyclic(struct cache_data *cd_header,
> mdf_pfn_t per;
> mdf_pfn_t start_pfn, end_pfn;
> struct page_desc pd;
> - struct timeval tv_start;
> - struct timeval last, new;
> + struct timespec ts_start;
> + struct timespec last, new;
> pthread_t **threads = NULL;
> struct thread_args *kdump_thread_args = NULL;
> void *thread_result;
> @@ -8043,7 +8043,7 @@ write_kdump_pages_parallel_cyclic(struct cache_data *cd_header,
> per = info->num_dumpable / 10000;
> per = per ? per : 1;
>
> - gettimeofday(&tv_start, NULL);
> + clock_gettime(CLOCK_MONOTONIC, &ts_start);
>
> start_pfn = cycle->start_pfn;
> end_pfn = cycle->end_pfn;
> @@ -8091,7 +8091,7 @@ write_kdump_pages_parallel_cyclic(struct cache_data *cd_header,
> * The next pfn is smallest pfn in all page_flag_buf.
> */
> sem_wait(&info->page_flag_buf_sem);
> - gettimeofday(&last, NULL);
> + clock_gettime(CLOCK_MONOTONIC, &last);
> while (1) {
> current_pfn = end_pfn;
>
> @@ -8134,7 +8134,7 @@ write_kdump_pages_parallel_cyclic(struct cache_data *cd_header,
> * So we should recheck.
> */
> if (info->page_flag_buf[consuming]->ready != FLAG_READY) {
> - gettimeofday(&new, NULL);
> + clock_gettime(CLOCK_MONOTONIC, &new);
> if (new.tv_sec - last.tv_sec > WAIT_TIME) {
> ERRMSG("Can't get data of pfn.\n");
> goto out;
> @@ -8147,7 +8147,7 @@ write_kdump_pages_parallel_cyclic(struct cache_data *cd_header,
> }
>
> if ((num_dumped % per) == 0)
> - print_progress(PROGRESS_COPY, num_dumped, info->num_dumpable, &tv_start);
> + print_progress(PROGRESS_COPY, num_dumped, info->num_dumpable, &ts_start);
>
> num_dumped++;
>
> @@ -8183,8 +8183,8 @@ finish:
> /*
> * print [100 %]
> */
> - print_progress(PROGRESS_COPY, num_dumped, info->num_dumpable, &tv_start);
> - print_execution_time(PROGRESS_COPY, &tv_start);
> + print_progress(PROGRESS_COPY, num_dumped, info->num_dumpable, &ts_start);
> + print_execution_time(PROGRESS_COPY, &ts_start);
> PROGRESS_MSG("\n");
>
> out:
> @@ -8234,7 +8234,7 @@ write_kdump_pages_cyclic(struct cache_data *cd_header, struct cache_data *cd_pag
> struct page_desc pd;
> unsigned char buf[info->page_size], *buf_out = NULL;
> unsigned long len_buf_out;
> - struct timeval tv_start;
> + struct timespec ts_start;
> const off_t failed = (off_t)-1;
> unsigned long len_buf_out_zlib, len_buf_out_lzo, len_buf_out_snappy;
>
> @@ -8295,12 +8295,12 @@ write_kdump_pages_cyclic(struct cache_data *cd_header, struct cache_data *cd_pag
> end_pfn = info->split_end_pfn;
> }
>
> - gettimeofday(&tv_start, NULL);
> + clock_gettime(CLOCK_MONOTONIC, &ts_start);
>
> for (pfn = start_pfn; pfn < end_pfn; pfn++) {
>
> if ((num_dumped % per) == 0)
> - print_progress(PROGRESS_COPY, num_dumped, info->num_dumpable, &tv_start);
> + print_progress(PROGRESS_COPY, num_dumped, info->num_dumpable, &ts_start);
>
> /*
> * Check the excluded page.
> @@ -8380,8 +8380,8 @@ out:
> free(wrkmem);
> #endif
>
> - print_progress(PROGRESS_COPY, num_dumped, info->num_dumpable, &tv_start);
> - print_execution_time(PROGRESS_COPY, &tv_start);
> + print_progress(PROGRESS_COPY, num_dumped, info->num_dumpable, &ts_start);
> + print_execution_time(PROGRESS_COPY, &ts_start);
>
> return ret;
> }
> @@ -8743,7 +8743,7 @@ write_kdump_pages_and_bitmap_cyclic(struct cache_data *cd_header, struct cache_d
> off_t offset_data=0;
> struct disk_dump_header *dh = info->dump_header;
> unsigned char buf[info->page_size];
> - struct timeval tv_start;
> + struct timespec ts_start;
>
> cd_header->offset
> = (DISKDUMP_HEADER_BLOCKS + dh->sub_hdr_size + dh->bitmap_blocks)
> @@ -8825,7 +8825,7 @@ write_kdump_pages_and_bitmap_cyclic(struct cache_data *cd_header, struct cache_d
> }
> free_bitmap2_buffer();
>
> - gettimeofday(&tv_start, NULL);
> + clock_gettime(CLOCK_MONOTONIC, &ts_start);
>
> /*
> * Write the remainder.
> @@ -8838,8 +8838,8 @@ write_kdump_pages_and_bitmap_cyclic(struct cache_data *cd_header, struct cache_d
> /*
> * print [100 %]
> */
> - print_progress(PROGRESS_COPY, num_dumped, info->num_dumpable, &tv_start);
> - print_execution_time(PROGRESS_COPY, &tv_start);
> + print_progress(PROGRESS_COPY, num_dumped, info->num_dumpable, &ts_start);
> + print_execution_time(PROGRESS_COPY, &ts_start);
> PROGRESS_MSG("\n");
>
> return TRUE;
> @@ -9559,10 +9559,10 @@ exclude_xen4_user_domain(void)
> int
> exclude_xen_user_domain(void)
> {
> - struct timeval tv_start;
> + struct timespec ts_start;
> int ret;
>
> - gettimeofday(&tv_start, NULL);
> + clock_gettime(CLOCK_MONOTONIC, &ts_start);
>
> if (info->xen_crash_info.com &&
> info->xen_crash_info.com->xen_major_version >= 4)
> @@ -9574,7 +9574,7 @@ exclude_xen_user_domain(void)
> * print [100 %]
> */
> print_progress(PROGRESS_XEN_DOMAIN, 1, 1, NULL);
> - print_execution_time(PROGRESS_XEN_DOMAIN, &tv_start);
> + print_execution_time(PROGRESS_XEN_DOMAIN, &ts_start);
>
> return ret;
> }
> @@ -10498,7 +10498,7 @@ reassemble_kdump_pages(void)
> struct disk_dump_header dh;
> struct page_desc pd, pd_zero;
> struct cache_data cd_pd, cd_data;
> - struct timeval tv_start;
> + struct timespec ts_start;
> char *data = NULL;
> unsigned long data_buf_size = info->page_size;
>
> @@ -10534,7 +10534,7 @@ reassemble_kdump_pages(void)
> /*
> * Write page header of zero-filled page.
> */
> - gettimeofday(&tv_start, NULL);
> + clock_gettime(CLOCK_MONOTONIC, &ts_start);
> if (info->dump_level & DL_EXCLUDE_ZERO) {
> /*
> * makedumpfile outputs the data of zero-filled page at first
> @@ -10569,7 +10569,7 @@ reassemble_kdump_pages(void)
>
> num_dumped++;
>
> - print_progress(PROGRESS_COPY, num_dumped, num_dumpable, &tv_start);
> + print_progress(PROGRESS_COPY, num_dumped, num_dumpable, &ts_start);
>
> if (lseek(fd, offset_ph_org, SEEK_SET) < 0) {
> ERRMSG("Can't seek a file(%s). %s\n",
> @@ -10666,8 +10666,8 @@ reassemble_kdump_pages(void)
> size_eraseinfo))
> goto out;
> }
> - print_progress(PROGRESS_COPY, num_dumpable, num_dumpable, &tv_start);
> - print_execution_time(PROGRESS_COPY, &tv_start);
> + print_progress(PROGRESS_COPY, num_dumpable, num_dumpable, &ts_start);
> + print_execution_time(PROGRESS_COPY, &ts_start);
>
> ret = TRUE;
> out:
> diff --git a/print_info.c b/print_info.c
> index 6bfcd11..732d5b8 100644
> --- a/print_info.c
> +++ b/print_info.c
> @@ -19,6 +19,8 @@
>
> #define PROGRESS_MAXLEN "50"
>
> +#define NSEC_PER_SEC 1000000000L
> +
> int message_level;
> int flag_strerr_message;
> int flag_ignore_r_char; /* 0: '\r' is effective. 1: not effective. */
> @@ -338,16 +340,16 @@ print_usage(void)
> MSG("\n");
> }
>
> -static void calc_delta(struct timeval *tv_start, struct timeval *delta)
> +static void calc_delta(struct timespec *ts_start, struct timespec *delta)
> {
> - struct timeval tv_end;
> + struct timespec ts_end;
>
> - gettimeofday(&tv_end, NULL);
> - delta->tv_sec = tv_end.tv_sec - tv_start->tv_sec;
> - delta->tv_usec = tv_end.tv_usec - tv_start->tv_usec;
> - if (delta->tv_usec < 0) {
> + clock_gettime(CLOCK_MONOTONIC, &ts_end);
> + delta->tv_sec = ts_end.tv_sec - ts_start->tv_sec;
> + delta->tv_nsec = ts_end.tv_nsec - ts_start->tv_nsec;
> + if (delta->tv_nsec < 0) {
> delta->tv_sec--;
> - delta->tv_usec += 1000000;
> + delta->tv_nsec += NSEC_PER_SEC;
> }
> }
>
> @@ -371,14 +373,14 @@ static int eta_to_human_short (unsigned long secs, char* msg)
>
>
> void
> -print_progress(const char *msg, unsigned long current, unsigned long end, struct timeval *start)
> +print_progress(const char *msg, unsigned long current, unsigned long end, struct timespec *start)
> {
> unsigned progress; /* in promilles (tenths of a percent) */
> time_t tm;
> static time_t last_time = 0;
> static unsigned int lapse = 0;
> static const char *spinner = "/|\\-";
> - struct timeval delta;
> + struct timespec delta;
> unsigned long eta;
> char eta_msg[16] = " ";
>
> @@ -393,7 +395,7 @@ print_progress(const char *msg, unsigned long current, unsigned long end, struct
>
> if (start != NULL && progress != 0) {
> calc_delta(start, &delta);
> - eta = 1000 * delta.tv_sec + delta.tv_usec / 1000;
> + eta = 1000 * delta.tv_sec + delta.tv_nsec / (NSEC_PER_SEC / 1000);
> eta = eta / progress - delta.tv_sec;
> eta_to_human_short(eta, eta_msg);
> }
> @@ -411,12 +413,12 @@ print_progress(const char *msg, unsigned long current, unsigned long end, struct
> }
>
> void
> -print_execution_time(char *step_name, struct timeval *tv_start)
> +print_execution_time(char *step_name, struct timespec *ts_start)
> {
> - struct timeval delta;
> + struct timespec delta;
>
> - calc_delta(tv_start, &delta);
> + calc_delta(ts_start, &delta);
> REPORT_MSG("STEP [%s] : %ld.%06ld seconds\n",
> - step_name, delta.tv_sec, delta.tv_usec);
> + step_name, delta.tv_sec, delta.tv_nsec / 1000);
> }
>
> diff --git a/print_info.h b/print_info.h
> index 1ce3593..49b70f4 100644
> --- a/print_info.h
> +++ b/print_info.h
> @@ -17,7 +17,7 @@
> #define _PRINT_INFO_H
>
> #include <stdio.h>
> -#include <sys/time.h>
> +#include <time.h>
>
> extern int message_level;
> extern int flag_strerr_message;
> @@ -25,9 +25,9 @@ extern int flag_ignore_r_char;
>
> void show_version(void);
> void print_usage(void);
> -void print_progress(const char *msg, unsigned long current, unsigned long end, struct timeval *start);
> +void print_progress(const char *msg, unsigned long current, unsigned long end, struct timespec *start);
>
> -void print_execution_time(char *step_name, struct timeval *tv_start);
> +void print_execution_time(char *step_name, struct timespec *ts_start);
>
> /*
> * Message texts
>
_______________________________________________
kexec mailing list
kexec@lists.infradead.org
http://lists.infradead.org/mailman/listinfo/kexec
^ permalink raw reply [flat|nested] 5+ messages in thread
end of thread, other threads:[~2018-07-06 13:41 UTC | newest]
Thread overview: 5+ messages (download: mbox.gz / follow: Atom feed)
-- links below jump to the message on this page --
2018-06-20 9:50 [PATCH 1/2] makedumpfile: Use monotonic clock to calculate ETA and stats Petr Tesarik
2018-06-20 9:50 ` [PATCH 2/2] makedumpfile: Check if clock_gettime() requires -lrt Petr Tesarik
2018-06-29 7:26 ` [PATCH 1/2] makedumpfile: Use monotonic clock to calculate ETA and stats lijiang
2018-06-29 13:49 ` Kazuhito Hagio
2018-07-06 13:40 ` Kazuhito Hagio
This is an external index of several public inboxes,
see mirroring instructions on how to clone and mirror
all data and code used by this external index.