Commit 49bc3005 authored by Krzysztof Karas's avatar Krzysztof Karas Committed by Tomasz Zawadzki
Browse files

spdk_top: move store_last_run_counter() function 



Moves store_last_run_counter() function to allow next patch to
call it earlier in the code, inside get_data() function.

Signed-off-by: default avatarKrzysztof Karas <krzysztof.karas@intel.com>
Change-Id: I1e37080ec86309bbf33442fa12cbe9dc575cc864
Reviewed-on: https://review.spdk.io/gerrit/c/spdk/spdk/+/7950


Tested-by: default avatarSPDK CI Jenkins <sys_sgci@intel.com>
Community-CI: Mellanox Build Bot
Reviewed-by: default avatarTomasz Zawadzki <tomasz.zawadzki@intel.com>
Reviewed-by: default avatarPaul Luse <paul.e.luse@intel.com>
Reviewed-by: default avatarAleksey Marchuk <alexeymar@mellanox.com>
parent 39950bc8

app/spdk_top/spdk_top.c

+24 −24
Original line number Diff line number Diff line
@@ -592,6 +592,30 @@ sort_threads(const void *p1, const void *p2) 
	}

}



static void

store_last_run_counter(const char *poller_name, uint64_t thread_id, uint64_t last_run_counter)

{

	struct run_counter_history *history;



	TAILQ_FOREACH(history, &g_run_counter_history, link) {

		if (!strcmp(history->poller_name, poller_name) && history->thread_id == thread_id) {

			history->last_run_counter = last_run_counter;

			return;

		}

	}



	history = calloc(1, sizeof(*history));

	if (history == NULL) {

		fprintf(stderr, "Unable to allocate a history object in store_last_run_counter.\n");

		return;

	}

	history->poller_name = strdup(poller_name);

	history->thread_id = thread_id;

	history->last_run_counter = last_run_counter;



	TAILQ_INSERT_TAIL(&g_run_counter_history, history, link);

}



static int

get_data(void)

{
@@ -995,30 +1019,6 @@ get_last_run_counter(const char *poller_name, uint64_t thread_id) 
	return NULL;

}



static void

store_last_run_counter(const char *poller_name, uint64_t thread_id, uint64_t last_run_counter)

{

	struct run_counter_history *history;



	TAILQ_FOREACH(history, &g_run_counter_history, link) {

		if (!strcmp(history->poller_name, poller_name) && history->thread_id == thread_id) {

			history->last_run_counter = last_run_counter;

			return;

		}

	}



	history = calloc(1, sizeof(*history));

	if (history == NULL) {

		fprintf(stderr, "Unable to allocate a history object in store_last_run_counter.\n");

		return;

	}

	history->poller_name = strdup(poller_name);

	history->thread_id = thread_id;

	history->last_run_counter = last_run_counter;



	TAILQ_INSERT_TAIL(&g_run_counter_history, history, link);

}



enum sort_type {

	BY_NAME,

	USE_GLOBAL,