| /external/grpc-grpc/src/ruby/spec/generic/ |
| server_interceptors_spec.rb | 17 let(:interceptor) { TestServerInterceptor.new }
18 let(:request) { EchoMsg.new }
20 let(:service) { EchoService.new(trailing_metadata) }
68 let(:requests) { [EchoMsg.new, EchoMsg.new] }
103 let(:request) { EchoMsg.new }
143 let(:requests) { [EchoMsg.new, EchoMsg.new] }
183 let(:interceptor2) { TestServerInterceptor.new }
184 let(:interceptor3) { TestServerInterceptor.new }
[all...] |
| /external/libchrome/mojo/public/js/ |
| bindings.js | 18 return new mojo.AssociatedInterfaceRequest(handle1);
26 return new mojo.InterfaceRequest(pipe.handle1);
30 output.ptr.bind(new mojo.InterfacePtrInfo(pipe.handle0, 0));
31 return new mojo.InterfaceRequest(pipe.handle1);
103 throw new Error("Cannot set connection error handler if not bound.");
113 result = new mojo.InterfacePtrInfo(
118 result = new mojo.InterfacePtrInfo(this.handle_, this.version);
135 this.router_ = new internal.Router(this.handle_, true);
138 this.interfaceEndpointClient_ = new internal.InterfaceEndpointClient(
143 this.proxy_ = new this.interfaceType_.proxyClass
[all...] |
| /external/grpc-grpc/src/csharp/Grpc.IntegrationTesting/ |
| StressTestClient.cs | 67 CancellationTokenSource finishedTokenSource = new CancellationTokenSource();
68 Histogram histogram = new Histogram(0.01, 60 * SecondsToNanos);
75 this.testCaseGenerator = new WeightedRandomGenerator(this.weightedTestCases);
80 GrpcEnvironment.SetLogger(new ConsoleLogger());
93 var interopClient = new StressTestClient(options, serverAddresses.ToList(), testCases);
100 var metricsServer = new Server()
102 Services = { MetricsService.BindService(new MetricsServiceImpl(histogram)) },
112 var tasks = new List<Task>();
113 var channels = new List<Channel>();
118 var channel = new Channel(serverAddress, ChannelCredentials.Insecure)
[all...] |
| /external/grpc-grpc/src/csharp/Grpc.Core/Internal/ |
| AuthContextSafeHandle.cs | 40 /// Copies contents of the native auth context into a new <c>AuthContext</c> instance.
46 return new AuthContext(null, new Dictionary<string, List<AuthProperty>>());
51 var propertiesDict = new Dictionary<string, List<AuthProperty>>();
61 propertiesDict[authProperty.Name] = new List<AuthProperty>();
66 return new AuthContext(peerIdentityPropertyName, propertiesDict);
82 var valueBytes = new byte[(int) nativeAuthProperty.ValueLength];
|
| UnimplementedCallInvoker.cs | 37 throw new NotImplementedException();
42 throw new NotImplementedException();
47 throw new NotImplementedException();
52 throw new NotImplementedException();
57 throw new NotImplementedException();
|
| ServerCallHandler.cs | 54 var asyncCall = new AsyncCallServer<TRequest, TResponse>(
61 var requestStream = new ServerRequestStream<TRequest, TResponse>(asyncCall);
62 var responseStream = new ServerResponseStream<TRequest, TResponse>(asyncCall);
73 responseWithFlags = new AsyncCallServer<TRequest, TResponse>.ResponseWithFlags(response, HandlerUtils.GetWriteFlags(context.WriteOptions));
97 return new UnaryServerCallHandler<TRequest, TResponse>(method, (request, context) => interceptor.UnaryServerHandler(request, context, handler));
118 var asyncCall = new AsyncCallServer<TRequest, TResponse>(
125 var requestStream = new ServerRequestStream<TRequest, TResponse>(asyncCall);
126 var responseStream = new ServerResponseStream<TRequest, TResponse>(asyncCall);
160 return new ServerStreamingServerCallHandler<TRequest, TResponse>(method, (request, responseStream, context) => interceptor.ServerStreamingServerHandler(request, responseStream, context, handler));
181 var asyncCall = new AsyncCallServer<TRequest, TResponse>
[all...] |
| /external/grpc-grpc/src/csharp/Grpc.Core/Profiling/ |
| Profilers.cs | 28 static readonly NopProfiler DefaultProfiler = new NopProfiler();
29 static readonly ThreadLocal<IProfiler> profilers = new ThreadLocal<IProfiler>();
43 return new ProfilerScope(profiler, tag);
74 this.entries = new ProfilerEntry[capacity];
79 AddEntry(new ProfilerEntry(Timespec.PreciseNow, ProfilerEntry.Type.BEGIN, tag));
84 AddEntry(new ProfilerEntry(Timespec.PreciseNow, ProfilerEntry.Type.END, tag));
89 AddEntry(new ProfilerEntry(Timespec.PreciseNow, ProfilerEntry.Type.MARK, tag));
|
| /external/python/cpython2/Lib/idlelib/ |
| ReplaceDialog.py | 70 new = m.expand(repl)
73 new = None
75 new = repl
76 return new
106 new = self._replace_expand(m, repl)
107 if new is None:
112 if new == orig:
118 if new:
119 text.insert(first, new)
120 col = i + len(new)
[all...] |
| /external/python/cpython3/Lib/idlelib/ |
| replace.py | 80 new = m.expand(repl)
83 new = None
85 new = repl
87 return new
118 new = self._replace_expand(m, repl)
119 if new is None:
124 if new == orig:
130 if new:
131 text.insert(first, new)
132 col = i + len(new)
[all...] |
| /external/boringssl/src/crypto/fipsmodule/bn/ |
| check_bn_tests.go | 55 s.setError(errors.New("invalid syntax"))
62 valueInt, ok := new(big.Int).SetString(value, 16)
180 r := new(big.Int).Add(test.Values["A"], test.Values["B"])
185 r := new(big.Int).Add(test.Values["A"], test.Values["A"])
190 r := new(big.Int).Lsh(test.Values["A"], uint(test.Values["N"].Uint64()))
195 r := new(big.Int).Rsh(test.Values["A"], uint(test.Values["N"].Uint64()))
200 r := new(big.Int).Mul(test.Values["A"], test.Values["A"])
205 r := new(big.Int).Mul(test.Values["A"], test.Values["B"])
210 q, r := new(big.Int).QuoRem(test.Values["A"], test.Values["B"], new(big.Int)
[all...] |
| /external/elfutils/tests/ |
| run-dwfllines.sh | 24 0 0x804842c /home/drepper/gnu/new-bu/build/ttt/m.c:5:0
26 1 0x8048432 /home/drepper/gnu/new-bu/build/ttt/m.c:6:0
28 2 0x804844d /home/drepper/gnu/new-bu/build/ttt/m.c:7:0
30 3 0x8048458 /home/drepper/gnu/new-bu/build/ttt/m.c:8:0
32 4 0x804845a /home/drepper/gnu/new-bu/build/ttt/m.c:8:0
35 0 0x804845c /home/drepper/gnu/new-bu/build/ttt/b.c:4:0
37 1 0x804845f /home/drepper/gnu/new-bu/build/ttt/b.c:5:0
39 2 0x8048464 /home/drepper/gnu/new-bu/build/ttt/b.c:6:0
41 3 0x8048466 /home/drepper/gnu/new-bu/build/ttt/b.c:6:0
44 0 0x8048468 /home/drepper/gnu/new-bu/build/ttt/f.c:3:
[all...] |
| run-get-lines.sh | 26 804842c: /home/drepper/gnu/new-bu/build/ttt/m.c:5:0: is_stmt:yes, end_seq:no, bb:no, prologue:no, epilogue:no
27 8048432: /home/drepper/gnu/new-bu/build/ttt/m.c:6:0: is_stmt:yes, end_seq:no, bb:no, prologue:no, epilogue:no
28 804844d: /home/drepper/gnu/new-bu/build/ttt/m.c:7:0: is_stmt:yes, end_seq:no, bb:no, prologue:no, epilogue:no
29 8048458: /home/drepper/gnu/new-bu/build/ttt/m.c:8:0: is_stmt:yes, end_seq:no, bb:no, prologue:no, epilogue:no
30 804845a: /home/drepper/gnu/new-bu/build/ttt/m.c:8:0: is_stmt:yes, end_seq:yes, bb:no, prologue:no, epilogue:no
33 804845c: /home/drepper/gnu/new-bu/build/ttt/b.c:4:0: is_stmt:yes, end_seq:no, bb:no, prologue:no, epilogue:no
34 804845f: /home/drepper/gnu/new-bu/build/ttt/b.c:5:0: is_stmt:yes, end_seq:no, bb:no, prologue:no, epilogue:no
35 8048464: /home/drepper/gnu/new-bu/build/ttt/b.c:6:0: is_stmt:yes, end_seq:no, bb:no, prologue:no, epilogue:no
36 8048466: /home/drepper/gnu/new-bu/build/ttt/b.c:6:0: is_stmt:yes, end_seq:yes, bb:no, prologue:no, epilogue:no
39 8048468: /home/drepper/gnu/new-bu/build/ttt/f.c:3:0: is_stmt:yes, end_seq:no, bb:no, prologue:no, epilogue:n
[all...] |
| /external/grpc-grpc/src/csharp/Grpc.Core/ |
| Calls.cs | 44 var asyncCall = new AsyncCall<TRequest, TResponse>(call);
60 var asyncCall = new AsyncCall<TRequest, TResponse>(call);
62 return new AsyncUnaryCall<TResponse>(asyncResult, asyncCall.ResponseHeadersAsync, asyncCall.GetStatus, asyncCall.GetTrailers, asyncCall.Cancel);
78 var asyncCall = new AsyncCall<TRequest, TResponse>(call);
80 var responseStream = new ClientResponseStream<TRequest, TResponse>(asyncCall);
81 return new AsyncServerStreamingCall<TResponse>(responseStream, asyncCall.ResponseHeadersAsync, asyncCall.GetStatus, asyncCall.GetTrailers, asyncCall.Cancel);
96 var asyncCall = new AsyncCall<TRequest, TResponse>(call);
98 var requestStream = new ClientRequestStream<TRequest, TResponse>(asyncCall);
99 return new AsyncClientStreamingCall<TRequest, TResponse>(requestStream, resultTask, asyncCall.ResponseHeadersAsync, asyncCall.GetStatus, asyncCall.GetTrailers, asyncCall.Cancel);
115 var asyncCall = new AsyncCall<TRequest, TResponse>(call)
[all...] |
| CallCredentials.cs | 38 /// <returns>The new <c>CompositeCallCredentials</c></returns>
41 return new CompositeCallCredentials(credentials);
45 /// Creates a new instance of <c>CallCredentials</c> class from an
51 return new MetadataCredentials(interceptor);
70 /// Initializes a new instance of <c>MetadataCredentials</c> class.
80 NativeMetadataCredentialsPlugin plugin = new NativeMetadataCredentialsPlugin(interceptor);
93 /// Initializes a new instance of <c>CompositeCallCredentials</c> class.
100 this.credentials = new List<CallCredentials>(credentials);
123 throw new ArgumentException("Error creating native composite credentials. Likely, this is because you are trying to compose incompatible credentials.");
|
| /external/protobuf/csharp/src/Google.Protobuf.Test/TestProtos/ |
| UnittestImportProto3.cs | 35 new pbr::FileDescriptor[] { global::Google.Protobuf.TestProtos.UnittestImportPublicProto3Reflection.Descriptor, },
36 new pbr::GeneratedClrTypeInfo(new[] {typeof(global::Google.Protobuf.TestProtos.ImportEnum), }, new pbr::GeneratedClrTypeInfo[] {
37 new pbr::GeneratedClrTypeInfo(typeof(global::Google.Protobuf.TestProtos.ImportMessage), global::Google.Protobuf.TestProtos.ImportMessage.Parser, new[]{ "D" }, null, null, null)
56 private static readonly pb::MessageParser<ImportMessage> _parser = new pb::MessageParser<ImportMessage>(() => new ImportMessage());
78 return new ImportMessage(this);
|
| /external/antlr/runtime/Ruby/test/functional/parser/ |
| properties.rb | 41 lexer = RuleProperties::Lexer.new( ' a a a a ' )
42 parser = RuleProperties::Parser.new lexer
87 lexer = Labels::Lexer.new 'a, b, c, 1, 2 A FOOBAR GNU1 A BLARZ'
88 parser = Labels::Parser.new lexer
162 lexer = TokenLabels::Lexer.new( ' a' )
163 parser = TokenLabels::Parser.new lexer
212 lexer = RuleLabelReference::Lexer.new( ' a a a a ' )
213 parser = RuleLabelReference::Parser.new lexer
237 lexer = ReferenceSetChannel::Lexer.new( "- 34" )
238 parser = ReferenceSetChannel::Parser.new lexe
[all...] |
| /external/flatbuffers/tests/ |
| JavaScriptUnionVectorTest.js | 7 var fbb = new flatbuffers.Builder();
34 var buf = new flatbuffers.ByteBuffer(fbb.asUint8Array());
45 var bookReader7 = movie.characters(0, new Test.BookReader());
48 var attacker = movie.characters(1, new Test.Attacker());
51 var bookReader2 = movie.characters(2, new Test.BookReader());
|
| /external/grpc-grpc/examples/ruby/route_guide/ |
| route_guide_server.rb | 80 pt = Point.new(
82 yield Feature.new(location: pt, name: name)
92 @received_notes = Hash.new { |h, k| h[k] = [] }
99 Feature.new(location: point, name: name)
103 RectangleEnum.new(@feature_db, rectangle).each
124 RouteSummary.new(point_count: count,
131 RouteChatEnumerator.new(notes, @received_notes).each_item
152 yield RouteNote.new(location: n.location, message: r)
171 s = GRPC::RpcServer.new
174 s.handle(ServerImpl.new(feature_db)
[all...] |
| /external/bcc/tests/lua/ |
| test_clang.lua | 13 local b = BPF:new{text=text, debug=0}
25 local b = BPF:new{text=text, debug=0}
48 local b = BPF:new{text=text, debug=0}
60 local b = BPF:new{text=text, debug=0}
81 local b = BPF:new{text=text, debug=0}
116 local b = BPF:new{text=text, debug=0}
129 local b = BPF:new{text=text, debug=0}
139 local b = BPF:new{text=text, debug=0}
161 local b = BPF:new{text=text, debug=0}
175 local b = BPF:new{text=text, debug=0
[all...] |
| /external/ImageMagick/PerlMagick/demo/ |
| composite.pl | 5 $image = Image::Magick->new();
6 $smile = Image::Magick->new();
16 $thumbnail=Image::Magick->new(size=>"600x600",pointsize=>24,fill=>'black');
|
| /external/antlr/runtime/Ruby/test/functional/lexer/ |
| basic.rb | 18 lexer = Zero::Lexer.new( '0' )
28 lexer = Zero::Lexer.new( '0' )
35 lexer = Zero::Lexer.new( '1' )
60 lexer = Binary::Lexer.new( '01' )
73 lexer = Binary::Lexer.new( '2' )
98 lexer = BinaryFooze::Lexer.new( '0fooze1' )
114 lexer = BinaryFooze::Lexer.new( '2' )
137 lexer = FooStar::Lexer.new( 'ffofoofooo' )
168 lexer = FooStar::Lexer.new( '2' )
191 lexer = FooPlus::Lexer.new( 'fofoofooo'
[all...] |
| /external/curl/src/ |
| mkhelp.pl | 205 $new = $_;
207 $outsize += length($new)+1; # one for the newline
209 $new =~ s/\\/\\\\/g;
210 $new =~ s/\"/\\\"/g;
216 $outsize=length($new)+1;
218 printf("\"%s\\n\"\n", $new);
|
| /external/grpc-grpc/examples/csharp/Helloworld/GreeterClient/ |
| Program.cs | 25 Channel channel = new Channel("127.0.0.1:50051", ChannelCredentials.Insecure);
27 var client = new Greeter.GreeterClient(channel);
30 var reply = client.SayHello(new HelloRequest { Name = user });
|
| /external/grpc-grpc/examples/csharp/HelloworldLegacyCsproj/GreeterClient/ |
| Program.cs | 25 Channel channel = new Channel("127.0.0.1:50051", ChannelCredentials.Insecure);
27 var client = new Greeter.GreeterClient(channel);
30 var reply = client.SayHello(new HelloRequest { Name = user });
|
| /external/grpc-grpc/examples/csharp/RouteGuide/RouteGuideServer/ |
| Program.cs | 32 Server server = new Server
34 Services = { RouteGuide.BindService(new RouteGuideImpl(features)) },
35 Ports = { new ServerPort("localhost", Port, ServerCredentials.Insecure) }
|
