Home
last modified time | relevance | path

Searched refs:num_recv (Results 1 – 25 of 30) sorted by relevance

12

/dports/science/chrono/chrono-7.0.1/src/chrono_distributed/comm/
H A DChCommDistributed.h134 void ProcessExchanges(int num_recv, BodyExchange* buf, int updown);
137 void ProcessUpdates(int num_recv, BodyUpdate* buf);
140 void ProcessTakes(int num_recv, uint* buf);
143 void ProcessShapes(int num_recv, Shape* buf);
H A DChCommDistributed.cpp90 void ChCommDistributed::ProcessExchanges(int num_recv, BodyExchange* buf, int updown) { in ProcessExchanges() argument
98 for (int n = 0; n < num_recv; n++) { in ProcessExchanges()
135 void ChCommDistributed::ProcessUpdates(int num_recv, BodyUpdate* buf) { in ProcessUpdates() argument
141 for (int n = 0; n < num_recv; n++) { in ProcessUpdates()
168 void ChCommDistributed::ProcessTakes(int num_recv, uint* buf) { in ProcessTakes() argument
172 for (int i = 0; i < num_recv; i++) { in ProcessTakes()
179 void ChCommDistributed::ProcessShapes(int num_recv, Shape* buf) { in ProcessShapes() argument
191 while (n < num_recv) { in ProcessShapes()
208 while (n < num_recv && (buf + n)->gid == gid) { in ProcessShapes()
/dports/science/sparta/sparta-20Oct2021/src/
H A Dirregular.cpp50 memory->create(num_recv,nprocs,"irregular:num_recv"); in Irregular()
83 memory->destroy(num_recv); in ~Irregular()
339 nrecvdatum += num_recv[i]; in create_data_uniform()
359 num_recv_ordered[i] = num_recv[j]; in create_data_uniform()
363 memcpy(num_recv,num_recv_ordered,nrecv*sizeof(int)); in create_data_uniform()
511 nrecvdatum += num_recv[i]; in create_data_uniform_grouped()
531 num_recv_ordered[i] = num_recv[j]; in create_data_uniform_grouped()
535 memcpy(num_recv,num_recv_ordered,nrecv*sizeof(int)); in create_data_uniform_grouped()
741 num_recv[proc2recv[iproc]] = m; in augment_data_uniform()
771 MPI_Irecv(&recvbuf[offset],num_recv[irecv]*nbytes,MPI_CHAR, in exchange_uniform()
[all …]
H A Dirregular.h57 int *num_recv; // # of datums to recv from each proc variable
/dports/science/sparta/sparta-20Oct2021/src/KOKKOS/
H A Dirregular_kokkos.cpp191 MPI_Recv(&num_recv[i],1,MPI_INT,MPI_ANY_SOURCE,0,world,status); in create_data_uniform()
193 nrecvdatum += num_recv[i]; in create_data_uniform()
213 num_recv_ordered[i] = num_recv[j]; in create_data_uniform()
217 memcpy(num_recv,num_recv_ordered,nrecv*sizeof(int)); in create_data_uniform()
320 num_recv[proc2recv[iproc]] = m; in augment_data_uniform()
362 MPI_Irecv(&d_recvbuf_ptr[offset],num_recv[irecv]*nbytes,MPI_CHAR, in exchange_uniform()
365 MPI_Irecv(h_recvbuf.data() + offset,num_recv[irecv]*nbytes,MPI_CHAR, in exchange_uniform()
368 offset += num_recv[irecv]*nbytes; in exchange_uniform()
/dports/science/lammps/lammps-stable_29Sep2021/src/
H A Dirregular.cpp614 num_recv = new int[nrecv_proc]; in create_data()
700 nrecvdatum += num_recv[i]; in create_data()
725 num_recv_ordered[i] = num_recv[j]; in create_data()
729 memcpy(num_recv,num_recv_ordered,nrecv_proc*sizeof(int)); in create_data()
786 num_recv = new int[nrecv_proc]; in create_data_grouped()
874 nrecvdatum += num_recv[i]; in create_data_grouped()
898 num_recv_ordered[i] = num_recv[j]; in create_data_grouped()
902 memcpy(num_recv,num_recv_ordered,nrecv_proc*sizeof(int)); in create_data_grouped()
935 MPI_Irecv(&recvbuf[offset],num_recv[irecv]*nbytes,MPI_CHAR, in exchange_data()
937 offset += (bigint)num_recv[irecv]*nbytes; in exchange_data()
[all …]
H A Dirregular.h81 int *num_recv; // # of datums to recv from each proc variable
/dports/science/hypre/hypre-2.23.0/src/distributed_ls/ParaSails/
H A DMatrix.c64 mat->num_recv = 0; in MatrixCreate()
112 mat->num_recv = 0; in MatrixCreateLocal()
138 for (i=0; i<mat->num_recv; i++) in MatrixDestroy()
147 for (i=0; i<mat->num_recv; i++) in MatrixDestroy()
593 mat->num_recv = 0; in SetupReceives()
622 comm, &mat->recv_req[mat->num_recv]); in SetupReceives()
625 comm, &mat->send_req2[mat->num_recv]); in SetupReceives()
627 mat->num_recv++; in SetupReceives()
758 hypre_MPI_Startall(mat->num_recv, mat->recv_req); in MatrixMatvec()
800 hypre_MPI_Startall(mat->num_recv, mat->recv_req); in MatrixMatvecSerial()
[all …]
H A DMatrix.h40 HYPRE_Int num_recv; member
/dports/science/liggghts/LIGGGHTS-PUBLIC-3.8.0-26-g6e873439/src/
H A Dirregular.cpp530 int *num_recv = new int[nrecv]; in create_data() local
610 MPI_Recv(&num_recv[i],1,MPI_INT,MPI_ANY_SOURCE,0,world,status); in create_data()
612 nrecvsize += num_recv[i]; in create_data()
636 dplan->num_recv = num_recv; in create_data()
661 MPI_Irecv(&recvbuf[offset],dplan->num_recv[irecv]*nbytes,MPI_CHAR, in exchange_data()
663 offset += dplan->num_recv[irecv]*nbytes; in exchange_data()
718 delete [] dplan->num_recv; in destroy_data()
H A Dirregular.h107 int *num_recv; // # of datums to recv from each proc member
/dports/net/fping/fping-5.0/src/
H A Dfping.c1280 if(h->num_recv > 0) {
1286 if (h->num_recv <= h->num_sent) {
1490 if (!h->num_recv) {
1569 if (h->num_recv <= h->num_sent) {
1571 …h->num_sent, h->num_recv, h->num_sent > 0 ? ((h->num_sent - h->num_recv) * 100) / h->num_sent : 0);
1581 h->num_sent, h->num_recv,
1585 if (h->num_recv) {
1991 h->num_recv++;
2363 if (h->num_recv == 1) {
2389 avg = h->total_time / h->num_recv;
[all …]
/dports/net-im/tox/c-toxcore-0.2.13/auto_tests/
H A Dconference_test.c93 static uint32_t num_recv; variable
100 ++num_recv; in handle_conference_message()
304 num_recv = 0; in run_conference_tests()
310 ck_assert_msg(num_recv == NUM_GROUP_TOX, "failed to recv group messages"); in run_conference_tests()
/dports/net/samba412/samba-4.12.15/python/samba/tests/
H A Dldap_raw.py140 def recv(self, num_recv=0xffff, timeout=None): argument
146 data = self.socket.recv(num_recv, 0)
/dports/security/snort3/snort3-3.1.19.0/src/main/
H A Danalyzer.cc834 unsigned num_recv = 0; in process_messages() local
848 num_recv++; in process_messages()
856 if (exit_after_cnt && (exit_after_cnt -= num_recv) == 0) in process_messages()
858 if (pause_after_cnt && (pause_after_cnt -= num_recv) == 0) in process_messages()
/dports/math/moab/fathomteam-moab-7bde9dfb84a8/src/parallel/
H A DParCommGraph.cpp97 int num_recv = ((int)receiverTasks.size()); in compute_trivial_partition() local
99 int num_per_receiver = (int)(total_elems/num_recv); in compute_trivial_partition()
100 int leftover = total_elems - num_per_receiver*num_recv; in compute_trivial_partition()
104 starts.resize(num_recv+1); in compute_trivial_partition()
106 for (int k=0; k<num_recv; k++) in compute_trivial_partition()
118 for (int k = lastUsedReceiverRank; k<num_recv; k++ ) in compute_trivial_partition()
/dports/science/hypre/hypre-2.23.0/src/distributed_ls/Euclid/
H A DMat_dh.c68 tmp->num_recv = 0; in Mat_dhCreate()
107 for (i=0; i<mat->num_recv; i++) hypre_MPI_Request_free(&mat->recv_req[i]); in Mat_dhDestroy()
224 mat->num_recv = 0; in setup_matvec_receives_private()
250 comm_dh, &mat->recv_req[mat->num_recv]); CHECK_MPI_V_ERROR(ierr); in setup_matvec_receives_private()
252 mat->num_recv++; in setup_matvec_receives_private()
345 ierr = hypre_MPI_Startall(mat->num_recv, mat->recv_req); CHECK_MPI_V_ERROR(ierr); in Mat_dhMatVec()
347 ierr = hypre_MPI_Waitall(mat->num_recv, mat->recv_req, mat->status); CHECK_MPI_V_ERROR(ierr); in Mat_dhMatVec()
413 ierr = hypre_MPI_Startall(mat->num_recv, mat->recv_req); CHECK_MPI_V_ERROR(ierr); in Mat_dhMatVec_omp()
415 ierr = hypre_MPI_Waitall(mat->num_recv, mat->recv_req, mat->status); CHECK_MPI_V_ERROR(ierr); in Mat_dhMatVec_omp()
H A DMat_dh.h54 HYPRE_Int num_recv; member
H A DFactor_dh.c337 HYPRE_Int i, j, this_pe, num_recv = 0; in setup_receives_private() local
378 comm_dh, req+num_recv); in setup_receives_private()
379 ++num_recv; in setup_receives_private()
382 END_FUNC_VAL(num_recv); in setup_receives_private()
/dports/net/arp-scan/arp-scan-1.9.7/
H A Darp-scan.h165 unsigned short num_recv; /* Number of packets received */ member
/dports/science/quantum-espresso/q-e-qe-6.7.0/CPV/src/
H A Dexx_gs.f90115 INTEGER, ALLOCATABLE :: obtl_recv(:,:), obtl_send(:,:), num_recv(:), num_send(:) local
196 ALLOCATE (num_recv(ndim)); num_recv=0
200 CALL exx_index_pair(wannierc_tmp, obtl_recv, num_recv, nj_max, ndim)
461 my_var3=num_recv( gindex_of_iobtl )
927 IF (ALLOCATED(num_recv)) DEALLOCATE(num_recv)
/dports/net/libdaq/libdaq-3.0.5/
H A DREADME.md49 unsigned num_recv = daq_instance_msg_receive(instance, 16, msgs, &rstat);
51 for (unsigned idx = 0; idx < num_recv; idx++)
/dports/net/libdaq/libdaq-3.0.5/example/
H A Ddaqtest.c1482 … unsigned num_recv = daq_instance_msg_receive(ctxt->instance, batch_size, ctxt->msgs, &rstat); in processing_thread() local
1484 if (num_recv > max_recv) in processing_thread()
1485 max_recv = num_recv; in processing_thread()
1487 if (num_recv > 0) in processing_thread()
1490 for (unsigned idx = 0; idx < num_recv; idx++) in processing_thread()
/dports/security/zeronet/ZeroNet-0.7.1/plugins/Chart/
H A DChartCollector.py62 collectors["request_num_recv|change"] = lambda: file_server.num_recv
/dports/comms/libusbmuxd/libusbmuxd-2.0.2/src/
H A Dlibusbmuxd.c1591 int num_recv = socket_receive_timeout(sfd, (void*)data, len, 0, timeout); in usbmuxd_recv_timeout() local
1592 if (num_recv < 0) { in usbmuxd_recv_timeout()
1594 return num_recv; in usbmuxd_recv_timeout()
1597 *recv_bytes = num_recv; in usbmuxd_recv_timeout()

12