| /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/conscrypt/benchmark-base/src/main/java/org/conscrypt/ |
| D | ServerEndpoint.java | 149 int bytesRead = readMessage(); in run()
159 private int readMessage() throws IOException { in readMessage() method in ServerEndpoint.ProcessTask
|
| D | ClientEndpoint.java | 62 int readMessage(byte[] buffer) { in readMessage() method in ClientEndpoint
|
| D | ServerSocketBenchmark.java | 98 int numBytes = client.readMessage(buffer); in ServerSocketBenchmark()
|
| /external/libmojo/mojo/public/java/bindings/src/org/chromium/mojo/bindings/ |
| D | Connector.java | 235 handle.readMessage(null, 0, MessagePipeHandle.ReadFlags.NONE); in readAndDispatchMessage()
242 result = handle.readMessage( in readAndDispatchMessage()
|
| D | ExecutorFactory.java | 127 mReadHandle.readMessage(NOTIFY_BUFFER, 0, MessagePipeHandle.ReadFlags.NONE); in readNotifyBufferMessage()
|
| /external/protobuf/objectivec/ |
| D | GPBCodedInputStream.h | 97 - (void)readMessage:(GPBMessage *)message
|
| /external/skia/tools/viewer/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/public/js/ |
| D | core.js | 187 function readMessage(handle, flags) { [native code] } function
|
| D | connector.js | 87 var read = core.readMessage(this.handle_,
|
| /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/android/javatests/src/org/chromium/mojo/system/impl/ |
| D | CoreImplTest.java | 111 out.readMessage(receiveBuffer, 0, MessagePipeHandle.ReadFlags.NONE); in checkSendingMessage()
118 result = out.readMessage(receiveBuffer, 0, MessagePipeHandle.ReadFlags.NONE); in checkSendingMessage()
302 handles.first.readMessage(null, 0, MessagePipeHandle.ReadFlags.NONE); in testMessagePipeEmpty()
361 handles.second.readMessage(receiveBuffer, 0, MessagePipeHandle.ReadFlags.NONE); in testMessagePipeReceiveOnSmallBuffer()
382 handles.second.readMessage(null, 1, MessagePipeHandle.ReadFlags.NONE); in testMessagePipeSendHandles()
579 handles.second.readMessage(null, 1, MessagePipeHandle.ReadFlags.NONE); in testInvalidHandle()
|
| /external/conscrypt/openjdk/src/test/java/org/conscrypt/ |
| 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
|
| /external/libmojo/mojo/edk/js/tests/ |
| D | connection_tests.js | 143 core.readMessage = function() { function
|
| /external/okhttp/okhttp-ws/src/main/java/com/squareup/okhttp/ws/ |
| D | WebSocketCall.java | 153 while (webSocket.readMessage()) { in createWebSocket()
|
| /external/okhttp/okhttp-ws/src/main/java/com/squareup/okhttp/internal/ws/ |
| D | RealWebSocket.java | 95 public boolean readMessage() { in readMessage() method in RealWebSocket
|