diff options
author | 2018-02-09 09:16:55 -0800 | |
---|---|---|
committer | 2018-02-09 09:16:55 -0800 | |
commit | be82e64b3debcdb1d9ec6a149fc85af0d46bfb7e (patch) | |
tree | cc5e1234073eb250a2c319b5a4db2919fce060ea /src/core/lib/iomgr/resource_quota.cc | |
parent | 194436342137924b4fb7429bede037a4b5ec7edb (diff) |
Autofix c casts to c++ casts
Diffstat (limited to 'src/core/lib/iomgr/resource_quota.cc')
-rw-r--r-- | src/core/lib/iomgr/resource_quota.cc | 64 |
1 files changed, 32 insertions, 32 deletions
diff --git a/src/core/lib/iomgr/resource_quota.cc b/src/core/lib/iomgr/resource_quota.cc index e64d772a7d..40dd29b6a4 100644 --- a/src/core/lib/iomgr/resource_quota.cc +++ b/src/core/lib/iomgr/resource_quota.cc @@ -244,7 +244,7 @@ static bool rq_reclaim_from_per_user_free_pool( static bool rq_reclaim(grpc_resource_quota* resource_quota, bool destructive); static void rq_step(void* rq, grpc_error* error) { - grpc_resource_quota* resource_quota = (grpc_resource_quota*)rq; + grpc_resource_quota* resource_quota = static_cast<grpc_resource_quota*>(rq); resource_quota->step_scheduled = false; do { if (rq_alloc(resource_quota)) goto done; @@ -303,7 +303,7 @@ static bool rq_alloc(grpc_resource_quota* resource_quota) { resource_user->free_pool += aborted_allocations; GRPC_CLOSURE_LIST_SCHED(&resource_user->on_allocated); gpr_mu_unlock(&resource_user->mu); - ru_unref_by(resource_user, (gpr_atm)aborted_allocations); + ru_unref_by(resource_user, static_cast<gpr_atm>(aborted_allocations)); continue; } if (resource_user->free_pool < 0 && @@ -401,12 +401,12 @@ typedef struct { } ru_slice_refcount; static void ru_slice_ref(void* p) { - ru_slice_refcount* rc = (ru_slice_refcount*)p; + ru_slice_refcount* rc = static_cast<ru_slice_refcount*>(p); gpr_ref(&rc->refs); } static void ru_slice_unref(void* p) { - ru_slice_refcount* rc = (ru_slice_refcount*)p; + ru_slice_refcount* rc = static_cast<ru_slice_refcount*>(p); if (gpr_unref(&rc->refs)) { grpc_resource_user_free(rc->resource_user, rc->size); gpr_free(rc); @@ -420,7 +420,7 @@ static const grpc_slice_refcount_vtable ru_slice_vtable = { static grpc_slice ru_slice_create(grpc_resource_user* resource_user, size_t size) { ru_slice_refcount* rc = - (ru_slice_refcount*)gpr_malloc(sizeof(ru_slice_refcount) + size); + static_cast<ru_slice_refcount*>(gpr_malloc(sizeof(ru_slice_refcount) + size)); rc->base.vtable = &ru_slice_vtable; rc->base.sub_refcount = &rc->base; gpr_ref_init(&rc->refs, 1); @@ -428,7 +428,7 @@ static grpc_slice ru_slice_create(grpc_resource_user* resource_user, rc->size = size; grpc_slice slice; slice.refcount = &rc->base; - slice.data.refcounted.bytes = (uint8_t*)(rc + 1); + slice.data.refcounted.bytes = reinterpret_cast<uint8_t*>(rc + 1); slice.data.refcounted.length = size; return slice; } @@ -439,7 +439,7 @@ static grpc_slice ru_slice_create(grpc_resource_user* resource_user, */ static void ru_allocate(void* ru, grpc_error* error) { - grpc_resource_user* resource_user = (grpc_resource_user*)ru; + grpc_resource_user* resource_user = static_cast<grpc_resource_user*>(ru); if (rulist_empty(resource_user->resource_quota, GRPC_RULIST_AWAITING_ALLOCATION)) { rq_step_sched(resource_user->resource_quota); @@ -448,7 +448,7 @@ static void ru_allocate(void* ru, grpc_error* error) { } static void ru_add_to_free_pool(void* ru, grpc_error* error) { - grpc_resource_user* resource_user = (grpc_resource_user*)ru; + grpc_resource_user* resource_user = static_cast<grpc_resource_user*>(ru); if (!rulist_empty(resource_user->resource_quota, GRPC_RULIST_AWAITING_ALLOCATION) && rulist_empty(resource_user->resource_quota, @@ -473,7 +473,7 @@ static bool ru_post_reclaimer(grpc_resource_user* resource_user, } static void ru_post_benign_reclaimer(void* ru, grpc_error* error) { - grpc_resource_user* resource_user = (grpc_resource_user*)ru; + grpc_resource_user* resource_user = static_cast<grpc_resource_user*>(ru); if (!ru_post_reclaimer(resource_user, false)) return; if (!rulist_empty(resource_user->resource_quota, GRPC_RULIST_AWAITING_ALLOCATION) && @@ -487,7 +487,7 @@ static void ru_post_benign_reclaimer(void* ru, grpc_error* error) { } static void ru_post_destructive_reclaimer(void* ru, grpc_error* error) { - grpc_resource_user* resource_user = (grpc_resource_user*)ru; + grpc_resource_user* resource_user = static_cast<grpc_resource_user*>(ru); if (!ru_post_reclaimer(resource_user, true)) return; if (!rulist_empty(resource_user->resource_quota, GRPC_RULIST_AWAITING_ALLOCATION) && @@ -506,7 +506,7 @@ static void ru_shutdown(void* ru, grpc_error* error) { if (grpc_resource_quota_trace.enabled()) { gpr_log(GPR_DEBUG, "RU shutdown %p", ru); } - grpc_resource_user* resource_user = (grpc_resource_user*)ru; + grpc_resource_user* resource_user = static_cast<grpc_resource_user*>(ru); gpr_mu_lock(&resource_user->mu); GRPC_CLOSURE_SCHED(resource_user->reclaimers[0], GRPC_ERROR_CANCELLED); GRPC_CLOSURE_SCHED(resource_user->reclaimers[1], GRPC_ERROR_CANCELLED); @@ -521,10 +521,10 @@ static void ru_shutdown(void* ru, grpc_error* error) { } static void ru_destroy(void* ru, grpc_error* error) { - grpc_resource_user* resource_user = (grpc_resource_user*)ru; + grpc_resource_user* resource_user = static_cast<grpc_resource_user*>(ru); GPR_ASSERT(gpr_atm_no_barrier_load(&resource_user->refs) == 0); for (int i = 0; i < GRPC_RULIST_COUNT; i++) { - rulist_remove(resource_user, (grpc_rulist)i); + rulist_remove(resource_user, static_cast<grpc_rulist>(i)); } GRPC_CLOSURE_SCHED(resource_user->reclaimers[0], GRPC_ERROR_CANCELLED); GRPC_CLOSURE_SCHED(resource_user->reclaimers[1], GRPC_ERROR_CANCELLED); @@ -540,7 +540,7 @@ static void ru_destroy(void* ru, grpc_error* error) { static void ru_allocated_slices(void* arg, grpc_error* error) { grpc_resource_user_slice_allocator* slice_allocator = - (grpc_resource_user_slice_allocator*)arg; + static_cast<grpc_resource_user_slice_allocator*>(arg); if (error == GRPC_ERROR_NONE) { for (size_t i = 0; i < slice_allocator->count; i++) { grpc_slice_buffer_add_indexed( @@ -563,7 +563,7 @@ typedef struct { } rq_resize_args; static void rq_resize(void* args, grpc_error* error) { - rq_resize_args* a = (rq_resize_args*)args; + rq_resize_args* a = static_cast<rq_resize_args*>(args); int64_t delta = a->size - a->resource_quota->size; a->resource_quota->size += delta; a->resource_quota->free_pool += delta; @@ -574,7 +574,7 @@ static void rq_resize(void* args, grpc_error* error) { } static void rq_reclamation_done(void* rq, grpc_error* error) { - grpc_resource_quota* resource_quota = (grpc_resource_quota*)rq; + grpc_resource_quota* resource_quota = static_cast<grpc_resource_quota*>(rq); resource_quota->reclaiming = false; rq_step_sched(resource_quota); grpc_resource_quota_unref_internal(resource_quota); @@ -587,7 +587,7 @@ static void rq_reclamation_done(void* rq, grpc_error* error) { /* Public API */ grpc_resource_quota* grpc_resource_quota_create(const char* name) { grpc_resource_quota* resource_quota = - (grpc_resource_quota*)gpr_malloc(sizeof(*resource_quota)); + static_cast<grpc_resource_quota*>(gpr_malloc(sizeof(*resource_quota))); gpr_ref_init(&resource_quota->refs, 1); resource_quota->combiner = grpc_combiner_create(); resource_quota->free_pool = INT64_MAX; @@ -640,18 +640,18 @@ void grpc_resource_quota_ref(grpc_resource_quota* resource_quota) { double grpc_resource_quota_get_memory_pressure( grpc_resource_quota* resource_quota) { - return ((double)(gpr_atm_no_barrier_load( + return (static_cast<double>(gpr_atm_no_barrier_load( &resource_quota->memory_usage_estimation))) / - ((double)MEMORY_USAGE_ESTIMATION_MAX); + (static_cast<double>(MEMORY_USAGE_ESTIMATION_MAX)); } /* Public API */ void grpc_resource_quota_resize(grpc_resource_quota* resource_quota, size_t size) { grpc_core::ExecCtx exec_ctx; - rq_resize_args* a = (rq_resize_args*)gpr_malloc(sizeof(*a)); + rq_resize_args* a = static_cast<rq_resize_args*>(gpr_malloc(sizeof(*a))); a->resource_quota = grpc_resource_quota_ref_internal(resource_quota); - a->size = (int64_t)size; + a->size = static_cast<int64_t>(size); gpr_atm_no_barrier_store(&resource_quota->last_size, (gpr_atm)GPR_MIN((size_t)GPR_ATM_MAX, size)); GRPC_CLOSURE_INIT(&a->closure, rq_resize, a, grpc_schedule_on_exec_ctx); @@ -659,7 +659,7 @@ void grpc_resource_quota_resize(grpc_resource_quota* resource_quota, } size_t grpc_resource_quota_peek_size(grpc_resource_quota* resource_quota) { - return (size_t)gpr_atm_no_barrier_load(&resource_quota->last_size); + return static_cast<size_t>gpr_atm_no_barrier_load(&resource_quota->last_size); } /******************************************************************************* @@ -672,7 +672,7 @@ grpc_resource_quota* grpc_resource_quota_from_channel_args( if (0 == strcmp(channel_args->args[i].key, GRPC_ARG_RESOURCE_QUOTA)) { if (channel_args->args[i].type == GRPC_ARG_POINTER) { return grpc_resource_quota_ref_internal( - (grpc_resource_quota*)channel_args->args[i].value.pointer.p); + static_cast<grpc_resource_quota*>(channel_args->args[i].value.pointer.p)); } else { gpr_log(GPR_DEBUG, GRPC_ARG_RESOURCE_QUOTA " should be a pointer"); } @@ -682,12 +682,12 @@ grpc_resource_quota* grpc_resource_quota_from_channel_args( } static void* rq_copy(void* rq) { - grpc_resource_quota_ref((grpc_resource_quota*)rq); + grpc_resource_quota_ref(static_cast<grpc_resource_quota*>(rq)); return rq; } static void rq_destroy(void* rq) { - grpc_resource_quota_unref_internal((grpc_resource_quota*)rq); + grpc_resource_quota_unref_internal(static_cast<grpc_resource_quota*>(rq)); } static int rq_cmp(void* a, void* b) { return GPR_ICMP(a, b); } @@ -704,7 +704,7 @@ const grpc_arg_pointer_vtable* grpc_resource_quota_arg_vtable(void) { grpc_resource_user* grpc_resource_user_create( grpc_resource_quota* resource_quota, const char* name) { grpc_resource_user* resource_user = - (grpc_resource_user*)gpr_malloc(sizeof(*resource_user)); + static_cast<grpc_resource_user*>(gpr_malloc(sizeof(*resource_user))); resource_user->resource_quota = grpc_resource_quota_ref_internal(resource_quota); GRPC_CLOSURE_INIT(&resource_user->allocate_closure, &ru_allocate, @@ -785,9 +785,9 @@ void grpc_resource_user_shutdown(grpc_resource_user* resource_user) { void grpc_resource_user_alloc(grpc_resource_user* resource_user, size_t size, grpc_closure* optional_on_done) { gpr_mu_lock(&resource_user->mu); - ru_ref_by(resource_user, (gpr_atm)size); - resource_user->free_pool -= (int64_t)size; - resource_user->outstanding_allocations += (int64_t)size; + ru_ref_by(resource_user, static_cast<gpr_atm>(size)); + resource_user->free_pool -= static_cast<int64_t>(size); + resource_user->outstanding_allocations += static_cast<int64_t>(size); if (grpc_resource_quota_trace.enabled()) { gpr_log(GPR_DEBUG, "RQ %s %s: alloc %" PRIdPTR "; free_pool -> %" PRId64, resource_user->resource_quota->name, resource_user->name, size, @@ -801,7 +801,7 @@ void grpc_resource_user_alloc(grpc_resource_user* resource_user, size_t size, GRPC_CLOSURE_SCHED(&resource_user->allocate_closure, GRPC_ERROR_NONE); } } else { - resource_user->outstanding_allocations -= (int64_t)size; + resource_user->outstanding_allocations -= static_cast<int64_t>(size); GRPC_CLOSURE_SCHED(optional_on_done, GRPC_ERROR_NONE); } gpr_mu_unlock(&resource_user->mu); @@ -810,7 +810,7 @@ void grpc_resource_user_alloc(grpc_resource_user* resource_user, size_t size, void grpc_resource_user_free(grpc_resource_user* resource_user, size_t size) { gpr_mu_lock(&resource_user->mu); bool was_zero_or_negative = resource_user->free_pool <= 0; - resource_user->free_pool += (int64_t)size; + resource_user->free_pool += static_cast<int64_t>(size); if (grpc_resource_quota_trace.enabled()) { gpr_log(GPR_DEBUG, "RQ %s %s: free %" PRIdPTR "; free_pool -> %" PRId64, resource_user->resource_quota->name, resource_user->name, size, @@ -824,7 +824,7 @@ void grpc_resource_user_free(grpc_resource_user* resource_user, size_t size) { GRPC_ERROR_NONE); } gpr_mu_unlock(&resource_user->mu); - ru_unref_by(resource_user, (gpr_atm)size); + ru_unref_by(resource_user, static_cast<gpr_atm>(size)); } void grpc_resource_user_post_reclaimer(grpc_resource_user* resource_user, |