OpenGrok
Home
Sort by relevance
Sort by last modified time
Full Search
Definition
Symbol
File Path
History
|
|
Help
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