rte_power_empty_poll.h

Go to the documentation of this file.

/* SPDX-License-Identifier: BSD-3-Clause
 * Copyright(c) 2010-2018 Intel Corporation
 */

#ifndef _RTE_EMPTY_POLL_H
#define _RTE_EMPTY_POLL_H

#include <stdint.h>
#include <stdbool.h>

#include <rte_common.h>
#include <rte_byteorder.h>
#include <rte_log.h>
#include <rte_string_fns.h>
#include <rte_power.h>
#include <rte_timer.h>

#ifdef __cplusplus
extern "C" {
#endif

#define NUM_FREQS  RTE_MAX_LCORE_FREQS

#define BINS_AV 4 /* Has to be ^2 */

#define DROP (NUM_DIRECTIONS * NUM_DEVICES)

#define NUM_PRIORITIES          2

#define NUM_NODES         256  /* Max core number*/

/* Processor Power State */
enum freq_val {
    LOW,
    MED,
    HGH,
    NUM_FREQ = NUM_FREQS
};


/* Queue Polling State */
enum queue_state {
    TRAINING, /* NO TRAFFIC */
    MED_NORMAL,   /* MED */
    HGH_BUSY,     /* HIGH */
    LOW_PURGE,    /* LOW */
};

/* Queue Stats */
struct freq_threshold {

    uint64_t base_edpi;
    bool trained;
    uint32_t threshold_percent;
    uint32_t cur_train_iter;
};

/* Each Worker Thread Empty Poll Stats */
struct priority_worker {

    /* Current dequeue and throughput counts */
    /* These 2 are written to by the worker threads */
    /* So keep them on their own cache line */
    uint64_t empty_dequeues;
    uint64_t num_dequeue_pkts;

    enum queue_state queue_state;

    uint64_t empty_dequeues_prev;
    uint64_t num_dequeue_pkts_prev;

    /* Used for training only */
    struct freq_threshold thresh[NUM_FREQ];
    enum freq_val cur_freq;

    /* bucket arrays to calculate the averages */
    /* edpi mean empty poll counter difference per interval */
    uint64_t edpi_av[BINS_AV];
    /* empty poll counter */
    uint32_t ec;
    /* ppi mean valid poll counter per interval */
    uint64_t ppi_av[BINS_AV];
    /* valid poll counter */
    uint32_t pc;

    uint32_t lcore_id;
    uint32_t iter_counter;
    uint32_t threshold_ctr;
    uint32_t display_ctr;
    uint8_t  dev_id;

} __rte_cache_aligned;


struct stats_data {

    struct priority_worker wrk_stats[NUM_NODES];

    /* flag to stop rx threads processing packets until training over */
    bool start_rx;

};

/* Empty Poll Parameters */
struct ep_params {

    /* Timer related stuff */
    uint64_t interval_ticks;
    uint32_t max_train_iter;

    struct rte_timer timer0;
    struct stats_data wrk_data;
};


/* Sample App Init information */
struct ep_policy {

    uint64_t med_base_edpi;
    uint64_t hgh_base_edpi;

    enum queue_state state;
};



int __rte_experimental
rte_power_empty_poll_stat_init(struct ep_params **eptr, uint8_t *freq_tlb,
        struct ep_policy *policy);

void __rte_experimental
rte_power_empty_poll_stat_free(void);

int __rte_experimental
rte_power_empty_poll_stat_update(unsigned int lcore_id);

int __rte_experimental
rte_power_poll_stat_update(unsigned int lcore_id, uint8_t nb_pkt);

uint64_t __rte_experimental
rte_power_empty_poll_stat_fetch(unsigned int lcore_id);

uint64_t __rte_experimental
rte_power_poll_stat_fetch(unsigned int lcore_id);

void  __rte_experimental
rte_empty_poll_detection(struct rte_timer *tim, void *arg);

#ifdef __cplusplus
}
#endif

#endif