xlt_quote_latency.h

浏览该文件的文档.

 
#pragma once
 
#include <cstdint>
#include <ctime>
 
#ifdef __x86_64__
#include <x86intrin.h>
#endif
 
namespace x1 {
 
extern thread_local uint64_t g_quote_rx_tsc;
 
extern thread_local uint64_t g_quote_rx_timestamp_ns;
 
extern thread_local uint64_t g_quote_rx_poll_return_ns;
 
extern thread_local uint64_t g_quote_rx_before_notify_ns;
 
extern thread_local uint32_t g_quote_rx_frame_bytes;
extern thread_local uint32_t g_quote_rx_poll_batch_size;
extern thread_local uint32_t g_quote_rx_poll_event_index;
 
inline uint64_t xlt_quote_rx_timestamp_ns() {
    return g_quote_rx_timestamp_ns;
}
 
inline bool xlt_quote_has_rx_hw_timestamp() {
    return g_quote_rx_timestamp_ns != 0;
}
 
inline bool xlt_quote_has_rx_latency_breakdown() {
    return g_quote_rx_poll_return_ns != 0 && g_quote_rx_before_notify_ns != 0;
}
 
inline uint64_t xlt_quote_rx_poll_return_ns() {
    return g_quote_rx_poll_return_ns;
}
 
inline uint64_t xlt_quote_rx_before_notify_ns() {
    return g_quote_rx_before_notify_ns;
}
 
inline uint32_t xlt_quote_rx_frame_bytes() {
    return g_quote_rx_frame_bytes;
}
 
inline uint32_t xlt_quote_rx_poll_batch_size() {
    return g_quote_rx_poll_batch_size;
}
 
inline uint32_t xlt_quote_rx_poll_event_index() {
    return g_quote_rx_poll_event_index;
}
 
inline uint64_t xlt_quote_rx_timestamp_tsc() {
    return g_quote_rx_tsc;
}
 
inline void xlt_quote_set_rx_timestamps(uint64_t rx_tsc,
                                        uint64_t timestamp_ns,
                                        uint64_t poll_return_ns = 0,
                                        uint64_t before_notify_ns = 0,
                                        uint32_t frame_bytes = 0,
                                        uint32_t poll_batch_size = 0,
                                        uint32_t poll_event_index = 0) {
    g_quote_rx_tsc = rx_tsc;
    g_quote_rx_timestamp_ns = timestamp_ns;
    g_quote_rx_poll_return_ns = poll_return_ns;
    g_quote_rx_before_notify_ns = before_notify_ns;
    g_quote_rx_frame_bytes = frame_bytes;
    g_quote_rx_poll_batch_size = poll_batch_size;
    g_quote_rx_poll_event_index = poll_event_index;
}
 
inline uint64_t xlt_quote_rx_latency_ns() {
    struct timespec ts;
    clock_gettime(CLOCK_REALTIME, &ts);
    return (uint64_t)ts.tv_sec * 1000000000ULL + (uint64_t)ts.tv_nsec;
}
 
inline uint64_t xlt_quote_rx_latency_tsc() {
#ifdef __x86_64__
    unsigned int aux;
    return __rdtscp(&aux);
#else
    // fallback: 非x86架构
    struct timespec ts;
    clock_gettime(CLOCK_MONOTONIC, &ts);
    return (uint64_t)ts.tv_sec * 1000000000ULL + ts.tv_nsec;
#endif
}
 
} // namespace x1