Home
last modified time | relevance | path

Searched defs:send_bytes (Results 1 – 11 of 11) sorted by relevance

/third_party/mindspore/mindspore-src/source/mindspore/ccsrc/distributed/rpc/rdma/
Drdma_client.cc81 bool RDMAClient::SendSync(std::unique_ptr<MessageBase> &&msg, size_t *const send_bytes) { in SendSync()
/third_party/mindspore/mindspore-src/source/mindspore/ccsrc/distributed/rpc/tcp/
Dtcp_client.cc116 bool TCPClient::SendSync(std::unique_ptr<MessageBase> &&msg, size_t *const send_bytes) { in SendSync()
Dtcp_socket_operation.cc148 size_t send_bytes = static_cast<size_t>(retval); in SendMessage() local
Dssl_socket_operation.cc140 size_t send_bytes = static_cast<size_t>(retval); in SendMessage() local
Dtcp_comm.cc341 bool TCPComm::Send(MessageBase *msg, size_t *const send_bytes, bool sync) { in Send()
/third_party/libuv/test/
Dtest-poll.c309 int send_bytes = MIN(TRANSFER_BYTES - context->sent, sizeof buffer); local
333 int send_bytes = MIN(TRANSFER_BYTES - context->sent, sizeof buffer); local
/third_party/grpc/src/core/ext/transport/chttp2/transport/
Dwriting.cc185 static bool update_list(grpc_chttp2_transport* t, int64_t send_bytes, in update_list()
399 uint32_t send_bytes = in FlushBytes() local
/third_party/python/Lib/multiprocessing/
Dqueues.py212 def _feed(buffer, notempty, send_bytes, writelock, reader_close, argument
Dconnection.py181 def send_bytes(self, buf, offset=0, size=None): member in _ConnectionBase
/third_party/libwebsockets/lib/tls/mbedtls/wrapper/library/
Dssl_lib.c493 int send_bytes, bytes; in SSL_write() local
/third_party/python/Lib/test/
D_test_multiprocessing.py4649 def send_bytes(self, data): member in OtherTest.test_deliver_challenge_auth_failure._FakeConnection
4666 def send_bytes(self, data): member in OtherTest.test_answer_challenge_auth_failure._FakeConnection