| /external/grpc-grpc/src/csharp/Grpc.Core.Tests/ |
| D | GrpcEnvironmentTest.cs | 32 var env = GrpcEnvironment.AddRef(); in InitializeAndShutdownGrpcEnvironment()
38 GrpcEnvironment.ReleaseAsync().Wait(); in InitializeAndShutdownGrpcEnvironment()
44 var env1 = GrpcEnvironment.AddRef(); in SubsequentInvocations()
45 var env2 = GrpcEnvironment.AddRef(); in SubsequentInvocations()
47 GrpcEnvironment.ReleaseAsync().Wait(); in SubsequentInvocations()
48 GrpcEnvironment.ReleaseAsync().Wait(); in SubsequentInvocations()
54 Assert.AreEqual(0, GrpcEnvironment.GetRefCount()); in InitializeAfterShutdown()
56 var env1 = GrpcEnvironment.AddRef(); in InitializeAfterShutdown()
57 GrpcEnvironment.ReleaseAsync().Wait(); in InitializeAfterShutdown()
59 var env2 = GrpcEnvironment.AddRef(); in InitializeAfterShutdown()
[all …]
|
| D | PInvokeTest.cs | 43 … GrpcEnvironment.AddRef(); // completion queue requires gRPC environment being initialized. in CompletionQueueCreateSyncDestroyBenchmark()
53 GrpcEnvironment.ReleaseAsync().Wait(); in CompletionQueueCreateSyncDestroyBenchmark()
|
| D | NUnitMain.cs | 36 GrpcEnvironment.SetLogger(new ConsoleLogger()); in Main()
|
| /external/grpc-grpc/src/csharp/Grpc.Core/ |
| D | GrpcEnvironment.cs | 33 public class GrpcEnvironment class
42 static GrpcEnvironment instance;
69 internal static GrpcEnvironment AddRef() in AddRef()
78 instance = new GrpcEnvironment(); in AddRef()
89 GrpcEnvironment instanceToShutdown = null; in ReleaseAsync()
247 GrpcEnvironment.inlineHandlers = inlineHandlers; in SetHandlerInlining()
300 private GrpcEnvironment() in GrpcEnvironment() method in Grpc.Core.GrpcEnvironment
486 … Task.WaitAll(GrpcEnvironment.ShutdownChannelsAsync(), GrpcEnvironment.KillServersAsync()); in HandleShutdown()
|
| D | Channel.cs | 35 static readonly ILogger Logger = GrpcEnvironment.Logger.ForType<Channel>();
42 readonly GrpcEnvironment environment;
72 this.environment = GrpcEnvironment.AddRef(); in Channel()
87 GrpcEnvironment.RegisterChannel(this); in Channel()
242 GrpcEnvironment.UnregisterChannel(this); in ShutdownAsync()
257 await GrpcEnvironment.ReleaseAsync().ConfigureAwait(false); in ShutdownAsync()
268 internal GrpcEnvironment Environment
|
| D | Server.cs | 37 static readonly ILogger Logger = GrpcEnvironment.Logger.ForType<Server>();
43 readonly GrpcEnvironment environment;
72 this.environment = GrpcEnvironment.AddRef(); in Server()
83 GrpcEnvironment.RegisterServer(this); in Server()
217 GrpcEnvironment.UnregisterServer(this); in ShutdownInternalAsync()
229 await GrpcEnvironment.ReleaseAsync().ConfigureAwait(false); in ShutdownInternalAsync()
|
| /external/grpc-grpc/src/csharp/Grpc.Core.Tests/Internal/ |
| D | CompletionQueueSafeHandleTest.cs | 33 GrpcEnvironment.AddRef(); in CreateSyncAndDestroy()
36 GrpcEnvironment.ReleaseAsync().Wait(); in CreateSyncAndDestroy()
42 var env = GrpcEnvironment.AddRef(); in CreateAsyncAndShutdown()
47 GrpcEnvironment.ReleaseAsync().Wait(); in CreateAsyncAndShutdown()
|
| /external/grpc-grpc/src/csharp/Grpc.Microbenchmarks/ |
| D | CompletionRegistryBenchmark.cs | 31 GrpcEnvironment environment;
35 environment = GrpcEnvironment.AddRef(); in Init()
40 GrpcEnvironment.ReleaseAsync().Wait(); in Cleanup()
|
| D | SendMessageBenchmark.cs | 32 GrpcEnvironment environment;
37 environment = GrpcEnvironment.AddRef(); in Init()
42 GrpcEnvironment.ReleaseAsync().Wait(); in Cleanup()
|
| D | Program.cs | 45 GrpcEnvironment.SetLogger(new ConsoleLogger()); in Main()
|
| /external/grpc-grpc/src/csharp/Grpc.Core/Internal/ |
| D | ChannelSafeHandle.cs | 39 GrpcEnvironment.GrpcNativeInit(); in CreateInsecure()
47 GrpcEnvironment.GrpcNativeInit(); in CreateSecure()
84 GrpcEnvironment.GrpcNativeShutdown(); in ReleaseHandle()
|
| D | GrpcThreadPool.cs | 35 static readonly ILogger Logger = GrpcEnvironment.Logger.ForType<GrpcThreadPool>();
39 readonly GrpcEnvironment environment;
62 …public GrpcThreadPool(GrpcEnvironment environment, int poolSize, int completionQueueCount, bool in… in GrpcThreadPool()
217 …dOnlyCollection<CompletionQueueSafeHandle> CreateCompletionQueueList(GrpcEnvironment environment, … in CreateCompletionQueueList()
|
| D | CompletionRegistry.cs | 36 static readonly ILogger Logger = GrpcEnvironment.Logger.ForType<CompletionRegistry>();
38 readonly GrpcEnvironment environment;
45 …public CompletionRegistry(GrpcEnvironment environment, Func<BatchContextSafeHandle> batchContextFa… in CompletionRegistry()
|
| D | ServerSafeHandle.cs | 36 GrpcEnvironment.GrpcNativeInit(); in NewServer()
86 GrpcEnvironment.GrpcNativeShutdown(); in ReleaseHandle()
|
| D | ServerCallHandler.cs | 41 …static readonly ILogger Logger = GrpcEnvironment.Logger.ForType<UnaryServerCallHandler<TRequest, T…
105 …static readonly ILogger Logger = GrpcEnvironment.Logger.ForType<ServerStreamingServerCallHandler<T…
168 …static readonly ILogger Logger = GrpcEnvironment.Logger.ForType<ClientStreamingServerCallHandler<T…
231 …static readonly ILogger Logger = GrpcEnvironment.Logger.ForType<DuplexStreamingServerCallHandler<T…
|
| D | NativeLogRedirector.cs | 59 var logger = GrpcEnvironment.Logger; in HandleWrite()
|
| /external/grpc-grpc/src/csharp/Grpc.IntegrationTesting/ |
| D | QpsWorker.cs | 54 GrpcEnvironment.SetLogger(new ConsoleLogger()); in Run()
78 GrpcEnvironment.Logger.Info("Running qps worker server on {0}:{1}", host, boundPort); in RunAsync()
83 … GrpcEnvironment.Logger.Info("GC collection counts (after shutdown): gen0 {0}, gen1 {1}, gen2 {2}", in RunAsync()
|
| D | ServerRunners.cs | 41 static readonly ILogger Logger = GrpcEnvironment.Logger.ForType<ServerRunners>();
143 …GrpcEnvironment.Logger.Info("[ServerRunner.GetStats] GC collection counts: gen0 {0}, gen1 {1}, gen… in GetStats()
|
| D | NUnitMain.cs | 36 GrpcEnvironment.SetLogger(new ConsoleLogger()); in Main()
|
| D | StressTestClient.cs | 37 static readonly ILogger Logger = GrpcEnvironment.Logger.ForType<StressTestClient>();
80 GrpcEnvironment.SetLogger(new ConsoleLogger()); in Run()
|
| D | InteropServer.cs | 57 GrpcEnvironment.SetLogger(new ConsoleLogger()); in Run()
|
| /external/grpc-grpc/src/csharp/Grpc.HealthCheck.Tests/ |
| D | NUnitMain.cs | 36 GrpcEnvironment.SetLogger(new ConsoleLogger()); in Main()
|
| /external/grpc-grpc/src/csharp/Grpc.Examples.Tests/ |
| D | NUnitMain.cs | 36 GrpcEnvironment.SetLogger(new ConsoleLogger()); in Main()
|
| /external/grpc-grpc/src/csharp/Grpc.Reflection.Tests/ |
| D | NUnitMain.cs | 36 GrpcEnvironment.SetLogger(new ConsoleLogger()); in Main()
|
| /external/grpc-grpc/src/csharp/Grpc.Core/Utils/ |
| D | BenchmarkUtil.cs | 37 var logger = GrpcEnvironment.Logger; in RunBenchmark()
|