aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/core/lib/iomgr/executor.h
diff options
context:
space:
mode:
authorGravatar Sree Kuchibhotla <sreek@google.com>2018-07-10 11:29:43 -0700
committerGravatar Sree Kuchibhotla <sreek@google.com>2018-07-10 11:29:43 -0700
commit83d0bfa3dbc6a15abb3821f6b16a0b1535e4c880 (patch)
treef9c99d6f2a52d3bee9f90e41b210d256ec4c5df8 /src/core/lib/iomgr/executor.h
parent7e9d52530d0145fe8202d2fd35621407745e91ab (diff)
address code review comemnts
Diffstat (limited to 'src/core/lib/iomgr/executor.h')
-rw-r--r--src/core/lib/iomgr/executor.h21
1 files changed, 9 insertions, 12 deletions
diff --git a/src/core/lib/iomgr/executor.h b/src/core/lib/iomgr/executor.h
index cafe47decb..b6515605cb 100644
--- a/src/core/lib/iomgr/executor.h
+++ b/src/core/lib/iomgr/executor.h
@@ -34,12 +34,9 @@ typedef struct {
bool shutdown;
bool queued_long_job;
grpc_core::Thread thd;
-} thread_state;
+} ThreadState;
-typedef enum {
- GRPC_EXECUTOR_SHORT,
- GRPC_EXECUTOR_LONG
-} grpc_executor_job_length;
+typedef enum { GRPC_EXECUTOR_SHORT, GRPC_EXECUTOR_LONG } grpc_executor_job_type;
class GrpcExecutor {
public:
@@ -47,7 +44,7 @@ class GrpcExecutor {
void Init();
/** Is the executor multi-threaded? */
- bool IsThreaded();
+ bool IsThreaded() const;
/* Enable/disable threading - must be called after Init and Shutdown() */
void SetThreading(bool threading);
@@ -63,11 +60,11 @@ class GrpcExecutor {
static size_t RunClosures(grpc_closure_list list);
static void ThreadMain(void* arg);
- const char* name;
- thread_state* thd_state;
- size_t max_threads;
- gpr_atm num_threads;
- gpr_spinlock adding_thread_lock;
+ const char* name_;
+ ThreadState* thd_state_;
+ size_t max_threads_;
+ gpr_atm num_threads_;
+ gpr_spinlock adding_thread_lock_;
};
// == Global executor functions ==
@@ -75,7 +72,7 @@ class GrpcExecutor {
void grpc_executor_init();
grpc_closure_scheduler* grpc_executor_scheduler(
- grpc_executor_job_length length);
+ grpc_executor_job_type job_type);
void grpc_executor_shutdown();