Commit 155522df authored by Philipp Reisner's avatar Philipp Reisner

drbd: Remove dead code

Signed-off-by: default avatarPhilipp Reisner <philipp.reisner@linbit.com>
Signed-off-by: default avatarLars Ellenberg <lars.ellenberg@linbit.com>
parent b66623e3
...@@ -504,37 +504,15 @@ static int drbd_recv(struct drbd_tconn *tconn, void *buf, size_t size) ...@@ -504,37 +504,15 @@ static int drbd_recv(struct drbd_tconn *tconn, void *buf, size_t size)
oldfs = get_fs(); oldfs = get_fs();
set_fs(KERNEL_DS); set_fs(KERNEL_DS);
rv = sock_recvmsg(tconn->data.socket, &msg, size, msg.msg_flags);
for (;;) {
rv = sock_recvmsg(tconn->data.socket, &msg, size, msg.msg_flags);
if (rv == size)
break;
/* Note:
* ECONNRESET other side closed the connection
* ERESTARTSYS (on sock) we got a signal
*/
if (rv < 0) {
if (rv == -ECONNRESET)
conn_info(tconn, "sock was reset by peer\n");
else if (rv != -ERESTARTSYS)
conn_err(tconn, "sock_recvmsg returned %d\n", rv);
break;
} else if (rv == 0) {
break;
} else {
/* signal came in, or peer/link went down,
* after we read a partial message
*/
/* D_ASSERT(signal_pending(current)); */
break;
}
};
set_fs(oldfs); set_fs(oldfs);
if (rv == 0) { if (rv < 0) {
if (rv == -ECONNRESET)
conn_info(tconn, "sock was reset by peer\n");
else if (rv != -ERESTARTSYS)
conn_err(tconn, "sock_recvmsg returned %d\n", rv);
} else if (rv == 0) {
if (test_bit(DISCONNECT_SENT, &tconn->flags)) { if (test_bit(DISCONNECT_SENT, &tconn->flags)) {
long t; long t;
rcu_read_lock(); rcu_read_lock();
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment