diff --git a/sys/netinet/if_ether.c b/sys/netinet/if_ether.c
index bdb4efc..02d9af4 100644
--- a/sys/netinet/if_ether.c
+++ b/sys/netinet/if_ether.c
@@ -165,36 +165,26 @@ arptimer(void *arg)
 {
 	struct ifnet *ifp;
 	struct llentry   *lle;
-	int pkts_dropped;
+	size_t pkts_dropped;
 
 	KASSERT(arg != NULL, ("%s: arg NULL", __func__));
 	lle = (struct llentry *)arg;
+
+	if (lle->la_flags & LLE_STATIC)
+		return;
+
 	ifp = lle->lle_tbl->llt_ifp;
 	CURVNET_SET(ifp->if_vnet);
-	IF_AFDATA_LOCK(ifp);
+	IF_AFDATA_LOCK_ASSERT(ifp);
 	LLE_WLOCK(lle);
-	if (lle->la_flags & LLE_STATIC)
-		LLE_WUNLOCK(lle);
-	else {
-		if (!callout_pending(&lle->la_timer) &&
-		    callout_active(&lle->la_timer)) {
-			callout_stop(&lle->la_timer);
-			LLE_REMREF(lle);
-			pkts_dropped = llentry_free(lle);
-			ARPSTAT_ADD(dropped, pkts_dropped);
-			ARPSTAT_INC(timeouts);
-		} else {
-#ifdef DIAGNOSTIC
-			struct sockaddr *l3addr = L3_ADDR(lle);
-			log(LOG_INFO, 
-			    "arptimer issue: %p, IPv4 address: \"%s\"\n", lle,
-			    inet_ntoa(
-			        ((const struct sockaddr_in *)l3addr)->sin_addr));
-#endif
-			LLE_WUNLOCK(lle);
-		}
-	}
-	IF_AFDATA_UNLOCK(ifp);
+	LLE_REMREF(lle);
+
+	/* llentry_free drops the LLE_WLOCK */
+	pkts_dropped = llentry_free(lle);
+
+	ARPSTAT_ADD(dropped, pkts_dropped);
+	ARPSTAT_INC(timeouts);
+
 	CURVNET_RESTORE();
 }
 
diff --git a/sys/netinet/in.c b/sys/netinet/in.c
index ac0aada..0d5d80e 100644
--- a/sys/netinet/in.c
+++ b/sys/netinet/in.c
@@ -1275,15 +1275,17 @@ in_lltable_free(struct lltable *llt, struct llentry *lle)
 }
 
 static struct llentry *
-in_lltable_new(const struct sockaddr *l3addr, u_int flags)
+in_lltable_new(struct lltable *llt, const struct sockaddr *l3addr, u_int flags)
 {
 	struct in_llentry *lle;
+	struct ifnet *ifp;
 
 	lle = malloc(sizeof(struct in_llentry), M_LLTABLE, M_DONTWAIT | M_ZERO);
 	if (lle == NULL)		/* NB: caller generates msg */
 		return NULL;
 
-	callout_init(&lle->base.la_timer, CALLOUT_MPSAFE);
+	ifp = llt->llt_ifp;
+	callout_init_rw(&lle->base.la_timer, &ifp->if_afdata_lock, 0);
 	/*
 	 * For IPv4 this will trigger "arpresolve" to generate
 	 * an ARP request.
@@ -1292,6 +1294,7 @@ in_lltable_new(const struct sockaddr *l3addr, u_int flags)
 	lle->l3_addr4 = *(const struct sockaddr_in *)l3addr;
 	lle->base.lle_refcnt = 1;
 	lle->base.lle_free = in_lltable_free;
+	lle->base.lle_tbl = llt;
 	LLE_LOCK_INIT(&lle->base);
 	return &lle->base;
 }
@@ -1311,6 +1314,7 @@ in_lltable_prefix_free(struct lltable *llt,
 	register int i;
 	size_t pkts_dropped;
 
+	IF_AFDATA_WLOCK(llt->llt_ifp);
 	for (i=0; i < LLTBL_HASHTBL_SIZE; i++) {
 		LIST_FOREACH_SAFE(lle, &llt->lle_head[i], lle_next, next) {
 
@@ -1318,20 +1322,19 @@ in_lltable_prefix_free(struct lltable *llt,
 			 * (flags & LLE_STATIC) means deleting all entries
 			 * including static ARP entries
 			 */
-			if (IN_ARE_MASKED_ADDR_EQUAL((struct sockaddr_in *)L3_ADDR(lle), 
-						     pfx, msk) &&
-			    ((flags & LLE_STATIC) || !(lle->la_flags & LLE_STATIC))) {
-				int canceled;
+			if (IN_ARE_MASKED_ADDR_EQUAL(satosin(L3_ADDR(lle)), 
+			    pfx, msk) && ((flags & LLE_STATIC) ||
+			    !(lle->la_flags & LLE_STATIC))) {
 
-				canceled = callout_drain(&lle->la_timer);
 				LLE_WLOCK(lle);
-				if (canceled)
+				if (callout_stop(&lle->la_timer))
 					LLE_REMREF(lle);
 				pkts_dropped = llentry_free(lle);
 				ARPSTAT_ADD(dropped, pkts_dropped);
 			}
 		}
 	}
+	IF_AFDATA_WUNLOCK(llt->llt_ifp);
 }
 
 
@@ -1451,7 +1454,7 @@ in_lltable_lookup(struct lltable *llt, u_int flags, const struct sockaddr *l3add
 		    in_lltable_rtcheck(ifp, flags, l3addr) != 0)
 			goto done;
 
-		lle = in_lltable_new(l3addr, flags);
+		lle = in_lltable_new(llt, l3addr, flags);
 		if (lle == NULL) {
 			log(LOG_INFO, "lla_lookup: new lle malloc failed\n");
 			goto done;
@@ -1462,7 +1465,6 @@ in_lltable_lookup(struct lltable *llt, u_int flags, const struct sockaddr *l3add
 			lle->la_flags |= (LLE_VALID | LLE_STATIC);
 		}
 
-		lle->lle_tbl  = llt;
 		lle->lle_head = lleh;
 		LIST_INSERT_HEAD(lleh, lle, lle_next);
 	} else if (flags & LLE_DELETE) {