| /third_party/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()
81 responseStream.WriteOptions = null; 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()
94 call.RequestStream.WriteOptions = new WriteOptions(); in WriteOptions_DuplexStreaming()
97 call.RequestStream.WriteOptions = null; in WriteOptions_DuplexStreaming()
100 call.RequestStream.WriteOptions = new WriteOptions(WriteFlags.NoCompress); in WriteOptions_DuplexStreaming()
|
| D | CallOptionsTest.cs | 45 var writeOptions = new WriteOptions(); in WithMethods()
46 Assert.AreSame(writeOptions, options.WithWriteOptions(writeOptions).WriteOptions); in WithMethods()
62 Assert.IsNull(options.WriteOptions); in WithMethods()
|
| /third_party/grpc/src/csharp/Grpc.Core.Testing/ |
| D | TestServerCallContext.cs | 36 …Func<Metadata, Task> writeHeadersFunc, Func<WriteOptions> writeOptionsGetter, Action<WriteOptions>… in Create()
55 private readonly Func<WriteOptions> writeOptionsGetter;
56 private readonly Action<WriteOptions> writeOptionsSetter;
60 …Func<Metadata, Task> writeHeadersFunc, Func<WriteOptions> writeOptionsGetter, Action<WriteOptions>… in TestingServerCallContext()
92 …protected override WriteOptions WriteOptionsCore { get => writeOptionsGetter(); set => writeOption…
|
| /third_party/grpc/src/csharp/Grpc.Core.Api/ |
| D | WriteOptions.cs | 45 public class WriteOptions class
50 public static readonly WriteOptions Default = new WriteOptions();
58 public WriteOptions(WriteFlags flags = default(WriteFlags)) in WriteOptions() method in Grpc.Core.WriteOptions
|
| D | CallOptions.cs | 34 WriteOptions writeOptions;
49 …WriteOptions writeOptions = null, ContextPropagationToken propagationToken = null, CallCredentials… in CallOptions()
93 public WriteOptions WriteOptions property
173 public CallOptions WithWriteOptions(WriteOptions writeOptions) in WithWriteOptions()
|
| D | ServerCallContext.cs | 100 public WriteOptions WriteOptions property in Grpc.Core.ServerCallContext
146 protected abstract WriteOptions WriteOptionsCore { get; set; }
|
| D | IAsyncStreamWriter.cs | 45 WriteOptions WriteOptions { get; set; } property
|
| /third_party/grpc/src/csharp/Grpc.Core/Internal/ |
| D | ClientRequestStream.cs | 28 WriteOptions writeOptions;
33 this.writeOptions = call.Details.Options.WriteOptions; in ClientRequestStream()
46 public WriteOptions WriteOptions property in Grpc.Core.Internal.ClientRequestStream
|
| D | ServerResponseStream.cs | 31 WriteOptions writeOptions;
48 public WriteOptions WriteOptions property in Grpc.Core.Internal.ServerResponseStream
|
| D | DefaultServerCallContext.cs | 92 protected override WriteOptions WriteOptionsCore
94 get => serverResponseStream.WriteOptions;
95 set => serverResponseStream.WriteOptions = value;
|
| D | IServerResponseStream.cs | 36 WriteOptions WriteOptions { get; set; } property
|
| /third_party/grpc/include/grpcpp/impl/codegen/ |
| D | call_op_set.h | 79 class WriteOptions {
81 WriteOptions() : flags_(0), last_message_(false) {} in WriteOptions() function
92 inline WriteOptions& set_no_compression() { in set_no_compression()
100 inline WriteOptions& clear_no_compression() { in clear_no_compression()
117 inline WriteOptions& set_buffer_hint() { in set_buffer_hint()
126 inline WriteOptions& clear_buffer_hint() { in clear_buffer_hint()
139 inline WriteOptions& set_corked() { in set_corked()
144 inline WriteOptions& clear_corked() { in clear_corked()
156 inline WriteOptions& set_last_message() { in set_last_message()
163 inline WriteOptions& clear_last_message() { in clear_last_message()
[all …]
|
| D | server_callback_impl.h | 227 virtual void Write(const Response* msg, ::grpc::WriteOptions options) = 0;
228 virtual void WriteAndFinish(const Response* msg, ::grpc::WriteOptions options,
245 virtual void Write(const Response* msg, ::grpc::WriteOptions options) = 0;
246 virtual void WriteAndFinish(const Response* msg, ::grpc::WriteOptions options,
314 StartWrite(resp, ::grpc::WriteOptions()); in StartWrite()
323 void StartWrite(const Response* resp, ::grpc::WriteOptions options) { in StartWrite()
351 void StartWriteAndFinish(const Response* resp, ::grpc::WriteOptions options, in StartWriteAndFinish()
377 void StartWriteLast(const Response* resp, ::grpc::WriteOptions options) { in StartWriteLast()
480 ::grpc::WriteOptions write_options_wanted;
596 StartWrite(resp, ::grpc::WriteOptions()); in StartWrite()
[all …]
|
| D | server_callback.h | 227 virtual void Write(const Response* msg, ::grpc::WriteOptions options) = 0;
228 virtual void WriteAndFinish(const Response* msg, ::grpc::WriteOptions options,
245 virtual void Write(const Response* msg, ::grpc::WriteOptions options) = 0;
246 virtual void WriteAndFinish(const Response* msg, ::grpc::WriteOptions options,
314 StartWrite(resp, ::grpc::WriteOptions()); in StartWrite()
323 void StartWrite(const Response* resp, ::grpc::WriteOptions options) { in StartWrite()
351 void StartWriteAndFinish(const Response* resp, ::grpc::WriteOptions options, in StartWriteAndFinish()
377 void StartWriteLast(const Response* resp, ::grpc::WriteOptions options) { in StartWriteLast()
476 ::grpc::WriteOptions write_options_wanted;
591 StartWrite(resp, ::grpc::WriteOptions()); in StartWrite()
[all …]
|
| D | sync_stream.h | 115 virtual bool Write(const W& msg, ::grpc::WriteOptions options) = 0;
123 inline bool Write(const W& msg) { return Write(msg, ::grpc::WriteOptions()); } in Write()
139 void WriteLast(const W& msg, ::grpc::WriteOptions options) { in WriteLast()
320 bool Write(const W& msg, ::grpc::WriteOptions options) override { in Write()
493 bool Write(const W& msg, ::grpc::WriteOptions options) override { in Write()
660 bool Write(const W& msg, ::grpc::WriteOptions options) override { in Write()
740 bool Write(const W& msg, ::grpc::WriteOptions options) { in Write()
798 bool Write(const W& msg, ::grpc::WriteOptions options) override { in Write()
861 ::grpc::WriteOptions options) override { in Write()
927 ::grpc::WriteOptions options) override { in Write()
|
| D | sync_stream_impl.h | 115 virtual bool Write(const W& msg, ::grpc::WriteOptions options) = 0;
123 inline bool Write(const W& msg) { return Write(msg, ::grpc::WriteOptions()); } in Write()
139 void WriteLast(const W& msg, ::grpc::WriteOptions options) { in WriteLast()
321 bool Write(const W& msg, ::grpc::WriteOptions options) override { in Write()
494 bool Write(const W& msg, ::grpc::WriteOptions options) override { in Write()
661 bool Write(const W& msg, ::grpc::WriteOptions options) override { in Write()
742 bool Write(const W& msg, ::grpc::WriteOptions options) { in Write()
800 bool Write(const W& msg, ::grpc::WriteOptions options) override { in Write()
864 ::grpc::WriteOptions options) override { in Write()
931 ::grpc::WriteOptions options) override { in Write()
|
| D | async_stream.h | 136 virtual void Write(const W& msg, ::grpc::WriteOptions options, void* tag) = 0;
156 void WriteLast(const W& msg, ::grpc::WriteOptions options, void* tag) { in WriteLast()
389 void Write(const W& msg, ::grpc::WriteOptions options, void* tag) override { in Write()
566 void Write(const W& msg, ::grpc::WriteOptions options, void* tag) override { in Write()
837 virtual void WriteAndFinish(const W& msg, ::grpc::WriteOptions options,
877 void Write(const W& msg, ::grpc::WriteOptions options, void* tag) override { in Write()
899 void WriteAndFinish(const W& msg, ::grpc::WriteOptions options, in WriteAndFinish()
1000 virtual void WriteAndFinish(const W& msg, ::grpc::WriteOptions options,
1049 void Write(const W& msg, ::grpc::WriteOptions options, void* tag) override { in Write()
1070 void WriteAndFinish(const W& msg, ::grpc::WriteOptions options, in WriteAndFinish()
|
| D | async_stream_impl.h | 136 virtual void Write(const W& msg, ::grpc::WriteOptions options, void* tag) = 0;
156 void WriteLast(const W& msg, ::grpc::WriteOptions options, void* tag) { in WriteLast()
390 void Write(const W& msg, ::grpc::WriteOptions options, void* tag) override { in Write()
568 void Write(const W& msg, ::grpc::WriteOptions options, void* tag) override { in Write()
840 virtual void WriteAndFinish(const W& msg, ::grpc::WriteOptions options,
880 void Write(const W& msg, ::grpc::WriteOptions options, void* tag) override { in Write()
902 void WriteAndFinish(const W& msg, ::grpc::WriteOptions options, in WriteAndFinish()
1003 virtual void WriteAndFinish(const W& msg, ::grpc::WriteOptions options,
1052 void Write(const W& msg, ::grpc::WriteOptions options, void* tag) override { in Write()
1073 void WriteAndFinish(const W& msg, ::grpc::WriteOptions options, in WriteAndFinish()
|
| D | client_callback.h | 151 virtual void Write(const Request* req, ::grpc::WriteOptions options) = 0;
183 void Write(const Request* req) { Write(req, ::grpc::WriteOptions()); } in Write()
184 virtual void Write(const Request* req, ::grpc::WriteOptions options) = 0;
185 void WriteLast(const Request* req, ::grpc::WriteOptions options) { in WriteLast()
244 StartWrite(req, ::grpc::WriteOptions()); in StartWrite()
253 void StartWrite(const Request* req, ::grpc::WriteOptions options) { in StartWrite()
266 void StartWriteLast(const Request* req, ::grpc::WriteOptions options) { in StartWriteLast()
391 StartWrite(req, ::grpc::WriteOptions()); in StartWrite()
393 void StartWrite(const Request* req, ::grpc::WriteOptions options) { in StartWrite()
396 void StartWriteLast(const Request* req, ::grpc::WriteOptions options) { in StartWriteLast()
[all …]
|
| D | client_callback_impl.h | 146 virtual void Write(const Request* req, ::grpc::WriteOptions options) = 0;
178 void Write(const Request* req) { Write(req, ::grpc::WriteOptions()); } in Write()
179 virtual void Write(const Request* req, ::grpc::WriteOptions options) = 0;
180 void WriteLast(const Request* req, ::grpc::WriteOptions options) { in WriteLast()
239 StartWrite(req, ::grpc::WriteOptions()); in StartWrite()
248 void StartWrite(const Request* req, ::grpc::WriteOptions options) { in StartWrite()
261 void StartWriteLast(const Request* req, ::grpc::WriteOptions options) { in StartWriteLast()
386 StartWrite(req, ::grpc::WriteOptions()); in StartWrite()
388 void StartWrite(const Request* req, ::grpc::WriteOptions options) { in StartWrite()
391 void StartWriteLast(const Request* req, ::grpc::WriteOptions options) { in StartWriteLast()
[all …]
|
| /third_party/grpc/src/csharp/Grpc.HealthCheck.Tests/ |
| D | TestResponseStreamWriter.cs | 46 public WriteOptions WriteOptions { get; set; } property in Grpc.HealthCheck.Tests.TestResponseStreamWriter
|
| /third_party/cef/libcef/browser/extensions/value_store/ |
| D | cef_value_store.h | 45 WriteResult Set(WriteOptions options,
48 WriteResult Set(WriteOptions options,
|
| /third_party/grpc/src/csharp/Grpc.Core.Tests/Interceptors/ |
| D | ClientInterceptorTest.cs | 215 public WriteOptions WriteOptions property in Grpc.Core.Interceptors.Tests.ClientInterceptorTest.WrappedClientStreamWriter
219 return writer.WriteOptions;
223 writer.WriteOptions = value;
|
| /third_party/grpc/include/grpcpp/test/ |
| D | mock_stream.h | 58 MOCK_METHOD2_T(Write, bool(const W&, const WriteOptions));
78 MOCK_METHOD2_T(Write, bool(const W&, const WriteOptions));
|
| /third_party/grpc/doc/cpp/ |
| D | perf_notes.md | 10 possible to enable write batching by passing a WriteOptions argument to Write
14 stream_writer->Write(message, WriteOptions().set_buffer_hint());
|