[jbossnative-commits] JBoss Native SVN: r2325 - trunk/mod_cluster/test/native.

Author: jfrederic.clere(a)jboss.com Date: 2009-02-26 11:34:10 -0500 (Thu, 26 Feb 2009) New Revision: 2325 Modified: trunk/mod_cluster/test/native/Advertise.c Log: Like in mod_advertise... Modified: trunk/mod_cluster/test/native/Advertise.c =================================================================== --- trunk/mod_cluster/test/native/Advertise.c 2009-02-26 16:33:36 UTC (rev 2324) +++ trunk/mod_cluster/test/native/Advertise.c 2009-02-26 16:34:10 UTC (rev 2325) @@ -33,6 +33,8 @@ apr_pool_t *pool; apr_status_t rv; apr_sockaddr_t *ma_mgroup_sa; + apr_sockaddr_t *ma_listen_sa; + apr_sockaddr_t *ma_niface_sa; apr_socket_t *ma_mgroup_socket; char buf[20]; apr_size_t n; @@ -47,17 +49,45 @@ printf("apr_sockaddr_info_get failed %d\n", rv); return 1; } + rv = apr_sockaddr_info_get(&ma_listen_sa, NULL, ma_mgroup_sa->family, 0, APR_UNSPEC, pool); + if (rv != APR_SUCCESS) { + printf("apr_sockaddr_info_get(NULL) failed %d\n", rv); + return 1; + } + rv = apr_sockaddr_info_get(&ma_niface_sa, NULL, ma_mgroup_sa->family, 0, APR_UNSPEC, pool); + if (rv != APR_SUCCESS) { + printf("apr_sockaddr_info_get(NULL) failed %d\n", rv); + return 1; + } rv = apr_socket_create(&ma_mgroup_socket, ma_mgroup_sa->family, SOCK_DGRAM, APR_PROTO_UDP, pool); if (rv != APR_SUCCESS) { printf("apr_socket_create failed %d\n", rv); return 1; } - rv = apr_mcast_join(ma_mgroup_socket, ma_mgroup_sa, NULL, NULL); + rv = apr_socket_bind(ma_mgroup_socket, ma_listen_sa); if (rv != APR_SUCCESS) { + printf("apr_socket_bind failed %d\n", rv); + return 1; + } + + rv = apr_mcast_join(ma_mgroup_socket, ma_mgroup_sa, ma_niface_sa, NULL); + if (rv != APR_SUCCESS) { printf("apr_mcast_join failed %d\n", rv); return 1; } +/* + rv = apr_mcast_loopback(ma_mgroup_socket, 1); + if (rv != APR_SUCCESS) { + printf("apr_mcast_loopback failed %d\n", rv); + return 1; + } + */ + rv = apr_mcast_hops(ma_mgroup_socket, 10); + if (rv != APR_SUCCESS) { + printf("apr_mcast_hops failed %d\n", rv); + return 1; + } n = apr_snprintf(buf, 20, "Advertize !!!\n"); rv = apr_socket_sendto(ma_mgroup_socket,