r 961 ompi/dpm/dpm.c uint32_t r; r 964 ompi/dpm/dpm.c r = opal_rand(&rnd); r 966 ompi/dpm/dpm.c snprintf(port_name, MPI_MAX_PORT_NAME-1, "%s:%u", tmp, r); r 303 ompi/mca/coll/base/coll_base_reduce_scatter_block.c static int ompi_range_sum(int a, int b, int r) r 305 ompi/mca/coll/base/coll_base_reduce_scatter_block.c if (r < a) r 307 ompi/mca/coll/base/coll_base_reduce_scatter_block.c else if (r > b) r 309 ompi/mca/coll/base/coll_base_reduce_scatter_block.c return 2 * (r - a + 1) + b - r; r 516 ompi/mca/coll/base/coll_base_topo.c for (int r = 1; r < radix; r++) { r 517 ompi/mca/coll/base/coll_base_topo.c int child = vrank + mask * r; r 562 ompi/mca/coll/libnbc/libdict/hb_tree.c unsigned l, r; r 567 ompi/mca/coll/libnbc/libdict/hb_tree.c r = node->rlink ? node_height(node->rlink) + 1 : 0; r 568 ompi/mca/coll/libnbc/libdict/hb_tree.c return MAX(l, r); r 574 ompi/mca/coll/libnbc/libdict/hb_tree.c unsigned l, r; r 579 ompi/mca/coll/libnbc/libdict/hb_tree.c r = node->rlink ? node_mheight(node->rlink) + 1 : 0; r 580 ompi/mca/coll/libnbc/libdict/hb_tree.c return MIN(l, r); r 238 ompi/mca/coll/libnbc/nbc_iallgather.c for (int r = 0 ; r < rsize ; ++r) { r 240 ompi/mca/coll/libnbc/nbc_iallgather.c rbuf = (char *) recvbuf + r * recvcount * rcvext; r 241 ompi/mca/coll/libnbc/nbc_iallgather.c res = NBC_Sched_recv (rbuf, false, recvcount, recvtype, r, schedule, false); r 248 ompi/mca/coll/libnbc/nbc_iallgather.c res = NBC_Sched_send (sendbuf, false, sendcount, sendtype, r, schedule, false); r 88 ompi/mca/coll/libnbc/nbc_iallgatherv.c for (int r = 1 ; r < p ; ++r) { r 89 ompi/mca/coll/libnbc/nbc_iallgatherv.c speer = (rank + r) % p; r 90 ompi/mca/coll/libnbc/nbc_iallgatherv.c rpeer = (rank - r + p) % p; r 164 ompi/mca/coll/libnbc/nbc_iallgatherv.c for (int r = 0 ; r < rsize ; ++r) { r 165 ompi/mca/coll/libnbc/nbc_iallgatherv.c char *rbuf = (char *) recvbuf + displs[r] * rcvext; r 167 ompi/mca/coll/libnbc/nbc_iallgatherv.c if (recvcounts[r]) { r 168 ompi/mca/coll/libnbc/nbc_iallgatherv.c res = NBC_Sched_recv (rbuf, false, recvcounts[r], recvtype, r, schedule, false); r 177 ompi/mca/coll/libnbc/nbc_iallgatherv.c for (int r = 0 ; r < rsize ; ++r) { r 178 ompi/mca/coll/libnbc/nbc_iallgatherv.c res = NBC_Sched_send (sendbuf, false, sendcount, sendtype, r, schedule, false); r 386 ompi/mca/coll/libnbc/nbc_iallreduce.c for (int r = 1, firstred = 1 ; r <= maxr ; ++r) { r 387 ompi/mca/coll/libnbc/nbc_iallreduce.c if ((vrank % (1 << r)) == 0) { r 389 ompi/mca/coll/libnbc/nbc_iallreduce.c vpeer = vrank + (1 << (r - 1)); r 416 ompi/mca/coll/libnbc/nbc_iallreduce.c vpeer = vrank - (1 << (r - 1)); r 441 ompi/mca/coll/libnbc/nbc_iallreduce.c for (int r = 0; r < maxr ; ++r) { r 442 ompi/mca/coll/libnbc/nbc_iallreduce.c if ((vrank >= (1 << r)) && (vrank < (1 << (r + 1)))) { r 443 ompi/mca/coll/libnbc/nbc_iallreduce.c VRANK2RANK(peer, vrank - (1 << r), root); r 459 ompi/mca/coll/libnbc/nbc_iallreduce.c for (int r = 0; r < maxr; ++r) { r 460 ompi/mca/coll/libnbc/nbc_iallreduce.c if (((vrank + (1 << r) < p) && (vrank < (1 << r))) || (vrank == 0)) { r 461 ompi/mca/coll/libnbc/nbc_iallreduce.c VRANK2RANK(peer, vrank + (1 << r), root); r 473 ompi/mca/coll/libnbc/nbc_iallreduce.c static inline int allred_sched_ring (int r, int p, int count, MPI_Datatype datatype, const void *sendbuf, void *recvbuf, MPI_Op op, r 508 ompi/mca/coll/libnbc/nbc_iallreduce.c speer = (r + 1) % p; r 509 ompi/mca/coll/libnbc/nbc_iallreduce.c rpeer = (r - 1 + p) % p; r 611 ompi/mca/coll/libnbc/nbc_iallreduce.c int selement = (r+1-round + 2*p /*2*p avoids negative mod*/)%p; /* the element I am sending */ r 613 ompi/mca/coll/libnbc/nbc_iallreduce.c int relement = (r-round + 2*p /*2*p avoids negative mod*/)%p; /* the element that I receive from my neighbor */ r 649 ompi/mca/coll/libnbc/nbc_iallreduce.c int selement = (r+1-round + 2*p /*2*p avoids negative mod*/)%p; /* the element I am sending */ r 651 ompi/mca/coll/libnbc/nbc_iallreduce.c int relement = (r-round + 2*p /*2*p avoids negative mod*/)%p; /* the element that I receive from my neighbor */ r 396 ompi/mca/coll/libnbc/nbc_ialltoall.c for (int r = 1 ; r < p ; ++r) { r 397 ompi/mca/coll/libnbc/nbc_ialltoall.c int sndpeer = (rank + r) % p; r 398 ompi/mca/coll/libnbc/nbc_ialltoall.c int rcvpeer = (rank - r + p) % p; r 421 ompi/mca/coll/libnbc/nbc_ialltoall.c for (int r = 0 ; r < p ; ++r) { r 423 ompi/mca/coll/libnbc/nbc_ialltoall.c if (r == rank) { r 427 ompi/mca/coll/libnbc/nbc_ialltoall.c char *rbuf = (char *) recvbuf + (intptr_t)r * (intptr_t)recvcount * rcvext; r 428 ompi/mca/coll/libnbc/nbc_ialltoall.c res = NBC_Sched_recv (rbuf, false, recvcount, recvtype, r, schedule, false); r 433 ompi/mca/coll/libnbc/nbc_ialltoall.c char *sbuf = (char *) sendbuf + (intptr_t)r * (intptr_t)sendcount * sndext; r 434 ompi/mca/coll/libnbc/nbc_ialltoall.c res = NBC_Sched_send (sbuf, false, sendcount, sendtype, r, schedule, false); r 476 ompi/mca/coll/libnbc/nbc_ialltoall.c for (int r = 1; r < p; r <<= 1) { r 480 ompi/mca/coll/libnbc/nbc_ialltoall.c if (i & r) { r 492 ompi/mca/coll/libnbc/nbc_ialltoall.c speer = (rank + r) % p; r 494 ompi/mca/coll/libnbc/nbc_ialltoall.c rpeer = ((rank - r) + p) % p; r 510 ompi/mca/coll/libnbc/nbc_ialltoall.c if (i & r) { r 247 ompi/mca/coll/libnbc/nbc_ibcast.c for (int r = 0 ; r < maxr ; ++r) { r 248 ompi/mca/coll/libnbc/nbc_ibcast.c if ((vrank >= (1 << r)) && (vrank < (1 << (r + 1)))) { r 249 ompi/mca/coll/libnbc/nbc_ibcast.c VRANK2RANK(peer, vrank - (1 << r), root); r 264 ompi/mca/coll/libnbc/nbc_ibcast.c for (int r = 0 ; r < maxr ; ++r) { r 265 ompi/mca/coll/libnbc/nbc_ibcast.c if (((vrank + (1 << r) < p) && (vrank < (1 << r))) || (vrank == 0)) { r 266 ompi/mca/coll/libnbc/nbc_ibcast.c VRANK2RANK(peer, vrank + (1 << r), root); r 396 ompi/mca/coll/libnbc/nbc_ibcast.c for (int r = 1; r < knomial_radix; r++) { r 397 ompi/mca/coll/libnbc/nbc_ibcast.c int child = vrank + mask * r; r 397 ompi/mca/coll/libnbc/nbc_ireduce.c for (int r = 1, firstred = 1 ; r <= maxr ; ++r) { r 398 ompi/mca/coll/libnbc/nbc_ireduce.c if ((vrank % (1 << r)) == 0) { r 400 ompi/mca/coll/libnbc/nbc_ireduce.c vpeer = vrank + (1 << (r - 1)); r 430 ompi/mca/coll/libnbc/nbc_ireduce.c vpeer = vrank - (1 << (r - 1)); r 69 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c for (int r = 0 ; r < p ; ++r) { r 70 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c count += recvcounts[r]; r 103 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c for (int r = 1, firstred = 1 ; r <= maxr ; ++r) { r 104 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c if ((rank % (1 << r)) == 0) { r 106 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c peer = rank + (1 << (r - 1)); r 136 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c peer = rank - (1 << (r - 1)); r 164 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c for (long int r = 1, offset = 0 ; r < p ; ++r) { r 165 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c offset += recvcounts[r-1]; r 168 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c res = NBC_Sched_send (sbuf, true, recvcounts[r], datatype, r, schedule, r 250 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c for (int r = 0 ; r < lsize ; ++r) { r 251 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c count += recvcounts[r]; r 101 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c for (int r = 1, firstred = 1 ; r <= maxr; ++r) { r 102 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c if ((rank % (1 << r)) == 0) { r 104 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c peer = rank + (1 << (r - 1)); r 133 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c peer = rank - (1 << (r - 1)); r 169 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c for (int r = 1, offset = 0 ; r < p ; ++r) { r 173 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c res = NBC_Sched_send (sbuf, true, recvcount, datatype, r, schedule, false); r 699 ompi/mca/common/ompio/common_ompio_aggregators.c int r = 0; r 819 ompi/mca/common/ompio/common_ompio_aggregators.c sendreqs + r++)); r 832 ompi/mca/common/ompio/common_ompio_aggregators.c sendreqs + r++)); r 876 ompi/mca/common/ompio/common_ompio_aggregators.c ret = ompi_request_wait_all (r, sendreqs, MPI_STATUSES_IGNORE); r 33 ompi/mca/common/ompio/common_ompio_print_queue.c int mca_common_ompio_initialize_print_queue( struct mca_common_ompio_print_queue **r){ r 46 ompi/mca/common/ompio/common_ompio_print_queue.c *r = q; r 1427 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c int i, j, heapsize, l, r, k, smallest; r 1446 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c r = 2*(k+1); r 1452 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c if ((r < heapsize) && r 1453 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c (*(a[r].off_list) < *(a[smallest].off_list))) r 1454 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c smallest = r; r 1497 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c r = 2*(k+1); r 1504 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c if ((r < heapsize) && r 1505 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c (*(a[r].off_list) < *(a[smallest].off_list))) r 1506 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c smallest = r; r 122 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c GPFSMPIO_T_CIO_RESET( r); r 147 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c GPFSMPIO_T_CIO_SET_GET( r, 1, 0, GPFSMPIO_CIO_T_MPIO_CRW, GPFSMPIO_CIO_LAST) r 148 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c GPFSMPIO_T_CIO_SET_GET( r, 1, 0, GPFSMPIO_CIO_T_LCOMP, GPFSMPIO_CIO_LAST ) r 162 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c GPFSMPIO_T_CIO_SET_GET( r, 1, 1, GPFSMPIO_CIO_T_GATHER, GPFSMPIO_CIO_T_LCOMP ) r 237 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c GPFSMPIO_T_CIO_SET_GET( r, 1, 1, GPFSMPIO_CIO_T_PATANA, GPFSMPIO_CIO_T_GATHER ) r 279 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c GPFSMPIO_T_CIO_SET_GET( r, 1, 1, GPFSMPIO_CIO_T_FD_PART, GPFSMPIO_CIO_T_PATANA ) r 343 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c GPFSMPIO_T_CIO_SET_GET( r, 1, 1, GPFSMPIO_CIO_T_MYREQ, GPFSMPIO_CIO_T_FD_PART ); r 418 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c GPFSMPIO_T_CIO_SET_GET( r, 1, 1, GPFSMPIO_CIO_T_OTHREQ, GPFSMPIO_CIO_T_MYREQ ) r 439 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c GPFSMPIO_T_CIO_SET_GET( r, 1, 1, GPFSMPIO_CIO_T_DEXCH, GPFSMPIO_CIO_T_OTHREQ ) r 462 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c GPFSMPIO_T_CIO_SET_GET( r, 0, 1, GPFSMPIO_CIO_LAST, GPFSMPIO_CIO_T_DEXCH ) r 463 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c GPFSMPIO_T_CIO_SET_GET( r, 0, 1, GPFSMPIO_CIO_LAST, GPFSMPIO_CIO_T_MPIO_CRW ) r 1413 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c int i, j, heapsize, l, r, k, smallest; r 1438 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c r = 2*(k+1); r 1445 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c if ((r < heapsize) && r 1446 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c (*(a[r].off_list) < *(a[smallest].off_list))) r 1447 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c smallest = r; r 1489 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c r = 2*(k+1); r 1496 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c if ((r < heapsize) && r 1497 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c (*(a[r].off_list) < *(a[smallest].off_list))) r 1498 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c smallest = r; r 87 ompi/mca/io/romio321/romio/adio/ad_gpfs/bg/ad_bg_aggrs.c int r, s; r 93 ompi/mca/io/romio321/romio/adio/ad_gpfs/bg/ad_bg_aggrs.c MPI_Comm_rank( fd->comm, &r ); r 98 ompi/mca/io/romio321/romio/adio/ad_gpfs/bg/ad_bg_aggrs.c ADIOI_BG_persInfo_init( confInfo, procInfo, s, r, n_aggrs_per_pset, fd->comm); r 110 ompi/mca/io/romio321/romio/adio/ad_gpfs/bg/ad_bg_aggrs.c if (r == 0) { r 122 ompi/mca/io/romio321/romio/adio/ad_gpfs/bg/ad_bg_aggrs.c if (r != 0) { r 132 ompi/mca/io/romio321/romio/adio/ad_gpfs/bg/ad_bg_aggrs.c if (r != 0) { r 75 ompi/mca/io/romio321/romio/adio/ad_gpfs/bg/ad_bg_pset.h int s, int r, int n_aggrs, MPI_Comm comm); r 980 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c int i, j, heapsize, l, r, k, smallest; r 1005 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c r = 2*(k+1); r 1012 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c if ((r < heapsize) && r 1013 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c (*(a[r].off_list) < *(a[smallest].off_list))) r 1014 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c smallest = r; r 1056 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c r = 2*(k+1); r 1063 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c if ((r < heapsize) && r 1064 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c (*(a[r].off_list) < *(a[smallest].off_list))) r 1065 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c smallest = r; r 56 ompi/mca/io/romio321/romio/adio/common/heap-sort.c int l, r, smallest; r 63 ompi/mca/io/romio321/romio/adio/common/heap-sort.c r = right(i); r 70 ompi/mca/io/romio321/romio/adio/common/heap-sort.c if ((r <= heap->size) && (nodes[r].offset < nodes[smallest].offset)) r 71 ompi/mca/io/romio321/romio/adio/common/heap-sort.c smallest = r; r 33 ompi/mca/io/romio321/romio/adio/common/utils.c int r = count%INT_MAX; r 36 ompi/mca/io/romio321/romio/adio/common/utils.c MPI_Type_contiguous(r, oldtype, &remainder); r 423 ompi/mca/osc/pt2pt/osc_pt2pt_header.h #define OSC_PT2PT_HTON(h, m, r) \ r 424 ompi/mca/osc/pt2pt/osc_pt2pt_header.h osc_pt2pt_hton_intr((ompi_osc_pt2pt_header_t *)(h), ompi_comm_peer_lookup((m)->comm, (r))); r 428 ompi/mca/osc/pt2pt/osc_pt2pt_header.h #define OSC_PT2PT_HTON(h, m, r) \ r 221 ompi/mca/pml/ob1/pml_ob1_recvreq.h #define MCA_PML_OB1_RECV_REQUEST_START(r) mca_pml_ob1_recv_req_start(r) r 165 ompi/mca/pml/ob1/pml_ob1_sendreq.h size_t r; r 168 ompi/mca/pml/ob1/pml_ob1_sendreq.h for(r = 0; r < sendreq->req_rdma_cnt; r++) { r 169 ompi/mca/pml/ob1/pml_ob1_sendreq.h struct mca_btl_base_registration_handle_t *handle = sendreq->req_rdma[r].btl_reg; r 170 ompi/mca/pml/ob1/pml_ob1_sendreq.h mca_bml_base_btl_t *bml_btl = sendreq->req_rdma[r].bml_btl; r 174 ompi/mca/pml/ob1/pml_ob1_sendreq.h sendreq->req_rdma[r].btl_reg = NULL; r 517 ompi/mca/topo/treematch/treematch/uthash.h #define MUR_ROTL32(x,r) (((x) << (r)) | ((x) >> (32 - (r)))) r 50 ompi/mpi/c/type_create_f90_complex.c int MPI_Type_create_f90_complex(int p, int r, MPI_Datatype *newtype) r 66 ompi/mpi/c/type_create_f90_complex.c if ((MPI_UNDEFINED == p && MPI_UNDEFINED == r)) { r 75 ompi/mpi/c/type_create_f90_complex.c r_key = r; r 77 ompi/mpi/c/type_create_f90_complex.c if( MPI_UNDEFINED == r ) r_key = 0; r 88 ompi/mpi/c/type_create_f90_complex.c if ( (LDBL_DIG < p) || (LDBL_MAX_10_EXP < r) || (-LDBL_MIN_10_EXP < r) ) *newtype = &ompi_mpi_datatype_null.dt; r 89 ompi/mpi/c/type_create_f90_complex.c else if( (DBL_DIG < p) || (DBL_MAX_10_EXP < r) || (-DBL_MIN_10_EXP < r) ) *newtype = &ompi_mpi_ldblcplex.dt; r 90 ompi/mpi/c/type_create_f90_complex.c else if( (FLT_DIG < p) || (FLT_MAX_10_EXP < r) || (-FLT_MIN_10_EXP < r) ) *newtype = &ompi_mpi_dblcplex.dt; r 92 ompi/mpi/c/type_create_f90_complex.c (sflt_dig < p) || (sflt_max_10_exp < r) || (-sflt_min_10_exp < r) ) *newtype = &ompi_mpi_cplex.dt; r 125 ompi/mpi/c/type_create_f90_complex.c a_i[1] = &r; r 46 ompi/mpi/c/type_create_f90_integer.c int MPI_Type_create_f90_integer(int r, MPI_Datatype *newtype) r 69 ompi/mpi/c/type_create_f90_integer.c if (r > 38) *newtype = &ompi_mpi_datatype_null.dt; r 71 ompi/mpi/c/type_create_f90_integer.c else if (r > 18) *newtype = &ompi_mpi_long_long_int.dt; r 73 ompi/mpi/c/type_create_f90_integer.c else if (r > 18) *newtype = &ompi_mpi_datatype_null.dt; r 76 ompi/mpi/c/type_create_f90_integer.c else if (r > 9) *newtype = &ompi_mpi_long.dt; r 79 ompi/mpi/c/type_create_f90_integer.c else if (r > 9) *newtype = &ompi_mpi_long_long_int.dt; r 81 ompi/mpi/c/type_create_f90_integer.c else if (r > 9) *newtype = &ompi_mpi_datatype_null.dt; r 84 ompi/mpi/c/type_create_f90_integer.c else if (r > 4) *newtype = &ompi_mpi_int.dt; r 85 ompi/mpi/c/type_create_f90_integer.c else if (r > 2) *newtype = &ompi_mpi_short.dt; r 94 ompi/mpi/c/type_create_f90_integer.c r, (void**)newtype ) ) { r 116 ompi/mpi/c/type_create_f90_integer.c a_i[0] = &r; r 119 ompi/mpi/c/type_create_f90_integer.c rc = opal_hash_table_set_value_uint32( &ompi_mpi_f90_integer_hashtable, r, datatype ); r 50 ompi/mpi/c/type_create_f90_real.c int MPI_Type_create_f90_real(int p, int r, MPI_Datatype *newtype) r 66 ompi/mpi/c/type_create_f90_real.c if ((MPI_UNDEFINED == p && MPI_UNDEFINED == r)) { r 75 ompi/mpi/c/type_create_f90_real.c r_key = r; r 77 ompi/mpi/c/type_create_f90_real.c if( MPI_UNDEFINED == r ) r_key = 0; r 88 ompi/mpi/c/type_create_f90_real.c if ( (LDBL_DIG < p) || (LDBL_MAX_10_EXP < r) || (-LDBL_MIN_10_EXP < r) ) *newtype = &ompi_mpi_datatype_null.dt; r 89 ompi/mpi/c/type_create_f90_real.c else if( (DBL_DIG < p) || (DBL_MAX_10_EXP < r) || (-DBL_MIN_10_EXP < r) ) *newtype = &ompi_mpi_long_double.dt; r 90 ompi/mpi/c/type_create_f90_real.c else if( (FLT_DIG < p) || (FLT_MAX_10_EXP < r) || (-FLT_MIN_10_EXP < r) ) *newtype = &ompi_mpi_double.dt; r 92 ompi/mpi/c/type_create_f90_real.c (sflt_dig < p) || (sflt_max_10_exp < r) || (-sflt_min_10_exp < r) ) *newtype = &ompi_mpi_float.dt; r 97 ompi/mpi/c/type_create_f90_real.c const int* a_i[2] = {&p, &r}; r 174 ompi/mpi/cxx/datatype.h static Datatype Create_f90_complex(int p, int r); r 176 ompi/mpi/cxx/datatype.h static Datatype Create_f90_integer(int r); r 178 ompi/mpi/cxx/datatype.h static Datatype Create_f90_real(int p, int r); r 226 ompi/mpi/cxx/datatype_inln.h MPI::Datatype::Create_f90_complex(int p, int r) r 229 ompi/mpi/cxx/datatype_inln.h (void) MPI_Type_create_f90_complex(p, r, &type); r 234 ompi/mpi/cxx/datatype_inln.h MPI::Datatype::Create_f90_integer(int r) r 237 ompi/mpi/cxx/datatype_inln.h (void) MPI_Type_create_f90_integer(r, &type); r 242 ompi/mpi/cxx/datatype_inln.h MPI::Datatype::Create_f90_real(int p, int r) r 245 ompi/mpi/cxx/datatype_inln.h (void) MPI_Type_create_f90_real(p, r, &type); r 34 ompi/mpi/cxx/request.h Request(const Request& r) : pmpi_request(r.pmpi_request) { } r 36 ompi/mpi/cxx/request.h Request(const PMPI::Request& r) : pmpi_request(r) { } r 40 ompi/mpi/cxx/request.h Request& operator=(const Request& r) { r 41 ompi/mpi/cxx/request.h pmpi_request = r.pmpi_request; return *this; } r 65 ompi/mpi/cxx/request.h Request(const Request& r) : mpi_request(r.mpi_request) { } r 67 ompi/mpi/cxx/request.h Request& operator=(const Request& r) { r 68 ompi/mpi/cxx/request.h mpi_request = r.mpi_request; return *this; } r 157 ompi/mpi/cxx/request.h Prequest(const PMPI::Prequest& r) : r 158 ompi/mpi/cxx/request.h Request((const PMPI::Request&)r), r 159 ompi/mpi/cxx/request.h pmpi_request(r) { } r 165 ompi/mpi/cxx/request.h Prequest& operator=(const Request& r) { r 166 ompi/mpi/cxx/request.h Request::operator=(r); r 167 ompi/mpi/cxx/request.h pmpi_request = (PMPI::Prequest)r; return *this; } r 169 ompi/mpi/cxx/request.h Prequest& operator=(const Prequest& r) { r 170 ompi/mpi/cxx/request.h Request::operator=(r); r 171 ompi/mpi/cxx/request.h pmpi_request = r.pmpi_request; return *this; } r 179 ompi/mpi/cxx/request.h Prequest& operator=(const Request& r) { r 180 ompi/mpi/cxx/request.h mpi_request = r; return *this; } r 182 ompi/mpi/cxx/request.h Prequest& operator=(const Prequest& r) { r 183 ompi/mpi/cxx/request.h mpi_request = r.mpi_request; return *this; } r 369 ompi/mpi/fortran/mpif-h/prototypes_mpi.h PN2(void, MPI_Type_create_f90_complex, mpi_type_create_f90_complex, MPI_TYPE_CREATE_F90_COMPLEX, (MPI_Fint *p, MPI_Fint *r, MPI_Fint *newtype, MPI_Fint *ierr)); r 370 ompi/mpi/fortran/mpif-h/prototypes_mpi.h PN2(void, MPI_Type_create_f90_integer, mpi_type_create_f90_integer, MPI_TYPE_CREATE_F90_INTEGER, (MPI_Fint *r, MPI_Fint *newtype, MPI_Fint *ierr)); r 371 ompi/mpi/fortran/mpif-h/prototypes_mpi.h PN2(void, MPI_Type_create_f90_real, mpi_type_create_f90_real, MPI_TYPE_CREATE_F90_REAL, (MPI_Fint *p, MPI_Fint *r, MPI_Fint *newtype, MPI_Fint *ierr)); r 41 ompi/mpi/fortran/mpif-h/type_create_f90_complex_f.c (MPI_Fint *p, MPI_Fint *r, MPI_Fint *newtype, MPI_Fint *ierr), r 42 ompi/mpi/fortran/mpif-h/type_create_f90_complex_f.c (p, r, newtype, ierr) ) r 61 ompi/mpi/fortran/mpif-h/type_create_f90_complex_f.c (MPI_Fint *p, MPI_Fint *r, MPI_Fint *newtype, MPI_Fint *ierr), r 62 ompi/mpi/fortran/mpif-h/type_create_f90_complex_f.c (p, r, newtype, ierr) ) r 69 ompi/mpi/fortran/mpif-h/type_create_f90_complex_f.c void ompi_type_create_f90_complex_f(MPI_Fint *p, MPI_Fint *r, r 76 ompi/mpi/fortran/mpif-h/type_create_f90_complex_f.c OMPI_FINT_2_INT(*r), r 41 ompi/mpi/fortran/mpif-h/type_create_f90_integer_f.c (MPI_Fint *r, MPI_Fint *newtype, MPI_Fint *ierr), r 42 ompi/mpi/fortran/mpif-h/type_create_f90_integer_f.c (r, newtype, ierr) ) r 61 ompi/mpi/fortran/mpif-h/type_create_f90_integer_f.c (MPI_Fint *r, MPI_Fint *newtype, MPI_Fint *ierr), r 62 ompi/mpi/fortran/mpif-h/type_create_f90_integer_f.c (r, newtype, ierr) ) r 69 ompi/mpi/fortran/mpif-h/type_create_f90_integer_f.c void ompi_type_create_f90_integer_f(MPI_Fint *r, MPI_Fint *newtype, r 75 ompi/mpi/fortran/mpif-h/type_create_f90_integer_f.c c_ierr = PMPI_Type_create_f90_integer(OMPI_FINT_2_INT(*r), &c_new); r 41 ompi/mpi/fortran/mpif-h/type_create_f90_real_f.c (MPI_Fint *p, MPI_Fint *r, MPI_Fint *newtype, MPI_Fint *ierr), r 42 ompi/mpi/fortran/mpif-h/type_create_f90_real_f.c (p, r, newtype, ierr) ) r 61 ompi/mpi/fortran/mpif-h/type_create_f90_real_f.c (MPI_Fint *p, MPI_Fint *r, MPI_Fint *newtype, MPI_Fint *ierr), r 62 ompi/mpi/fortran/mpif-h/type_create_f90_real_f.c (p, r, newtype, ierr) ) r 69 ompi/mpi/fortran/mpif-h/type_create_f90_real_f.c void ompi_type_create_f90_real_f(MPI_Fint *p, MPI_Fint *r, r 76 ompi/mpi/fortran/mpif-h/type_create_f90_real_f.c OMPI_FINT_2_INT(*r), r 3260 ompi/mpi/fortran/use-mpi-f08/bindings/mpi-f-interfaces-bind.h subroutine ompi_type_create_f90_complex_f(p,r,newtype,ierror) & r 3263 ompi/mpi/fortran/use-mpi-f08/bindings/mpi-f-interfaces-bind.h INTEGER, INTENT(IN) :: p, r r 3268 ompi/mpi/fortran/use-mpi-f08/bindings/mpi-f-interfaces-bind.h subroutine ompi_type_create_f90_integer_f(r,newtype,ierror) & r 3271 ompi/mpi/fortran/use-mpi-f08/bindings/mpi-f-interfaces-bind.h INTEGER, INTENT(IN) :: r r 3276 ompi/mpi/fortran/use-mpi-f08/bindings/mpi-f-interfaces-bind.h subroutine ompi_type_create_f90_real_f(p,r,newtype,ierror) & r 3279 ompi/mpi/fortran/use-mpi-f08/bindings/mpi-f-interfaces-bind.h INTEGER, INTENT(IN) :: p, r r 1435 ompi/mpi/fortran/use-mpi-tkr/mpi-f90-interfaces.h subroutine MPI_Type_create_f90_complex(p, r, newtype, ierror) r 1437 ompi/mpi/fortran/use-mpi-tkr/mpi-f90-interfaces.h integer, intent(in) :: r r 1447 ompi/mpi/fortran/use-mpi-tkr/mpi-f90-interfaces.h subroutine MPI_Type_create_f90_integer(r, newtype, ierror) r 1448 ompi/mpi/fortran/use-mpi-tkr/mpi-f90-interfaces.h integer, intent(in) :: r r 1458 ompi/mpi/fortran/use-mpi-tkr/mpi-f90-interfaces.h subroutine MPI_Type_create_f90_real(p, r, newtype, ierror) r 1460 ompi/mpi/fortran/use-mpi-tkr/mpi-f90-interfaces.h integer, intent(in) :: r r 1435 ompi/mpi/fortran/use-mpi-tkr/pmpi-f90-interfaces.h subroutine PMPI_Type_create_f90_complex(p, r, newtype, ierror) r 1437 ompi/mpi/fortran/use-mpi-tkr/pmpi-f90-interfaces.h integer, intent(in) :: r r 1447 ompi/mpi/fortran/use-mpi-tkr/pmpi-f90-interfaces.h subroutine PMPI_Type_create_f90_integer(r, newtype, ierror) r 1448 ompi/mpi/fortran/use-mpi-tkr/pmpi-f90-interfaces.h integer, intent(in) :: r r 1458 ompi/mpi/fortran/use-mpi-tkr/pmpi-f90-interfaces.h subroutine PMPI_Type_create_f90_real(p, r, newtype, ierror) r 1460 ompi/mpi/fortran/use-mpi-tkr/pmpi-f90-interfaces.h integer, intent(in) :: r r 124 ompi/mpi/java/c/mpi_MPI.c int r = opal_free_list_init(&ompi_java_buffers, r 138 ompi/mpi/java/c/mpi_MPI.c if(r != OPAL_SUCCESS) r 148 ompi/mpi/java/c/mpi_MPI.c r = (*env)->NewGlobalRef(env, c); r 151 ompi/mpi/java/c/mpi_MPI.c return r; r 89 ompi/mpi/java/java/Prequest.java long[] r = getHandles(requests); r 90 ompi/mpi/java/java/Prequest.java startAll(r); r 91 ompi/mpi/java/java/Prequest.java setHandles(requests, r); r 252 ompi/mpi/java/java/Request.java long[] r = getHandles(requests); r 254 ompi/mpi/java/java/Request.java waitAnyStatus(r, status.data); r 255 ompi/mpi/java/java/Request.java setHandles(requests, r); r 276 ompi/mpi/java/java/Request.java long[] r = getHandles(requests); r 277 ompi/mpi/java/java/Request.java int index = waitAny(r); r 278 ompi/mpi/java/java/Request.java setHandles(requests, r); r 299 ompi/mpi/java/java/Request.java long[] r = getHandles(requests); r 300 ompi/mpi/java/java/Request.java Status status = testAnyStatus(r); r 301 ompi/mpi/java/java/Request.java setHandles(requests, r); r 320 ompi/mpi/java/java/Request.java long[] r = getHandles(requests); r 321 ompi/mpi/java/java/Request.java int index = testAny(r); r 322 ompi/mpi/java/java/Request.java setHandles(requests, r); r 342 ompi/mpi/java/java/Request.java long[] r = getHandles(requests); r 343 ompi/mpi/java/java/Request.java Status[] status = waitAllStatus(r); r 344 ompi/mpi/java/java/Request.java setHandles(requests, r); r 361 ompi/mpi/java/java/Request.java long[] r = getHandles(requests); r 362 ompi/mpi/java/java/Request.java waitAll(r); r 363 ompi/mpi/java/java/Request.java setHandles(requests, r); r 382 ompi/mpi/java/java/Request.java long[] r = getHandles(requests); r 383 ompi/mpi/java/java/Request.java Status[] status = testAllStatus(r); r 384 ompi/mpi/java/java/Request.java setHandles(requests, r); r 403 ompi/mpi/java/java/Request.java long[] r = getHandles(requests); r 404 ompi/mpi/java/java/Request.java boolean completed = testAll(r); r 405 ompi/mpi/java/java/Request.java setHandles(requests, r); r 428 ompi/mpi/java/java/Request.java long[] r = getHandles(requests); r 429 ompi/mpi/java/java/Request.java Status[] status = waitSomeStatus(r); r 430 ompi/mpi/java/java/Request.java setHandles(requests, r); r 452 ompi/mpi/java/java/Request.java long[] r = getHandles(requests); r 453 ompi/mpi/java/java/Request.java int[] indexes = waitSome(r); r 454 ompi/mpi/java/java/Request.java setHandles(requests, r); r 472 ompi/mpi/java/java/Request.java long[] r = getHandles(requests); r 473 ompi/mpi/java/java/Request.java Status[] status = testSomeStatus(r); r 474 ompi/mpi/java/java/Request.java setHandles(requests, r); r 493 ompi/mpi/java/java/Request.java long[] r = getHandles(requests); r 494 ompi/mpi/java/java/Request.java int[] indexes = testSome(r); r 495 ompi/mpi/java/java/Request.java setHandles(requests, r); r 501 ompi/mpi/java/java/Request.java protected static long[] getHandles(Request[] r) r 503 ompi/mpi/java/java/Request.java long[] h = new long[r.length]; r 505 ompi/mpi/java/java/Request.java for(int i = 0; i < r.length; i++) { r 506 ompi/mpi/java/java/Request.java if(r[i] != null) r 507 ompi/mpi/java/java/Request.java h[i] = r[i].handle; r 515 ompi/mpi/java/java/Request.java protected static void setHandles(Request[] r, long[] h) r 517 ompi/mpi/java/java/Request.java for(int i = 0; i < r.length; i++) r 518 ompi/mpi/java/java/Request.java r[i].handle = h[i]; r 92 opal/include/opal/types.h } w, r; r 98 opal/include/opal/types.h r.l[0] = htonl(w.l[1]); r 99 opal/include/opal/types.h r.l[1] = htonl(w.l[0]); r 100 opal/include/opal/types.h return r.ll; r 116 opal/include/opal/types.h } w, r; r 122 opal/include/opal/types.h r.l[0] = ntohl(w.l[1]); r 123 opal/include/opal/types.h r.l[1] = ntohl(w.l[0]); r 124 opal/include/opal/types.h return r.ll; r 157 opal/include/opal/types.h } w, r; r 160 opal/include/opal/types.h r.arrayval[0] = w.arrayval[1]; r 161 opal/include/opal/types.h r.arrayval[1] = w.arrayval[0]; r 163 opal/include/opal/types.h return r.bigval; r 171 opal/include/opal/types.h } w, r; r 174 opal/include/opal/types.h r.arrayval[0] = w.arrayval[3]; r 175 opal/include/opal/types.h r.arrayval[1] = w.arrayval[2]; r 176 opal/include/opal/types.h r.arrayval[2] = w.arrayval[1]; r 177 opal/include/opal/types.h r.arrayval[3] = w.arrayval[0]; r 179 opal/include/opal/types.h return r.bigval; r 187 opal/include/opal/types.h } w, r; r 190 opal/include/opal/types.h r.arrayval[0] = w.arrayval[7]; r 191 opal/include/opal/types.h r.arrayval[1] = w.arrayval[6]; r 192 opal/include/opal/types.h r.arrayval[2] = w.arrayval[5]; r 193 opal/include/opal/types.h r.arrayval[3] = w.arrayval[4]; r 194 opal/include/opal/types.h r.arrayval[4] = w.arrayval[3]; r 195 opal/include/opal/types.h r.arrayval[5] = w.arrayval[2]; r 196 opal/include/opal/types.h r.arrayval[6] = w.arrayval[1]; r 197 opal/include/opal/types.h r.arrayval[7] = w.arrayval[0]; r 199 opal/include/opal/types.h return r.bigval; r 59 opal/mca/btl/usnic/btl_usnic_util.h int r = 32; r 66 opal/mca/btl/usnic/btl_usnic_util.h r -= 16; r 70 opal/mca/btl/usnic/btl_usnic_util.h r -= 8; r 74 opal/mca/btl/usnic/btl_usnic_util.h r -= 4; r 78 opal/mca/btl/usnic/btl_usnic_util.h r -= 2; r 81 opal/mca/btl/usnic/btl_usnic_util.h r -= 1; r 83 opal/mca/btl/usnic/btl_usnic_util.h return r; r 530 opal/mca/event/libevent2022/libevent/arc4random.c ARC4RANDOM_UINT32 r, min; r 554 opal/mca/event/libevent2022/libevent/arc4random.c r = arc4random(); r 555 opal/mca/event/libevent2022/libevent/arc4random.c if (r >= min) r 559 opal/mca/event/libevent2022/libevent/arc4random.c return r % upper_bound; r 2506 opal/mca/event/libevent2022/libevent/buffer.c int r; r 2523 opal/mca/event/libevent2022/libevent/buffer.c r = memcmp(chain->buffer + chain->misalign + position, mem, r 2525 opal/mca/event/libevent2022/libevent/buffer.c if (r) r 2526 opal/mca/event/libevent2022/libevent/buffer.c return r; r 174 opal/mca/event/libevent2022/libevent/buffer_iocp.c int r = -1; r 190 opal/mca/event/libevent2022/libevent/buffer_iocp.c r = 0; r 237 opal/mca/event/libevent2022/libevent/buffer_iocp.c r = 0; r 240 opal/mca/event/libevent2022/libevent/buffer_iocp.c return r; r 248 opal/mca/event/libevent2022/libevent/buffer_iocp.c int r = -1, i; r 303 opal/mca/event/libevent2022/libevent/buffer_iocp.c r = 0; r 306 opal/mca/event/libevent2022/libevent/buffer_iocp.c return r; r 412 opal/mca/event/libevent2022/libevent/bufferevent.c int r = 0; r 423 opal/mca/event/libevent2022/libevent/bufferevent.c r = -1; r 426 opal/mca/event/libevent2022/libevent/bufferevent.c return r; r 434 opal/mca/event/libevent2022/libevent/bufferevent.c int r = 0; r 448 opal/mca/event/libevent2022/libevent/bufferevent.c r = bufev->be_ops->adj_timeouts(bufev); r 451 opal/mca/event/libevent2022/libevent/bufferevent.c return r; r 482 opal/mca/event/libevent2022/libevent/bufferevent.c int r = 0; r 491 opal/mca/event/libevent2022/libevent/bufferevent.c r = -1; r 494 opal/mca/event/libevent2022/libevent/bufferevent.c return r; r 500 opal/mca/event/libevent2022/libevent/bufferevent.c int r = 0; r 506 opal/mca/event/libevent2022/libevent/bufferevent.c r = -1; r 509 opal/mca/event/libevent2022/libevent/bufferevent.c return r; r 569 opal/mca/event/libevent2022/libevent/bufferevent.c int r = -1; r 572 opal/mca/event/libevent2022/libevent/bufferevent.c r = bufev->be_ops->flush(bufev, iotype, mode); r 574 opal/mca/event/libevent2022/libevent/bufferevent.c return r; r 592 opal/mca/event/libevent2022/libevent/bufferevent.c struct bufferevent_private *r = BEV_UPCAST(recipient); r 593 opal/mca/event/libevent2022/libevent/bufferevent.c if (d->lock != r->lock) r 595 opal/mca/event/libevent2022/libevent/bufferevent.c if (r->own_lock) r 599 opal/mca/event/libevent2022/libevent/bufferevent.c r->own_lock = 1; r 771 opal/mca/event/libevent2022/libevent/bufferevent.c short r; r 773 opal/mca/event/libevent2022/libevent/bufferevent.c r = bufev->enabled; r 775 opal/mca/event/libevent2022/libevent/bufferevent.c return r; r 133 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c int r = 0; r 149 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c r = evbuffer_remove(input, out, outlen); r 152 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c return r; r 384 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c int r; r 385 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c r = _bufferevent_add_event(&bev->ev_read, &bev->timeout_read); r 386 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (r == 0 && bev_ssl->read_blocked_on_write) r 387 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c r = _bufferevent_add_event(&bev->ev_write, r 389 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c return r; r 399 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c int r = 0; r 404 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c r = _bufferevent_add_event(&bev->ev_write, &bev->timeout_write); r 405 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (!r && bev_ssl->write_blocked_on_read) r 406 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c r = _bufferevent_add_event(&bev->ev_read, r 409 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c return r; r 461 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c int r = 0; r 466 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c r = start_reading(bev_ssl); r 467 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c return r; r 475 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c int r = 0; r 480 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c r = start_writing(bev_ssl); r 481 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c return r; r 550 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c unsigned long r = num_r - bev_ssl->counts.n_read; r 553 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (r) r 554 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c _bufferevent_decrement_read_buckets(&bev_ssl->bev, r); r 570 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c int r, n, i, n_used = 0, atmost; r 588 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c r = SSL_read(bev_ssl->ssl, space[i].iov_base, space[i].iov_len); r 589 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (r>0) { r 595 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c space[i].iov_len = r; r 598 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c int err = SSL_get_error(bev_ssl->ssl, r); r 615 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c conn_closed(bev_ssl, err, r); r 637 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c int i, r, n, n_written = 0; r 664 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c r = SSL_write(bev_ssl->ssl, space[i].iov_base, r 666 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (r > 0) { r 671 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c n_written += r; r 675 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c int err = SSL_get_error(bev_ssl->ssl, r); r 694 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c conn_closed(bev_ssl, err, r); r 768 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c int r; r 773 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c r = do_write(bev_ssl, WRITE_FRAME); r 774 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (r & (OP_BLOCKED|OP_ERR)) r 783 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c r = do_read(bev_ssl, n_to_read); r 784 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c all_result_flags |= r; r 786 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (r & (OP_BLOCKED|OP_ERR)) r 841 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c int r; r 847 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c r = do_read(bev_ssl, 1024); /* XXXX 1024 is a hack */ r 848 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (r & OP_MADE_PROGRESS) { r 856 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (r & (OP_ERR|OP_BLOCKED)) r 874 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c r = do_write(bev_ssl, n_to_write); r 875 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (r & (OP_BLOCKED|OP_ERR)) r 994 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c int r; r 1003 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c r = SSL_do_handshake(bev_ssl->ssl); r 1008 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c if (r==1) { r 1018 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c int err = SSL_get_error(bev_ssl->ssl, r); r 1034 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c conn_closed(bev_ssl, err, r); r 1112 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c int r = 0; r 1117 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c r = _bufferevent_add_event(&bev_ssl->bev.bev.ev_write, r 1122 opal/mca/event/libevent2022/libevent/bufferevent_openssl.c (void)r; r 146 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c struct ev_token_bucket_cfg *r; r 161 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c r = mm_calloc(1, sizeof(struct ev_token_bucket_cfg)); r 162 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if (!r) r 164 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c r->read_rate = read_rate; r 165 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c r->write_rate = write_rate; r 166 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c r->read_maximum = read_burst; r 167 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c r->write_maximum = write_burst; r 168 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c memcpy(&r->tick_timeout, tick_len, sizeof(struct timeval)); r 169 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c r->msec_per_tick = (tick_len->tv_sec * 1000) + r 171 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c return r; r 278 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c int r = 0; r 289 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c r = -1; r 309 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c return r; r 316 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c int r = 0; r 327 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c r = -1; r 347 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c return r; r 564 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c int r = -1; r 582 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c r = 0; r 591 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c r = 0; r 630 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c r = 0; r 634 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c return r; r 820 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c ev_ssize_t r; r 826 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c r = bevp->rate_limiting->limit.read_limit; r 828 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c r = EV_SSIZE_MAX; r 831 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c return r; r 839 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c ev_ssize_t r; r 845 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c r = bevp->rate_limiting->limit.write_limit; r 847 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c r = EV_SSIZE_MAX; r 850 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c return r; r 856 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c ev_ssize_t r; r 858 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c r = _bufferevent_get_read_max(BEV_UPCAST(bev)); r 860 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c return r; r 866 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c ev_ssize_t r; r 868 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c r = _bufferevent_get_write_max(BEV_UPCAST(bev)); r 870 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c return r; r 880 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c ev_ssize_t r; r 882 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c r = grp->rate_limit.read_limit; r 884 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c return r; r 893 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c ev_ssize_t r; r 895 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c r = grp->rate_limit.write_limit; r 897 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c return r; r 903 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c int r = 0; r 916 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c r = -1; r 924 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c return r; r 932 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c int r = 0; r 945 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c r = -1; r 953 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c return r; r 960 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c int r = 0; r 973 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c return r; r 980 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c int r = 0; r 993 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c return r; r 360 opal/mca/event/libevent2022/libevent/bufferevent_sock.c int r = 0; r 384 opal/mca/event/libevent2022/libevent/bufferevent_sock.c r = bufferevent_async_connect(bev, fd, sa, socklen); r 385 opal/mca/event/libevent2022/libevent/bufferevent_sock.c if (r < 0) r 392 opal/mca/event/libevent2022/libevent/bufferevent_sock.c r = evutil_socket_connect(&fd, sa, socklen); r 393 opal/mca/event/libevent2022/libevent/bufferevent_sock.c if (r < 0) r 406 opal/mca/event/libevent2022/libevent/bufferevent_sock.c if (r == 0) { r 412 opal/mca/event/libevent2022/libevent/bufferevent_sock.c } else if (r == 1) { r 444 opal/mca/event/libevent2022/libevent/bufferevent_sock.c int r; r 461 opal/mca/event/libevent2022/libevent/bufferevent_sock.c r = bufferevent_socket_connect(bev, ai->ai_addr, (int)ai->ai_addrlen); r 462 opal/mca/event/libevent2022/libevent/bufferevent_sock.c (void)r; r 601 opal/mca/event/libevent2022/libevent/bufferevent_sock.c int r = 0; r 604 opal/mca/event/libevent2022/libevent/bufferevent_sock.c r = -1; r 607 opal/mca/event/libevent2022/libevent/bufferevent_sock.c r = -1; r 609 opal/mca/event/libevent2022/libevent/bufferevent_sock.c return r; r 644 opal/mca/event/libevent2022/libevent/bufferevent_sock.c int r = -1; r 655 opal/mca/event/libevent2022/libevent/bufferevent_sock.c r = 0; r 658 opal/mca/event/libevent2022/libevent/bufferevent_sock.c return r; r 339 opal/mca/event/libevent2022/libevent/epoll.c int r = 0; r 345 opal/mca/event/libevent2022/libevent/epoll.c r = -1; r 348 opal/mca/event/libevent2022/libevent/epoll.c return (r); r 1363 opal/mca/event/libevent2022/libevent/evdns.c const int r = recvfrom(ns->socket, (void*)packet, r 1366 opal/mca/event/libevent2022/libevent/evdns.c if (r < 0) { r 1385 opal/mca/event/libevent2022/libevent/evdns.c reply_parse(ns->base, packet, r); r 1396 opal/mca/event/libevent2022/libevent/evdns.c int r; r 1401 opal/mca/event/libevent2022/libevent/evdns.c r = recvfrom(s->socket, (void*)packet, sizeof(packet), 0, r 1403 opal/mca/event/libevent2022/libevent/evdns.c if (r < 0) { r 1412 opal/mca/event/libevent2022/libevent/evdns.c request_parse(packet, r, s, (struct sockaddr*) &addr, addrlen); r 1423 opal/mca/event/libevent2022/libevent/evdns.c int r = sendto(port->socket, req->response, (int)req->response_len, 0, r 1425 opal/mca/event/libevent2022/libevent/evdns.c if (r < 0) { r 1879 opal/mca/event/libevent2022/libevent/evdns.c off_t j = 0, r; r 1923 opal/mca/event/libevent2022/libevent/evdns.c r = dnsname_to_labels(buf, buf_len, j, item->name, strlen(item->name), &table); r 1924 opal/mca/event/libevent2022/libevent/evdns.c if (r < 0) r 1926 opal/mca/event/libevent2022/libevent/evdns.c j = r; r 1935 opal/mca/event/libevent2022/libevent/evdns.c r = dnsname_to_labels(buf, buf_len, j, item->data, strlen(item->data), &table); r 1936 opal/mca/event/libevent2022/libevent/evdns.c if (r < 0) r 1938 opal/mca/event/libevent2022/libevent/evdns.c j = r; r 1977 opal/mca/event/libevent2022/libevent/evdns.c int r = -1; r 1981 opal/mca/event/libevent2022/libevent/evdns.c if ((r = evdns_server_request_format_response(req, err))<0) r 1985 opal/mca/event/libevent2022/libevent/evdns.c r = sendto(port->socket, req->response, (int)req->response_len, 0, r 1987 opal/mca/event/libevent2022/libevent/evdns.c if (r<0) { r 2011 opal/mca/event/libevent2022/libevent/evdns.c r = 1; r 2015 opal/mca/event/libevent2022/libevent/evdns.c r = 0; r 2022 opal/mca/event/libevent2022/libevent/evdns.c r = 0; r 2025 opal/mca/event/libevent2022/libevent/evdns.c return r; r 2189 opal/mca/event/libevent2022/libevent/evdns.c int r; r 2192 opal/mca/event/libevent2022/libevent/evdns.c r = sendto(server->socket, (void*)req->request, req->request_len, 0, r 2194 opal/mca/event/libevent2022/libevent/evdns.c if (r < 0) { r 2200 opal/mca/event/libevent2022/libevent/evdns.c } else if (r != (int)req->request_len) { r 2215 opal/mca/event/libevent2022/libevent/evdns.c int retcode = 0, r; r 2236 opal/mca/event/libevent2022/libevent/evdns.c r = evdns_request_transmit_to(req, req->ns); r 2237 opal/mca/event/libevent2022/libevent/evdns.c switch (r) { r 3291 opal/mca/event/libevent2022/libevent/evdns.c const int r = strtol(str, &endptr, 10); r 3293 opal/mca/event/libevent2022/libevent/evdns.c return r; r 3316 opal/mca/event/libevent2022/libevent/evdns.c int r = strtoint(str); r 3317 opal/mca/event/libevent2022/libevent/evdns.c if (r == -1) r 3318 opal/mca/event/libevent2022/libevent/evdns.c return r; r 3319 opal/mca/event/libevent2022/libevent/evdns.c else if (r<min) r 3321 opal/mca/event/libevent2022/libevent/evdns.c else if (r>max) r 3324 opal/mca/event/libevent2022/libevent/evdns.c return r; r 3617 opal/mca/event/libevent2022/libevent/evdns.c int r; r 3630 opal/mca/event/libevent2022/libevent/evdns.c r = evdns_base_nameserver_ip_add(base, buf); r 3632 opal/mca/event/libevent2022/libevent/evdns.c if (r) return r; r 3649 opal/mca/event/libevent2022/libevent/evdns.c int status = 0, r, added_any; r 3669 opal/mca/event/libevent2022/libevent/evdns.c r = fn(fixed, &size); r 3670 opal/mca/event/libevent2022/libevent/evdns.c if (r != ERROR_SUCCESS && r != ERROR_BUFFER_OVERFLOW) { r 3674 opal/mca/event/libevent2022/libevent/evdns.c if (r != ERROR_SUCCESS) { r 3679 opal/mca/event/libevent2022/libevent/evdns.c r = fn(fixed, &size); r 3680 opal/mca/event/libevent2022/libevent/evdns.c if (r != ERROR_SUCCESS) { r 3691 opal/mca/event/libevent2022/libevent/evdns.c r = evdns_nameserver_ip_add_line(base, ns->IpAddress.String); r 3692 opal/mca/event/libevent2022/libevent/evdns.c if (r) { r 3695 opal/mca/event/libevent2022/libevent/evdns.c status = r; r 3751 opal/mca/event/libevent2022/libevent/evdns.c int r; r 3771 opal/mca/event/libevent2022/libevent/evdns.c r = RegOpenKeyEx(nt_key, TEXT("Interfaces"), 0, r 3774 opal/mca/event/libevent2022/libevent/evdns.c if (r != ERROR_SUCCESS) { r 3806 opal/mca/event/libevent2022/libevent/evdns.c int r; r 3817 opal/mca/event/libevent2022/libevent/evdns.c r = load_nameservers_from_registry(base); r 3825 opal/mca/event/libevent2022/libevent/evdns.c return r; r 3890 opal/mca/event/libevent2022/libevent/evdns.c int r; r 3892 opal/mca/event/libevent2022/libevent/evdns.c r = evdns_base_config_windows_nameservers(base); r 3894 opal/mca/event/libevent2022/libevent/evdns.c r = evdns_base_resolv_conf_parse(base, DNS_OPTIONS_ALL, "/etc/resolv.conf"); r 3896 opal/mca/event/libevent2022/libevent/evdns.c if (r == -1) { r 4140 opal/mca/event/libevent2022/libevent/evdns.c struct evdns_request *r; r 4239 opal/mca/event/libevent2022/libevent/evdns.c if (data->ipv4_request.r) { r 4242 opal/mca/event/libevent2022/libevent/evdns.c evdns_cancel_request(NULL, data->ipv4_request.r); r 4248 opal/mca/event/libevent2022/libevent/evdns.c if (data->ipv6_request.r) { r 4251 opal/mca/event/libevent2022/libevent/evdns.c evdns_cancel_request(NULL, data->ipv6_request.r); r 4334 opal/mca/event/libevent2022/libevent/evdns.c if (other_req->r == NULL) r 4338 opal/mca/event/libevent2022/libevent/evdns.c req->r = NULL; r 4343 opal/mca/event/libevent2022/libevent/evdns.c if (other_req->r == NULL) r 4366 opal/mca/event/libevent2022/libevent/evdns.c if (other_req->r) { r 4392 opal/mca/event/libevent2022/libevent/evdns.c if (other_req->r) { r 4433 opal/mca/event/libevent2022/libevent/evdns.c if (other_req->r) { r 4434 opal/mca/event/libevent2022/libevent/evdns.c evdns_cancel_request(NULL, other_req->r); r 4440 opal/mca/event/libevent2022/libevent/evdns.c if (other_req->r == NULL) r 4447 opal/mca/event/libevent2022/libevent/evdns.c if (other_req->r) { r 4627 opal/mca/event/libevent2022/libevent/evdns.c data->ipv4_request.r = evdns_base_resolve_ipv4(dns_base, r 4631 opal/mca/event/libevent2022/libevent/evdns.c data->ipv4_request.r->current_req->put_cname_in_ptr = r 4638 opal/mca/event/libevent2022/libevent/evdns.c data->ipv6_request.r = evdns_base_resolve_ipv6(dns_base, r 4642 opal/mca/event/libevent2022/libevent/evdns.c data->ipv6_request.r->current_req->put_cname_in_ptr = r 4649 opal/mca/event/libevent2022/libevent/evdns.c if (data->ipv4_request.r || data->ipv6_request.r) { r 4668 opal/mca/event/libevent2022/libevent/evdns.c if (data->ipv4_request.r) r 4669 opal/mca/event/libevent2022/libevent/evdns.c evdns_cancel_request(data->evdns_base, data->ipv4_request.r); r 4670 opal/mca/event/libevent2022/libevent/evdns.c if (data->ipv6_request.r) r 4671 opal/mca/event/libevent2022/libevent/evdns.c evdns_cancel_request(data->evdns_base, data->ipv6_request.r); r 395 opal/mca/event/libevent2022/libevent/event.c int r; r 404 opal/mca/event/libevent2022/libevent/event.c r = evutil_gettimeofday(tv, NULL); r 411 opal/mca/event/libevent2022/libevent/event.c r = 0; r 414 opal/mca/event/libevent2022/libevent/event.c return r; r 636 opal/mca/event/libevent2022/libevent/event.c int r; r 641 opal/mca/event/libevent2022/libevent/event.c r = evthread_make_base_notifiable(base); r 642 opal/mca/event/libevent2022/libevent/event.c if (r<0) { r 1512 opal/mca/event/libevent2022/libevent/event.c int r = 0; r 1520 opal/mca/event/libevent2022/libevent/event.c r = evthread_notify_base(event_base); r 1522 opal/mca/event/libevent2022/libevent/event.c r = (0); r 1525 opal/mca/event/libevent2022/libevent/event.c return r; r 1806 opal/mca/event/libevent2022/libevent/event.c int r; r 1807 opal/mca/event/libevent2022/libevent/event.c r = event_assign(ev, current_base, fd, events, callback, arg); r 1808 opal/mca/event/libevent2022/libevent/event.c EVUTIL_ASSERT(r == 0); r 2004 opal/mca/event/libevent2022/libevent/event.c int r; r 2007 opal/mca/event/libevent2022/libevent/event.c r = send(base->th_notify_fd[1], buf, 1, 0); r 2009 opal/mca/event/libevent2022/libevent/event.c r = write(base->th_notify_fd[1], buf, 1); r 2011 opal/mca/event/libevent2022/libevent/event.c return (r < 0 && errno != EAGAIN) ? -1 : 0; r 2021 opal/mca/event/libevent2022/libevent/event.c int r; r 2023 opal/mca/event/libevent2022/libevent/event.c r = write(base->th_notify_fd[0], (void*) &msg, sizeof(msg)); r 2024 opal/mca/event/libevent2022/libevent/event.c } while (r < 0 && errno == EAGAIN); r 2026 opal/mca/event/libevent2022/libevent/event.c return (r < 0) ? -1 : 0; r 2740 opal/mca/event/libevent2022/libevent/event.c ev_ssize_t r; r 2743 opal/mca/event/libevent2022/libevent/event.c r = read(fd, (void*) &msg, sizeof(msg)); r 2744 opal/mca/event/libevent2022/libevent/event.c if (r<0 && errno != EAGAIN) { r 238 opal/mca/event/libevent2022/libevent/event_iocp.c int i, r, ok=1; r 240 opal/mca/event/libevent2022/libevent/event_iocp.c r = PostQueuedCompletionStatus(port->port, 0, NOTIFICATION_KEY, r 242 opal/mca/event/libevent2022/libevent/event_iocp.c if (!r) r 279 opal/mca/event/libevent2022/libevent/event_iocp.c BOOL r; r 281 opal/mca/event/libevent2022/libevent/event_iocp.c r = PostQueuedCompletionStatus(port->port, n, key, &o->overlapped); r 282 opal/mca/event/libevent2022/libevent/event_iocp.c return (r==0) ? -1 : 0; r 97 opal/mca/event/libevent2022/libevent/evrpc.c int r; r 100 opal/mca/event/libevent2022/libevent/evrpc.c r = evrpc_unregister_rpc(base, rpc->uri); r 101 opal/mca/event/libevent2022/libevent/evrpc.c EVUTIL_ASSERT(r == 0); r 108 opal/mca/event/libevent2022/libevent/evrpc.c r = evrpc_remove_hook(base, EVRPC_INPUT, hook); r 109 opal/mca/event/libevent2022/libevent/evrpc.c EVUTIL_ASSERT(r); r 112 opal/mca/event/libevent2022/libevent/evrpc.c r = evrpc_remove_hook(base, EVRPC_OUTPUT, hook); r 113 opal/mca/event/libevent2022/libevent/evrpc.c EVUTIL_ASSERT(r); r 253 opal/mca/event/libevent2022/libevent/evrpc.c int r; r 269 opal/mca/event/libevent2022/libevent/evrpc.c r = evhttp_del_cb(base->http_server, registered_uri); r 270 opal/mca/event/libevent2022/libevent/evrpc.c EVUTIL_ASSERT(r == 0); r 546 opal/mca/event/libevent2022/libevent/evrpc.c int r; r 564 opal/mca/event/libevent2022/libevent/evrpc.c r = evrpc_remove_hook(pool, EVRPC_INPUT, hook); r 565 opal/mca/event/libevent2022/libevent/evrpc.c EVUTIL_ASSERT(r); r 569 opal/mca/event/libevent2022/libevent/evrpc.c r = evrpc_remove_hook(pool, EVRPC_OUTPUT, hook); r 570 opal/mca/event/libevent2022/libevent/evrpc.c EVUTIL_ASSERT(r); r 138 opal/mca/event/libevent2022/libevent/evthread-internal.h int r = ompi__evthread_lock_fns.lock(EVTHREAD_TRY, lock); r 139 opal/mca/event/libevent2022/libevent/evthread-internal.h return !r; r 252 opal/mca/event/libevent2022/libevent/evthread-internal.h int r = _evthreadimpl_lock_lock(EVTHREAD_TRY, lock); r 253 opal/mca/event/libevent2022/libevent/evthread-internal.h return !r; r 256 opal/mca/event/libevent2022/libevent/evthread.c int r; r 261 opal/mca/event/libevent2022/libevent/evthread.c r = _original_cond_fns.wait_condition(_cond, lock->lock, tv); r 263 opal/mca/event/libevent2022/libevent/evthread.c return r; r 93 opal/mca/event/libevent2022/libevent/evthread_pthread.c } r; r 95 opal/mca/event/libevent2022/libevent/evthread_pthread.c memset(&r, 0, sizeof(r)); r 97 opal/mca/event/libevent2022/libevent/evthread_pthread.c r.thr = pthread_self(); r 98 opal/mca/event/libevent2022/libevent/evthread_pthread.c return (unsigned long)r.id; r 126 opal/mca/event/libevent2022/libevent/evthread_pthread.c int r; r 128 opal/mca/event/libevent2022/libevent/evthread_pthread.c r = pthread_cond_broadcast(cond); r 130 opal/mca/event/libevent2022/libevent/evthread_pthread.c r = pthread_cond_signal(cond); r 131 opal/mca/event/libevent2022/libevent/evthread_pthread.c return r ? -1 : 0; r 137 opal/mca/event/libevent2022/libevent/evthread_pthread.c int r; r 148 opal/mca/event/libevent2022/libevent/evthread_pthread.c r = pthread_cond_timedwait(cond, lock, &ts); r 149 opal/mca/event/libevent2022/libevent/evthread_pthread.c if (r == ETIMEDOUT) r 151 opal/mca/event/libevent2022/libevent/evthread_pthread.c else if (r) r 156 opal/mca/event/libevent2022/libevent/evthread_pthread.c r = pthread_cond_wait(cond, lock); r 157 opal/mca/event/libevent2022/libevent/evthread_pthread.c return r ? -1 : 0; r 129 opal/mca/event/libevent2022/libevent/evutil.c int fd, r; r 164 opal/mca/event/libevent2022/libevent/evutil.c while ((r = read(fd, mem+read_so_far, N_TO_READ(st.st_size - read_so_far))) > 0) { r 165 opal/mca/event/libevent2022/libevent/evutil.c read_so_far += r; r 171 opal/mca/event/libevent2022/libevent/evutil.c if (r < 0) { r 373 opal/mca/event/libevent2022/libevent/evutil.c ev_int64_t r; r 376 opal/mca/event/libevent2022/libevent/evutil.c r = (ev_int64_t) _atoi64(s); r 385 opal/mca/event/libevent2022/libevent/evutil.c return r; r 389 opal/mca/event/libevent2022/libevent/evutil.c long long r; r 394 opal/mca/event/libevent2022/libevent/evutil.c n = sscanf(s, "%lld", &r); r 400 opal/mca/event/libevent2022/libevent/evutil.c r = (long long) ru; r 417 opal/mca/event/libevent2022/libevent/evutil.c return r; r 560 opal/mca/event/libevent2022/libevent/evutil.c int r; r 573 opal/mca/event/libevent2022/libevent/evutil.c r = evutil_inet_pton(AF_INET, "18.244.0.188", &sin.sin_addr); r 574 opal/mca/event/libevent2022/libevent/evutil.c EVUTIL_ASSERT(r); r 579 opal/mca/event/libevent2022/libevent/evutil.c r = evutil_inet_pton(AF_INET6, "2001:4860:b002::68", &sin6.sin6_addr); r 580 opal/mca/event/libevent2022/libevent/evutil.c EVUTIL_ASSERT(r); r 1091 opal/mca/event/libevent2022/libevent/evutil.c int r, r2; r 1105 opal/mca/event/libevent2022/libevent/evutil.c r = getaddrinfo("1.2.3.4", "80", &hints, &ai); r 1108 opal/mca/event/libevent2022/libevent/evutil.c if (r2 == 0 && r != 0) { r 1307 opal/mca/event/libevent2022/libevent/evutil.c int r; r 1308 opal/mca/event/libevent2022/libevent/evutil.c r = gethostbyname_r(nodename, &hostent, buf, sizeof(buf), &ent, r 1551 opal/mca/event/libevent2022/libevent/evutil.c int r; r 1554 opal/mca/event/libevent2022/libevent/evutil.c r = evutil_vsnprintf(buf, buflen, format, ap); r 1556 opal/mca/event/libevent2022/libevent/evutil.c return r; r 1562 opal/mca/event/libevent2022/libevent/evutil.c int r; r 1566 opal/mca/event/libevent2022/libevent/evutil.c r = _vsnprintf(buf, buflen, format, ap); r 1567 opal/mca/event/libevent2022/libevent/evutil.c if (r < 0) r 1568 opal/mca/event/libevent2022/libevent/evutil.c r = _vscprintf(format, ap); r 1575 opal/mca/event/libevent2022/libevent/evutil.c r = _xpg5_vsnprintf(buf, buflen, format, ap); r 1577 opal/mca/event/libevent2022/libevent/evutil.c r = vsnprintf(buf, buflen, format, ap); r 1580 opal/mca/event/libevent2022/libevent/evutil.c return r; r 1595 opal/mca/event/libevent2022/libevent/evutil.c int r; r 1596 opal/mca/event/libevent2022/libevent/evutil.c r = evutil_snprintf(dst, len, "%d.%d.%d.%d", r 1601 opal/mca/event/libevent2022/libevent/evutil.c if (r<0||(size_t)r>=len) r 1741 opal/mca/event/libevent2022/libevent/evutil.c long r = strtol(src, &next, 16); r 1746 opal/mca/event/libevent2022/libevent/evutil.c if (r<0 || r>65536) r 1749 opal/mca/event/libevent2022/libevent/evutil.c words[i++] = (ev_uint16_t)r; r 1930 opal/mca/event/libevent2022/libevent/evutil.c int r; r 1931 opal/mca/event/libevent2022/libevent/evutil.c if (0 != (r = (sa1->sa_family - sa2->sa_family))) r 1932 opal/mca/event/libevent2022/libevent/evutil.c return r; r 1943 opal/mca/event/libevent2022/libevent/evutil.c (r = ((int)sin1->sin_port - (int)sin2->sin_port))) r 1944 opal/mca/event/libevent2022/libevent/evutil.c return r; r 1953 opal/mca/event/libevent2022/libevent/evutil.c if ((r = memcmp(sin1->sin6_addr.s6_addr, sin2->sin6_addr.s6_addr, 16))) r 1954 opal/mca/event/libevent2022/libevent/evutil.c return r; r 1956 opal/mca/event/libevent2022/libevent/evutil.c (r = ((int)sin1->sin6_port - (int)sin2->sin6_port))) r 1957 opal/mca/event/libevent2022/libevent/evutil.c return r; r 184 opal/mca/event/libevent2022/libevent/ht-internal.h struct type **p, *r; \ r 189 opal/mca/event/libevent2022/libevent/ht-internal.h r = *p; \ r 191 opal/mca/event/libevent2022/libevent/ht-internal.h if (r && (r!=elm)) { \ r 192 opal/mca/event/libevent2022/libevent/ht-internal.h elm->field.hte_next = r->field.hte_next; \ r 193 opal/mca/event/libevent2022/libevent/ht-internal.h r->field.hte_next = NULL; \ r 194 opal/mca/event/libevent2022/libevent/ht-internal.h return r; \ r 205 opal/mca/event/libevent2022/libevent/ht-internal.h struct type **p, *r; \ r 210 opal/mca/event/libevent2022/libevent/ht-internal.h r = *p; \ r 211 opal/mca/event/libevent2022/libevent/ht-internal.h *p = r->field.hte_next; \ r 212 opal/mca/event/libevent2022/libevent/ht-internal.h r->field.hte_next = NULL; \ r 214 opal/mca/event/libevent2022/libevent/ht-internal.h return r; \ r 3825 opal/mca/event/libevent2022/libevent/http.c int on = 1, r; r 3848 opal/mca/event/libevent2022/libevent/http.c r = bind(fd, ai->ai_addr, (ev_socklen_t)ai->ai_addrlen); r 3849 opal/mca/event/libevent2022/libevent/http.c if (r == -1) r 282 opal/mca/event/libevent2022/libevent/listener.c int r; r 286 opal/mca/event/libevent2022/libevent/listener.c r = lev->ops->enable(lev); r 288 opal/mca/event/libevent2022/libevent/listener.c r = 0; r 290 opal/mca/event/libevent2022/libevent/listener.c return r; r 296 opal/mca/event/libevent2022/libevent/listener.c int r; r 299 opal/mca/event/libevent2022/libevent/listener.c r = lev->ops->disable(lev); r 301 opal/mca/event/libevent2022/libevent/listener.c return r; r 102 opal/mca/event/libevent2022/libevent/sample/dns-example.c int i, r; r 111 opal/mca/event/libevent2022/libevent/sample/dns-example.c r = evdns_server_request_add_a_reply(req, req->questions[i]->name, r 113 opal/mca/event/libevent2022/libevent/sample/dns-example.c if (r<0) r 118 opal/mca/event/libevent2022/libevent/sample/dns-example.c r = evdns_server_request_add_ptr_reply(req, NULL, req->questions[i]->name, r 120 opal/mca/event/libevent2022/libevent/sample/dns-example.c if (r<0) r 128 opal/mca/event/libevent2022/libevent/sample/dns-example.c r = evdns_server_request_respond(req, 0); r 129 opal/mca/event/libevent2022/libevent/sample/dns-example.c if (r<0) r 255 opal/mca/event/libevent2022/libevent/sample/le-proxy.c int r; r 260 opal/mca/event/libevent2022/libevent/sample/le-proxy.c r = RAND_poll(); r 261 opal/mca/event/libevent2022/libevent/sample/le-proxy.c if (r == 0) { r 433 opal/mca/event/libevent2022/libevent/test/regress.c int r = write(pair2[1], buf, sizeof(buf)); r 434 opal/mca/event/libevent2022/libevent/test/regress.c if (r<0) { r 1271 opal/mca/event/libevent2022/libevent/test/regress.c int r; r 1273 opal/mca/event/libevent2022/libevent/test/regress.c r = event_assign(&ev, NULL, -1, EV_SIGNAL|EV_READ, dummy_read_cb, NULL); r 1274 opal/mca/event/libevent2022/libevent/test/regress.c tt_int_op(r,==,-1); r 1286 opal/mca/event/libevent2022/libevent/test/regress.c int r; r 1290 opal/mca/event/libevent2022/libevent/test/regress.c r = event_base_loop(base, 0); r 1291 opal/mca/event/libevent2022/libevent/test/regress.c tt_int_op(r, ==, -1); r 1302 opal/mca/event/libevent2022/libevent/test/regress.c int r; r 1307 opal/mca/event/libevent2022/libevent/test/regress.c r = event_base_loop(base, 0); r 1308 opal/mca/event/libevent2022/libevent/test/regress.c tt_int_op(r, ==, 1); r 2116 opal/mca/event/libevent2022/libevent/test/regress.c int r; r 2121 opal/mca/event/libevent2022/libevent/test/regress.c r = event_base_once(data->base, data->pair[0], EV_READ, r 2123 opal/mca/event/libevent2022/libevent/test/regress.c tt_int_op(r, ==, 0); r 2124 opal/mca/event/libevent2022/libevent/test/regress.c r = event_base_once(data->base, -1, EV_TIMEOUT, r 2126 opal/mca/event/libevent2022/libevent/test/regress.c tt_int_op(r, ==, 0); r 2127 opal/mca/event/libevent2022/libevent/test/regress.c r = event_base_once(data->base, -1, 0, NULL, NULL, NULL); r 2128 opal/mca/event/libevent2022/libevent/test/regress.c tt_int_op(r, <, 0); r 2147 opal/mca/event/libevent2022/libevent/test/regress.c struct event *r=NULL, *w=NULL, *t=NULL; r 2152 opal/mca/event/libevent2022/libevent/test/regress.c r = event_new(data->base, data->pair[0], EV_READ, simple_read_cb, r 2158 opal/mca/event/libevent2022/libevent/test/regress.c tt_assert(r); r 2163 opal/mca/event/libevent2022/libevent/test/regress.c event_add(r, NULL); r 2166 opal/mca/event/libevent2022/libevent/test/regress.c tt_assert( event_pending(r, EV_READ, NULL)); r 2168 opal/mca/event/libevent2022/libevent/test/regress.c tt_assert(!event_pending(r, EV_WRITE, NULL)); r 2169 opal/mca/event/libevent2022/libevent/test/regress.c tt_assert( event_pending(r, EV_READ|EV_WRITE, NULL)); r 2170 opal/mca/event/libevent2022/libevent/test/regress.c tt_assert(!event_pending(r, EV_TIMEOUT, NULL)); r 2181 opal/mca/event/libevent2022/libevent/test/regress.c if (r) { r 2182 opal/mca/event/libevent2022/libevent/test/regress.c event_del(r); r 2183 opal/mca/event/libevent2022/libevent/test/regress.c event_free(r); r 257 opal/mca/event/libevent2022/libevent/test/regress_buffer.c int i, j, r; r 260 opal/mca/event/libevent2022/libevent/test/regress_buffer.c r = evbuffer_reserve_space(evb, 10000, v, 1); r 261 opal/mca/event/libevent2022/libevent/test/regress_buffer.c tt_int_op(r, ==, 1); r 637 opal/mca/event/libevent2022/libevent/test/regress_buffer.c int r=0, n_written=0; r 681 opal/mca/event/libevent2022/libevent/test/regress_buffer.c (r = evbuffer_write(src, pair[0])) > 0) { r 683 opal/mca/event/libevent2022/libevent/test/regress_buffer.c n_written += r; r 685 opal/mca/event/libevent2022/libevent/test/regress_buffer.c tt_int_op(r, !=, -1); r 1558 opal/mca/event/libevent2022/libevent/test/regress_buffer.c int r; r 1585 opal/mca/event/libevent2022/libevent/test/regress_buffer.c r = evbuffer_add(buf, "abc", 0); r 1586 opal/mca/event/libevent2022/libevent/test/regress_buffer.c FREEZE_EQ(r, 0, -1); r 1587 opal/mca/event/libevent2022/libevent/test/regress_buffer.c r = evbuffer_reserve_space(buf, 10, v, 1); r 1588 opal/mca/event/libevent2022/libevent/test/regress_buffer.c FREEZE_EQ(r, 1, -1); r 1589 opal/mca/event/libevent2022/libevent/test/regress_buffer.c if (r == 0) { r 1593 opal/mca/event/libevent2022/libevent/test/regress_buffer.c r = evbuffer_commit_space(buf, v, 1); r 1594 opal/mca/event/libevent2022/libevent/test/regress_buffer.c FREEZE_EQ(r, 0, -1); r 1595 opal/mca/event/libevent2022/libevent/test/regress_buffer.c r = evbuffer_add_reference(buf, string, 5, NULL, NULL); r 1596 opal/mca/event/libevent2022/libevent/test/regress_buffer.c FREEZE_EQ(r, 0, -1); r 1597 opal/mca/event/libevent2022/libevent/test/regress_buffer.c r = evbuffer_add_printf(buf, "Hello %s", "world"); r 1598 opal/mca/event/libevent2022/libevent/test/regress_buffer.c FREEZE_EQ(r, 11, -1); r 1607 opal/mca/event/libevent2022/libevent/test/regress_buffer.c r = evbuffer_remove(buf, charbuf, 1); r 1608 opal/mca/event/libevent2022/libevent/test/regress_buffer.c FREEZE_EQ(r, -1, 1); r 1609 opal/mca/event/libevent2022/libevent/test/regress_buffer.c r = evbuffer_drain(buf, 3); r 1610 opal/mca/event/libevent2022/libevent/test/regress_buffer.c FREEZE_EQ(r, -1, 0); r 1611 opal/mca/event/libevent2022/libevent/test/regress_buffer.c r = evbuffer_prepend(buf, "dummy", 5); r 1612 opal/mca/event/libevent2022/libevent/test/regress_buffer.c FREEZE_EQ(r, -1, 0); r 593 opal/mca/event/libevent2022/libevent/test/regress_bufferevent.c int r; r 613 opal/mca/event/libevent2022/libevent/test/regress_bufferevent.c r = bufferevent_socket_connect(bev, sa, slen); r 616 opal/mca/event/libevent2022/libevent/test/regress_bufferevent.c tt_want(r == 0 || r == -1); r 227 opal/mca/event/libevent2022/libevent/test/regress_dns.c int i, r; r 243 opal/mca/event/libevent2022/libevent/test/regress_dns.c r = evdns_server_request_add_a_reply(req, qname, r 245 opal/mca/event/libevent2022/libevent/test/regress_dns.c if (r<0) r 251 opal/mca/event/libevent2022/libevent/test/regress_dns.c r = evdns_server_request_add_aaaa_reply(req, r 253 opal/mca/event/libevent2022/libevent/test/regress_dns.c if (r<0) r 258 opal/mca/event/libevent2022/libevent/test/regress_dns.c r = evdns_server_request_add_ptr_reply(req, NULL, r 260 opal/mca/event/libevent2022/libevent/test/regress_dns.c if (r<0) r 265 opal/mca/event/libevent2022/libevent/test/regress_dns.c r = evdns_server_request_add_ptr_reply(req, NULL, r 268 opal/mca/event/libevent2022/libevent/test/regress_dns.c if (r<0) r 282 opal/mca/event/libevent2022/libevent/test/regress_dns.c r = evdns_server_request_respond(req, 0); r 283 opal/mca/event/libevent2022/libevent/test/regress_dns.c if (r<0) { r 517 opal/mca/event/libevent2022/libevent/test/regress_dns.c struct generic_dns_callback_result r[8]; r 529 opal/mca/event/libevent2022/libevent/test/regress_dns.c n_replies_left = sizeof(r)/sizeof(r[0]); r 532 opal/mca/event/libevent2022/libevent/test/regress_dns.c evdns_base_resolve_ipv4(dns, "host", 0, generic_dns_callback, &r[0]); r 533 opal/mca/event/libevent2022/libevent/test/regress_dns.c evdns_base_resolve_ipv4(dns, "host2", 0, generic_dns_callback, &r[1]); r 534 opal/mca/event/libevent2022/libevent/test/regress_dns.c evdns_base_resolve_ipv4(dns, "host", DNS_NO_SEARCH, generic_dns_callback, &r[2]); r 535 opal/mca/event/libevent2022/libevent/test/regress_dns.c evdns_base_resolve_ipv4(dns, "host2", DNS_NO_SEARCH, generic_dns_callback, &r[3]); r 536 opal/mca/event/libevent2022/libevent/test/regress_dns.c evdns_base_resolve_ipv4(dns, "host3", 0, generic_dns_callback, &r[4]); r 537 opal/mca/event/libevent2022/libevent/test/regress_dns.c evdns_base_resolve_ipv4(dns, "hostn.a.example.com", DNS_NO_SEARCH, generic_dns_callback, &r[5]); r 538 opal/mca/event/libevent2022/libevent/test/regress_dns.c evdns_base_resolve_ipv4(dns, "hostn.b.example.com", DNS_NO_SEARCH, generic_dns_callback, &r[6]); r 539 opal/mca/event/libevent2022/libevent/test/regress_dns.c evdns_base_resolve_ipv4(dns, "hostn.c.example.com", DNS_NO_SEARCH, generic_dns_callback, &r[7]); r 543 opal/mca/event/libevent2022/libevent/test/regress_dns.c tt_int_op(r[0].type, ==, DNS_IPv4_A); r 544 opal/mca/event/libevent2022/libevent/test/regress_dns.c tt_int_op(r[0].count, ==, 1); r 545 opal/mca/event/libevent2022/libevent/test/regress_dns.c tt_int_op(((ev_uint32_t*)r[0].addrs)[0], ==, htonl(0x0b16212c)); r 546 opal/mca/event/libevent2022/libevent/test/regress_dns.c tt_int_op(r[1].type, ==, DNS_IPv4_A); r 547 opal/mca/event/libevent2022/libevent/test/regress_dns.c tt_int_op(r[1].count, ==, 1); r 548 opal/mca/event/libevent2022/libevent/test/regress_dns.c tt_int_op(((ev_uint32_t*)r[1].addrs)[0], ==, htonl(0xc8640064)); r 549 opal/mca/event/libevent2022/libevent/test/regress_dns.c tt_int_op(r[2].result, ==, DNS_ERR_NOTEXIST); r 550 opal/mca/event/libevent2022/libevent/test/regress_dns.c tt_int_op(r[3].result, ==, DNS_ERR_NOTEXIST); r 551 opal/mca/event/libevent2022/libevent/test/regress_dns.c tt_int_op(r[4].result, ==, DNS_ERR_NOTEXIST); r 552 opal/mca/event/libevent2022/libevent/test/regress_dns.c tt_int_op(r[5].result, ==, DNS_ERR_NODATA); r 553 opal/mca/event/libevent2022/libevent/test/regress_dns.c tt_int_op(r[5].ttl, ==, 42); r 554 opal/mca/event/libevent2022/libevent/test/regress_dns.c tt_int_op(r[6].result, ==, DNS_ERR_NOTEXIST); r 555 opal/mca/event/libevent2022/libevent/test/regress_dns.c tt_int_op(r[6].ttl, ==, 42); r 556 opal/mca/event/libevent2022/libevent/test/regress_dns.c tt_int_op(r[7].result, ==, DNS_ERR_NODATA); r 557 opal/mca/event/libevent2022/libevent/test/regress_dns.c tt_int_op(r[7].ttl, ==, 0); r 831 opal/mca/event/libevent2022/libevent/test/regress_dns.c struct generic_dns_callback_result r[20]; r 843 opal/mca/event/libevent2022/libevent/test/regress_dns.c evdns_base_resolve_ipv4(dns, "foof.example.com", 0, generic_dns_callback, &r[i]); r 851 opal/mca/event/libevent2022/libevent/test/regress_dns.c tt_int_op(r[i].type, ==, DNS_IPv4_A); r 852 opal/mca/event/libevent2022/libevent/test/regress_dns.c tt_int_op(r[i].count, ==, 1); r 853 opal/mca/event/libevent2022/libevent/test/regress_dns.c tt_int_op(((ev_uint32_t*)r[i].addrs)[0], ==, htonl(0xf00ff00f)); r 1022 opal/mca/event/libevent2022/libevent/test/regress_dns.c int r; r 1023 opal/mca/event/libevent2022/libevent/test/regress_dns.c if ((r = bufferevent_socket_get_dns_error(bev))) { r 1024 opal/mca/event/libevent2022/libevent/test/regress_dns.c got->dnserr = r; r 1025 opal/mca/event/libevent2022/libevent/test/regress_dns.c TT_BLATHER(("DNS error %d: %s", r, r 1026 opal/mca/event/libevent2022/libevent/test/regress_dns.c evutil_gai_strerror(r))); r 1193 opal/mca/event/libevent2022/libevent/test/regress_dns.c struct evdns_getaddrinfo_request *r = ptr; r 1194 opal/mca/event/libevent2022/libevent/test/regress_dns.c evdns_getaddrinfo_cancel(r); r 1205 opal/mca/event/libevent2022/libevent/test/regress_dns.c struct evdns_getaddrinfo_request *r; r 1228 opal/mca/event/libevent2022/libevent/test/regress_dns.c r = evdns_getaddrinfo(dns_base, "1.2.3.4", "http", r 1230 opal/mca/event/libevent2022/libevent/test/regress_dns.c tt_assert(! r); r 1245 opal/mca/event/libevent2022/libevent/test/regress_dns.c r = evdns_getaddrinfo(dns_base, "www.google.com", "80", r 1247 opal/mca/event/libevent2022/libevent/test/regress_dns.c tt_ptr_op(r,==,NULL); r 1256 opal/mca/event/libevent2022/libevent/test/regress_dns.c r = evdns_getaddrinfo(dns_base, "f::f", "8008", r 1258 opal/mca/event/libevent2022/libevent/test/regress_dns.c tt_assert(!r); r 1270 opal/mca/event/libevent2022/libevent/test/regress_dns.c r = evdns_getaddrinfo(dns_base, "5.6.7.8", NULL, r 1272 opal/mca/event/libevent2022/libevent/test/regress_dns.c tt_assert(!r); r 1290 opal/mca/event/libevent2022/libevent/test/regress_dns.c r = evdns_getaddrinfo(dns_base, NULL, "9090", r 1292 opal/mca/event/libevent2022/libevent/test/regress_dns.c tt_assert(!r); r 1311 opal/mca/event/libevent2022/libevent/test/regress_dns.c r = evdns_getaddrinfo(dns_base, NULL, "2", r 1313 opal/mca/event/libevent2022/libevent/test/regress_dns.c tt_assert(!r); r 1332 opal/mca/event/libevent2022/libevent/test/regress_dns.c r = evdns_getaddrinfo(dns_base, "LOCALHOST", "80", r 1334 opal/mca/event/libevent2022/libevent/test/regress_dns.c tt_assert(!r); r 1353 opal/mca/event/libevent2022/libevent/test/regress_dns.c r = evdns_getaddrinfo(dns_base, "LOCALHOST", "9999", r 1355 opal/mca/event/libevent2022/libevent/test/regress_dns.c tt_assert(! r); r 1379 opal/mca/event/libevent2022/libevent/test/regress_dns.c r = evdns_getaddrinfo(dns_base, "both.example.com", "8000", r 1381 opal/mca/event/libevent2022/libevent/test/regress_dns.c tt_assert(r); r 1384 opal/mca/event/libevent2022/libevent/test/regress_dns.c r = evdns_getaddrinfo(dns_base, "v4only.example.com", "8001", r 1386 opal/mca/event/libevent2022/libevent/test/regress_dns.c tt_assert(r); r 1390 opal/mca/event/libevent2022/libevent/test/regress_dns.c r = evdns_getaddrinfo(dns_base, "v6only.example.com", "8002", r 1392 opal/mca/event/libevent2022/libevent/test/regress_dns.c tt_assert(r); r 1397 opal/mca/event/libevent2022/libevent/test/regress_dns.c r = evdns_getaddrinfo(dns_base, "v4assert.example.com", "8003", r 1399 opal/mca/event/libevent2022/libevent/test/regress_dns.c tt_assert(r); r 1404 opal/mca/event/libevent2022/libevent/test/regress_dns.c r = evdns_getaddrinfo(dns_base, "v6assert.example.com", "8004", r 1406 opal/mca/event/libevent2022/libevent/test/regress_dns.c tt_assert(r); r 1410 opal/mca/event/libevent2022/libevent/test/regress_dns.c r = evdns_getaddrinfo(dns_base, "nosuchplace.example.com", "8005", r 1412 opal/mca/event/libevent2022/libevent/test/regress_dns.c tt_assert(r); r 1417 opal/mca/event/libevent2022/libevent/test/regress_dns.c r = evdns_getaddrinfo(dns_base, "nosuchplace.example.com", "8006", r 1419 opal/mca/event/libevent2022/libevent/test/regress_dns.c tt_assert(r); r 1424 opal/mca/event/libevent2022/libevent/test/regress_dns.c r = evdns_getaddrinfo(dns_base, "v6timeout.example.com", "8007", r 1426 opal/mca/event/libevent2022/libevent/test/regress_dns.c tt_assert(r); r 1431 opal/mca/event/libevent2022/libevent/test/regress_dns.c r = evdns_getaddrinfo(dns_base, "v6timeout-nonexist.example.com", r 1433 opal/mca/event/libevent2022/libevent/test/regress_dns.c tt_assert(r); r 1438 opal/mca/event/libevent2022/libevent/test/regress_dns.c r = evdns_getaddrinfo(dns_base, "both.example.com", r 1440 opal/mca/event/libevent2022/libevent/test/regress_dns.c tt_assert(r); r 1446 opal/mca/event/libevent2022/libevent/test/regress_dns.c r = evdns_getaddrinfo(dns_base, "v4timeout.example.com", "8010", r 1448 opal/mca/event/libevent2022/libevent/test/regress_dns.c tt_assert(r); r 1451 opal/mca/event/libevent2022/libevent/test/regress_dns.c r = evdns_getaddrinfo(dns_base, "all-timeout.example.com", "8011", r 1453 opal/mca/event/libevent2022/libevent/test/regress_dns.c tt_assert(r); r 1459 opal/mca/event/libevent2022/libevent/test/regress_dns.c r, &tv); r 1680 opal/mca/event/libevent2022/libevent/test/regress_dns.c struct generic_dns_callback_result r; r 1698 opal/mca/event/libevent2022/libevent/test/regress_dns.c generic_dns_callback, &env->r); r 180 opal/mca/event/libevent2022/libevent/test/regress_http.c int r; r 186 opal/mca/event/libevent2022/libevent/test/regress_http.c if ((r = memcmp(d, s, s_sz))) r 187 opal/mca/event/libevent2022/libevent/test/regress_http.c return r; r 1922 opal/mca/event/libevent2022/libevent/test/regress_http.c int r; r 1926 opal/mca/event/libevent2022/libevent/test/regress_http.c r = evhttp_parse_query("http://www.test.com/?q=test", &headers); r 1928 opal/mca/event/libevent2022/libevent/test/regress_http.c tt_int_op(r, ==, 0); r 1931 opal/mca/event/libevent2022/libevent/test/regress_http.c r = evhttp_parse_query("http://www.test.com/?q=test&foo=bar", &headers); r 1934 opal/mca/event/libevent2022/libevent/test/regress_http.c tt_int_op(r, ==, 0); r 1937 opal/mca/event/libevent2022/libevent/test/regress_http.c r = evhttp_parse_query("http://www.test.com/?q=test+foo", &headers); r 1939 opal/mca/event/libevent2022/libevent/test/regress_http.c tt_int_op(r, ==, 0); r 1942 opal/mca/event/libevent2022/libevent/test/regress_http.c r = evhttp_parse_query("http://www.test.com/?q=test%0Afoo", &headers); r 1944 opal/mca/event/libevent2022/libevent/test/regress_http.c tt_int_op(r, ==, 0); r 1947 opal/mca/event/libevent2022/libevent/test/regress_http.c r = evhttp_parse_query("http://www.test.com/?q=test%0Dfoo", &headers); r 1949 opal/mca/event/libevent2022/libevent/test/regress_http.c tt_int_op(r, ==, 0); r 1952 opal/mca/event/libevent2022/libevent/test/regress_http.c r = evhttp_parse_query("http://www.test.com/?q=test&&q2", &headers); r 1953 opal/mca/event/libevent2022/libevent/test/regress_http.c tt_int_op(r, ==, -1); r 1956 opal/mca/event/libevent2022/libevent/test/regress_http.c r = evhttp_parse_query("http://www.test.com/?q=test+this", &headers); r 1958 opal/mca/event/libevent2022/libevent/test/regress_http.c tt_int_op(r, ==, 0); r 1961 opal/mca/event/libevent2022/libevent/test/regress_http.c r = evhttp_parse_query("http://www.test.com/?q=test&q2=foo", &headers); r 1962 opal/mca/event/libevent2022/libevent/test/regress_http.c tt_int_op(r, ==, 0); r 1967 opal/mca/event/libevent2022/libevent/test/regress_http.c r = evhttp_parse_query("http://www.test.com/?q&q2=foo", &headers); r 1968 opal/mca/event/libevent2022/libevent/test/regress_http.c tt_int_op(r, ==, -1); r 1971 opal/mca/event/libevent2022/libevent/test/regress_http.c r = evhttp_parse_query("http://www.test.com/?q=foo&q2", &headers); r 1972 opal/mca/event/libevent2022/libevent/test/regress_http.c tt_int_op(r, ==, -1); r 1975 opal/mca/event/libevent2022/libevent/test/regress_http.c r = evhttp_parse_query("http://www.test.com/?q=foo&q2&q3=x", &headers); r 1976 opal/mca/event/libevent2022/libevent/test/regress_http.c tt_int_op(r, ==, -1); r 1979 opal/mca/event/libevent2022/libevent/test/regress_http.c r = evhttp_parse_query("http://www.test.com/?q=&q2=&q3=", &headers); r 1980 opal/mca/event/libevent2022/libevent/test/regress_http.c tt_int_op(r, ==, 0); r 147 opal/mca/event/libevent2022/libevent/test/regress_main.c DWORD r, written; r 150 opal/mca/event/libevent2022/libevent/test/regress_main.c r = GetTempPathA(MAX_PATH, tmpfilepath); r 151 opal/mca/event/libevent2022/libevent/test/regress_main.c if (r > MAX_PATH || r == 0) r 154 opal/mca/event/libevent2022/libevent/test/regress_main.c r = GetTempFileNameA(tmpfilepath, "LIBEVENT", 0, tmpfilename); r 155 opal/mca/event/libevent2022/libevent/test/regress_main.c if (r == 0) r 345 opal/mca/event/libevent2022/libevent/test/regress_main.c int r = basic_test_cleanup(testcase, ptr); r 348 opal/mca/event/libevent2022/libevent/test/regress_main.c return r; r 286 opal/mca/event/libevent2022/libevent/test/regress_thread.c int r; r 290 opal/mca/event/libevent2022/libevent/test/regress_thread.c r = EVTHREAD_COND_WAIT_TIMED(rec->cond->cond, rec->cond->lock, r 293 opal/mca/event/libevent2022/libevent/test/regress_thread.c r = EVTHREAD_COND_WAIT(rec->cond->cond, rec->cond->lock); r 298 opal/mca/event/libevent2022/libevent/test/regress_thread.c if (r == 1) r 117 opal/mca/event/libevent2022/libevent/test/regress_util.c int r; r 118 opal/mca/event/libevent2022/libevent/test/regress_util.c r = evutil_inet_pton(AF_INET, ent->addr, &in); r 119 opal/mca/event/libevent2022/libevent/test/regress_util.c if (r == 0) { r 164 opal/mca/event/libevent2022/libevent/test/regress_util.c int r; r 165 opal/mca/event/libevent2022/libevent/test/regress_util.c r = evutil_inet_pton(AF_INET6, ent->addr, &in6); r 166 opal/mca/event/libevent2022/libevent/test/regress_util.c if (r == 0) { r 230 opal/mca/event/libevent2022/libevent/test/regress_util.c int i, r; r 236 opal/mca/event/libevent2022/libevent/test/regress_util.c r = evutil_parse_sockaddr_port(ent->parse, (struct sockaddr*)&ss, &len); r 237 opal/mca/event/libevent2022/libevent/test/regress_util.c if (r < 0) { r 253 opal/mca/event/libevent2022/libevent/test/regress_util.c r = evutil_inet_pton(AF_INET, ent->addr, &sin.sin_addr); r 254 opal/mca/event/libevent2022/libevent/test/regress_util.c if (1 != r) { r 269 opal/mca/event/libevent2022/libevent/test/regress_util.c r = evutil_inet_pton(AF_INET6, ent->addr, &sin6.sin6_addr); r 270 opal/mca/event/libevent2022/libevent/test/regress_util.c if (1 != r) { r 289 opal/mca/event/libevent2022/libevent/test/regress_util.c int r; r 292 opal/mca/event/libevent2022/libevent/test/regress_util.c r = evutil_parse_sockaddr_port("192.168.1.1:80", r 294 opal/mca/event/libevent2022/libevent/test/regress_util.c tt_int_op(r,==,0); r 301 opal/mca/event/libevent2022/libevent/test/regress_util.c r = evutil_parse_sockaddr_port("[ff00::8010]:999", r 303 opal/mca/event/libevent2022/libevent/test/regress_util.c tt_int_op(r,==,0); r 341 opal/mca/event/libevent2022/libevent/test/regress_util.c int r, i; r 347 opal/mca/event/libevent2022/libevent/test/regress_util.c r = evutil_parse_sockaddr_port(ent->parse, (struct sockaddr*)&ss, &len); r 349 opal/mca/event/libevent2022/libevent/test/regress_util.c if (r<0) { r 382 opal/mca/event/libevent2022/libevent/test/regress_util.c int r; r 388 opal/mca/event/libevent2022/libevent/test/regress_util.c r = evutil_snprintf(buf, sizeof(buf), "%d %d", 50, 100); r 390 opal/mca/event/libevent2022/libevent/test/regress_util.c tt_int_op(r, ==, 6); r 392 opal/mca/event/libevent2022/libevent/test/regress_util.c r = evutil_snprintf(buf, sizeof(buf), "longish %d", 1234567890); r 394 opal/mca/event/libevent2022/libevent/test/regress_util.c tt_int_op(r, ==, 18); r 396 opal/mca/event/libevent2022/libevent/test/regress_util.c r = evutil_snprintf(buf, sizeof(buf), EV_U64_FMT, EV_U64_ARG(u64)); r 398 opal/mca/event/libevent2022/libevent/test/regress_util.c tt_int_op(r, ==, 12); r 400 opal/mca/event/libevent2022/libevent/test/regress_util.c r = evutil_snprintf(buf, sizeof(buf), EV_I64_FMT, EV_I64_ARG(i64)); r 402 opal/mca/event/libevent2022/libevent/test/regress_util.c tt_int_op(r, ==, 13); r 404 opal/mca/event/libevent2022/libevent/test/regress_util.c r = evutil_snprintf(buf, sizeof(buf), EV_SIZE_FMT" "EV_SSIZE_FMT, r 407 opal/mca/event/libevent2022/libevent/test/regress_util.c tt_int_op(r, ==, 10); r 884 opal/mca/event/libevent2022/libevent/test/regress_util.c int r; r 890 opal/mca/event/libevent2022/libevent/test/regress_util.c r = evutil_getaddrinfo("1.2.3.4", "8080", &hints, &ai); r 891 opal/mca/event/libevent2022/libevent/test/regress_util.c tt_int_op(r, ==, 0); r 901 opal/mca/event/libevent2022/libevent/test/regress_util.c r = evutil_getaddrinfo("1001:b0b::f00f", "4321", &hints, &ai); r 902 opal/mca/event/libevent2022/libevent/test/regress_util.c tt_int_op(r, ==, 0); r 914 opal/mca/event/libevent2022/libevent/test/regress_util.c r = evutil_getaddrinfo(NULL, "9999", &hints, &ai); r 915 opal/mca/event/libevent2022/libevent/test/regress_util.c tt_int_op(r,==,0); r 922 opal/mca/event/libevent2022/libevent/test/regress_util.c r = evutil_getaddrinfo(NULL, "9998", &hints, &ai); r 924 opal/mca/event/libevent2022/libevent/test/regress_util.c tt_int_op(r,==,0); r 932 opal/mca/event/libevent2022/libevent/test/regress_util.c r = evutil_getaddrinfo(NULL, "9997", &hints, &ai); r 934 opal/mca/event/libevent2022/libevent/test/regress_util.c tt_int_op(r,==,0); r 942 opal/mca/event/libevent2022/libevent/test/regress_util.c r = evutil_getaddrinfo(NULL, "9996", &hints, &ai); r 944 opal/mca/event/libevent2022/libevent/test/regress_util.c tt_int_op(r,==,0); r 952 opal/mca/event/libevent2022/libevent/test/regress_util.c r = evutil_getaddrinfo(NULL, "9996", &hints, &ai); r 954 opal/mca/event/libevent2022/libevent/test/regress_util.c tt_int_op(r,==,0); r 969 opal/mca/event/libevent2022/libevent/test/regress_util.c r = evutil_getaddrinfo("1.2.3.4", NULL, &hints, &ai); r 970 opal/mca/event/libevent2022/libevent/test/regress_util.c tt_int_op(r, ==, 0); r 984 opal/mca/event/libevent2022/libevent/test/regress_util.c r = evutil_getaddrinfo("www.google.com", "80", &hints, &ai); r 985 opal/mca/event/libevent2022/libevent/test/regress_util.c tt_int_op(r, ==, EVUTIL_EAI_NONAME); r 993 opal/mca/event/libevent2022/libevent/test/regress_util.c r = evutil_getaddrinfo("1.2.3.4", "http", &hints, &ai); r 994 opal/mca/event/libevent2022/libevent/test/regress_util.c tt_int_op(r,==,EVUTIL_EAI_NONAME); r 1000 opal/mca/event/libevent2022/libevent/test/regress_util.c r = evutil_getaddrinfo("1.2.3.4", "http", &hints, &ai); r 1001 opal/mca/event/libevent2022/libevent/test/regress_util.c if (r!=0) { r 1015 opal/mca/event/libevent2022/libevent/test/regress_util.c r = evutil_getaddrinfo("www.google.com", "80", &hints, &ai); r 1016 opal/mca/event/libevent2022/libevent/test/regress_util.c if (r != 0) { r 1037 opal/mca/event/libevent2022/libevent/test/regress_util.c r = evutil_getaddrinfo("ipv6.google.com", "80", &hints, &ai); r 1038 opal/mca/event/libevent2022/libevent/test/regress_util.c if (r != 0) { r 279 opal/mca/event/libevent2022/libevent/test/regress_zlib.c int i, r; r 297 opal/mca/event/libevent2022/libevent/test/regress_zlib.c r = deflateInit(&z_output, Z_DEFAULT_COMPRESSION); r 298 opal/mca/event/libevent2022/libevent/test/regress_zlib.c tt_int_op(r, ==, Z_OK); r 300 opal/mca/event/libevent2022/libevent/test/regress_zlib.c r = inflateInit(&z_input); r 301 opal/mca/event/libevent2022/libevent/test/regress_zlib.c tt_int_op(r, ==, Z_OK); r 68 opal/mca/event/libevent2022/libevent/test/test-changelist.c int r; r 71 opal/mca/event/libevent2022/libevent/test/test-changelist.c r = GetThreadTimes(timer->thread, &createtime, &exittime, r 73 opal/mca/event/libevent2022/libevent/test/test-changelist.c if (r==0) printf("GetThreadTimes failed."); r 94 opal/mca/event/libevent2022/libevent/test/test-changelist.c double r; r 98 opal/mca/event/libevent2022/libevent/test/test-changelist.c r = (double) diff; r 99 opal/mca/event/libevent2022/libevent/test/test-changelist.c return r / 1.0e7; r 110 opal/mca/event/libevent2022/libevent/test/test-changelist.c int r; r 118 opal/mca/event/libevent2022/libevent/test/test-changelist.c r = GetThreadTimes(timer->thread, &createtime, &exittime, r 120 opal/mca/event/libevent2022/libevent/test/test-changelist.c if (r==0) printf("GetThreadTimes failed."); r 93 opal/mca/event/libevent2022/libevent/test/test-ratelim.c int r = rand() % 256; r 95 opal/mca/event/libevent2022/libevent/test/test-ratelim.c int r = random() % 256; r 97 opal/mca/event/libevent2022/libevent/test/test-ratelim.c memset(buf, r, sizeof(buf)); r 193 opal/mca/event/libevent2022/libevent/test/tinytest.c int status, r; r 198 opal/mca/event/libevent2022/libevent/test/tinytest.c r = (int)read(outcome_pipe[0], b, 1); r 199 opal/mca/event/libevent2022/libevent/test/tinytest.c if (r == 0) { r 202 opal/mca/event/libevent2022/libevent/test/tinytest.c } else if (r != 1) { r 561 opal/mca/hwloc/hwloc201/hwloc/include/netloc/uthash.h #define MUR_ROTL32(x,r) (((x) << (r)) | ((x) >> (32 - (r)))) r 778 opal/mca/pmix/ext1x/pmix1x_client.c opal_list_t results, *r = NULL; r 830 opal/mca/pmix/ext1x/pmix1x_client.c r = &results; r 834 opal/mca/pmix/ext1x/pmix1x_client.c op->lkcbfunc(rc, r, op->cbdata); r 836 opal/mca/pmix/ext1x/pmix1x_client.c if (NULL != r) { r 196 opal/mca/pmix/ext2x/ext2x.h #define OPAL_PMIX_NOTIFY_THREADSHIFT(s, sr, r, i, fn, cb, cd) \ r 202 opal/mca/pmix/ext2x/ext2x.h _cd->range = (r); \ r 961 opal/mca/pmix/ext2x/ext2x_client.c opal_list_t results, *r = NULL; r 1013 opal/mca/pmix/ext2x/ext2x_client.c r = &results; r 1019 opal/mca/pmix/ext2x/ext2x_client.c op->lkcbfunc(rc, r, op->cbdata); r 1021 opal/mca/pmix/ext2x/ext2x_client.c if (NULL != r) { r 191 opal/mca/pmix/ext3x/ext3x.h #define OPAL_PMIX_NOTIFY_THREADSHIFT(s, sr, r, i, fn, cb, cd) \ r 197 opal/mca/pmix/ext3x/ext3x.h _cd->range = (r); \ r 962 opal/mca/pmix/ext3x/ext3x_client.c opal_list_t results, *r = NULL; r 1014 opal/mca/pmix/ext3x/ext3x_client.c r = &results; r 1020 opal/mca/pmix/ext3x/ext3x_client.c op->lkcbfunc(rc, r, op->cbdata); r 1022 opal/mca/pmix/ext3x/ext3x_client.c if (NULL != r) { r 64 opal/mca/pmix/pmix.h #define OPAL_MODEX_SEND_VALUE(r, sc, s, d, t) \ r 69 opal/mca/pmix/pmix.h if (OPAL_SUCCESS != ((r) = opal_value_load(&(_kv), (d), (t)))) { \ r 70 opal/mca/pmix/pmix.h OPAL_ERROR_LOG((r)); \ r 72 opal/mca/pmix/pmix.h if (OPAL_SUCCESS != ((r) = opal_pmix.put(sc, &(_kv)))) { \ r 73 opal/mca/pmix/pmix.h OPAL_ERROR_LOG((r)); \ r 91 opal/mca/pmix/pmix.h #define OPAL_MODEX_SEND_STRING(r, sc, s, d, sz) \ r 99 opal/mca/pmix/pmix.h if (OPAL_SUCCESS != ((r) = opal_pmix.put(sc, &(_kv)))) { \ r 100 opal/mca/pmix/pmix.h OPAL_ERROR_LOG((r)); \ r 117 opal/mca/pmix/pmix.h #define OPAL_MODEX_SEND(r, sc, s, d, sz) \ r 121 opal/mca/pmix/pmix.h OPAL_MODEX_SEND_STRING((r), (sc), _key, (d), (sz)); \ r 138 opal/mca/pmix/pmix.h #define OPAL_MODEX_RECV_VALUE_OPTIONAL(r, s, p, d, t) \ r 153 opal/mca/pmix/pmix.h if (OPAL_SUCCESS == ((r) = opal_pmix.get((p), (s), &(_ilist), &(_kv)))) { \ r 155 opal/mca/pmix/pmix.h (r) = OPAL_ERR_NOT_FOUND; \ r 157 opal/mca/pmix/pmix.h (r) = opal_value_unload(_kv, (void**)(d), (t)); \ r 179 opal/mca/pmix/pmix.h #define OPAL_MODEX_RECV_VALUE_IMMEDIATE(r, s, p, d, t) \ r 194 opal/mca/pmix/pmix.h if (OPAL_SUCCESS == ((r) = opal_pmix.get((p), (s), &(_ilist), &(_kv)))) { \ r 196 opal/mca/pmix/pmix.h (r) = OPAL_ERR_NOT_FOUND; \ r 198 opal/mca/pmix/pmix.h (r) = opal_value_unload(_kv, (void**)(d), (t)); \ r 217 opal/mca/pmix/pmix.h #define OPAL_MODEX_RECV_VALUE(r, s, p, d, t) \ r 225 opal/mca/pmix/pmix.h if (OPAL_SUCCESS == ((r) = opal_pmix.get((p), (s), NULL, &(_kv)))) { \ r 227 opal/mca/pmix/pmix.h (r) = OPAL_ERR_NOT_FOUND; \ r 229 opal/mca/pmix/pmix.h (r) = opal_value_unload(_kv, (void**)(d), (t)); \ r 248 opal/mca/pmix/pmix.h #define OPAL_MODEX_RECV_STRING(r, s, p, d, sz) \ r 256 opal/mca/pmix/pmix.h if (OPAL_SUCCESS == ((r) = opal_pmix.get((p), (s), NULL, &(_kv)))) { \ r 259 opal/mca/pmix/pmix.h (r) = OPAL_ERR_NOT_FOUND; \ r 268 opal/mca/pmix/pmix.h (r) = OPAL_ERR_NOT_FOUND; \ r 285 opal/mca/pmix/pmix.h #define OPAL_MODEX_RECV(r, s, p, d, sz) \ r 296 opal/mca/pmix/pmix.h (r) = OPAL_ERR_OUT_OF_RESOURCE; \ r 298 opal/mca/pmix/pmix.h OPAL_MODEX_RECV_STRING((r), _key, (p), (d), (sz)); \ r 307 opal/mca/pmix/pmix.h #define OPAL_PMIX_EXCHANGE(r, i, p, t) \ r 314 opal/mca/pmix/pmix.h (r) = opal_pmix_base_exchange((i), (p), (t)); \ r 110 opal/mca/pmix/pmix4x/pmix/examples/examples.h #define DEBUG_CONSTRUCT_MYREL(r) \ r 112 opal/mca/pmix/pmix4x/pmix/examples/examples.h DEBUG_CONSTRUCT_LOCK(&((r)->lock)); \ r 113 opal/mca/pmix/pmix4x/pmix/examples/examples.h (r)->nspace = NULL; \ r 114 opal/mca/pmix/pmix4x/pmix/examples/examples.h (r)->exit_code = 0; \ r 115 opal/mca/pmix/pmix4x/pmix/examples/examples.h (r)->exit_code_given = false; \ r 118 opal/mca/pmix/pmix4x/pmix/examples/examples.h #define DEBUG_DESTRUCT_MYREL(r) \ r 120 opal/mca/pmix/pmix4x/pmix/examples/examples.h DEBUG_DESTRUCT_LOCK(&((r)->lock)); \ r 121 opal/mca/pmix/pmix4x/pmix/examples/examples.h if (NULL != (r)->nspace) { \ r 122 opal/mca/pmix/pmix4x/pmix/examples/examples.h free((r)->nspace); \ r 175 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event.h #define PMIX_REPORT_EVENT(e, p, r, f) \ r 194 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event.h ch->range = (r); \ r 412 opal/mca/pmix/pmix4x/pmix/src/include/pmix_globals.h #define PMIX_THREADSHIFT(r, c) \ r 414 opal/mca/pmix/pmix4x/pmix/src/include/pmix_globals.h pmix_event_assign(&((r)->ev), pmix_globals.evbase, \ r 415 opal/mca/pmix/pmix4x/pmix/src/include/pmix_globals.h -1, EV_WRITE, (c), (r)); \ r 416 opal/mca/pmix/pmix4x/pmix/src/include/pmix_globals.h PMIX_POST_OBJECT((r)); \ r 417 opal/mca/pmix/pmix4x/pmix/src/include/pmix_globals.h pmix_event_active(&((r)->ev), EV_WRITE, 1); \ r 109 opal/mca/pmix/pmix4x/pmix/src/include/types.h } w, r; r 115 opal/mca/pmix/pmix4x/pmix/src/include/types.h r.l[0] = htonl(w.l[1]); r 116 opal/mca/pmix/pmix4x/pmix/src/include/types.h r.l[1] = htonl(w.l[0]); r 117 opal/mca/pmix/pmix4x/pmix/src/include/types.h return r.ll; r 133 opal/mca/pmix/pmix4x/pmix/src/include/types.h } w, r; r 139 opal/mca/pmix/pmix4x/pmix/src/include/types.h r.l[0] = ntohl(w.l[1]); r 140 opal/mca/pmix/pmix4x/pmix/src/include/types.h r.l[1] = ntohl(w.l[0]); r 141 opal/mca/pmix/pmix4x/pmix/src/include/types.h return r.ll; r 174 opal/mca/pmix/pmix4x/pmix/src/include/types.h } w, r; r 177 opal/mca/pmix/pmix4x/pmix/src/include/types.h r.arrayval[0] = w.arrayval[1]; r 178 opal/mca/pmix/pmix4x/pmix/src/include/types.h r.arrayval[1] = w.arrayval[0]; r 180 opal/mca/pmix/pmix4x/pmix/src/include/types.h return r.bigval; r 188 opal/mca/pmix/pmix4x/pmix/src/include/types.h } w, r; r 191 opal/mca/pmix/pmix4x/pmix/src/include/types.h r.arrayval[0] = w.arrayval[3]; r 192 opal/mca/pmix/pmix4x/pmix/src/include/types.h r.arrayval[1] = w.arrayval[2]; r 193 opal/mca/pmix/pmix4x/pmix/src/include/types.h r.arrayval[2] = w.arrayval[1]; r 194 opal/mca/pmix/pmix4x/pmix/src/include/types.h r.arrayval[3] = w.arrayval[0]; r 196 opal/mca/pmix/pmix4x/pmix/src/include/types.h return r.bigval; r 204 opal/mca/pmix/pmix4x/pmix/src/include/types.h } w, r; r 207 opal/mca/pmix/pmix4x/pmix/src/include/types.h r.arrayval[0] = w.arrayval[7]; r 208 opal/mca/pmix/pmix4x/pmix/src/include/types.h r.arrayval[1] = w.arrayval[6]; r 209 opal/mca/pmix/pmix4x/pmix/src/include/types.h r.arrayval[2] = w.arrayval[5]; r 210 opal/mca/pmix/pmix4x/pmix/src/include/types.h r.arrayval[3] = w.arrayval[4]; r 211 opal/mca/pmix/pmix4x/pmix/src/include/types.h r.arrayval[4] = w.arrayval[3]; r 212 opal/mca/pmix/pmix4x/pmix/src/include/types.h r.arrayval[5] = w.arrayval[2]; r 213 opal/mca/pmix/pmix4x/pmix/src/include/types.h r.arrayval[6] = w.arrayval[1]; r 214 opal/mca/pmix/pmix4x/pmix/src/include/types.h r.arrayval[7] = w.arrayval[0]; r 216 opal/mca/pmix/pmix4x/pmix/src/include/types.h return r.bigval; r 196 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/base/base.h #define PMIX_BFROPS_PACK_TYPE(r, b, s, n, t, arr) \ r 203 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/base/base.h (r) = PMIX_ERR_UNKNOWN_DATA_TYPE; \ r 205 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/base/base.h (r) = __info->odti_pack_fn(arr, b, s, n, t); \ r 209 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/base/base.h #define PMIX_BFROPS_UNPACK_TYPE(r, b, d, n, t, arr) \ r 216 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/base/base.h (r) = PMIX_ERR_UNKNOWN_DATA_TYPE; \ r 218 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/base/base.h (r) = __info->odti_unpack_fn(arr, b, d, n, t); \ r 239 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/base/bfrop_base_fns.c pmix_regattr_t *regattr, *r; r 390 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/base/bfrop_base_fns.c r = (pmix_regattr_t*)kv->data.ptr; r 391 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/base/bfrop_base_fns.c if (NULL != r->name) { r 392 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/base/bfrop_base_fns.c regattr->name = strdup(r->name); r 394 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/base/bfrop_base_fns.c PMIX_LOAD_KEY(regattr->string, r->string); r 395 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/base/bfrop_base_fns.c regattr->type = r->type; r 396 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/base/bfrop_base_fns.c if (NULL != r->info) { r 397 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/base/bfrop_base_fns.c PMIX_INFO_XFER(regattr->info, r->info); r 399 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/base/bfrop_base_fns.c regattr->ninfo = r->ninfo; r 400 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/base/bfrop_base_fns.c regattr->description = pmix_argv_copy(r->description); r 878 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/base/bfrop_base_print.c pmix_regattr_t *r; r 1031 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/base/bfrop_base_print.c r = (pmix_regattr_t*)src->data.ptr; r 1033 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/base/bfrop_base_print.c prefx, (NULL == r->name) ? "NULL" : r->name, r 1034 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/base/bfrop_base_print.c (0 == strlen(r->string)) ? "NULL" : r->string); r 398 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/bfrops.h #define PMIX_BFROPS_PACK(r, p, b, s, n, t) \ r 406 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/bfrops.h (r) = (p)->nptr->compat.bfrops->pack(b, s, n, t); \ r 408 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/bfrops.h (r) = (p)->nptr->compat.bfrops->pack(b, s, n, t); \ r 410 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/bfrops.h (r) = PMIX_ERR_PACK_MISMATCH; \ r 414 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/bfrops.h #define PMIX_BFROPS_UNPACK(r, p, b, d, m, t) \ r 421 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/bfrops.h (r) = (p)->nptr->compat.bfrops->unpack(b, d, m, t); \ r 423 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/bfrops.h (r) = PMIX_ERR_UNPACK_FAILURE; \ r 427 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/bfrops.h #define PMIX_BFROPS_COPY(r, p, d, s, t) \ r 428 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/bfrops.h (r) = (p)->nptr->compat.bfrops->copy(d, s, t) r 430 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/bfrops.h #define PMIX_BFROPS_PRINT(r, p, o, pr, s, t) \ r 431 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/bfrops.h (r) = (p)->nptr->compat.bfrops->print(o, pr, s, t) r 433 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/bfrops.h #define PMIX_BFROPS_COPY_PAYLOAD(r, p, d, s) \ r 437 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/bfrops.h (r) = (p)->nptr->compat.bfrops->copy_payload(d, s); \ r 439 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/bfrops.h (r) = (p)->nptr->compat.bfrops->copy_payload(d, s); \ r 441 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/bfrops.h (r) = PMIX_ERR_PACK_MISMATCH; \ r 445 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/bfrops.h #define PMIX_BFROPS_VALUE_XFER(r, p, d, s) \ r 446 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/bfrops.h (r) = (p)->nptr->compat.bfrops->value_xfer(d, s) r 451 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/bfrops.h #define PMIX_BFROPS_VALUE_UNLOAD(r, p, k, d, s) \ r 452 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/bfrops.h (r) = (p)->nptr->compat.bfrops->value_unload(k,, d, s) r 454 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/bfrops.h #define PMIX_BFROPS_VALUE_CMP(r, p, q, s) \ r 455 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/bfrops.h (r) = (p)->nptr->compat.bfrops->value_cmp(q, s) r 457 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/bfrops.h #define PMIX_BFROPS_REGISTER(r, p, n, t, pk, u, c, pr) \ r 458 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/bfrops.h (r) = (p)->nptr->compat.bfrops->register_type(n, t, pk, u, c, pr) r 85 opal/mca/pmix/pmix4x/pmix/src/mca/gds/gds.h #define PMIX_GDS_ASSEMB_KVS_REQ(s, p, r, k, b, c) \ r 93 opal/mca/pmix/pmix4x/pmix/src/mca/gds/gds.h (s) = _g->assemb_kvs_req(r, k, b, (void*)c); \ r 257 opal/mca/pmix/pmix4x/pmix/src/mca/gds/gds.h #define PMIX_GDS_STORE_MODEX(r, n, b, t) \ r 262 opal/mca/pmix/pmix4x/pmix/src/mca/gds/gds.h (r) = (n)->compat.gds->store_modex((struct pmix_namespace_t*)n, b, t); \ r 131 opal/mca/pmix/pmix4x/pmix/src/mca/psec/psec.h #define PMIX_PSEC_CREATE_CRED(r, p, d, nd, in, nin, c) \ r 132 opal/mca/pmix/pmix4x/pmix/src/mca/psec/psec.h (r) = (p)->nptr->compat.psec->create_cred((struct pmix_peer_t*)(p), \ r 135 opal/mca/pmix/pmix4x/pmix/src/mca/psec/psec.h #define PMIX_PSEC_CLIENT_HANDSHAKE(r, p, sd) \ r 136 opal/mca/pmix/pmix4x/pmix/src/mca/psec/psec.h (r) = (p)->nptr->compat.psec->client_handshake(sd) r 138 opal/mca/pmix/pmix4x/pmix/src/mca/psec/psec.h #define PMIX_PSEC_VALIDATE_CRED(r, p, d, nd, in, nin, c) \ r 139 opal/mca/pmix/pmix4x/pmix/src/mca/psec/psec.h (r) = (p)->nptr->compat.psec->validate_cred((struct pmix_peer_t*)(p), \ r 143 opal/mca/pmix/pmix4x/pmix/src/mca/psec/psec.h #define PMIX_PSEC_VALIDATE_CONNECTION(r, p, d, nd, in, nin, c) \ r 162 opal/mca/pmix/pmix4x/pmix/src/mca/psec/psec.h (r) = _r; \ r 175 opal/mca/pmix/pmix4x/pmix/src/mca/psec/psec.h (r) = _r; \ r 178 opal/mca/pmix/pmix4x/pmix/src/mca/psec/psec.h (r) = PMIX_ERR_NOT_SUPPORTED; \ r 40 opal/mca/pmix/pmix4x/pmix/src/mca/psquash/base/base.h #define PMIX_SQUASH_TYPE_SIZEOF(r, t, s) \ r 42 opal/mca/pmix/pmix4x/pmix/src/mca/psquash/base/base.h (r) = PMIX_SUCCESS; \ r 62 opal/mca/pmix/pmix4x/pmix/src/mca/psquash/base/base.h (r) = PMIX_ERR_BAD_PARAM; \ r 94 opal/mca/pmix/pmix4x/pmix/src/mca/psquash/flex128/psquash_flex128.c #define FLEX128_PACK_CONVERT(r, t, s, d) \ r 96 opal/mca/pmix/pmix4x/pmix/src/mca/psquash/flex128/psquash_flex128.c (r) = PMIX_SUCCESS; \ r 122 opal/mca/pmix/pmix4x/pmix/src/mca/psquash/flex128/psquash_flex128.c (r) = PMIX_ERR_BAD_PARAM; \ r 175 opal/mca/pmix/pmix4x/pmix/src/mca/psquash/flex128/psquash_flex128.c #define FLEX128_UNPACK_CONVERT(r, t, s, d) \ r 177 opal/mca/pmix/pmix4x/pmix/src/mca/psquash/flex128/psquash_flex128.c (r) = PMIX_SUCCESS; \ r 203 opal/mca/pmix/pmix4x/pmix/src/mca/psquash/flex128/psquash_flex128.c (r) = PMIX_ERR_BAD_PARAM; \ r 146 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl.h #define PMIX_PTL_SEND_RECV(r, p, b, c, d) \ r 149 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl.h (r) = PMIX_ERR_UNREACH; \ r 151 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl.h (r) = (p)->nptr->compat.ptl->send_recv((struct pmix_peer_t*)(p), b, c, d); \ r 155 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl.h #define PMIX_PTL_SEND_ONEWAY(r, p, b, t) \ r 158 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl.h (r) = PMIX_ERR_UNREACH; \ r 160 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl.h (r) = (p)->nptr->compat.ptl->send((struct pmix_peer_t*)(p), b, t); \ r 164 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl.h #define PMIX_PTL_RECV(r, p, c, t) \ r 165 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl.h (r) = (p)->nptr->compat.ptl->recv((struct pmix_peer_t*)(p), c, t) r 167 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl.h #define PMIX_PTL_CANCEL(r, p, t) \ r 168 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl.h (r) = (p)->nptr->compat.ptl->cancel((struct pmix_peer_t*)(p), t) r 263 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl_types.h #define PMIX_SERVER_QUEUE_REPLY(r, p, t, b) \ r 273 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl_types.h (r) = PMIX_ERR_UNREACH; \ r 297 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl_types.h (r) = PMIX_SUCCESS; \ r 42 opal/mca/pmix/pmix4x/pmix/src/util/error.h #define PMIX_ERROR_LOG(r) \ r 44 opal/mca/pmix/pmix4x/pmix/src/util/error.h if (PMIX_ERR_SILENT != (r)) { \ r 46 opal/mca/pmix/pmix4x/pmix/src/util/error.h PMIx_Error_string((r)), __FILE__, __LINE__); \ r 170 opal/mca/pmix/pmix4x/pmix/src/util/pif.c struct addrinfo hints, *res = NULL, *r; r 192 opal/mca/pmix/pmix4x/pmix/src/util/pif.c for (r = res; r != NULL; r = r->ai_next) { r 197 opal/mca/pmix/pmix4x/pmix/src/util/pif.c if (AF_INET == r->ai_family) { r 202 opal/mca/pmix/pmix4x/pmix/src/util/pif.c memcpy (&ipv4, r->ai_addr, r->ai_addrlen); r 212 opal/mca/pmix/pmix4x/pmix/src/util/pif.c &((struct sockaddr_in6*) r->ai_addr)->sin6_addr)) { r 237 opal/mca/pmix/pmix4x/pmix/src/util/pif.c struct addrinfo hints, *res = NULL, *r; r 253 opal/mca/pmix/pmix4x/pmix/src/util/pif.c for (r = res; r != NULL; r = r->ai_next) { r 255 opal/mca/pmix/pmix4x/pmix/src/util/pif.c if (AF_INET == r->ai_family && AF_INET == intf->af_family) { r 258 opal/mca/pmix/pmix4x/pmix/src/util/pif.c len = (r->ai_addrlen < sizeof(struct sockaddr_in)) ? r->ai_addrlen : sizeof(struct sockaddr_in); r 259 opal/mca/pmix/pmix4x/pmix/src/util/pif.c memcpy(&ipv4, r->ai_addr, len); r 267 opal/mca/pmix/pmix4x/pmix/src/util/pif.c } else if (AF_INET6 == r->ai_family && AF_INET6 == intf->af_family) { r 270 opal/mca/pmix/pmix4x/pmix/src/util/pif.c len = (r->ai_addrlen < sizeof(struct sockaddr_in6)) ? r->ai_addrlen : sizeof(struct sockaddr_in6); r 271 opal/mca/pmix/pmix4x/pmix/src/util/pif.c memcpy(&ipv6, r->ai_addr, len); r 242 opal/mca/pmix/pmix4x/pmix/src/util/timings.h #define PMIX_TIMING_ID(n, r) pmix_timing_id((n), (r)); r 391 opal/mca/pmix/pmix4x/pmix/src/util/timings.h #define PMIX_TIMING_ID(n, r) r 497 opal/mca/pmix/pmix4x/pmix/test/pmi2_client.c int i, j, r; r 535 opal/mca/pmix/pmix4x/pmix/test/pmi2_client.c for (r = 0; r < size; r++) { r 541 opal/mca/pmix/pmix4x/pmix/test/pmi2_client.c sprintf(key, "RANK%d-key-%d", r, i); r 543 opal/mca/pmix/pmix4x/pmix/test/pmi2_client.c if (PMI2_SUCCESS != (rc = PMI2_KVS_Get(jobid, r, key, val, sizeof(val), &len))) { r 548 opal/mca/pmix/pmix4x/pmix/test/pmi2_client.c log_info("%d : PMI2_KVS_Get from %d [%s=%s] %d\n", r, rank, key, val, rc); r 552 opal/mca/pmix/pmix4x/pmix/test/pmi2_client.c " %d instead of %d\n", rank, r, i, len, val_size); r 559 opal/mca/pmix/pmix4x/pmix/test/pmi2_client.c r, i, j, val[j], symb); r 253 opal/mca/pmix/pmix4x/pmix/test/test_common.h #define GET(dtype, data, ns, r, fence_num, ind, use_same_keys, blocking, ok_notfnd) do { \ r 261 opal/mca/pmix/pmix4x/pmix/test/test_common.h foobar.rank = r; \ r 262 opal/mca/pmix/pmix4x/pmix/test/test_common.h TEST_VERBOSE(("%s:%d want to get from %s:%d key %s", my_nspace, my_rank, ns, r, key)); \ r 266 opal/mca/pmix/pmix4x/pmix/test/test_common.h TEST_ERROR(("%s:%d: PMIx_Get failed: %d from %s:%d, key %s", my_nspace, my_rank, rc, ns, r, key)); \ r 276 opal/mca/pmix/pmix4x/pmix/test/test_common.h TEST_VERBOSE(("%s:%d: PMIx_Get_nb failed: %d from %s:%d, key=%s", my_nspace, my_rank, rc, ns, r, key)); \ r 294 opal/mca/pmix/pmix4x/pmix/test/test_common.h my_nspace, my_rank, rc, my_nspace, r)); \ r 304 opal/mca/pmix/pmix4x/pmix/test/test_common.h my_nspace, my_rank, ns, r, key, PMIX_VAL_TYPE_ ## dtype, val->type)); \ r 309 opal/mca/pmix/pmix4x/pmix/test/test_common.h TEST_VERBOSE(("%s:%d: GET OF %s from %s:%d SUCCEEDED", my_nspace, my_rank, key, ns, r)); \ r 191 opal/mca/pmix/pmix4x/pmix4x.h #define OPAL_PMIX_NOTIFY_THREADSHIFT(s, sr, r, i, fn, cb, cd) \ r 197 opal/mca/pmix/pmix4x/pmix4x.h _cd->range = (r); \ r 961 opal/mca/pmix/pmix4x/pmix4x_client.c opal_list_t results, *r = NULL; r 1013 opal/mca/pmix/pmix4x/pmix4x_client.c r = &results; r 1019 opal/mca/pmix/pmix4x/pmix4x_client.c op->lkcbfunc(rc, r, op->cbdata); r 1021 opal/mca/pmix/pmix4x/pmix4x_client.c if (NULL != r) { r 29 opal/util/error.h #define OPAL_ERROR_LOG(r) \ r 31 opal/util/error.h opal_strerror((r)), __FILE__, __LINE__); r 163 opal/util/if.c struct addrinfo hints, *res = NULL, *r; r 185 opal/util/if.c for (r = res; r != NULL; r = r->ai_next) { r 187 opal/util/if.c if (AF_INET == r->ai_family) { r 192 opal/util/if.c memcpy (&ipv4, r->ai_addr, r->ai_addrlen); r 203 opal/util/if.c &((struct sockaddr_in6*) r->ai_addr)->sin6_addr)) { r 229 opal/util/if.c struct addrinfo hints, *res = NULL, *r; r 245 opal/util/if.c for (r = res; r != NULL; r = r->ai_next) { r 247 opal/util/if.c if (AF_INET == r->ai_family && AF_INET == intf->af_family) { r 249 opal/util/if.c len = (r->ai_addrlen < sizeof(struct sockaddr_in)) ? r->ai_addrlen : sizeof(struct sockaddr_in); r 250 opal/util/if.c memcpy(&ipv4, r->ai_addr, len); r 258 opal/util/if.c else if (AF_INET6 == r->ai_family && AF_INET6 == intf->af_family) { r 260 opal/util/if.c len = (r->ai_addrlen < sizeof(struct sockaddr_in6)) ? r->ai_addrlen : sizeof(struct sockaddr_in6); r 261 opal/util/if.c memcpy(&ipv6, r->ai_addr, len); r 101 opal/util/qsort.c int d, r, swaptype, swap_cnt; r 130 opal/util/qsort.c while (pb <= pc && (r = CMP(thunk, pb, a)) <= 0) { r 131 opal/util/qsort.c if (r == 0) { r 138 opal/util/qsort.c while (pb <= pc && (r = CMP(thunk, pc, a)) >= 0) { r 139 opal/util/qsort.c if (r == 0) { r 163 opal/util/qsort.c r = (int) min(pa - (char *)a, pb - pa); r 164 opal/util/qsort.c vecswap(a, pb - r, r); r 165 opal/util/qsort.c r = (int) (min((char*) (pd - pc), (char*) (pn - pd - es))); r 166 opal/util/qsort.c vecswap(pb, pn - r, r); r 167 opal/util/qsort.c if ((size_t) (r = pb - pa) > es) r 168 opal/util/qsort.c opal_qsort(a, r / es, es, cmp); r 169 opal/util/qsort.c if ((size_t) (r = pd - pc) > es) { r 171 opal/util/qsort.c a = pn - r; r 172 opal/util/qsort.c n = r / es; r 244 orte/mca/oob/tcp/oob_tcp_sendrecv.h #define ORTE_ACTIVATE_TCP_MSG_ERROR(s, r, h, cbfunc) \ r 257 orte/mca/oob/tcp/oob_tcp_sendrecv.h } else if (NULL != (r)) { \ r 259 orte/mca/oob/tcp/oob_tcp_sendrecv.h proxy = (r); \ r 281 orte/mca/oob/tcp/oob_tcp_sendrecv.h #define ORTE_ACTIVATE_TCP_NO_ROUTE(r, h, c) \ r 290 orte/mca/oob/tcp/oob_tcp_sendrecv.h mop->rmsg = (r); \ r 377 orte/mca/routed/debruijn/routed_debruijn.c register unsigned int r = 0; r 381 orte/mca/routed/debruijn/routed_debruijn.c r |= S[i]; r 385 orte/mca/routed/debruijn/routed_debruijn.c return r; r 134 orte/orted/pmix/pmix_server_fence.c pmix_server_req_t *r; r 165 orte/orted/pmix/pmix_server_fence.c opal_hotel_knock(&orte_pmix_server_globals.reqs, rnum, (void**)&r); r 166 orte/orted/pmix/pmix_server_fence.c if (NULL == r) { r 169 orte/orted/pmix/pmix_server_fence.c if (r->target.jobid == req->target.jobid && r 170 orte/orted/pmix/pmix_server_fence.c r->target.vpid == req->target.vpid) { r 190 orte/runtime/orte_globals.h #define ORTE_COMPUTE_TIME_DIFF(r, ur, s1, us1, s2, us2) \ r 192 orte/runtime/orte_globals.h (r) = (s2) - (s1); \ r 196 orte/runtime/orte_globals.h (r)--; \ r 322 oshmem/mca/memheap/base/memheap_base_mkey.c oob_comm_request_t *r; r 325 oshmem/mca/memheap/base/memheap_base_mkey.c r = (oob_comm_request_t *)opal_list_get_first(&memheap_oob.req_list); r 326 oshmem/mca/memheap/base/memheap_base_mkey.c assert(r); r 327 oshmem/mca/memheap/base/memheap_base_mkey.c while(r != (oob_comm_request_t *)opal_list_get_end(&memheap_oob.req_list)) { r 328 oshmem/mca/memheap/base/memheap_base_mkey.c my_MPI_Test(&r->recv_req, &flag, &status); r 347 oshmem/mca/memheap/base/memheap_base_mkey.c memcpy(tmp_buf, (void*)&r->buf, size); r 367 oshmem/mca/memheap/base/memheap_base_mkey.c rc = PMPI_Start(&r->recv_req); r 373 oshmem/mca/memheap/base/memheap_base_mkey.c opal_list_append(&memheap_oob.req_list, &r->super); r 376 oshmem/mca/memheap/base/memheap_base_mkey.c r = (oob_comm_request_t *)opal_list_get_first(&memheap_oob.req_list); r 377 oshmem/mca/memheap/base/memheap_base_mkey.c assert(r); r 387 oshmem/mca/memheap/base/memheap_base_mkey.c oob_comm_request_t *r; r 397 oshmem/mca/memheap/base/memheap_base_mkey.c r = &memheap_oob.req_pool[i]; r 398 oshmem/mca/memheap/base/memheap_base_mkey.c rc = PMPI_Recv_init(r->buf, sizeof(r->buf), MPI_BYTE, r 401 oshmem/mca/memheap/base/memheap_base_mkey.c &r->recv_req); r 407 oshmem/mca/memheap/base/memheap_base_mkey.c rc = PMPI_Start(&r->recv_req); r 412 oshmem/mca/memheap/base/memheap_base_mkey.c opal_list_append(&memheap_oob.req_list, &r->super); r 424 oshmem/mca/memheap/base/memheap_base_mkey.c oob_comm_request_t *r; r 433 oshmem/mca/memheap/base/memheap_base_mkey.c r = &memheap_oob.req_pool[i]; r 434 oshmem/mca/memheap/base/memheap_base_mkey.c PMPI_Cancel(&r->recv_req); r 435 oshmem/mca/memheap/base/memheap_base_mkey.c PMPI_Request_free(&r->recv_req); r 3877 oshmem/mca/memheap/ptmalloc/malloc.c mchunkptr r = m->top = chunk_plus_offset(p, nb); r 3878 oshmem/mca/memheap/ptmalloc/malloc.c r->head = rsize | PINUSE_BIT; r 4059 oshmem/mca/memheap/ptmalloc/malloc.c mchunkptr r = chunk_plus_offset(v, nb); r 4061 oshmem/mca/memheap/ptmalloc/malloc.c if (RTCHECK(ok_next(v, r))) { r 4067 oshmem/mca/memheap/ptmalloc/malloc.c set_size_and_pinuse_of_free_chunk(r, rsize); r 4068 oshmem/mca/memheap/ptmalloc/malloc.c insert_chunk(m, r, rsize); r 4098 oshmem/mca/memheap/ptmalloc/malloc.c mchunkptr r = chunk_plus_offset(v, nb); r 4100 oshmem/mca/memheap/ptmalloc/malloc.c if (RTCHECK(ok_next(v, r))) { r 4106 oshmem/mca/memheap/ptmalloc/malloc.c set_size_and_pinuse_of_free_chunk(r, rsize); r 4107 oshmem/mca/memheap/ptmalloc/malloc.c replace_dv(m, r, rsize); r 4457 oshmem/mca/memheap/ptmalloc/malloc.c mchunkptr b, p, r; r 4473 oshmem/mca/memheap/ptmalloc/malloc.c r = chunk_plus_offset(p, nb); r 4474 oshmem/mca/memheap/ptmalloc/malloc.c set_size_and_pinuse_of_free_chunk(r, rsize); r 4475 oshmem/mca/memheap/ptmalloc/malloc.c replace_dv(gm, r, rsize); r 4502 oshmem/mca/memheap/ptmalloc/malloc.c mchunkptr r = gm->dv = chunk_plus_offset(p, nb); r 4504 oshmem/mca/memheap/ptmalloc/malloc.c set_size_and_pinuse_of_free_chunk(r, rsize); r 4521 oshmem/mca/memheap/ptmalloc/malloc.c mchunkptr r = gm->top = chunk_plus_offset(p, nb); r 4522 oshmem/mca/memheap/ptmalloc/malloc.c r->head = rsize | PINUSE_BIT; r 4886 oshmem/mca/memheap/ptmalloc/malloc.c mchunkptr b, p, r; r 4902 oshmem/mca/memheap/ptmalloc/malloc.c r = chunk_plus_offset(p, nb); r 4903 oshmem/mca/memheap/ptmalloc/malloc.c set_size_and_pinuse_of_free_chunk(r, rsize); r 4904 oshmem/mca/memheap/ptmalloc/malloc.c replace_dv(ms, r, rsize); r 4931 oshmem/mca/memheap/ptmalloc/malloc.c mchunkptr r = ms->dv = chunk_plus_offset(p, nb); r 4933 oshmem/mca/memheap/ptmalloc/malloc.c set_size_and_pinuse_of_free_chunk(r, rsize); r 4950 oshmem/mca/memheap/ptmalloc/malloc.c mchunkptr r = ms->top = chunk_plus_offset(p, nb); r 4951 oshmem/mca/memheap/ptmalloc/malloc.c r->head = rsize | PINUSE_BIT; r 33 test/class/opal_fifo.c #define timersub(a, b, r) \ r 35 test/class/opal_fifo.c (r)->tv_sec = (a)->tv_sec - (b)->tv_sec; \ r 37 test/class/opal_fifo.c (r)->tv_sec--; \ r 40 test/class/opal_fifo.c (r)->tv_usec = (a)->tv_usec - (b)->tv_usec; \ r 31 test/class/opal_lifo.c #define timersub(a, b, r) \ r 33 test/class/opal_lifo.c (r)->tv_sec = (a)->tv_sec - (b)->tv_sec; \ r 35 test/class/opal_lifo.c (r)->tv_sec--; \ r 38 test/class/opal_lifo.c (r)->tv_usec = (a)->tv_usec - (b)->tv_usec; \