aboutsummaryrefslogtreecommitdiffstats
path: root/drivers/block/drbd/drbd_receiver.c
diff options
context:
space:
mode:
authorAndreas Gruenbacher <agruen@linbit.com>2011-05-11 08:34:35 -0400
committerPhilipp Reisner <philipp.reisner@linbit.com>2012-11-08 10:55:50 -0500
commit69ef82dea4c34e4a0541fc3f415b0fef70fe12b0 (patch)
tree100c36a32e871fa8cead4f98969086482699bb83 /drivers/block/drbd/drbd_receiver.c
parent6394b9358e6187414b7a6de7ba2c681ee4a790ac (diff)
drbd: Refer to connect-int consistently throughout the code
Signed-off-by: Philipp Reisner <philipp.reisner@linbit.com> Signed-off-by: Lars Ellenberg <lars.ellenberg@linbit.com>
Diffstat (limited to 'drivers/block/drbd/drbd_receiver.c')
-rw-r--r--drivers/block/drbd/drbd_receiver.c12
1 files changed, 6 insertions, 6 deletions
diff --git a/drivers/block/drbd/drbd_receiver.c b/drivers/block/drbd/drbd_receiver.c
index 684f79542727..7deade196a33 100644
--- a/drivers/block/drbd/drbd_receiver.c
+++ b/drivers/block/drbd/drbd_receiver.c
@@ -617,7 +617,7 @@ static struct socket *drbd_try_connect(struct drbd_tconn *tconn)
617 struct sockaddr_in6 peer_in6; 617 struct sockaddr_in6 peer_in6;
618 struct net_conf *nc; 618 struct net_conf *nc;
619 int err, peer_addr_len, my_addr_len; 619 int err, peer_addr_len, my_addr_len;
620 int sndbuf_size, rcvbuf_size, try_connect_int; 620 int sndbuf_size, rcvbuf_size, connect_int;
621 int disconnect_on_error = 1; 621 int disconnect_on_error = 1;
622 622
623 rcu_read_lock(); 623 rcu_read_lock();
@@ -629,7 +629,7 @@ static struct socket *drbd_try_connect(struct drbd_tconn *tconn)
629 629
630 sndbuf_size = nc->sndbuf_size; 630 sndbuf_size = nc->sndbuf_size;
631 rcvbuf_size = nc->rcvbuf_size; 631 rcvbuf_size = nc->rcvbuf_size;
632 try_connect_int = nc->try_connect_int; 632 connect_int = nc->connect_int;
633 633
634 my_addr_len = min_t(int, nc->my_addr_len, sizeof(src_in6)); 634 my_addr_len = min_t(int, nc->my_addr_len, sizeof(src_in6));
635 memcpy(&src_in6, nc->my_addr, my_addr_len); 635 memcpy(&src_in6, nc->my_addr, my_addr_len);
@@ -653,7 +653,7 @@ static struct socket *drbd_try_connect(struct drbd_tconn *tconn)
653 } 653 }
654 654
655 sock->sk->sk_rcvtimeo = 655 sock->sk->sk_rcvtimeo =
656 sock->sk->sk_sndtimeo = try_connect_int * HZ; 656 sock->sk->sk_sndtimeo = connect_int * HZ;
657 drbd_setbufsize(sock, sndbuf_size, rcvbuf_size); 657 drbd_setbufsize(sock, sndbuf_size, rcvbuf_size);
658 658
659 /* explicitly bind to the configured IP as source IP 659 /* explicitly bind to the configured IP as source IP
@@ -702,7 +702,7 @@ out:
702static struct socket *drbd_wait_for_connect(struct drbd_tconn *tconn) 702static struct socket *drbd_wait_for_connect(struct drbd_tconn *tconn)
703{ 703{
704 int timeo, err, my_addr_len; 704 int timeo, err, my_addr_len;
705 int sndbuf_size, rcvbuf_size, try_connect_int; 705 int sndbuf_size, rcvbuf_size, connect_int;
706 struct socket *s_estab = NULL, *s_listen; 706 struct socket *s_estab = NULL, *s_listen;
707 struct sockaddr_in6 my_addr; 707 struct sockaddr_in6 my_addr;
708 struct net_conf *nc; 708 struct net_conf *nc;
@@ -717,7 +717,7 @@ static struct socket *drbd_wait_for_connect(struct drbd_tconn *tconn)
717 717
718 sndbuf_size = nc->sndbuf_size; 718 sndbuf_size = nc->sndbuf_size;
719 rcvbuf_size = nc->rcvbuf_size; 719 rcvbuf_size = nc->rcvbuf_size;
720 try_connect_int = nc->try_connect_int; 720 connect_int = nc->connect_int;
721 721
722 my_addr_len = min_t(int, nc->my_addr_len, sizeof(struct sockaddr_in6)); 722 my_addr_len = min_t(int, nc->my_addr_len, sizeof(struct sockaddr_in6));
723 memcpy(&my_addr, nc->my_addr, my_addr_len); 723 memcpy(&my_addr, nc->my_addr, my_addr_len);
@@ -731,7 +731,7 @@ static struct socket *drbd_wait_for_connect(struct drbd_tconn *tconn)
731 goto out; 731 goto out;
732 } 732 }
733 733
734 timeo = try_connect_int * HZ; 734 timeo = connect_int * HZ;
735 timeo += (random32() & 1) ? timeo / 7 : -timeo / 7; /* 28.5% random jitter */ 735 timeo += (random32() & 1) ? timeo / 7 : -timeo / 7; /* 28.5% random jitter */
736 736
737 s_listen->sk->sk_reuse = 1; /* SO_REUSEADDR */ 737 s_listen->sk->sk_reuse = 1; /* SO_REUSEADDR */