Home
last modified time | relevance | path

Searched refs:recv_data (Results 1 – 25 of 506) sorted by relevance

12345678910>>...21

/dports/net/openmpi/openmpi-4.1.1/test/datatype/
H A Dexternal32.c128 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 Dexternal32.c112 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 Dcollective.hpp131 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 Dcurl_util.c80 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 Dbootstrap.c202 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 Dname_lookup.c212 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 Dsclient.c96 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 Dsclient.c96 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 Dtest_ucp_wakeup.cc74 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 Dtest_ucp_tag_match.cc75 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 Dtest_ucp_tag_mt.cc57 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 Dtest_ucp_tag_cancel.cc20 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 Dparcelport_verbs.cpp572 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 DMessageReader.java54 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 Dtcpserver.c45 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 Dtcpclient.c42 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 DopnetProtoSimProcess.ex.cpp235 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 DopnetProtoSimProcess.ex.cpp257 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 Dtest_types_ucp15 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 Drfnoc_block_axi_ram_fifo_tb.sv592 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 Dtransport_test.cpp110 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 Dsserver.c83 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 Dsserver.c83 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 Dpar_csr_pmvcomm.h25 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 Dcxd2880-spi.c159 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()

12345678910>>...21