/external/libchrome/mojo/public/java/system/src/org/chromium/mojo/system/ |
D | DataPipe.java | 107 public static class WriteFlags extends Flags<WriteFlags> { class 114 public static final WriteFlags NONE = WriteFlags.none().immutable(); 121 private WriteFlags(int flags) { in WriteFlags() method in DataPipe.WriteFlags 132 public WriteFlags setAllOrNone(boolean allOrNone) { in setAllOrNone() 139 public static WriteFlags none() { in none() 140 return new WriteFlags(FLAG_NONE); in none() 237 public ResultAnd<Integer> writeData(ByteBuffer elements, WriteFlags flags); in writeData() 258 public ByteBuffer beginWriteData(int numBytes, WriteFlags flags); in beginWriteData()
|
D | MessagePipeHandle.java | 63 public static class WriteFlags extends Flags<WriteFlags> { class 69 public static final WriteFlags NONE = WriteFlags.none().immutable(); 76 private WriteFlags(int flags) { in WriteFlags() method in MessagePipeHandle.WriteFlags 83 public static WriteFlags none() { in none() 84 return new WriteFlags(FLAG_NONE); in none() 151 void writeMessage(ByteBuffer bytes, List<? extends Handle> handles, WriteFlags flags); in writeMessage()
|
D | InvalidHandle.java | 147 public ResultAnd<Integer> writeData(ByteBuffer elements, DataPipe.WriteFlags flags) { in writeData() 156 DataPipe.WriteFlags flags) { in beginWriteData() 206 public void writeMessage(ByteBuffer bytes, List<? extends Handle> handles, WriteFlags flags) { in writeMessage()
|
/external/grpc-grpc/src/csharp/Grpc.Core/ |
D | WriteOptions.cs | 27 public enum WriteFlags enum 52 private readonly WriteFlags flags; 58 public WriteOptions(WriteFlags flags = default(WriteFlags)) in WriteOptions() 66 public WriteFlags Flags
|
/external/grpc-grpc/src/csharp/Grpc.Core.Tests/ |
D | CompressionTest.cs | 60 context.WriteOptions = new WriteOptions(WriteFlags.NoCompress); in WriteOptions_Unary() 64 … var callOptions = new CallOptions(writeOptions: new WriteOptions(WriteFlags.NoCompress)); in WriteOptions_Unary() 75 context.WriteOptions = new WriteOptions(WriteFlags.NoCompress); in WriteOptions_DuplexStreaming() 84 responseStream.WriteOptions = new WriteOptions(WriteFlags.NoCompress); in WriteOptions_DuplexStreaming() 88 … var callOptions = new CallOptions(writeOptions: new WriteOptions(WriteFlags.NoCompress)); in WriteOptions_DuplexStreaming() 92 Assert.IsTrue((call.RequestStream.WriteOptions.Flags & WriteFlags.NoCompress) != 0); in WriteOptions_DuplexStreaming() 100 call.RequestStream.WriteOptions = new WriteOptions(WriteFlags.NoCompress); in WriteOptions_DuplexStreaming()
|
/external/grpc-grpc/src/csharp/Grpc.Core/Internal/ |
D | AsyncCallServer.cs | 81 public Task SendMessageAsync(TResponse msg, WriteFlags writeFlags) in SendMessageAsync() 133 … var writeFlags = optionalWrite.HasValue ? optionalWrite.Value.WriteFlags : default(WriteFlags); in SendStatusFromServerAsync() 253 public ResponseWithFlags(TResponse response, WriteFlags writeFlags) in ResponseWithFlags() 256 this.WriteFlags = writeFlags; in ResponseWithFlags() 260 public WriteFlags WriteFlags { get; } property
|
D | INativeCall.cs | 70 …void StartUnary(IUnaryResponseClientCallback callback, byte[] payload, WriteFlags writeFlags, Meta… in StartUnary() 72 …void StartUnary(BatchContextSafeHandle ctx, byte[] payload, WriteFlags writeFlags, MetadataArraySa… in StartUnary() 76 …verStreaming(IReceivedStatusOnClientCallback callback, byte[] payload, WriteFlags writeFlags, Meta… in StartServerStreaming() 86 …void StartSendMessage(ISendCompletionCallback callback, byte[] payload, WriteFlags writeFlags, boo… in StartSendMessage() 90 …andle metadataArray, bool sendEmptyInitialMetadata, byte[] optionalPayload, WriteFlags writeFlags); in StartSendStatusFromServer()
|
D | CallSafeHandle.cs | 69 …public void StartUnary(IUnaryResponseClientCallback callback, byte[] payload, WriteFlags writeFlag… in StartUnary() 79 …public void StartUnary(BatchContextSafeHandle ctx, byte[] payload, WriteFlags writeFlags, Metadata… in StartUnary() 94 …verStreaming(IReceivedStatusOnClientCallback callback, byte[] payload, WriteFlags writeFlags, Meta… in StartServerStreaming() 112 …public void StartSendMessage(ISendCompletionCallback callback, byte[] payload, WriteFlags writeFla… in StartSendMessage() 131 byte[] optionalPayload, WriteFlags writeFlags) in StartSendStatusFromServer()
|
D | ClientRequestStream.cs | 59 private WriteFlags GetWriteFlags() in GetWriteFlags() 62 return options != null ? options.Flags : default(WriteFlags); in GetWriteFlags()
|
D | ServerResponseStream.cs | 61 private WriteFlags GetWriteFlags() in GetWriteFlags() 64 return options != null ? options.Flags : default(WriteFlags); in GetWriteFlags()
|
D | NativeMethods.Generated.cs | 462 … BatchContextSafeHandle ctx, byte[] sendBuffer, UIntPtr sendBufferLen, WriteFlags writeFlags, Meta… in grpcsharp_call_start_unary_delegate() 464 … BatchContextSafeHandle ctx, byte[] sendBuffer, UIntPtr sendBufferLen, WriteFlags writeFlags, Meta… in grpcsharp_call_start_server_streaming_delegate() 466 … BatchContextSafeHandle ctx, byte[] sendBuffer, UIntPtr sendBufferLen, WriteFlags writeFlags, int … in grpcsharp_call_send_message_delegate() 468 …yInitialMetadata, byte[] optionalSendBuffer, UIntPtr optionalSendBufferLen, WriteFlags writeFlags); in grpcsharp_call_send_status_from_server_delegate() 617 … BatchContextSafeHandle ctx, byte[] sendBuffer, UIntPtr sendBufferLen, WriteFlags writeFlags, Meta… in grpcsharp_call_start_unary() 623 … BatchContextSafeHandle ctx, byte[] sendBuffer, UIntPtr sendBufferLen, WriteFlags writeFlags, Meta… in grpcsharp_call_start_server_streaming() 629 … BatchContextSafeHandle ctx, byte[] sendBuffer, UIntPtr sendBufferLen, WriteFlags writeFlags, int … in grpcsharp_call_send_message() 635 …yInitialMetadata, byte[] optionalSendBuffer, UIntPtr optionalSendBufferLen, WriteFlags writeFlags); in grpcsharp_call_send_status_from_server() 910 … BatchContextSafeHandle ctx, byte[] sendBuffer, UIntPtr sendBufferLen, WriteFlags writeFlags, Meta… in grpcsharp_call_start_unary() 916 … BatchContextSafeHandle ctx, byte[] sendBuffer, UIntPtr sendBufferLen, WriteFlags writeFlags, Meta… in grpcsharp_call_start_server_streaming() [all …]
|
D | AsyncCall.cs | 295 public Task SendMessageAsync(TRequest msg, WriteFlags writeFlags) in SendMessageAsync() 522 private WriteFlags GetWriteFlagsForCall() in GetWriteFlagsForCall() 525 return writeOptions != null ? writeOptions.Flags : default(WriteFlags); in GetWriteFlagsForCall()
|
/external/grpc-grpc/src/csharp/Grpc.Core.Tests/Internal/ |
D | FakeNativeCall.cs | 104 …public void StartUnary(IUnaryResponseClientCallback callback, byte[] payload, WriteFlags writeFlag… in StartUnary() 110 …public void StartUnary(BatchContextSafeHandle ctx, byte[] payload, WriteFlags writeFlags, Metadata… in StartUnary() 122 …verStreaming(IReceivedStatusOnClientCallback callback, byte[] payload, WriteFlags writeFlags, Meta… in StartServerStreaming() 149 …public void StartSendMessage(ISendCompletionCallback callback, byte[] payload, WriteFlags writeFla… in StartSendMessage() 160 byte[] optionalPayload, WriteFlags writeFlags) in StartSendStatusFromServer()
|
/external/libchrome/mojo/public/java/system/src/org/chromium/mojo/system/impl/ |
D | DataPipeProducerHandleImpl.java | 8 import org.chromium.mojo.system.DataPipe.WriteFlags; 43 public ResultAnd<Integer> writeData(ByteBuffer elements, WriteFlags flags) { in writeData() 51 public ByteBuffer beginWriteData(int numBytes, WriteFlags flags) { in beginWriteData()
|
D | MessagePipeHandleImpl.java | 44 public void writeMessage(ByteBuffer bytes, List<? extends Handle> handles, WriteFlags flags) { in writeMessage()
|
D | CoreImpl.java | 222 List<? extends Handle> handles, MessagePipeHandle.WriteFlags flags) { in writeMessage() 330 DataPipeProducerHandleImpl handle, ByteBuffer elements, DataPipe.WriteFlags flags) { in writeData() 339 DataPipeProducerHandleImpl handle, int numBytes, DataPipe.WriteFlags flags) { in beginWriteData()
|
/external/libchrome/mojo/public/java/system/javatests/src/org/chromium/mojo/ |
D | HandleMock.java | 123 public ResultAnd<Integer> writeData(ByteBuffer elements, DataPipe.WriteFlags flags) { in writeData() 132 public ByteBuffer beginWriteData(int numBytes, DataPipe.WriteFlags flags) { in beginWriteData() 150 public void writeMessage(ByteBuffer bytes, List<? extends Handle> handles, WriteFlags flags) { in writeMessage()
|
/external/pigweed/pw_log/ |
D | proto_utils.cc | 47 status = encoder.WriteFlags(flags); in EncodeLog() 78 status = encoder.WriteFlags(metadata.flags()); in CreateEncoderAndEncodeTokenizedLog()
|
/external/rust/crates/grpcio/src/call/ |
D | mod.rs | 642 pub struct WriteFlags { struct 646 impl WriteFlags { argument 651 pub fn buffer_hint(mut self, need_buffered: bool) -> WriteFlags { in buffer_hint() argument 661 pub fn force_no_compress(mut self, no_compress: bool) -> WriteFlags { in force_no_compress() argument 692 buf_flags: Option<WriteFlags>, 714 flags: WriteFlags, in start_send() argument
|
D | client.rs | 16 use super::{ShareCall, ShareCallHolder, SinkBase, WriteFlags}; 39 write_flags: WriteFlags, 76 pub fn write_flags(mut self, write_flags: WriteFlags) -> CallOption { in write_flags() 364 impl<Req> Sink<(Req, WriteFlags)> for StreamingCallSink<Req> { 373 fn start_send(mut self: Pin<&mut Self>, (msg, flags): (Req, WriteFlags)) -> Result<()> { in start_send()
|
/external/libchrome/mojo/public/java/system/javatests/src/org/chromium/mojo/system/impl/ |
D | CoreImplTest.java | 93 in.writeMessage(buffer, null, MessagePipeHandle.WriteFlags.NONE); in checkSendingMessage() 111 ResultAnd<Integer> result = in.writeData(buffer, DataPipe.WriteFlags.NONE); in checkSendingData() 254 MessagePipeHandle.WriteFlags.NONE); in testMessagePipeSendHandles() 320 ByteBuffer buffer = handles.first.beginWriteData(bytes.length, DataPipe.WriteFlags.NONE); in testDataPipeTwoPhaseSend() 352 ResultAnd<Integer> result = handles.first.writeData(buffer, DataPipe.WriteFlags.NONE); in testDataPipeDiscard() 435 MessagePipeHandle.WriteFlags.NONE); in testInvalidHandle()
|
D | WatcherImplTest.java | 129 ByteBuffer.allocateDirect(1), null, MessagePipeHandle.WriteFlags.NONE); in testCorrectResult() 245 ByteBuffer.allocateDirect(1), null, MessagePipeHandle.WriteFlags.NONE); in testCancel()
|
/external/grpc-grpc/templates/src/csharp/Grpc.Core/Internal/ |
D | NativeMethods.Generated.cs.template | 30 … BatchContextSafeHandle ctx, byte[] sendBuffer, UIntPtr sendBufferLen, WriteFlags writeFlags, Meta… 32 … BatchContextSafeHandle ctx, byte[] sendBuffer, UIntPtr sendBufferLen, WriteFlags writeFlags, Meta… 34 … BatchContextSafeHandle ctx, byte[] sendBuffer, UIntPtr sendBufferLen, WriteFlags writeFlags, int … 36 …InitialMetadata, byte[] optionalSendBuffer, UIntPtr optionalSendBufferLen, WriteFlags writeFlags)',
|
/external/libchrome/mojo/public/java/system/javatests/src/org/chromium/mojo/bindings/ |
D | RouterTest.java | 95 MessagePipeHandle.WriteFlags.NONE); in testSendingToRouterWithResponse() 120 MessagePipeHandle.WriteFlags.NONE); in sendMessageToRouter()
|
/external/grpc-grpc/src/csharp/Grpc.Microbenchmarks/ |
D | SendMessageBenchmark.cs | 61 var writeFlags = default(WriteFlags); in ThreadBody()
|