GRPC Core
18.0.0
|
#include <grpc/support/port_platform.h>
#include "src/core/lib/iomgr/port.h"
#include <inttypes.h>
#include <string>
#include "absl/strings/str_cat.h"
#include "src/core/lib/iomgr/timer.h"
#include <grpc/support/alloc.h>
#include <grpc/support/cpu.h>
#include <grpc/support/log.h>
#include <grpc/support/sync.h>
#include "src/core/lib/debug/trace.h"
#include "src/core/lib/gpr/spinlock.h"
#include "src/core/lib/gpr/tls.h"
#include "src/core/lib/gpr/useful.h"
#include "src/core/lib/iomgr/exec_ctx.h"
#include "src/core/lib/iomgr/time_averaged_stats.h"
#include "src/core/lib/iomgr/timer_heap.h"
Data Structures | |
struct | timer_shard |
struct | shared_mutables |
Macros | |
#define | INVALID_HEAP_INDEX 0xffffffffu |
#define | ADD_DEADLINE_SCALE 0.33 |
#define | MIN_QUEUE_WINDOW_DURATION 0.01 |
#define | MAX_QUEUE_WINDOW_DURATION 1 |
#define | NUM_HASH_BUCKETS 1009 /* Prime number close to 1000 */ |
#define | INIT_TIMER_HASH_TABLE() init_timer_ht() |
#define | DESTROY_TIMER_HASH_TABLE() destroy_timer_ht() |
#define | ADD_TO_HASH_TABLE(t) add_to_ht((t)) |
#define | REMOVE_FROM_HASH_TABLE(t) remove_from_ht((t)) |
#define | VALIDATE_NON_PENDING_TIMER(t) validate_non_pending_timer((t)) |
Functions | |
struct shared_mutables | GPR_ALIGN_STRUCT (GPR_CACHELINE_SIZE) |
void | grpc_timer_init_unset (grpc_timer *timer) |
Variables | |
grpc_core::TraceFlag | grpc_timer_trace (false, "timer") |
grpc_core::TraceFlag | grpc_timer_check_trace (false, "timer_check") |
grpc_millis | min_timer |
gpr_spinlock | checker_mu |
bool | initialized |
gpr_mu | mu |
grpc_timer_vtable | grpc_generic_timer_vtable |
#define ADD_DEADLINE_SCALE 0.33 |
#define ADD_TO_HASH_TABLE | ( | t | ) | add_to_ht((t)) |
#define DESTROY_TIMER_HASH_TABLE | ( | ) | destroy_timer_ht() |
#define INIT_TIMER_HASH_TABLE | ( | ) | init_timer_ht() |
#define INVALID_HEAP_INDEX 0xffffffffu |
#define MAX_QUEUE_WINDOW_DURATION 1 |
#define MIN_QUEUE_WINDOW_DURATION 0.01 |
#define NUM_HASH_BUCKETS 1009 /* Prime number close to 1000 */ |
#define REMOVE_FROM_HASH_TABLE | ( | t | ) | remove_from_ht((t)) |
#define VALIDATE_NON_PENDING_TIMER | ( | t | ) | validate_non_pending_timer((t)) |
struct shared_mutables GPR_ALIGN_STRUCT | ( | GPR_CACHELINE_SIZE | ) |
void grpc_timer_init_unset | ( | grpc_timer * | timer | ) |
gpr_spinlock checker_mu |
grpc_timer_vtable grpc_generic_timer_vtable |
grpc_core::TraceFlag grpc_timer_check_trace(false, "timer_check") | ( | false | , |
"timer_check" | |||
) |
grpc_core::TraceFlag grpc_timer_trace(false, "timer") | ( | false | , |
"timer" | |||
) |
bool initialized |
grpc_millis min_timer |
gpr_mu mu |