| /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()
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()
|
| /external/grpc-grpc/src/csharp/Grpc.Core.Testing/ |
| D | TestServerCallContext.cs | 37 …Func<Metadata, Task> writeHeadersFunc, Func<WriteOptions> writeOptionsGetter, Action<WriteOptions>… in Create()
46 Func<WriteOptions> writeOptionsGetter;
47 Action<WriteOptions> writeOptionsSetter;
49 …public WriteOptionsHolder(Func<WriteOptions> writeOptionsGetter, Action<WriteOptions> writeOptions… in WriteOptionsHolder()
55 …public WriteOptions WriteOptions { get => writeOptionsGetter(); set => writeOptionsSetter(value); } property in Grpc.Core.Testing.TestServerCallContext.WriteOptionsHolder
|
| /external/grpc-grpc/include/grpcpp/impl/codegen/ |
| D | call.h | 81 class WriteOptions {
83 WriteOptions() : flags_(0), last_message_(false) {} in WriteOptions() function
84 WriteOptions(const WriteOptions& other) in WriteOptions() function
96 inline WriteOptions& set_no_compression() { in set_no_compression()
104 inline WriteOptions& clear_no_compression() { in clear_no_compression()
121 inline WriteOptions& set_buffer_hint() { in set_buffer_hint()
130 inline WriteOptions& clear_buffer_hint() { in clear_buffer_hint()
143 inline WriteOptions& set_corked() { in set_corked()
148 inline WriteOptions& clear_corked() { in clear_corked()
160 inline WriteOptions& set_last_message() { in set_last_message()
[all …]
|
| D | sync_stream.h | 116 virtual bool Write(const W& msg, WriteOptions options) = 0;
124 inline bool Write(const W& msg) { return Write(msg, WriteOptions()); } in Write()
140 void WriteLast(const W& msg, WriteOptions options) { in WriteLast()
319 bool Write(const W& msg, WriteOptions options) override { in Write()
490 bool Write(const W& msg, WriteOptions options) override { in Write()
654 bool Write(const W& msg, WriteOptions options) override { in Write()
733 bool Write(const W& msg, WriteOptions options) { in Write()
791 bool Write(const W& msg, WriteOptions options) override { in Write()
853 bool Write(const ResponseType& response, WriteOptions options) override { in Write()
918 bool Write(const ResponseType& response, WriteOptions options) override { in Write()
|
| D | async_stream.h | 139 virtual void Write(const W& msg, WriteOptions options, void* tag) = 0;
159 void WriteLast(const W& msg, WriteOptions options, void* tag) { in WriteLast()
392 void Write(const W& msg, WriteOptions options, void* tag) override { in Write()
569 void Write(const W& msg, WriteOptions options, void* tag) override { in Write()
839 virtual void WriteAndFinish(const W& msg, WriteOptions options,
879 void Write(const W& msg, WriteOptions options, void* tag) override { in Write()
901 void WriteAndFinish(const W& msg, WriteOptions options, const Status& status, in WriteAndFinish()
1002 virtual void WriteAndFinish(const W& msg, WriteOptions options,
1051 void Write(const W& msg, WriteOptions options, void* tag) override { in Write()
1072 void WriteAndFinish(const W& msg, WriteOptions options, const Status& status, in WriteAndFinish()
|
| /external/grpc-grpc/src/csharp/Grpc.Core/ |
| 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 | ServerCallContext.cs | 186 public WriteOptions WriteOptions property in Grpc.Core.ServerCallContext
190 return writeOptionsHolder.WriteOptions;
195 writeOptionsHolder.WriteOptions = value;
232 WriteOptions WriteOptions { get; set; } property
|
| D | CallOptions.cs | 35 WriteOptions writeOptions;
50 …WriteOptions writeOptions = null, ContextPropagationToken propagationToken = null, CallCredentials… in CallOptions()
94 public WriteOptions WriteOptions property
174 public CallOptions WithWriteOptions(WriteOptions writeOptions) in WithWriteOptions()
|
| D | IAsyncStreamWriter.cs | 45 WriteOptions WriteOptions { get; set; } property
|
| /external/tensorflow/tensorflow/lite/toco/tflite/ |
| D | operator.cc | 44 flatbuffers::Offset<TfLiteOptions> WriteOptions( in WriteOptions() function in toco::tflite::AveragePool
82 flatbuffers::Offset<TfLiteOptions> WriteOptions( in WriteOptions() function in toco::tflite::Convolution
136 flatbuffers::Offset<TfLiteOptions> WriteOptions( in WriteOptions() function in toco::tflite::DepthwiseConvolution
188 flatbuffers::Offset<TfLiteOptions> WriteOptions( in WriteOptions() function in toco::tflite::Add
218 flatbuffers::Offset<TfLiteOptions> WriteOptions( in WriteOptions() function in toco::tflite::AddN
239 flatbuffers::Offset<TfLiteOptions> WriteOptions( in WriteOptions() function in toco::tflite::SpaceToBatchND
264 flatbuffers::Offset<TfLiteOptions> WriteOptions( in WriteOptions() function in toco::tflite::Sub
294 flatbuffers::Offset<TfLiteOptions> WriteOptions( in WriteOptions() function in toco::tflite::Div
320 flatbuffers::Offset<TfLiteOptions> WriteOptions( in WriteOptions() function in toco::tflite::BatchToSpaceND
344 flatbuffers::Offset<TfLiteOptions> WriteOptions( in WriteOptions() function in toco::tflite::Cast
[all …]
|
| D | custom_operator.h | 40 virtual void WriteOptions(const TocoOperator& op, in WriteOptions() function
51 [&]() { WriteOptions(static_cast<const TocoOperator&>(op), &fbb); }); in Serialize()
|
| D | builtin_operator.h | 43 virtual flatbuffers::Offset<TfLiteOptions> WriteOptions(
54 auto options = WriteOptions(static_cast<const TocoOperator&>(op), builder); in Serialize()
|
| /external/grpc-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 | ServerCallHandler.cs | 73 …TRequest, TResponse>.ResponseWithFlags(response, HandlerUtils.GetWriteFlags(context.WriteOptions)); in HandleCall()
198 …TRequest, TResponse>.ResponseWithFlags(response, HandlerUtils.GetWriteFlags(context.WriteOptions)); in HandleCall()
343 public static WriteFlags GetWriteFlags(WriteOptions writeOptions) in GetWriteFlags()
|
| /external/grpc-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;
|
| /external/grpc-grpc/include/grpcpp/test/ |
| D | mock_stream.h | 58 MOCK_METHOD2_T(Write, bool(const W&, const WriteOptions));
77 MOCK_METHOD2_T(Write, bool(const W&, const WriteOptions));
|
| /external/grpc-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());
|
| /external/grpc-grpc/test/cpp/microbenchmarks/ |
| D | fullstack_streaming_ping_pong.h | 287 request_rw->WriteLast(send_request, WriteOptions(), tag(2)); in BM_StreamingPingPongWithCoalescingApi()
326 response_rw.WriteAndFinish(send_response, WriteOptions(), in BM_StreamingPingPongWithCoalescingApi()
330 response_rw.WriteLast(send_response, WriteOptions(), tag(5)); in BM_StreamingPingPongWithCoalescingApi()
|
| /external/grpc-grpc/src/csharp/Grpc.Examples.Tests/ |
| D | MathServiceImplTestabilityTest.cs | 41 ….0.0.1", null, null, (metadata) => TaskUtils.CompletedTask, () => new WriteOptions(), (writeOption… in ServerCallImplIsTestable()
|
| /external/grpc-grpc/test/cpp/end2end/ |
| D | test_service_impl.cc | 256 writer->WriteLast(response, WriteOptions()); in ResponseStream()
315 stream->WriteLast(response, WriteOptions()); in BidiStream()
|
| D | async_end2end_test.cc | 577 cli_stream->WriteLast(send_request, WriteOptions(), tag(5)); in TEST_P()
667 srv_stream.WriteAndFinish(send_response, WriteOptions(), Status::OK, tag(5)); in TEST_P()
710 srv_stream.WriteLast(send_response, WriteOptions(), tag(5)); in TEST_P()
790 cli_stream->WriteLast(send_request, WriteOptions(), tag(3)); in TEST_P()
805 srv_stream.WriteAndFinish(send_response, WriteOptions(), Status::OK, tag(6)); in TEST_P()
837 cli_stream->WriteLast(send_request, WriteOptions(), tag(3)); in TEST_P()
852 srv_stream.WriteLast(send_response, WriteOptions(), tag(6)); in TEST_P()
|
| D | end2end_test.cc | 757 stream->WriteLast(request, WriteOptions()); in TEST_P()
787 EXPECT_TRUE(stream->Write(request, WriteOptions().set_write_through())); in TEST_P()
788 EXPECT_TRUE(stream->Write(request, WriteOptions().set_write_through())); in TEST_P()
805 stream->WriteLast(request, WriteOptions()); in TEST_P()
917 stream->WriteLast(request, WriteOptions()); in TEST_P()
942 stream->WriteLast(request, WriteOptions()); in TEST_P()
|
| /external/grpc-grpc/test/cpp/interop/ |
| D | interop_server.cc | 57 using grpc::WriteOptions;
205 WriteOptions wopts; in StreamingOutputCall()
|