Searched refs:pendingData (Results 1 – 3 of 3) sorted by relevance
152 pendingData uint32 member178 estSenderQuota := int32(f.limit - (f.pendingData + f.pendingUpdate))182 estUntransmittedData := int32(n - f.pendingData) // Casting into int32 since it could be negative.206 f.pendingData += n207 if f.pendingData+f.pendingUpdate > f.limit+f.delta {209 rcvd := f.pendingData + f.pendingUpdate221 if f.pendingData == 0 {225 f.pendingData -= n
192 private Queue<PendingData> pendingData = new ArrayDeque<PendingData>(); field in OkHttpClientStream.TransportState226 if (pendingData != null) { in start()233 while (!pendingData.isEmpty()) { in start()234 PendingData data = pendingData.poll(); in start()243 pendingData = null; in start()343 if (pendingData != null) { in cancel()348 for (PendingData data : pendingData) { in cancel()351 pendingData = null; in cancel()366 if (pendingData != null) { in sendBuffer()368 pendingData.add(new PendingData(buffer, endOfStream, flush)); in sendBuffer()
215 private Queue<PendingData> pendingData = new LinkedList<PendingData>(); field in CronetClientStream.TransportState296 for (PendingData data : pendingData) { in clearPendingData()299 pendingData.clear(); in clearPendingData()304 pendingData.add(data); in enqueuePendingData()309 for (PendingData data : pendingData) { in writeAllPendingData()312 pendingData.clear(); in writeAllPendingData()