diff options
Diffstat (limited to 'src/node/ext/call_credentials.cc')
-rw-r--r-- | src/node/ext/call_credentials.cc | 72 |
1 files changed, 36 insertions, 36 deletions
diff --git a/src/node/ext/call_credentials.cc b/src/node/ext/call_credentials.cc index 0644a812e9..c5818a735b 100644 --- a/src/node/ext/call_credentials.cc +++ b/src/node/ext/call_credentials.cc @@ -50,12 +50,12 @@ using v8::Object; using v8::ObjectTemplate; using v8::Value; -Nan::Callback *CallCredentials::constructor; +Nan::Callback* CallCredentials::constructor; Persistent<FunctionTemplate> CallCredentials::fun_tpl; -static Callback *plugin_callback; +static Callback* plugin_callback; -CallCredentials::CallCredentials(grpc_call_credentials *credentials) +CallCredentials::CallCredentials(grpc_call_credentials* credentials) : wrapped_credentials(credentials) {} CallCredentials::~CallCredentials() { @@ -87,14 +87,14 @@ bool CallCredentials::HasInstance(Local<Value> val) { return Nan::New(fun_tpl)->HasInstance(val); } -Local<Value> CallCredentials::WrapStruct(grpc_call_credentials *credentials) { +Local<Value> CallCredentials::WrapStruct(grpc_call_credentials* credentials) { EscapableHandleScope scope; const int argc = 1; if (credentials == NULL) { return scope.Escape(Nan::Null()); } Local<Value> argv[argc] = { - Nan::New<External>(reinterpret_cast<void *>(credentials))}; + Nan::New<External>(reinterpret_cast<void*>(credentials))}; MaybeLocal<Object> maybe_instance = Nan::NewInstance(constructor->GetFunction(), argc, argv); if (maybe_instance.IsEmpty()) { @@ -104,7 +104,7 @@ Local<Value> CallCredentials::WrapStruct(grpc_call_credentials *credentials) { } } -grpc_call_credentials *CallCredentials::GetWrappedCredentials() { +grpc_call_credentials* CallCredentials::GetWrappedCredentials() { return wrapped_credentials; } @@ -115,9 +115,9 @@ NAN_METHOD(CallCredentials::New) { "CallCredentials can only be created with the provided functions"); } Local<External> ext = info[0].As<External>(); - grpc_call_credentials *creds_value = - reinterpret_cast<grpc_call_credentials *>(ext->Value()); - CallCredentials *credentials = new CallCredentials(creds_value); + grpc_call_credentials* creds_value = + reinterpret_cast<grpc_call_credentials*>(ext->Value()); + CallCredentials* credentials = new CallCredentials(creds_value); credentials->Wrap(info.This()); info.GetReturnValue().Set(info.This()); return; @@ -137,10 +137,10 @@ NAN_METHOD(CallCredentials::Compose) { return Nan::ThrowTypeError( "compose's first argument must be a CallCredentials object"); } - CallCredentials *self = ObjectWrap::Unwrap<CallCredentials>(info.This()); - CallCredentials *other = ObjectWrap::Unwrap<CallCredentials>( + CallCredentials* self = ObjectWrap::Unwrap<CallCredentials>(info.This()); + CallCredentials* other = ObjectWrap::Unwrap<CallCredentials>( Nan::To<Object>(info[0]).ToLocalChecked()); - grpc_call_credentials *creds = grpc_composite_call_credentials_create( + grpc_call_credentials* creds = grpc_composite_call_credentials_create( self->wrapped_credentials, other->wrapped_credentials, NULL); info.GetReturnValue().Set(WrapStruct(creds)); } @@ -151,20 +151,20 @@ NAN_METHOD(CallCredentials::CreateFromPlugin) { "createFromPlugin's argument must be a function"); } grpc_metadata_credentials_plugin plugin; - plugin_state *state = new plugin_state; + plugin_state* state = new plugin_state; state->callback = new Nan::Callback(info[0].As<Function>()); - state->pending_callbacks = new std::queue<plugin_callback_data *>(); + state->pending_callbacks = new std::queue<plugin_callback_data*>(); uv_mutex_init(&state->plugin_mutex); uv_async_init(uv_default_loop(), &state->plugin_async, SendPluginCallback); - uv_unref((uv_handle_t *)&state->plugin_async); + uv_unref((uv_handle_t*)&state->plugin_async); state->plugin_async.data = state; plugin.get_metadata = plugin_get_metadata; plugin.destroy = plugin_destroy_state; - plugin.state = reinterpret_cast<void *>(state); + plugin.state = reinterpret_cast<void*>(state); plugin.type = ""; - grpc_call_credentials *creds = + grpc_call_credentials* creds = grpc_metadata_credentials_create_from_plugin(plugin, NULL); info.GetReturnValue().Set(WrapStruct(creds)); } @@ -190,7 +190,7 @@ NAN_METHOD(PluginCallback) { grpc_status_code code = static_cast<grpc_status_code>(Nan::To<uint32_t>(info[0]).FromJust()); Utf8String details_utf8_str(info[1]); - char *details = *details_utf8_str; + char* details = *details_utf8_str; grpc_metadata_array array; grpc_metadata_array_init(&array); Local<Object> callback_data = Nan::To<Object>(info[3]).ToLocalChecked(); @@ -203,7 +203,7 @@ NAN_METHOD(PluginCallback) { .ToLocalChecked() .As<External>() ->Value()); - void *user_data = + void* user_data = Nan::Get(callback_data, Nan::New("user_data").ToLocalChecked()) .ToLocalChecked() .As<External>() @@ -214,17 +214,17 @@ NAN_METHOD(PluginCallback) { NAUV_WORK_CB(SendPluginCallback) { Nan::HandleScope scope; - plugin_state *state = reinterpret_cast<plugin_state *>(async->data); - std::queue<plugin_callback_data *> callbacks; + plugin_state* state = reinterpret_cast<plugin_state*>(async->data); + std::queue<plugin_callback_data*> callbacks; uv_mutex_lock(&state->plugin_mutex); state->pending_callbacks->swap(callbacks); uv_mutex_unlock(&state->plugin_mutex); while (!callbacks.empty()) { - plugin_callback_data *data = callbacks.front(); + plugin_callback_data* data = callbacks.front(); callbacks.pop(); Local<Object> callback_data = Nan::New<Object>(); Nan::Set(callback_data, Nan::New("cb").ToLocalChecked(), - Nan::New<v8::External>(reinterpret_cast<void *>(data->cb))); + Nan::New<v8::External>(reinterpret_cast<void*>(data->cb))); Nan::Set(callback_data, Nan::New("user_data").ToLocalChecked(), Nan::New<v8::External>(data->user_data)); const int argc = 3; @@ -232,20 +232,20 @@ NAUV_WORK_CB(SendPluginCallback) { Nan::New(data->service_url).ToLocalChecked(), callback_data, // Get Local<Function> from Nan::Callback* **plugin_callback}; - Nan::Callback *callback = state->callback; + Nan::Callback* callback = state->callback; callback->Call(argc, argv); delete data; } } int plugin_get_metadata( - void *state, grpc_auth_metadata_context context, - grpc_credentials_plugin_metadata_cb cb, void *user_data, + void* state, grpc_auth_metadata_context context, + grpc_credentials_plugin_metadata_cb cb, void* user_data, grpc_metadata creds_md[GRPC_METADATA_CREDENTIALS_PLUGIN_SYNC_MAX], - size_t *num_creds_md, grpc_status_code *status, - const char **error_details) { - plugin_state *p_state = reinterpret_cast<plugin_state *>(state); - plugin_callback_data *data = new plugin_callback_data; + size_t* num_creds_md, grpc_status_code* status, + const char** error_details) { + plugin_state* p_state = reinterpret_cast<plugin_state*>(state); + plugin_callback_data* data = new plugin_callback_data; data->service_url = context.service_url; data->cb = cb; data->user_data = user_data; @@ -258,18 +258,18 @@ int plugin_get_metadata( return 0; // Async processing. } -void plugin_uv_close_cb(uv_handle_t *handle) { - uv_async_t *async = reinterpret_cast<uv_async_t *>(handle); - plugin_state *state = reinterpret_cast<plugin_state *>(async->data); +void plugin_uv_close_cb(uv_handle_t* handle) { + uv_async_t* async = reinterpret_cast<uv_async_t*>(handle); + plugin_state* state = reinterpret_cast<plugin_state*>(async->data); uv_mutex_destroy(&state->plugin_mutex); delete state->pending_callbacks; delete state->callback; delete state; } -void plugin_destroy_state(void *ptr) { - plugin_state *state = reinterpret_cast<plugin_state *>(ptr); - uv_close((uv_handle_t *)&state->plugin_async, plugin_uv_close_cb); +void plugin_destroy_state(void* ptr) { + plugin_state* state = reinterpret_cast<plugin_state*>(ptr); + uv_close((uv_handle_t*)&state->plugin_async, plugin_uv_close_cb); } } // namespace node |