Searched refs:receivedMessage (Results 1 – 6 of 6) sorted by relevance
| /external/grpc-grpc/src/csharp/Grpc.Core/Internal/ |
| D | AsyncCallBase.cs | 319 protected void HandleReadFinished(bool success, byte[] receivedMessage) in HandleReadFinished() argument
326 …var deserializeException = (success && receivedMessage != null) ? TryDeserialize(receivedMessage, … in HandleReadFinished()
333 if (receivedMessage == null) in HandleReadFinished()
377 void IReceivedMessageCallback.OnReceivedMessage(bool success, byte[] receivedMessage) in IReceivedMessageCallback.OnReceivedMessage() argument
379 HandleReadFinished(success, receivedMessage); in IReceivedMessageCallback.OnReceivedMessage()
|
| D | INativeCall.cs | 25 …ResponseClient(bool success, ClientSideStatus receivedStatus, byte[] receivedMessage, Metadata res… in OnUnaryResponseClient() argument
36 void OnReceivedMessage(bool success, byte[] receivedMessage); in OnReceivedMessage() argument
|
| D | AsyncCall.cs | 540 …eUnaryResponse(bool success, ClientSideStatus receivedStatus, byte[] receivedMessage, Metadata res… in HandleUnaryResponse() argument
547 var deserializeException = TryDeserialize(receivedMessage, out msg); in HandleUnaryResponse()
637 …ResponseClient(bool success, ClientSideStatus receivedStatus, byte[] receivedMessage, Metadata res… in IUnaryResponseClientCallback.OnUnaryResponseClient() argument
639 HandleUnaryResponse(success, receivedStatus, receivedMessage, responseHeaders); in IUnaryResponseClientCallback.OnUnaryResponseClient()
|
| /external/libchrome/mojo/public/java/system/javatests/src/org/chromium/mojo/bindings/ |
| D | RouterTest.java | 124 Pair<Message, MessageReceiver> receivedMessage = in sendMessageToRouter() local
126 Assert.assertEquals(headerMessage.getData(), receivedMessage.first.getData()); in sendMessageToRouter()
137 Pair<Message, MessageReceiver> receivedMessage = in sendResponseFromRouter() local
140 long requestId = receivedMessage.first.asServiceMessage().getHeader().getRequestId(); in sendResponseFromRouter()
147 receivedMessage.second.accept(message); in sendResponseFromRouter()
168 for (Pair<Message, MessageReceiver> receivedMessage : in clearAllMessageReceivers()
171 (RouterImpl.ResponderThunk) receivedMessage.second; in clearAllMessageReceivers()
|
| /external/google-breakpad/src/client/linux/handler/ |
| D | exception_handler.cc | 556 char receivedMessage; in WaitForContinueSignal() local
557 r = HANDLE_EINTR(sys_read(fdes[0], &receivedMessage, sizeof(char))); in WaitForContinueSignal()
|
| /external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/ |
| D | OkHttpClientTransportTest.java | 873 final String receivedMessage = "No, you are fine."; in receiveGoAway() local
874 Buffer buffer = createMessageFrame(receivedMessage); in receiveGoAway()
879 assertEquals(receivedMessage, listener1.messages.get(0)); in receiveGoAway()
|