Searched refs:receivedStatus (Results 1 – 3 of 3) sorted by relevance
| /external/grpc-grpc/src/csharp/Grpc.Core/Internal/ |
| D | AsyncCall.cs | 540 …private void HandleUnaryResponse(bool success, ClientSideStatus receivedStatus, byte[] receivedMes… in HandleUnaryResponse() argument
554 … if (deserializeException != null && receivedStatus.Status.StatusCode == StatusCode.OK) in HandleUnaryResponse()
556 … receivedStatus = new ClientSideStatus(DeserializeResponseFailureStatus, receivedStatus.Trailers); in HandleUnaryResponse()
558 finishedStatus = receivedStatus; in HandleUnaryResponse()
581 var status = receivedStatus.Status; in HandleUnaryResponse()
584 unaryResponseTcs.SetException(new RpcException(status, receivedStatus.Trailers)); in HandleUnaryResponse()
594 private void HandleFinished(bool success, ClientSideStatus receivedStatus) in HandleFinished() argument
605 finishedStatus = receivedStatus; in HandleFinished()
625 var status = receivedStatus.Status; in HandleFinished()
628 … streamingResponseCallFinishedTcs.SetException(new RpcException(status, receivedStatus.Trailers)); in HandleFinished()
[all …]
|
| D | INativeCall.cs | 25 …void OnUnaryResponseClient(bool success, ClientSideStatus receivedStatus, byte[] receivedMessage, … in OnUnaryResponseClient() argument
31 void OnReceivedStatusOnClient(bool success, ClientSideStatus receivedStatus); in OnReceivedStatusOnClient() argument
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/channels/ |
| D | ChannelUndeliveredElementStressTest.kt | 56 private val receivedStatus = ItemStatus() // 1-6 received in <lambda>() constant
120 receivedStatus.clear() in <lambda>()
135 val min = minOf(sentStatus.min, receivedStatus.min, failedStatus.min) in <lambda>()
136 val max = maxOf(sentStatus.max, receivedStatus.max, failedStatus.max) in <lambda>()
139 val receivedCnt = if (receivedStatus[x] != 0) 1 else 0 in <lambda>()
206 receivedStatus[received] = receiveMode in <lambda>()
|