| /external/grpc-grpc/src/csharp/Grpc.Core.Tests/Internal/ |
| AsyncCallServerTest.cs | 44 server = new Server()
50 fakeCall = new FakeNativeCall();
51 asyncCallServer = new AsyncCallServer<string, string>(
75 var requestStream = new ServerRequestStream<string, string>(asyncCallServer);
90 var requestStream = new ServerRequestStream<string, string>(asyncCallServer);
105 var requestStream = new ServerRequestStream<string, string>(asyncCallServer);
121 var responseStream = new ServerResponseStream<string, string>(asyncCallServer);
134 var responseStream = new ServerResponseStream<string, string>(asyncCallServer);
148 var responseStream = new ServerResponseStream<string, string>(asyncCallServer);
151 var writeStatusTask = asyncCallServer.SendStatusFromServerAsync(Status.DefaultSuccess, new Metadata(), null)
[all...] |
| /external/grpc-grpc/src/csharp/Grpc.Core.Tests/ |
| ResponseHeadersTest.cs | 48 helper = new MockServiceHelper();
54 headers = new Metadata { { "ascii-header", "abcdefg" } };
67 helper.UnaryHandler = new UnaryServerMethod<string, string>(async (request, context) =>
86 helper.ClientStreamingHandler = new ClientStreamingServerMethod<string, string>(async (requestStream, context) =>
103 helper.ServerStreamingHandler = new ServerStreamingServerMethod<string, string>(async (request, responseStream, context) =>
113 CollectionAssert.AreEqual(new[] { "PASS" }, await call.ResponseStream.ToListAsync());
119 helper.DuplexStreamingHandler = new DuplexStreamingServerMethod<string, string>(async (requestStream, responseStream, context) =>
131 var messages = new[] { "PASS" };
141 helper.UnaryHandler = new UnaryServerMethod<string, string>((request, context) =>
153 helper.UnaryHandler = new UnaryServerMethod<string, string>(async (request, context) =
[all...] |
| /external/grpc-grpc/src/csharp/Grpc.IntegrationTesting/ |
| ControlExtensions.cs | 35 return new ChannelOption(channelArgument.Name, channelArgument.StrValue);
37 return new ChannelOption(channelArgument.Name, channelArgument.IntValue);
39 throw new ArgumentException("Unsupported channel argument value.");
|
| QpsWorker.cs | 54 GrpcEnvironment.SetLogger(new ConsoleLogger());
59 var workerServer = new QpsWorker(options);
69 var tcs = new TaskCompletionSource<object>();
70 var workerServiceImpl = new WorkerServiceImpl(() => { Task.Run(() => tcs.SetResult(null)); });
72 var server = new Server
75 Ports = { new ServerPort(host, options.DriverPort, ServerCredentials.Insecure )}
|
| WorkerServiceImpl.cs | 48 await responseStream.WriteAsync(new ServerStatus
58 await responseStream.WriteAsync(new ServerStatus
72 await responseStream.WriteAsync(new ClientStatus
80 await responseStream.WriteAsync(new ClientStatus
90 return Task.FromResult(new CoreResponse { Cores = Environment.ProcessorCount });
96 return Task.FromResult(new Void());
|
| /external/grpc-grpc/src/ruby/spec/ |
| call_spec.rb | 84 let(:test_tag) { Object.new }
88 @ch = GRPC::Core::Channel.new(fake_host, nil, :this_channel_is_insecure)
94 sts = Struct::Status.new(OK, 'OK')
101 bad_sts = Object.new
121 bad_md = Object.new
135 creds = GRPC::Core::CallCredentials.new auth_proc
|
| /external/grpc-grpc/src/ruby/spec/support/ |
| services.rb | 25 EchoMsg.new
56 EchoMsg.new
61 [EchoMsg.new, EchoMsg.new]
69 [EchoMsg.new, EchoMsg.new]
|
| /external/libchrome/mojo/public/js/lib/ |
| pipe_control_message_handler.js | 9 var messageValidator = new internal.Validator(message);
16 throw new Error("Control message name is not kRunOrClosePipeMessageId");
28 var reader = new internal.MessageReader(message);
|
| /external/protobuf/csharp/src/Google.Protobuf/WellKnownTypes/ |
| Wrappers.cs | 37 new pbr::FileDescriptor[] { },
38 new pbr::GeneratedClrTypeInfo(null, new pbr::GeneratedClrTypeInfo[] {
39 new pbr::GeneratedClrTypeInfo(typeof(global::Google.Protobuf.WellKnownTypes.DoubleValue), global::Google.Protobuf.WellKnownTypes.DoubleValue.Parser, new[]{ "Value" }, null, null, null),
40 new pbr::GeneratedClrTypeInfo(typeof(global::Google.Protobuf.WellKnownTypes.FloatValue), global::Google.Protobuf.WellKnownTypes.FloatValue.Parser, new[]{ "Value" }, null, null, null),
41 new pbr::GeneratedClrTypeInfo(typeof(global::Google.Protobuf.WellKnownTypes.Int64Value), global::Google.Protobuf.WellKnownTypes.Int64Value.Parser, new[]{ "Value" }, null, null, null),
42 new pbr::GeneratedClrTypeInfo(typeof(global::Google.Protobuf.WellKnownTypes.UInt64Value), global::Goog (…)
[all...] |
| /external/skia/modules/canvaskit/htmlcanvas/ |
| imagedata.js | 29 return new ImageData(new Uint8ClampedArray(byteLength),
48 return new ImageData(arr, width, height);
|
| /external/skqp/experimental/canvaskit/htmlcanvas/ |
| imagedata.js | 29 return new ImageData(new Uint8ClampedArray(byteLength),
48 return new ImageData(arr, width, height);
|
| /dalvik/dx/ |
| Android.mk | 5 # We use copy-file-to-new-target so that the installed
6 # script files' timestamps are at least as new as the
25 $(copy-file-to-new-target)
44 $(copy-file-to-new-target)
86 $(copy-file-to-new-target)
108 $(copy-file-to-new-target)
|
| /device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.2/Tools/scripts/ |
| linktree.py | 50 def linknames(old, new, link):
51 if debug: print 'linknames', (old, new, link)
61 newname = os.path.join(new, name)
|
| /external/deqp/scripts/ |
| caselist_diff.py | 166 def diffCaseLists (old, new):
171 newSet = set(new)
174 for case in new:
187 print "%s [old caselist] [new caselist]" % sys.argv[0]
|
| /external/grpc-grpc/src/csharp/Grpc.Core/Internal/ |
| MetadataArraySafeHandle.cs | 38 return new MetadataArraySafeHandle();
42 var metadataArray = Native.grpcsharp_metadata_array_create(new UIntPtr((ulong)metadata.Count));
46 Native.grpcsharp_metadata_array_add(metadataArray, metadata[i].Key, valueBytes, new UIntPtr((ulong)valueBytes.Length));
63 var metadata = new Metadata();
66 var index = new UIntPtr(i);
72 var bytes = new byte[valueLen.ToUInt64()];
|
| /external/grpc-grpc/src/csharp/Grpc.Core/Utils/ |
| GrpcPreconditions.cs | 36 throw new ArgumentException();
49 throw new ArgumentException(errorMessage);
61 throw new ArgumentNullException();
75 throw new ArgumentNullException(paramName);
88 throw new InvalidOperationException();
101 throw new InvalidOperationException(errorMessage);
|
| /external/grpc-grpc/src/csharp/Grpc.Examples/ |
| MathServiceImpl.cs | 60 return new Num { Num_ = sum };
74 throw new RpcException(new Status(StatusCode.InvalidArgument, "Division by zero"));
79 return new DivReply { Quotient = quotient, Remainder = remainder };
85 yield return new Num { Num_ = a };
93 yield return new Num { Num_ = a };
|
| /external/python/cpython2/Mac/Tools/ |
| fixapplepython23.py | 53 for old, new in CHANGES:
54 i = findline(lines, new)
63 lines[i] = new
|
| /external/python/cpython2/Tools/scripts/ |
| linktree.py | 50 def linknames(old, new, link):
51 if debug: print 'linknames', (old, new, link)
61 newname = os.path.join(new, name)
|
| /external/python/cpython3/Tools/scripts/ |
| linktree.py | 50 def linknames(old, new, link):
51 if debug: print('linknames', (old, new, link))
61 newname = os.path.join(new, name)
|
| /bionic/tests/libs/ |
| Android.build.dt_runpath.mk | 48 libtest_dt_runpath_b_ldflags := -Wl,--rpath,\$${ORIGIN}/../dt_runpath_a -Wl,--enable-new-dtags
60 libtest_dt_runpath_c_ldflags := -Wl,--rpath,\$${ORIGIN}/invalid_dt_runpath -Wl,--enable-new-dtags
76 -Wl,--enable-new-dtags
94 -Wl,--enable-new-dtags
|
| /device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.2/Demo/md5test/ |
| md5driver.py | 45 mdContext = md5.new()
60 MDPrint(md5.new(str).digest())
66 mdContext = md5.new()
81 mdContext = md5.new()
|
| /external/antlr/runtime/Ruby/test/functional/parser/ |
| rule-methods.rb | 46 lexer = Parameters::Lexer.new( 'a a a' )
47 parser = Parameters::Parser.new lexer
100 lexer = MultipleReturnValues::Lexer.new( ' a' )
101 parser = MultipleReturnValues::Parser.new lexer
|
| /external/e2fsprogs/tests/f_detect_junk/ |
| script | 32 sed -f $cmd_dir/filter.sed < $OUT > $OUT.new
33 mv $OUT.new $OUT
|
| /external/e2fsprogs/tests/f_detect_xfs/ |
| script | 26 sed -f $cmd_dir/filter.sed < $OUT > $OUT.new
27 mv $OUT.new $OUT
|
