Searched refs:SendMessageAsync (Results 1 – 10 of 10) sorted by relevance
/third_party/grpc/src/csharp/Grpc.Core/Internal/ |
D | ClientRequestStream.cs | 38 return call.SendMessageAsync(message, GetWriteFlags()); in WriteAsync()
|
D | ServerResponseStream.cs | 40 return call.SendMessageAsync(message, GetWriteFlags()); in WriteAsync()
|
D | AsyncCallServer.cs | 81 public Task SendMessageAsync(TResponse msg, WriteFlags writeFlags) in SendMessageAsync() method in Grpc.Core.Internal.AsyncCallServer
|
D | AsyncCall.cs | 299 public Task SendMessageAsync(TRequest msg, WriteFlags writeFlags) in SendMessageAsync() method in Grpc.Core.Internal.AsyncCall
|
/third_party/mindspore/mindspore/ccsrc/ps/core/ |
D | node.h | 83 …uint64_t SendMessageAsync(const std::shared_ptr<TcpClient> &client, const std::shared_ptr<MessageM…
|
D | node.cc | 57 uint64_t Node::SendMessageAsync(const std::shared_ptr<TcpClient> &client, const std::shared_ptr<Mes… in SendMessageAsync() function in mindspore::ps::core::Node
|
D | abstract_node.h | 184 …uint64_t SendMessageAsync(const std::shared_ptr<TcpClient> &client, const std::shared_ptr<MessageM…
|
D | abstract_node.cc | 350 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
|
D | scheduler_node.cc | 355 …if (!SendMessageAsync(client, message_meta, Protos::PROTOBUF, send_metadata_message.SerializeAsStr… in SendMetadata()
|
/third_party/grpc/src/csharp/Grpc.Core.Tests/Internal/ |
D | AsyncCallTest.cs | 73 () => asyncCall.SendMessageAsync("abc", new WriteFlags())); in AsyncUnary_StreamingOperationsNotAllowed() 384 () => asyncCall.SendMessageAsync("abc", new WriteFlags())); in ServerStreaming_StreamingSendNotAllowed()
|