| /external/grpc-grpc/src/ruby/lib/grpc/generic/ |
| active_call.rb | 102 @send_initial_md_mutex = Mutex.new
107 @call_finished_mu = Mutex.new
110 @client_call_executed_mu = Mutex.new
142 MultiReqView.new(self)
148 SingleReqView.new(self)
154 @op_notifier = Notifier.new
155 Operation.new(self)
164 InterceptableView.new(self)
210 SEND_STATUS_FROM_SERVER => Struct::Status.new(code, details, metadata)
237 ops[SEND_STATUS_FROM_SERVER] = Struct::Status.new(
[all...] |
| /external/protobuf/csharp/src/Google.Protobuf/WellKnownTypes/ |
| Struct.cs | 42 new pbr::FileDescriptor[] { },
43 new pbr::GeneratedClrTypeInfo(new[] {typeof(global::Google.Protobuf.WellKnownTypes.NullValue), }, new pbr::GeneratedClrTypeInfo[] {
44 new pbr::GeneratedClrTypeInfo(typeof(global::Google.Protobuf.WellKnownTypes.Struct), global::Google.Protobuf.WellKnownTypes.Struct.Parser, new[]{ "Fields" }, null, null, new pbr::GeneratedClrTypeInfo[] { null, }),
45 new pbr::GeneratedClrTypeInfo(typeof(global::Google.Protobuf.WellKnownTypes.Value), global::Google.Protobuf.WellKnownTypes.Value.Parser, new[]{ "NullValue", "NumberValue", "StringValue", "BoolValue", "StructValue", "ListValue" }, new[]{ "Kind" }, null, null)
[all...] |
| /external/grpc-grpc/src/csharp/Grpc.HealthCheck/ |
| HealthGrpc.cs | 36 static readonly grpc::Method<global::Grpc.Health.V1.HealthCheckRequest, global::Grpc.Health.V1.HealthCheckResponse> __Method_Check = new grpc::Method<global::Grpc.Health.V1.HealthCheckRequest, global::Grpc.Health.V1.HealthCheckResponse>(
54 throw new grpc::RpcException(new grpc::Status(grpc::StatusCode.Unimplemented, ""));
62 /// <summary>Creates a new client for Health</summary>
67 /// <summary>Creates a new client for Health that uses a custom <c>CallInvoker</c>.</summary>
84 return Check(request, new grpc::CallOptions(headers, deadline, cancellationToken));
92 return CheckAsync(request, new grpc::CallOptions(headers, deadline, cancellationToken));
98 /// <summary>Creates a new instance of client from given <c>ClientBaseConfiguration</c>.</summary>
101 return new HealthClient(configuration);
|
| Health.cs | 38 new pbr::FileDescriptor[] { },
39 new pbr::GeneratedClrTypeInfo(null, new pbr::GeneratedClrTypeInfo[] {
40 new pbr::GeneratedClrTypeInfo(typeof(global::Grpc.Health.V1.HealthCheckRequest), global::Grpc.Health.V1.HealthCheckRequest.Parser, new[]{ "Service" }, null, null, null),
41 new pbr::GeneratedClrTypeInfo(typeof(global::Grpc.Health.V1.HealthCheckResponse), global::Grpc.Health.V1.HealthCheckResponse.Parser, new[]{ "Status" }, null, new[]{ typeof(global::Grpc.Health.V1.HealthCheckResponse.Types.ServingStatus) }, null)
49 private static readonly pb::MessageParser<HealthCheckRequest> _parser = new pb::MessageParser<HealthCheckRequest>(() => new HealthCheckRequest())
[all...] |
| /device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.2/Demo/pdist/ |
| rrcs.py | 51 new = not x.isvalid(fn)
52 if not new and same(x, copts, fn, data):
56 message = asklogmessage(new)
118 lsum = md5.new(data).digest()
122 def asklogmessage(new):
123 if new:
128 if new:
|
| /external/antlr/runtime/Ruby/lib/antlr3/test/ |
| core-extensions.rb | 15 exp = Regexp.new( "^ *#{ chr }" )
190 if list.empty? then list << String.new( File::Separator )
202 relative_list = Array.new( reference_list.length, '..' )
246 Array.new( ( len+size ).abs,val ) + self
248 self + Array.new( len-size,val )
263 replace Array.new( ( len+size ).abs,val ) + self
265 concat Array.new( len-size,val )
|
| /external/python/cpython2/Demo/pdist/ |
| rrcs.py | 51 new = not x.isvalid(fn)
52 if not new and same(x, copts, fn, data):
56 message = asklogmessage(new)
118 lsum = md5.new(data).digest()
122 def asklogmessage(new):
123 if new:
128 if new:
|
| /external/antlr/runtime/Ruby/test/functional/template-output/ |
| template-output.rb | 21 @lexer = grammar_module::Lexer.new( input )
22 @parser = grammar_module::Parser.new( @lexer, parser_options )
55 templates = ANTLR3::Template::Group.new do
179 templates = ANTLR3::Template::Group.new do
394 lexer = TreeRewrite::Lexer.new( input )
395 tokens = ANTLR3::TokenRewriteStream.new( lexer )
396 parser = TreeRewrite::Parser.new( tokens )
398 nodes = ANTLR3::AST::CommonTreeNodeStream.new( tree )
400 tree_parser = TreeRewriteTG::TreeParser.new( nodes )
|
| /external/grpc-grpc/src/csharp/Grpc.Core/ |
| Server.cs | 39 readonly AtomicCounter activeCallCounter = new AtomicCounter();
46 readonly object myLock = new object();
48 readonly List<ServerServiceDefinition> serviceDefinitionsList = new List<ServerServiceDefinition>();
49 readonly List<ServerPort> serverPortList = new List<ServerPort>();
50 readonly Dictionary<string, IServerCallHandler> callHandlers = new Dictionary<string, IServerCallHandler>();
51 readonly TaskCompletionSource<object> shutdownTcs = new TaskCompletionSource<object>();
58 /// Creates a new server.
65 /// Creates a new server.
70 this.serviceDefinitions = new ServiceDefinitionCollection(this);
71 this.ports = new ServerPortCollection(this)
[all...] |
| /external/lzma/CS/7zip/Compress/LZMA/ |
| LzmaEncoder.cs | 19 static Byte[] g_FastPos = new Byte[1 << 11];
53 Base.State _state = new Base.State();
55 UInt32[] _repDistances = new UInt32[Base.kNumRepDistances];
74 public void Create() { m_Encoders = new BitEncoder[0x300]; }
151 m_Coders = new Encoder2[numStates];
169 RangeCoder.BitEncoder _choice = new RangeCoder.BitEncoder();
170 RangeCoder.BitEncoder _choice2 = new RangeCoder.BitEncoder();
171 RangeCoder.BitTreeEncoder[] _lowCoder = new RangeCoder.BitTreeEncoder[Base.kNumPosStatesEncodingMax];
172 RangeCoder.BitTreeEncoder[] _midCoder = new RangeCoder.BitTreeEncoder[Base.kNumPosStatesEncodingMax];
173 RangeCoder.BitTreeEncoder _highCoder = new RangeCoder.BitTreeEncoder(Base.kNumHighLenBits);
[all...] |
| /device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.10/Lib/ |
| weakref.py | 109 new = WeakValueDictionary()
113 new[key] = o
114 return new
120 new = self.__class__()
124 new[deepcopy(key, memo)] = o
125 return new
324 new = WeakKeyDictionary()
328 new[o] = value
329 return new
335 new = self.__class__()
[all...] |
| /device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.2/Lib/lib2to3/fixes/ |
| fix_idioms.py | 125 new = simple_expr.clone()
126 new.prefix = u""
127 simple_expr.replace(Call(Name(u"sorted"), [new],
138 # The new prefix should be everything from the sort_stmt's
139 # prefix up to the last newline, then the old prefix after a new
150 # The new prefix should be everything up to the first new line
|
| fix_import.py | 81 new = FromImport(u".", [imp])
82 new.prefix = node.prefix
83 return new
|
| /device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.2/Lib/ |
| weakref.py | 83 new = WeakValueDictionary()
87 new[key] = o
88 return new
94 new = self.__class__()
98 new[deepcopy(key, memo)] = o
99 return new
265 new = WeakKeyDictionary()
269 new[o] = value
270 return new
276 new = self.__class__()
[all...] |
| /external/antlr/runtime/Ruby/test/functional/parser/ |
| backtracking.rb | 38 $Symbols::types = Set.new
238 lexer = Backtrack::Lexer.new( 'int a;' )
239 parser = Backtrack::Parser.new lexer
|
| ll-star.rb | 12 @init { @output = StringIO.new() }
120 lexer = LLStar::Lexer.new( <<-'END'.fixed_indent( 0 ) )
134 parser = LLStar::Parser.new lexer
|
| /external/grpc-grpc/src/csharp/Grpc.Core/Interceptors/ |
| InterceptingCallInvoker.cs | 34 /// Creates a new instance of <see cref="Grpc.Core.Interceptors.InterceptingCallInvoker" />
50 new ClientInterceptorContext<TRequest, TResponse>(method, host, options),
61 new ClientInterceptorContext<TRequest, TResponse>(method, host, options),
72 new ClientInterceptorContext<TRequest, TResponse>(method, host, options),
82 new ClientInterceptorContext<TRequest, TResponse>(method, host, options),
92 new ClientInterceptorContext<TRequest, TResponse>(method, host, options),
|
| /external/grpc-grpc/src/csharp/Grpc.Core/Internal/ |
| BatchContextSafeHandle.cs | 72 completionCallbackData = new CompletionCallbackData(callback, state);
88 var status = new Status(Native.grpcsharp_batch_context_recv_status_on_client_status(this), details);
93 return new ClientSideStatus(status, metadata);
100 if (len == new IntPtr(-1))
104 byte[] data = new byte[(int)len];
105 Native.grpcsharp_batch_context_recv_message_to_buffer(this, data, new UIntPtr((ulong)data.Length));
|
| /external/ltp/testcases/commands/mv/ |
| mv_tests.sh | 107 mv tst_mv.old tst_mv.new > tst_mv.err 2>&1
110 tst_brk TFAIL "Test #1: 'mv tst_mv.old tst_mv.new' failed"
114 ls -R tst_mv.new > tst_mv.out 2>&1
117 creat_expout $numdirs $numfiles tst_mv.new
|
| /external/ltp/testcases/kernel/tracing/dynamic_debug/ |
| dynamic_debug01.sh | 143 dmesg > ./dmesg.new
144 sed -i -e 1,`wc -l < ./dmesg.old`d ./dmesg.new
147 -e "fault" -e "warn" -e "BUG" ./dmesg.new ; then
|
| /external/protobuf/csharp/src/Google.Protobuf/Collections/ |
| ReadOnlyDictionary.cs | 53 throw new InvalidOperationException();
68 throw new InvalidOperationException();
84 set { throw new InvalidOperationException(); }
89 throw new InvalidOperationException();
94 throw new InvalidOperationException();
119 throw new InvalidOperationException();
|
| /external/python/cpython2/Lib/lib2to3/fixes/ |
| fix_idioms.py | 125 new = simple_expr.clone()
126 new.prefix = u""
127 simple_expr.replace(Call(Name(u"sorted"), [new],
138 # The new prefix should be everything from the sort_stmt's
139 # prefix up to the last newline, then the old prefix after a new
150 # The new prefix should be everything up to the first new line
|
| fix_import.py | 81 new = FromImport(u".", [imp])
82 new.prefix = node.prefix
83 return new
|
| /external/python/cpython3/Lib/lib2to3/fixes/ |
| fix_idioms.py | 125 new = simple_expr.clone()
126 new.prefix = ""
127 simple_expr.replace(Call(Name("sorted"), [new],
138 # The new prefix should be everything from the sort_stmt's
139 # prefix up to the last newline, then the old prefix after a new
150 # The new prefix should be everything up to the first new line
|
| fix_import.py | 81 new = FromImport(".", [imp])
82 new.prefix = node.prefix
83 return new
|
