From patchwork Thu Mar 6 22:02:05 2025 Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit X-Patchwork-Submitter: Cong Wang X-Patchwork-Id: 14005389 X-Patchwork-Delegate: bpf@iogearbox.net Received: from mail-pl1-f173.google.com (mail-pl1-f173.google.com [209.85.214.173]) (using TLSv1.2 with cipher ECDHE-RSA-AES128-GCM-SHA256 (128/128 bits)) (No client certificate requested) by smtp.subspace.kernel.org (Postfix) with ESMTPS id 0819327C873; Thu, 6 Mar 2025 22:02:46 +0000 (UTC) Authentication-Results: smtp.subspace.kernel.org; arc=none smtp.client-ip=209.85.214.173 ARC-Seal: i=1; a=rsa-sha256; d=subspace.kernel.org; s=arc-20240116; t=1741298568; cv=none; b=PIXI5hvoysiA5Sh9HTYv2h8Px80I7nMYUGQfE+Oy/jEUbVL4a3HMGjQt+NjAFjjWseOe7MTvFmgEdC5S7NsJm4ISEHh6rJcbrpRBf9gJDOit4DB8cwZ0bEz+/v/9Np17GX3T+Tgu/aq47ezQPBsBhXVgtFK+ANqRR/vrh+mikas= ARC-Message-Signature: i=1; a=rsa-sha256; d=subspace.kernel.org; s=arc-20240116; t=1741298568; c=relaxed/simple; bh=x5NxNijXKivXEJOS7av3uTcW3M2ZUHwI4eMi0CriAx4=; h=From:To:Cc:Subject:Date:Message-Id:In-Reply-To:References: MIME-Version; b=de9Ggyx8RruaQw6uNAuCfOpzwXyyrm6Cr/l+JeuWlEVNtiowuzezkAQIZcDlFkHP7uguSKVFcl9ma0jQoRjRSumFf9MmAHzL32GSNFLEI5t32A20cNb44GwLcz59Zcd2qbiZKDR5VIorzvgssq0LXw3iJBKMXSJ/7I03p5MEsVg= ARC-Authentication-Results: i=1; smtp.subspace.kernel.org; dmarc=pass (p=none dis=none) header.from=gmail.com; spf=pass smtp.mailfrom=gmail.com; dkim=pass (2048-bit key) header.d=gmail.com header.i=@gmail.com header.b=UUGU2S7z; arc=none smtp.client-ip=209.85.214.173 Authentication-Results: smtp.subspace.kernel.org; dmarc=pass (p=none dis=none) header.from=gmail.com Authentication-Results: smtp.subspace.kernel.org; spf=pass smtp.mailfrom=gmail.com Authentication-Results: smtp.subspace.kernel.org; dkim=pass (2048-bit key) header.d=gmail.com header.i=@gmail.com header.b="UUGU2S7z" Received: by mail-pl1-f173.google.com with SMTP id d9443c01a7336-2240b4de12bso29998925ad.2; Thu, 06 Mar 2025 14:02:46 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20230601; t=1741298566; x=1741903366; darn=vger.kernel.org; h=content-transfer-encoding:mime-version:references:in-reply-to :message-id:date:subject:cc:to:from:from:to:cc:subject:date :message-id:reply-to; bh=aEWaeuMj8wkgxtzeJ5VWC4rlkU29HiqQYCgHRNUEAn4=; b=UUGU2S7z2eHFVA7E2y6uc/YzEkj70xBjCMkwxQ1XlOf/52uXvhMykgpPlmSAxM6Rvw a26ndIUhqfZZwJIml6PSz15mXFgoXVwm0IKoE/yKGkNkzF131i0gRrZBWi519EbyubsM P4GItuMat4GvdaxXdXdCAuIyrbAaRsQkhHiZoBRbxjH1OTpGasPQDqCmFNUhb70+UGUT av+7HyZt5WSHvG4bxcxoV9bHkJc+LkvhoLIMa/IPlN3RGRkyFsxwok+PtaaALhJT7+Ci 4lxkRD3yt2juwUZybTTk3i9O4o1Cpv+e7lCxzDQNbDeqTnaR3askNKoVy08lLWdaT2nS 5HFA== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20230601; t=1741298566; x=1741903366; h=content-transfer-encoding:mime-version:references:in-reply-to :message-id:date:subject:cc:to:from:x-gm-message-state:from:to:cc :subject:date:message-id:reply-to; bh=aEWaeuMj8wkgxtzeJ5VWC4rlkU29HiqQYCgHRNUEAn4=; b=RfloCj9+UhCzQW4awsLp63qOw5W1MmG9alW5VjIIh8PUC8zDhqP4H47bM7pAz5vfGR 8F8Ys83XW0vmNyM90a4yig93sfyYfMgd+WJUWqC5ybK133yfEon9nCkyt4n/6BLON4Sm JsP0Nge+gG28ZYr1YVsLXMJC+p3uRNC0CFeaItTJz0g8t4Jn59eaTaFV+QoN4+uxm1er EBGKas3W/SrwSXNUvJq7zWJgC3OWzXPeDc0mWv1Xt+XvtGAIVO6qAXd2py1zjnKJ8tEB l0Mo7DCP8DEtSbJzQF7jtwAJ9Qp9qEYKjH7pHN8to0YfARTkj6fzx/JgVIfgDAaxToRF 4ZRA== X-Gm-Message-State: AOJu0Yx/jCPhtgxLCNWlQiEAHb+bymPZHa1Svs5vXaic7E83DwQTU0w1 TWrNW/pldkRubT31qwpOmZyCQhAnJ6eSR4l9w/+YRAWitG5W9L/OaeLVtA== X-Gm-Gg: ASbGncvBLIBdD2ZlqBKeNJcKs0bhXfYbx2I45MEj6EAJL2oo0BRREfaHOimtFXZWNk+ BOZnlzKWvVy1RyRZH4ztJRTEYpfCyDZduomBUvkgb/o2eFGpXHVuWA9Jj6ru3I3YGXasgMQKHt9 /JONeJAc4e5iaALr3Wo7uCwQs33yI1Nw/vi+VjM+bIvaRd+QRvTV0Cmero0GppB7D4hUqSgWZrr zvP0XaAtwT1wUyX3HWa8NPY8TA8WhY9EjPtMMal/nYHa6/fhc/l5dMaR99RV91D6cNUTtWgA4H3 k33Sp23ITL3p4Yf2YyPn8a+8+x0R/H2ff78MLTgiml065hnUwSLUdo0= X-Google-Smtp-Source: AGHT+IHXtVcKfC97MtukUkNo68wfYQ48IHSbNmjBIr/8B0w7pjbsbiw69q7ugDG/QAxEteF/+4FRqw== X-Received: by 2002:a17:902:ccca:b0:223:fabd:4f76 with SMTP id d9443c01a7336-224289946c6mr12511215ad.30.1741298565683; Thu, 06 Mar 2025 14:02:45 -0800 (PST) Received: from pop-os.scu.edu ([129.210.115.104]) by smtp.gmail.com with ESMTPSA id d9443c01a7336-224109ddfa6sm17478775ad.33.2025.03.06.14.02.44 (version=TLS1_3 cipher=TLS_AES_256_GCM_SHA384 bits=256/256); Thu, 06 Mar 2025 14:02:45 -0800 (PST) From: Cong Wang To: netdev@vger.kernel.org Cc: bpf@vger.kernel.org, jakub@cloudflare.com, john.fastabend@gmail.com, zhoufeng.zf@bytedance.com, Zijian Zhang , Amery Hung , Cong Wang Subject: [Patch bpf-next v2 4/4] tcp_bpf: improve ingress redirection performance with message corking Date: Thu, 6 Mar 2025 14:02:05 -0800 Message-Id: <20250306220205.53753-5-xiyou.wangcong@gmail.com> X-Mailer: git-send-email 2.34.1 In-Reply-To: <20250306220205.53753-1-xiyou.wangcong@gmail.com> References: <20250306220205.53753-1-xiyou.wangcong@gmail.com> Precedence: bulk X-Mailing-List: bpf@vger.kernel.org List-Id: List-Subscribe: List-Unsubscribe: MIME-Version: 1.0 X-Patchwork-Delegate: bpf@iogearbox.net From: Zijian Zhang The TCP_BPF ingress redirection path currently lacks the message corking mechanism found in standard TCP. This causes the sender to wake up the receiver for every message, even when messages are small, resulting in reduced throughput compared to regular TCP in certain scenarios. This change introduces a kernel worker-based intermediate layer to provide automatic message corking for TCP_BPF. While this adds a slight latency overhead, it significantly improves overall throughput by reducing unnecessary wake-ups and reducing the sock lock contention. Reviewed-by: Amery Hung Co-developed-by: Cong Wang Signed-off-by: Cong Wang Signed-off-by: Zijian Zhang --- include/linux/skmsg.h | 19 ++++ net/core/skmsg.c | 139 ++++++++++++++++++++++++++++- net/ipv4/tcp_bpf.c | 197 ++++++++++++++++++++++++++++++++++++++++-- 3 files changed, 347 insertions(+), 8 deletions(-) diff --git a/include/linux/skmsg.h b/include/linux/skmsg.h index 7620f170c4b1..2531428168ad 100644 --- a/include/linux/skmsg.h +++ b/include/linux/skmsg.h @@ -15,6 +15,8 @@ #define MAX_MSG_FRAGS MAX_SKB_FRAGS #define NR_MSG_FRAG_IDS (MAX_MSG_FRAGS + 1) +/* GSO size for TCP BPF backlog processing */ +#define TCP_BPF_GSO_SIZE 65536 enum __sk_action { __SK_DROP = 0, @@ -85,8 +87,10 @@ struct sk_psock { struct sock *sk_redir; u32 apply_bytes; u32 cork_bytes; + u32 backlog_since_notify; u8 eval; u8 redir_ingress : 1; /* undefined if sk_redir is null */ + u8 backlog_work_delayed : 1; struct sk_msg *cork; struct sk_psock_progs progs; #if IS_ENABLED(CONFIG_BPF_STREAM_PARSER) @@ -97,6 +101,9 @@ struct sk_psock { struct sk_buff_head ingress_skb; struct list_head ingress_msg; spinlock_t ingress_lock; + struct list_head backlog_msg; + /* spin_lock for backlog_msg and backlog_since_notify */ + spinlock_t backlog_msg_lock; unsigned long state; struct list_head link; spinlock_t link_lock; @@ -117,11 +124,13 @@ struct sk_psock { struct mutex work_mutex; struct sk_psock_work_state work_state; struct delayed_work work; + struct delayed_work backlog_work; struct sock *sk_pair; struct rcu_work rwork; }; struct sk_msg *sk_msg_alloc(gfp_t gfp); +bool sk_msg_try_coalesce_ok(struct sk_msg *msg, int elem_first_coalesce); int sk_msg_expand(struct sock *sk, struct sk_msg *msg, int len, int elem_first_coalesce); int sk_msg_clone(struct sock *sk, struct sk_msg *dst, struct sk_msg *src, @@ -396,9 +405,19 @@ static inline void sk_psock_report_error(struct sk_psock *psock, int err) sk_error_report(sk); } +void sk_psock_backlog_msg(struct sk_psock *psock); struct sk_psock *sk_psock_init(struct sock *sk, int node); void sk_psock_stop(struct sk_psock *psock); +static inline void sk_psock_run_backlog_work(struct sk_psock *psock, + bool delayed) +{ + if (!sk_psock_test_state(psock, SK_PSOCK_TX_ENABLED)) + return; + psock->backlog_work_delayed = delayed; + schedule_delayed_work(&psock->backlog_work, delayed ? 1 : 0); +} + #if IS_ENABLED(CONFIG_BPF_STREAM_PARSER) int sk_psock_init_strp(struct sock *sk, struct sk_psock *psock); void sk_psock_start_strp(struct sock *sk, struct sk_psock *psock); diff --git a/net/core/skmsg.c b/net/core/skmsg.c index 25c53c8c9857..32507163fd2d 100644 --- a/net/core/skmsg.c +++ b/net/core/skmsg.c @@ -12,7 +12,7 @@ struct kmem_cache *sk_msg_cachep; -static bool sk_msg_try_coalesce_ok(struct sk_msg *msg, int elem_first_coalesce) +bool sk_msg_try_coalesce_ok(struct sk_msg *msg, int elem_first_coalesce) { if (msg->sg.end > msg->sg.start && elem_first_coalesce < msg->sg.end) @@ -707,6 +707,118 @@ static void sk_psock_backlog(struct work_struct *work) mutex_unlock(&psock->work_mutex); } +static bool backlog_notify(struct sk_psock *psock, bool m_sched_failed, + bool ingress_empty) +{ + /* Notify if: + * 1. We have corked enough bytes + * 2. We have already delayed notification + * 3. Memory allocation failed + * 4. Ingress queue was empty and we're about to add data + */ + return psock->backlog_since_notify >= TCP_BPF_GSO_SIZE || + psock->backlog_work_delayed || + m_sched_failed || + ingress_empty; +} + +static bool backlog_xfer_to_local(struct sk_psock *psock, struct sock *sk_from, + struct list_head *local_head, u32 *tot_size) +{ + struct sock *sk = psock->sk; + struct sk_msg *msg, *tmp; + u32 size = 0; + + list_for_each_entry_safe(msg, tmp, &psock->backlog_msg, list) { + if (msg->sk != sk_from) + break; + + if (!__sk_rmem_schedule(sk, msg->sg.size, false)) + return true; + + list_move_tail(&msg->list, local_head); + sk_wmem_queued_add(msg->sk, -msg->sg.size); + sock_put(msg->sk); + msg->sk = NULL; + psock->backlog_since_notify += msg->sg.size; + size += msg->sg.size; + } + + *tot_size = size; + return false; +} + +/* This function handles the transfer of backlogged messages from the sender + * backlog queue to the ingress queue of the peer socket. Notification of data + * availability will be sent under some conditions. + */ +void sk_psock_backlog_msg(struct sk_psock *psock) +{ + bool rmem_schedule_failed = false; + struct sock *sk_from = NULL; + struct sock *sk = psock->sk; + LIST_HEAD(local_head); + struct sk_msg *msg; + bool should_notify; + u32 tot_size = 0; + + if (!sk_psock_test_state(psock, SK_PSOCK_TX_ENABLED)) + return; + + lock_sock(sk); + spin_lock(&psock->backlog_msg_lock); + + msg = list_first_entry_or_null(&psock->backlog_msg, + struct sk_msg, list); + if (!msg) { + should_notify = !list_empty(&psock->ingress_msg); + spin_unlock(&psock->backlog_msg_lock); + goto notify; + } + + sk_from = msg->sk; + sock_hold(sk_from); + + rmem_schedule_failed = backlog_xfer_to_local(psock, sk_from, + &local_head, &tot_size); + should_notify = backlog_notify(psock, rmem_schedule_failed, + list_empty(&psock->ingress_msg)); + spin_unlock(&psock->backlog_msg_lock); + + spin_lock_bh(&psock->ingress_lock); + list_splice_tail_init(&local_head, &psock->ingress_msg); + spin_unlock_bh(&psock->ingress_lock); + + atomic_add(tot_size, &sk->sk_rmem_alloc); + sk_mem_charge(sk, tot_size); + +notify: + if (should_notify) { + psock->backlog_since_notify = 0; + sk_psock_data_ready(sk, psock); + if (!list_empty(&psock->backlog_msg)) + sk_psock_run_backlog_work(psock, rmem_schedule_failed); + } else { + sk_psock_run_backlog_work(psock, true); + } + release_sock(sk); + + if (sk_from) { + bool slow = lock_sock_fast(sk_from); + + sk_mem_uncharge(sk_from, tot_size); + unlock_sock_fast(sk_from, slow); + sock_put(sk_from); + } +} + +static void sk_psock_backlog_msg_work(struct work_struct *work) +{ + struct delayed_work *dwork = to_delayed_work(work); + + sk_psock_backlog_msg(container_of(dwork, struct sk_psock, backlog_work)); +} + struct sk_psock *sk_psock_init(struct sock *sk, int node) { struct sk_psock *psock; @@ -744,8 +856,11 @@ struct sk_psock *sk_psock_init(struct sock *sk, int node) INIT_DELAYED_WORK(&psock->work, sk_psock_backlog); mutex_init(&psock->work_mutex); + INIT_DELAYED_WORK(&psock->backlog_work, sk_psock_backlog_msg_work); INIT_LIST_HEAD(&psock->ingress_msg); spin_lock_init(&psock->ingress_lock); + INIT_LIST_HEAD(&psock->backlog_msg); + spin_lock_init(&psock->backlog_msg_lock); skb_queue_head_init(&psock->ingress_skb); sk_psock_set_state(psock, SK_PSOCK_TX_ENABLED); @@ -799,6 +914,26 @@ static void __sk_psock_zap_ingress(struct sk_psock *psock) __sk_psock_purge_ingress_msg(psock); } +static void __sk_psock_purge_backlog_msg(struct sk_psock *psock) +{ + struct sk_msg *msg, *tmp; + + spin_lock(&psock->backlog_msg_lock); + list_for_each_entry_safe(msg, tmp, &psock->backlog_msg, list) { + struct sock *sk_from = msg->sk; + bool slow; + + list_del(&msg->list); + slow = lock_sock_fast(sk_from); + sk_wmem_queued_add(sk_from, -msg->sg.size); + sock_put(sk_from); + sk_msg_free(sk_from, msg); + unlock_sock_fast(sk_from, slow); + kfree_sk_msg(msg); + } + spin_unlock(&psock->backlog_msg_lock); +} + static void sk_psock_link_destroy(struct sk_psock *psock) { struct sk_psock_link *link, *tmp; @@ -828,7 +963,9 @@ static void sk_psock_destroy(struct work_struct *work) sk_psock_done_strp(psock); cancel_delayed_work_sync(&psock->work); + cancel_delayed_work_sync(&psock->backlog_work); __sk_psock_zap_ingress(psock); + __sk_psock_purge_backlog_msg(psock); mutex_destroy(&psock->work_mutex); psock_progs_drop(&psock->progs); diff --git a/net/ipv4/tcp_bpf.c b/net/ipv4/tcp_bpf.c index f0ef41c951e2..82d437210f6f 100644 --- a/net/ipv4/tcp_bpf.c +++ b/net/ipv4/tcp_bpf.c @@ -381,6 +381,183 @@ static int tcp_bpf_recvmsg(struct sock *sk, struct msghdr *msg, size_t len, return ret; } +static int tcp_bpf_coalesce_msg(struct sk_msg *last, struct sk_msg *msg, + u32 *apply_bytes_ptr, u32 *tot_size) +{ + struct scatterlist *sge_from, *sge_to; + u32 apply_bytes = *apply_bytes_ptr; + bool apply = apply_bytes; + int i = msg->sg.start; + u32 size; + + while (i != msg->sg.end) { + int last_sge_idx = last->sg.end; + + if (sk_msg_full(last)) + break; + + sge_from = sk_msg_elem(msg, i); + sk_msg_iter_var_prev(last_sge_idx); + sge_to = &last->sg.data[last_sge_idx]; + + size = (apply && apply_bytes < sge_from->length) ? + apply_bytes : sge_from->length; + if (sk_msg_try_coalesce_ok(last, last_sge_idx) && + sg_page(sge_to) == sg_page(sge_from) && + sge_to->offset + sge_to->length == sge_from->offset) { + sge_to->length += size; + } else { + sge_to = &last->sg.data[last->sg.end]; + sg_unmark_end(sge_to); + sg_set_page(sge_to, sg_page(sge_from), size, + sge_from->offset); + get_page(sg_page(sge_to)); + sk_msg_iter_next(last, end); + } + + sge_from->length -= size; + sge_from->offset += size; + + if (sge_from->length == 0) { + put_page(sg_page(sge_to)); + sk_msg_iter_var_next(i); + } + + msg->sg.size -= size; + last->sg.size += size; + *tot_size += size; + + if (apply) { + apply_bytes -= size; + if (!apply_bytes) + break; + } + } + + if (apply) + *apply_bytes_ptr = apply_bytes; + + msg->sg.start = i; + return i; +} + +static void tcp_bpf_xfer_msg(struct sk_msg *dst, struct sk_msg *msg, + u32 *apply_bytes_ptr, u32 *tot_size) +{ + u32 apply_bytes = *apply_bytes_ptr; + bool apply = apply_bytes; + struct scatterlist *sge; + int i = msg->sg.start; + u32 size; + + do { + sge = sk_msg_elem(msg, i); + size = (apply && apply_bytes < sge->length) ? + apply_bytes : sge->length; + + sk_msg_xfer(dst, msg, i, size); + *tot_size += size; + if (sge->length) + get_page(sk_msg_page(dst, i)); + sk_msg_iter_var_next(i); + dst->sg.end = i; + if (apply) { + apply_bytes -= size; + if (!apply_bytes) { + if (sge->length) + sk_msg_iter_var_prev(i); + break; + } + } + } while (i != msg->sg.end); + + if (apply) + *apply_bytes_ptr = apply_bytes; + msg->sg.start = i; +} + +static int tcp_bpf_ingress_backlog(struct sock *sk, struct sock *sk_redir, + struct sk_msg *msg, u32 apply_bytes) +{ + bool ingress_msg_empty = false; + bool apply = apply_bytes; + struct sk_psock *psock; + struct sk_msg *tmp; + u32 tot_size = 0; + int ret = 0; + u8 nonagle; + + psock = sk_psock_get(sk_redir); + if (unlikely(!psock)) + return -EPIPE; + + spin_lock(&psock->backlog_msg_lock); + /* If possible, coalesce the curr sk_msg to the last sk_msg from the + * psock->backlog_msg. + */ + if (!list_empty(&psock->backlog_msg)) { + struct sk_msg *last; + + last = list_last_entry(&psock->backlog_msg, struct sk_msg, list); + if (last->sk == sk) { + int i = tcp_bpf_coalesce_msg(last, msg, &apply_bytes, + &tot_size); + + if (i == msg->sg.end || (apply && !apply_bytes)) + goto out_unlock; + } + } + + /* Otherwise, allocate a new sk_msg and transfer the data from the + * passed in msg to it. + */ + tmp = sk_msg_alloc(GFP_ATOMIC); + if (!tmp) { + ret = -ENOMEM; + spin_unlock(&psock->backlog_msg_lock); + goto error; + } + + tmp->sk = sk; + sock_hold(tmp->sk); + tmp->sg.start = msg->sg.start; + tcp_bpf_xfer_msg(tmp, msg, &apply_bytes, &tot_size); + + ingress_msg_empty = list_empty(&psock->ingress_msg); + list_add_tail(&tmp->list, &psock->backlog_msg); + +out_unlock: + spin_unlock(&psock->backlog_msg_lock); + sk_wmem_queued_add(sk, tot_size); + + /* At this point, the data has been handled well. If one of the + * following conditions is met, we can notify the peer socket in + * the context of this system call immediately. + * 1. If the write buffer has been used up; + * 2. Or, the message size is larger than TCP_BPF_GSO_SIZE; + * 3. Or, the ingress queue was empty; + * 4. Or, the tcp socket is set to no_delay. + * Otherwise, kick off the backlog work so that we can have some + * time to wait for any incoming messages before sending a + * notification to the peer socket. + */ + nonagle = tcp_sk(sk)->nonagle; + if (!sk_stream_memory_free(sk) || + tot_size >= TCP_BPF_GSO_SIZE || ingress_msg_empty || + (!(nonagle & TCP_NAGLE_CORK) && (nonagle & TCP_NAGLE_OFF))) { + release_sock(sk); + psock->backlog_work_delayed = false; + sk_psock_backlog_msg(psock); + lock_sock(sk); + } else { + sk_psock_run_backlog_work(psock, false); + } + +error: + sk_psock_put(sk_redir, psock); + return ret; +} + static int tcp_bpf_send_verdict(struct sock *sk, struct sk_psock *psock, struct sk_msg *msg, int *copied, int flags) { @@ -442,18 +619,24 @@ static int tcp_bpf_send_verdict(struct sock *sk, struct sk_psock *psock, cork = true; psock->cork = NULL; } - release_sock(sk); - origsize = msg->sg.size; - ret = tcp_bpf_sendmsg_redir(sk_redir, redir_ingress, - msg, tosend, flags); - sent = origsize - msg->sg.size; + if (redir_ingress) { + ret = tcp_bpf_ingress_backlog(sk, sk_redir, msg, tosend); + } else { + release_sock(sk); + + origsize = msg->sg.size; + ret = tcp_bpf_sendmsg_redir(sk_redir, redir_ingress, + msg, tosend, flags); + sent = origsize - msg->sg.size; + + lock_sock(sk); + sk_mem_uncharge(sk, sent); + } if (eval == __SK_REDIRECT) sock_put(sk_redir); - lock_sock(sk); - sk_mem_uncharge(sk, sent); if (unlikely(ret < 0)) { int free = sk_msg_free(sk, msg);