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::Combiner *	grpc_combiner_create (void)
void	grpc_combiner_unref (grpc_core::Combiner *lock GRPC_COMBINER_DEBUG_ARGS)
grpc_core::Combiner *	grpc_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:

  if (grpc_combiner_trace.enabled()) {                                     \
    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); \
  }

GRPC_COMBINER_TRACE

#define GRPC_COMBINER_TRACE

(

fn

)

Value:

  do {                                   \
    if (grpc_combiner_trace.enabled()) { \
      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))

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"
	)