mirror of
https://github.com/grpc/grpc-node.git
synced 2025-12-08 18:23:54 +00:00
Merge github.com:grpc/grpc into grpc_slice
This commit is contained in:
commit
49c198784f
@ -44,8 +44,8 @@
|
||||
namespace grpc {
|
||||
namespace node {
|
||||
|
||||
using Nan::MaybeLocal;
|
||||
|
||||
using v8::Context;
|
||||
using v8::Function;
|
||||
using v8::Local;
|
||||
using v8::Object;
|
||||
@ -89,15 +89,19 @@ Local<Value> ByteBufferToBuffer(grpc_byte_buffer *buffer) {
|
||||
Local<Value> MakeFastBuffer(Local<Value> slowBuffer) {
|
||||
Nan::EscapableHandleScope scope;
|
||||
Local<Object> globalObj = Nan::GetCurrentContext()->Global();
|
||||
MaybeLocal<Value> constructorValue = Nan::Get(
|
||||
globalObj, Nan::New("Buffer").ToLocalChecked());
|
||||
Local<Function> bufferConstructor = Local<Function>::Cast(
|
||||
globalObj->Get(Nan::New("Buffer").ToLocalChecked()));
|
||||
Local<Value> consArgs[3] = {
|
||||
constructorValue.ToLocalChecked());
|
||||
const int argc = 3;
|
||||
Local<Value> consArgs[argc] = {
|
||||
slowBuffer,
|
||||
Nan::New<Number>(::node::Buffer::Length(slowBuffer)),
|
||||
Nan::New<Number>(0)
|
||||
};
|
||||
Local<Object> fastBuffer = bufferConstructor->NewInstance(3, consArgs);
|
||||
return scope.Escape(fastBuffer);
|
||||
MaybeLocal<Object> fastBuffer = Nan::NewInstance(bufferConstructor,
|
||||
argc, consArgs);
|
||||
return scope.Escape(fastBuffer.ToLocalChecked());
|
||||
}
|
||||
} // namespace node
|
||||
} // namespace grpc
|
||||
|
||||
@ -669,16 +669,16 @@ NAN_METHOD(Call::New) {
|
||||
return Nan::ThrowTypeError("Call's fourth argument must be a string");
|
||||
}
|
||||
call = new Call(wrapped_call);
|
||||
info.This()->SetHiddenValue(Nan::New("channel_").ToLocalChecked(),
|
||||
channel_object);
|
||||
Nan::Set(info.This(), Nan::New("channel_").ToLocalChecked(),
|
||||
channel_object);
|
||||
}
|
||||
call->Wrap(info.This());
|
||||
info.GetReturnValue().Set(info.This());
|
||||
} else {
|
||||
const int argc = 4;
|
||||
Local<Value> argv[argc] = {info[0], info[1], info[2], info[3]};
|
||||
MaybeLocal<Object> maybe_instance = constructor->GetFunction()->NewInstance(
|
||||
argc, argv);
|
||||
MaybeLocal<Object> maybe_instance = Nan::NewInstance(
|
||||
constructor->GetFunction(), argc, argv);
|
||||
if (maybe_instance.IsEmpty()) {
|
||||
// There's probably a pending exception
|
||||
return;
|
||||
|
||||
@ -208,8 +208,8 @@ NAN_METHOD(Channel::New) {
|
||||
} else {
|
||||
const int argc = 3;
|
||||
Local<Value> argv[argc] = {info[0], info[1], info[2]};
|
||||
MaybeLocal<Object> maybe_instance = constructor->GetFunction()->NewInstance(
|
||||
argc, argv);
|
||||
MaybeLocal<Object> maybe_instance = Nan::NewInstance(
|
||||
constructor->GetFunction(), argc, argv);
|
||||
if (maybe_instance.IsEmpty()) {
|
||||
// There's probably a pending exception
|
||||
return;
|
||||
|
||||
@ -222,7 +222,7 @@ NAN_METHOD(Server::New) {
|
||||
const int argc = 1;
|
||||
Local<Value> argv[argc] = {info[0]};
|
||||
MaybeLocal<Object> maybe_instance =
|
||||
constructor->GetFunction()->NewInstance(argc, argv);
|
||||
Nan::NewInstance(constructor->GetFunction(), argc, argv);
|
||||
if (maybe_instance.IsEmpty()) {
|
||||
// There's probably a pending exception
|
||||
return;
|
||||
|
||||
@ -141,7 +141,7 @@ exports.getProtobufServiceAttrs = function getProtobufServiceAttrs(service,
|
||||
binaryAsBase64 = options.binaryAsBase64;
|
||||
longsAsStrings = options.longsAsStrings;
|
||||
}
|
||||
return _.object(_.map(service.children, function(method) {
|
||||
return _.fromPairs(_.map(service.children, function(method) {
|
||||
return [_.camelCase(method.name), {
|
||||
path: prefix + method.name,
|
||||
requestStream: method.requestStream,
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user