/dports/net/openmpi3/openmpi-3.1.6/ompi/request/ |
H A D | grequest.c | 52 if (greq->greq_funcs_are_c) { in ompi_grequest_cancel() 53 rc = greq->greq_cancel.c_cancel(greq->greq_state, in ompi_grequest_cancel() 57 greq->greq_cancel.f_cancel((MPI_Aint*)greq->greq_state, &fflag, &ierr); in ompi_grequest_cancel() 73 greq->greq_funcs_are_c = true; in ompi_grequest_construct() 127 if (greq->greq_funcs_are_c) { in ompi_grequest_destruct() 128 greq->greq_free.c_free(greq->greq_state); in ompi_grequest_destruct() 130 greq->greq_free.f_free((MPI_Aint*)greq->greq_state, &ierr); in ompi_grequest_destruct() 153 if(greq == NULL) { in ompi_grequest_start() 158 OBJ_RETAIN(greq); in ompi_grequest_start() 161 greq->greq_state = gstate; in ompi_grequest_start() [all …]
|
/dports/net/openmpi/openmpi-4.1.1/ompi/request/ |
H A D | grequest.c | 52 if (greq->greq_funcs_are_c) { in ompi_grequest_cancel() 53 rc = greq->greq_cancel.c_cancel(greq->greq_state, in ompi_grequest_cancel() 57 greq->greq_cancel.f_cancel((MPI_Aint*)greq->greq_state, &fflag, &ierr); in ompi_grequest_cancel() 73 greq->greq_funcs_are_c = true; in ompi_grequest_construct() 127 if (greq->greq_funcs_are_c) { in ompi_grequest_destruct() 128 greq->greq_free.c_free(greq->greq_state); in ompi_grequest_destruct() 130 greq->greq_free.f_free((MPI_Aint*)greq->greq_state, &ierr); in ompi_grequest_destruct() 153 if(greq == NULL) { in ompi_grequest_start() 158 OBJ_RETAIN(greq); in ompi_grequest_start() 161 greq->greq_state = gstate; in ompi_grequest_start() [all …]
|
/dports/net/py-mpi4py/mpi4py-3.1.3/test/ |
H A D | test_grequest.py | 31 self.assertFalse(greq.Test()) 33 greq.Cancel() 36 greq.Complete() 38 greq.Cancel() 45 greq.Wait() 52 greq.Cancel() 53 greq.Complete() 60 greq.Wait() 65 greq.Cancel() 66 greq.Complete() [all …]
|
/dports/multimedia/libdvbpsi/libdvbpsi-1.3.3/examples/dvbinfo/ |
H A D | udp.c | 104 struct group_req greq; in mcast_connect() local 105 memset(&greq, 0, sizeof(greq)); in mcast_connect() 110 greq.gr_interface = ifindex; in mcast_connect() 111 assert(len <= sizeof(greq.gr_group)); in mcast_connect() 112 memcpy(&greq.gr_group, addr, len); in mcast_connect() 121 greq.gr_interface = sin6->sin6_scope_id; in mcast_connect() 122 if (setsockopt(s, SOL_IPV6, MCAST_JOIN_GROUP, &greq, sizeof(greq)) == 0) in mcast_connect() 127 if (setsockopt(s, SOL_IP, MCAST_JOIN_GROUP, &greq, sizeof(greq)) == 0) in mcast_connect()
|
/dports/net/gnu-radius/radius-1.6.1/radiusd/ |
H A D | radius.c | 174 grad_request_t *greq; in radius_auth_req_decode() local 188 if (!greq) in radius_auth_req_decode() 191 if (validate_client(greq)) { in radius_auth_req_decode() 193 grad_request_free(greq); in radius_auth_req_decode() 197 radreq = radiusd_request_alloc(greq); in radius_auth_req_decode() 224 grad_request_t *greq; in radius_acct_req_decode() local 237 if (!greq) in radius_acct_req_decode() 240 if (validate_client(greq)) { in radius_acct_req_decode() 242 grad_request_free(greq); in radius_acct_req_decode() 246 add_server_address (greq, srv_sa); in radius_acct_req_decode() [all …]
|
/dports/net/udpxy/udpxy-1.0-24.1/chipmunk/test/ |
H A D | mcprobe.c | 89 struct group_req greq; in setup_mcast_socket() local 179 greq.gr_interface = (unsigned)ifc_idx; in setup_mcast_socket() 180 (void) memcpy(&greq.gr_group, &sa, sizeof(sa)); in setup_mcast_socket() 183 &greq, sizeof(greq)); in setup_mcast_socket() 219 struct group_req greq; in close_mcast_socket() local 256 greq.gr_interface = (unsigned)ifc_idx; in close_mcast_socket() 257 (void) memcpy(&greq.gr_group, &addr, sizeof(addr)); in close_mcast_socket() 260 &greq, sizeof(greq)); in close_mcast_socket()
|
/dports/sysutils/node_exporter/node_exporter-1.2.2/vendor/github.com/mdlayher/genetlink/genltest/ |
H A D | family_linux.go | 15 return func(greq genetlink.Message, nreq netlink.Message) ([]genetlink.Message, error) { 17 if nreq.Header.Type != unix.GENL_ID_CTRL || greq.Header.Command != unix.CTRL_CMD_GETFAMILY { 18 return fn(greq, nreq) 21 ad, err := netlink.NewAttributeDecoder(greq.Data)
|
H A D | genltest_test.go | 113 greq genetlink.Message 143 greq: genetlink.Message{ 160 greq: genetlink.Message{ 172 _, err := fn(tt.greq, tt.nreq) 184 var noop = func(greq genetlink.Message, nreq netlink.Message) ([]genetlink.Message, error) {
|
H A D | genltest.go | 40 type Func func(greq genetlink.Message, nreq netlink.Message) ([]genetlink.Message, error) 80 return func(greq genetlink.Message, nreq netlink.Message) ([]genetlink.Message, error) { 85 if want, got := command, greq.Header.Command; command != 0 && want != got { 89 return fn(greq, nreq)
|
/dports/net-mgmt/omping/omping-0.0.4/ |
H A D | sockfunc.c | 388 struct group_source_req greq; in sf_mcast_join_ssm_group() local 423 memset(&greq, 0, sizeof(greq)); in sf_mcast_join_ssm_group() 440 greq.gsr_interface = iface_index; in sf_mcast_join_ssm_group() 441 memcpy(&greq.gsr_group, mcast_addr, addr_len); in sf_mcast_join_ssm_group() 442 memcpy(&greq.gsr_source, remote_addr, addr_len); in sf_mcast_join_ssm_group() 444 if (setsockopt(sock, ip_lv, MCAST_JOIN_SOURCE_GROUP, &greq, sizeof(greq)) == -1) { in sf_mcast_join_ssm_group()
|
/dports/net/mpich/mpich-3.4.3/src/mpid/ch4/src/ |
H A D | ch4r_rma_target_callbacks.c | 743 get_ack.greq_ptr = MPIDIG_REQUEST(rreq, req->greq.greq_ptr); in get_target_cmpl_cb() 744 win = MPIDIG_REQUEST(rreq, req->greq.win_ptr); in get_target_cmpl_cb() 747 if (MPIDIG_REQUEST(rreq, req->greq.flattened_dt) == NULL) { in get_target_cmpl_cb() 778 MPIDIG_REQUEST(rreq, req->greq.dt) = dt; in get_target_cmpl_cb() 779 MPIDIG_REQUEST(rreq, req->greq.count) /= dt->size; in get_target_cmpl_cb() 1049 win = MPIDIG_REQUEST(rreq, req->greq.win_ptr); in get_ack_target_cmpl_cb() 1986 MPIDIG_REQUEST(rreq, req->greq.win_ptr) = win; in MPIDIG_get_target_msg_cb() 1987 MPIDIG_REQUEST(rreq, req->greq.count) = msg_hdr->target_count; in MPIDIG_get_target_msg_cb() 1989 MPIDIG_REQUEST(rreq, req->greq.flattened_dt) = NULL; in MPIDIG_get_target_msg_cb() 1990 MPIDIG_REQUEST(rreq, req->greq.dt) = NULL; in MPIDIG_get_target_msg_cb() [all …]
|
H A D | ch4r_rma_origin_callbacks.c | 66 MPL_free(MPIDIG_REQUEST(req, req->greq.flattened_dt)); in MPIDIG_get_ack_origin_cb() 67 if (MPIDIG_REQUEST(req, req->greq.dt)) in MPIDIG_get_ack_origin_cb() 68 MPIR_Datatype_ptr_release(MPIDIG_REQUEST(req, req->greq.dt)); in MPIDIG_get_ack_origin_cb()
|
/dports/devel/godot-tools/godot-3.2.3-stable/drivers/unix/ |
H A D | net_socket_posix.cpp | 267 struct ip_mreq greq; in _change_multicast_group() local 269 copymem(&greq.imr_multiaddr, p_ip.get_ipv4(), 4); in _change_multicast_group() 270 copymem(&greq.imr_interface, if_ip.get_ipv4(), 4); in _change_multicast_group() 271 ret = setsockopt(_sock, level, sock_opt, (const char *)&greq, sizeof(greq)); in _change_multicast_group() 273 struct ipv6_mreq greq; in _change_multicast_group() local 275 copymem(&greq.ipv6mr_multiaddr, p_ip.get_ipv6(), 16); in _change_multicast_group() 276 greq.ipv6mr_interface = if_v6id; in _change_multicast_group() 277 ret = setsockopt(_sock, level, sock_opt, (const char *)&greq, sizeof(greq)); in _change_multicast_group()
|
/dports/devel/godot/godot-3.2.3-stable/drivers/unix/ |
H A D | net_socket_posix.cpp | 267 struct ip_mreq greq; in _change_multicast_group() local 269 copymem(&greq.imr_multiaddr, p_ip.get_ipv4(), 4); in _change_multicast_group() 270 copymem(&greq.imr_interface, if_ip.get_ipv4(), 4); in _change_multicast_group() 271 ret = setsockopt(_sock, level, sock_opt, (const char *)&greq, sizeof(greq)); in _change_multicast_group() 273 struct ipv6_mreq greq; in _change_multicast_group() local 275 copymem(&greq.ipv6mr_multiaddr, p_ip.get_ipv6(), 16); in _change_multicast_group() 276 greq.ipv6mr_interface = if_v6id; in _change_multicast_group() 277 ret = setsockopt(_sock, level, sock_opt, (const char *)&greq, sizeof(greq)); in _change_multicast_group()
|
/dports/sysutils/node_exporter/node_exporter-1.2.2/vendor/github.com/mdlayher/wifi/ |
H A D | client_linux_test.go | 240 func(greq genetlink.Message, nreq netlink.Message) ([]genetlink.Message, error) { 243 attrs, err := netlink.UnmarshalAttributes(greq.Data) 252 return msgsFn(greq, nreq) 351 func(greq genetlink.Message, nreq netlink.Message) ([]genetlink.Message, error) { 354 attrs, err := netlink.UnmarshalAttributes(greq.Data) 363 return msgsFn(greq, nreq) 401 …c := genltest.Dial(genltest.ServeFamily(family, func(greq genetlink.Message, nreq netlink.Message)… 407 if diff := cmp.Diff(family.Version, greq.Header.Version); diff != "" { 411 msgs, err := fn(greq, nreq)
|
/dports/x11-toolkits/Xaw3d/xc/lib/Xaw3d/ |
H A D | Repeater.c | 205 static void Initialize (greq, gnew, args, num_args) in Initialize() argument 206 Widget greq, gnew; in Initialize() 223 static Boolean SetValues (gcur, greq, gnew, args, num_args) in SetValues() argument 224 Widget gcur, greq, gnew; in SetValues()
|
/dports/x11-toolkits/neXtaw/neXtaw-0.15.1/X11/neXtaw/ |
H A D | Repeater.c | 220 static void Initialize (greq, gnew, args, num_args) in Initialize() argument 221 Widget greq, gnew; in Initialize() 238 static Boolean SetValues (gcur, greq, gnew, args, num_args) in SetValues() argument 239 Widget gcur, greq, gnew; in SetValues()
|
/dports/sysutils/node_exporter/node_exporter-1.2.2/vendor/github.com/mdlayher/genetlink/ |
H A D | family_linux_test.go | 35 …c := genltest.Dial(func(greq genetlink.Message, nreq netlink.Message) ([]genetlink.Message, error)… 40 if diff := cmp.Diff(wantgenl, greq); diff != "" { 96 …c := genltest.Dial(func(greq genetlink.Message, nreq netlink.Message) ([]genetlink.Message, error)… 101 if diff := cmp.Diff(wantgenl, greq); diff != "" {
|
/dports/japanese/skkinput/skkinput-2.06.4/ |
H A D | CliMsg.c | 37 ( Widget greq, Widget gnew, ArgList args, Cardinal *num_args ) ; 110 ( Widget greq, Widget gnew, ArgList args, Cardinal *num_args ) in CM_Initialize() argument
|
H A D | WmcloseShell.c | 36 ( Widget greq, Widget gnew, ArgList args, Cardinal *num_args ) ; 132 ( Widget greq, Widget gnew, ArgList args, Cardinal *num_args ) in WMCS_Initialize() argument
|
H A D | Canvas.c | 61 ( Widget greq, Widget gnew, ArgList args, Cardinal *num_args ) ; 112 ( Widget greq, Widget gnew, ArgList args, Cardinal *num_args ) in Canvas_Initialize() argument
|
/dports/net/php73-sockets/php-7.3.33/ext/sockets/ |
H A D | multicast.c | 455 struct group_req greq = {0}; in _php_mcast_join_leave() local 457 memcpy(&greq.gr_group, group, group_len); in _php_mcast_join_leave() 458 assert(greq.gr_group.ss_family != 0); /* the caller has set this */ in _php_mcast_join_leave() 459 greq.gr_interface = if_index; in _php_mcast_join_leave() 462 join ? MCAST_JOIN_GROUP : MCAST_LEAVE_GROUP, (char*)&greq, in _php_mcast_join_leave() 463 sizeof(greq)); in _php_mcast_join_leave()
|
/dports/net/php81-sockets/php-8.1.1/ext/sockets/ |
H A D | multicast.c | 448 struct group_req greq = {0}; in _php_mcast_join_leave() local 450 memcpy(&greq.gr_group, group, group_len); in _php_mcast_join_leave() 451 assert(greq.gr_group.ss_family != 0); /* the caller has set this */ in _php_mcast_join_leave() 452 greq.gr_interface = if_index; in _php_mcast_join_leave() 455 join ? MCAST_JOIN_GROUP : MCAST_LEAVE_GROUP, (char*)&greq, in _php_mcast_join_leave() 456 sizeof(greq)); in _php_mcast_join_leave()
|
/dports/net/php74-sockets/php-7.4.27/ext/sockets/ |
H A D | multicast.c | 455 struct group_req greq = {0}; in _php_mcast_join_leave() local 457 memcpy(&greq.gr_group, group, group_len); in _php_mcast_join_leave() 458 assert(greq.gr_group.ss_family != 0); /* the caller has set this */ in _php_mcast_join_leave() 459 greq.gr_interface = if_index; in _php_mcast_join_leave() 462 join ? MCAST_JOIN_GROUP : MCAST_LEAVE_GROUP, (char*)&greq, in _php_mcast_join_leave() 463 sizeof(greq)); in _php_mcast_join_leave()
|
/dports/net/php80-sockets/php-8.0.15/ext/sockets/ |
H A D | multicast.c | 448 struct group_req greq = {0}; in _php_mcast_join_leave() local 450 memcpy(&greq.gr_group, group, group_len); in _php_mcast_join_leave() 451 assert(greq.gr_group.ss_family != 0); /* the caller has set this */ in _php_mcast_join_leave() 452 greq.gr_interface = if_index; in _php_mcast_join_leave() 455 join ? MCAST_JOIN_GROUP : MCAST_LEAVE_GROUP, (char*)&greq, in _php_mcast_join_leave() 456 sizeof(greq)); in _php_mcast_join_leave()
|