aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/node/ext/call_credentials.cc
diff options
context:
space:
mode:
Diffstat (limited to 'src/node/ext/call_credentials.cc')
-rw-r--r--src/node/ext/call_credentials.cc72
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