Home
last modified time | relevance | path

Searched refs:maxsend (Results 1 – 25 of 41) sorted by relevance

12

/dports/mail/avenger/avenger-0.8.5/libasync/
H A Dbackoff.h46 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 Doperators.c63 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 Dwoperators.c77 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 Dtransformers.c48 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 Dbc.c122 bc->maxsend = 0; in bc_init()
127 if (n > bc->maxsend) in bc_init()
128 bc->maxsend = n; in bc_init()
H A Dbc.h28 int maxsend; member
/dports/science/lammps/lammps-stable_29Sep2021/src/
H A Dirregular.cpp75 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 Dcomm_brick.cpp113 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 Dirregular.h45 int maxsend, maxrecv; // size of buf send/recv in # of doubles variable
H A Drcb.h107 int maxrecv, maxsend; variable
H A Dcomm_brick.h78 int maxsend, maxrecv; // current size of send/recv buffer variable
/dports/science/liggghts/LIGGGHTS-PUBLIC-3.8.0-26-g6e873439/src/
H A Dirregular.cpp81 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 Dirregular.h75 int maxsend,maxrecv; // size of buffers in # of doubles variable
H A Dcomm.cpp171 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 Dautoreply.c172 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 Dboundaries.cl58 __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 Dboundaries_inc.F90369 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 Dd_net.c54 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 Dd_net.c61 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 Dtrifactor.c271 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 Drcb.h105 int maxrecv,maxsend; variable
H A Dfix_ablate.h86 int maxsend;
H A Drcb.cpp63 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 Dcomm_kokkos.cpp102 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 Datom_vec_kokkos.cpp76 … 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()

12