diff options
author | 2015-06-24 14:03:29 +0300 | |
---|---|---|
committer | 2015-06-24 14:03:29 +0300 | |
commit | 8b52a31ed2c299b759f330c4f976b9c70f5765f4 (patch) | |
tree | 9d6da5438b5b56b1d2d57e6c13494b4e65d000e7 /src/time_histogram.h |
first version
Diffstat (limited to 'src/time_histogram.h')
-rwxr-xr-x | src/time_histogram.h | 92 |
1 files changed, 92 insertions, 0 deletions
diff --git a/src/time_histogram.h b/src/time_histogram.h new file mode 100755 index 00000000..e733c65f --- /dev/null +++ b/src/time_histogram.h @@ -0,0 +1,92 @@ +#ifndef C_TIME_HISTOGRAM_H +#define C_TIME_HISTOGRAM_H +/* + Hanoh Haim + Cisco Systems, Inc. +*/ + +/* +Copyright (c) 2015-2015 Cisco Systems, Inc. + +Licensed under the Apache License, Version 2.0 (the "License"); +you may not use this file except in compliance with the License. +You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + +Unless required by applicable law or agreed to in writing, software +distributed under the License is distributed on an "AS IS" BASIS, +WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +See the License for the specific language governing permissions and +limitations under the License. +*/ + + +#include <stdint.h> +#include "os_time.h" +#include <stdio.h> +#include <math.h> +#include "mbuf.h" +#include <string> + + +class CTimeHistogram { +public: + enum { + HISTOGRAM_SIZE=9, + HISTOGRAM_SIZE_LOG=5, + HISTOGRAM_QUEUE_SIZE=14, + }; + bool Create(void); + void Delete(); + void Reset(); + bool Add(dsec_t dt); + void Dump(FILE *fd); + void DumpWinMax(FILE *fd); + /* should be called each 1 sec */ + void update(); + dsec_t get_average_latency(); + /* get average of total data */ + dsec_t get_total_average(); + + + dsec_t get_max_latency(){ + return (get_usec(m_max_dt)); + } + + dsec_t get_max_latency_last_update(){ + return ( get_usec(m_max_win_last_dt) ); + } + + void dump_json(std::string name,std::string & json ); + + +private: + uint32_t get_usec(dsec_t d); + double get_cur_average(); + void update_average(); + + double get_base_usec(int j,int i){ + double base=pow(10.0,(double)j+1.0); + return ( base * ((double)i+1.0) ); + } + +public: + dsec_t m_min_delta;/* set to 10usec*/ + uint64_t m_cnt; + uint64_t m_high_cnt; + dsec_t m_max_dt; + dsec_t m_max_win_dt; + dsec_t m_max_win_last_dt; + dsec_t m_average; /* moving average */ + + uint32_t m_win_cnt; + dsec_t m_max_ar[HISTOGRAM_QUEUE_SIZE]; + + uint64_t m_hcnt[HISTOGRAM_SIZE_LOG][HISTOGRAM_SIZE] __rte_cache_aligned ; + uint64_t m_hcnt_shadow[HISTOGRAM_SIZE_LOG][HISTOGRAM_SIZE] __rte_cache_aligned ; // this this contorl side + uint64_t m_cnt_shadow; + uint64_t m_high_cnt_shadow; +}; + +#endif |