Home
last modified time | relevance | path

Searched refs:SendMessageAsync (Results 1 – 10 of 10) sorted by relevance

/third_party/grpc/src/csharp/Grpc.Core/Internal/
DClientRequestStream.cs38 return call.SendMessageAsync(message, GetWriteFlags()); in WriteAsync()
DServerResponseStream.cs40 return call.SendMessageAsync(message, GetWriteFlags()); in WriteAsync()
DAsyncCallServer.cs81 public Task SendMessageAsync(TResponse msg, WriteFlags writeFlags) in SendMessageAsync() method in Grpc.Core.Internal.AsyncCallServer
DAsyncCall.cs299 public Task SendMessageAsync(TRequest msg, WriteFlags writeFlags) in SendMessageAsync() method in Grpc.Core.Internal.AsyncCall
/third_party/mindspore/mindspore/ccsrc/ps/core/
Dnode.h83 …uint64_t SendMessageAsync(const std::shared_ptr<TcpClient> &client, const std::shared_ptr<MessageM…
Dnode.cc57 uint64_t Node::SendMessageAsync(const std::shared_ptr<TcpClient> &client, const std::shared_ptr<Mes… in SendMessageAsync() function in mindspore::ps::core::Node
Dabstract_node.h184 …uint64_t SendMessageAsync(const std::shared_ptr<TcpClient> &client, const std::shared_ptr<MessageM…
Dabstract_node.cc350 return SendMessageAsync(client, message_meta, Protos::RAW, data, size); in CollectiveSendAsync()
905 uint64_t AbstractNode::SendMessageAsync(const std::shared_ptr<TcpClient> &client, in SendMessageAsync() function in mindspore::ps::core::AbstractNode
Dscheduler_node.cc355 …if (!SendMessageAsync(client, message_meta, Protos::PROTOBUF, send_metadata_message.SerializeAsStr… in SendMetadata()
/third_party/grpc/src/csharp/Grpc.Core.Tests/Internal/
DAsyncCallTest.cs73 () => asyncCall.SendMessageAsync("abc", new WriteFlags())); in AsyncUnary_StreamingOperationsNotAllowed()
384 () => asyncCall.SendMessageAsync("abc", new WriteFlags())); in ServerStreaming_StreamingSendNotAllowed()