@@ -1224,7 +1224,7 @@ static int svc_tcp_recvfrom(struct svc_rqst *rqstp)
12241224 * that the pages backing @xdr are unchanging.
12251225 */
12261226static int svc_tcp_sendmsg (struct svc_sock * svsk , struct svc_rqst * rqstp ,
1227- rpc_fraghdr marker , int * sentp )
1227+ rpc_fraghdr marker )
12281228{
12291229 struct msghdr msg = {
12301230 .msg_flags = MSG_SPLICE_PAGES ,
@@ -1233,8 +1233,6 @@ static int svc_tcp_sendmsg(struct svc_sock *svsk, struct svc_rqst *rqstp,
12331233 void * buf ;
12341234 int ret ;
12351235
1236- * sentp = 0 ;
1237-
12381236 /* The stream record marker is copied into a temporary page
12391237 * fragment buffer so that it can be included in rq_bvec.
12401238 */
@@ -1252,10 +1250,7 @@ static int svc_tcp_sendmsg(struct svc_sock *svsk, struct svc_rqst *rqstp,
12521250 1 + count , sizeof (marker ) + rqstp -> rq_res .len );
12531251 ret = sock_sendmsg (svsk -> sk_sock , & msg );
12541252 page_frag_free (buf );
1255- if (ret < 0 )
1256- return ret ;
1257- * sentp += ret ;
1258- return 0 ;
1253+ return ret ;
12591254}
12601255
12611256/**
@@ -1274,17 +1269,17 @@ static int svc_tcp_sendto(struct svc_rqst *rqstp)
12741269 struct xdr_buf * xdr = & rqstp -> rq_res ;
12751270 rpc_fraghdr marker = cpu_to_be32 (RPC_LAST_STREAM_FRAGMENT |
12761271 (u32 )xdr -> len );
1277- int sent , err ;
1272+ int sent ;
12781273
12791274 svc_tcp_release_ctxt (xprt , rqstp -> rq_xprt_ctxt );
12801275 rqstp -> rq_xprt_ctxt = NULL ;
12811276
12821277 mutex_lock (& xprt -> xpt_mutex );
12831278 if (svc_xprt_is_dead (xprt ))
12841279 goto out_notconn ;
1285- err = svc_tcp_sendmsg (svsk , rqstp , marker , & sent );
1286- trace_svcsock_tcp_send (xprt , err < 0 ? ( long ) err : sent );
1287- if (err < 0 || sent != (xdr -> len + sizeof (marker )))
1280+ sent = svc_tcp_sendmsg (svsk , rqstp , marker );
1281+ trace_svcsock_tcp_send (xprt , sent );
1282+ if (sent < 0 || sent != (xdr -> len + sizeof (marker )))
12881283 goto out_close ;
12891284 mutex_unlock (& xprt -> xpt_mutex );
12901285 return sent ;
@@ -1295,8 +1290,8 @@ static int svc_tcp_sendto(struct svc_rqst *rqstp)
12951290out_close :
12961291 pr_notice ("rpc-srv/tcp: %s: %s %d when sending %zu bytes - shutting down socket\n" ,
12971292 xprt -> xpt_server -> sv_name ,
1298- (err < 0 ) ? "got error" : "sent" ,
1299- ( err < 0 ) ? err : sent , xdr -> len + sizeof (marker ));
1293+ (sent < 0 ) ? "got error" : "sent" ,
1294+ sent , xdr -> len + sizeof (marker ));
13001295 svc_xprt_deferred_close (xprt );
13011296 mutex_unlock (& xprt -> xpt_mutex );
13021297 return - EAGAIN ;
0 commit comments