Home
last modified time | relevance | path

Searched refs:send_buff (Results 1 – 25 of 50) sorted by relevance

12

/dports/science/qmcpack/qmcpack-3.11.0/external_codes/mpi_wrapper/mpi3/test/
H A Dcommunicator_all_to_all.cpp14 std::vector<int> send_buff ={ in main() local
21 assert( (int)send_buff.size() == world.size() ); in main()
27 world.all_to_all( send_buff.begin(), recv_buff.begin() ); in main()
36 for(std::size_t i = 0; i != send_buff.size(); ++i) in main()
37 world[i] << send_buff[i] >> recv_buff2[i]; in main()
42 auto const& csend_buff = send_buff; in main()
47 auto const& csend_buff = send_buff; in main()
52 world & send_buff; in main() local
53 assert( recv_buff == send_buff ); in main()
/dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/nfc/
H A Dvirtual_ncidev.c31 static struct sk_buff *send_buff; variable
43 kfree_skb(send_buff); in virtual_nci_close()
44 send_buff = NULL; in virtual_nci_close()
58 if (send_buff) { in virtual_nci_send()
62 send_buff = skb_copy(skb, GFP_KERNEL); in virtual_nci_send()
80 if (!send_buff) { in virtual_ncidev_read()
85 actual_len = min_t(size_t, count, send_buff->len); in virtual_ncidev_read()
92 skb_pull(send_buff, actual_len); in virtual_ncidev_read()
93 if (send_buff->len == 0) { in virtual_ncidev_read()
94 consume_skb(send_buff); in virtual_ncidev_read()
[all …]
/dports/multimedia/libv4l/linux-5.13-rc2/drivers/nfc/
H A Dvirtual_ncidev.c31 static struct sk_buff *send_buff; variable
43 kfree_skb(send_buff); in virtual_nci_close()
44 send_buff = NULL; in virtual_nci_close()
58 if (send_buff) { in virtual_nci_send()
62 send_buff = skb_copy(skb, GFP_KERNEL); in virtual_nci_send()
80 if (!send_buff) { in virtual_ncidev_read()
85 actual_len = min_t(size_t, count, send_buff->len); in virtual_ncidev_read()
92 skb_pull(send_buff, actual_len); in virtual_ncidev_read()
93 if (send_buff->len == 0) { in virtual_ncidev_read()
94 consume_skb(send_buff); in virtual_ncidev_read()
[all …]
/dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/nfc/
H A Dvirtual_ncidev.c31 static struct sk_buff *send_buff; variable
43 kfree_skb(send_buff); in virtual_nci_close()
44 send_buff = NULL; in virtual_nci_close()
58 if (send_buff) { in virtual_nci_send()
62 send_buff = skb_copy(skb, GFP_KERNEL); in virtual_nci_send()
80 if (!send_buff) { in virtual_ncidev_read()
85 actual_len = min_t(size_t, count, send_buff->len); in virtual_ncidev_read()
92 skb_pull(send_buff, actual_len); in virtual_ncidev_read()
93 if (send_buff->len == 0) { in virtual_ncidev_read()
94 consume_skb(send_buff); in virtual_ncidev_read()
[all …]
/dports/devel/radare2/radare2-5.1.1/shlr/gdb/src/
H A Dpacket.c198 g->send_buff[g->send_len] = '\0'; in send_packet()
218 if (!g->send_buff) { in pack()
221 g->send_buff[0] = '$'; in pack()
231 g->send_buff[g->send_len++] = '}'; in pack()
232 g->send_buff[g->send_len++] = *src++ ^ 0x20; in pack()
235 g->send_buff[g->send_len++] = *src++; in pack()
246 g->send_buff[g->send_len++] = *src++; in pack()
256 g->send_buff[g->send_len++] = '*'; in pack()
257 g->send_buff[g->send_len++] = run_len; in pack()
261 g->send_buff[g->send_len] = '\0'; in pack()
[all …]
H A Dlibgdbr.c20 g->send_buff = (char *) calloc (g->send_max, 1); in gdbr_init()
23 if (!g->send_buff) { in gdbr_init()
30 R_FREE (g->send_buff); in gdbr_init()
42 R_FREE (g->send_buff); in gdbr_init()
145 R_FREE (g->send_buff); in gdbr_cleanup()
/dports/comms/uhd/uhd-90ce6062b6b5df2eddeee723777be85108e4e7c7/host/tests/
H A Dtransport_test.cpp57 auto send_buff = send_xport->get_data_buff(0); in BOOST_AUTO_TEST_CASE() local
58 send_buff->set_packet_size(0); in BOOST_AUTO_TEST_CASE()
59 send_xport->release_data_buff(send_buff, 0); in BOOST_AUTO_TEST_CASE()
95 auto send_buff = send_xport->get_data_buff(0); in BOOST_AUTO_TEST_CASE() local
96 UHD_ASSERT_THROW(send_buff); in BOOST_AUTO_TEST_CASE()
97 auto buff_data = send_xport->buff_to_data(send_buff.get()); in BOOST_AUTO_TEST_CASE()
104 send_xport->release_data_buff(send_buff, 16); in BOOST_AUTO_TEST_CASE()
133 auto send_buff = send_xport->get_data_buff(0); in BOOST_AUTO_TEST_CASE() local
134 UHD_ASSERT_THROW(send_buff); in BOOST_AUTO_TEST_CASE()
135 auto buff_data = send_xport->buff_to_data(send_buff.get()); in BOOST_AUTO_TEST_CASE()
[all …]
/dports/science/dakota/dakota-6.13.0-release-public.src-UI/src/
H A DParallelLibrary.hpp829 void bcast_w(MPIPackBuffer& send_buff);
833 void bcast_e(MPIPackBuffer& send_buff);
835 void bcast_a(MPIPackBuffer& send_buff);
1412 MPI_Send((void*)send_buff.buf(), send_buff.size(), MPI_PACKED, 0, tag, in send()
1414 MPI_Send((void*)send_buff.buf(), send_buff.size(), MPI_PACKED, 0, tag, in send()
1417 err_code = MPI_Send((void*)send_buff.buf(), send_buff.size(), MPI_PACKED, in send()
1509 MPI_Isend((void*)send_buff.buf(), send_buff.size(), MPI_PACKED, 0, tag, in isend()
1511 MPI_Isend((void*)send_buff.buf(), send_buff.size(), MPI_PACKED, 0, tag, in isend()
1514 err_code = MPI_Isend((void*)send_buff.buf(), send_buff.size(), MPI_PACKED, in isend()
1792 { bcast(send_buff, pl.serverIntraComm); } in bcast()
[all …]
/dports/benchmarks/dbs/dbs-1.1.5/sample/
H A DTCP2.cmd9 send_buff = 32768;
21 send_buff = 32768;
41 send_buff = 32768;
53 send_buff = 32768;
H A DTCPvsMPEG.cmd9 send_buff = 32768;
21 send_buff = 32768;
41 send_buff = 32768;
/dports/net/openmpi3/openmpi-3.1.6/orte/test/mpi/
H A Dsendrecv_blaster.c26 unsigned char* send_buff; in main() local
140 send_buff = (unsigned char *) valloc(n_bytes); in main()
149 send_buff[i] = i%128; in main()
161 mpierr = MPI_Sendrecv(send_buff, count, MPI_CHAR, dest, tag0, in main()
174 mpierr = MPI_Sendrecv(send_buff, count, MPI_CHAR, rank, tag0, in main()
H A Dcrisscross.c33 unsigned char* send_buff; in main() local
58 send_buff = (unsigned char *) valloc(n_bytes); in main()
63 send_buff[i] = i%128; in main()
155 mpierr = MPI_Send(send_buff, n_bytes, MPI_BYTE, j, tag1, MPI_COMM_WORLD); in main()
/dports/net/openmpi/openmpi-4.1.1/orte/test/mpi/
H A Dsendrecv_blaster.c26 unsigned char* send_buff; in main() local
140 send_buff = (unsigned char *) valloc(n_bytes); in main()
149 send_buff[i] = i%128; in main()
161 mpierr = MPI_Sendrecv(send_buff, count, MPI_CHAR, dest, tag0, in main()
174 mpierr = MPI_Sendrecv(send_buff, count, MPI_CHAR, rank, tag0, in main()
H A Dcrisscross.c33 unsigned char* send_buff; in main() local
58 send_buff = (unsigned char *) valloc(n_bytes); in main()
63 send_buff[i] = i%128; in main()
155 mpierr = MPI_Send(send_buff, n_bytes, MPI_BYTE, j, tag1, MPI_COMM_WORLD); in main()
/dports/comms/uhd/uhd-90ce6062b6b5df2eddeee723777be85108e4e7c7/host/lib/rfnoc/
H A Dchdr_ctrl_endpoint.cpp90 auto send_buff = _xport->get_send_buff(timeout * 1000); in get_ctrlport_ep() local
91 _send_pkt->refresh(send_buff->data(), header, payload); in get_ctrlport_ep()
92 send_buff->set_packet_size(header.get_length()); in get_ctrlport_ep()
93 _xport->release_send_buff(std::move(send_buff)); in get_ctrlport_ep()
/dports/x11/polybar/polybar-3.5.7/lib/i3ipcpp/src/
H A Dipc-util.cpp163 auto send_buff = i3_pack(type, payload); in i3_msg() local
164 i3_send(sockfd, *send_buff); in i3_msg()
166 if (send_buff->header->type != recv_buff->header->type) { in i3_msg()
167 …throw invalid_header_error(auss_t() << "Invalid reply type: Expected 0x" << std::hex << send_buff-… in i3_msg()
/dports/science/hypre/hypre-2.23.0/src/parcsr_ls/
H A Dpar_stats.c76 HYPRE_Real *send_buff; in hypre_BoomerAMGSetupStats() local
630 send_buff[0] = - (HYPRE_Real) min_entries; in hypre_BoomerAMGSetupStats()
631 send_buff[1] = (HYPRE_Real) max_entries; in hypre_BoomerAMGSetupStats()
632 send_buff[2] = - min_rowsum; in hypre_BoomerAMGSetupStats()
633 send_buff[3] = max_rowsum; in hypre_BoomerAMGSetupStats()
906 send_buff[1] = (HYPRE_Real) max_entries; in hypre_BoomerAMGSetupStats()
907 send_buff[2] = - min_rowsum; in hypre_BoomerAMGSetupStats()
908 send_buff[3] = max_rowsum; in hypre_BoomerAMGSetupStats()
909 send_buff[4] = - min_weight; in hypre_BoomerAMGSetupStats()
910 send_buff[5] = max_weight; in hypre_BoomerAMGSetupStats()
[all …]
/dports/net-mgmt/nrpe3/nrpe-nrpe-3.2.1/src/
H A Dnrpe.c1735 send_buff = strdup(buffer);
1737 send_buff = calloc(1, sizeof(buffer));
1738 strcpy(send_buff, buffer);
1752 send_buff = strdup(buffer);
1755 strcpy(send_buff, buffer);
1779 result, send_buff);
1786 } else if (!strcmp(send_buff, "")) {
1809 pkt_size = strlen(send_buff);
1811 if (send_buff[strlen(send_buff) - 1] == '\n')
1812 send_buff[strlen(send_buff) - 1] = '\x0';
[all …]
/dports/science/hypre/hypre-2.23.0/src/parcsr_mv/
H A Dpar_csr_communication.c65 void *send_buff = NULL, *recv_buff = NULL; in hypre_ParCSRPersistentCommHandleCreate() local
72 …send_buff = hypre_TAlloc(HYPRE_Complex, hypre_ParCSRCommPkgSendMapStart(comm_pkg, num_sends), HYPR… in hypre_ParCSRPersistentCommHandleCreate()
87 hypre_MPI_Send_init( (HYPRE_Complex *)send_buff + vec_start, vec_len, HYPRE_MPI_COMPLEX, in hypre_ParCSRPersistentCommHandleCreate()
110 hypre_MPI_Send_init( (HYPRE_Complex *)send_buff + vec_start, vec_len, HYPRE_MPI_COMPLEX, in hypre_ParCSRPersistentCommHandleCreate()
118 …send_buff = hypre_TAlloc(HYPRE_Int, hypre_ParCSRCommPkgSendMapStart(comm_pkg, num_sends), HYPRE_ME… in hypre_ParCSRPersistentCommHandleCreate()
133 hypre_MPI_Send_init( (HYPRE_Int *)send_buff + vec_start, vec_len, HYPRE_MPI_INT, in hypre_ParCSRPersistentCommHandleCreate()
142 …send_buff = hypre_TAlloc(HYPRE_Int, hypre_ParCSRCommPkgRecvVecStart(comm_pkg, num_recvs), HYPRE_ME… in hypre_ParCSRPersistentCommHandleCreate()
156 hypre_MPI_Send_init( (HYPRE_Int *)send_buff + vec_start, vec_len, HYPRE_MPI_INT, in hypre_ParCSRPersistentCommHandleCreate()
179 …hypre_MPI_Send_init( (HYPRE_BigInt *)send_buff + (HYPRE_BigInt)vec_start, vec_len, HYPRE_MPI_BIG_I… in hypre_ParCSRPersistentCommHandleCreate()
203 …hypre_MPI_Send_init( (HYPRE_BigInt *)send_buff + (HYPRE_BigInt)vec_start, vec_len, HYPRE_MPI_BIG_I… in hypre_ParCSRPersistentCommHandleCreate()
[all …]
/dports/devel/radare2/radare2-5.1.1/shlr/qnx/src/
H A Dpacket.c155 p = g->send_buff; in qnxr_send_packet()
195 return r_socket_write (g->sock, g->send_buff, p - g->send_buff); in qnxr_send_packet()
/dports/comms/uhd/uhd-90ce6062b6b5df2eddeee723777be85108e4e7c7/host/lib/usrp/usrp2/
H A Dio_impl.cpp434 managed_send_buffer::sptr send_buff = xport->get_send_buff(); in program_stream_dest() local
435 std::memcpy(send_buff->cast<void*>(), &stream_ctrl, sizeof(stream_ctrl)); in program_stream_dest()
436 send_buff->commit(sizeof(stream_ctrl)); in program_stream_dest()
437 send_buff.reset(); in program_stream_dest()
454 managed_send_buffer::sptr send_buff = xport->get_send_buff(); in program_stream_dest() local
455 std::memcpy(send_buff->cast<void*>(), &stream_ctrl, sizeof(stream_ctrl)); in program_stream_dest()
456 send_buff->commit(sizeof(stream_ctrl) / 2); in program_stream_dest()
/dports/net/openmpi/openmpi-4.1.1/ompi/mca/coll/adapt/
H A Dcoll_adapt_ibcast.c148 char *send_buff = send_context->buff; in send_cb() local
155 (send_buff, send_count, send_context->con->datatype, send_context->peer, in send_cb()
271 char *send_buff = send_context->buff; in recv_cb() local
279 (send_buff, send_count, send_context->con->datatype, in recv_cb()
491 char *send_buff = context->buff; in ompi_coll_adapt_ibcast_generic() local
495 (void *) send_buff, send_count, con->ibcast_tag - i)); in ompi_coll_adapt_ibcast_generic()
498 (send_buff, send_count, datatype, context->peer, in ompi_coll_adapt_ibcast_generic()
/dports/science/cantera/cantera-2.5.1-611-gc4d6ecc15/ext/sundials/examples/ida/parallel/
H A DidaHeat2D_kry_p.c74 realtype *send_buff; member
445 realtype *send_buffer = data->send_buff; in rescomm()
737 data->send_buff = NULL; in InitUserData()
767 data->send_buff = (realtype*) malloc(2*(data->mxsub + data->mysub)*sizeof(realtype)); in AllocUserData()
768 if(data->send_buff == NULL) { in AllocUserData()
779 free(data->send_buff); in AllocUserData()
794 if (data->send_buff != NULL) in DeleteUserData()
795 free(data->send_buff); in DeleteUserData()
/dports/math/sundials/sundials-5.7.0/examples/ida/parallel/
H A DidaHeat2D_kry_p.c74 realtype *send_buff; member
445 realtype *send_buffer = data->send_buff; in rescomm()
737 data->send_buff = NULL; in InitUserData()
767 data->send_buff = (realtype*) malloc(2*(data->mxsub + data->mysub)*sizeof(realtype)); in AllocUserData()
768 if(data->send_buff == NULL) { in AllocUserData()
779 free(data->send_buff); in AllocUserData()
794 if (data->send_buff != NULL) in DeleteUserData()
795 free(data->send_buff); in DeleteUserData()
/dports/devel/py-wsgitools/wsgitools-0.3.1/wsgitools/scgi/
H A Dasynchronous.py158 def send_buff(self): member in SCGIConnection
179 self.send_buff()
182 self.send_buff()

12