Searched refs:maxOutboundMessageSize (Results 1 – 3 of 3) sorted by relevance
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | MessageFramer.java | 73 private int maxOutboundMessageSize = NO_MAX_OUTBOUND_MESSAGE_SIZE; field in MessageFramer
116 checkState(maxOutboundMessageSize == NO_MAX_OUTBOUND_MESSAGE_SIZE, "max size already set"); in setMaxOutboundMessageSize()
117 maxOutboundMessageSize = maxSize; in setMaxOutboundMessageSize()
171 if (maxOutboundMessageSize >= 0 && written > maxOutboundMessageSize) { in writeUncompressed()
174 String.format("message too large %d > %d", written , maxOutboundMessageSize)) in writeUncompressed()
191 if (maxOutboundMessageSize >= 0 && written > maxOutboundMessageSize) { in writeCompressed()
194 String.format("message too large %d > %d", written , maxOutboundMessageSize)) in writeCompressed()
214 if (maxOutboundMessageSize >= 0 && messageLength > maxOutboundMessageSize) { in writeKnownLengthUncompressed()
217 String.format("message too large %d > %d", messageLength , maxOutboundMessageSize)) in writeKnownLengthUncompressed()
|
| D | ServiceConfigInterceptor.java | 134 final Integer maxOutboundMessageSize; field in ServiceConfigInterceptor.MethodInfo
155 maxOutboundMessageSize = in MethodInfo()
157 if (maxOutboundMessageSize != null) { in MethodInfo()
159 maxOutboundMessageSize >= 0, in MethodInfo()
160 "maxOutboundMessageSize %s exceeds bounds", maxOutboundMessageSize); in MethodInfo()
177 timeoutNanos, waitForReady, maxInboundMessageSize, maxOutboundMessageSize, retryPolicy); in hashCode()
189 && Objects.equal(this.maxOutboundMessageSize, that.maxOutboundMessageSize) in equals()
199 .add("maxOutboundMessageSize", maxOutboundMessageSize) in toString()
386 if (info.maxOutboundMessageSize != null) { in interceptCall()
390 Math.min(existingLimit, info.maxOutboundMessageSize)); in interceptCall()
[all …]
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/ |
| D | CallOptions.java | 74 private Integer maxOutboundMessageSize; field in CallOptions
387 newOptions.maxOutboundMessageSize = maxSize; in withMaxOutboundMessageSize()
406 return maxOutboundMessageSize; in getMaxOutboundMessageSize()
421 maxOutboundMessageSize = other.maxOutboundMessageSize; in CallOptions()
436 .add("maxOutboundMessageSize", maxOutboundMessageSize) in toString()
|