Minki/linux
1
0
Fork 1
mirror of https://github.com/torvalds/linux.git synced 2024-11-30 16:11:38 +00:00
Code Issues Packages Projects Releases Wiki Activity

tipc: return POLLOUT for sockets in an unconnected state

Browse Source 
If an implied connect is attempted on a nonblocking STREAM/SEQPACKET
socket during link congestion, the connect message will be discarded
and sendmsg will return EAGAIN. This is normal behavior, and the
application is expected to poll the socket until POLLOUT is set,
after which the connection attempt can be retried.
However, the POLLOUT flag is never set for unconnected sockets and
poll() always returns a zero mask. The application is then left without
a trigger for when it can make another attempt at sending the message.

The solution is to check if we're polling on an unconnected socket
and set the POLLOUT flag if the TIPC port owned by this socket
is not congested. The TIPC ports waiting on a specific link will be
marked as 'not congested' when the link congestion have abated.

Signed-off-by: Erik Hugne <erik.hugne@ericsson.com>
Signed-off-by: Paul Gortmaker <paul.gortmaker@windriver.com>
This commit is contained in:
Erik Hugne 2012-10-16 16:47:06 +02:00 committed by Paul Gortmaker
parent f288bef464
commit c4fc298ab4
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
net/tipc/socket.c
View File

@ -412,7 +412,7 @@ static int get_name(struct socket *sock, struct sockaddr *uaddr,
* socket state flags set * socket state flags set
* ------------ --------- * ------------ ---------
* unconnected no read flags * unconnected no read flags
* no write flags * POLLOUT if port is not congested
* *
* connecting POLLIN/POLLRDNORM if ACK/NACK in rx queue * connecting POLLIN/POLLRDNORM if ACK/NACK in rx queue
* no write flags * no write flags
@ -442,6 +442,10 @@ static unsigned int poll(struct file *file, struct socket *sock,
sock_poll_wait(file, sk_sleep(sk), wait); sock_poll_wait(file, sk_sleep(sk), wait);
switch ((int)sock->state) { switch ((int)sock->state) {
case SS_UNCONNECTED:
if (!tipc_sk_port(sk)->congested)
mask |= POLLOUT;
break;
case SS_READY: case SS_READY:
case SS_CONNECTED: case SS_CONNECTED:
if (!tipc_sk_port(sk)->congested) if (!tipc_sk_port(sk)->congested)