/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
Stream.java | 53 void writeMessage(InputStream message);
|
ForwardingClientStream.java | 36 public void writeMessage(InputStream message) { 37 delegate().writeMessage(message);
|
NoopClientStream.java | 48 public void writeMessage(InputStream message) {}
|
DelayedStream.java | 221 public void writeMessage(final InputStream message) { 224 realStream.writeMessage(message); 229 realStream.writeMessage(message);
|
AbstractStream.java | 49 public final void writeMessage(InputStream message) {
|
/external/libchrome/mojo/public/java/system/src/org/chromium/mojo/system/impl/ |
MessagePipeHandleImpl.java | 41 * @see MessagePipeHandle#writeMessage(ByteBuffer, List, WriteFlags) 44 public void writeMessage(ByteBuffer bytes, List<? extends Handle> handles, WriteFlags flags) { 45 mCore.writeMessage(this, bytes, handles, flags);
|
/external/deqp/external/openglcts/modules/common/ |
glcTestSubcase.cpp | 123 log.writeMessage(line.c_str()); 138 log.writeMessage(line.c_str()); 234 log.writeMessage("Test Setup() failed"); 238 log.writeMessage(ex.what()); 243 log.writeMessage("Undefined exception."); 254 log.writeMessage("Test Run() failed"); 258 log.writeMessage(ex.what()); 263 log.writeMessage("Undefined exception."); 274 log.writeMessage("Test Cleanup() failed"); 279 log.writeMessage(ex.what()) [all...] |
/external/deqp/execserver/ |
xsTestDriver.cpp | 93 if (writeMessage(messageBuffer, ProcessLaunchFailedMessage(m_lastLaunchFailure.c_str()))) 104 if (writeMessage(messageBuffer, ProcessStartedMessage())) 164 if (writeMessage(messageBuffer, ProcessFinishedMessage(m_lastExitCode))) 227 bool TestDriver::writeMessage (ByteBuffer& messageBuffer, const Message& message)
|
xsTestDriver.hpp | 65 bool writeMessage (ByteBuffer& messageBuffer, const Message& message);
|
/external/libchrome/mojo/public/java/system/src/org/chromium/mojo/system/ |
MessagePipeHandle.java | 151 void writeMessage(ByteBuffer bytes, List<? extends Handle> handles, WriteFlags flags);
|
InvalidHandle.java | 202 * @see MessagePipeHandle#writeMessage(java.nio.ByteBuffer, java.util.List, 206 public void writeMessage(ByteBuffer bytes, List<? extends Handle> handles, WriteFlags flags) {
|
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
AbstractServerStreamTest.java | 259 stream.writeMessage(new ByteArrayInputStream(new byte[]{})); 271 stream.writeMessage(new ByteArrayInputStream(new byte[]{})); 278 public void writeMessage() { 281 stream.writeMessage(new ByteArrayInputStream(new byte[]{})); 291 stream.writeMessage(input);
|
ForwardingClientStreamTest.java | 68 forward.writeMessage(is); 69 verify(mock).writeMessage(same(is));
|
DelayedStreamTest.java | 100 stream.writeMessage(message); 102 stream.writeMessage(message); 112 verify(realStream, times(2)).writeMessage(message); 115 stream.writeMessage(message); 116 verify(realStream, times(3)).writeMessage(message);
|
ServerCallImplTest.java | 176 verify(stream).writeMessage(isA(InputStream.class)); 202 doThrow(new RuntimeException("bad")).when(stream).writeMessage(isA(InputStream.class)); 231 verify(stream, times(1)).writeMessage(any(InputStream.class)); 236 verify(stream, times(1)).writeMessage(any(InputStream.class)); 266 verify(stream, times(1)).writeMessage(any(InputStream.class));
|
RetriableStreamTest.java | 242 inOrder.verify(mockStream1, times(2)).writeMessage(any(InputStream.class)); 245 inOrder.verify(mockStream1).writeMessage(any(InputStream.class)); 277 inOrder.verify(mockStream2, times(2)).writeMessage(any(InputStream.class)); 280 inOrder.verify(mockStream2).writeMessage(any(InputStream.class)); 282 inOrder.verify(mockStream2, times(2)).writeMessage(any(InputStream.class)); 291 inOrder.verify(mockStream2, times(2)).writeMessage(any(InputStream.class)); 324 inOrder.verify(mockStream3, times(2)).writeMessage(any(InputStream.class)); 327 inOrder.verify(mockStream3).writeMessage(any(InputStream.class)); 329 inOrder.verify(mockStream3, times(7)).writeMessage(any(InputStream.class)); 669 inOrder.verify(mockStream1).writeMessage(any(InputStream.class)); // msg "substream1 request 3 [all...] |
/cts/apps/CtsVerifier/src/com/android/cts/verifier/nfc/tech/ |
NdefTagTester.java | 71 writeMessage(tag, expectedMessage); 107 private void writeMessage(Tag tag, NdefMessage message) throws IOException, FormatException {
|
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
NettyStreamTestBase.java | 155 stream.writeMessage(new ByteArrayInputStream(msg)); 170 stream.writeMessage(new ByteArrayInputStream(msg)); 185 stream.writeMessage(new ByteArrayInputStream(msg));
|
/device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.2/Lib/test/ |
test_mhlib.py | 62 def writeMessage(folder, n, headers, body):
114 writeMessage('inbox', 1,
118 writeMessage('inbox', 2,
125 writeMessage('wide', i,
131 writeMessage(folder, n,
|
/external/python/cpython2/Lib/test/ |
test_mhlib.py | 62 def writeMessage(folder, n, headers, body): 114 writeMessage('inbox', 1, 118 writeMessage('inbox', 2, 125 writeMessage('wide', i, 131 writeMessage(folder, n,
|
/external/libchrome/mojo/public/java/bindings/src/org/chromium/mojo/bindings/ |
ExecutorFactory.java | 148 mWriteHandle.writeMessage(NOTIFY_BUFFER, null, MessagePipeHandle.WriteFlags.NONE);
|
Connector.java | 97 mMessagePipeHandle.writeMessage(message.getData(),
|
/external/libchrome/mojo/public/java/system/javatests/src/org/chromium/mojo/ |
HandleMock.java | 146 * @see MessagePipeHandle#writeMessage(java.nio.ByteBuffer, java.util.List, 150 public void writeMessage(ByteBuffer bytes, List<? extends Handle> handles, WriteFlags flags) {
|
/external/libchrome/mojo/public/java/system/javatests/src/org/chromium/mojo/bindings/ |
RouterTest.java | 94 mHandle.writeMessage(responseMessage.getData(), new ArrayList<Handle>(), 119 mHandle.writeMessage(headerMessage.getData(), new ArrayList<Handle>(),
|
/external/grpc-grpc/examples/node/static_codegen/route_guide/ |
route_guide_pb.js | 337 writer.writeMessage( 345 writer.writeMessage( 545 writer.writeMessage( 732 writer.writeMessage(
|