/dports/net/openmpi/openmpi-4.1.1/test/datatype/ |
H A D | external32.c | 128 void* recv_data, in pack_unpack_datatype() argument 171 int32_t recv_data[2] = {-1, -1}; in main() local 183 printf("recv data %08x %08x \n", recv_data[0], recv_data[1]); in main() 185 if( (send_data[0] != recv_data[0]) || (send_data[1] != recv_data[1]) ) { in main() 193 int16_t recv_data[2] = {-1, -1}; in main() local 205 printf("recv data %08x %08x \n", recv_data[0], recv_data[1]); in main() 207 if( (send_data[0] != recv_data[0]) || (send_data[1] != recv_data[1]) ) { in main() 218 int recv_data[3] = {-1, -1, -1}; in main() local 237 printf("recv data %08x %08x %08x \n", recv_data[0], recv_data[1], recv_data[2]); in main() 240 if( (send_data[0] != recv_data[0]) || (send_data[2] != recv_data[2]) ) { in main() [all …]
|
/dports/net/openmpi3/openmpi-3.1.6/test/datatype/ |
H A D | external32.c | 112 void* recv_data, in pack_unpack_datatype() argument 138 recv_data, count, datatype); in pack_unpack_datatype() 154 int32_t recv_data[2] = {-1, -1}; in main() local 164 printf("recv data %08x %08x \n", recv_data[0], recv_data[1]); in main() 166 if( (send_data[0] != recv_data[0]) || (send_data[1] != recv_data[1]) ) { in main() 174 int16_t recv_data[2] = {-1, -1}; in main() local 184 printf("recv data %08x %08x \n", recv_data[0], recv_data[1]); in main() 186 if( (send_data[0] != recv_data[0]) || (send_data[1] != recv_data[1]) ) { in main() 197 int recv_data[3] = {-1, -1, -1}; in main() local 216 printf("recv data %08x %08x %08x \n", recv_data[0], recv_data[1], recv_data[2]); in main() [all …]
|
/dports/misc/thrill/thrill-12c5b59bca66df93b66628b3829027bd0f110dd9/thrill/net/ |
H A D | collective.hpp | 131 T recv_data; in PrefixSumHypercube() local 133 ReceiveFrom(peer, &recv_data); in PrefixSumHypercube() 143 value = sum_op(recv_data, value); in PrefixSumHypercube() 350 T recv_data; in Reduce() local 352 value = sum_op(value, recv_data); in Reduce() 431 T recv_data; in AllReduceHypercube() local 466 T recv_data; 469 return sum_op(recv_data, value); 473 return sum_op(value, recv_data); 509 T recv_data; in AllReduceEliminationProcess() local [all …]
|
/dports/net-im/toxic/toxic-0.11.3/src/ |
H A D | curl_util.c | 80 struct Recv_Curl_Data *recv_data = (struct Recv_Curl_Data *) user_pointer; in curl_cb_write_data() local 83 size_t total_size = length + recv_data->length; in curl_cb_write_data() 89 memcpy(recv_data->data + recv_data->length, data, length); in curl_cb_write_data() 90 recv_data->data[total_size] = '\0'; in curl_cb_write_data() 91 recv_data->length += length; in curl_cb_write_data()
|
H A D | bootstrap.c | 202 static int curl_fetch_nodes_JSON(struct Recv_Curl_Data *recv_data) in curl_fetch_nodes_JSON() argument 219 curl_easy_setopt(c_handle, CURLOPT_WRITEDATA, recv_data); in curl_fetch_nodes_JSON() 289 struct Recv_Curl_Data *recv_data = calloc(1, sizeof(struct Recv_Curl_Data)); in update_DHT_nodeslist() local 291 if (recv_data == NULL) { in update_DHT_nodeslist() 296 if (curl_fetch_nodes_JSON(recv_data) == -1) { in update_DHT_nodeslist() 297 free(recv_data); in update_DHT_nodeslist() 302 if (recv_data->length == 0) { in update_DHT_nodeslist() 303 free(recv_data); in update_DHT_nodeslist() 308 if (fwrite(recv_data->data, recv_data->length, 1, fp) != 1) { in update_DHT_nodeslist() 309 free(recv_data); in update_DHT_nodeslist() [all …]
|
H A D | name_lookup.c | 212 static int process_response(struct Recv_Curl_Data *recv_data) in process_response() argument 216 if (recv_data->length < TOX_ADDRESS_SIZE * 2 + prefix_size) { in process_response() 220 const char *IDstart = strstr(recv_data->data, ID_PREFIX); in process_response() 275 struct Recv_Curl_Data *recv_data = calloc(1, sizeof(struct Recv_Curl_Data)); in lookup_thread_func() local 277 if (recv_data == NULL) { in lookup_thread_func() 298 curl_easy_setopt(c_handle, CURLOPT_WRITEDATA, recv_data); in lookup_thread_func() 347 if (process_response(recv_data) == -1) { in lookup_thread_func() 357 free(recv_data); in lookup_thread_func()
|
/dports/sysutils/vector/vector-0.10.0/cargo-crates/krb5-src-0.2.4+1.18.2/krb5/src/appl/sample/sclient/ |
H A D | sclient.c | 96 krb5_data recv_data; in main() local 236 recv_data.length = ntohs(xmitlen); in main() 237 if (!(recv_data.data = (char *)malloc((size_t) recv_data.length + 1))) { in main() 242 if ((retval = net_read(sock, (char *)recv_data.data, in main() 243 recv_data.length)) <= 0) { in main() 249 recv_data.data[recv_data.length] = '\0'; in main() 251 recv_data.length,recv_data.data); in main() 252 free(recv_data.data); in main()
|
/dports/security/krb5/krb5-1.19.2/src/appl/sample/sclient/ |
H A D | sclient.c | 96 krb5_data recv_data; in main() local 236 recv_data.length = ntohs(xmitlen); in main() 237 if (!(recv_data.data = (char *)malloc((size_t) recv_data.length + 1))) { in main() 242 if ((retval = net_read(sock, (char *)recv_data.data, in main() 243 recv_data.length)) <= 0) { in main() 249 recv_data.data[recv_data.length] = '\0'; in main() 251 recv_data.length,recv_data.data); in main() 252 free(recv_data.data); in main()
|
/dports/net/mpich/mpich-3.4.3/modules/ucx/test/gtest/ucp/ |
H A D | test_ucp_wakeup.cc | 74 uint64_t recv_data = 0; in UCS_TEST_P() local 75 req = ucp_tag_recv_nb(receiver().worker(), &recv_data, sizeof(recv_data), in UCS_TEST_P() 109 EXPECT_EQ(send_data, recv_data); in UCS_TEST_P() 124 std::string send_data(COUNT, '2'), recv_data(COUNT, '1'); variable 129 rreq = ucp_tag_recv_nb(receiver().worker(), &recv_data[0], COUNT, DATATYPE, 148 EXPECT_EQ(send_data, recv_data); 231 uint64_t recv_data = 0; in UCS_TEST_P() local 232 req = ucp_tag_recv_nb(receiver().worker(), &recv_data, sizeof(recv_data), in UCS_TEST_P() 266 EXPECT_EQ(send_data, recv_data); in UCS_TEST_P()
|
H A D | test_ucp_tag_match.cc | 75 uint64_t recv_data = 0; in UCS_TEST_P() local 81 status = recv_b(&recv_data, sizeof(recv_data), DATATYPE, 0x1337, 0xffff, &info); in UCS_TEST_P() 94 uint64_t recv_data = 0; variable 96 my_recv_req = recv_nb(&recv_data, sizeof(recv_data), DATATYPE, 0x1337, 0xffff); 298 uint64_t recv_data = 0; in UCS_TEST_P() local 306 status = recv_b(&recv_data, sizeof(recv_data), DATATYPE, 0x1337, 0xffff, &info); in UCS_TEST_P() 330 uint64_t recv_data; in UCS_TEST_P() local 364 uint64_t recv_data = 0; in UCS_TEST_P() local 367 my_recv_req = recv_nb(&recv_data, sizeof(recv_data), DATATYPE, 0x1337, 0xffff); in UCS_TEST_P() 390 uint64_t recv_data = 0; in UCS_TEST_P() local [all …]
|
H A D | test_ucp_tag_mt.cc | 57 uint64_t recv_data[MT_TEST_NUM_THREADS] GTEST_ATTRIBUTE_UNUSED_; in UCS_TEST_P() local 62 recv_data[i] = 0; in UCS_TEST_P() 79 status = recv_b(&(recv_data[i]), sizeof(recv_data[i]), DATATYPE, 0x1337+i, in UCS_TEST_P() 85 EXPECT_EQ(send_data[i], recv_data[i]); in UCS_TEST_P()
|
H A D | test_ucp_tag_cancel.cc | 20 uint64_t recv_data = 0; in UCS_TEST_P() local 23 req = recv_nb(&recv_data, sizeof(recv_data), DATATYPE, 1, 1); in UCS_TEST_P() 34 EXPECT_EQ(0ul, recv_data); in UCS_TEST_P()
|
/dports/devel/hpx/hpx-1.2.1/plugins/parcelport/verbs/ |
H A D | parcelport_verbs.cpp | 572 parcel_recv_data &recv_data = *recv; in delete_recv_data() local 576 << hexuint32(recv_data.tag)); in delete_recv_data() 720 recv_data.message_region = nullptr; in handle_recv_completion() 730 recv_data.tag = h->tag(); in handle_recv_completion() 760 if (recv_data.rdma_count>0) { in handle_recv_completion() 802 recv_data.chunks[index] = in handle_recv_completion() 859 recv_data.chunks.push_back( in handle_recv_completion() 975 if (--recv_data.rdma_count > 0) { in handle_rdma_get_completion() 986 *tag_memory = recv_data.tag; in handle_rdma_get_completion() 996 false, true, recv_data.tag); in handle_rdma_get_completion() [all …]
|
/dports/net/seda/seda-release-20020712/seda/src/seda/sandStorm/test/bench/simple-p2p/ |
H A D | MessageReader.java | 54 byte recv_data[] = pkt.getBytes(); in parse() 57 …if (DEBUG) System.err.println("MessageReader: Got "+recv_data.length+" bytes, need "+(MSG_SIZE-cur… in parse() 59 while (recv_offset < recv_data.length) { in parse() 60 int toread = Math.min(MSG_SIZE - cur_offset, recv_data.length - recv_offset); in parse() 61 …if (DEBUG) System.err.println("MessageReader: recv_data.length "+recv_data.length+", recv_offset "… in parse() 62 System.arraycopy(recv_data, recv_offset, cur_data, cur_offset, toread); in parse()
|
/dports/devel/libqb/libqb-2.0.3/examples/ |
H A D | tcpserver.c | 45 char recv_data[1024]; in sock_read_fn() local 55 bytes_recieved = recv(fd, recv_data, 1024, 0); in sock_read_fn() 60 recv_data[bytes_recieved] = '\0'; in sock_read_fn() 62 if (strcmp(recv_data, "q") == 0 || strcmp(recv_data, "Q") == 0) { in sock_read_fn() 67 printf("Recieved: %s\n", recv_data); in sock_read_fn()
|
H A D | tcpclient.c | 42 char recv_data[1024]; in main() local 81 res = recv(sock, recv_data, 1024, 0); in main() 83 recv_data[res] = '\0'; in main() 84 printf("\nResponse: %s ", recv_data); in main()
|
/dports/net/norm/norm-1.5r6/protolib/src/sim/opnet/11.5/ |
H A D | opnetProtoSimProcess.ex.cpp | 235 recv_data(NULL), recv_data_len(0), udp_command_ici(NULL) in UdpSocketProxy() 332 if (recv_data) in RecvFrom() 338 memcpy(buffer, recv_data, numBytes); in RecvFrom() 339 op_prg_mem_free (recv_data); // LP 6-25-04 - added in RecvFrom() 341 recv_data = NULL; in RecvFrom() 407 recv_data(NULL), recv_data_len(0), tcp_command_ici(NULL) in TcpSocketProxy() 512 if (recv_data) in RecvFrom() 518 memcpy(buffer, recv_data, numBytes); in RecvFrom() 519 op_prg_mem_free (recv_data); in RecvFrom() 521 recv_data = NULL; in RecvFrom() [all …]
|
/dports/net/norm/norm-1.5r6/protolib/src/sim/opnet/12.0/ |
H A D | opnetProtoSimProcess.ex.cpp | 257 recv_data(NULL), recv_data_len(0), udp_command_ici(NULL) in UdpSocketProxy() 354 if (recv_data) in RecvFrom() 360 memcpy(buffer, recv_data, numBytes); in RecvFrom() 361 op_prg_mem_free (recv_data); // LP 6-25-04 - added in RecvFrom() 363 recv_data = NULL; in RecvFrom() 429 recv_data(NULL), recv_data_len(0), tcp_command_ici(NULL) in TcpSocketProxy() 555 if (recv_data) in Recv() 560 memcpy(buffer, recv_data+recv_data_read_index, numBytes); in Recv() 561 op_prg_mem_free (recv_data); in Recv() 562 recv_data = NULL; in Recv() [all …]
|
/dports/net/mpich/mpich-3.4.3/modules/ucx/contrib/ucx_perftest_config/ |
H A D | test_types_ucp | 15 ucp_contig_stream_bw -t stream_bw -r recv_data 16 ucp_contig_stream_lat -t stream_lat -r recv_data 26 ucp_contig_cuda_stream_bw -t stream_bw -r recv_data -m cuda 27 ucp_contig_cuda_stream_lat -t stream_lat -r recv_data -m cuda 32 ucp_contig_cuda_mng_stream_bw -t stream_bw -r recv_data -m cuda-managed 33 ucp_contig_cuda_mng_stream_lat -t stream_lat -r recv_data -m cuda-managed
|
/dports/comms/uhd/uhd-90ce6062b6b5df2eddeee723777be85108e4e7c7/fpga/usrp3/lib/rfnoc/blocks/rfnoc_block_axi_ram_fifo/ |
H A D | rfnoc_block_axi_ram_fifo_tb.sv | 592 chdr_word_t recv_data[$]; register 606 recv_data[i] == test_data[count], 630 chdr_word_t recv_data[$]; register 636 blk_ctrl.recv(port, recv_data, data_bytes); 643 recv_data[0][7:0] == test_data[0][7:0], 721 chdr_word_t recv_data[$]; register 802 chdr_word_t recv_data[$]; register 804 blk_ctrl.recv(port, recv_data, data_bytes); 811 recv_data[i] == test_data[count], 904 chdr_word_t recv_data[$]; register [all …]
|
/dports/comms/uhd/uhd-90ce6062b6b5df2eddeee723777be85108e4e7c7/host/tests/ |
H A D | transport_test.cpp | 110 auto recv_data = recv_xport->buff_to_data(recv_buff.get()); in BOOST_AUTO_TEST_CASE() local 111 UHD_ASSERT_THROW(recv_data.second == 16); in BOOST_AUTO_TEST_CASE() 112 data = recv_data.first; in BOOST_AUTO_TEST_CASE() 155 auto recv_data = recv_xport->buff_to_data(recv_buff.get()); in BOOST_AUTO_TEST_CASE() local 156 UHD_ASSERT_THROW(recv_data.second == 16); in BOOST_AUTO_TEST_CASE() 157 data = recv_data.first; in BOOST_AUTO_TEST_CASE()
|
/dports/sysutils/vector/vector-0.10.0/cargo-crates/krb5-src-0.2.4+1.18.2/krb5/src/appl/sample/sserver/ |
H A D | sserver.c | 83 krb5_data recv_data; in main() local 224 recv_data.length = strlen(repbuf); in main() 225 recv_data.data = repbuf; in main() 231 if ((retval = krb5_net_write(context, 0, (char *)recv_data.data, in main() 232 recv_data.length)) < 0) { in main()
|
/dports/security/krb5/krb5-1.19.2/src/appl/sample/sserver/ |
H A D | sserver.c | 83 krb5_data recv_data; in main() local 224 recv_data.length = strlen(repbuf); in main() 225 recv_data.data = repbuf; in main() 231 if ((retval = krb5_net_write(context, 0, (char *)recv_data.data, in main() 232 recv_data.length)) < 0) { in main()
|
/dports/science/hypre/hypre-2.23.0/src/multivector/ |
H A D | par_csr_pmvcomm.h | 25 void *recv_data; member 37 #define hypre_ParCSRCommMultiHandleRecvData(comm_handle) (comm_handle -> recv_data) 46 void *recv_data,
|
/dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/media/spi/ |
H A D | cxd2880-spi.c | 159 u8 recv_data[2]; in cxd2880_spi_read_ts_buffer_info() local 168 recv_data, sizeof(recv_data)); in cxd2880_spi_read_ts_buffer_info() 172 info->read_ready = (recv_data[0] & 0x80) ? 1 : 0; in cxd2880_spi_read_ts_buffer_info() 173 info->almost_full = (recv_data[0] & 0x40) ? 1 : 0; in cxd2880_spi_read_ts_buffer_info() 174 info->almost_empty = (recv_data[0] & 0x20) ? 1 : 0; in cxd2880_spi_read_ts_buffer_info() 175 info->overflow = (recv_data[0] & 0x10) ? 1 : 0; in cxd2880_spi_read_ts_buffer_info() 176 info->underflow = (recv_data[0] & 0x08) ? 1 : 0; in cxd2880_spi_read_ts_buffer_info() 177 info->pkt_num = ((recv_data[0] & 0x07) << 8) | recv_data[1]; in cxd2880_spi_read_ts_buffer_info()
|