| /external/okhttp/okhttp-ws-tests/src/test/java/com/squareup/okhttp/internal/ws/ |
| D | RealWebSocketTest.java | 107 server.readMessage(); in textMessage()
113 server.readMessage(); in binaryMessage()
151 server.readMessage(); in streamingMessage()
170 server.readMessage(); in streamingMessageCanInterleavePing()
172 client.readMessage(); in streamingMessageCanInterleavePing()
178 server.readMessage(); // Read the ping, write the pong. in pingWritesPong()
179 client.readMessage(); // Read the pong. in pingWritesPong()
185 server.readMessage(); in unsolicitedPong()
191 assertFalse(server.readMessage()); // This will trigger a close response. in close()
193 assertFalse(client.readMessage()); in close()
[all …]
|
| /external/libmojo/mojo/android/system/src/org/chromium/mojo/system/impl/ |
| D | MessagePipeHandleImpl.java | 53 public ResultAnd<ReadMessageResult> readMessage( in readMessage() method in MessagePipeHandleImpl
55 return mCore.readMessage(this, bytes, maxNumberOfHandles, flags); in readMessage()
|
| /external/deqp/execserver/tools/ |
| D | xsTest.cpp | 108 Message* readMessage (de::Socket& socket) in readMessage() function
395 ScopedMsgPtr msg(readMessage(socket)); in runClient()
438 ScopedMsgPtr msg(readMessage(socket)); in runClient()
498 ScopedMsgPtr msg(readMessage(socket)); in runClient()
560 ScopedMsgPtr msg(readMessage(socket)); in runClient()
652 ScopedMsgPtr msg(readMessage(socket)); in runClient()
756 ScopedMsgPtr msg(readMessage(socket)); in runClient()
788 ScopedMsgPtr msg(readMessage(socket)); in runClient()
|
| D | xsClient.cpp | 102 Message* readMessage (de::Socket& socket) in readMessage() function
199 ScopedMsgPtr msg(readMessage(m_socket)); in run()
|
| /external/protobuf/js/binary/ |
| D | reader_test.js | 98 reader.readMessage(dummyMessage, function() {
104 reader.readMessage(dummyMessage, function() {
143 reader.readMessage(dummyMessage, goog.nullFunction);
154 reader.readMessage(dummyMessage, function() {
564 reader.readMessage(dummyMessage, function() {
583 reader.readMessage(dummyMessage, function() {
862 reader.readMessage(dummyMessage, function() {
|
| /external/libmojo/mojo/public/java/bindings/src/org/chromium/mojo/bindings/ |
| D | Connector.java | 199 handle.readMessage(null, 0, MessagePipeHandle.ReadFlags.NONE); in readAndDispatchMessage()
206 result = handle.readMessage( in readAndDispatchMessage()
|
| D | ExecutorFactory.java | 112 mReadHandle.readMessage(NOTIFY_BUFFER, 0, MessagePipeHandle.ReadFlags.NONE); in readNotifyBufferMessage()
|
| /external/conscrypt/benchmark-base/src/main/java/org/conscrypt/ |
| D | ServerEndpoint.java | 161 int bytesRead = readMessage(); in run()
171 private int readMessage() throws IOException { in readMessage() method in ServerEndpoint.ProcessTask
|
| D | ClientEndpoint.java | 65 int readMessage(byte[] buffer) { in readMessage() method in ClientEndpoint
|
| D | ServerSocketBenchmark.java | 106 int numBytes = client.readMessage(buffer); in ServerSocketBenchmark()
|
| /external/libmojo/mojo/android/javatests/src/org/chromium/mojo/system/impl/ |
| D | CoreImplTest.java | 108 out.readMessage(receiveBuffer, 0, MessagePipeHandle.ReadFlags.NONE); in checkSendingMessage()
115 result = out.readMessage(receiveBuffer, 0, MessagePipeHandle.ReadFlags.NONE); in checkSendingMessage()
299 handles.first.readMessage(null, 0, MessagePipeHandle.ReadFlags.NONE); in testMessagePipeEmpty()
358 handles.second.readMessage(receiveBuffer, 0, MessagePipeHandle.ReadFlags.NONE); in testMessagePipeReceiveOnSmallBuffer()
379 handles.second.readMessage(null, 1, MessagePipeHandle.ReadFlags.NONE); in testMessagePipeSendHandles()
576 handles.second.readMessage(null, 1, MessagePipeHandle.ReadFlags.NONE); in testInvalidHandle()
|
| /external/protobuf/objectivec/ |
| D | GPBCodedInputStream.h | 97 - (void)readMessage:(GPBMessage *)message
|
| /external/skqp/tools/sk_app/android/ |
| D | surface_glue_android.h | 56 void readMessage(Message* message) const;
|
| D | surface_glue_android.cpp | 85 void SkiaAndroidApp::readMessage(Message* message) const { in readMessage() function in sk_app::SkiaAndroidApp
93 skiaAndroidApp->readMessage(&message); in message_callback()
|
| /external/skia/tools/sk_app/android/ |
| D | surface_glue_android.h | 56 void readMessage(Message* message) const;
|
| D | surface_glue_android.cpp | 85 void SkiaAndroidApp::readMessage(Message* message) const { in readMessage() function in sk_app::SkiaAndroidApp
93 skiaAndroidApp->readMessage(&message); in message_callback()
|
| /external/libmojo/mojo/android/javatests/src/org/chromium/mojo/bindings/ |
| D | RouterTest.java | 69 mHandle.readMessage(receiveBuffer, 0, MessagePipeHandle.ReadFlags.NONE); in testSendingToRouterWithResponse()
142 mHandle.readMessage(receivedResponseMessage, 0, MessagePipeHandle.ReadFlags.NONE); in sendResponseFromRouter()
|
| D | ConnectorTest.java | 76 mHandle.readMessage(received, 0, MessagePipeHandle.ReadFlags.NONE); in testSendingMessage()
|
| /external/libmojo/mojo/public/java/system/src/org/chromium/mojo/system/ |
| D | MessagePipeHandle.java | 222 ResultAnd<ReadMessageResult> readMessage( in readMessage() method
|
| D | InvalidHandle.java | 215 public ResultAnd<ReadMessageResult> readMessage( in readMessage() method in InvalidHandle
|
| /external/libmojo/mojo/public/js/ |
| D | core.js | 208 function readMessage(handle, flags) { [native code] } function
|
| D | connector.js | 93 var read = core.readMessage(this.handle_,
|
| /external/conscrypt/openjdk/src/test/java/org/conscrypt/ |
| D | RenegotiationTest.java | 313 readMessage();
342 private void readMessage() throws IOException {
|
| D | OpenSSLServerSocketImplTest.java | 120 int numBytes = client.readMessage(responseBuffer); in pingPong()
|
| /external/libmojo/mojo/android/javatests/src/org/chromium/mojo/ |
| D | HandleMock.java | 165 public ResultAnd<ReadMessageResult> readMessage( in readMessage() method in HandleMock
|