/*
- * Copyright (c) 2010-2012 Apple Inc. All rights reserved.
+ * Copyright (c) 2010-2016 Apple Inc. All rights reserved.
*
* @APPLE_OSREFERENCE_LICENSE_HEADER_START@
*
static struct in_msource *inms_alloc(int);
static void inms_free(struct in_msource *);
-#define IMO_CAST_TO_NONCONST(x) ((struct ip_moptions *)(void *)(uintptr_t)x)
-#define INM_CAST_TO_NONCONST(x) ((struct in_multi *)(void *)(uintptr_t)x)
-
static __inline int
ip_msource_cmp(const struct ip_msource *a, const struct ip_msource *b)
{
int idx;
int nmships;
- IMO_LOCK_ASSERT_HELD(IMO_CAST_TO_NONCONST(imo));
+ IMO_LOCK_ASSERT_HELD(__DECONST(struct ip_moptions *, imo));
gsin = (struct sockaddr_in *)(uintptr_t)(size_t)group;
struct ip_msource *ims;
const sockunion_t *psa;
- IMO_LOCK_ASSERT_HELD(IMO_CAST_TO_NONCONST(imo));
+ IMO_LOCK_ASSERT_HELD(__DECONST(struct ip_moptions *, imo));
VERIFY(src->sa_family == AF_INET);
VERIFY(gidx != (size_t)-1 && gidx < imo->imo_num_memberships);
struct in_msource *ims;
int mode;
- IMO_LOCK_ASSERT_HELD(IMO_CAST_TO_NONCONST(imo));
+ IMO_LOCK_ASSERT_HELD(__DECONST(struct ip_moptions *, imo));
VERIFY(ifp != NULL);
gidx = imo_match_group(imo, ifp, group);
lims->imsl_st[1] = lims->imsl_st[0];
} else {
/* revert source added t1 */
- IGMP_PRINTF(("%s: free inms %p\n", __func__, lims));
+ IGMP_PRINTF(("%s: free inms 0x%llx\n", __func__,
+ (uint64_t)VM_KERNEL_ADDRPERM(lims)));
RB_REMOVE(ip_msource_tree, &imf->imf_sources, ims);
inms_free(lims);
imf->imf_nsrc--;
lims = (struct in_msource *)ims;
if ((lims->imsl_st[0] == MCAST_UNDEFINED) &&
(lims->imsl_st[1] == MCAST_UNDEFINED)) {
- IGMP_PRINTF(("%s: free inms %p\n", __func__, lims));
+ IGMP_PRINTF(("%s: free inms 0x%llx\n", __func__,
+ (uint64_t)VM_KERNEL_ADDRPERM(lims)));
RB_REMOVE(ip_msource_tree, &imf->imf_sources, ims);
inms_free(lims);
imf->imf_nsrc--;
RB_FOREACH_SAFE(ims, ip_msource_tree, &imf->imf_sources, tims) {
lims = (struct in_msource *)ims;
- IGMP_PRINTF(("%s: free inms %p\n", __func__, lims));
+ IGMP_PRINTF(("%s: free inms 0x%llx\n", __func__,
+ (uint64_t)VM_KERNEL_ADDRPERM(lims)));
RB_REMOVE(ip_msource_tree, &imf->imf_sources, ims);
inms_free(lims);
imf->imf_nsrc--;
struct ip_msource *ims, *nims;
#ifdef IGMP_DEBUG
struct in_addr ia;
+ char buf[MAX_IPv4_STR_LEN];
#endif
INM_LOCK_ASSERT_HELD(inm);
ims = nims;
#ifdef IGMP_DEBUG
ia.s_addr = htonl(haddr);
- IGMP_PRINTF(("%s: allocated %s as %p\n", __func__,
- inet_ntoa(ia), ims));
+ inet_ntop(AF_INET, &ia, buf, sizeof(buf));
+ IGMP_PRINTF(("%s: allocated %s as 0x%llx\n", __func__,
+ buf, (uint64_t)VM_KERNEL_ADDRPERM(ims)));
#endif
}
ims_get_mode(const struct in_multi *inm, const struct ip_msource *ims,
uint8_t t)
{
- INM_LOCK_ASSERT_HELD(INM_CAST_TO_NONCONST(inm));
+ INM_LOCK_ASSERT_HELD(__DECONST(struct in_multi *, inm));
t = !!t;
if (inm->inm_st[t].iss_ex > 0 &&
#endif
if (lims->imsl_st[0] == MCAST_EXCLUDE) {
- IGMP_PRINTF(("%s: t1 ex -= %d on %s\n",
- __func__, n, inet_ntoa(ia)));
+ IGMP_INET_PRINTF(ia,
+ ("%s: t1 ex -= %d on %s\n",
+ __func__, n, _igmp_inet_buf));
ims->ims_st[1].ex -= n;
} else if (lims->imsl_st[0] == MCAST_INCLUDE) {
- IGMP_PRINTF(("%s: t1 in -= %d on %s\n",
- __func__, n, inet_ntoa(ia)));
+ IGMP_INET_PRINTF(ia,
+ ("%s: t1 in -= %d on %s\n",
+ __func__, n, _igmp_inet_buf));
ims->ims_st[1].in -= n;
}
if (lims->imsl_st[1] == MCAST_EXCLUDE) {
- IGMP_PRINTF(("%s: t1 ex += %d on %s\n",
- __func__, n, inet_ntoa(ia)));
+ IGMP_INET_PRINTF(ia,
+ ("%s: t1 ex += %d on %s\n",
+ __func__, n, _igmp_inet_buf));
ims->ims_st[1].ex += n;
} else if (lims->imsl_st[1] == MCAST_INCLUDE) {
- IGMP_PRINTF(("%s: t1 in += %d on %s\n",
- __func__, n, inet_ntoa(ia)));
+ IGMP_INET_PRINTF(ia,
+ ("%s: t1 in += %d on %s\n",
+ __func__, n, _igmp_inet_buf));
ims->ims_st[1].in += n;
}
}
inm->inm_st[1].iss_asm++;
}
- IGMP_PRINTF(("%s: merged imf %p to inm %p\n", __func__, imf, inm));
+ IGMP_PRINTF(("%s: merged imf 0x%llx to inm 0x%llx\n", __func__,
+ (uint64_t)VM_KERNEL_ADDRPERM(imf),
+ (uint64_t)VM_KERNEL_ADDRPERM(inm)));
inm_print(inm);
out_reap:
INM_LOCK_ASSERT_HELD(inm);
- IGMP_PRINTF(("%s: commit inm %p\n", __func__, inm));
+ IGMP_PRINTF(("%s: commit inm 0x%llx\n", __func__,
+ (uint64_t)VM_KERNEL_ADDRPERM(inm)));
IGMP_PRINTF(("%s: pre commit:\n", __func__));
inm_print(inm);
ims->ims_st[1].ex > 0 || ims->ims_st[1].in > 0 ||
ims->ims_stp != 0)
continue;
- IGMP_PRINTF(("%s: free ims %p\n", __func__, ims));
+ IGMP_PRINTF(("%s: free ims 0x%llx\n", __func__,
+ (uint64_t)VM_KERNEL_ADDRPERM(ims)));
RB_REMOVE(ip_msource_tree, &inm->inm_srcs, ims);
ipms_free(ims);
inm->inm_nsrc--;
INM_LOCK_ASSERT_HELD(inm);
RB_FOREACH_SAFE(ims, ip_msource_tree, &inm->inm_srcs, tims) {
- IGMP_PRINTF(("%s: free ims %p\n", __func__, ims));
+ IGMP_PRINTF(("%s: free ims 0x%llx\n", __func__,
+ (uint64_t)VM_KERNEL_ADDRPERM(ims)));
RB_REMOVE(ip_msource_tree, &inm->inm_srcs, ims);
ipms_free(ims);
inm->inm_nsrc--;
struct in_mfilter timf;
struct in_multi *inm = NULL;
int error = 0;
+ struct igmp_tparams itp;
- IGMP_PRINTF(("%s: join %s on %p(%s%d))\n", __func__,
- inet_ntoa(*gina), ifp, ifp->if_name, ifp->if_unit));
+ IGMP_INET_PRINTF(*gina, ("%s: join %s on 0x%llx(%s))\n", __func__,
+ _igmp_inet_buf, (uint64_t)VM_KERNEL_ADDRPERM(ifp), if_name(ifp)));
+ bzero(&itp, sizeof (itp));
*pinm = NULL;
/*
}
IGMP_PRINTF(("%s: doing igmp downcall\n", __func__));
- error = igmp_change_state(inm);
+ error = igmp_change_state(inm, &itp);
if (error) {
IGMP_PRINTF(("%s: failed to update source\n", __func__));
+ imf_rollback(imf);
goto out_inm_release;
}
out_inm_release:
if (error) {
- IGMP_PRINTF(("%s: dropping ref on %p\n", __func__, inm));
+ IGMP_PRINTF(("%s: dropping ref on 0x%llx\n", __func__,
+ (uint64_t)VM_KERNEL_ADDRPERM(inm)));
INM_UNLOCK(inm);
INM_REMREF(inm);
} else {
*pinm = inm; /* keep refcount from in_getmulti() */
}
+ /* schedule timer now that we've dropped the lock(s) */
+ igmp_set_timeout(&itp);
+
return (error);
}
{
struct in_mfilter timf;
int error, lastref;
+ struct igmp_tparams itp;
+ bzero(&itp, sizeof (itp));
error = 0;
INM_LOCK_ASSERT_NOTHELD(inm);
in_multihead_lock_exclusive();
INM_LOCK(inm);
- IGMP_PRINTF(("%s: leave inm %p, %s/%s%d, imf %p\n", __func__,
- inm, inet_ntoa(inm->inm_addr),
+ IGMP_INET_PRINTF(inm->inm_addr,
+ ("%s: leave inm 0x%llx, %s/%s%d, imf 0x%llx\n", __func__,
+ (uint64_t)VM_KERNEL_ADDRPERM(inm), _igmp_inet_buf,
(inm_is_ifp_detached(inm) ? "null" : inm->inm_ifp->if_name),
- inm->inm_ifp->if_unit, imf));
+ inm->inm_ifp->if_unit, (uint64_t)VM_KERNEL_ADDRPERM(imf)));
/*
* If no imf was specified (i.e. kernel consumer),
KASSERT(error == 0, ("%s: failed to merge inm state\n", __func__));
IGMP_PRINTF(("%s: doing igmp downcall\n", __func__));
- error = igmp_change_state(inm);
+ error = igmp_change_state(inm, &itp);
#if IGMP_DEBUG
if (error)
IGMP_PRINTF(("%s: failed igmp downcall\n", __func__));
if (lastref)
INM_REMREF(inm); /* for in_multihead list */
+ /* schedule timer now that we've dropped the lock(s) */
+ igmp_set_timeout(&itp);
+
return (error);
}
uint16_t fmode;
int error, doblock;
unsigned int ifindex = 0;
+ struct igmp_tparams itp;
+ bzero(&itp, sizeof (itp));
ifp = NULL;
error = 0;
doblock = 0;
if (sopt->sopt_name == IP_BLOCK_SOURCE)
doblock = 1;
- IGMP_PRINTF(("%s: imr_interface = %s, ifp = %p\n",
- __func__, inet_ntoa(mreqs.imr_interface), ifp));
+ IGMP_INET_PRINTF(mreqs.imr_interface,
+ ("%s: imr_interface = %s, ifp = 0x%llx\n", __func__,
+ _igmp_inet_buf, (uint64_t)VM_KERNEL_ADDRPERM(ifp)));
break;
}
IGMP_PRINTF(("%s: unknown sopt_name %d\n",
__func__, sopt->sopt_name));
return (EOPNOTSUPP);
- break;
}
if (!IN_MULTICAST(ntohl(gsa->sin.sin_addr.s_addr)))
*/
ims = imo_match_source(imo, idx, &ssa->sa);
if ((ims != NULL && doblock) || (ims == NULL && !doblock)) {
- IGMP_PRINTF(("%s: source %s %spresent\n", __func__,
- inet_ntoa(ssa->sin.sin_addr), doblock ? "" : "not "));
+ IGMP_INET_PRINTF(ssa->sin.sin_addr,
+ ("%s: source %s %spresent\n", __func__,
+ _igmp_inet_buf, doblock ? "" : "not "));
error = EADDRNOTAVAIL;
goto out_imo_locked;
}
}
IGMP_PRINTF(("%s: doing igmp downcall\n", __func__));
- error = igmp_change_state(inm);
+ error = igmp_change_state(inm, &itp);
INM_UNLOCK(inm);
#if IGMP_DEBUG
if (error)
out_imo_locked:
IMO_UNLOCK(imo);
IMO_REMREF(imo); /* from inp_findmoptions() */
+
+ /* schedule timer now that we've dropped the lock(s) */
+ igmp_set_timeout(&itp);
+
return (error);
}
if (error)
return (error);
/* we never use msfr.msfr_srcs; */
- memcpy(&msfr, &msfr64, sizeof(msfr));
+ memcpy(&msfr, &msfr64, sizeof(msfr64));
} else {
error = sooptcopyin(sopt, &msfr32,
sizeof(struct __msfilterreq32),
if (error)
return (error);
/* we never use msfr.msfr_srcs; */
- memcpy(&msfr, &msfr32, sizeof(msfr));
+ memcpy(&msfr, &msfr32, sizeof(msfr32));
}
ifnet_head_lock_shared();
return (EADDRNOTAVAIL);
if ((size_t) msfr.msfr_nsrcs >
- SIZE_MAX / sizeof(struct sockaddr_storage))
- msfr.msfr_nsrcs = SIZE_MAX / sizeof(struct sockaddr_storage);
+ UINT32_MAX / sizeof(struct sockaddr_storage))
+ msfr.msfr_nsrcs = UINT32_MAX / sizeof(struct sockaddr_storage);
if (msfr.msfr_nsrcs > in_mcast_maxsocksrc)
msfr.msfr_nsrcs = in_mcast_maxsocksrc;
IMO_UNLOCK(imo);
return (ENOBUFS);
}
- bzero(tss, (size_t) msfr.msfr_nsrcs * sizeof(*tss));
}
/*
msfr32.msfr_ifindex = msfr.msfr_ifindex;
msfr32.msfr_fmode = msfr.msfr_fmode;
msfr32.msfr_nsrcs = msfr.msfr_nsrcs;
- memcpy(&msfr64.msfr_group, &msfr.msfr_group,
+ memcpy(&msfr32.msfr_group, &msfr.msfr_group,
sizeof(struct sockaddr_storage));
error = sooptcopyout(sopt, &msfr32,
sizeof(struct __msfilterreq32));
* If socket is neither of type SOCK_RAW or SOCK_DGRAM,
* or is a divert socket, reject it.
*/
- if (inp->inp_socket->so_proto->pr_protocol == IPPROTO_DIVERT ||
- (inp->inp_socket->so_proto->pr_type != SOCK_RAW &&
- inp->inp_socket->so_proto->pr_type != SOCK_DGRAM)) {
+ if (SOCK_PROTO(inp->inp_socket) == IPPROTO_DIVERT ||
+ (SOCK_TYPE(inp->inp_socket) != SOCK_RAW &&
+ SOCK_TYPE(inp->inp_socket) != SOCK_DGRAM)) {
return (EOPNOTSUPP);
}
error = 0;
switch (sopt->sopt_name) {
-#ifdef MROUTING
- case IP_MULTICAST_VIF:
- if (imo != NULL) {
- IMO_LOCK(imo);
- optval = imo->imo_multicast_vif;
- IMO_UNLOCK(imo);
- } else
- optval = -1;
- error = sooptcopyout(sopt, &optval, sizeof(int));
- break;
-#endif /* MROUTING */
-
case IP_MULTICAST_IF:
memset(&mreqn, 0, sizeof(struct ip_mreqn));
if (imo != NULL) {
if (ro.ro_rt != NULL) {
ifp = ro.ro_rt->rt_ifp;
VERIFY(ifp != NULL);
- rtfree(ro.ro_rt);
} else {
struct in_ifaddr *ia;
struct ifnet *mifp;
}
lck_rw_done(in_ifaddr_rwlock);
}
+ ROUTE_RELEASE(&ro);
}
return (ifp);
struct in_msource *lims;
size_t idx;
int error, is_new;
+ struct igmp_tparams itp;
+ bzero(&itp, sizeof (itp));
ifp = NULL;
imf = NULL;
error = 0;
ifp = inp_lookup_mcast_ifp(inp, &gsa->sin,
mreqs.imr_interface);
- IGMP_PRINTF(("%s: imr_interface = %s, ifp = %p\n",
- __func__, inet_ntoa(mreqs.imr_interface), ifp));
+ IGMP_INET_PRINTF(mreqs.imr_interface,
+ ("%s: imr_interface = %s, ifp = 0x%llx\n", __func__,
+ _igmp_inet_buf, (uint64_t)VM_KERNEL_ADDRPERM(ifp)));
break;
}
IGMP_PRINTF(("%s: unknown sopt_name %d\n",
__func__, sopt->sopt_name));
return (EOPNOTSUPP);
- break;
}
if (ifp == NULL || (ifp->if_flags & IFF_MULTICAST) == 0)
/*
* Begin state merge transaction at IGMP layer.
*/
-
if (is_new) {
+ /*
+ * Unlock socket as we may end up calling ifnet_ioctl() to join (or leave)
+ * the multicast group and we run the risk of a lock ordering issue
+ * if the ifnet thread calls into the socket layer to acquire the pcb list
+ * lock while the input thread delivers multicast packets
+ */
+ IMO_ADDREF_LOCKED(imo);
+ IMO_UNLOCK(imo);
+ socket_unlock(inp->inp_socket, 0);
+
VERIFY(inm == NULL);
error = in_joingroup(ifp, &gsa->sin.sin_addr, imf, &inm);
+
+ socket_lock(inp->inp_socket, 0);
+ IMO_REMREF(imo);
+ IMO_LOCK(imo);
+
VERIFY(inm != NULL || error != 0);
if (error)
goto out_imo_free;
goto out_imf_rollback;
}
IGMP_PRINTF(("%s: doing igmp downcall\n", __func__));
- error = igmp_change_state(inm);
+ error = igmp_change_state(inm, &itp);
INM_UNLOCK(inm);
if (error) {
IGMP_PRINTF(("%s: failed igmp downcall\n",
out_imo_locked:
IMO_UNLOCK(imo);
IMO_REMREF(imo); /* from inp_findmoptions() */
+
+ /* schedule timer now that we've dropped the lock(s) */
+ igmp_set_timeout(&itp);
+
return (error);
}
size_t idx;
int error, is_final;
unsigned int ifindex = 0;
+ struct igmp_tparams itp;
+ bzero(&itp, sizeof (itp));
ifp = NULL;
error = 0;
is_final = 1;
if (!in_nullhost(mreqs.imr_interface))
ifp = ip_multicast_if(&mreqs.imr_interface, &ifindex);
- IGMP_PRINTF(("%s: imr_interface = %s, ifp = %p\n",
- __func__, inet_ntoa(mreqs.imr_interface), ifp));
+ IGMP_INET_PRINTF(mreqs.imr_interface,
+ ("%s: imr_interface = %s, ifp = 0x%llx\n", __func__,
+ _igmp_inet_buf, (uint64_t)VM_KERNEL_ADDRPERM(ifp)));
break;
IGMP_PRINTF(("%s: unknown sopt_name %d\n",
__func__, sopt->sopt_name));
return (EOPNOTSUPP);
- break;
}
if (!IN_MULTICAST(ntohl(gsa->sin.sin_addr.s_addr)))
}
ims = imo_match_source(imo, idx, &ssa->sa);
if (ims == NULL) {
- IGMP_PRINTF(("%s: source %s %spresent\n", __func__,
- inet_ntoa(ssa->sin.sin_addr), "not "));
+ IGMP_INET_PRINTF(ssa->sin.sin_addr,
+ ("%s: source %s %spresent\n", __func__,
+ _igmp_inet_buf, "not "));
error = EADDRNOTAVAIL;
goto out_locked;
}
* Begin state merge transaction at IGMP layer.
*/
+
if (is_final) {
/*
* Give up the multicast address record to which
}
IGMP_PRINTF(("%s: doing igmp downcall\n", __func__));
- error = igmp_change_state(inm);
+ error = igmp_change_state(inm, &itp);
if (error) {
IGMP_PRINTF(("%s: failed igmp downcall\n", __func__));
}
imf_reap(imf);
if (is_final) {
- /* Remove the gap in the membership and filter array. */
+ /* Remove the gap in the membership array. */
VERIFY(inm == imo->imo_membership[idx]);
imo->imo_membership[idx] = NULL;
+
+ /*
+ * See inp_join_group() for why we need to unlock
+ */
+ IMO_ADDREF_LOCKED(imo);
+ IMO_UNLOCK(imo);
+ socket_unlock(inp->inp_socket, 0);
+
INM_REMREF(inm);
+
+ socket_lock(inp->inp_socket, 0);
+ IMO_REMREF(imo);
+ IMO_LOCK(imo);
+
for (++idx; idx < imo->imo_num_memberships; ++idx) {
imo->imo_membership[idx-1] = imo->imo_membership[idx];
imo->imo_mfilters[idx-1] = imo->imo_mfilters[idx];
out_locked:
IMO_UNLOCK(imo);
IMO_REMREF(imo); /* from inp_findmoptions() */
+
+ /* schedule timer now that we've dropped the lock(s) */
+ igmp_set_timeout(&itp);
+
return (error);
}
} else {
ifp = ip_multicast_if(&addr, &ifindex);
if (ifp == NULL) {
- IGMP_PRINTF(("%s: can't find ifp for addr=%s\n",
- __func__, inet_ntoa(addr)));
+ IGMP_INET_PRINTF(addr,
+ ("%s: can't find ifp for addr=%s\n",
+ __func__, _igmp_inet_buf));
return (EADDRNOTAVAIL);
}
}
+ /* XXX remove? */
#ifdef IGMP_DEBUG0
- IGMP_PRINTF(("%s: ifp = %p, addr = %s\n", __func__, ifp,
- inet_ntoa(addr)));
+ IGMP_PRINTF(("%s: ifp = 0x%llx, addr = %s\n", __func__,
+ (uint64_t)VM_KERNEL_ADDRPERM(ifp), inet_ntoa(addr)));
#endif
}
struct in_mfilter *imf;
struct ip_moptions *imo;
struct in_multi *inm;
- size_t idx;
+ size_t idx;
int error;
- user_addr_t tmp_ptr;
+ user_addr_t tmp_ptr;
+ struct igmp_tparams itp;
+
+ bzero(&itp, sizeof (itp));
if (IS_64BIT_PROCESS(current_proc())) {
error = sooptcopyin(sopt, &msfr64,
if (error)
return (error);
/* we never use msfr.msfr_srcs; */
- memcpy(&msfr, &msfr64, sizeof(msfr));
+ memcpy(&msfr, &msfr64, sizeof(msfr64));
} else {
error = sooptcopyin(sopt, &msfr32,
sizeof(struct __msfilterreq32),
if (error)
return (error);
/* we never use msfr.msfr_srcs; */
- memcpy(&msfr, &msfr32, sizeof(msfr));
+ memcpy(&msfr, &msfr32, sizeof(msfr32));
}
if ((size_t) msfr.msfr_nsrcs >
- SIZE_MAX / sizeof(struct sockaddr_storage))
- msfr.msfr_nsrcs = SIZE_MAX / sizeof(struct sockaddr_storage);
+ UINT32_MAX / sizeof(struct sockaddr_storage))
+ msfr.msfr_nsrcs = UINT32_MAX / sizeof(struct sockaddr_storage);
if (msfr.msfr_nsrcs > in_mcast_maxsocksrc)
return (ENOBUFS);
}
IGMP_PRINTF(("%s: doing igmp downcall\n", __func__));
- error = igmp_change_state(inm);
+ error = igmp_change_state(inm, &itp);
INM_UNLOCK(inm);
#ifdef IGMP_DEBUG
if (error)
IMO_UNLOCK(imo);
IMO_REMREF(imo); /* from inp_findmoptions() */
+ /* schedule timer now that we've dropped the lock(s) */
+ igmp_set_timeout(&itp);
+
return (error);
}
* it is not possible to merge the duplicate code, because the idempotence
* of the IPv4 multicast part of the BSD Sockets API must be preserved;
* the effects of these options must be treated as separate and distinct.
- *
- * FUTURE: The IP_MULTICAST_VIF option may be eliminated if MROUTING
- * is refactored to no longer use vifs.
*/
int
inp_setmoptions(struct inpcb *inp, struct sockopt *sopt)
* If socket is neither of type SOCK_RAW or SOCK_DGRAM,
* or is a divert socket, reject it.
*/
- if (inp->inp_socket->so_proto->pr_protocol == IPPROTO_DIVERT ||
- (inp->inp_socket->so_proto->pr_type != SOCK_RAW &&
- inp->inp_socket->so_proto->pr_type != SOCK_DGRAM))
+ if (SOCK_PROTO(inp->inp_socket) == IPPROTO_DIVERT ||
+ (SOCK_TYPE(inp->inp_socket) != SOCK_RAW &&
+ SOCK_TYPE(inp->inp_socket) != SOCK_DGRAM))
return (EOPNOTSUPP);
switch (sopt->sopt_name) {
-#if MROUTING
- case IP_MULTICAST_VIF: {
- int vifi;
- /*
- * Select a multicast VIF for transmission.
- * Only useful if multicast forwarding is active.
- */
- if (legal_vif_num == NULL) {
- error = EOPNOTSUPP;
- break;
- }
- error = sooptcopyin(sopt, &vifi, sizeof(int), sizeof(int));
- if (error)
- break;
- if (!legal_vif_num(vifi) && (vifi != -1)) {
- error = EINVAL;
- break;
- }
- imo = inp_findmoptions(inp);
- if (imo == NULL) {
- error = ENOMEM;
- break;
- }
- IMO_LOCK(imo);
- imo->imo_multicast_vif = vifi;
- IMO_UNLOCK(imo);
- IMO_REMREF(imo); /* from inp_findmoptions() */
- break;
- }
-#endif
case IP_MULTICAST_IF:
error = inp_set_multicast_if(inp, sopt);
break;
group.s_addr = name[1];
if (!IN_MULTICAST(ntohl(group.s_addr))) {
- IGMP_PRINTF(("%s: group %s is not multicast\n",
- __func__, inet_ntoa(group)));
+ IGMP_INET_PRINTF(group,
+ ("%s: group %s is not multicast\n",
+ __func__, _igmp_inet_buf));
ifnet_head_done();
return (EINVAL);
}
#ifdef IGMP_DEBUG
struct in_addr ina;
ina.s_addr = htonl(ims->ims_haddr);
- IGMP_PRINTF(("%s: visit node %s\n", __func__,
- inet_ntoa(ina)));
+ IGMP_INET_PRINTF(ina,
+ ("%s: visit node %s\n", __func__, _igmp_inet_buf));
#endif
/*
* Only copy-out sources which are in-mode.
static const char *inm_statestrs[] = {
"not-member\n",
"silent\n",
+ "reporting\n",
"idle\n",
"lazy\n",
"sleeping\n",
inm_print(const struct in_multi *inm)
{
int t;
+ char buf[MAX_IPv4_STR_LEN];
- INM_LOCK_ASSERT_HELD(INM_CAST_TO_NONCONST(inm));
+ INM_LOCK_ASSERT_HELD(__DECONST(struct in_multi *, inm));
if (igmp_debug == 0)
return;
- printf("%s: --- begin inm %p ---\n", __func__, inm);
- printf("addr %s ifp %p(%s%d) ifma %p\n",
- inet_ntoa(inm->inm_addr),
- inm->inm_ifp,
- inm->inm_ifp->if_name,
- inm->inm_ifp->if_unit,
- inm->inm_ifma);
+ inet_ntop(AF_INET, &inm->inm_addr, buf, sizeof(buf));
+ printf("%s: --- begin inm 0x%llx ---\n", __func__,
+ (uint64_t)VM_KERNEL_ADDRPERM(inm));
+ printf("addr %s ifp 0x%llx(%s) ifma 0x%llx\n",
+ buf,
+ (uint64_t)VM_KERNEL_ADDRPERM(inm->inm_ifp),
+ if_name(inm->inm_ifp),
+ (uint64_t)VM_KERNEL_ADDRPERM(inm->inm_ifma));
printf("timer %u state %s refcount %u scq.len %u\n",
inm->inm_timer,
inm_state_str(inm->inm_state),
inm->inm_refcount,
inm->inm_scq.ifq_len);
- printf("igi %p nsrc %lu sctimer %u scrv %u\n",
- inm->inm_igi,
+ printf("igi 0x%llx nsrc %lu sctimer %u scrv %u\n",
+ (uint64_t)VM_KERNEL_ADDRPERM(inm->inm_igi),
inm->inm_nsrc,
inm->inm_sctimer,
inm->inm_scrv);
inm->inm_st[t].iss_in,
inm->inm_st[t].iss_rec);
}
- printf("%s: --- end inm %p ---\n", __func__, inm);
+ printf("%s: --- end inm 0x%llx ---\n", __func__,
+ (uint64_t)VM_KERNEL_ADDRPERM(inm));
}
#else
projects / apple / xnu.git / blobdiff