diff options
Diffstat (limited to 'examples/redis-unstable/src/monotonic.c')
| -rw-r--r-- | examples/redis-unstable/src/monotonic.c | 247 |
1 files changed, 0 insertions, 247 deletions
diff --git a/examples/redis-unstable/src/monotonic.c b/examples/redis-unstable/src/monotonic.c deleted file mode 100644 index b198fe3..0000000 --- a/examples/redis-unstable/src/monotonic.c +++ /dev/null @@ -1,247 +0,0 @@ -#include "monotonic.h" -#include <stddef.h> -#include <stdlib.h> -#include <stdio.h> -#include <time.h> -#include "redisassert.h" -#include <string.h> - -/* The function pointer for clock retrieval. */ -monotime (*getMonotonicUs)(void) = NULL; - -static char monotonic_info_string[32]; - - -/* Using the processor clock (aka TSC on x86) can provide improved performance - * throughout Redis wherever the monotonic clock is used. The processor clock - * is significantly faster than calling 'clock_getting' (POSIX). While this is - * generally safe on modern systems, this link provides additional information - * about use of the x86 TSC: http://oliveryang.net/2015/09/pitfalls-of-TSC-usage - * - * On ARM aarch64 systems, the hardware clock is enabled by default because the - * ARM Generic Timer is architecturally guaranteed to be available and monotonic - * on all ARMv8-A processors (see the “The Generic Timer in AArch64 state” - * section of the Arm Architecture Reference Manual for Armv8-A). - * - * To use the processor clock on other architectures, either uncomment this line, - * or build with - * CFLAGS="-DUSE_PROCESSOR_CLOCK" -#define USE_PROCESSOR_CLOCK - */ - - -#if defined(USE_PROCESSOR_CLOCK) && defined(__x86_64__) && defined(__linux__) -#include <regex.h> -#include <x86intrin.h> - -static long mono_ticksPerMicrosecond = 0; - -static monotime getMonotonicUs_x86(void) { - return __rdtsc() / mono_ticksPerMicrosecond; -} - -static void monotonicInit_x86linux(void) { - const int bufflen = 256; - char buf[bufflen]; - regex_t cpuGhzRegex, constTscRegex; - const size_t nmatch = 2; - regmatch_t pmatch[nmatch]; - int constantTsc = 0; - int rc; - - /* Determine the number of TSC ticks in a micro-second. This is - * a constant value matching the standard speed of the processor. - * On modern processors, this speed remains constant even though - * the actual clock speed varies dynamically for each core. */ - rc = regcomp(&cpuGhzRegex, "^model name\\s+:.*@ ([0-9.]+)GHz", REG_EXTENDED); - assert(rc == 0); - - /* Also check that the constant_tsc flag is present. (It should be - * unless this is a really old CPU. */ - rc = regcomp(&constTscRegex, "^flags\\s+:.* constant_tsc", REG_EXTENDED); - assert(rc == 0); - - FILE *cpuinfo = fopen("/proc/cpuinfo", "r"); - if (cpuinfo != NULL) { - while (fgets(buf, bufflen, cpuinfo) != NULL) { - if (regexec(&cpuGhzRegex, buf, nmatch, pmatch, 0) == 0) { - buf[pmatch[1].rm_eo] = '\0'; - double ghz = atof(&buf[pmatch[1].rm_so]); - mono_ticksPerMicrosecond = (long)(ghz * 1000); - break; - } - } - while (fgets(buf, bufflen, cpuinfo) != NULL) { - if (regexec(&constTscRegex, buf, nmatch, pmatch, 0) == 0) { - constantTsc = 1; - break; - } - } - - fclose(cpuinfo); - } - regfree(&cpuGhzRegex); - regfree(&constTscRegex); - - if (mono_ticksPerMicrosecond == 0) { - fprintf(stderr, "monotonic: x86 linux, unable to determine clock rate\n"); - return; - } - if (!constantTsc) { - fprintf(stderr, "monotonic: x86 linux, 'constant_tsc' flag not present\n"); - return; - } - - snprintf(monotonic_info_string, sizeof(monotonic_info_string), - "X86 TSC @ %ld ticks/us", mono_ticksPerMicrosecond); - getMonotonicUs = getMonotonicUs_x86; -} -#endif - -#if defined(__aarch64__) -static long mono_ticksPerMicrosecond = 0; - -/* Read the clock value. - * CNTVCT_EL0 is a system counter register, that provides the monotonic - * timestamp as a 64-bit count value. */ -static inline uint64_t __cntvct(void) { - uint64_t virtual_timer_value; - __asm__ volatile("mrs %0, cntvct_el0" : "=r"(virtual_timer_value)); - return virtual_timer_value; -} - -/* Read the Count-timer Frequency. - * CNTFRQ_EL0 is a system counter register that provides the frequency (in Hz) - * needed to convert ticks to microseconds. Together with CNTVCT_EL0, this enables - * high-performance monotonic time measurement without system calls. */ -static inline uint32_t cntfrq_hz(void) { - uint64_t virtual_freq_value; - __asm__ volatile("mrs %0, cntfrq_el0" : "=r"(virtual_freq_value)); - return (uint32_t)virtual_freq_value; /* top 32 bits are reserved */ -} - -static monotime getMonotonicUs_aarch64(void) { - return __cntvct() / mono_ticksPerMicrosecond; -} - -static void monotonicInit_aarch64(void) { - mono_ticksPerMicrosecond = (long)cntfrq_hz() / 1000L / 1000L; - if (mono_ticksPerMicrosecond == 0) { - fprintf(stderr, "monotonic: aarch64, unable to determine clock rate\n"); - return; - } - - snprintf(monotonic_info_string, sizeof(monotonic_info_string), - "ARM CNTVCT @ %ld ticks/us", mono_ticksPerMicrosecond); - getMonotonicUs = getMonotonicUs_aarch64; -} -#endif - - -#if defined(USE_PROCESSOR_CLOCK) && defined(__riscv) && defined(__linux__) -static long mono_ticksPerMicrosecond = 0; - -static inline uint64_t read_mtime(void) { - uint64_t val; - asm volatile("csrr %0, time" : "=r"(val)); - return val; -} - -/* Read RISC-V timebase-frequency, which may be stored as either a 64-bit - * or 32-bit big-endian integer in the device tree. */ -static uint64_t get_timebase_frequency(void) { - uint64_t freq = 0; - FILE *fp = fopen("/proc/device-tree/cpus/timebase-frequency", "rb"); - if (!fp) - return 0; - - uint8_t buf[8] = {0}; - size_t cnt = fread(buf, 1, sizeof(buf), fp); - fclose(fp); - - if (cnt == 8) { - uint64_t be64 = 0; - memcpy(&be64, buf, sizeof(be64)); - /* Convert be64 from big-endian to little-endian. */ - freq = __builtin_bswap64(be64); - } else if (cnt == 4) { - uint32_t be32 = 0; - memcpy(&be32, buf, sizeof(be32)); - /* Convert be32 from big-endian to little-endian. */ - freq = __builtin_bswap32(be32); - } else { - /* Unable to read timebase-frequency. */ - return 0; - } - - return freq; -} - -static monotime getMonotonicUs_riscv(void) { - return read_mtime() / mono_ticksPerMicrosecond; -} - -static void monotonicInit_riscv(void) { - mono_ticksPerMicrosecond = (long)get_timebase_frequency() / 1000L / 1000L; - if (mono_ticksPerMicrosecond == 0) { - fprintf(stderr, "monotonic: riscv, unable to determine clock rate\n"); - return; - } - snprintf(monotonic_info_string, sizeof(monotonic_info_string), - "RISC-V mtime @ %ld ticks/us", mono_ticksPerMicrosecond); - getMonotonicUs = getMonotonicUs_riscv; -} -#endif - -static monotime getMonotonicUs_posix(void) { - /* clock_gettime() is specified in POSIX.1b (1993). Even so, some systems - * did not support this until much later. CLOCK_MONOTONIC is technically - * optional and may not be supported - but it appears to be universal. - * If this is not supported, provide a system-specific alternate version. */ - struct timespec ts; - clock_gettime(CLOCK_MONOTONIC, &ts); - return ((uint64_t)ts.tv_sec) * 1000000 + ts.tv_nsec / 1000; -} - -static void monotonicInit_posix(void) { - /* Ensure that CLOCK_MONOTONIC is supported. This should be supported - * on any reasonably current OS. If the assertion below fails, provide - * an appropriate alternate implementation. */ - struct timespec ts; - int rc = clock_gettime(CLOCK_MONOTONIC, &ts); - assert(rc == 0); - - snprintf(monotonic_info_string, sizeof(monotonic_info_string), - "POSIX clock_gettime"); - getMonotonicUs = getMonotonicUs_posix; -} - - - -const char * monotonicInit(void) { - #if defined(USE_PROCESSOR_CLOCK) && defined(__x86_64__) && defined(__linux__) - if (getMonotonicUs == NULL) monotonicInit_x86linux(); - #endif - - #if defined(__aarch64__) - if (getMonotonicUs == NULL) monotonicInit_aarch64(); - #endif - - #if defined(USE_PROCESSOR_CLOCK) && defined(__riscv) && defined(__linux__) - if (getMonotonicUs == NULL) monotonicInit_riscv(); - #endif - - if (getMonotonicUs == NULL) monotonicInit_posix(); - - return monotonic_info_string; -} - -const char *monotonicInfoString(void) { - return monotonic_info_string; -} - -monotonic_clock_type monotonicGetType(void) { - if (getMonotonicUs == getMonotonicUs_posix) - return MONOTONIC_CLOCK_POSIX; - return MONOTONIC_CLOCK_HW; -} |
