]> bbs.cooldavid.org Git - net-next-2.6.git/blobdiff - net/xfrm/xfrm_user.c
[XFRM] netlink: Inline attach_encap_tmpl(), attach_sec_ctx(), and attach_one_addr()
[net-next-2.6.git] / net / xfrm / xfrm_user.c
index c06883bf620ee21fa896654847fc4ee85f445e33..9e516f5cbb5e2bb50fde5f5ccb6398bd0c7c8274 100644 (file)
@@ -19,7 +19,6 @@
 #include <linux/string.h>
 #include <linux/net.h>
 #include <linux/skbuff.h>
-#include <linux/rtnetlink.h>
 #include <linux/pfkeyv2.h>
 #include <linux/ipsec.h>
 #include <linux/init.h>
 #endif
 #include <linux/audit.h>
 
-static int verify_one_alg(struct rtattr **xfrma, enum xfrm_attr_type_t type)
+static inline int alg_len(struct xfrm_algo *alg)
 {
-       struct rtattr *rt = xfrma[type - 1];
+       return sizeof(*alg) + ((alg->alg_key_len + 7) / 8);
+}
+
+static int verify_one_alg(struct nlattr **attrs, enum xfrm_attr_type_t type)
+{
+       struct nlattr *rt = attrs[type];
        struct xfrm_algo *algp;
-       int len;
 
        if (!rt)
                return 0;
 
-       len = (rt->rta_len - sizeof(*rt)) - sizeof(*algp);
-       if (len < 0)
-               return -EINVAL;
-
-       algp = RTA_DATA(rt);
-
-       len -= (algp->alg_key_len + 7U) / 8;
-       if (len < 0)
+       algp = nla_data(rt);
+       if (nla_len(rt) < alg_len(algp))
                return -EINVAL;
 
        switch (type) {
@@ -77,55 +74,25 @@ static int verify_one_alg(struct rtattr **xfrma, enum xfrm_attr_type_t type)
        return 0;
 }
 
-static int verify_encap_tmpl(struct rtattr **xfrma)
-{
-       struct rtattr *rt = xfrma[XFRMA_ENCAP - 1];
-       struct xfrm_encap_tmpl *encap;
-
-       if (!rt)
-               return 0;
-
-       if ((rt->rta_len - sizeof(*rt)) < sizeof(*encap))
-               return -EINVAL;
-
-       return 0;
-}
-
-static int verify_one_addr(struct rtattr **xfrma, enum xfrm_attr_type_t type,
+static void verify_one_addr(struct nlattr **attrs, enum xfrm_attr_type_t type,
                           xfrm_address_t **addrp)
 {
-       struct rtattr *rt = xfrma[type - 1];
+       struct nlattr *rt = attrs[type];
 
-       if (!rt)
-               return 0;
-
-       if ((rt->rta_len - sizeof(*rt)) < sizeof(**addrp))
-               return -EINVAL;
-
-       if (addrp)
-               *addrp = RTA_DATA(rt);
-
-       return 0;
+       if (rt && addrp)
+               *addrp = nla_data(rt);
 }
 
-static inline int verify_sec_ctx_len(struct rtattr **xfrma)
+static inline int verify_sec_ctx_len(struct nlattr **attrs)
 {
-       struct rtattr *rt = xfrma[XFRMA_SEC_CTX - 1];
+       struct nlattr *rt = attrs[XFRMA_SEC_CTX];
        struct xfrm_user_sec_ctx *uctx;
-       int len = 0;
 
        if (!rt)
                return 0;
 
-       if (rt->rta_len < sizeof(*uctx))
-               return -EINVAL;
-
-       uctx = RTA_DATA(rt);
-
-       len += sizeof(struct xfrm_user_sec_ctx);
-       len += uctx->ctx_len;
-
-       if (uctx->len != len)
+       uctx = nla_data(rt);
+       if (uctx->len != (sizeof(struct xfrm_user_sec_ctx) + uctx->ctx_len))
                return -EINVAL;
 
        return 0;
@@ -133,7 +100,7 @@ static inline int verify_sec_ctx_len(struct rtattr **xfrma)
 
 
 static int verify_newsa_info(struct xfrm_usersa_info *p,
-                            struct rtattr **xfrma)
+                            struct nlattr **attrs)
 {
        int err;
 
@@ -157,35 +124,35 @@ static int verify_newsa_info(struct xfrm_usersa_info *p,
        err = -EINVAL;
        switch (p->id.proto) {
        case IPPROTO_AH:
-               if (!xfrma[XFRMA_ALG_AUTH-1]    ||
-                   xfrma[XFRMA_ALG_CRYPT-1]    ||
-                   xfrma[XFRMA_ALG_COMP-1])
+               if (!attrs[XFRMA_ALG_AUTH]      ||
+                   attrs[XFRMA_ALG_CRYPT]      ||
+                   attrs[XFRMA_ALG_COMP])
                        goto out;
                break;
 
        case IPPROTO_ESP:
-               if ((!xfrma[XFRMA_ALG_AUTH-1] &&
-                    !xfrma[XFRMA_ALG_CRYPT-1]) ||
-                   xfrma[XFRMA_ALG_COMP-1])
+               if ((!attrs[XFRMA_ALG_AUTH] &&
+                    !attrs[XFRMA_ALG_CRYPT])   ||
+                   attrs[XFRMA_ALG_COMP])
                        goto out;
                break;
 
        case IPPROTO_COMP:
-               if (!xfrma[XFRMA_ALG_COMP-1]    ||
-                   xfrma[XFRMA_ALG_AUTH-1]     ||
-                   xfrma[XFRMA_ALG_CRYPT-1])
+               if (!attrs[XFRMA_ALG_COMP]      ||
+                   attrs[XFRMA_ALG_AUTH]       ||
+                   attrs[XFRMA_ALG_CRYPT])
                        goto out;
                break;
 
 #if defined(CONFIG_IPV6) || defined(CONFIG_IPV6_MODULE)
        case IPPROTO_DSTOPTS:
        case IPPROTO_ROUTING:
-               if (xfrma[XFRMA_ALG_COMP-1]     ||
-                   xfrma[XFRMA_ALG_AUTH-1]     ||
-                   xfrma[XFRMA_ALG_CRYPT-1]    ||
-                   xfrma[XFRMA_ENCAP-1]        ||
-                   xfrma[XFRMA_SEC_CTX-1]      ||
-                   !xfrma[XFRMA_COADDR-1])
+               if (attrs[XFRMA_ALG_COMP]       ||
+                   attrs[XFRMA_ALG_AUTH]       ||
+                   attrs[XFRMA_ALG_CRYPT]      ||
+                   attrs[XFRMA_ENCAP]          ||
+                   attrs[XFRMA_SEC_CTX]        ||
+                   !attrs[XFRMA_COADDR])
                        goto out;
                break;
 #endif
@@ -194,17 +161,13 @@ static int verify_newsa_info(struct xfrm_usersa_info *p,
                goto out;
        }
 
-       if ((err = verify_one_alg(xfrma, XFRMA_ALG_AUTH)))
-               goto out;
-       if ((err = verify_one_alg(xfrma, XFRMA_ALG_CRYPT)))
+       if ((err = verify_one_alg(attrs, XFRMA_ALG_AUTH)))
                goto out;
-       if ((err = verify_one_alg(xfrma, XFRMA_ALG_COMP)))
+       if ((err = verify_one_alg(attrs, XFRMA_ALG_CRYPT)))
                goto out;
-       if ((err = verify_encap_tmpl(xfrma)))
+       if ((err = verify_one_alg(attrs, XFRMA_ALG_COMP)))
                goto out;
-       if ((err = verify_sec_ctx_len(xfrma)))
-               goto out;
-       if ((err = verify_one_addr(xfrma, XFRMA_COADDR, NULL)))
+       if ((err = verify_sec_ctx_len(attrs)))
                goto out;
 
        err = -EINVAL;
@@ -227,25 +190,22 @@ out:
 
 static int attach_one_algo(struct xfrm_algo **algpp, u8 *props,
                           struct xfrm_algo_desc *(*get_byname)(char *, int),
-                          struct rtattr *u_arg)
+                          struct nlattr *rta)
 {
-       struct rtattr *rta = u_arg;
        struct xfrm_algo *p, *ualg;
        struct xfrm_algo_desc *algo;
-       int len;
 
        if (!rta)
                return 0;
 
-       ualg = RTA_DATA(rta);
+       ualg = nla_data(rta);
 
        algo = get_byname(ualg->alg_name, 1);
        if (!algo)
                return -ENOSYS;
        *props = algo->desc.sadb_alg_id;
 
-       len = sizeof(*ualg) + (ualg->alg_key_len + 7U) / 8;
-       p = kmemdup(ualg, len, GFP_KERNEL);
+       p = kmemdup(ualg, alg_len(ualg), GFP_KERNEL);
        if (!p)
                return -ENOMEM;
 
@@ -254,24 +214,6 @@ static int attach_one_algo(struct xfrm_algo **algpp, u8 *props,
        return 0;
 }
 
-static int attach_encap_tmpl(struct xfrm_encap_tmpl **encapp, struct rtattr *u_arg)
-{
-       struct rtattr *rta = u_arg;
-       struct xfrm_encap_tmpl *p, *uencap;
-
-       if (!rta)
-               return 0;
-
-       uencap = RTA_DATA(rta);
-       p = kmemdup(uencap, sizeof(*p), GFP_KERNEL);
-       if (!p)
-               return -ENOMEM;
-
-       *encapp = p;
-       return 0;
-}
-
-
 static inline int xfrm_user_sec_ctx_size(struct xfrm_sec_ctx *xfrm_ctx)
 {
        int len = 0;
@@ -283,34 +225,6 @@ static inline int xfrm_user_sec_ctx_size(struct xfrm_sec_ctx *xfrm_ctx)
        return len;
 }
 
-static int attach_sec_ctx(struct xfrm_state *x, struct rtattr *u_arg)
-{
-       struct xfrm_user_sec_ctx *uctx;
-
-       if (!u_arg)
-               return 0;
-
-       uctx = RTA_DATA(u_arg);
-       return security_xfrm_state_alloc(x, uctx);
-}
-
-static int attach_one_addr(xfrm_address_t **addrpp, struct rtattr *u_arg)
-{
-       struct rtattr *rta = u_arg;
-       xfrm_address_t *p, *uaddrp;
-
-       if (!rta)
-               return 0;
-
-       uaddrp = RTA_DATA(rta);
-       p = kmemdup(uaddrp, sizeof(*p), GFP_KERNEL);
-       if (!p)
-               return -ENOMEM;
-
-       *addrpp = p;
-       return 0;
-}
-
 static void copy_from_user_state(struct xfrm_state *x, struct xfrm_usersa_info *p)
 {
        memcpy(&x->id, &p->id, sizeof(x->id));
@@ -322,6 +236,13 @@ static void copy_from_user_state(struct xfrm_state *x, struct xfrm_usersa_info *
        x->props.family = p->family;
        memcpy(&x->props.saddr, &p->saddr, sizeof(x->props.saddr));
        x->props.flags = p->flags;
+
+       /*
+        * Set inner address family if the KM left it as zero.
+        * See comment in validate_tmpl.
+        */
+       if (!x->sel.family)
+               x->sel.family = p->family;
 }
 
 /*
@@ -329,53 +250,38 @@ static void copy_from_user_state(struct xfrm_state *x, struct xfrm_usersa_info *
  * somehow made shareable and move it to xfrm_state.c - JHS
  *
 */
-static int xfrm_update_ae_params(struct xfrm_state *x, struct rtattr **xfrma)
+static void xfrm_update_ae_params(struct xfrm_state *x, struct nlattr **attrs)
 {
-       int err = - EINVAL;
-       struct rtattr *rp = xfrma[XFRMA_REPLAY_VAL-1];
-       struct rtattr *lt = xfrma[XFRMA_LTIME_VAL-1];
-       struct rtattr *et = xfrma[XFRMA_ETIMER_THRESH-1];
-       struct rtattr *rt = xfrma[XFRMA_REPLAY_THRESH-1];
+       struct nlattr *rp = attrs[XFRMA_REPLAY_VAL];
+       struct nlattr *lt = attrs[XFRMA_LTIME_VAL];
+       struct nlattr *et = attrs[XFRMA_ETIMER_THRESH];
+       struct nlattr *rt = attrs[XFRMA_REPLAY_THRESH];
 
        if (rp) {
                struct xfrm_replay_state *replay;
-               if (RTA_PAYLOAD(rp) < sizeof(*replay))
-                       goto error;
-               replay = RTA_DATA(rp);
+               replay = nla_data(rp);
                memcpy(&x->replay, replay, sizeof(*replay));
                memcpy(&x->preplay, replay, sizeof(*replay));
        }
 
        if (lt) {
                struct xfrm_lifetime_cur *ltime;
-               if (RTA_PAYLOAD(lt) < sizeof(*ltime))
-                       goto error;
-               ltime = RTA_DATA(lt);
+               ltime = nla_data(lt);
                x->curlft.bytes = ltime->bytes;
                x->curlft.packets = ltime->packets;
                x->curlft.add_time = ltime->add_time;
                x->curlft.use_time = ltime->use_time;
        }
 
-       if (et) {
-               if (RTA_PAYLOAD(et) < sizeof(u32))
-                       goto error;
-               x->replay_maxage = *(u32*)RTA_DATA(et);
-       }
+       if (et)
+               x->replay_maxage = nla_get_u32(et);
 
-       if (rt) {
-               if (RTA_PAYLOAD(rt) < sizeof(u32))
-                       goto error;
-               x->replay_maxdiff = *(u32*)RTA_DATA(rt);
-       }
-
-       return 0;
-error:
-       return err;
+       if (rt)
+               x->replay_maxdiff = nla_get_u32(rt);
 }
 
 static struct xfrm_state *xfrm_state_construct(struct xfrm_usersa_info *p,
-                                              struct rtattr **xfrma,
+                                              struct nlattr **attrs,
                                               int *errp)
 {
        struct xfrm_state *x = xfrm_state_alloc();
@@ -388,25 +294,37 @@ static struct xfrm_state *xfrm_state_construct(struct xfrm_usersa_info *p,
 
        if ((err = attach_one_algo(&x->aalg, &x->props.aalgo,
                                   xfrm_aalg_get_byname,
-                                  xfrma[XFRMA_ALG_AUTH-1])))
+                                  attrs[XFRMA_ALG_AUTH])))
                goto error;
        if ((err = attach_one_algo(&x->ealg, &x->props.ealgo,
                                   xfrm_ealg_get_byname,
-                                  xfrma[XFRMA_ALG_CRYPT-1])))
+                                  attrs[XFRMA_ALG_CRYPT])))
                goto error;
        if ((err = attach_one_algo(&x->calg, &x->props.calgo,
                                   xfrm_calg_get_byname,
-                                  xfrma[XFRMA_ALG_COMP-1])))
-               goto error;
-       if ((err = attach_encap_tmpl(&x->encap, xfrma[XFRMA_ENCAP-1])))
-               goto error;
-       if ((err = attach_one_addr(&x->coaddr, xfrma[XFRMA_COADDR-1])))
+                                  attrs[XFRMA_ALG_COMP])))
                goto error;
+
+       if (attrs[XFRMA_ENCAP]) {
+               x->encap = kmemdup(nla_data(attrs[XFRMA_ENCAP]),
+                                  sizeof(*x->encap), GFP_KERNEL);
+               if (x->encap == NULL)
+                       goto error;
+       }
+
+       if (attrs[XFRMA_COADDR]) {
+               x->coaddr = kmemdup(nla_data(attrs[XFRMA_COADDR]),
+                                   sizeof(*x->coaddr), GFP_KERNEL);
+               if (x->coaddr == NULL)
+                       goto error;
+       }
+
        err = xfrm_init_state(x);
        if (err)
                goto error;
 
-       if ((err = attach_sec_ctx(x, xfrma[XFRMA_SEC_CTX-1])))
+       if (attrs[XFRMA_SEC_CTX] &&
+           security_xfrm_state_alloc(x, nla_data(attrs[XFRMA_SEC_CTX])))
                goto error;
 
        x->km.seq = p->seq;
@@ -419,9 +337,7 @@ static struct xfrm_state *xfrm_state_construct(struct xfrm_usersa_info *p,
 
        /* override default values from above */
 
-       err = xfrm_update_ae_params(x, (struct rtattr **)xfrma);
-       if (err < 0)
-               goto error;
+       xfrm_update_ae_params(x, attrs);
 
        return x;
 
@@ -434,18 +350,18 @@ error_no_put:
 }
 
 static int xfrm_add_sa(struct sk_buff *skb, struct nlmsghdr *nlh,
-               struct rtattr **xfrma)
+               struct nlattr **attrs)
 {
-       struct xfrm_usersa_info *p = NLMSG_DATA(nlh);
+       struct xfrm_usersa_info *p = nlmsg_data(nlh);
        struct xfrm_state *x;
        int err;
        struct km_event c;
 
-       err = verify_newsa_info(p, xfrma);
+       err = verify_newsa_info(p, attrs);
        if (err)
                return err;
 
-       x = xfrm_state_construct(p, xfrma, &err);
+       x = xfrm_state_construct(p, attrs, &err);
        if (!x)
                return err;
 
@@ -475,7 +391,7 @@ out:
 }
 
 static struct xfrm_state *xfrm_user_state_lookup(struct xfrm_usersa_id *p,
-                                                struct rtattr **xfrma,
+                                                struct nlattr **attrs,
                                                 int *errp)
 {
        struct xfrm_state *x = NULL;
@@ -487,10 +403,7 @@ static struct xfrm_state *xfrm_user_state_lookup(struct xfrm_usersa_id *p,
        } else {
                xfrm_address_t *saddr = NULL;
 
-               err = verify_one_addr(xfrma, XFRMA_SRCADDR, &saddr);
-               if (err)
-                       goto out;
-
+               verify_one_addr(attrs, XFRMA_SRCADDR, &saddr);
                if (!saddr) {
                        err = -EINVAL;
                        goto out;
@@ -508,14 +421,14 @@ static struct xfrm_state *xfrm_user_state_lookup(struct xfrm_usersa_id *p,
 }
 
 static int xfrm_del_sa(struct sk_buff *skb, struct nlmsghdr *nlh,
-               struct rtattr **xfrma)
+               struct nlattr **attrs)
 {
        struct xfrm_state *x;
        int err = -ESRCH;
        struct km_event c;
-       struct xfrm_usersa_id *p = NLMSG_DATA(nlh);
+       struct xfrm_usersa_id *p = nlmsg_data(nlh);
 
-       x = xfrm_user_state_lookup(p, xfrma, &err);
+       x = xfrm_user_state_lookup(p, attrs, &err);
        if (x == NULL)
                return err;
 
@@ -569,6 +482,27 @@ struct xfrm_dump_info {
        int this_idx;
 };
 
+static int copy_sec_ctx(struct xfrm_sec_ctx *s, struct sk_buff *skb)
+{
+       int ctx_size = sizeof(struct xfrm_sec_ctx) + s->ctx_len;
+       struct xfrm_user_sec_ctx *uctx;
+       struct nlattr *attr;
+
+       attr = nla_reserve(skb, XFRMA_SEC_CTX, ctx_size);
+       if (attr == NULL)
+               return -EMSGSIZE;
+
+       uctx = nla_data(attr);
+       uctx->exttype = XFRMA_SEC_CTX;
+       uctx->len = ctx_size;
+       uctx->ctx_doi = s->ctx_doi;
+       uctx->ctx_alg = s->ctx_alg;
+       uctx->ctx_len = s->ctx_len;
+       memcpy(uctx + 1, s->ctx_str, s->ctx_len);
+
+       return 0;
+}
+
 static int dump_one_state(struct xfrm_state *x, int count, void *ptr)
 {
        struct xfrm_dump_info *sp = ptr;
@@ -576,60 +510,45 @@ static int dump_one_state(struct xfrm_state *x, int count, void *ptr)
        struct sk_buff *skb = sp->out_skb;
        struct xfrm_usersa_info *p;
        struct nlmsghdr *nlh;
-       unsigned char *b = skb_tail_pointer(skb);
 
        if (sp->this_idx < sp->start_idx)
                goto out;
 
-       nlh = NLMSG_PUT(skb, NETLINK_CB(in_skb).pid,
-                       sp->nlmsg_seq,
-                       XFRM_MSG_NEWSA, sizeof(*p));
-       nlh->nlmsg_flags = sp->nlmsg_flags;
+       nlh = nlmsg_put(skb, NETLINK_CB(in_skb).pid, sp->nlmsg_seq,
+                       XFRM_MSG_NEWSA, sizeof(*p), sp->nlmsg_flags);
+       if (nlh == NULL)
+               return -EMSGSIZE;
 
-       p = NLMSG_DATA(nlh);
+       p = nlmsg_data(nlh);
        copy_to_user_state(x, p);
 
        if (x->aalg)
-               RTA_PUT(skb, XFRMA_ALG_AUTH,
-                       sizeof(*(x->aalg))+(x->aalg->alg_key_len+7)/8, x->aalg);
+               NLA_PUT(skb, XFRMA_ALG_AUTH, alg_len(x->aalg), x->aalg);
        if (x->ealg)
-               RTA_PUT(skb, XFRMA_ALG_CRYPT,
-                       sizeof(*(x->ealg))+(x->ealg->alg_key_len+7)/8, x->ealg);
+               NLA_PUT(skb, XFRMA_ALG_CRYPT, alg_len(x->ealg), x->ealg);
        if (x->calg)
-               RTA_PUT(skb, XFRMA_ALG_COMP, sizeof(*(x->calg)), x->calg);
+               NLA_PUT(skb, XFRMA_ALG_COMP, sizeof(*(x->calg)), x->calg);
 
        if (x->encap)
-               RTA_PUT(skb, XFRMA_ENCAP, sizeof(*x->encap), x->encap);
+               NLA_PUT(skb, XFRMA_ENCAP, sizeof(*x->encap), x->encap);
 
-       if (x->security) {
-               int ctx_size = sizeof(struct xfrm_sec_ctx) +
-                               x->security->ctx_len;
-               struct rtattr *rt = __RTA_PUT(skb, XFRMA_SEC_CTX, ctx_size);
-               struct xfrm_user_sec_ctx *uctx = RTA_DATA(rt);
-
-               uctx->exttype = XFRMA_SEC_CTX;
-               uctx->len = ctx_size;
-               uctx->ctx_doi = x->security->ctx_doi;
-               uctx->ctx_alg = x->security->ctx_alg;
-               uctx->ctx_len = x->security->ctx_len;
-               memcpy(uctx + 1, x->security->ctx_str, x->security->ctx_len);
-       }
+       if (x->security && copy_sec_ctx(x->security, skb) < 0)
+               goto nla_put_failure;
 
        if (x->coaddr)
-               RTA_PUT(skb, XFRMA_COADDR, sizeof(*x->coaddr), x->coaddr);
+               NLA_PUT(skb, XFRMA_COADDR, sizeof(*x->coaddr), x->coaddr);
 
        if (x->lastused)
-               RTA_PUT(skb, XFRMA_LASTUSED, sizeof(x->lastused), &x->lastused);
+               NLA_PUT_U64(skb, XFRMA_LASTUSED, x->lastused);
 
-       nlh->nlmsg_len = skb_tail_pointer(skb) - b;
+       nlmsg_end(skb, nlh);
 out:
        sp->this_idx++;
        return 0;
 
-nlmsg_failure:
-rtattr_failure:
-       nlmsg_trim(skb, b);
-       return -1;
+nla_put_failure:
+       nlmsg_cancel(skb, nlh);
+       return -EMSGSIZE;
 }
 
 static int xfrm_dump_sa(struct sk_buff *skb, struct netlink_callback *cb)
@@ -654,7 +573,7 @@ static struct sk_buff *xfrm_state_netlink(struct sk_buff *in_skb,
        struct xfrm_dump_info info;
        struct sk_buff *skb;
 
-       skb = alloc_skb(NLMSG_GOODSIZE, GFP_ATOMIC);
+       skb = nlmsg_new(NLMSG_DEFAULT_SIZE, GFP_ATOMIC);
        if (!skb)
                return ERR_PTR(-ENOMEM);
 
@@ -672,6 +591,13 @@ static struct sk_buff *xfrm_state_netlink(struct sk_buff *in_skb,
        return skb;
 }
 
+static inline size_t xfrm_spdinfo_msgsize(void)
+{
+       return NLMSG_ALIGN(4)
+              + nla_total_size(sizeof(struct xfrmu_spdinfo))
+              + nla_total_size(sizeof(struct xfrmu_spdhinfo));
+}
+
 static int build_spdinfo(struct sk_buff *skb, u32 pid, u32 seq, u32 flags)
 {
        struct xfrmk_spdinfo si;
@@ -707,18 +633,14 @@ nla_put_failure:
 }
 
 static int xfrm_get_spdinfo(struct sk_buff *skb, struct nlmsghdr *nlh,
-               struct rtattr **xfrma)
+               struct nlattr **attrs)
 {
        struct sk_buff *r_skb;
-       u32 *flags = NLMSG_DATA(nlh);
+       u32 *flags = nlmsg_data(nlh);
        u32 spid = NETLINK_CB(skb).pid;
        u32 seq = nlh->nlmsg_seq;
-       int len = NLMSG_LENGTH(sizeof(u32));
-
-       len += RTA_SPACE(sizeof(struct xfrmu_spdinfo));
-       len += RTA_SPACE(sizeof(struct xfrmu_spdhinfo));
 
-       r_skb = alloc_skb(len, GFP_ATOMIC);
+       r_skb = nlmsg_new(xfrm_spdinfo_msgsize(), GFP_ATOMIC);
        if (r_skb == NULL)
                return -ENOMEM;
 
@@ -728,6 +650,13 @@ static int xfrm_get_spdinfo(struct sk_buff *skb, struct nlmsghdr *nlh,
        return nlmsg_unicast(xfrm_nl, r_skb, spid);
 }
 
+static inline size_t xfrm_sadinfo_msgsize(void)
+{
+       return NLMSG_ALIGN(4)
+              + nla_total_size(sizeof(struct xfrmu_sadhinfo))
+              + nla_total_size(4); /* XFRMA_SAD_CNT */
+}
+
 static int build_sadinfo(struct sk_buff *skb, u32 pid, u32 seq, u32 flags)
 {
        struct xfrmk_sadinfo si;
@@ -757,19 +686,14 @@ nla_put_failure:
 }
 
 static int xfrm_get_sadinfo(struct sk_buff *skb, struct nlmsghdr *nlh,
-               struct rtattr **xfrma)
+               struct nlattr **attrs)
 {
        struct sk_buff *r_skb;
-       u32 *flags = NLMSG_DATA(nlh);
+       u32 *flags = nlmsg_data(nlh);
        u32 spid = NETLINK_CB(skb).pid;
        u32 seq = nlh->nlmsg_seq;
-       int len = NLMSG_LENGTH(sizeof(u32));
-
-       len += RTA_SPACE(sizeof(struct xfrmu_sadhinfo));
-       len += RTA_SPACE(sizeof(u32));
-
-       r_skb = alloc_skb(len, GFP_ATOMIC);
 
+       r_skb = nlmsg_new(xfrm_sadinfo_msgsize(), GFP_ATOMIC);
        if (r_skb == NULL)
                return -ENOMEM;
 
@@ -780,14 +704,14 @@ static int xfrm_get_sadinfo(struct sk_buff *skb, struct nlmsghdr *nlh,
 }
 
 static int xfrm_get_sa(struct sk_buff *skb, struct nlmsghdr *nlh,
-               struct rtattr **xfrma)
+               struct nlattr **attrs)
 {
-       struct xfrm_usersa_id *p = NLMSG_DATA(nlh);
+       struct xfrm_usersa_id *p = nlmsg_data(nlh);
        struct xfrm_state *x;
        struct sk_buff *resp_skb;
        int err = -ESRCH;
 
-       x = xfrm_user_state_lookup(p, xfrma, &err);
+       x = xfrm_user_state_lookup(p, attrs, &err);
        if (x == NULL)
                goto out_noput;
 
@@ -795,8 +719,7 @@ static int xfrm_get_sa(struct sk_buff *skb, struct nlmsghdr *nlh,
        if (IS_ERR(resp_skb)) {
                err = PTR_ERR(resp_skb);
        } else {
-               err = netlink_unicast(xfrm_nl, resp_skb,
-                                     NETLINK_CB(skb).pid, MSG_DONTWAIT);
+               err = nlmsg_unicast(xfrm_nl, resp_skb, NETLINK_CB(skb).pid);
        }
        xfrm_state_put(x);
 out_noput:
@@ -827,7 +750,7 @@ static int verify_userspi_info(struct xfrm_userspi_info *p)
 }
 
 static int xfrm_alloc_userspi(struct sk_buff *skb, struct nlmsghdr *nlh,
-               struct rtattr **xfrma)
+               struct nlattr **attrs)
 {
        struct xfrm_state *x;
        struct xfrm_userspi_info *p;
@@ -836,7 +759,7 @@ static int xfrm_alloc_userspi(struct sk_buff *skb, struct nlmsghdr *nlh,
        int family;
        int err;
 
-       p = NLMSG_DATA(nlh);
+       p = nlmsg_data(nlh);
        err = verify_userspi_info(p);
        if (err)
                goto out_noput;
@@ -877,8 +800,7 @@ static int xfrm_alloc_userspi(struct sk_buff *skb, struct nlmsghdr *nlh,
                goto out;
        }
 
-       err = netlink_unicast(xfrm_nl, resp_skb,
-                             NETLINK_CB(skb).pid, MSG_DONTWAIT);
+       err = nlmsg_unicast(xfrm_nl, resp_skb, NETLINK_CB(skb).pid);
 
 out:
        xfrm_state_put(x);
@@ -957,15 +879,15 @@ static int verify_newpolicy_info(struct xfrm_userpolicy_info *p)
        return verify_policy_dir(p->dir);
 }
 
-static int copy_from_user_sec_ctx(struct xfrm_policy *pol, struct rtattr **xfrma)
+static int copy_from_user_sec_ctx(struct xfrm_policy *pol, struct nlattr **attrs)
 {
-       struct rtattr *rt = xfrma[XFRMA_SEC_CTX-1];
+       struct nlattr *rt = attrs[XFRMA_SEC_CTX];
        struct xfrm_user_sec_ctx *uctx;
 
        if (!rt)
                return 0;
 
-       uctx = RTA_DATA(rt);
+       uctx = nla_data(rt);
        return security_xfrm_policy_alloc(pol, uctx);
 }
 
@@ -1025,38 +947,35 @@ static int validate_tmpl(int nr, struct xfrm_user_tmpl *ut, u16 family)
        return 0;
 }
 
-static int copy_from_user_tmpl(struct xfrm_policy *pol, struct rtattr **xfrma)
+static int copy_from_user_tmpl(struct xfrm_policy *pol, struct nlattr **attrs)
 {
-       struct rtattr *rt = xfrma[XFRMA_TMPL-1];
+       struct nlattr *rt = attrs[XFRMA_TMPL];
 
        if (!rt) {
                pol->xfrm_nr = 0;
        } else {
-               struct xfrm_user_tmpl *utmpl = RTA_DATA(rt);
-               int nr = (rt->rta_len - sizeof(*rt)) / sizeof(*utmpl);
+               struct xfrm_user_tmpl *utmpl = nla_data(rt);
+               int nr = nla_len(rt) / sizeof(*utmpl);
                int err;
 
                err = validate_tmpl(nr, utmpl, pol->family);
                if (err)
                        return err;
 
-               copy_templates(pol, RTA_DATA(rt), nr);
+               copy_templates(pol, utmpl, nr);
        }
        return 0;
 }
 
-static int copy_from_user_policy_type(u8 *tp, struct rtattr **xfrma)
+static int copy_from_user_policy_type(u8 *tp, struct nlattr **attrs)
 {
-       struct rtattr *rt = xfrma[XFRMA_POLICY_TYPE-1];
+       struct nlattr *rt = attrs[XFRMA_POLICY_TYPE];
        struct xfrm_userpolicy_type *upt;
        u8 type = XFRM_POLICY_TYPE_MAIN;
        int err;
 
        if (rt) {
-               if (rt->rta_len < sizeof(*upt))
-                       return -EINVAL;
-
-               upt = RTA_DATA(rt);
+               upt = nla_data(rt);
                type = upt->type;
        }
 
@@ -1094,7 +1013,7 @@ static void copy_to_user_policy(struct xfrm_policy *xp, struct xfrm_userpolicy_i
        p->share = XFRM_SHARE_ANY; /* XXX xp->share */
 }
 
-static struct xfrm_policy *xfrm_policy_construct(struct xfrm_userpolicy_info *p, struct rtattr **xfrma, int *errp)
+static struct xfrm_policy *xfrm_policy_construct(struct xfrm_userpolicy_info *p, struct nlattr **attrs, int *errp)
 {
        struct xfrm_policy *xp = xfrm_policy_alloc(GFP_KERNEL);
        int err;
@@ -1106,12 +1025,12 @@ static struct xfrm_policy *xfrm_policy_construct(struct xfrm_userpolicy_info *p,
 
        copy_from_user_policy(xp, p);
 
-       err = copy_from_user_policy_type(&xp->type, xfrma);
+       err = copy_from_user_policy_type(&xp->type, attrs);
        if (err)
                goto error;
 
-       if (!(err = copy_from_user_tmpl(xp, xfrma)))
-               err = copy_from_user_sec_ctx(xp, xfrma);
+       if (!(err = copy_from_user_tmpl(xp, attrs)))
+               err = copy_from_user_sec_ctx(xp, attrs);
        if (err)
                goto error;
 
@@ -1123,9 +1042,9 @@ static struct xfrm_policy *xfrm_policy_construct(struct xfrm_userpolicy_info *p,
 }
 
 static int xfrm_add_policy(struct sk_buff *skb, struct nlmsghdr *nlh,
-               struct rtattr **xfrma)
+               struct nlattr **attrs)
 {
-       struct xfrm_userpolicy_info *p = NLMSG_DATA(nlh);
+       struct xfrm_userpolicy_info *p = nlmsg_data(nlh);
        struct xfrm_policy *xp;
        struct km_event c;
        int err;
@@ -1134,11 +1053,11 @@ static int xfrm_add_policy(struct sk_buff *skb, struct nlmsghdr *nlh,
        err = verify_newpolicy_info(p);
        if (err)
                return err;
-       err = verify_sec_ctx_len(xfrma);
+       err = verify_sec_ctx_len(attrs);
        if (err)
                return err;
 
-       xp = xfrm_policy_construct(p, xfrma, &err);
+       xp = xfrm_policy_construct(p, attrs, &err);
        if (!xp)
                return err;
 
@@ -1190,32 +1109,9 @@ static int copy_to_user_tmpl(struct xfrm_policy *xp, struct sk_buff *skb)
                up->ealgos = kp->ealgos;
                up->calgos = kp->calgos;
        }
-       RTA_PUT(skb, XFRMA_TMPL,
-               (sizeof(struct xfrm_user_tmpl) * xp->xfrm_nr),
-               vec);
-
-       return 0;
-
-rtattr_failure:
-       return -1;
-}
-
-static int copy_sec_ctx(struct xfrm_sec_ctx *s, struct sk_buff *skb)
-{
-       int ctx_size = sizeof(struct xfrm_sec_ctx) + s->ctx_len;
-       struct rtattr *rt = __RTA_PUT(skb, XFRMA_SEC_CTX, ctx_size);
-       struct xfrm_user_sec_ctx *uctx = RTA_DATA(rt);
-
-       uctx->exttype = XFRMA_SEC_CTX;
-       uctx->len = ctx_size;
-       uctx->ctx_doi = s->ctx_doi;
-       uctx->ctx_alg = s->ctx_alg;
-       uctx->ctx_len = s->ctx_len;
-       memcpy(uctx + 1, s->ctx_str, s->ctx_len);
-       return 0;
 
- rtattr_failure:
-       return -1;
+       return nla_put(skb, XFRMA_TMPL,
+                      sizeof(struct xfrm_user_tmpl) * xp->xfrm_nr, vec);
 }
 
 static inline int copy_to_user_state_sec_ctx(struct xfrm_state *x, struct sk_buff *skb)
@@ -1233,21 +1129,23 @@ static inline int copy_to_user_sec_ctx(struct xfrm_policy *xp, struct sk_buff *s
        }
        return 0;
 }
+static inline size_t userpolicy_type_attrsize(void)
+{
+#ifdef CONFIG_XFRM_SUB_POLICY
+       return nla_total_size(sizeof(struct xfrm_userpolicy_type));
+#else
+       return 0;
+#endif
+}
 
 #ifdef CONFIG_XFRM_SUB_POLICY
 static int copy_to_user_policy_type(u8 type, struct sk_buff *skb)
 {
-       struct xfrm_userpolicy_type upt;
-
-       memset(&upt, 0, sizeof(upt));
-       upt.type = type;
-
-       RTA_PUT(skb, XFRMA_POLICY_TYPE, sizeof(upt), &upt);
-
-       return 0;
+       struct xfrm_userpolicy_type upt = {
+               .type = type,
+       };
 
-rtattr_failure:
-       return -1;
+       return nla_put(skb, XFRMA_POLICY_TYPE, sizeof(upt), &upt);
 }
 
 #else
@@ -1264,17 +1162,16 @@ static int dump_one_policy(struct xfrm_policy *xp, int dir, int count, void *ptr
        struct sk_buff *in_skb = sp->in_skb;
        struct sk_buff *skb = sp->out_skb;
        struct nlmsghdr *nlh;
-       unsigned char *b = skb_tail_pointer(skb);
 
        if (sp->this_idx < sp->start_idx)
                goto out;
 
-       nlh = NLMSG_PUT(skb, NETLINK_CB(in_skb).pid,
-                       sp->nlmsg_seq,
-                       XFRM_MSG_NEWPOLICY, sizeof(*p));
-       p = NLMSG_DATA(nlh);
-       nlh->nlmsg_flags = sp->nlmsg_flags;
+       nlh = nlmsg_put(skb, NETLINK_CB(in_skb).pid, sp->nlmsg_seq,
+                       XFRM_MSG_NEWPOLICY, sizeof(*p), sp->nlmsg_flags);
+       if (nlh == NULL)
+               return -EMSGSIZE;
 
+       p = nlmsg_data(nlh);
        copy_to_user_policy(xp, p, dir);
        if (copy_to_user_tmpl(xp, skb) < 0)
                goto nlmsg_failure;
@@ -1283,14 +1180,14 @@ static int dump_one_policy(struct xfrm_policy *xp, int dir, int count, void *ptr
        if (copy_to_user_policy_type(xp->type, skb) < 0)
                goto nlmsg_failure;
 
-       nlh->nlmsg_len = skb_tail_pointer(skb) - b;
+       nlmsg_end(skb, nlh);
 out:
        sp->this_idx++;
        return 0;
 
 nlmsg_failure:
-       nlmsg_trim(skb, b);
-       return -1;
+       nlmsg_cancel(skb, nlh);
+       return -EMSGSIZE;
 }
 
 static int xfrm_dump_policy(struct sk_buff *skb, struct netlink_callback *cb)
@@ -1319,7 +1216,7 @@ static struct sk_buff *xfrm_policy_netlink(struct sk_buff *in_skb,
        struct xfrm_dump_info info;
        struct sk_buff *skb;
 
-       skb = alloc_skb(NLMSG_GOODSIZE, GFP_KERNEL);
+       skb = nlmsg_new(NLMSG_DEFAULT_SIZE, GFP_KERNEL);
        if (!skb)
                return ERR_PTR(-ENOMEM);
 
@@ -1338,7 +1235,7 @@ static struct sk_buff *xfrm_policy_netlink(struct sk_buff *in_skb,
 }
 
 static int xfrm_get_policy(struct sk_buff *skb, struct nlmsghdr *nlh,
-               struct rtattr **xfrma)
+               struct nlattr **attrs)
 {
        struct xfrm_policy *xp;
        struct xfrm_userpolicy_id *p;
@@ -1347,10 +1244,10 @@ static int xfrm_get_policy(struct sk_buff *skb, struct nlmsghdr *nlh,
        struct km_event c;
        int delete;
 
-       p = NLMSG_DATA(nlh);
+       p = nlmsg_data(nlh);
        delete = nlh->nlmsg_type == XFRM_MSG_DELPOLICY;
 
-       err = copy_from_user_policy_type(&type, xfrma);
+       err = copy_from_user_policy_type(&type, attrs);
        if (err)
                return err;
 
@@ -1361,16 +1258,16 @@ static int xfrm_get_policy(struct sk_buff *skb, struct nlmsghdr *nlh,
        if (p->index)
                xp = xfrm_policy_byid(type, p->dir, p->index, delete, &err);
        else {
-               struct rtattr *rt = xfrma[XFRMA_SEC_CTX-1];
+               struct nlattr *rt = attrs[XFRMA_SEC_CTX];
                struct xfrm_policy tmp;
 
-               err = verify_sec_ctx_len(xfrma);
+               err = verify_sec_ctx_len(attrs);
                if (err)
                        return err;
 
                memset(&tmp, 0, sizeof(struct xfrm_policy));
                if (rt) {
-                       struct xfrm_user_sec_ctx *uctx = RTA_DATA(rt);
+                       struct xfrm_user_sec_ctx *uctx = nla_data(rt);
 
                        if ((err = security_xfrm_policy_alloc(&tmp, uctx)))
                                return err;
@@ -1389,9 +1286,8 @@ static int xfrm_get_policy(struct sk_buff *skb, struct nlmsghdr *nlh,
                if (IS_ERR(resp_skb)) {
                        err = PTR_ERR(resp_skb);
                } else {
-                       err = netlink_unicast(xfrm_nl, resp_skb,
-                                             NETLINK_CB(skb).pid,
-                                             MSG_DONTWAIT);
+                       err = nlmsg_unicast(xfrm_nl, resp_skb,
+                                           NETLINK_CB(skb).pid);
                }
        } else {
                xfrm_audit_log(NETLINK_CB(skb).loginuid, NETLINK_CB(skb).sid,
@@ -1413,10 +1309,10 @@ out:
 }
 
 static int xfrm_flush_sa(struct sk_buff *skb, struct nlmsghdr *nlh,
-               struct rtattr **xfrma)
+               struct nlattr **attrs)
 {
        struct km_event c;
-       struct xfrm_usersa_flush *p = NLMSG_DATA(nlh);
+       struct xfrm_usersa_flush *p = nlmsg_data(nlh);
        struct xfrm_audit audit_info;
        int err;
 
@@ -1434,18 +1330,25 @@ static int xfrm_flush_sa(struct sk_buff *skb, struct nlmsghdr *nlh,
        return 0;
 }
 
+static inline size_t xfrm_aevent_msgsize(void)
+{
+       return NLMSG_ALIGN(sizeof(struct xfrm_aevent_id))
+              + nla_total_size(sizeof(struct xfrm_replay_state))
+              + nla_total_size(sizeof(struct xfrm_lifetime_cur))
+              + nla_total_size(4) /* XFRM_AE_RTHR */
+              + nla_total_size(4); /* XFRM_AE_ETHR */
+}
 
 static int build_aevent(struct sk_buff *skb, struct xfrm_state *x, struct km_event *c)
 {
        struct xfrm_aevent_id *id;
        struct nlmsghdr *nlh;
-       struct xfrm_lifetime_cur ltime;
-       unsigned char *b = skb_tail_pointer(skb);
 
-       nlh = NLMSG_PUT(skb, c->pid, c->seq, XFRM_MSG_NEWAE, sizeof(*id));
-       id = NLMSG_DATA(nlh);
-       nlh->nlmsg_flags = 0;
+       nlh = nlmsg_put(skb, c->pid, c->seq, XFRM_MSG_NEWAE, sizeof(*id), 0);
+       if (nlh == NULL)
+               return -EMSGSIZE;
 
+       id = nlmsg_data(nlh);
        memcpy(&id->sa_id.daddr, &x->id.daddr,sizeof(x->id.daddr));
        id->sa_id.spi = x->id.spi;
        id->sa_id.family = x->props.family;
@@ -1454,54 +1357,34 @@ static int build_aevent(struct sk_buff *skb, struct xfrm_state *x, struct km_eve
        id->reqid = x->props.reqid;
        id->flags = c->data.aevent;
 
-       RTA_PUT(skb, XFRMA_REPLAY_VAL, sizeof(x->replay), &x->replay);
+       NLA_PUT(skb, XFRMA_REPLAY_VAL, sizeof(x->replay), &x->replay);
+       NLA_PUT(skb, XFRMA_LTIME_VAL, sizeof(x->curlft), &x->curlft);
 
-       ltime.bytes = x->curlft.bytes;
-       ltime.packets = x->curlft.packets;
-       ltime.add_time = x->curlft.add_time;
-       ltime.use_time = x->curlft.use_time;
+       if (id->flags & XFRM_AE_RTHR)
+               NLA_PUT_U32(skb, XFRMA_REPLAY_THRESH, x->replay_maxdiff);
 
-       RTA_PUT(skb, XFRMA_LTIME_VAL, sizeof(struct xfrm_lifetime_cur), &ltime);
+       if (id->flags & XFRM_AE_ETHR)
+               NLA_PUT_U32(skb, XFRMA_ETIMER_THRESH,
+                           x->replay_maxage * 10 / HZ);
 
-       if (id->flags&XFRM_AE_RTHR) {
-               RTA_PUT(skb,XFRMA_REPLAY_THRESH,sizeof(u32),&x->replay_maxdiff);
-       }
-
-       if (id->flags&XFRM_AE_ETHR) {
-               u32 etimer = x->replay_maxage*10/HZ;
-               RTA_PUT(skb,XFRMA_ETIMER_THRESH,sizeof(u32),&etimer);
-       }
-
-       nlh->nlmsg_len = skb_tail_pointer(skb) - b;
-       return skb->len;
+       return nlmsg_end(skb, nlh);
 
-rtattr_failure:
-nlmsg_failure:
-       nlmsg_trim(skb, b);
-       return -1;
+nla_put_failure:
+       nlmsg_cancel(skb, nlh);
+       return -EMSGSIZE;
 }
 
 static int xfrm_get_ae(struct sk_buff *skb, struct nlmsghdr *nlh,
-               struct rtattr **xfrma)
+               struct nlattr **attrs)
 {
        struct xfrm_state *x;
        struct sk_buff *r_skb;
        int err;
        struct km_event c;
-       struct xfrm_aevent_id *p = NLMSG_DATA(nlh);
-       int len = NLMSG_LENGTH(sizeof(struct xfrm_aevent_id));
+       struct xfrm_aevent_id *p = nlmsg_data(nlh);
        struct xfrm_usersa_id *id = &p->sa_id;
 
-       len += RTA_SPACE(sizeof(struct xfrm_replay_state));
-       len += RTA_SPACE(sizeof(struct xfrm_lifetime_cur));
-
-       if (p->flags&XFRM_AE_RTHR)
-               len+=RTA_SPACE(sizeof(u32));
-
-       if (p->flags&XFRM_AE_ETHR)
-               len+=RTA_SPACE(sizeof(u32));
-
-       r_skb = alloc_skb(len, GFP_ATOMIC);
+       r_skb = nlmsg_new(xfrm_aevent_msgsize(), GFP_ATOMIC);
        if (r_skb == NULL)
                return -ENOMEM;
 
@@ -1523,22 +1406,21 @@ static int xfrm_get_ae(struct sk_buff *skb, struct nlmsghdr *nlh,
 
        if (build_aevent(r_skb, x, &c) < 0)
                BUG();
-       err = netlink_unicast(xfrm_nl, r_skb,
-                             NETLINK_CB(skb).pid, MSG_DONTWAIT);
+       err = nlmsg_unicast(xfrm_nl, r_skb, NETLINK_CB(skb).pid);
        spin_unlock_bh(&x->lock);
        xfrm_state_put(x);
        return err;
 }
 
 static int xfrm_new_ae(struct sk_buff *skb, struct nlmsghdr *nlh,
-               struct rtattr **xfrma)
+               struct nlattr **attrs)
 {
        struct xfrm_state *x;
        struct km_event c;
        int err = - EINVAL;
-       struct xfrm_aevent_id *p = NLMSG_DATA(nlh);
-       struct rtattr *rp = xfrma[XFRMA_REPLAY_VAL-1];
-       struct rtattr *lt = xfrma[XFRMA_LTIME_VAL-1];
+       struct xfrm_aevent_id *p = nlmsg_data(nlh);
+       struct nlattr *rp = attrs[XFRMA_REPLAY_VAL];
+       struct nlattr *lt = attrs[XFRMA_LTIME_VAL];
 
        if (!lt && !rp)
                return err;
@@ -1555,10 +1437,8 @@ static int xfrm_new_ae(struct sk_buff *skb, struct nlmsghdr *nlh,
                goto out;
 
        spin_lock_bh(&x->lock);
-       err = xfrm_update_ae_params(x, xfrma);
+       xfrm_update_ae_params(x, attrs);
        spin_unlock_bh(&x->lock);
-       if (err < 0)
-               goto out;
 
        c.event = nlh->nlmsg_type;
        c.seq = nlh->nlmsg_seq;
@@ -1572,14 +1452,14 @@ out:
 }
 
 static int xfrm_flush_policy(struct sk_buff *skb, struct nlmsghdr *nlh,
-               struct rtattr **xfrma)
+               struct nlattr **attrs)
 {
        struct km_event c;
        u8 type = XFRM_POLICY_TYPE_MAIN;
        int err;
        struct xfrm_audit audit_info;
 
-       err = copy_from_user_policy_type(&type, xfrma);
+       err = copy_from_user_policy_type(&type, attrs);
        if (err)
                return err;
 
@@ -1597,31 +1477,31 @@ static int xfrm_flush_policy(struct sk_buff *skb, struct nlmsghdr *nlh,
 }
 
 static int xfrm_add_pol_expire(struct sk_buff *skb, struct nlmsghdr *nlh,
-               struct rtattr **xfrma)
+               struct nlattr **attrs)
 {
        struct xfrm_policy *xp;
-       struct xfrm_user_polexpire *up = NLMSG_DATA(nlh);
+       struct xfrm_user_polexpire *up = nlmsg_data(nlh);
        struct xfrm_userpolicy_info *p = &up->pol;
        u8 type = XFRM_POLICY_TYPE_MAIN;
        int err = -ENOENT;
 
-       err = copy_from_user_policy_type(&type, xfrma);
+       err = copy_from_user_policy_type(&type, attrs);
        if (err)
                return err;
 
        if (p->index)
                xp = xfrm_policy_byid(type, p->dir, p->index, 0, &err);
        else {
-               struct rtattr *rt = xfrma[XFRMA_SEC_CTX-1];
+               struct nlattr *rt = attrs[XFRMA_SEC_CTX];
                struct xfrm_policy tmp;
 
-               err = verify_sec_ctx_len(xfrma);
+               err = verify_sec_ctx_len(attrs);
                if (err)
                        return err;
 
                memset(&tmp, 0, sizeof(struct xfrm_policy));
                if (rt) {
-                       struct xfrm_user_sec_ctx *uctx = RTA_DATA(rt);
+                       struct xfrm_user_sec_ctx *uctx = nla_data(rt);
 
                        if ((err = security_xfrm_policy_alloc(&tmp, uctx)))
                                return err;
@@ -1658,11 +1538,11 @@ out:
 }
 
 static int xfrm_add_sa_expire(struct sk_buff *skb, struct nlmsghdr *nlh,
-               struct rtattr **xfrma)
+               struct nlattr **attrs)
 {
        struct xfrm_state *x;
        int err;
-       struct xfrm_user_expire *ue = NLMSG_DATA(nlh);
+       struct xfrm_user_expire *ue = nlmsg_data(nlh);
        struct xfrm_usersa_info *p = &ue->state;
 
        x = xfrm_state_lookup(&p->id.daddr, p->id.spi, p->id.proto, p->family);
@@ -1690,14 +1570,14 @@ out:
 }
 
 static int xfrm_add_acquire(struct sk_buff *skb, struct nlmsghdr *nlh,
-               struct rtattr **xfrma)
+               struct nlattr **attrs)
 {
        struct xfrm_policy *xp;
        struct xfrm_user_tmpl *ut;
        int i;
-       struct rtattr *rt = xfrma[XFRMA_TMPL-1];
+       struct nlattr *rt = attrs[XFRMA_TMPL];
 
-       struct xfrm_user_acquire *ua = NLMSG_DATA(nlh);
+       struct xfrm_user_acquire *ua = nlmsg_data(nlh);
        struct xfrm_state *x = xfrm_state_alloc();
        int err = -ENOMEM;
 
@@ -1712,7 +1592,7 @@ static int xfrm_add_acquire(struct sk_buff *skb, struct nlmsghdr *nlh,
        }
 
        /*   build an XP */
-       xp = xfrm_policy_construct(&ua->policy, (struct rtattr **) xfrma, &err);
+       xp = xfrm_policy_construct(&ua->policy, attrs, &err);
        if (!xp) {
                kfree(x);
                return err;
@@ -1722,7 +1602,7 @@ static int xfrm_add_acquire(struct sk_buff *skb, struct nlmsghdr *nlh,
        memcpy(&x->props.saddr, &ua->saddr, sizeof(ua->saddr));
        memcpy(&x->sel, &ua->sel, sizeof(ua->sel));
 
-       ut = RTA_DATA(rt);
+       ut = nla_data(rt);
        /* extract the templates and for each call km_key */
        for (i = 0; i < xp->xfrm_nr; i++, ut++) {
                struct xfrm_tmpl *t = &xp->xfrm_vec[i];
@@ -1744,29 +1624,15 @@ static int xfrm_add_acquire(struct sk_buff *skb, struct nlmsghdr *nlh,
 }
 
 #ifdef CONFIG_XFRM_MIGRATE
-static int verify_user_migrate(struct rtattr **xfrma)
-{
-       struct rtattr *rt = xfrma[XFRMA_MIGRATE-1];
-       struct xfrm_user_migrate *um;
-
-       if (!rt)
-               return -EINVAL;
-
-       if ((rt->rta_len - sizeof(*rt)) < sizeof(*um))
-               return -EINVAL;
-
-       return 0;
-}
-
 static int copy_from_user_migrate(struct xfrm_migrate *ma,
-                                 struct rtattr **xfrma, int *num)
+                                 struct nlattr **attrs, int *num)
 {
-       struct rtattr *rt = xfrma[XFRMA_MIGRATE-1];
+       struct nlattr *rt = attrs[XFRMA_MIGRATE];
        struct xfrm_user_migrate *um;
        int i, num_migrate;
 
-       um = RTA_DATA(rt);
-       num_migrate = (rt->rta_len - sizeof(*rt)) / sizeof(*um);
+       um = nla_data(rt);
+       num_migrate = nla_len(rt) / sizeof(*um);
 
        if (num_migrate <= 0 || num_migrate > XFRM_MAX_DEPTH)
                return -EINVAL;
@@ -1790,24 +1656,23 @@ static int copy_from_user_migrate(struct xfrm_migrate *ma,
 }
 
 static int xfrm_do_migrate(struct sk_buff *skb, struct nlmsghdr *nlh,
-                          struct rtattr **xfrma)
+                          struct nlattr **attrs)
 {
-       struct xfrm_userpolicy_id *pi = NLMSG_DATA(nlh);
+       struct xfrm_userpolicy_id *pi = nlmsg_data(nlh);
        struct xfrm_migrate m[XFRM_MAX_DEPTH];
        u8 type;
        int err;
        int n = 0;
 
-       err = verify_user_migrate((struct rtattr **)xfrma);
-       if (err)
-               return err;
+       if (attrs[XFRMA_MIGRATE] == NULL)
+               return -EINVAL;
 
-       err = copy_from_user_policy_type(&type, (struct rtattr **)xfrma);
+       err = copy_from_user_policy_type(&type, attrs);
        if (err)
                return err;
 
        err = copy_from_user_migrate((struct xfrm_migrate *)m,
-                                    (struct rtattr **)xfrma, &n);
+                                    attrs, &n);
        if (err)
                return err;
 
@@ -1820,7 +1685,7 @@ static int xfrm_do_migrate(struct sk_buff *skb, struct nlmsghdr *nlh,
 }
 #else
 static int xfrm_do_migrate(struct sk_buff *skb, struct nlmsghdr *nlh,
-                          struct rtattr **xfrma)
+                          struct nlattr **attrs)
 {
        return -ENOPROTOOPT;
 }
@@ -1842,11 +1707,14 @@ static int copy_to_user_migrate(struct xfrm_migrate *m, struct sk_buff *skb)
        memcpy(&um.new_daddr, &m->new_daddr, sizeof(um.new_daddr));
        memcpy(&um.new_saddr, &m->new_saddr, sizeof(um.new_saddr));
 
-       RTA_PUT(skb, XFRMA_MIGRATE, sizeof(um), &um);
-       return 0;
+       return nla_put(skb, XFRMA_MIGRATE, sizeof(um), &um);
+}
 
-rtattr_failure:
-       return -1;
+static inline size_t xfrm_migrate_msgsize(int num_migrate)
+{
+       return NLMSG_ALIGN(sizeof(struct xfrm_userpolicy_id))
+              + nla_total_size(sizeof(struct xfrm_user_migrate) * num_migrate)
+              + userpolicy_type_attrsize();
 }
 
 static int build_migrate(struct sk_buff *skb, struct xfrm_migrate *m,
@@ -1856,13 +1724,13 @@ static int build_migrate(struct sk_buff *skb, struct xfrm_migrate *m,
        struct xfrm_migrate *mp;
        struct xfrm_userpolicy_id *pol_id;
        struct nlmsghdr *nlh;
-       unsigned char *b = skb_tail_pointer(skb);
        int i;
 
-       nlh = NLMSG_PUT(skb, 0, 0, XFRM_MSG_MIGRATE, sizeof(*pol_id));
-       pol_id = NLMSG_DATA(nlh);
-       nlh->nlmsg_flags = 0;
+       nlh = nlmsg_put(skb, 0, 0, XFRM_MSG_MIGRATE, sizeof(*pol_id), 0);
+       if (nlh == NULL)
+               return -EMSGSIZE;
 
+       pol_id = nlmsg_data(nlh);
        /* copy data from selector, dir, and type to the pol_id */
        memset(pol_id, 0, sizeof(*pol_id));
        memcpy(&pol_id->sel, sel, sizeof(pol_id->sel));
@@ -1876,25 +1744,18 @@ static int build_migrate(struct sk_buff *skb, struct xfrm_migrate *m,
                        goto nlmsg_failure;
        }
 
-       nlh->nlmsg_len = skb_tail_pointer(skb) - b;
-       return skb->len;
+       return nlmsg_end(skb, nlh);
 nlmsg_failure:
-       nlmsg_trim(skb, b);
-       return -1;
+       nlmsg_cancel(skb, nlh);
+       return -EMSGSIZE;
 }
 
 static int xfrm_send_migrate(struct xfrm_selector *sel, u8 dir, u8 type,
                             struct xfrm_migrate *m, int num_migrate)
 {
        struct sk_buff *skb;
-       size_t len;
 
-       len = RTA_SPACE(sizeof(struct xfrm_user_migrate) * num_migrate);
-       len += NLMSG_SPACE(sizeof(struct xfrm_userpolicy_id));
-#ifdef CONFIG_XFRM_SUB_POLICY
-       len += RTA_SPACE(sizeof(struct xfrm_userpolicy_type));
-#endif
-       skb = alloc_skb(len, GFP_ATOMIC);
+       skb = nlmsg_new(xfrm_migrate_msgsize(num_migrate), GFP_ATOMIC);
        if (skb == NULL)
                return -ENOMEM;
 
@@ -1902,9 +1763,7 @@ static int xfrm_send_migrate(struct xfrm_selector *sel, u8 dir, u8 type,
        if (build_migrate(skb, m, num_migrate, sel, dir, type) < 0)
                BUG();
 
-       NETLINK_CB(skb).dst_group = XFRMNLGRP_MIGRATE;
-       return netlink_broadcast(xfrm_nl, skb, 0, XFRMNLGRP_MIGRATE,
-                                GFP_ATOMIC);
+       return nlmsg_multicast(xfrm_nl, skb, 0, XFRMNLGRP_MIGRATE, GFP_ATOMIC);
 }
 #else
 static int xfrm_send_migrate(struct xfrm_selector *sel, u8 dir, u8 type,
@@ -1914,7 +1773,7 @@ static int xfrm_send_migrate(struct xfrm_selector *sel, u8 dir, u8 type,
 }
 #endif
 
-#define XMSGSIZE(type) NLMSG_LENGTH(sizeof(struct type))
+#define XMSGSIZE(type) sizeof(struct type)
 
 static const int xfrm_msg_min[XFRM_NR_MSGTYPES] = {
        [XFRM_MSG_NEWSA       - XFRM_MSG_BASE] = XMSGSIZE(xfrm_usersa_info),
@@ -1930,19 +1789,36 @@ static const int xfrm_msg_min[XFRM_NR_MSGTYPES] = {
        [XFRM_MSG_UPDSA       - XFRM_MSG_BASE] = XMSGSIZE(xfrm_usersa_info),
        [XFRM_MSG_POLEXPIRE   - XFRM_MSG_BASE] = XMSGSIZE(xfrm_user_polexpire),
        [XFRM_MSG_FLUSHSA     - XFRM_MSG_BASE] = XMSGSIZE(xfrm_usersa_flush),
-       [XFRM_MSG_FLUSHPOLICY - XFRM_MSG_BASE] = NLMSG_LENGTH(0),
+       [XFRM_MSG_FLUSHPOLICY - XFRM_MSG_BASE] = 0,
        [XFRM_MSG_NEWAE       - XFRM_MSG_BASE] = XMSGSIZE(xfrm_aevent_id),
        [XFRM_MSG_GETAE       - XFRM_MSG_BASE] = XMSGSIZE(xfrm_aevent_id),
        [XFRM_MSG_REPORT      - XFRM_MSG_BASE] = XMSGSIZE(xfrm_user_report),
        [XFRM_MSG_MIGRATE     - XFRM_MSG_BASE] = XMSGSIZE(xfrm_userpolicy_id),
-       [XFRM_MSG_GETSADINFO  - XFRM_MSG_BASE] = NLMSG_LENGTH(sizeof(u32)),
-       [XFRM_MSG_GETSPDINFO  - XFRM_MSG_BASE] = NLMSG_LENGTH(sizeof(u32)),
+       [XFRM_MSG_GETSADINFO  - XFRM_MSG_BASE] = sizeof(u32),
+       [XFRM_MSG_GETSPDINFO  - XFRM_MSG_BASE] = sizeof(u32),
 };
 
 #undef XMSGSIZE
 
+static const struct nla_policy xfrma_policy[XFRMA_MAX+1] = {
+       [XFRMA_ALG_AUTH]        = { .len = sizeof(struct xfrm_algo) },
+       [XFRMA_ALG_CRYPT]       = { .len = sizeof(struct xfrm_algo) },
+       [XFRMA_ALG_COMP]        = { .len = sizeof(struct xfrm_algo) },
+       [XFRMA_ENCAP]           = { .len = sizeof(struct xfrm_encap_tmpl) },
+       [XFRMA_TMPL]            = { .len = sizeof(struct xfrm_user_tmpl) },
+       [XFRMA_SEC_CTX]         = { .len = sizeof(struct xfrm_sec_ctx) },
+       [XFRMA_LTIME_VAL]       = { .len = sizeof(struct xfrm_lifetime_cur) },
+       [XFRMA_REPLAY_VAL]      = { .len = sizeof(struct xfrm_replay_state) },
+       [XFRMA_REPLAY_THRESH]   = { .type = NLA_U32 },
+       [XFRMA_ETIMER_THRESH]   = { .type = NLA_U32 },
+       [XFRMA_SRCADDR]         = { .len = sizeof(xfrm_address_t) },
+       [XFRMA_COADDR]          = { .len = sizeof(xfrm_address_t) },
+       [XFRMA_POLICY_TYPE]     = { .len = sizeof(struct xfrm_userpolicy_type)},
+       [XFRMA_MIGRATE]         = { .len = sizeof(struct xfrm_user_migrate) },
+};
+
 static struct xfrm_link {
-       int (*doit)(struct sk_buff *, struct nlmsghdr *, struct rtattr **);
+       int (*doit)(struct sk_buff *, struct nlmsghdr *, struct nlattr **);
        int (*dump)(struct sk_buff *, struct netlink_callback *);
 } xfrm_dispatch[XFRM_NR_MSGTYPES] = {
        [XFRM_MSG_NEWSA       - XFRM_MSG_BASE] = { .doit = xfrm_add_sa        },
@@ -1970,9 +1846,9 @@ static struct xfrm_link {
 
 static int xfrm_user_rcv_msg(struct sk_buff *skb, struct nlmsghdr *nlh)
 {
-       struct rtattr *xfrma[XFRMA_MAX];
+       struct nlattr *attrs[XFRMA_MAX+1];
        struct xfrm_link *link;
-       int type, min_len;
+       int type, err;
 
        type = nlh->nlmsg_type;
        if (type > XFRM_MSG_MAX)
@@ -1994,30 +1870,15 @@ static int xfrm_user_rcv_msg(struct sk_buff *skb, struct nlmsghdr *nlh)
                return netlink_dump_start(xfrm_nl, skb, nlh, link->dump, NULL);
        }
 
-       memset(xfrma, 0, sizeof(xfrma));
-
-       if (nlh->nlmsg_len < (min_len = xfrm_msg_min[type]))
-               return -EINVAL;
-
-       if (nlh->nlmsg_len > min_len) {
-               int attrlen = nlh->nlmsg_len - NLMSG_ALIGN(min_len);
-               struct rtattr *attr = (void *) nlh + NLMSG_ALIGN(min_len);
-
-               while (RTA_OK(attr, attrlen)) {
-                       unsigned short flavor = attr->rta_type;
-                       if (flavor) {
-                               if (flavor > XFRMA_MAX)
-                                       return -EINVAL;
-                               xfrma[flavor - 1] = attr;
-                       }
-                       attr = RTA_NEXT(attr, attrlen);
-               }
-       }
+       err = nlmsg_parse(nlh, xfrm_msg_min[type], attrs, XFRMA_MAX,
+                         xfrma_policy);
+       if (err < 0)
+               return err;
 
        if (link->doit == NULL)
                return -EINVAL;
 
-       return link->doit(skb, nlh, xfrma);
+       return link->doit(skb, nlh, attrs);
 }
 
 static void xfrm_netlink_rcv(struct sock *sk, int len)
@@ -2032,60 +1893,53 @@ static void xfrm_netlink_rcv(struct sock *sk, int len)
        } while (qlen);
 }
 
+static inline size_t xfrm_expire_msgsize(void)
+{
+       return NLMSG_ALIGN(sizeof(struct xfrm_user_expire));
+}
+
 static int build_expire(struct sk_buff *skb, struct xfrm_state *x, struct km_event *c)
 {
        struct xfrm_user_expire *ue;
        struct nlmsghdr *nlh;
-       unsigned char *b = skb_tail_pointer(skb);
 
-       nlh = NLMSG_PUT(skb, c->pid, 0, XFRM_MSG_EXPIRE,
-                       sizeof(*ue));
-       ue = NLMSG_DATA(nlh);
-       nlh->nlmsg_flags = 0;
+       nlh = nlmsg_put(skb, c->pid, 0, XFRM_MSG_EXPIRE, sizeof(*ue), 0);
+       if (nlh == NULL)
+               return -EMSGSIZE;
 
+       ue = nlmsg_data(nlh);
        copy_to_user_state(x, &ue->state);
        ue->hard = (c->data.hard != 0) ? 1 : 0;
 
-       nlh->nlmsg_len = skb_tail_pointer(skb) - b;
-       return skb->len;
-
-nlmsg_failure:
-       nlmsg_trim(skb, b);
-       return -1;
+       return nlmsg_end(skb, nlh);
 }
 
 static int xfrm_exp_state_notify(struct xfrm_state *x, struct km_event *c)
 {
        struct sk_buff *skb;
-       int len = NLMSG_LENGTH(sizeof(struct xfrm_user_expire));
 
-       skb = alloc_skb(len, GFP_ATOMIC);
+       skb = nlmsg_new(xfrm_expire_msgsize(), GFP_ATOMIC);
        if (skb == NULL)
                return -ENOMEM;
 
        if (build_expire(skb, x, c) < 0)
                BUG();
 
-       NETLINK_CB(skb).dst_group = XFRMNLGRP_EXPIRE;
-       return netlink_broadcast(xfrm_nl, skb, 0, XFRMNLGRP_EXPIRE, GFP_ATOMIC);
+       return nlmsg_multicast(xfrm_nl, skb, 0, XFRMNLGRP_EXPIRE, GFP_ATOMIC);
 }
 
 static int xfrm_aevent_state_notify(struct xfrm_state *x, struct km_event *c)
 {
        struct sk_buff *skb;
-       int len = NLMSG_LENGTH(sizeof(struct xfrm_aevent_id));
 
-       len += RTA_SPACE(sizeof(struct xfrm_replay_state));
-       len += RTA_SPACE(sizeof(struct xfrm_lifetime_cur));
-       skb = alloc_skb(len, GFP_ATOMIC);
+       skb = nlmsg_new(xfrm_aevent_msgsize(), GFP_ATOMIC);
        if (skb == NULL)
                return -ENOMEM;
 
        if (build_aevent(skb, x, c) < 0)
                BUG();
 
-       NETLINK_CB(skb).dst_group = XFRMNLGRP_AEVENTS;
-       return netlink_broadcast(xfrm_nl, skb, 0, XFRMNLGRP_AEVENTS, GFP_ATOMIC);
+       return nlmsg_multicast(xfrm_nl, skb, 0, XFRMNLGRP_AEVENTS, GFP_ATOMIC);
 }
 
 static int xfrm_notify_sa_flush(struct km_event *c)
@@ -2093,42 +1947,37 @@ static int xfrm_notify_sa_flush(struct km_event *c)
        struct xfrm_usersa_flush *p;
        struct nlmsghdr *nlh;
        struct sk_buff *skb;
-       sk_buff_data_t b;
-       int len = NLMSG_LENGTH(sizeof(struct xfrm_usersa_flush));
+       int len = NLMSG_ALIGN(sizeof(struct xfrm_usersa_flush));
 
-       skb = alloc_skb(len, GFP_ATOMIC);
+       skb = nlmsg_new(len, GFP_ATOMIC);
        if (skb == NULL)
                return -ENOMEM;
-       b = skb->tail;
 
-       nlh = NLMSG_PUT(skb, c->pid, c->seq,
-                       XFRM_MSG_FLUSHSA, sizeof(*p));
-       nlh->nlmsg_flags = 0;
+       nlh = nlmsg_put(skb, c->pid, c->seq, XFRM_MSG_FLUSHSA, sizeof(*p), 0);
+       if (nlh == NULL) {
+               kfree_skb(skb);
+               return -EMSGSIZE;
+       }
 
-       p = NLMSG_DATA(nlh);
+       p = nlmsg_data(nlh);
        p->proto = c->data.proto;
 
-       nlh->nlmsg_len = skb->tail - b;
+       nlmsg_end(skb, nlh);
 
-       NETLINK_CB(skb).dst_group = XFRMNLGRP_SA;
-       return netlink_broadcast(xfrm_nl, skb, 0, XFRMNLGRP_SA, GFP_ATOMIC);
-
-nlmsg_failure:
-       kfree_skb(skb);
-       return -1;
+       return nlmsg_multicast(xfrm_nl, skb, 0, XFRMNLGRP_SA, GFP_ATOMIC);
 }
 
-static inline int xfrm_sa_len(struct xfrm_state *x)
+static inline size_t xfrm_sa_len(struct xfrm_state *x)
 {
-       int l = 0;
+       size_t l = 0;
        if (x->aalg)
-               l += RTA_SPACE(sizeof(*x->aalg) + (x->aalg->alg_key_len+7)/8);
+               l += nla_total_size(alg_len(x->aalg));
        if (x->ealg)
-               l += RTA_SPACE(sizeof(*x->ealg) + (x->ealg->alg_key_len+7)/8);
+               l += nla_total_size(alg_len(x->ealg));
        if (x->calg)
-               l += RTA_SPACE(sizeof(*x->calg));
+               l += nla_total_size(sizeof(*x->calg));
        if (x->encap)
-               l += RTA_SPACE(sizeof(*x->encap));
+               l += nla_total_size(sizeof(*x->encap));
 
        return l;
 }
@@ -2139,57 +1988,58 @@ static int xfrm_notify_sa(struct xfrm_state *x, struct km_event *c)
        struct xfrm_usersa_id *id;
        struct nlmsghdr *nlh;
        struct sk_buff *skb;
-       sk_buff_data_t b;
        int len = xfrm_sa_len(x);
        int headlen;
 
        headlen = sizeof(*p);
        if (c->event == XFRM_MSG_DELSA) {
-               len += RTA_SPACE(headlen);
+               len += nla_total_size(headlen);
                headlen = sizeof(*id);
        }
-       len += NLMSG_SPACE(headlen);
+       len += NLMSG_ALIGN(headlen);
 
-       skb = alloc_skb(len, GFP_ATOMIC);
+       skb = nlmsg_new(len, GFP_ATOMIC);
        if (skb == NULL)
                return -ENOMEM;
-       b = skb->tail;
 
-       nlh = NLMSG_PUT(skb, c->pid, c->seq, c->event, headlen);
-       nlh->nlmsg_flags = 0;
+       nlh = nlmsg_put(skb, c->pid, c->seq, c->event, headlen, 0);
+       if (nlh == NULL)
+               goto nla_put_failure;
 
-       p = NLMSG_DATA(nlh);
+       p = nlmsg_data(nlh);
        if (c->event == XFRM_MSG_DELSA) {
-               id = NLMSG_DATA(nlh);
+               struct nlattr *attr;
+
+               id = nlmsg_data(nlh);
                memcpy(&id->daddr, &x->id.daddr, sizeof(id->daddr));
                id->spi = x->id.spi;
                id->family = x->props.family;
                id->proto = x->id.proto;
 
-               p = RTA_DATA(__RTA_PUT(skb, XFRMA_SA, sizeof(*p)));
+               attr = nla_reserve(skb, XFRMA_SA, sizeof(*p));
+               if (attr == NULL)
+                       goto nla_put_failure;
+
+               p = nla_data(attr);
        }
 
        copy_to_user_state(x, p);
 
        if (x->aalg)
-               RTA_PUT(skb, XFRMA_ALG_AUTH,
-                       sizeof(*(x->aalg))+(x->aalg->alg_key_len+7)/8, x->aalg);
+               NLA_PUT(skb, XFRMA_ALG_AUTH, alg_len(x->aalg), x->aalg);
        if (x->ealg)
-               RTA_PUT(skb, XFRMA_ALG_CRYPT,
-                       sizeof(*(x->ealg))+(x->ealg->alg_key_len+7)/8, x->ealg);
+               NLA_PUT(skb, XFRMA_ALG_CRYPT, alg_len(x->ealg), x->ealg);
        if (x->calg)
-               RTA_PUT(skb, XFRMA_ALG_COMP, sizeof(*(x->calg)), x->calg);
+               NLA_PUT(skb, XFRMA_ALG_COMP, sizeof(*(x->calg)), x->calg);
 
        if (x->encap)
-               RTA_PUT(skb, XFRMA_ENCAP, sizeof(*x->encap), x->encap);
+               NLA_PUT(skb, XFRMA_ENCAP, sizeof(*x->encap), x->encap);
 
-       nlh->nlmsg_len = skb->tail - b;
+       nlmsg_end(skb, nlh);
 
-       NETLINK_CB(skb).dst_group = XFRMNLGRP_SA;
-       return netlink_broadcast(xfrm_nl, skb, 0, XFRMNLGRP_SA, GFP_ATOMIC);
+       return nlmsg_multicast(xfrm_nl, skb, 0, XFRMNLGRP_SA, GFP_ATOMIC);
 
-nlmsg_failure:
-rtattr_failure:
+nla_put_failure:
        kfree_skb(skb);
        return -1;
 }
@@ -2217,20 +2067,28 @@ static int xfrm_send_state_notify(struct xfrm_state *x, struct km_event *c)
 
 }
 
+static inline size_t xfrm_acquire_msgsize(struct xfrm_state *x,
+                                         struct xfrm_policy *xp)
+{
+       return NLMSG_ALIGN(sizeof(struct xfrm_user_acquire))
+              + nla_total_size(sizeof(struct xfrm_user_tmpl) * xp->xfrm_nr)
+              + nla_total_size(xfrm_user_sec_ctx_size(x->security))
+              + userpolicy_type_attrsize();
+}
+
 static int build_acquire(struct sk_buff *skb, struct xfrm_state *x,
                         struct xfrm_tmpl *xt, struct xfrm_policy *xp,
                         int dir)
 {
        struct xfrm_user_acquire *ua;
        struct nlmsghdr *nlh;
-       unsigned char *b = skb_tail_pointer(skb);
        __u32 seq = xfrm_get_acqseq();
 
-       nlh = NLMSG_PUT(skb, 0, 0, XFRM_MSG_ACQUIRE,
-                       sizeof(*ua));
-       ua = NLMSG_DATA(nlh);
-       nlh->nlmsg_flags = 0;
+       nlh = nlmsg_put(skb, 0, 0, XFRM_MSG_ACQUIRE, sizeof(*ua), 0);
+       if (nlh == NULL)
+               return -EMSGSIZE;
 
+       ua = nlmsg_data(nlh);
        memcpy(&ua->id, &x->id, sizeof(ua->id));
        memcpy(&ua->saddr, &x->props.saddr, sizeof(ua->saddr));
        memcpy(&ua->sel, &x->sel, sizeof(ua->sel));
@@ -2247,35 +2105,26 @@ static int build_acquire(struct sk_buff *skb, struct xfrm_state *x,
        if (copy_to_user_policy_type(xp->type, skb) < 0)
                goto nlmsg_failure;
 
-       nlh->nlmsg_len = skb_tail_pointer(skb) - b;
-       return skb->len;
+       return nlmsg_end(skb, nlh);
 
 nlmsg_failure:
-       nlmsg_trim(skb, b);
-       return -1;
+       nlmsg_cancel(skb, nlh);
+       return -EMSGSIZE;
 }
 
 static int xfrm_send_acquire(struct xfrm_state *x, struct xfrm_tmpl *xt,
                             struct xfrm_policy *xp, int dir)
 {
        struct sk_buff *skb;
-       size_t len;
 
-       len = RTA_SPACE(sizeof(struct xfrm_user_tmpl) * xp->xfrm_nr);
-       len += NLMSG_SPACE(sizeof(struct xfrm_user_acquire));
-       len += RTA_SPACE(xfrm_user_sec_ctx_size(x->security));
-#ifdef CONFIG_XFRM_SUB_POLICY
-       len += RTA_SPACE(sizeof(struct xfrm_userpolicy_type));
-#endif
-       skb = alloc_skb(len, GFP_ATOMIC);
+       skb = nlmsg_new(xfrm_acquire_msgsize(x, xp), GFP_ATOMIC);
        if (skb == NULL)
                return -ENOMEM;
 
        if (build_acquire(skb, x, xt, xp, dir) < 0)
                BUG();
 
-       NETLINK_CB(skb).dst_group = XFRMNLGRP_ACQUIRE;
-       return netlink_broadcast(xfrm_nl, skb, 0, XFRMNLGRP_ACQUIRE, GFP_ATOMIC);
+       return nlmsg_multicast(xfrm_nl, skb, 0, XFRMNLGRP_ACQUIRE, GFP_ATOMIC);
 }
 
 /* User gives us xfrm_user_policy_info followed by an array of 0
@@ -2337,18 +2186,26 @@ static struct xfrm_policy *xfrm_compile_policy(struct sock *sk, int opt,
        return xp;
 }
 
+static inline size_t xfrm_polexpire_msgsize(struct xfrm_policy *xp)
+{
+       return NLMSG_ALIGN(sizeof(struct xfrm_user_polexpire))
+              + nla_total_size(sizeof(struct xfrm_user_tmpl) * xp->xfrm_nr)
+              + nla_total_size(xfrm_user_sec_ctx_size(xp->security))
+              + userpolicy_type_attrsize();
+}
+
 static int build_polexpire(struct sk_buff *skb, struct xfrm_policy *xp,
                           int dir, struct km_event *c)
 {
        struct xfrm_user_polexpire *upe;
        struct nlmsghdr *nlh;
        int hard = c->data.hard;
-       unsigned char *b = skb_tail_pointer(skb);
 
-       nlh = NLMSG_PUT(skb, c->pid, 0, XFRM_MSG_POLEXPIRE, sizeof(*upe));
-       upe = NLMSG_DATA(nlh);
-       nlh->nlmsg_flags = 0;
+       nlh = nlmsg_put(skb, c->pid, 0, XFRM_MSG_POLEXPIRE, sizeof(*upe), 0);
+       if (nlh == NULL)
+               return -EMSGSIZE;
 
+       upe = nlmsg_data(nlh);
        copy_to_user_policy(xp, &upe->pol, dir);
        if (copy_to_user_tmpl(xp, skb) < 0)
                goto nlmsg_failure;
@@ -2358,34 +2215,25 @@ static int build_polexpire(struct sk_buff *skb, struct xfrm_policy *xp,
                goto nlmsg_failure;
        upe->hard = !!hard;
 
-       nlh->nlmsg_len = skb_tail_pointer(skb) - b;
-       return skb->len;
+       return nlmsg_end(skb, nlh);
 
 nlmsg_failure:
-       nlmsg_trim(skb, b);
-       return -1;
+       nlmsg_cancel(skb, nlh);
+       return -EMSGSIZE;
 }
 
 static int xfrm_exp_policy_notify(struct xfrm_policy *xp, int dir, struct km_event *c)
 {
        struct sk_buff *skb;
-       size_t len;
 
-       len = RTA_SPACE(sizeof(struct xfrm_user_tmpl) * xp->xfrm_nr);
-       len += NLMSG_SPACE(sizeof(struct xfrm_user_polexpire));
-       len += RTA_SPACE(xfrm_user_sec_ctx_size(xp->security));
-#ifdef CONFIG_XFRM_SUB_POLICY
-       len += RTA_SPACE(sizeof(struct xfrm_userpolicy_type));
-#endif
-       skb = alloc_skb(len, GFP_ATOMIC);
+       skb = nlmsg_new(xfrm_polexpire_msgsize(xp), GFP_ATOMIC);
        if (skb == NULL)
                return -ENOMEM;
 
        if (build_polexpire(skb, xp, dir, c) < 0)
                BUG();
 
-       NETLINK_CB(skb).dst_group = XFRMNLGRP_EXPIRE;
-       return netlink_broadcast(xfrm_nl, skb, 0, XFRMNLGRP_EXPIRE, GFP_ATOMIC);
+       return nlmsg_multicast(xfrm_nl, skb, 0, XFRMNLGRP_EXPIRE, GFP_ATOMIC);
 }
 
 static int xfrm_notify_policy(struct xfrm_policy *xp, int dir, struct km_event *c)
@@ -2394,30 +2242,30 @@ static int xfrm_notify_policy(struct xfrm_policy *xp, int dir, struct km_event *
        struct xfrm_userpolicy_id *id;
        struct nlmsghdr *nlh;
        struct sk_buff *skb;
-       sk_buff_data_t b;
-       int len = RTA_SPACE(sizeof(struct xfrm_user_tmpl) * xp->xfrm_nr);
+       int len = nla_total_size(sizeof(struct xfrm_user_tmpl) * xp->xfrm_nr);
        int headlen;
 
        headlen = sizeof(*p);
        if (c->event == XFRM_MSG_DELPOLICY) {
-               len += RTA_SPACE(headlen);
+               len += nla_total_size(headlen);
                headlen = sizeof(*id);
        }
-#ifdef CONFIG_XFRM_SUB_POLICY
-       len += RTA_SPACE(sizeof(struct xfrm_userpolicy_type));
-#endif
-       len += NLMSG_SPACE(headlen);
+       len += userpolicy_type_attrsize();
+       len += NLMSG_ALIGN(headlen);
 
-       skb = alloc_skb(len, GFP_ATOMIC);
+       skb = nlmsg_new(len, GFP_ATOMIC);
        if (skb == NULL)
                return -ENOMEM;
-       b = skb->tail;
 
-       nlh = NLMSG_PUT(skb, c->pid, c->seq, c->event, headlen);
+       nlh = nlmsg_put(skb, c->pid, c->seq, c->event, headlen, 0);
+       if (nlh == NULL)
+               goto nlmsg_failure;
 
-       p = NLMSG_DATA(nlh);
+       p = nlmsg_data(nlh);
        if (c->event == XFRM_MSG_DELPOLICY) {
-               id = NLMSG_DATA(nlh);
+               struct nlattr *attr;
+
+               id = nlmsg_data(nlh);
                memset(id, 0, sizeof(*id));
                id->dir = dir;
                if (c->data.byid)
@@ -2425,10 +2273,12 @@ static int xfrm_notify_policy(struct xfrm_policy *xp, int dir, struct km_event *
                else
                        memcpy(&id->sel, &xp->selector, sizeof(id->sel));
 
-               p = RTA_DATA(__RTA_PUT(skb, XFRMA_POLICY, sizeof(*p)));
-       }
+               attr = nla_reserve(skb, XFRMA_POLICY, sizeof(*p));
+               if (attr == NULL)
+                       goto nlmsg_failure;
 
-       nlh->nlmsg_flags = 0;
+               p = nla_data(attr);
+       }
 
        copy_to_user_policy(xp, p, dir);
        if (copy_to_user_tmpl(xp, skb) < 0)
@@ -2436,13 +2286,11 @@ static int xfrm_notify_policy(struct xfrm_policy *xp, int dir, struct km_event *
        if (copy_to_user_policy_type(xp->type, skb) < 0)
                goto nlmsg_failure;
 
-       nlh->nlmsg_len = skb->tail - b;
+       nlmsg_end(skb, nlh);
 
-       NETLINK_CB(skb).dst_group = XFRMNLGRP_POLICY;
-       return netlink_broadcast(xfrm_nl, skb, 0, XFRMNLGRP_POLICY, GFP_ATOMIC);
+       return nlmsg_multicast(xfrm_nl, skb, 0, XFRMNLGRP_POLICY, GFP_ATOMIC);
 
 nlmsg_failure:
-rtattr_failure:
        kfree_skb(skb);
        return -1;
 }
@@ -2451,28 +2299,20 @@ static int xfrm_notify_policy_flush(struct km_event *c)
 {
        struct nlmsghdr *nlh;
        struct sk_buff *skb;
-       sk_buff_data_t b;
-       int len = 0;
-#ifdef CONFIG_XFRM_SUB_POLICY
-       len += RTA_SPACE(sizeof(struct xfrm_userpolicy_type));
-#endif
-       len += NLMSG_LENGTH(0);
 
-       skb = alloc_skb(len, GFP_ATOMIC);
+       skb = nlmsg_new(userpolicy_type_attrsize(), GFP_ATOMIC);
        if (skb == NULL)
                return -ENOMEM;
-       b = skb->tail;
-
 
-       nlh = NLMSG_PUT(skb, c->pid, c->seq, XFRM_MSG_FLUSHPOLICY, 0);
-       nlh->nlmsg_flags = 0;
+       nlh = nlmsg_put(skb, c->pid, c->seq, XFRM_MSG_FLUSHPOLICY, 0, 0);
+       if (nlh == NULL)
+               goto nlmsg_failure;
        if (copy_to_user_policy_type(c->data.type, skb) < 0)
                goto nlmsg_failure;
 
-       nlh->nlmsg_len = skb->tail - b;
+       nlmsg_end(skb, nlh);
 
-       NETLINK_CB(skb).dst_group = XFRMNLGRP_POLICY;
-       return netlink_broadcast(xfrm_nl, skb, 0, XFRMNLGRP_POLICY, GFP_ATOMIC);
+       return nlmsg_multicast(xfrm_nl, skb, 0, XFRMNLGRP_POLICY, GFP_ATOMIC);
 
 nlmsg_failure:
        kfree_skb(skb);
@@ -2499,48 +2339,48 @@ static int xfrm_send_policy_notify(struct xfrm_policy *xp, int dir, struct km_ev
 
 }
 
+static inline size_t xfrm_report_msgsize(void)
+{
+       return NLMSG_ALIGN(sizeof(struct xfrm_user_report));
+}
+
 static int build_report(struct sk_buff *skb, u8 proto,
                        struct xfrm_selector *sel, xfrm_address_t *addr)
 {
        struct xfrm_user_report *ur;
        struct nlmsghdr *nlh;
-       unsigned char *b = skb_tail_pointer(skb);
 
-       nlh = NLMSG_PUT(skb, 0, 0, XFRM_MSG_REPORT, sizeof(*ur));
-       ur = NLMSG_DATA(nlh);
-       nlh->nlmsg_flags = 0;
+       nlh = nlmsg_put(skb, 0, 0, XFRM_MSG_REPORT, sizeof(*ur), 0);
+       if (nlh == NULL)
+               return -EMSGSIZE;
 
+       ur = nlmsg_data(nlh);
        ur->proto = proto;
        memcpy(&ur->sel, sel, sizeof(ur->sel));
 
        if (addr)
-               RTA_PUT(skb, XFRMA_COADDR, sizeof(*addr), addr);
+               NLA_PUT(skb, XFRMA_COADDR, sizeof(*addr), addr);
 
-       nlh->nlmsg_len = skb_tail_pointer(skb) - b;
-       return skb->len;
+       return nlmsg_end(skb, nlh);
 
-nlmsg_failure:
-rtattr_failure:
-       nlmsg_trim(skb, b);
-       return -1;
+nla_put_failure:
+       nlmsg_cancel(skb, nlh);
+       return -EMSGSIZE;
 }
 
 static int xfrm_send_report(u8 proto, struct xfrm_selector *sel,
                            xfrm_address_t *addr)
 {
        struct sk_buff *skb;
-       size_t len;
 
-       len = NLMSG_ALIGN(NLMSG_LENGTH(sizeof(struct xfrm_user_report)));
-       skb = alloc_skb(len, GFP_ATOMIC);
+       skb = nlmsg_new(xfrm_report_msgsize(), GFP_ATOMIC);
        if (skb == NULL)
                return -ENOMEM;
 
        if (build_report(skb, proto, sel, addr) < 0)
                BUG();
 
-       NETLINK_CB(skb).dst_group = XFRMNLGRP_REPORT;
-       return netlink_broadcast(xfrm_nl, skb, 0, XFRMNLGRP_REPORT, GFP_ATOMIC);
+       return nlmsg_multicast(xfrm_nl, skb, 0, XFRMNLGRP_REPORT, GFP_ATOMIC);
 }
 
 static struct xfrm_mgr netlink_mgr = {