GRPC C++
1.39.1
|
#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") |
#define GRPC_COMBINER_DEBUG_SPAM | ( | op, | |
delta | |||
) |
#define GRPC_COMBINER_TRACE | ( | fn | ) |
#define OLD_STATE_WAS | ( | orphaned, | |
elem_count | |||
) |
#define STATE_ELEM_COUNT_LOW_BIT 2 |
#define STATE_UNORPHANED 1 |
bool grpc_combiner_continue_exec_ctx | ( | ) |
grpc_core::Combiner* grpc_combiner_create | ( | void | ) |
grpc_core::Combiner* grpc_combiner_ref | ( | grpc_core::Combiner *lock | GRPC_COMBINER_DEBUG_ARGS | ) |
void grpc_combiner_unref | ( | grpc_core::Combiner *lock | GRPC_COMBINER_DEBUG_ARGS | ) |
grpc_core::DebugOnlyTraceFlag grpc_combiner_trace(false, "combiner") | ( | false | , |
"combiner" | |||
) |