/dports/mail/avenger/avenger-0.8.5/libasync/ |
H A D | backoff.h | 46 u_int minto, u_int maxsend> friend class tmoq; 50 template<class T, tmoq_entry<T> T::*field, u_int minto = 2, u_int maxsend = 5> 58 head queue[maxsend]; 59 bool pending[maxsend]; 81 if (qn < maxsend - 1) in runq() 84 (p->*field).qno = maxsend; in runq() 103 for (size_t i = 0; i < maxsend; i++) in tmoq() 110 assert ((p->*field).qno >= maxsend); in keeptrying() 111 insert (p, maxsend - 1); in keeptrying() 115 if ((p->*field).qno < maxsend) { in remove()
|
/dports/science/py-gpaw/gpaw-21.6.0/c/ |
H A D | operators.c | 63 double* sendbuf = GPAW_MALLOC(double, bc->maxsend); in Operator_relax() 104 double* sendbuf = GPAW_MALLOC(double, bc->maxsend * chunksize); in apply_worker() 155 double* sendbuf = GPAW_MALLOC(double, bc->maxsend * chunksize in apply_worker_cfd() 175 sendbuf + odd * bc->maxsend * chunksize + i * bc->maxsend * chunksize * GPAW_ASYNC2, in apply_worker_cfd() 194 … sendbuf + odd * bc->maxsend * chunksize + i * bc->maxsend * chunksize * GPAW_ASYNC2, in apply_worker_cfd() 266 if (bc->maxsend > 0 ) in Operator_apply() 267 chunksize = opt_msg_size * 1024 / (bc->maxsend / 2 * (2 - (int)real) * in Operator_apply()
|
H A D | woperators.c | 77 double* sendbuf = (double*) GPAW_MALLOC(double, bc->maxsend); in WOperator_relax() 123 double* sendbuf = (double*) GPAW_MALLOC(double, bc->maxsend * chunksize); in wapply_worker() 179 double* sendbuf = (double*) GPAW_MALLOC(double, bc->maxsend * chunksize in wapply_worker_cfd() 200 … sendbuf + odd * bc->maxsend * chunksize + i * bc->maxsend * chunksize * GPAW_ASYNC2, ph + 2 * i, in wapply_worker_cfd() 219 … sendbuf + odd * bc->maxsend * chunksize + i * bc->maxsend * chunksize * GPAW_ASYNC2, ph + 2 * i, in wapply_worker_cfd() 303 if (bc->maxsend > 0 ) in WOperator_apply() 304 chunksize = opt_msg_size * 1024 / (bc->maxsend / 2 * (2 - (int)real) * in WOperator_apply()
|
H A D | transformers.c | 48 double* sendbuf = GPAW_MALLOC(double, bc->maxsend * chunksize); in transapply_worker() 134 if (bc->maxsend > 0 ) in Transformer_apply() 135 chunksize = opt_msg_size * 1024 / (bc->maxsend / 2 * in Transformer_apply()
|
H A D | bc.c | 122 bc->maxsend = 0; in bc_init() 127 if (n > bc->maxsend) in bc_init() 128 bc->maxsend = n; in bc_init()
|
H A D | bc.h | 28 int maxsend; member
|
/dports/science/lammps/lammps-stable_29Sep2021/src/ |
H A D | irregular.cpp | 75 maxsend = maxrecv = BUFMIN; in Irregular() 77 grow_send(maxsend,2); in Irregular() 114 if (bufextra > bufextra_old) grow_send(maxsend+bufextra,2); in migrate_atoms() 170 if (nsend > maxsend) grow_send(nsend,1); in migrate_atoms() 188 if (nsend > maxsend) grow_send(nsend,1); in migrate_atoms() 1026 maxsend = static_cast<int> (BUFFACTOR * n); in grow_send() 1028 memory->create(buf_send,maxsend+bufextra,"comm:buf_send"); in grow_send() 1030 maxsend = static_cast<int> (BUFFACTOR * n); in grow_send() 1031 memory->grow(buf_send,maxsend+bufextra,"comm:buf_send"); in grow_send() 1034 memory->grow(buf_send,maxsend+bufextra,"comm:buf_send"); in grow_send() [all …]
|
H A D | comm_brick.cpp | 113 maxsend = maxrecv = BUFMIN; in init_buffers() 114 CommBrick::grow_send(maxsend,2); in init_buffers() 137 if (bufextra > bufextra_old) grow_send(maxsend+bufextra,2); in init() 718 if (nsend > maxsend) grow_send(nsend,1); in exchange() 990 if (max > maxsend) grow_send(max,0); in borders() 1180 if (nsend > maxsend) grow_send(nsend,0); in reverse_comm_fix_variable() 1481 maxsend = static_cast<int> (BUFFACTOR * n); in grow_send() 1485 maxsend = static_cast<int> (BUFFACTOR * n); in grow_send() 1486 memory->grow(buf_send,maxsend+bufextra,"comm:buf_send"); in grow_send() 1489 memory->grow(buf_send,maxsend+bufextra,"comm:buf_send"); in grow_send() [all …]
|
H A D | irregular.h | 45 int maxsend, maxrecv; // size of buf send/recv in # of doubles variable
|
H A D | rcb.h | 107 int maxrecv, maxsend; variable
|
H A D | comm_brick.h | 78 int maxsend, maxrecv; // current size of send/recv buffer variable
|
/dports/science/liggghts/LIGGGHTS-PUBLIC-3.8.0-26-g6e873439/src/ |
H A D | irregular.cpp | 81 maxsend = BUFMIN; in Irregular() 82 memory->create(buf_send,maxsend+BUFEXTRA,"comm:buf_send"); in Irregular() 161 if (nsend > maxsend) grow_send(nsend,1); in migrate_atoms() 808 maxsend = static_cast<int> (BUFFACTOR * n); in grow_send() 810 memory->grow(buf_send,maxsend+BUFEXTRA,"comm:buf_send"); in grow_send() 813 memory->create(buf_send,maxsend+BUFEXTRA,"comm:buf_send"); in grow_send() 834 bigint bytes = memory->usage(buf_send,maxsend); in memory_usage()
|
H A D | irregular.h | 75 int maxsend,maxrecv; // size of buffers in # of doubles variable
|
H A D | comm.cpp | 171 maxsend = BUFMIN; in Comm() 172 memory->create(buf_send,maxsend+bufextra,"comm:buf_send"); in Comm() 928 memory->grow(buf_send,maxsend+bufextra,"comm:buf_send"); in exchange() 958 if (nsend > maxsend) grow_send(nsend,1); in exchange() 1175 if (nsend*size_border > maxsend) grow_send(nsend*size_border,0); in borders() 1227 if (max > maxsend) grow_send(max,0); in borders() 1778 maxsend = static_cast<int> (BUFFACTOR * n); in grow_send() 1780 memory->grow(buf_send,maxsend+bufextra,"comm:buf_send"); in grow_send() 1783 memory->create(buf_send,maxsend+bufextra,"comm:buf_send"); in grow_send() 2075 bytes += memory->usage(buf_send,maxsend+bufextra); in memory_usage()
|
/dports/net-im/purple-plugin-pack/purple-plugin-pack-2.8.0/autoreply/ |
H A D | autoreply.c | 172 int count_sent, maxsend; in written_msg() local 183 maxsend = purple_prefs_get_int(PREFS_MAXSEND); in written_msg() 186 if (count_sent < maxsend || maxsend == -1) in written_msg()
|
/dports/science/octopus/octopus-10.5/share/opencl/ |
H A D | boundaries.cl | 58 __kernel void boundaries_periodic_send(const int maxsend, 73 const int ip_send = per_send[maxsend*ipart + ip] - 1; 75 sendbuffer[((maxsend*ipart + ip)<<ldff) + ist] = ff[(ip_send<<ldff) + ist];
|
/dports/science/octopus/octopus-10.5/src/grid/ |
H A D | boundaries_inc.F90 | 369 integer :: ipart, npart, maxsend, maxrecv, ldbuffer, ip2 383 maxsend = maxval(boundaries%nsend(1:npart)) 388 SAFE_ALLOCATE(sendbuffer(1:ldbuffer, 1:maxsend, 1:npart)) 417 …ll accel_create_buffer(buff_send, ACCEL_MEM_WRITE_ONLY, R_TYPE_VAL, ffb%pack_size(1)*maxsend*npart) 421 call accel_set_kernel_arg(kernel_send, 0, maxsend) 430 call accel_kernel_run(kernel_send, (/ffb%pack_size_real(1), pad(maxsend, wgsize), npart/), & 435 call accel_read_buffer(buff_send, ffb%pack_size(1)*maxsend*npart, sendbuffer) 447 send_disp(ipart) = ldbuffer*maxsend*(ipart - 1)
|
/dports/games/heretic/glheretic-1.2/ |
H A D | d_net.c | 54 int maxsend; /* BACKUPTICS/(2*ticdup)-1 */ variable 592 maxsend = BACKUPTICS/(2*ticdup)-1; in D_CheckNetGame() 593 if (maxsend<1) in D_CheckNetGame() 594 maxsend = 1; in D_CheckNetGame()
|
/dports/games/uhexen/uhexen-0.601/src/ |
H A D | d_net.c | 61 int maxsend; // BACKUPTICS/(2*ticdup)-1 variable 725 maxsend = BACKUPTICS/(2*ticdup)-1; in D_CheckNetGame() 726 if (maxsend<1) in D_CheckNetGame() 727 maxsend = 1; in D_CheckNetGame()
|
/dports/science/hypre/hypre-2.23.0/src/distributed_ls/pilut/ |
H A D | trifactor.c | 271 HYPRE_Int maxsend; in hypre_SetUpLUFactor() local 279 maxsend = 0; in hypre_SetUpLUFactor() 290 hypre_SetUpFactor( ddist, ldu, maxnz, petotal, rind, imap, &maxsend, true, in hypre_SetUpLUFactor() 307 hypre_SetUpFactor( ddist, ldu, maxnz, petotal, rind, imap, &maxsend, false, in hypre_SetUpLUFactor() 316 ldu->gatherbuf = hypre_fp_malloc(maxsend, "hypre_SetUpLUFactor: ldu->gatherbuf"); in hypre_SetUpLUFactor()
|
/dports/science/sparta/sparta-20Oct2021/src/ |
H A D | rcb.h | 105 int maxrecv,maxsend; variable
|
H A D | fix_ablate.h | 86 int maxsend;
|
H A D | rcb.cpp | 63 maxrecv = maxsend = 0; in RCB() 713 if (noriginal > maxsend) { in invert() 716 maxsend = noriginal; in invert() 717 memory->create(sendproc,maxsend,"RCB:sendproc"); in invert() 718 memory->create(sendindex,maxsend,"RCB:sendindex"); in invert()
|
/dports/science/lammps/lammps-stable_29Sep2021/src/KOKKOS/ |
H A D | comm_kokkos.cpp | 102 maxsend = BUFMIN; in init() 105 grow_send_kokkos(maxsend+bufextra,0,Host); in init() 731 if (nsend > maxsend) grow_send_kokkos(nsend,1); in exchange_device() 741 if (nsend > maxsend) grow_send_kokkos(nsend,1); in exchange_device() 1052 if (nsend*size_border > maxsend) in borders_device() 1127 if (max > maxsend) grow_send_kokkos(max,0); in borders_device() 1231 maxsend = static_cast<int> (BUFFACTOR * n); in grow_send_kokkos() 1232 int maxsend_border = (maxsend+BUFEXTRA+5)/atom->avec->size_border + 2; in grow_send_kokkos()
|
H A D | atom_vec_kokkos.cpp | 76 … const size_t maxsend = (buf.view<DeviceType>().extent(0)*buf.view<DeviceType>().extent(1))/3; in AtomVecKokkos_PackComm() local 78 buffer_view<DeviceType>(_buf,buf,maxsend,elements); in AtomVecKokkos_PackComm() 476 …const int maxsend = (buf.template view<DeviceType>().extent(0)*buf.template view<DeviceType>().ext… in AtomVecKokkos_PackCommVel() local 477 …_buf = typename ArrayTypes<DeviceType>::t_xfloat_2d_um(buf.view<DeviceType>().data(),maxsend,eleme… in AtomVecKokkos_PackCommVel() 677 …const int maxsend = (buf.template view<DeviceType>().extent(0)*buf.template view<DeviceType>().ext… in AtomVecKokkos_UnpackCommVel() local 678 buffer_view<DeviceType>(_buf,buf,maxsend,elements); in AtomVecKokkos_UnpackCommVel() 946 … const size_t maxsend = (buf.view<DeviceType>().extent(0)*buf.view<DeviceType>().extent(1))/3; in AtomVecKokkos_UnPackReverse() local 948 buffer_view<DeviceType>(_buf,buf,maxsend,elements); in AtomVecKokkos_UnPackReverse()
|