Searched refs:sharedCapacity (Results 1 – 3 of 3) sorted by relevance
38 readonly int sharedCapacity; field in Grpc.Core.Internal.DefaultObjectPool54 public DefaultObjectPool(Func<T> itemFactory, int sharedCapacity, int threadLocalCapacity) in DefaultObjectPool() argument56 GrpcPreconditions.CheckArgument(sharedCapacity >= 0); in DefaultObjectPool()60 this.sharedQueue = new Queue<T>(sharedCapacity); in DefaultObjectPool()61 this.sharedCapacity = sharedCapacity; in DefaultObjectPool()152 if (sharedQueue.Count < sharedCapacity && !disposed) in Return()157 … while (sharedQueue.Count < sharedCapacity && itemsReturned < returnLimit && !disposed) in Return()
259 public static void SetBatchContextPoolParams(int sharedCapacity, int threadLocalCapacity) in SetBatchContextPoolParams() argument264 …GrpcPreconditions.CheckArgument(sharedCapacity >= 0, "Shared capacity needs to be a non-negative n… in SetBatchContextPoolParams()266 batchContextPoolSharedCapacity = sharedCapacity; in SetBatchContextPoolParams()279 … public static void SetRequestCallContextPoolParams(int sharedCapacity, int threadLocalCapacity) in SetRequestCallContextPoolParams() argument284 …GrpcPreconditions.CheckArgument(sharedCapacity >= 0, "Shared capacity needs to be a non-negative n… in SetRequestCallContextPoolParams()286 requestCallContextPoolSharedCapacity = sharedCapacity; in SetRequestCallContextPoolParams()
34 public void ObjectIsReused(int sharedCapacity, int threadLocalCapacity) in ObjectIsReused() argument36 …ew DefaultObjectPool<TestPooledObject>(() => new TestPooledObject(), sharedCapacity, threadLocalCa… in ObjectIsReused()