| /third_party/ffmpeg/tools/ |
| D | zmqsend.c | 55 char *src_buf, *recv_buf; in main() local
150 recv_buf = av_malloc(recv_buf_size); in main()
151 if (!recv_buf) { in main()
158 memcpy(recv_buf, zmq_msg_data(&msg), recv_buf_size - 1); in main()
159 recv_buf[recv_buf_size-1] = 0; in main()
160 printf("%s\n", recv_buf); in main()
162 av_free(recv_buf); in main()
|
| /third_party/pulseaudio/src/modules/rtp/ |
| D | rtp-native.c | 56 uint8_t *recv_buf; member
78 c->recv_buf = NULL; in pa_rtp_context_new_send()
186 c->recv_buf = pa_xmalloc(c->recv_buf_size); in pa_rtp_context_new_recv()
246 c->recv_buf = pa_xrealloc(c->recv_buf, c->recv_buf_size); in pa_rtp_recv()
251 iov.iov_base = c->recv_buf; in pa_rtp_recv()
340 memcpy(pa_memblock_acquire_chunk(&c->memchunk), c->recv_buf + metadata_length, audio_length); in pa_rtp_recv()
384 pa_xfree(c->recv_buf); in pa_rtp_context_free()
|
| /third_party/boost/libs/asio/example/cpp03/tutorial/daytime4/ |
| D | client.cpp | 39 boost::array<char, 128> recv_buf; in main() local
42 boost::asio::buffer(recv_buf), sender_endpoint); in main()
44 std::cout.write(recv_buf.data(), len); in main()
|
| /third_party/boost/doc/html/boost_asio/example/cpp11/futures/ |
| D | daytime_client.cpp | 47 std::array<char, 128> recv_buf; in get_daytime() local
51 boost::asio::buffer(recv_buf), in get_daytime()
58 recv_buf.data(), in get_daytime()
|
| /third_party/boost/libs/asio/example/cpp11/futures/ |
| D | daytime_client.cpp | 47 std::array<char, 128> recv_buf; in get_daytime() local
51 boost::asio::buffer(recv_buf), in get_daytime()
58 recv_buf.data(), in get_daytime()
|
| /third_party/mindspore/mindspore/ccsrc/runtime/hccl_adapter/ |
| D | hccl_adapter.h | 68 …HcclResult HcclAllReduce(void *send_buf, void *recv_buf, uint64_t count, HcclDataType dataType, Hc…
70 …HcclResult HcclAllGather(void *send_buf, void *recv_buf, uint64_t count, HcclDataType dataType, ac…
72 …HcclResult HcclReduceScatter(void *send_buf, void *recv_buf, uint64_t count, HcclDataType dataType…
76 …HcclResult HcclRecv(void *recv_buf, uint64_t count, HcclDataType dataType, uint32_t srcRank, aclrt…
|
| D | hccl_adapter.cc | 279 HcclResult HcclAdapter::HcclAllReduce(void *send_buf, void *recv_buf, uint64_t count, HcclDataType … in HcclAllReduce() argument
284 return launch_hccl_all_reduce_(send_buf, recv_buf, count, dataType, op, hccl_comm, stream); in HcclAllReduce()
287 HcclResult HcclAdapter::HcclReduceScatter(void *send_buf, void *recv_buf, uint64_t count, HcclDataT… in HcclReduceScatter() argument
292 return launch_hccl_reduce_scatter_(send_buf, recv_buf, count, dataType, op, hccl_comm, stream); in HcclReduceScatter()
295 HcclResult HcclAdapter::HcclAllGather(void *send_buf, void *recv_buf, uint64_t count, HcclDataType … in HcclAllGather() argument
300 return launch_hccl_all_gather_(send_buf, recv_buf, count, dataType, hccl_comm, stream); in HcclAllGather()
311 HcclResult HcclAdapter::HcclRecv(void *recv_buf, uint64_t count, HcclDataType dataType, uint32_t sr… in HcclRecv() argument
316 return launch_hccl_recv_(recv_buf, count, dataType, srcRank, hccl_comm, stream); in HcclRecv()
|
| /third_party/boost/libs/asio/example/cpp03/tutorial/daytime5/ |
| D | server.cpp | 36 boost::array<char, 1> recv_buf; in main() local
38 socket.receive_from(boost::asio::buffer(recv_buf), remote_endpoint); in main()
|
| /third_party/ffmpeg/libavfilter/ |
| D | f_zmq.c | 157 char *recv_buf, *send_buf; in filter_frame() local
163 if (recv_msg(ctx, &recv_buf, &recv_buf_size) < 0) in filter_frame()
168 if (parse_command(&cmd, recv_buf, ctx) < 0) { in filter_frame()
196 av_freep(&recv_buf); in filter_frame()
|
| /third_party/ltp/testcases/kernel/syscalls/recvmsg/ |
| D | recvmsg03.c | 92 static char recv_buf[128]; in server() local
111 msg.msg_iov->iov_base = recv_buf; in server()
|
| /third_party/openssl/test/ |
| D | bad_dtls_test.c | 544 uint64_t recv_buf[2]; in test_bad_dtls() local
556 ret = SSL_read(con, recv_buf, 2 * sizeof(uint64_t)); in test_bad_dtls()
562 if (!TEST_true(recv_buf[0] == tests[i].seq)) in test_bad_dtls()
|
| /third_party/curl/lib/ |
| D | smb.h | 42 char *recv_buf; member
|
| D | smb.c | 268 smbc->recv_buf = malloc(MAX_MESSAGE_SIZE); in smb_connect()
269 if(!smbc->recv_buf) in smb_connect()
301 char *buf = smbc->recv_buf; in smb_recv_message()
949 Curl_safefree(smbc->recv_buf); in smb_disconnect()
|
| /third_party/grpc/test/cpp/end2end/ |
| D | client_callback_end2end_test.cc | 251 ByteBuffer recv_buf; in SendRpcsGeneric() local
262 &cli_ctx, kMethodName, send_buf.get(), &recv_buf, in SendRpcsGeneric()
263 [&request, &recv_buf, &done, &mu, &cv, maybe_except](Status s) { in SendRpcsGeneric()
267 EXPECT_TRUE(ParseFromByteBuffer(&recv_buf, &response)); in SendRpcsGeneric()
|
| /third_party/boost/libs/asio/doc/ |
| D | tutorial.qbk | 1557 ``''''''`` boost::array<char, 128> recv_buf;
1560 ``''''''`` boost::asio::buffer(recv_buf), sender_endpoint);
1562 ``''''''`` std::cout.write(recv_buf.data(), len);
1629 ``''''''`` boost::array<char, 128> recv_buf;
1632 ``''''''`` boost::asio::buffer(recv_buf), sender_endpoint);
1634 ``''''''`` std::cout.write(recv_buf.data(), len);
1677 ``''''''`` boost::array<char, 1> recv_buf;
1679 ``''''''`` socket.receive_from(boost::asio::buffer(recv_buf), remote_endpoint);
1764 ``''''''`` boost::array<char, 1> recv_buf;
1766 ``''''''`` socket.receive_from(boost::asio::buffer(recv_buf), remote_endpoint);
|