HomeSort by relevance Sort by last modified time
    Searched refs:pendingData (Results 1 - 3 of 3) sorted by null

  /external/syzkaller/vendor/google.golang.org/grpc/transport/
flowcontrol.go 150 // pendingData is the overall data which have been received but not been
152 pendingData uint32
178 estSenderQuota := int32(f.limit - (f.pendingData + f.pendingUpdate))
182 estUntransmittedData := int32(n - f.pendingData) // Casting into int32 since it could be negative.
203 // onData is invoked when some data frame is received. It updates pendingData.
206 f.pendingData += n
207 if f.pendingData+f.pendingUpdate > f.limit+f.delta {
209 rcvd := f.pendingData + f.pendingUpdate
221 if f.pendingData == 0 {
225 f.pendingData -=
    [all...]
  /external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/
OkHttpClientStream.java 192 private Queue<PendingData> pendingData = new ArrayDeque<PendingData>();
226 if (pendingData != null) {
233 while (!pendingData.isEmpty()) {
234 PendingData data = pendingData.poll();
243 pendingData = null;
343 if (pendingData != null) {
348 for (PendingData data : pendingData)
    [all...]
  /external/grpc-grpc-java/cronet/src/main/java/io/grpc/cronet/
CronetClientStream.java 179 state.enqueuePendingData(new PendingData(byteBuffer, endOfStream, flush));
215 private Queue<PendingData> pendingData = new LinkedList<PendingData>();
296 for (PendingData data : pendingData) {
299 pendingData.clear();
303 private void enqueuePendingData(PendingData data) {
304 pendingData.add(data);
309 for (PendingData data : pendingData)
    [all...]

Completed in 325 milliseconds