d/freebsd-nq
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Set MORETOCOME for AIO write requests on a socket.

Browse Source 
Add a MSG_MOREOTOCOME message flag. When this flag is set, sosend*
set PRUS_MOREOTOCOME when invoking the protocol send method. The aio
worker tasks for sending on a socket set this flag when there are
additional write jobs waiting on the socket buffer.

Reviewed by:	adrian
MFC after:	1 month
Sponsored by:	Chelsio Communications
Differential Revision:	https://reviews.freebsd.org/D8955
This commit is contained in:
John Baldwin 2017-01-06 23:41:45 +00:00
parent 69b4d461be
commit 14da48cbe4
3 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
sys/kern/sys_socket.c
View File

@ -604,6 +604,8 @@ retry:
if (td->td_ru.ru_msgrcv != ru_before) if (td->td_ru.ru_msgrcv != ru_before)
job->msgrcv = 1; job->msgrcv = 1;
} else { } else {
if (!TAILQ_EMPTY(&sb->sb_aiojobq))
flags |= MSG_MORETOCOME;
uio.uio_rw = UIO_WRITE; uio.uio_rw = UIO_WRITE;
ru_before = td->td_ru.ru_msgsnd; ru_before = td->td_ru.ru_msgsnd;
#ifdef MAC #ifdef MAC

2
sys/kern/uipc_socket.c
View File

@ -1182,6 +1182,7 @@ sosend_dgram(struct socket *so, struct sockaddr *addr, struct uio *uio,
(resid <= 0)) ? (resid <= 0)) ?
PRUS_EOF : PRUS_EOF :
/* If there is more to send set PRUS_MORETOCOME */ /* If there is more to send set PRUS_MORETOCOME */
(flags & MSG_MORETOCOME) ||
(resid > 0 && space > 0) ? PRUS_MORETOCOME : 0, (resid > 0 && space > 0) ? PRUS_MORETOCOME : 0,
top, addr, control, td); top, addr, control, td);
if (dontroute) { if (dontroute) {
@ -1368,6 +1369,7 @@ restart:
(resid <= 0)) ? (resid <= 0)) ?
PRUS_EOF : PRUS_EOF :
/* If there is more to send set PRUS_MORETOCOME. */ /* If there is more to send set PRUS_MORETOCOME. */
(flags & MSG_MORETOCOME) ||
(resid > 0 && space > 0) ? PRUS_MORETOCOME : 0, (resid > 0 && space > 0) ? PRUS_MORETOCOME : 0,
top, addr, control, td); top, addr, control, td);
if (dontroute) { if (dontroute) {

1
sys/sys/socket.h
View File

@ -435,6 +435,7 @@ struct msghdr {
#endif #endif
#ifdef _KERNEL #ifdef _KERNEL
#define MSG_SOCALLBCK 0x10000 /* for use by socket callbacks - soreceive (TCP) */ #define MSG_SOCALLBCK 0x10000 /* for use by socket callbacks - soreceive (TCP) */
#define MSG_MORETOCOME 0x20000 /* additional data pending */
#endif #endif
/* /*