recv.c (62910554656cdcd6b6f84a5154c4155aae4ca231) recv.c (aa395145165cb06a0d0885221bbe0ce4a564391d)
1/*
2 * Copyright (c) 2006 Oracle. All rights reserved.
3 *
4 * This software is available to you under a choice of one of two
5 * licenses. You may choose to be licensed under the terms of the GNU
6 * General Public License (GPL) Version 2, available from the file
7 * COPYING in the main directory of this source tree, or the
8 * OpenIB.org BSD license below:

--- 418 unchanged lines hidden (view full) ---

427 }
428
429 if (!rds_next_incoming(rs, &inc)) {
430 if (nonblock) {
431 ret = -EAGAIN;
432 break;
433 }
434
1/*
2 * Copyright (c) 2006 Oracle. All rights reserved.
3 *
4 * This software is available to you under a choice of one of two
5 * licenses. You may choose to be licensed under the terms of the GNU
6 * General Public License (GPL) Version 2, available from the file
7 * COPYING in the main directory of this source tree, or the
8 * OpenIB.org BSD license below:

--- 418 unchanged lines hidden (view full) ---

427 }
428
429 if (!rds_next_incoming(rs, &inc)) {
430 if (nonblock) {
431 ret = -EAGAIN;
432 break;
433 }
434
435 timeo = wait_event_interruptible_timeout(*sk->sk_sleep,
435 timeo = wait_event_interruptible_timeout(*sk_sleep(sk),
436 (!list_empty(&rs->rs_notify_queue) ||
437 rs->rs_cong_notify ||
438 rds_next_incoming(rs, &inc)), timeo);
439 rdsdebug("recvmsg woke inc %p timeo %ld\n", inc,
440 timeo);
441 if (timeo > 0 || timeo == MAX_SCHEDULE_TIMEOUT)
442 continue;
443

--- 105 unchanged lines hidden --- 		436 (!list_empty(&rs->rs_notify_queue) ||
437 rs->rs_cong_notify ||
438 rds_next_incoming(rs, &inc)), timeo);
439 rdsdebug("recvmsg woke inc %p timeo %ld\n", inc,
440 timeo);
441 if (timeo > 0 || timeo == MAX_SCHEDULE_TIMEOUT)
442 continue;
443

--- 105 unchanged lines hidden ---