/*
 * Copyright (c) 2013, Intel Corporation
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions are met:
 *
 *   * Redistributions of source code must retain the above copyright notice,
 *     this list of conditions and the following disclaimer.
 *   * Redistributions in binary form must reproduce the above copyright
 *     notice, this list of conditions and the following disclaimer in the
 *     documentation and/or other materials provided with the distribution.
 *   * Neither the name of Intel Corporation nor the names of its contributors
 *     may be used to endorse or promote products derived from this software
 *     without specific prior written permission.
 *
 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
 * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
 * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE
 * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
 * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
 * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
 * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
 * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
 * POSSIBILITY OF SUCH DAMAGE.
 */

#ifndef _NUMATOP_PERF_H
#define	_NUMATOP_PERF_H

#include <sys/types.h>
#include <inttypes.h>
#include <pthread.h>
#include "types.h"
#include "./os/os_perf.h"

#ifdef __cplusplus
extern "C" {
#endif

#define	PERF_WAIT_NSEC	60
#define	PERF_INTVAL_MIN_MS	1000

typedef enum {
	PERF_STATUS_IDLE = 0,
	PERF_STATUS_PROFILING_STARTED,
	PERF_STATUS_PROFILING_PART_STARTED,
	PERF_STATUS_PROFILING_MULTI_STARTED,
	PERF_STATUS_PROFILING_FAILED,
	PERF_STATUS_CALLCHAIN_STARTED,
	PERF_STATUS_CALLCHAIN_FAILED,
	PERF_STATUS_LL_STARTED,
	PERF_STATUS_LL_FAILED,
	PERF_STATUS_PQOS_CMT_STARTED,
	PERF_STATUS_PQOS_CMT_FAILED,
	PERF_STATUS_UNCORE_STARTED,
	PERF_STATUS_UNCORE_FAILED,
} perf_status_t;

typedef enum {
	PERF_INVALID_ID = 0,
	PERF_PROFILING_START_ID,
	PERF_PROFILING_PARTPAUSE_ID,
	PERF_PROFILING_MULTIPAUSE_ID,
	PERF_PROFILING_RESTORE_ID,
	PERF_PROFILING_MULTI_RESTORE_ID,
	PERF_PROFILING_SMPL_ID,
	PERF_CALLCHAIN_START_ID,
	PERF_CALLCHAIN_SMPL_ID,
	PERF_LL_START_ID,
	PERF_LL_SMPL_ID,	
	PERF_STOP_ID,
	PERF_QUIT_ID,
	PERF_PQOS_CMT_START_ID,
	PERF_PQOS_CMT_SMPL_ID,
	PERF_PQOS_CMT_STOP_ID,
	PERF_UNCORE_START_ID,
	PERF_UNCORE_SMPL_ID,
	PERF_UNCORE_STOP_ID,
} perf_taskid_t;

typedef struct _task_quit {
	perf_taskid_t task_id;
} task_quit_t;

typedef struct _task_allstop {
	perf_taskid_t task_id;
} task_allstop_t;

typedef struct _task_profiling {
	perf_taskid_t task_id;
	boolean_t use_dispflag1;
} task_profiling_t;

typedef struct _task_partpause {
	perf_taskid_t task_id;
	perf_count_id_t perf_count_id;
} task_partpause_t;

typedef struct _task_multipause {
	perf_taskid_t task_id;
	perf_count_id_t *perf_count_ids;
} task_multipause_t;

typedef struct _task_restore {
	perf_taskid_t task_id;
	perf_count_id_t perf_count_id;
} task_restore_t;

typedef struct _task_multi_restore {
	perf_taskid_t task_id;
	perf_count_id_t *perf_count_ids;
} task_multi_restore_t;

typedef struct _task_callchain {
	perf_taskid_t task_id;
	pid_t pid;
	int lwpid;
} task_callchain_t;

typedef struct _task_ll {
	perf_taskid_t task_id;
	pid_t pid;
	int lwpid;
} task_ll_t;

typedef struct _task_pqos_cmt {
	perf_taskid_t task_id;
	pid_t pid;
	int lwpid;
	int flags;
} task_pqos_cmt_t;

typedef struct _task_uncore {
	perf_taskid_t task_id;
	int nid;
} task_uncore_t;

typedef union _perf_task {
	task_quit_t quit;
	task_allstop_t allstop;
	task_profiling_t profiling;
	task_partpause_t partpause;
	task_restore_t restore;
	task_callchain_t callchain;
	task_ll_t ll;
	task_pqos_cmt_t pqos_cmt;
	task_uncore_t uncore;
} perf_task_t;

typedef struct _perf_llrecgrp {
	os_perf_llrec_t *rec_arr;
	int nrec_cur;
	int nrec_max;
	int cursor;
} perf_llrecgrp_t;

typedef struct _perf_chainrec {
	uint64_t count_value;
	os_perf_callchain_t callchain;
} perf_chainrec_t;

typedef struct _perf_chainrecgrp {
	perf_chainrec_t *rec_arr;
	int nrec_cur;
	int nrec_max;
	int cursor;
} perf_chainrecgrp_t;

typedef struct _perf_countchain {
	perf_chainrecgrp_t chaingrps[PERF_COUNT_NUM];
} perf_countchain_t;

#define	TASKID(task_addr) \
	(*(perf_taskid_t *)(task_addr))

#define	TASKID_SET(task_addr, task_id) \
	((*(perf_taskid_t *)(task_addr)) = (task_id))

#define	PERF_PROFILING_STARTED \
	(s_perf_ctl.status == PERF_STATUS_PROFILING_STARTED)

typedef struct _perf_ctl {
	pthread_mutex_t mutex;
	pthread_cond_t cond;
	pthread_mutex_t status_mutex;
	pthread_cond_t status_cond;
	perf_status_t status;
	pthread_t thr;
	perf_task_t task;
	boolean_t inited;
	uint64_t last_ms;
	uint64_t last_ms_pqos;
} perf_ctl_t;

extern int perf_init(void);
extern void perf_fini(void);
extern int perf_allstop(void);
extern boolean_t perf_profiling_started(void);
extern int perf_profiling_start(void);
extern int perf_profiling_smpl(boolean_t);
extern int perf_profiling_partpause(ui_count_id_t);
extern int perf_profiling_restore(ui_count_id_t);
extern boolean_t perf_callchain_started(void);
extern int perf_callchain_start(pid_t, int);
extern int perf_callchain_smpl(void);
extern boolean_t perf_ll_started(void);
extern int perf_ll_start(pid_t);
extern int perf_ll_smpl(pid_t, int);
extern void perf_llrecgrp_reset(perf_llrecgrp_t *);
extern void perf_countchain_reset(perf_countchain_t *);
extern void perf_status_set(perf_status_t);
extern void perf_status_set_no_signal(perf_status_t);
extern void* perf_priv_alloc(boolean_t *);
extern void perf_priv_free(void *);
extern void perf_task_set(perf_task_t *);
extern int perf_status_wait(perf_status_t);
extern void perf_smpl_wait(void);
extern void perf_ll_started_set(void);
extern int perf_pqos_cmt_start(int, int, int);
extern int perf_pqos_cmt_smpl(pid_t, int);
extern int perf_pqos_active_proc_setup(int, boolean_t);
extern boolean_t perf_pqos_cmt_started(void);
extern int perf_pqos_cmt_stop(pid_t, int);
extern int perf_pqos_proc_setup(int, int, int);
extern int perf_uncore_stop(int);
extern int perf_uncore_setup(int);
extern int perf_uncore_smpl(int);
extern boolean_t perf_uncore_started(void);

#ifdef __cplusplus
}
#endif

#endif /* _NUMATOP_PERF_H */