| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/src/ |
| D | ReactiveFlow.kt | 63 private val requestSize: Long in <lambda>() constant
92 val subscriber = ReactiveSubscriber<T>(capacity, onBufferOverflow, requestSize) in <lambda>()
101 if (++consumed == requestSize) { in <lambda>()
120 private val requestSize: Long constant
135 // Controlled by requestSize in onNext()
153 subscription.request(requestSize) in makeRequest()
|
| /external/ms-tpm-20-ref/TPMCmd/tpm/src/main/ |
| D | ExecCommand.c | 87 uint32_t requestSize, // IN: command buffer size in ExecuteCommand() argument
104 // the sizes do not include the tag, command.code, requestSize, or the authorization in ExecuteCommand()
116 TpmFailureMode(requestSize, request, responseSize, response); in ExecuteCommand()
141 command.parameterSize = requestSize; in ExecuteCommand()
158 // received on that port is requestSize it must be identical to commandSize. in ExecuteCommand()
163 // it reaches MAX_COMMAND_SIZE, and requestSize would not equal commandSize. in ExecuteCommand()
164 if(commandSize != requestSize || commandSize > MAX_COMMAND_SIZE) in ExecuteCommand()
|
| /external/nos/host/generic/libnos/ |
| D | NuggetClientDebuggable.cpp | 41 const uint32_t requestSize = request.size(); in CallApp() local
56 request.data(), requestSize, in CallApp()
|
| D | NuggetClient.cpp | 66 const uint32_t requestSize = request.size(); in CallApp() local
77 request.data(), requestSize, in CallApp()
|
| /external/grpc-grpc-java/gae-interop-testing/gae-jdk8/src/main/java/io/grpc/testing/integration/ |
| D | LongLivedChannel.java | 57 int requestSize = 1234; in doGet() local
62 .setBody(ByteString.copyFrom(new byte[requestSize]))) in doGet()
|
| /external/ms-tpm-20-ref/TPMCmd/Platform/src/ |
| D | RunCommand.c | 67 uint32_t requestSize, // IN: command buffer size in _plat__RunCommand() argument
74 ExecuteCommand(requestSize, request, responseSize, response); in _plat__RunCommand()
|
| /external/sdk-platform-java/gax-java/gax/src/main/java/com/google/api/gax/tracing/ |
| D | TracedBatchingCallable.java | 77 long requestSize = batchingDescriptor.countBytes(request); in futureCall() local
79 tracer.batchRequestSent(elementCount, requestSize); in futureCall()
|
| D | ApiTracer.java | 154 * @param requestSize the size of the batch in bytes.
156 void batchRequestSent(long elementCount, long requestSize); in batchRequestSent() argument
|
| D | BaseApiTracer.java | 140 public void batchRequestSent(long elementCount, long requestSize) { in batchRequestSent() argument
|
| D | OpencensusTracer.java | 406 public void batchRequestSent(long elementCount, long requestSize) {
408 span.putAttribute("batch size", AttributeValue.longAttributeValue(requestSize));
|
| /external/ms-tpm-20-ref/Samples/ARM32-FirmwareTPM/optee_ta/fTPM/platform/ |
| D | RunCommand.c | 71 uint32_t requestSize, // IN: command buffer size in _plat__RunCommand() argument
78 ExecuteCommand(requestSize, request, responseSize, response); in _plat__RunCommand()
|
| /external/ms-tpm-20-ref/Samples/Nucleo-TPM/Shared/Platform/src/ |
| D | RunCommand.c | 70 unsigned int requestSize, // IN: command buffer size in _plat__RunCommand() argument
77 ExecuteCommand((uint32_t)requestSize, request, (uint32_t*)responseSize, response); in _plat__RunCommand()
|
| /external/okhttp/okio/benchmarks/src/main/java/com/squareup/okio/benchmarks/ |
| D | BufferPerformanceBench.java | 163 int requestSize = 2048; field in BufferPerformanceBench
176 requestBytes = storeSourceData(new byte[requestSize]); in storeRequestResponseData()
177 responseBytes = storeSourceData(new byte[requestSize * responseFactor]); in storeRequestResponseData()
|
| /external/okio/okio/jvm/jmh/src/jmh/java/com/squareup/okio/benchmarks/ |
| D | BufferPerformanceBenchmark.java | 163 int requestSize = 2048; field in BufferPerformanceBenchmark
176 requestBytes = storeSourceData(new byte[requestSize]); in storeRequestResponseData()
177 responseBytes = storeSourceData(new byte[requestSize * responseFactor]); in storeRequestResponseData()
|
| /external/aws-sdk-java-v2/core/sdk-core/src/main/java/software/amazon/awssdk/core/internal/http/pipeline/stages/ |
| D | CompressRequestStage.java | 180 …int requestSize = SdkBytes.fromInputStream(input.contentStreamProvider().newStream()).asByteArray(… in isRequestSizeWithinThreshold() local
181 return requestSize >= minimumCompressionThreshold; in isRequestSizeWithinThreshold()
|
| /external/sdk-platform-java/java-common-protos/.github/ |
| D | auto-label.yaml | 14 requestsize:
|
| /external/google-cloud-java/owl-bot-postprocessor/synthtool/gcp/templates/java_library/.github/ |
| D | auto-label.yaml | 14 requestsize:
|
| /external/sdk-platform-java/.github/ |
| D | auto-label.yaml | 14 requestsize:
|
| /external/google-auth-library-java/.github/ |
| D | auto-label.yaml | 14 requestsize:
|
| /external/google-cloud-java/java-service-control/proto-google-cloud-service-control-v1/src/main/java/com/google/api/servicecontrol/v1/ |
| D | HttpRequestProto.java | 77 "RequestSize",
|
| /external/sdk-platform-java/java-common-protos/proto-google-common-protos/src/main/java/com/google/logging/type/ |
| D | HttpRequestProto.java | 75 "RequestSize",
|
| /external/ms-tpm-20-ref/Samples/ARM32-FirmwareTPM/optee_ta/fTPM/include/ |
| D | fTPM.h | 76 uint32_t requestSize, // IN: command buffer size
|
| /external/ms-tpm-20-ref/TPMCmd/tpm/include/prototypes/ |
| D | ExecCommand_fp.h | 82 uint32_t requestSize, // IN: command buffer size
|
| /external/grpc-grpc-java/benchmarks/src/jmh/java/io/grpc/benchmarks/netty/ |
| D | AbstractBenchmark.java | 194 MessageSize requestSize, in setup() argument
245 request = alloc.heapBuffer(requestSize.bytes()); in setup()
|
| /external/skia/src/gpu/ganesh/ |
| D | GrBufferAllocPool.cpp | 317 bool GrBufferAllocPool::createBlock(size_t requestSize) { in createBlock() argument
318 size_t size = std::max(requestSize, kDefaultBufferSize); in createBlock()
|