GRPC C++  1.39.1
Namespaces | Macros | Functions | Variables
combiner.cc File Reference
#include <grpc/support/port_platform.h>
#include "src/core/lib/iomgr/combiner.h"
#include <assert.h>
#include <inttypes.h>
#include <string.h>
#include <grpc/support/alloc.h>
#include <grpc/support/log.h>
#include "src/core/lib/debug/stats.h"
#include "src/core/lib/gprpp/mpscq.h"
#include "src/core/lib/iomgr/executor.h"
#include "src/core/lib/iomgr/iomgr.h"
#include "src/core/lib/profiling/timers.h"

Namespaces

 grpc_core
 Round Robin Policy.
 

Macros

#define GRPC_COMBINER_TRACE(fn)
 
#define STATE_UNORPHANED   1
 
#define STATE_ELEM_COUNT_LOW_BIT   2
 
#define GRPC_COMBINER_DEBUG_SPAM(op, delta)
 
#define OLD_STATE_WAS(orphaned, elem_count)
 

Functions

grpc_core::Combinergrpc_combiner_create (void)
 
void grpc_combiner_unref (grpc_core::Combiner *lock GRPC_COMBINER_DEBUG_ARGS)
 
grpc_core::Combinergrpc_combiner_ref (grpc_core::Combiner *lock GRPC_COMBINER_DEBUG_ARGS)
 
bool grpc_combiner_continue_exec_ctx ()
 

Variables

grpc_core::DebugOnlyTraceFlag grpc_combiner_trace (false, "combiner")
 

Macro Definition Documentation

◆ GRPC_COMBINER_DEBUG_SPAM

#define GRPC_COMBINER_DEBUG_SPAM (   op,
  delta 
)
Value:
gpr_log(file, line, GPR_LOG_SEVERITY_DEBUG, \
"C:%p %s %" PRIdPTR " --> %" PRIdPTR " %s", lock, (op), \
gpr_atm_no_barrier_load(&lock->refs.count), \
gpr_atm_no_barrier_load(&lock->refs.count) + (delta), reason); \
}
bool enabled()
Definition: trace.h:80
grpc_core::DebugOnlyTraceFlag grpc_combiner_trace(false, "combiner")
#define gpr_atm_no_barrier_load(p)
Definition: atm_gcc_atomic.h:51
@ GPR_LOG_SEVERITY_DEBUG
Definition: log.h:44

◆ GRPC_COMBINER_TRACE

#define GRPC_COMBINER_TRACE (   fn)
Value:
do { \
fn; \
} \
} while (0)

◆ OLD_STATE_WAS

#define OLD_STATE_WAS (   orphaned,
  elem_count 
)
Value:
(((orphaned) ? 0 : STATE_UNORPHANED) | \
((elem_count)*STATE_ELEM_COUNT_LOW_BIT))
#define STATE_UNORPHANED
Definition: combiner.cc:45
#define STATE_ELEM_COUNT_LOW_BIT
Definition: combiner.cc:46

◆ STATE_ELEM_COUNT_LOW_BIT

#define STATE_ELEM_COUNT_LOW_BIT   2

◆ STATE_UNORPHANED

#define STATE_UNORPHANED   1

Function Documentation

◆ grpc_combiner_continue_exec_ctx()

bool grpc_combiner_continue_exec_ctx ( )

◆ grpc_combiner_create()

grpc_core::Combiner* grpc_combiner_create ( void  )

◆ grpc_combiner_ref()

grpc_core::Combiner* grpc_combiner_ref ( grpc_core::Combiner *lock  GRPC_COMBINER_DEBUG_ARGS)

◆ grpc_combiner_unref()

void grpc_combiner_unref ( grpc_core::Combiner *lock  GRPC_COMBINER_DEBUG_ARGS)

Variable Documentation

◆ grpc_combiner_trace

grpc_core::DebugOnlyTraceFlag grpc_combiner_trace(false, "combiner") ( false  ,
"combiner"   
)