/dports/science/chrono/chrono-7.0.1/src/chrono_distributed/comm/ |
H A D | ChCommDistributed.h | 134 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 D | ChCommDistributed.cpp | 90 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 D | irregular.cpp | 50 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 D | irregular.h | 57 int *num_recv; // # of datums to recv from each proc variable
|
/dports/science/sparta/sparta-20Oct2021/src/KOKKOS/ |
H A D | irregular_kokkos.cpp | 191 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 D | irregular.cpp | 614 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 D | irregular.h | 81 int *num_recv; // # of datums to recv from each proc variable
|
/dports/science/hypre/hypre-2.23.0/src/distributed_ls/ParaSails/ |
H A D | Matrix.c | 64 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 D | Matrix.h | 40 HYPRE_Int num_recv; member
|
/dports/science/liggghts/LIGGGHTS-PUBLIC-3.8.0-26-g6e873439/src/ |
H A D | irregular.cpp | 530 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 D | irregular.h | 107 int *num_recv; // # of datums to recv from each proc member
|
/dports/net/fping/fping-5.0/src/ |
H A D | fping.c | 1280 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 D | conference_test.c | 93 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 D | ldap_raw.py | 140 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 D | analyzer.cc | 834 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 D | ParCommGraph.cpp | 97 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 D | Mat_dh.c | 68 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 D | Mat_dh.h | 54 HYPRE_Int num_recv; member
|
H A D | Factor_dh.c | 337 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 D | arp-scan.h | 165 unsigned short num_recv; /* Number of packets received */ member
|
/dports/science/quantum-espresso/q-e-qe-6.7.0/CPV/src/ |
H A D | exx_gs.f90 | 115 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 D | README.md | 49 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 D | daqtest.c | 1482 … 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 D | ChartCollector.py | 62 collectors["request_num_recv|change"] = lambda: file_server.num_recv
|
/dports/comms/libusbmuxd/libusbmuxd-2.0.2/src/ |
H A D | libusbmuxd.c | 1591 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()
|