Loading net/sunrpc/svcsock.c +4 −4 Original line number Original line Diff line number Diff line Loading @@ -952,8 +952,8 @@ static int svc_tcp_recv_record(struct svc_sock *svsk, struct svc_rqst *rqstp) dprintk("svc: TCP record, %d bytes\n", svc_sock_reclen(svsk)); dprintk("svc: TCP record, %d bytes\n", svc_sock_reclen(svsk)); if (svc_sock_reclen(svsk) + svsk->sk_datalen > if (svc_sock_reclen(svsk) + svsk->sk_datalen > serv->sv_max_mesg) { serv->sv_max_mesg) { net_notice_ratelimited("RPC: fragment too large: 0x%08lx\n", net_notice_ratelimited("RPC: fragment too large: %d\n", (unsigned long)svsk->sk_reclen); svc_sock_reclen(svsk)); goto err_delete; goto err_delete; } } } } Loading Loading @@ -1080,8 +1080,8 @@ static int svc_tcp_recvfrom(struct svc_rqst *rqstp) if (len == want) if (len == want) svc_tcp_fragment_received(svsk); svc_tcp_fragment_received(svsk); else else dprintk("svc: incomplete TCP record (%ld of %d)\n", dprintk("svc: incomplete TCP record (%d of %d)\n", svsk->sk_tcplen - sizeof(rpc_fraghdr), (int)(svsk->sk_tcplen - sizeof(rpc_fraghdr)), svc_sock_reclen(svsk)); svc_sock_reclen(svsk)); goto err_noclose; goto err_noclose; } } Loading Loading
net/sunrpc/svcsock.c +4 −4 Original line number Original line Diff line number Diff line Loading @@ -952,8 +952,8 @@ static int svc_tcp_recv_record(struct svc_sock *svsk, struct svc_rqst *rqstp) dprintk("svc: TCP record, %d bytes\n", svc_sock_reclen(svsk)); dprintk("svc: TCP record, %d bytes\n", svc_sock_reclen(svsk)); if (svc_sock_reclen(svsk) + svsk->sk_datalen > if (svc_sock_reclen(svsk) + svsk->sk_datalen > serv->sv_max_mesg) { serv->sv_max_mesg) { net_notice_ratelimited("RPC: fragment too large: 0x%08lx\n", net_notice_ratelimited("RPC: fragment too large: %d\n", (unsigned long)svsk->sk_reclen); svc_sock_reclen(svsk)); goto err_delete; goto err_delete; } } } } Loading Loading @@ -1080,8 +1080,8 @@ static int svc_tcp_recvfrom(struct svc_rqst *rqstp) if (len == want) if (len == want) svc_tcp_fragment_received(svsk); svc_tcp_fragment_received(svsk); else else dprintk("svc: incomplete TCP record (%ld of %d)\n", dprintk("svc: incomplete TCP record (%d of %d)\n", svsk->sk_tcplen - sizeof(rpc_fraghdr), (int)(svsk->sk_tcplen - sizeof(rpc_fraghdr)), svc_sock_reclen(svsk)); svc_sock_reclen(svsk)); goto err_noclose; goto err_noclose; } } Loading